Searched refs:local_stream (Results 1 – 3 of 3) sorted by relevance
59 fn run_forwarder(local_stream: StreamSocket, remote_stream: StreamSocket) -> Result<()> { in run_forwarder()66 poll_ctx.add(&local_stream, Token::LocalStreamReadable).map_err(Error::PollContextAdd)?; in run_forwarder()69 let mut forwarder = ForwarderSession::new(local_stream, remote_stream); in run_forwarder()80 .delete(forwarder.local_stream()) in run_forwarder()118 let local_stream = StreamSocket::connect(&args.local_sockaddr).map_err(Error::ConnectSocket)?; in main() localVariable122 run_forwarder(local_stream, remote_stream) in main()
233 let tag = session.local_stream().as_raw_fd() as u32; in accept_connection()236 .add(session.local_stream(), Token::LocalSocket(tag)) in accept_connection()251 poll_ctx.delete(session.local_stream()).map_err(Error::PollContextDelete)?; in forward_from_local()
98 pub fn local_stream(&self) -> &StreamSocket { in local_stream() method