Home
last modified time | relevance | path

Searched refs:record_start (Results 1 – 25 of 30) sorted by relevance

12

/external/pytorch/benchmarks/distributed/rpc/parameter_server/trainer/
Dtrainer.py33 def record_start(self, type, key, name, cuda=True): member in TrainerBase
42 self.__metrics_logger.record_start(type, key, name, cuda)
62 self.__metrics_logger.record_start(
85 self.__metrics_logger.record_start(
108 self.__metrics_logger.record_start(
136 self.__metrics_logger.record_start(type, key, name, cuda)
Dhooks.py21 cref.record_start(
47 cref.record_start("hook_c10d_metric", key, "gloo_sparse_allreduce")
55 cref.record_start("hook_future_metric", key, "nccl_dense_allreduce")
93 cref.record_start("hook_future_metric", key, f"{cref.backend}_dense_allreduce")
/external/pytorch/benchmarks/distributed/rpc/parameter_server/server/
Dserver.py53 def record_start(self, type, key, name, cuda=True): member in ParameterServerBase
62 self.__metrics_logger.record_start(type, key, name, cuda)
82 self.__metrics_logger.record_start(
108 self.__metrics_logger.record_start(
137 self.__metrics_logger.record_start(type, key, name, cuda)
/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/upb/upb/io/
Dtokenizer.c195 int record_start; member
225 if (t->record_target != NULL && t->record_start < t->buffer_size) { in Refresh()
226 upb_String_Append(t->record_target, t->buffer + t->record_start, in Refresh()
227 t->buffer_size - t->record_start); in Refresh()
228 t->record_start = 0; in Refresh()
273 t->record_start = t->buffer_pos; in RecordTo()
277 if (t->buffer_pos > t->record_start) { in StopRecording()
278 upb_String_Append(t->record_target, t->buffer + t->record_start, in StopRecording()
279 t->buffer_pos - t->record_start); in StopRecording()
282 t->record_start = -1; in StopRecording()
[all …]
/external/grpc-grpc/third_party/upb/upb/io/
Dtokenizer.c175 int record_start; member
205 if (t->record_target != NULL && t->record_start < t->buffer_size) { in Refresh()
206 upb_String_Append(t->record_target, t->buffer + t->record_start, in Refresh()
207 t->buffer_size - t->record_start); in Refresh()
208 t->record_start = 0; in Refresh()
253 t->record_start = t->buffer_pos; in RecordTo()
257 if (t->buffer_pos > t->record_start) { in StopRecording()
258 upb_String_Append(t->record_target, t->buffer + t->record_start, in StopRecording()
259 t->buffer_pos - t->record_start); in StopRecording()
262 t->record_start = -1; in StopRecording()
[all …]
/external/pytorch/benchmarks/distributed/rpc/parameter_server/metrics/
DMetricsLogger.py10 def record_start(self, type, key, name, cuda): member in MetricsLogger
22 metric.record_start()
DMetricBase.py11 def record_start(self): member in MetricBase
DCPUMetric.py12 def record_start(self): member in CPUMetric
DCUDAMetric.py13 def record_start(self): member in CUDAMetric
/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/cares/cares/test/
Dares-test-parse-txt.cc57 EXPECT_EQ(1, txt->record_start); in TEST_F()
63 EXPECT_EQ(1, txt2->record_start); in TEST_F()
70 EXPECT_EQ(0, txt3->record_start); in TEST_F()
/external/perfetto/src/profiling/perf/
Devent_reader.cc386 const char* record_start) { in ParseSampleRecord() argument
394 auto* event_hdr = reinterpret_cast<const perf_event_header*>(record_start); in ParseSampleRecord()
403 const char* parse_pos = record_start + sizeof(perf_event_header); in ParseSampleRecord()
483 PERFETTO_CHECK(parse_pos <= record_start + sample_size); in ParseSampleRecord()
Devent_reader.h112 ParsedSample ParseSampleRecord(uint32_t cpu, const char* record_start);
/external/pytorch/benchmarks/distributed/rpc/parameter_server/
Dutils.py49 cref.record_start("hook_future_metric", key, RPC_SPARSE if sparse else RPC_DENSE)
/external/autotest/server/cros/dynamic_suite/
Djob_status.py329 def record_start(self, record_entry): member in Status
378 self.record_start(record_entry)
/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/cares/cares/src/lib/
Dares_parse_txt_reply.c149 txt_curr->record_start = (strptr == aptr); in ares__parse_txt_reply()
Dares_data.c194 ptr->data.txt_ext.record_start = 0; in ares_malloc_data()
/external/tensorflow/tensorflow/core/data/
Dcaptured_function.cc835 if (collect_usage) node->record_start(EnvTime::NowNanos()); in Run()
897 if (collect_usage) node->record_start(EnvTime::NowNanos()); in RunWithBorrowedArgs()
1011 node->record_start(EnvTime::NowNanos()); in RunAsync()
1031 if (collect_usage) node->record_start(EnvTime::NowNanos()); in RunAsync()
/external/tensorflow/tensorflow/core/framework/
Ddataset.cc906 node_->record_start(now_nanos); in GetNext()
923 output->record_start(now_nanos); in GetNext()
950 node_->record_start(now_nanos); in Skip()
958 output->record_start(now_nanos); in Skip()
Dmodel.h337 void record_start(int64_t time_nanos) TF_LOCKS_EXCLUDED(mu_) { in record_start() function
Dmodel_test.cc594 node->record_start(1); in TEST()
1320 source->record_start(100); in TEST()
Ddataset.h1246 node_->record_start(now_nanos); in RecordStart()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/cares/cares/include/
Dares.h577 unsigned char record_start; member
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Dgrpc_ares_wrapper.cc784 if (result->record_start && in on_txt_done_locked()
797 for (result = result->next; result != nullptr && !result->record_start; in on_txt_done_locked()
/external/grpc-grpc/src/core/resolver/dns/c_ares/
Dgrpc_ares_wrapper.cc797 if (result->record_start && in on_txt_done_locked()
810 for (result = result->next; result != nullptr && !result->record_start; in on_txt_done_locked()
/external/grpc-grpc/src/core/lib/event_engine/
Dares_resolver.cc761 if (part->record_start) { in OnTXTDoneLocked()

12