Searched refs:param (Results 1 – 15 of 15) sorted by relevance
| /webrtc/sctp/src/param/ |
| H A D | param_unrecognized.rs | 1 use crate::param::param_header::PARAM_HEADER_LENGTH; 2 use crate::param::param_type::ParamType; 3 use crate::param::ParamHeader; 4 use crate::param::{build_param, Param}; 13 param: Box<dyn Param + Send + Sync>, field 18 Self { param } in wrap() 25 Display::fmt(&self.param, f) in fmt() 47 let param = build_param(&raw_param)?; in unmarshal() localVariable 48 Ok(Self { param }) in unmarshal() 53 self.param.marshal_to(buf)?; in marshal_to() [all …]
|
| H A D | param_unknown.rs | 1 use crate::param::param_header::ParamHeader; 2 use crate::param::param_header::PARAM_HEADER_LENGTH; 3 use crate::param::param_type::ParamType; 4 use crate::param::Param;
|
| H A D | mod.rs | 19 use crate::param::{ 30 use crate::param::param_unknown::ParamUnknown;
|
| /webrtc/webrtc/src/sctp_transport/ |
| H A D | mod.rs | 177 let param = AcceptDataChannelParams { in start() localVariable 189 RTCSctpTransport::accept_data_channels(param).await; in start() 215 async fn accept_data_channels(param: AcceptDataChannelParams) { in accept_data_channels() 216 let dcs = param.data_channels.lock().await; in accept_data_channels() 227 _ = param.notify_rx.notified() => break, in accept_data_channels() 229 ¶m.sctp_association, in accept_data_channels() 293 Arc::clone(¶m.setting_engine), in accept_data_channels() 296 if let Some(handler) = &*param.on_data_channel_handler.load() { in accept_data_channels() 300 param.data_channels_accepted.fetch_add(1, Ordering::SeqCst); in accept_data_channels() 302 let mut dcs = param.data_channels.lock().await; in accept_data_channels() [all …]
|
| /webrtc/sctp/fuzz/ |
| H A D | Cargo.toml | 29 name = "param" 30 path = "fuzz_targets/param.rs"
|
| /webrtc/sctp/fuzz/fuzz_targets/ |
| H A D | param.rs | 4 use webrtc_sctp::param::build_param;
|
| /webrtc/sctp/src/ |
| H A D | lib.rs | 9 pub mod param; module
|
| H A D | fuzz_artifact_test.rs | 25 crate::param::build_param(&Bytes::from(artifact)).ok(); in param_crash_artifacts()
|
| /webrtc/sctp/src/chunk/ |
| H A D | chunk_init.rs | 2 use crate::param::param_supported_extensions::ParamSupportedExtensions; 3 use crate::param::{param_header::*, *}; 112 for (i, param) in self.params.iter().enumerate() { in fmt()
|
| H A D | chunk_heartbeat_ack.rs | 2 use crate::param::param_type::ParamType; 3 use crate::param::{param_header::*, *};
|
| H A D | chunk_heartbeat.rs | 2 use crate::param::{param_header::*, param_type::*, *};
|
| H A D | chunk_reconfig.rs | 2 use crate::param::{param_header::*, *};
|
| H A D | chunk_test.rs | 468 use crate::param::param_outgoing_reset_request::ParamOutgoingResetRequest; 469 use crate::param::param_state_cookie::*;
|
| /webrtc/sctp/src/association/ |
| H A D | mod.rs | 26 use crate::param::param_heartbeat_info::ParamHeartbeatInfo; 27 use crate::param::param_outgoing_reset_request::ParamOutgoingResetRequest; 28 use crate::param::param_reconfig_response::{ParamReconfigResponse, ReconfigResult}; 29 use crate::param::param_state_cookie::ParamStateCookie; 30 use crate::param::param_supported_extensions::ParamSupportedExtensions; 31 use crate::param::Param;
|
| H A D | association_internal.rs | 6 use crate::param::param_type::ParamType; 7 use crate::param::param_unrecognized::ParamUnrecognized; 645 for param in &i.params { in handle_init() 646 if let Some(v) = param.as_any().downcast_ref::<ParamSupportedExtensions>() { in handle_init() 671 .filter_map(|param| { in handle_init() 672 if let ParamType::Unknown { param_type } = param.header().typ { in handle_init() 676 Box::new(ParamUnrecognized::wrap(param.clone())); in handle_init() 762 for param in &i.params { in handle_init_ack() 763 if let Some(v) = param.as_any().downcast_ref::<ParamStateCookie>() { in handle_init_ack() 765 } else if let Some(v) = param.as_any().downcast_ref::<ParamSupportedExtensions>() { in handle_init_ack()
|