| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/crates/tor-proto/src/circuit/ |
| H A D | celltypes.rs | 8 use tor_cell::chancell::msg::{self as chanmsg, ChanMsg};
24 impl TryFrom<ChanMsg> for CreateResponse {
27 fn try_from(m: ChanMsg) -> Result<CreateResponse> { in try_from()
52 impl TryFrom<ChanMsg> for ClientCircChanMsg {
75 use tor_cell::chancell::msg::{self, ChanMsg}; in create_response()
76 fn good(m: ChanMsg) { in create_response() argument
79 fn bad(m: ChanMsg) { in create_response() argument
92 use tor_cell::chancell::msg::{self, ChanMsg}; in client_circ_chan_msg()
93 fn good(m: ChanMsg) { in client_circ_chan_msg() argument
96 fn bad(m: ChanMsg) { in client_circ_chan_msg() argument
[all …]
|
| H A D | reactor.rs | 17 use tor_cell::chancell::msg::{ChanMsg, Relay};
858 fn send_msg_direct(&mut self, cx: &mut Context<'_>, msg: ChanMsg) -> Result<()> { in send_msg_direct()
882 async fn send_msg(&mut self, msg: ChanMsg) -> Result<()> { in send_msg()
913 ChanMsg::RelayEarly(msg) in send_relay_cell()
915 ChanMsg::Relay(msg) in send_relay_cell()
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/crates/tor-cell/src/chancell/ |
| H A D | msg.rs | 13 fn into_message(self) -> ChanMsg; in into_message() argument
28 pub enum ChanMsg { enum
73 impl ChanMsg { impl
76 use ChanMsg::*; in cmd()
102 use ChanMsg::*; in write_body_onto()
130 use ChanMsg::*; in take()
178 ChanMsg::Padding(self) in into_message()
204 ChanMsg::VPadding(self) in into_message()
339 ChanMsg::Create2(self) in into_message()
477 ChanMsg::Relay(self) in into_message()
[all …]
|
| H A D | codec.rs | 104 let msg = msg::ChanMsg::take(&mut r, cmd)?; in decode_cell()
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/crates/tor-cell/src/ |
| H A D | chancell.rs | 161 msg: msg::ChanMsg,
166 pub fn new(circid: CircId, msg: msg::ChanMsg) -> Self { in new()
174 pub fn msg(&self) -> &msg::ChanMsg { in msg() argument
178 pub fn into_circid_and_msg(self) -> (CircId, msg::ChanMsg) { in into_circid_and_msg() argument
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/crates/tor-cell/tests/ |
| H A D | testvec_chanmsg.rs | 29 msg::ChanMsg::take(&mut r, cmd).unwrap_err() in decode_err()
32 fn test_decode(cmd: ChanCmd, s: &str, pad_to_len: bool) -> (Vec<u8>, msg::ChanMsg) { in test_decode() argument
35 let msg = msg::ChanMsg::take(&mut r, cmd).unwrap(); in test_decode()
41 fn test_body(cmd: ChanCmd, s: &str, m: &msg::ChanMsg, pad_to_len: bool) { in test_body() argument
66 fn vbody(cmd: ChanCmd, s: &str, m: &msg::ChanMsg) { in vbody() argument
71 fn fbody(cmd: ChanCmd, s: &str, m: &msg::ChanMsg) { in fbody() argument
277 let expect: msg::ChanMsg = in test_netinfo()
|
| H A D | test_chancell.rs | 23 fn cell(body: &str, msg: msg::ChanMsg, id: CircId, pad_body: bool) { in cell() argument
59 fn fcell(body: &str, msg: msg::ChanMsg, id: CircId) { in fcell() argument
63 fn vcell(body: &str, msg: msg::ChanMsg, id: CircId) { in vcell() argument
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/crates/tor-proto/src/channel/ |
| H A D | reactor.rs | 15 use tor_cell::chancell::{msg::ChanMsg, ChanCell, CircId};
233 use ChanMsg::*; in handle_cell()
280 async fn deliver_relay(&mut self, circid: CircId, msg: ChanMsg) -> Result<()> { in deliver_relay()
300 async fn deliver_created(&mut self, circid: CircId, msg: ChanMsg) -> Result<()> { in deliver_created()
314 async fn deliver_destroy(&mut self, circid: CircId, msg: ChanMsg) -> Result<()> { in deliver_destroy()
496 assert!(matches!(cell.msg(), ChanMsg::Destroy(_))); in new_circ_closed()
546 assert!(matches!(cell_sent.msg(), msg::ChanMsg::CreateFast(_))); in new_circ_create_failure()
652 let relaycell: ChanMsg = msg::Relay::new(b"do you suppose").into(); in deliver_relay()
734 let destroycell: ChanMsg = msg::Destroy::new(0.into()).into(); in deliver_destroy()
|
| H A D | handshake.rs | 150 use msg::ChanMsg::*; in connect()
|
| /dports/irc/znc/znc-1.8.2/test/ |
| H A D | ModulesTest.cpp | 403 CTextMessage ChanMsg; in TEST_F() local
405 Modules.OnChanTextMessage(ChanMsg); in TEST_F()
406 EXPECT_EQ(ChanMsg.GetNick().GetNick(), "legacy"); in TEST_F()
407 EXPECT_EQ(ChanMsg.GetText(), "CLegacyModule::OnChanMsg"); in TEST_F()
409 Modules.OnChanTextMessage(ChanMsg); in TEST_F()
410 EXPECT_EQ(ChanMsg.GetNick().GetNick(), "nick"); in TEST_F()
411 EXPECT_EQ(ChanMsg.GetText(), "CMessageModule::OnChanTextMessage"); in TEST_F()
|
| H A D | MessageTest.cpp | 328 TEST(MessageTest, ChanMsg) { in TEST() argument
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/crates/tor-proto/src/ |
| H A D | circuit.rs | 59 chancell::{self, msg::ChanMsg, CircId},
517 fn to_chanmsg(&self, bytes: Vec<u8>) -> ChanMsg; in to_chanmsg() argument
527 fn to_chanmsg(&self, bytes: Vec<u8>) -> ChanMsg { in to_chanmsg() argument
550 fn to_chanmsg(&self, bytes: Vec<u8>) -> ChanMsg { in to_chanmsg() argument
616 use chanmsg::{ChanMsg, Created2, CreatedFast};
728 ChanMsg::CreateFast(cf) => cf, in test_create()
735 ChanMsg::Create2(c2) => c2, in test_create()
899 ChanMsg::Relay(r) => RelayCell::decode(r.into_relay_body()).unwrap(), in send_simple()
1122 ChanMsg::Relay(r) => RelayCell::decode(r.into_relay_body()).unwrap(), in begindir()
1136 ChanMsg::Relay(r) => RelayCell::decode(r.into_relay_body()).unwrap(), in begindir()
[all …]
|
| H A D | channel.rs | 131 use msg::ChanMsg::*; in start_send()
299 use msg::ChanMsg::*; in check_cell()
|
| /dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/crates/tor-cell/ |
| H A D | README.md | 13 encodes a single [Channel Message](chancell::msg::ChanMsg).
|