| /webrtc/interceptor/src/ |
| H A D | chain.rs | 54 info: &StreamInfo, in bind_local_stream() 58 writer = icpr.bind_local_stream(info, writer).await; in bind_local_stream() 64 async fn unbind_local_stream(&self, info: &StreamInfo) { in unbind_local_stream() 66 icpr.unbind_local_stream(info).await; in unbind_local_stream() 74 info: &StreamInfo, in bind_remote_stream() 78 reader = icpr.bind_remote_stream(info, reader).await; in bind_remote_stream() 84 async fn unbind_remote_stream(&self, info: &StreamInfo) { in unbind_remote_stream() 86 icpr.unbind_remote_stream(info).await; in unbind_remote_stream()
|
| H A D | lib.rs | 57 info: &StreamInfo, in bind_local_stream() 62 async fn unbind_local_stream(&self, info: &StreamInfo); in unbind_local_stream() 68 info: &StreamInfo, in bind_remote_stream() 73 async fn unbind_remote_stream(&self, info: &StreamInfo); in unbind_remote_stream()
|
| /webrtc/media/src/audio/ |
| H A D | buffer.rs | 1 pub mod info; module 12 pub use info::BufferInfo; 43 info: BufferInfo<L>, field 49 let info = { in new() localVariable 67 let info = { in new() localVariable 77 info: self.info, in as_ref() 84 let info = { in sub_range() localVariable 133 let info = buffer.info.into(); in from() localVariable 177 let info = buffer.info.into(); in from() localVariable 197 let info = { in from_bytes() localVariable [all …]
|
| /webrtc/interceptor/src/mock/ |
| H A D | mock_interceptor.rs | 90 info: &StreamInfo, in bind_local_stream() 94 f(info, writer).await in bind_local_stream() 101 async fn unbind_local_stream(&self, info: &StreamInfo) { in unbind_local_stream() 103 f(info).await in unbind_local_stream() 111 info: &StreamInfo, in bind_remote_stream() 115 f(info, reader).await in bind_remote_stream() 122 async fn unbind_remote_stream(&self, info: &StreamInfo) { in unbind_remote_stream() 124 f(info).await in unbind_remote_stream()
|
| H A D | mock_stream.rs | 36 info: &StreamInfo, in new() 75 info, in new() 116 info, in new()
|
| /webrtc/interceptor/src/twcc/sender/ |
| H A D | mod.rs | 79 info: &StreamInfo, in bind_local_stream() 83 for e in &info.rtp_header_extensions { in bind_local_stream() 102 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_local_stream() 109 async fn unbind_local_stream(&self, info: &StreamInfo) { in unbind_local_stream() 111 streams.remove(&info.ssrc); in unbind_local_stream()
|
| /webrtc/interceptor/src/nack/ |
| H A D | mod.rs | 8 fn stream_support_nack(info: &StreamInfo) -> bool { in stream_support_nack() 9 for fb in &info.rtcp_feedback { in stream_support_nack()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | mod.rs | 129 info: &StreamInfo, in bind_local_stream() 133 info.ssrc, in bind_local_stream() 134 info.clock_rate, in bind_local_stream() 140 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_local_stream() 147 async fn unbind_local_stream(&self, info: &StreamInfo) { in unbind_local_stream() 149 streams.remove(&info.ssrc); in unbind_local_stream()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | mod.rs | 184 info: &StreamInfo, in bind_remote_stream() 188 info.ssrc, in bind_remote_stream() 189 info.clock_rate, in bind_remote_stream() 195 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_remote_stream() 202 async fn unbind_remote_stream(&self, info: &StreamInfo) { in unbind_remote_stream() 204 streams.remove(&info.ssrc); in unbind_remote_stream()
|
| /webrtc/media/src/audio/buffer/ |
| H A D | layout.rs | 5 fn index_of(info: &BufferInfo<Self>, channel: usize, frame: usize) -> usize; in index_of() 15 fn index_of(info: &BufferInfo<Self>, channel: usize, frame: usize) -> usize { in index_of() 16 (channel * info.frames()) + frame in index_of() 27 fn index_of(info: &BufferInfo<Self>, channel: usize, frame: usize) -> usize { in index_of() 28 (frame * info.channels()) + channel in index_of()
|
| H A D | info.rs | 61 fn from(info: BufferInfo<$in_layout>) -> Self { 63 channels: info.channels, 64 frames: info.frames,
|
| /webrtc/.github/workflows/ |
| H A D | grcov.yml | 64 --output-path lcov.info \ 80 name: lcov.info 82 path: lcov.info 88 file: lcov.info
|
| /webrtc/interceptor/src/nack/responder/ |
| H A D | mod.rs | 163 info: &StreamInfo, in bind_local_stream() 166 if !stream_support_nack(info) { in bind_local_stream() 173 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_local_stream() 180 async fn unbind_local_stream(&self, info: &StreamInfo) { in unbind_local_stream() 182 streams.remove(&info.ssrc); in unbind_local_stream()
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | mod.rs | 208 info: &StreamInfo, in bind_remote_stream() 212 for e in &info.rtp_header_extensions { in bind_remote_stream() 226 info.ssrc, in bind_remote_stream() 233 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_remote_stream() 240 async fn unbind_remote_stream(&self, info: &StreamInfo) { in unbind_remote_stream() 242 streams.remove(&info.ssrc); in unbind_remote_stream()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | mod.rs | 218 info: &StreamInfo, in bind_remote_stream() 221 if !stream_support_nack(info) { in bind_remote_stream() 231 streams.insert(info.ssrc, Arc::clone(&stream)); in bind_remote_stream() 238 async fn unbind_remote_stream(&self, info: &StreamInfo) { in unbind_remote_stream() 240 receive_logs.remove(&info.ssrc); in unbind_remote_stream()
|
| /webrtc/mdns/examples/ |
| H A D | mdns_query.rs | 80 log::info!("querying dns"); in main() 85 log::info!("dns queried"); in main()
|
| /webrtc/ice/src/util/ |
| H A D | util_test.rs | 8 log::info!("interfaces: {:?}, ips: {:?}", interfaces, ips); in test_local_interfaces()
|
| /webrtc/.github/actions-rs/ |
| H A D | grcov.yml | 6 output-path: ./lcov.info
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_internal.rs | 1237 for (stats, info) in in collect_inbound_stats() 1240 let ssrc = info.ssrc; in collect_inbound_stats() 1241 let kind = info.kind; in collect_inbound_stats() 1280 mid: info.mid, in collect_inbound_stats() 1294 capitalize(info.kind), in collect_inbound_stats() 1295 info.ssrc in collect_inbound_stats() 1375 capitalize(info.kind), in collect_outbound_stats() 1376 info.ssrc in collect_outbound_stats() 1408 } = info; in collect_outbound_stats() 1434 capitalize(info.kind), in collect_outbound_stats() [all …]
|
| /webrtc/mdns/src/conn/ |
| H A D | mod.rs | 143 log::info!("Closing connection"); in close() 194 log::info!("Query close signal received."); in query() 199 log::info!("Received query result"); in query() 251 log::info!("Looping and listening {:?}", socket.local_addr()); in start() 259 log::info!("Closing server connection"); in start()
|
| /webrtc/ice/src/udp_mux/ |
| H A D | udp_mux_test.rs | 66 log::info!("Listening on {}", addr); in test_udp_mux() 168 log::info!("Bound for ufrag: {}", ufrag); in test_mux_connection() 170 log::info!("Connected to {} for ufrag: {}", connect_addr, ufrag); in test_mux_connection() 171 log::info!( in test_mux_connection()
|
| /webrtc/turn/src/server/ |
| H A D | mod.rs | 131 let mut info: HashMap<FiveTuple, AllocationInfo> = HashMap::new(); in get_allocations_info() localVariable 134 info.extend(infos_rx.recv().await.ok_or(Error::ErrClosed)?); in get_allocations_info() 137 Ok(info) in get_allocations_info()
|
| /webrtc/ice/src/mdns/ |
| H A D | mod.rs | 61 log::info!("mDNS is using {} as dest_addr", addr); in create_multicast_dns()
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 306 info: &StreamInfo, in bind_remote_stream() 312 .entry(info.ssrc) in bind_remote_stream() 319 async fn unbind_remote_stream(&self, info: &StreamInfo) { in unbind_remote_stream() 322 lock.remove(&info.ssrc); in unbind_remote_stream() 329 info: &StreamInfo, in bind_local_stream() 335 .entry(info.ssrc) in bind_local_stream() 342 async fn unbind_local_stream(&self, info: &StreamInfo) { in unbind_local_stream() 345 lock.remove(&info.ssrc); in unbind_local_stream()
|
| /webrtc/util/src/vnet/router/ |
| H A D | router_test.rs | 442 log::info!("min delay : {:?}", min_delay); in delay_sub_test() 443 log::info!("max jitter: {:?}", max_jitter); in delay_sub_test() 444 log::info!("actual delay: {:?}", d); in delay_sub_test()
|