From c2ab220fb1be4e7e0d154a803b1414040ba9d216 Mon Sep 17 00:00:00 2001 From: Christien Rioux Date: Mon, 3 Jun 2024 15:20:42 -0400 Subject: [PATCH] improve watchvalue fanout --- .../src/rpc_processor/rpc_watch_value.rs | 2 +- veilid-core/src/storage_manager/set_value.rs | 21 ------------------- 2 files changed, 1 insertion(+), 22 deletions(-) diff --git a/veilid-core/src/rpc_processor/rpc_watch_value.rs b/veilid-core/src/rpc_processor/rpc_watch_value.rs index 2a28aca1..4fff8dfc 100644 --- a/veilid-core/src/rpc_processor/rpc_watch_value.rs +++ b/veilid-core/src/rpc_processor/rpc_watch_value.rs @@ -251,7 +251,7 @@ impl RPCProcessor { // Get the nodes that we know about that are closer to the the key than our own node let closer_to_key_peers = network_result_try!( - routing_table.find_preferred_peers_closer_to_key(key, vec![CAP_DHT]) + routing_table.find_preferred_peers_closer_to_key(key, vec![CAP_DHT, CAP_DHT_WATCH]) ); // See if we would have accepted this as a set, same set_value_count for watches diff --git a/veilid-core/src/storage_manager/set_value.rs b/veilid-core/src/storage_manager/set_value.rs index dc9609e9..5b60625c 100644 --- a/veilid-core/src/storage_manager/set_value.rs +++ b/veilid-core/src/storage_manager/set_value.rs @@ -367,27 +367,6 @@ impl StorageManager { Ok(None) } - - - - - - - - - - - - - - - - - - - - - /// Handle a received 'Set Value' query /// Returns a None if the value passed in was set /// Returns a Some(current value) if the value was older and the current value was kept