Searched refs:Association (Results 1 – 8 of 8) sorted by relevance
| /webrtc/sctp/src/association/ |
| H A D | mod.rs | 199 pub struct Association { struct
215 impl Association { argument
218 let (a, mut handshake_completed_ch_rx) = Association::new(config, false).await?; in server()
233 let (a, mut handshake_completed_ch_rx) = Association::new(config, true).await?; in client()
371 Association::read_loop( in new()
382 Association::write_loop( in new()
405 Association { in new()
|
| H A D | association_test.rs | 25 ) -> Result<(Association, Association)> { in create_new_association_pair() argument
33 let client = Association::client(Config { in create_new_association_pair()
49 let server = Association::server(Config { in create_new_association_pair()
111 async fn close_association_pair(br: &Arc<Bridge>, client: Association, server: Association) { in close_association_pair() argument
159 async fn flush_buffers(br: &Arc<Bridge>, client: &Association, server: &Association) { in flush_buffers() argument
183 client: &Association, in establish_session_pair() argument
184 server: &mut Association, in establish_session_pair() argument
2210 let a = Association::client(Config { in test_stats()
2231 async fn create_assocs() -> Result<(Association, Association)> { in create_assocs()
2245 let a = Association::client(Config { in create_assocs()
[all …]
|
| /webrtc/webrtc/src/sctp_transport/ |
| H A D | mod.rs | 22 use sctp::association::Association;
52 sctp_association: Arc<Association>,
82 sctp_association: Mutex<Option<Arc<Association>>>,
159 association = sctp::association::Association::client(sctp::association::Config { in start()
428 pub(crate) async fn association(&self) -> Option<Arc<Association>> { in association() argument
|
| /webrtc/sctp/examples/ |
| H A D | throughput.rs | 70 let a = Association::server(config).await?; in main()
116 let a = Association::client(config).await.unwrap(); in main()
|
| H A D | pong.rs | 70 let a = Association::server(config).await?; in main()
|
| H A D | ping.rs | 71 let a = Association::client(config).await?; in main()
|
| /webrtc/data/src/data_channel/ |
| H A D | data_channel_test.rs | 28 ) -> Result<(Arc<Association>, Arc<Association>)> { in create_new_association_pair() argument
36 let client = Association::client(sctp::association::Config { in create_new_association_pair()
52 let server = Association::server(sctp::association::Config { in create_new_association_pair()
106 client: Arc<Association>, in close_association_pair() argument
107 server: Arc<Association>, in close_association_pair() argument
|
| H A D | mod.rs | 10 association::Association, chunk::chunk_payload_data::PayloadProtocolIdentifier, stream::*,
63 association: &Arc<Association>, in dial() argument
76 association: &Arc<Association>, in accept() argument
|