/dports/www/chromium-legacy/chromium-88.0.4324.182/media/cast/logging/ |
H A D | receiver_time_offset_estimator_impl_unittest.cc | 74 encode_event->frame_id = frame_id; in TEST_F() 75 encode_event->size = 1234; in TEST_F() 76 encode_event->key_frame = true; in TEST_F() 158 encode_event->size = 1234; in TEST_F() 159 encode_event->key_frame = true; in TEST_F() 250 encode_event->size = 1234; in TEST_F() 251 encode_event->key_frame = true; in TEST_F() 275 encode_event->size = 1234; in TEST_F() 276 encode_event->key_frame = true; in TEST_F() 347 encode_event->size = 1234; in TEST_F() [all …]
|
H A D | simple_event_subscriber_unittest.cc | 44 std::unique_ptr<FrameEvent> encode_event(new FrameEvent()); in TEST_F() local 45 encode_event->timestamp = testing_clock_.NowTicks(); in TEST_F() 46 encode_event->type = FRAME_ENCODED; in TEST_F() 47 encode_event->media_type = AUDIO_EVENT; in TEST_F() 48 encode_event->rtp_timestamp = RtpTimeTicks().Expand(UINT32_C(100)); in TEST_F() 49 encode_event->frame_id = FrameId::first(); in TEST_F() 50 encode_event->size = 1234; in TEST_F() 51 encode_event->key_frame = true; in TEST_F() 52 encode_event->target_bitrate = 128u; in TEST_F() 53 encode_event->encoder_cpu_utilization = 0.01; in TEST_F() [all …]
|
H A D | stats_event_subscriber_unittest.cc | 108 encode_event->frame_id = frame_id; in TEST_F() 109 encode_event->size = 1024; in TEST_F() 110 encode_event->key_frame = true; in TEST_F() 166 encode_event->type = FRAME_ENCODED; in TEST_F() 169 encode_event->frame_id = frame_id; in TEST_F() 170 encode_event->size = size; in TEST_F() 171 encode_event->key_frame = true; in TEST_F() 172 encode_event->target_bitrate = 5678; in TEST_F() 348 encode_event->type = FRAME_ENCODED; in TEST_F() 587 encode_event->size = 1024; in TEST_F() [all …]
|
H A D | encoding_event_subscriber_unittest.cc | 319 encode_event->timestamp = now; in TEST_F() 320 encode_event->type = FRAME_ENCODED; in TEST_F() 321 encode_event->media_type = VIDEO_EVENT; in TEST_F() 323 encode_event->frame_id = FrameId::first(); in TEST_F() 324 encode_event->size = size; in TEST_F() 325 encode_event->key_frame = key_frame; in TEST_F() 373 encode_event->timestamp = now2; in TEST_F() 374 encode_event->type = FRAME_ENCODED; in TEST_F() 375 encode_event->media_type = AUDIO_EVENT; in TEST_F() 377 encode_event->frame_id = FrameId::first(); in TEST_F() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/media/cast/logging/ |
H A D | receiver_time_offset_estimator_impl_unittest.cc | 74 encode_event->frame_id = frame_id; in TEST_F() 75 encode_event->size = 1234; in TEST_F() 76 encode_event->key_frame = true; in TEST_F() 158 encode_event->size = 1234; in TEST_F() 159 encode_event->key_frame = true; in TEST_F() 250 encode_event->size = 1234; in TEST_F() 251 encode_event->key_frame = true; in TEST_F() 275 encode_event->size = 1234; in TEST_F() 276 encode_event->key_frame = true; in TEST_F() 347 encode_event->size = 1234; in TEST_F() [all …]
|
H A D | simple_event_subscriber_unittest.cc | 44 std::unique_ptr<FrameEvent> encode_event(new FrameEvent()); in TEST_F() local 45 encode_event->timestamp = testing_clock_.NowTicks(); in TEST_F() 46 encode_event->type = FRAME_ENCODED; in TEST_F() 47 encode_event->media_type = AUDIO_EVENT; in TEST_F() 48 encode_event->rtp_timestamp = RtpTimeTicks().Expand(UINT32_C(100)); in TEST_F() 49 encode_event->frame_id = FrameId::first(); in TEST_F() 50 encode_event->size = 1234; in TEST_F() 51 encode_event->key_frame = true; in TEST_F() 52 encode_event->target_bitrate = 128u; in TEST_F() 53 encode_event->encoder_cpu_utilization = 0.01; in TEST_F() [all …]
|
H A D | stats_event_subscriber_unittest.cc | 108 encode_event->frame_id = frame_id; in TEST_F() 109 encode_event->size = 1024; in TEST_F() 110 encode_event->key_frame = true; in TEST_F() 168 encode_event->type = FRAME_ENCODED; in TEST_F() 171 encode_event->frame_id = frame_id; in TEST_F() 172 encode_event->size = size; in TEST_F() 173 encode_event->key_frame = true; in TEST_F() 174 encode_event->target_bitrate = 5678; in TEST_F() 356 encode_event->type = FRAME_ENCODED; in TEST_F() 597 encode_event->size = 1024; in TEST_F() [all …]
|
H A D | encoding_event_subscriber_unittest.cc | 319 encode_event->timestamp = now; in TEST_F() 320 encode_event->type = FRAME_ENCODED; in TEST_F() 321 encode_event->media_type = VIDEO_EVENT; in TEST_F() 323 encode_event->frame_id = FrameId::first(); in TEST_F() 324 encode_event->size = size; in TEST_F() 325 encode_event->key_frame = key_frame; in TEST_F() 373 encode_event->timestamp = now2; in TEST_F() 374 encode_event->type = FRAME_ENCODED; in TEST_F() 375 encode_event->media_type = AUDIO_EVENT; in TEST_F() 377 encode_event->frame_id = FrameId::first(); in TEST_F() [all …]
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/media/cast/net/rtcp/ |
H A D | receiver_rtcp_event_subscriber_unittest.cc | 115 std::unique_ptr<FrameEvent> encode_event(new FrameEvent()); in InsertEvents() local 116 encode_event->timestamp = testing_clock_.NowTicks(); in InsertEvents() 117 encode_event->type = FRAME_ENCODED; in InsertEvents() 118 encode_event->media_type = VIDEO_EVENT; in InsertEvents() 119 encode_event->rtp_timestamp = RtpTimeTicks().Expand(UINT32_C(100)); in InsertEvents() 120 encode_event->frame_id = FrameId::first() + 1; in InsertEvents() 123 encode_event.reset(new FrameEvent()); in InsertEvents() 124 encode_event->timestamp = testing_clock_.NowTicks(); in InsertEvents() 125 encode_event->type = FRAME_ENCODED; in InsertEvents() 126 encode_event->media_type = AUDIO_EVENT; in InsertEvents() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/media/cast/net/rtcp/ |
H A D | receiver_rtcp_event_subscriber_unittest.cc | 115 std::unique_ptr<FrameEvent> encode_event(new FrameEvent()); in InsertEvents() local 116 encode_event->timestamp = testing_clock_.NowTicks(); in InsertEvents() 117 encode_event->type = FRAME_ENCODED; in InsertEvents() 118 encode_event->media_type = VIDEO_EVENT; in InsertEvents() 119 encode_event->rtp_timestamp = RtpTimeTicks().Expand(UINT32_C(100)); in InsertEvents() 120 encode_event->frame_id = FrameId::first() + 1; in InsertEvents() 123 encode_event.reset(new FrameEvent()); in InsertEvents() 124 encode_event->timestamp = testing_clock_.NowTicks(); in InsertEvents() 125 encode_event->type = FRAME_ENCODED; in InsertEvents() 126 encode_event->media_type = AUDIO_EVENT; in InsertEvents() [all …]
|
/dports/sysutils/vector/vector-0.10.0/src/sinks/ |
H A D | console.rs | 76 fn encode_event( in encode_event() function 102 encode_event(event, encoding).map_err(|err| io::Error::new(io::ErrorKind::Other, err))?; in write_event_to_output() 131 use super::{encode_event, Encoding, EncodingConfig}; 141 encode_event(event, &EncodingConfig::from(Encoding::Text)).unwrap() in encodes_raw_logs() 153 let encoded = encode_event(event, &EncodingConfig::from(Encoding::Json)); in encodes_log_events() 177 encode_event(event, &EncodingConfig::from(Encoding::Text)).unwrap() in encodes_counter() 194 encode_event(event, &EncodingConfig::from(Encoding::Text)).unwrap() in encodes_set() 212 encode_event(event, &EncodingConfig::from(Encoding::Text)).unwrap() in encodes_histogram_without_timestamp()
|
H A D | statsd.rs | 109 .with_flat_map(move |event| iter_ok(encode_event(event, &namespace))); in new() 134 fn encode_event(event: Event, namespace: &str) -> Option<Vec<u8>> { in encode_event() function 270 let frame = &encode_event(event, "").unwrap(); in test_encode_counter() 286 let frame = &encode_event(event, "").unwrap(); in test_encode_gauge() 305 let frame = &encode_event(event, "").unwrap(); in test_encode_distribution() 323 let frame = &encode_event(event, "").unwrap(); in test_encode_set()
|
H A D | logdna.rs | 101 fn encode_event(&self, event: Event) -> Option<Self::Input> { in encode_event() method 230 fn encode_event() { in encode_event() function 247 let event1_out = config.encode_event(event1).unwrap(); in encode_event() 249 let event2_out = config.encode_event(event2).unwrap(); in encode_event() 251 let event3_out = config.encode_event(event3).unwrap(); in encode_event()
|
H A D | aws_kinesis_streams.rs | 159 .with_flat_map(move |e| iter_ok(encode_event(e, &partition_key_field, &encoding))); in new() 232 fn encode_event( in encode_event() function 301 let event = encode_event(message.clone().into(), &None, &Encoding::Text.into()).unwrap(); in kinesis_encode_event_text() 311 let event = encode_event(event, &None, &Encoding::Json.into()).unwrap(); in kinesis_encode_event_json() 323 let event = encode_event(event, &Some("key".into()), &Encoding::Text.into()).unwrap(); in kinesis_encode_event_custom_partition_key() 333 let event = encode_event(event, &Some("key".into()), &Encoding::Text.into()).unwrap(); in kinesis_encode_event_custom_partition_key_limit()
|
H A D | pulsar.rs | 140 let message = encode_event(item, &self.encoding).map_err(|_| ())?; in start_send() 188 fn encode_event(item: Event, encoding: &EncodingConfig<Encoding>) -> crate::Result<Vec<u8>> { in encode_event() function 210 let result = encode_event(evt, &EncodingConfig::from(Encoding::Json)).unwrap(); in pulsar_event_json() 219 let event = encode_event(evt, &EncodingConfig::from(Encoding::Text)).unwrap(); in pulsar_event_text()
|
H A D | papertrail.rs | 52 let sink = sink.with_flat_map(move |e| iter_ok(encode_event(e, pid, &encoding))); in build() 66 fn encode_event( in encode_event() function
|
H A D | vector.rs | 54 .with_flat_map(move |event| iter_ok(encode_event(event))); in build() 74 fn encode_event(event: Event) -> Option<Bytes> { in encode_event() function
|
H A D | aws_kinesis_firehose.rs | 151 .with_flat_map(move |e| iter_ok(encode_event(e, &encoding))); in new() 221 fn encode_event(mut event: Event, encoding: &EncodingConfig<Encoding>) -> Option<Record> { in encode_event() function 247 let event = encode_event(message.clone().into(), &Encoding::Text.into()).unwrap(); in firehose_encode_event_text() 257 let event = encode_event(event, &Encoding::Json.into()).unwrap(); in firehose_encode_event_json()
|
H A D | kafka.rs | 150 let (key, body) = encode_event(item.clone(), &self.key_field, &self.encoding); in start_send() 255 fn encode_event( in encode_event() function 289 let (key_bytes, bytes) = encode_event( in kafka_encode_event_text() 306 let (key, bytes) = encode_event( in kafka_encode_event_json()
|
/dports/www/chromium-legacy/chromium-88.0.4324.182/media/cast/sender/ |
H A D | frame_sender.cc | 278 std::unique_ptr<FrameEvent> encode_event(new FrameEvent()); in SendEncodedFrame() local 279 encode_event->timestamp = encoded_frame->encode_completion_time; in SendEncodedFrame() 280 encode_event->type = FRAME_ENCODED; in SendEncodedFrame() 281 encode_event->media_type = is_audio_ ? AUDIO_EVENT : VIDEO_EVENT; in SendEncodedFrame() 282 encode_event->rtp_timestamp = encoded_frame->rtp_timestamp; in SendEncodedFrame() 283 encode_event->frame_id = frame_id; in SendEncodedFrame() 285 encode_event->key_frame = encoded_frame->dependency == EncodedFrame::KEY; in SendEncodedFrame() 286 encode_event->target_bitrate = requested_bitrate_before_encode; in SendEncodedFrame() 287 encode_event->encoder_cpu_utilization = encoded_frame->encoder_utilization; in SendEncodedFrame() 288 encode_event->idealized_bitrate_utilization = in SendEncodedFrame() [all …]
|
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/media/cast/sender/ |
H A D | frame_sender.cc | 277 std::unique_ptr<FrameEvent> encode_event(new FrameEvent()); in SendEncodedFrame() local 278 encode_event->timestamp = encoded_frame->encode_completion_time; in SendEncodedFrame() 279 encode_event->type = FRAME_ENCODED; in SendEncodedFrame() 280 encode_event->media_type = is_audio_ ? AUDIO_EVENT : VIDEO_EVENT; in SendEncodedFrame() 281 encode_event->rtp_timestamp = encoded_frame->rtp_timestamp; in SendEncodedFrame() 282 encode_event->frame_id = frame_id; in SendEncodedFrame() 284 encode_event->key_frame = encoded_frame->dependency == EncodedFrame::KEY; in SendEncodedFrame() 285 encode_event->target_bitrate = requested_bitrate_before_encode; in SendEncodedFrame() 286 encode_event->encoder_cpu_utilization = encoded_frame->encoder_utilization; in SendEncodedFrame() 287 encode_event->idealized_bitrate_utilization = in SendEncodedFrame() [all …]
|
/dports/sysutils/vector/vector-0.10.0/src/sinks/datadog/ |
H A D | logs.rs | 60 sink.with_flat_map(move |e| iter_ok(encode_event(e, api_key.clone(), &encoding))); in build() 74 fn encode_event( in encode_event() function 95 if let Some(bytes) = util::encode_event(event, encoding) { in encode_event()
|
/dports/sysutils/vector/vector-0.10.0/src/sinks/gcp/ |
H A D | stackdriver_logs.rs | 167 fn encode_event(&self, mut event: Event) -> Option<Self::Input> { in encode_event() method 302 let json = sink.encode_event(Event::from(log)).unwrap(); in encode_valid() 358 let event1 = sink.encode_event(Event::from(log1)).unwrap(); in correct_request() 359 let event2 = sink.encode_event(Event::from(log2)).unwrap(); in correct_request()
|
/dports/sysutils/vector/vector-0.10.0/src/sinks/influxdb/ |
H A D | logs.rs | 138 fn encode_event(&self, event: Event) -> Option<Self::Input> { in encode_event() method 255 let bytes = sink.encode_event(event).unwrap(); in test_encode_event_v1() 299 let bytes = sink.encode_event(event).unwrap(); in test_encode_event() 338 let bytes = sink.encode_event(event).unwrap(); in test_encode_event_without_tags() 375 let bytes = sink.encode_event(event).unwrap(); in test_encode_nested_fields() 412 let bytes = sink.encode_event(event).unwrap(); in test_add_tag()
|
/dports/sysutils/vector/vector-0.10.0/src/sinks/util/ |
H A D | udp.rs | 1 use super::{encode_event, encoding::EncodingConfig, Encoding, SinkBuildError, StreamSink}; 58 iter_ok(encode_event(event, &encoding)) in raw_udp()
|