Skip to content

Commit b8324d9

Browse files
committed
fix(client): limit recursive poll throttle to recursive-only sets
1 parent a7c878f commit b8324d9

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

crates/slipstream-client/src/runtime.rs

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -861,7 +861,11 @@ pub async fn run_client(config: &ClientConfig<'_>) -> Result<i32, ClientError> {
861861
last_flow_block_log_at = now;
862862
}
863863
watchdog.set_phase(PHASE_POLL_QUERIES);
864-
let multi_resolver_mode = resolver_manager.as_slice().len() > 1;
864+
let recursive_multi_resolver_mode = resolver_manager.as_slice().len() > 1
865+
&& resolver_manager
866+
.as_slice()
867+
.iter()
868+
.all(|resolver| resolver.mode == ResolverMode::Recursive);
865869
for resolver in resolver_manager.as_mut_slice().iter_mut() {
866870
if !resolver.is_active() && resolver.mode == ResolverMode::Recursive {
867871
continue;
@@ -901,7 +905,7 @@ pub async fn run_client(config: &ClientConfig<'_>) -> Result<i32, ClientError> {
901905
cnx,
902906
&mut dispatch,
903907
resolver,
904-
multi_resolver_mode,
908+
recursive_multi_resolver_mode,
905909
has_ready_stream,
906910
flow_blocked,
907911
)

0 commit comments

Comments
 (0)