Home
last modified time | relevance | path

Searched refs:RecordMetadata (Results 1 – 25 of 28) sorted by relevance

12

/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/components/metrics/
H A Dcall_stack_profile_builder_unittest.cc129 profile_builder->RecordMetadata( in TEST()
132 profile_builder->RecordMetadata( in TEST()
230 profile_builder->RecordMetadata( in TEST()
233 profile_builder->RecordMetadata( in TEST()
270 profile_builder->RecordMetadata( in TEST()
273 profile_builder->RecordMetadata( in TEST()
316 profile_builder->RecordMetadata( in TEST()
367 profile_builder->RecordMetadata( in TEST()
419 profile_builder->RecordMetadata( in TEST()
425 profile_builder->RecordMetadata( in TEST()
[all …]
H A Dcall_stack_profile_metadata_unittest.cc86 metadata.RecordMetadata(metadata_recorder.CreateMetadataProvider().get()); in TEST()
101 metadata.RecordMetadata(metadata_recorder.CreateMetadataProvider().get()); in TEST()
120 metadata.RecordMetadata(metadata_recorder.CreateMetadataProvider().get()); in TEST()
140 metadata.RecordMetadata(metadata_recorder.CreateMetadataProvider().get()); in TEST()
143 metadata.RecordMetadata(metadata_recorder.CreateMetadataProvider().get()); in TEST()
159 metadata.RecordMetadata(metadata_recorder.CreateMetadataProvider().get()); in TEST()
162 metadata.RecordMetadata(metadata_recorder.CreateMetadataProvider().get()); in TEST()
178 metadata.RecordMetadata(metadata_recorder.CreateMetadataProvider().get()); in TEST()
182 metadata.RecordMetadata(metadata_recorder.CreateMetadataProvider().get()); in TEST()
200 metadata.RecordMetadata(metadata_recorder.CreateMetadataProvider().get()); in TEST()
[all …]
H A Dcall_stack_profile_builder.cc74 void CallStackProfileBuilder::RecordMetadata( in RecordMetadata() function in metrics::CallStackProfileBuilder
85 metadata_.RecordMetadata(metadata_provider); in RecordMetadata()
H A Dcall_stack_profile_metadata.h30 void RecordMetadata(
H A Dcall_stack_profile_builder.h75 void RecordMetadata(
H A Dcall_stack_profile_metadata.cc109 void CallStackProfileMetadata::RecordMetadata( in RecordMetadata() function in metrics::CallStackProfileMetadata
/dports/www/chromium-legacy/chromium-88.0.4324.182/components/metrics/
H A Dcall_stack_profile_builder_unittest.cc130 profile_builder->RecordMetadata( in TEST()
133 profile_builder->RecordMetadata( in TEST()
232 profile_builder->RecordMetadata( in TEST()
235 profile_builder->RecordMetadata( in TEST()
273 profile_builder->RecordMetadata( in TEST()
276 profile_builder->RecordMetadata( in TEST()
320 profile_builder->RecordMetadata( in TEST()
372 profile_builder->RecordMetadata( in TEST()
425 profile_builder->RecordMetadata( in TEST()
431 profile_builder->RecordMetadata( in TEST()
[all …]
H A Dcall_stack_profile_metadata_unittest.cc86 metadata.RecordMetadata( in TEST()
102 metadata.RecordMetadata( in TEST()
122 metadata.RecordMetadata( in TEST()
143 metadata.RecordMetadata( in TEST()
147 metadata.RecordMetadata( in TEST()
164 metadata.RecordMetadata( in TEST()
168 metadata.RecordMetadata( in TEST()
185 metadata.RecordMetadata( in TEST()
190 metadata.RecordMetadata( in TEST()
209 metadata.RecordMetadata( in TEST()
[all …]
H A Dcall_stack_profile_builder.cc74 void CallStackProfileBuilder::RecordMetadata( in RecordMetadata() function in metrics::CallStackProfileBuilder
85 metadata_.RecordMetadata(metadata_provider); in RecordMetadata()
H A Dcall_stack_profile_metadata.h30 void RecordMetadata(
H A Dcall_stack_profile_builder.h75 void RecordMetadata(const base::MetadataRecorder::MetadataProvider&
H A Dcall_stack_profile_metadata.cc109 void CallStackProfileMetadata::RecordMetadata( in RecordMetadata() function in metrics::CallStackProfileMetadata
/dports/sysutils/syslog-ng/syslog-ng-3.35.1/modules/java-modules/kafka/src/main/java/org/syslog_ng/
H A DKafkaDestination.java29 import org.apache.kafka.clients.producer.RecordMetadata;
86 Future<RecordMetadata> future = producer.send(producerRecord); in sendSynchronously()
92 public void onCompletion(RecordMetadata metadata, Exception e) { in sendAsynchronously()
103 private boolean waitForReceive(Future<RecordMetadata> future) { in waitForReceive()
/dports/net/py-kafka-python/kafka-python-1.4.5/kafka/producer/
H A Dfuture.py54 metadata = RecordMetadata(tp[0], tp[1], tp, offset, timestamp_ms,
69 RecordMetadata = collections.namedtuple( variable
/dports/www/chromium-legacy/chromium-88.0.4324.182/base/profiler/
H A Dprofile_builder.h38 virtual void RecordMetadata( in RecordMetadata() function
H A Dstack_sampler_impl.cc57 profile_builder_->RecordMetadata(*metadata_provider_); in OnStackCopy()
H A Dstack_sampling_profiler_test_util.cc66 void RecordMetadata( in RecordMetadata() function in base::__anon25495cc30111::TestProfileBuilder
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/base/profiler/
H A Dprofile_builder.h62 virtual void RecordMetadata(MetadataProvider* metadata_provider) {} in RecordMetadata() function
H A Dstack_sampler_impl.cc59 profile_builder_->RecordMetadata(metadata_provider_.get()); in OnStackCopy()
H A Dstack_sampling_profiler_test_util.cc38 void RecordMetadata(MetadataProvider* metadata_provider) override {} in RecordMetadata() function in base::__anonbe21275e0111::TestProfileBuilder
H A Dstack_sampler_impl_unittest.cc39 void RecordMetadata( in RecordMetadata() function in base::__anonb03582290111::TestProfileBuilder
H A Dstack_sampling_profiler_unittest.cc167 void RecordMetadata(
205 void TestProfileBuilder::RecordMetadata( in RecordMetadata() function in base::__anon6cd179810111::TestProfileBuilder
/dports/devel/spark/spark-2.1.1/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/
H A DKafkaWriteTask.scala60 override def onCompletion(recordMetadata: RecordMetadata, e: Exception): Unit = {
/dports/devel/spark/spark-2.1.1/external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/
H A DKafkaTestUtils.scala211 def sendMessages(topic: String, messages: Array[String]): Seq[(String, RecordMetadata)] = {
219 partition: Option[Int]): Seq[(String, RecordMetadata)] = {
H A DKafkaSourceSuite.scala30 import org.apache.kafka.clients.producer.RecordMetadata
120 def metadataToStr(m: (String, RecordMetadata)): String = {

12