fix fanout

veilid-core/src/rpc_processor/fanout/fanout_call.rs

@@ -260,7 +260,7 @@ impl<'a> FanoutCall<'a> {
         loop {
             // Put in a work request
             {
-                let context_locked = context.lock();
+                let mut context_locked = context.lock();
                 context_locked
                     .fanout_queue
                     .request_work(work_sender.clone());

veilid-core/src/rpc_processor/fanout/fanout_queue.rs

@@ -72,8 +72,11 @@ impl<'a> FanoutQueue<'a> {
     /// Ask for more work when some is ready
     /// When work is ready it will be sent to work_sender so it can be received
     /// by the worker
-    pub fn request_work(&self, work_sender: flume::Sender<NodeRef>) {
+    pub fn request_work(&mut self, work_sender: flume::Sender<NodeRef>) {
         let _ = self.sender.send(work_sender);
+
+        // Send whatever work is available immediately
+        self.send_more_work();
     }
 
     /// Add new nodes to a filtered and sorted list of fanout candidates

veilid-core/src/veilid_api/debug.rs

@@ -2120,7 +2120,7 @@ RPC Operations:
     appreply [#id] <data> - Reply to an 'App Call' RPC received by this node
 
 DHT Operations:
-    record list <local|remote|opened|offline> - display the dht records in the store
+    record list <local|remote|opened|offline|watched> - display the dht records in the store
            purge <local|remote> [bytes] - clear all dht records optionally down to some total size
            create <dhtschema> [<cryptokind> [<safety>]] - create a new dht record
            open <key>[+<safety>] [<writer>] - open an existing dht record

veilid-python/tests/test_dht.py

@@ -86,8 +86,8 @@ async def test_set_get_dht_value(api_connection: veilid.VeilidAPI):
         vd4 = await rc.get_dht_value(rec.key, ValueSubkey(1), False)
         assert vd4 is None
 
-        print("vd2: {}", vd2.__dict__)
-        print("vd3: {}", vd3.__dict__)
+        #print("vd2: {}", vd2.__dict__)
+        #print("vd3: {}", vd3.__dict__)
 
         assert vd2 == vd3