MCPcopy Create free account
hub / github.com/NVIDIA/OpenShell / fail_pending_relay

Method fail_pending_relay

crates/openshell-server/src/supervisor_session.rs:325–333  ·  view source on GitHub ↗
(&self, channel_id: &str, error: String)

Source from the content-addressed store, hash-verified

323 }
324
325 pub fn fail_pending_relay(&self, channel_id: &str, error: String) -> bool {
326 let pending = self.pending_relays.lock().unwrap().remove(channel_id);
327 if let Some(pending) = pending {
328 let _ = pending.sender.send(Err(Status::unavailable(error)));
329 true
330 } else {
331 false
332 }
333 }
334
335 /// Claim a pending relay channel. Called by the `/relay/{channel_id}` HTTP handler
336 /// when the supervisor's reverse CONNECT arrives.

Callers 1

Calls 1

removeMethod · 0.45

Tested by

no test coverage detected