| /webrtc/dtls/src/ |
| H A D | config.rs | 157 pub(crate) fn validate_config(is_client: bool, config: &Config) -> Result<()> { in validate_config()
158 if is_client && config.psk.is_some() && config.psk_identity_hint.is_none() { in validate_config()
162 if !is_client && config.psk.is_none() && config.certificates.is_empty() { in validate_config()
166 if !config.certificates.is_empty() && config.psk.is_some() { in validate_config()
170 if config.psk_identity_hint.is_some() && config.psk.is_none() { in validate_config()
174 for cert in &config.certificates { in validate_config()
183 &config.cipher_suites, in validate_config()
184 config.psk.is_none(), in validate_config()
185 config.psk.is_some(), in validate_config()
|
| H A D | listener.rs | 1 use crate::config::*;
18 pub async fn listen<A: 'static + ToSocketAddrs>(laddr: A, config: Config) -> Result<impl Listener> { in listen()
19 validate_config(false, &config)?; in listen()
48 Ok(DTLSListener { parent, config }) in listen()
54 config: Config, field
59 pub fn new(parent: Arc<dyn Listener + Send + Sync>, config: Config) -> Result<Self> { in new()
60 validate_config(false, &config)?; in new()
62 Ok(DTLSListener { parent, config }) in new()
76 let dtls_conn = DTLSConn::new(conn, self.config.clone(), false, None) in accept()
|
| /webrtc/srtp/src/session/ |
| H A D | mod.rs | 7 config::*,
44 config: Config, in new()
48 &config.keys.local_master_key, in new()
49 &config.keys.local_master_salt, in new()
50 config.profile, in new()
51 config.local_rtp_options, in new()
52 config.local_rtcp_options, in new()
56 &config.keys.remote_master_key, in new()
58 config.profile, in new()
64 config.remote_rtp_options in new()
[all …]
|
| /webrtc/data/src/data_channel/ |
| H A D | mod.rs | 42 pub config: Config, field
55 config, in new()
65 config: Config, in dial()
71 Self::client(stream, config).await in dial()
77 config: Config, in accept()
99 Self::server(stream, config).await in accept()
104 if !config.negotiated { in client()
107 priority: config.priority, in client()
118 Ok(DataChannel::new(stream, config)) in client()
136 config.priority = dco.priority; in server()
[all …]
|
| /webrtc/turn/src/client/ |
| H A D | mod.rs | 155 async fn new(config: ClientConfig) -> Result<Self> { in new()
156 let net = if let Some(vnet) = config.vnet { in new()
169 let local_addr = config.conn.local_addr()?; in new()
181 let local_addr = config.conn.local_addr()?; in new()
190 conn: Arc::clone(&config.conn), in new()
194 password: config.password, in new()
195 realm: Realm::new(ATTR_REALM, config.realm), in new()
199 rto_in_ms: if config.rto_in_ms != 0 { in new()
200 config.rto_in_ms in new()
584 let ci = ClientInternal::new(config).await?; in new()
[all …]
|
| H A D | transaction.rs | 144 pub fn new(config: TransactionConfig) -> Self { in new()
145 let (result_ch_tx, result_ch_rx) = if !config.ignore_result { in new()
153 key: config.key, in new()
154 raw: config.raw, in new()
155 to: config.to, in new()
156 interval: Arc::new(AtomicU16::new(config.interval)), in new()
|
| H A D | relay_conn.rs | 84 pub(crate) async fn new(obs: Arc<Mutex<T>>, config: RelayConnConfig) -> Self { in new()
85 log::debug!("initial lifetime: {} seconds", config.lifetime.as_secs()); in new()
90 relayed_addr: config.relayed_addr, in new()
91 read_ch_rx: Arc::clone(&config.read_ch_rx), in new()
92 relay_conn: Arc::new(Mutex::new(RelayConnInternal::new(obs, config))), in new()
195 fn new(obs: Arc<Mutex<T>>, config: RelayConnConfig) -> Self { in new()
198 relayed_addr: config.relayed_addr, in new()
200 binding_mgr: config.binding_mgr, in new()
201 integrity: config.integrity, in new()
202 nonce: config.nonce, in new()
[all …]
|
| /webrtc/ice/src/agent/ |
| H A D | mod.rs | 118 pub async fn new(config: AgentConfig) -> Result<Self> { in new()
128 let mdns_mode = config.multicast_dns_mode; in new()
148 config.init_with_defaults(&mut ai); in new()
153 config.candidate_types.clone() in new()
163 if !config.urls.is_empty() in new()
179 let net = if let Some(net) = config.net { in new()
193 udp_network: config.udp_network, in new()
196 ip_filter: Arc::clone(&config.ip_filter), in new()
204 urls: config.urls.clone(), in new()
205 network_types: config.network_types.clone(), in new()
[all …]
|
| /webrtc/webrtc/src/ice_transport/ |
| H A D | ice_candidate.rs | 70 let config = CandidateHostConfig { in to_ice() localVariable
84 config.new_candidate_host()? in to_ice()
87 let config = CandidateServerReflexiveConfig { in to_ice() localVariable
101 config.new_candidate_server_reflexive()? in to_ice()
104 let config = CandidatePeerReflexiveConfig { in to_ice() localVariable
118 config.new_candidate_peer_reflexive()? in to_ice()
121 let config = CandidateRelayConfig { in to_ice() localVariable
136 config.new_candidate_relay()? in to_ice()
|
| /webrtc/turn/src/server/ |
| H A D | mod.rs | 4 pub mod config; module
13 use config::*;
40 pub async fn new(config: ServerConfig) -> Result<Self> { in new()
41 config.validate()?; in new()
45 auth_handler: config.auth_handler, in new()
46 realm: config.realm, in new()
47 channel_bind_timeout: config.channel_bind_timeout, in new()
56 for p in config.conn_configs.into_iter() { in new()
65 alloc_close_notify: config.alloc_close_notify.clone(), in new()
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 7 use crate::config::*;
146 mut config: Config, in new()
150 validate_config(is_client, &config)?; in new()
153 &config.cipher_suites, in new()
154 config.psk.is_none(), in new()
155 config.psk.is_some(), in new()
165 config.flight_interval in new()
181 config.mtu in new()
187 config.replay_protection_window in new()
210 client_auth: config.client_auth, in new()
[all …]
|
| /webrtc/dtls/examples/dial/selfsign/ |
| H A D | dial_selfsign.rs | 7 use webrtc_dtls::{config::*, conn::DTLSConn, crypto::Certificate};
64 let config = Config { in main() localVariable
71 Arc::new(DTLSConn::new(conn, config, true, None).await?); in main()
|
| /webrtc/dtls/examples/dial/verify/ |
| H A D | dial_verify.rs | 8 use webrtc_dtls::{config::*, conn::DTLSConn};
74 let config = Config { in main() localVariable
82 Arc::new(DTLSConn::new(conn, config, true, None).await?); in main()
|
| /webrtc/dtls/examples/dial/psk/ |
| H A D | dial_psk.rs | 8 use webrtc_dtls::{config::*, conn::DTLSConn};
62 let config = Config { in main() localVariable
73 Arc::new(DTLSConn::new(conn, config, true, None).await?); in main()
|
| /webrtc/sctp/examples/ |
| H A D | throughput.rs | 64 let config = Config { in main() localVariable
70 let a = Association::server(config).await?; in main()
110 let config = Config { in main() localVariable
116 let a = Association::client(config).await.unwrap(); in main()
|
| /webrtc/util/src/vnet/ |
| H A D | router.rs | 215 pub fn new(config: RouterConfig) -> Result<Self> { in new()
216 let ipv4net: IpNet = config.cidr.parse()?; in new()
218 let queue_size = if config.queue_size > 0 { in new()
219 config.queue_size in new()
239 let name = if config.name.is_empty() { in new()
242 config.name.clone() in new()
247 for ip_str in &config.static_ips { in new()
260 if !config.static_ip.is_empty() { in new()
273 nat_type: config.nat_type, in new()
288 min_delay: config.min_delay, in new()
[all …]
|
| H A D | nat.rs | 103 pub(crate) fn new(config: NatConfig) -> Result<Self> { in new()
104 let mut nat_type = config.nat_type; in new()
113 if config.mapped_ips.is_empty() { in new()
116 if config.mapped_ips.len() != config.local_ips.len() { in new()
128 name: config.name, in new()
130 mapped_ips: config.mapped_ips, in new()
131 local_ips: config.local_ips, in new()
|
| /webrtc/ice/src/candidate/ |
| H A D | candidate_base.rs | 457 let config = CandidateHostConfig { in unmarshal_candidate() localVariable
469 config.new_candidate_host() in unmarshal_candidate()
472 let config = CandidateServerReflexiveConfig { in unmarshal_candidate() localVariable
485 config.new_candidate_server_reflexive() in unmarshal_candidate()
488 let config = CandidatePeerReflexiveConfig { in unmarshal_candidate() localVariable
502 config.new_candidate_peer_reflexive() in unmarshal_candidate()
505 let config = CandidateRelayConfig { in unmarshal_candidate() localVariable
519 config.new_candidate_relay() in unmarshal_candidate()
|
| H A D | candidate_server_reflexive_test.rs | 32 let server = turn::server::Server::new(turn::server::config::ServerConfig { in test_server_reflexive_only_connection()
35 conn_configs: vec![turn::server::config::ConnConfig { in test_server_reflexive_only_connection()
|
| /webrtc/mdns/src/ |
| H A D | lib.rs | 4 pub mod config; module
|
| /webrtc/srtp/src/ |
| H A D | lib.rs | 5 pub mod config; module
|
| /webrtc/webrtc/src/mux/ |
| H A D | mod.rs | 40 pub fn new(config: Config) -> Self { in new()
44 next_conn: Arc::clone(&config.conn), in new()
46 buffer_size: config.buffer_size, in new()
|
| /webrtc/dtls/examples/listen/selfsign/ |
| H A D | listen_selfsign.rs | 5 use webrtc_dtls::config::ExtendedMasterSecretType;
7 use webrtc_dtls::{config::Config, crypto::Certificate, listener::listen};
|
| /webrtc/dtls/examples/listen/psk/ |
| H A D | listen_psk.rs | 6 use webrtc_dtls::config::ExtendedMasterSecretType;
8 use webrtc_dtls::{config::Config, listener::listen};
|
| /webrtc/turn/src/client/relay_conn/ |
| H A D | relay_conn_test.rs | 50 let config = RelayConnConfig { in test_relay_conn() localVariable
59 let rc = RelayConn::new(Arc::new(Mutex::new(obs)), config).await; in test_relay_conn()
|