MCPcopy Create free account
hub / github.com/NodeDB-Lab/nodedb / try_send_response

Method try_send_response

nodedb-bridge/src/async_bridge.rs:224–230  ·  view source on GitHub ↗

Try to send a response back to the Control Plane.

(&mut self, rsp: Rsp)

Source from the content-addressed store, hash-verified

222
223 /// Try to send a response back to the Control Plane.
224 pub fn try_send_response(&mut self, rsp: Rsp) -> Result<()> {
225 let result = self.producer.try_push(rsp);
226 if result.is_ok() {
227 let _ = self.rsp_wake.consumer_wake.notify();
228 }
229 result
230 }
231
232 /// Current backpressure state (read by Data Plane to decide I/O depth).
233 pub fn pressure(&self) -> PressureState {

Callers 7

async_recv_wakes_on_dataFunction · 0.80
bridge_channel_roundtripFunction · 0.80
pin_workflow_roundtripFunction · 0.80
tpc_event_loopFunction · 0.80

Calls 3

try_pushMethod · 0.80
is_okMethod · 0.80
notifyMethod · 0.45

Tested by 5

bridge_channel_roundtripFunction · 0.64
pin_workflow_roundtripFunction · 0.64
tpc_event_loopFunction · 0.64