Home
last modified time | relevance | path

Searched refs:encode_event (Results 1 – 25 of 52) sorted by relevance

123

/dports/www/chromium-legacy/chromium-88.0.4324.182/media/cast/logging/
H A Dreceiver_time_offset_estimator_impl_unittest.cc74 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 Dsimple_event_subscriber_unittest.cc44 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 Dstats_event_subscriber_unittest.cc108 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 Dencoding_event_subscriber_unittest.cc319 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 Dreceiver_time_offset_estimator_impl_unittest.cc74 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 Dsimple_event_subscriber_unittest.cc44 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 Dstats_event_subscriber_unittest.cc108 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 Dencoding_event_subscriber_unittest.cc319 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 Dreceiver_rtcp_event_subscriber_unittest.cc115 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 Dreceiver_rtcp_event_subscriber_unittest.cc115 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 Dconsole.rs76 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 Dstatsd.rs109 .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 Dlogdna.rs101 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 Daws_kinesis_streams.rs159 .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 Dpulsar.rs140 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 Dpapertrail.rs52 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 Dvector.rs54 .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 Daws_kinesis_firehose.rs151 .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 Dkafka.rs150 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 Dframe_sender.cc278 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 Dframe_sender.cc277 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 Dlogs.rs60 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 Dstackdriver_logs.rs167 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 Dlogs.rs138 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 Dudp.rs1 use super::{encode_event, encoding::EncodingConfig, Encoding, SinkBuildError, StreamSink};
58 iter_ok(encode_event(event, &encoding)) in raw_udp()

123