Searched refs:vg_ (Results 1 – 13 of 13) sorted by relevance
| /third_party/mindspore/tests/ut/cpp/dataset/ |
| D | interrupt_test.cc | 34 TaskGroup vg_; member in MindDataTestIntrpService
40 q.Register(&vg_); in TEST_F()
41 vg_.CreateAsyncTask("Test1", [&]() -> Status { in TEST_F()
49 vg_.GetIntrpService()->InterruptAll(); in TEST_F()
50 vg_.join_all(Task::WaitFlag::kNonBlocking); in TEST_F()
57 rc = wp.Register(&vg_); in TEST_F()
59 vg_.CreateAsyncTask("Test1", [&]() -> Status { in TEST_F()
65 vg_.GetIntrpService()->InterruptAll(); in TEST_F()
66 vg_.join_all(Task::WaitFlag::kNonBlocking); in TEST_F()
|
| D | circular_pool_test.cc | 36 TaskGroup vg_; member in MindDataTestCircularPool
76 vg_.CreateAsyncTask("TestMem", f); in TEST_F()
78 vg_.join_all(); in TEST_F()
79 MS_LOG(DEBUG) << vg_.GetTaskErrorIfAny() << std::endl; in TEST_F()
80 ASSERT_TRUE(vg_.GetTaskErrorIfAny().IsOk()); in TEST_F()
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/ |
| D | cache_grpc_client.cc | 59 RETURN_IF_NOT_OK(vg_.ServiceStart()); in DoServiceStart()
68 vg_.interrupt_all(); in DoServiceStop()
69 RETURN_IF_NOT_OK(vg_.join_all(Task::WaitFlag::kNonBlocking)); in DoServiceStop()
154 RETURN_IF_NOT_OK(vg_.CreateAsyncTask("Async reply", f)); in DispatchWorkers()
|
| D | cache_grpc_client.h | 98 TaskGroup vg_; variable
|
| D | cache_server.cc | 46 RETURN_IF_NOT_OK(vg_.ServiceStart()); in DoServiceStart()
69 RETURN_IF_NOT_OK(cache_q_->Register(&vg_)); in DoServiceStart()
82 RETURN_IF_NOT_OK(vg_.CreateAsyncTask("Monitor unix socket", inotify_f)); in DoServiceStart()
88 RETURN_IF_NOT_OK(vg_.CreateAsyncTask("Cache service worker", std::bind(f, i), &pTask)); in DoServiceStart()
101 RETURN_IF_NOT_OK(vg_.CreateAsyncTask("rpc worker", std::bind(r, i), &pTask)); in DoServiceStart()
115 RETURN_IF_NOT_OK(vg_.ServiceStop()); in DoServiceStop()
1037 RETURN_IF_NOT_OK(vg_.join_all(Task::WaitFlag::kBlocking)); in Run()
1193 vg_.interrupt_all(); in GlobalShutdown()
|
| D | cache_client.cc | 356 (void)vg_.ServiceStop(); in ~AsyncBufferStream()
388 RETURN_IF_NOT_OK(vg_.ServiceStart()); in Init()
|
| D | cache_client.h | 350 TaskGroup vg_; variable
|
| D | cache_server.h | 288 TaskGroup vg_; variable
|
| /third_party/mindspore/mindspore/ccsrc/minddata/dataset/engine/cache/perf/ |
| D | cache_pipeline_run.cc | 165 RETURN_IF_NOT_OK(vg_.ServiceStart()); in Run()
170 RETURN_IF_NOT_OK(io_block_queues_.Register(&vg_)); in Run()
182 …RETURN_IF_NOT_OK(vg_.CreateAsyncTask("Queue listener", std::bind(&CachePipelineRun::ListenToParent… in Run()
199 RETURN_IF_NOT_OK(vg_.join_all()); in Run()
220 RETURN_IF_NOT_OK(vg_.CreateAsyncTask("Parallel worker", std::bind(f, i), &pTask)); in RunFirstEpoch()
357 RETURN_IF_NOT_OK(vg_.CreateAsyncTask("Parallel worker", std::bind(f, i), &pTask)); in RunReadEpoch()
|
| D | cache_perf_run.h | 86 TaskGroup vg_; variable
|
| D | cache_pipeline_run.h | 100 TaskGroup vg_; variable
|
| D | cache_perf_run.cc | 530 RETURN_IF_NOT_OK(vg_.ServiceStart()); in Run()
533 RETURN_IF_NOT_OK(vg_.CreateAsyncTask("Queue listener", std::bind(f, i))); in Run()
|
| /third_party/skia/experimental/wasm-skp-debugger/debugger/ |
| D | anim.mskp | 13683 �Fy+7_7�U��c�M"+��/6�6��i{��c�śD�r��%��������1ڤvg_�8U��O�F���w4�@���X���"0����d�EA�A;��…
|