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

Method data

crates/openshell-supervisor-process/src/ssh.rs:506–520  ·  view source on GitHub ↗
(
        &mut self,
        channel: ChannelId,
        data: &[u8],
        _session: &mut Session,
    )

Source from the content-addressed store, hash-verified

504 }
505
506 async fn data(
507 &mut self,
508 channel: ChannelId,
509 data: &[u8],
510 _session: &mut Session,
511 ) -> Result<(), Self::Error> {
512 let Some(state) = self.channels.get(&channel) else {
513 warn!("data on unknown channel {channel:?}");
514 return Ok(());
515 };
516 if let Some(sender) = state.input_sender.as_ref() {
517 let _ = sender.send(data.to_vec());
518 }
519 Ok(())
520 }
521
522 async fn channel_eof(
523 &mut self,

Callers 4

run_exec_with_russhFunction · 0.80
spawn_pty_shellFunction · 0.80
spawn_pipe_execFunction · 0.80

Calls 1

getMethod · 0.45

Tested by

no test coverage detected