Skip to content
This repository was archived by the owner on Jan 27, 2026. It is now read-only.

Commit 4f66957

Browse files
committed
store outbound request when already authenticated
1 parent 8663553 commit 4f66957

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

crates/shared/src/p2p/service.rs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -184,6 +184,9 @@ async fn handle_outgoing_message(message: OutgoingRequest, context: Context) ->
184184
log::debug!(
185185
"already authenticated with peer {peer_id}, skipping validation authentication"
186186
);
187+
let mut ongoing_outbound_requests = context.ongoing_outbound_requests.write().await;
188+
ongoing_outbound_requests.insert((peer_id, request.protocol()), response_tx);
189+
187190
// multiaddresses are already known, as we've connected to them previously
188191
context
189192
.outgoing_messages
@@ -309,7 +312,7 @@ async fn handle_incoming_response(
309312
bail!("received GetTaskLogsResponse from {from}, but get task logs protocol is not enabled");
310313
}
311314

312-
log::debug!("received GetTaskLogsResponse from {from}: {resp:?}");
315+
log::info!("received GetTaskLogsResponse from {from}: {resp:?}");
313316
let mut ongoing_outbound_requests = context.ongoing_outbound_requests.write().await;
314317
let Some(response_tx) =
315318
ongoing_outbound_requests.remove(&(from, Protocol::GetTaskLogs))

0 commit comments

Comments
 (0)