Searched defs:checkpoint_name (Results 1 – 10 of 10) sorted by relevance
35 auto checkpoint_name = "on_consumer_disconnect_" + std::to_string(i++); in ~MockConsumer() local45 auto checkpoint_name = "on_consumer_connect_" + std::to_string(i++); in Connect() local74 auto checkpoint_name = "on_tracing_disabled_consumer_" + std::to_string(i++); in WaitForTracingDisabled() local82 auto checkpoint_name = "on_consumer_flush_" + std::to_string(i++); in Flush() local103 std::string checkpoint_name = "on_read_buffers_" + std::to_string(i++); in ReadBuffers() local129 auto checkpoint_name = "on_trace_stats_" + std::to_string(i++); in WaitForTraceStats() local153 std::string checkpoint_name = "on_observable_events_" + std::to_string(i++); in WaitForObservableEvents() local168 std::string checkpoint_name = "query_service_state_" + std::to_string(i++); in QueryServiceState() local
40 auto checkpoint_name = "on_producer_disconnect_" + std::to_string(i++); in ~MockProducer() local58 auto checkpoint_name = "on_producer_connect_" + producer_name; in Connect() local91 auto checkpoint_name = in WaitForTracingSetup() local100 auto checkpoint_name = "on_ds_setup_" + name + "_" + std::to_string(i++); in WaitForDataSourceSetup() local119 auto checkpoint_name = "on_ds_start_" + name + "_" + std::to_string(i++); in WaitForDataSourceStart() local141 auto checkpoint_name = "on_ds_stop_" + name + "_" + std::to_string(i++); in WaitForDataSourceStop() local
188 auto checkpoint_name = "writers_changed_" + std::to_string(producer_id) + in WaitForTraceWritersChanged() local
93 const std::string& checkpoint_name, in WaitForProcess()108 const std::string& checkpoint_name, in StartAppActivity()118 const std::string& checkpoint_name, in StopApp()
137 std::string checkpoint_name = "ReadTask " + std::to_string(iteration); in TEST_F() local215 std::string checkpoint_name = "ReadTask " + std::to_string(iteration); in TEST_F() local
151 std::string checkpoint_name = "flush." + std::to_string(flush_num++); in FlushAndWait() local186 std::string checkpoint_name = "producer_sync_" + std::to_string(++sync_id); in SyncAndWaitProducer() local
532 checkpoint_name="ckpt"): argument
182 def tensor_tracepoint(tensor, checkpoint_name): argument203 def keras_layer_tracepoint(layer, checkpoint_name): argument
163 auto checkpoint_name = "wait_snapshot_" + std::to_string(attempt++); in WaitForNextSyncMarker() local172 auto checkpoint_name = "writers_changed_" + std::to_string(producer_id) + in WaitForTraceWritersChanged() local706 auto checkpoint_name = "on_tracing_disabled_consumer_1_and_2"; in TEST_F() local
442 auto checkpoint_name = "on_connect_or_disconnect" + std::to_string(i); in TEST_F() local