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

Method try_recv_request

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

Try to receive a request from the Control Plane.

(&mut self)

Source from the content-addressed store, hash-verified

204
205 /// Try to receive a request from the Control Plane.
206 pub fn try_recv_request(&mut self) -> Result<Req> {
207 let result = self.consumer.try_pop();
208 if result.is_ok() {
209 let _ = self.req_wake.producer_wake.notify();
210 }
211 result
212 }
213
214 /// Drain up to `max` requests into the buffer.
215 pub fn drain_requests(&mut self, buf: &mut Vec<Req>, max: usize) -> usize {

Callers 4

bridge_channel_roundtripFunction · 0.80
pin_workflow_roundtripFunction · 0.80

Calls 3

try_popMethod · 0.80
is_okMethod · 0.80
notifyMethod · 0.45

Tested by 2

bridge_channel_roundtripFunction · 0.64
pin_workflow_roundtripFunction · 0.64