| /external/tensorflow/tensorflow/core/framework/ |
| D | rendezvous_test.cc | 74 void SchedClosure(std::function<void()> fn) { in SchedClosure() function in tensorflow::__anon2f0f779b0111::LocalRendezvousTest
127 SchedClosure([this]() { in TEST_F()
140 SchedClosure([this]() { in TEST_F()
178 SchedClosure([this, i, micros]() { in TEST_F()
202 SchedClosure([this, i, micros, recv_done]() { in TEST_F()
222 SchedClosure([=]() { in TEST_F()
238 SchedClosure([this]() { in TEST_F()
253 SchedClosure([this]() { in TEST_F()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | master.cc | 107 SchedClosure([this, sess]() { in GC()
357 SchedClosure([this, req, resp, done]() { in CreateSession()
502 SchedClosure([session, req, resp, done]() { in ExtendSession()
526 SchedClosure([session, req, resp, done]() { in PartialRunSetup()
548 SchedClosure([this, start_time, session, opts, req, resp, done]() { in RunStep()
581 SchedClosure([session, done]() { in CloseSession()
590 SchedClosure([this, req, resp, done]() { in ListDevices()
668 SchedClosure([sessions_to_close, done]() { in Reset()
692 SchedClosure(std::bind( in MakeCallable()
715 SchedClosure(std::bind( in RunCallable()
[all …]
|
| D | worker_cache_partial.cc | 45 SchedClosure([this, &device_name, locality, done]() { in GetDeviceLocalityAsync()
|
| D | collective_rma_distributed.cc | 143 SchedClosure([s, done] { done(s); }); in RecvFromPeer()
|
| D | collective_rma_distributed_test.cc | 93 SchedClosure([this]() { in RecvBufAsync()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | process_util.cc | 109 void SchedClosure(std::function<void()> closure) { in SchedClosure() function
111 return Env::Default()->SchedClosure(std::move(closure)); in SchedClosure()
116 Env::Default()->SchedClosure(std::bind( in SchedClosure()
|
| D | collective_param_resolver_local_test.cc | 175 Env::Default()->SchedClosure([this, i, cp, ¬e, &statuses]() { in TEST_F()
228 Env::Default()->SchedClosure([this, i, cp, ¬e, &statuses]() { in TEST_F()
266 Env::Default()->SchedClosure([this, i, cp, ¬e, &statuses]() { in TEST_F()
|
| D | process_util.h | 52 void SchedClosure(std::function<void()> closure);
|
| D | executor_test.cc | 335 SchedClosure([this]() { in TEST_F()
342 SchedClosure([this]() { in TEST_F()
349 SchedClosure([this]() { in TEST_F()
356 SchedClosure([this]() { in TEST_F()
|
| D | base_collective_executor.cc | 267 SchedClosure([col_impl, col_ctx, done_safe]() { in ExecuteAsync()
|
| D | direct_session.cc | 232 void DirectSession::SchedClosure(thread::ThreadPool* pool, in SchedClosure() function in tensorflow::DirectSession
635 SchedClosure(pool, std::move(c)); in RunInternal()
651 SchedClosure(device_thread_pool, std::move(c)); in RunInternal()
889 SchedClosure(pool, std::move(c)); in PRunSetup()
|
| D | direct_session.h | 334 void SchedClosure(thread::ThreadPool* pool, std::function<void()> c);
|
| D | ring_gatherer_test.cc | 246 SchedClosure([di, &done] { in Gather()
|
| D | ring_reducer_test.cc | 268 SchedClosure([di, &done] { in Reduce()
|
| /external/tensorflow/tensorflow/core/platform/ |
| D | env.h | 286 virtual void SchedClosure(std::function<void()> closure) = 0;
376 void SchedClosure(std::function<void()> closure) override { in SchedClosure() function
377 target_->SchedClosure(closure); in SchedClosure()
|
| /external/tensorflow/tensorflow/core/platform/posix/ |
| D | env.cc | 118 void SchedClosure(std::function<void()> closure) override { in SchedClosure() function in tensorflow::__anoncb12d2290111::PosixEnv
130 SchedClosure([this, micros, closure]() { in SchedClosureAfter()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | rpc_rendezvous_mgr_test.cc | 115 SchedClosure([this, rendez]() { in TEST_F()
129 SchedClosure([this, step_id]() { in TEST_F()
|
| /external/tensorflow/tensorflow/core/util/ |
| D | exec_on_stall.h | 47 env_->SchedClosure([this]() { in disabled_()
|
| /external/tensorflow/tensorflow/core/platform/windows/ |
| D | env.cc | 100 void SchedClosure(std::function<void()> closure) override { in SchedClosure() function in tensorflow::__anon839461010111::WindowsEnv
|
| /external/tensorflow/tensorflow/cc/training/ |
| D | coordinator_test.cc | 45 Env::Default()->SchedClosure( in TEST()
|
| D | queue_runner_test.cc | 261 Env::Default()->SchedClosure( in TEST()
|
| /external/tensorflow/tensorflow/compiler/xrt/kernels/ |
| D | xrt_execute_op.cc | 133 Env::Default()->SchedClosure([this, context, done]() { in ComputeAsync()
|
| /external/tensorflow/tensorflow/core/grappler/clusters/ |
| D | single_machine.cc | 331 Env::Default()->SchedClosure([this, n]() { in ShutdownSession()
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | collective_nccl_reducer_test.cc | 145 SchedClosure([di, &done, &done_mu, &done_cv] { in Reduce()
|
| D | collective_ops.cc | 45 c->env()->SchedClosure([this, c, done, col_exec]() { in CanProceedWithCompute()
|