| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | rpc_rendezvous_mgr_test.cc | 92 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local
93 TF_ASSERT_OK(rendez->Initialize(&worker_session_)); in TEST_F()
94 core::ScopedUnref unref(rendez); in TEST_F()
96 TF_ASSERT_OK(rendez->Send(key, args, V("peach"), false)); in TEST_F()
113 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local
114 core::ScopedUnref unref(rendez); in TEST_F()
115 SchedClosure([this, rendez]() { in TEST_F()
117 rendez->StartAbort(errors::Aborted("")); in TEST_F()
122 TF_ASSERT_OK(rendez->Initialize(&worker_session_)); in TEST_F()
123 EXPECT_TRUE(errors::IsAborted(rendez->Recv(key, args, &val, &val_dead))); in TEST_F()
[all …]
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | base_rendezvous_mgr.cc | 38 static void StartAbortRendevous(Rendezvous* rendez, const Status& s) { in StartAbortRendevous() argument
39 rendez->StartAbort(s); in StartAbortRendevous()
40 rendez->Unref(); in StartAbortRendevous()
48 auto rendez = p.second; in ~BaseRendezvousMgr() local
49 StartAbortRendevous(rendez, errors::Aborted("Shutdown")); in ~BaseRendezvousMgr()
71 auto rendez = FindOrCreate(step_id); in RecvLocalAsync() local
74 [rendez](Rendezvous::DoneCallback done, in RecvLocalAsync()
78 rendez->Unref(); in RecvLocalAsync()
82 rendez->RecvLocalAsync(parsed, std::move(done_cb)); in RecvLocalAsync()
105 Rendezvous* rendez = nullptr; in Cleanup() local
[all …]
|
| D | worker.cc | 102 Rendezvous* rendez = env_->rendezvous_mgr->Find(step_id); in AbortStep() local
103 SchedNonBlockingClosureAfter(1000000, [rendez, step_id]() { in AbortStep()
107 rendez->StartAbort(errors::Aborted("Step ", step_id, in AbortStep()
109 rendez->Unref(); in AbortStep()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | rendezvous_test.cc | 316 Rendezvous* rendez = NewLocalRendezvous(); in BM_SendRecv() local
323 TF_CHECK_OK(rendez->Send(KeyFoo(), args, orig, is_dead)); in BM_SendRecv()
324 TF_CHECK_OK(rendez->Recv(KeyFoo(), args, &val, &is_dead)); in BM_SendRecv()
328 rendez->Unref(); in BM_SendRecv()
339 Rendezvous* rendez = NewLocalRendezvous(); in BM_PingPong() local
340 pool->Schedule([rendez, iters]() { in BM_PingPong()
346 TF_CHECK_OK(rendez->Recv(KeyFoo(), args, &foo, &is_dead)); in BM_PingPong()
347 TF_CHECK_OK(rendez->Send(KeyBar(), args, bar, is_dead)); in BM_PingPong()
356 TF_CHECK_OK(rendez->Send(KeyFoo(), args, foo, is_dead)); in BM_PingPong()
357 TF_CHECK_OK(rendez->Recv(KeyBar(), args, &bar, &is_dead)); in BM_PingPong()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | executor_test.cc | 77 Status Run(Rendezvous* rendez) { in Run() argument
79 args.rendezvous = rendez; in Run()
269 Rendezvous* rendez = NewLocalRendezvous(); in TEST_F() local
270 TF_ASSERT_OK(Run(rendez)); in TEST_F()
274 TF_ASSERT_OK(rendez->Recv(Key(ALICE, kIncarnation, BOB, "out"), args, &out, in TEST_F()
278 rendez->Unref(); in TEST_F()
385 Rendezvous* rendez = NewLocalRendezvous(); in TEST_F() local
387 TF_ASSERT_OK(rendez->Send(Key(ALICE, 1, BOB, "one"), Rendezvous::Args(), in TEST_F()
390 EXPECT_TRUE(errors::IsInternal(Run(rendez))); in TEST_F()
393 EXPECT_TRUE(errors::IsInternal(rendez->Recv( in TEST_F()
[all …]
|
| D | graph_runner.cc | 127 SimpleRendezvous* rendez = new SimpleRendezvous; in Run() local
128 core::ScopedUnref rendez_unref(rendez); in Run()
139 TF_RETURN_IF_ERROR(rendez->Send(parsed, Rendezvous::Args(), in.second, in Run()
179 args.rendezvous = rendez; in Run()
200 rendez->Recv(parsed, Rendezvous::Args(), &output_tensor, &is_dead)); in Run()
|
| D | direct_session.cc | 482 run_state.rendez = new IntraProcessRendezvous(device_mgr_.get()); in RunInternal()
518 num_executors, run_state.rendez, [&run_state](const Status& ret) { in RunInternal()
529 args.rendezvous = run_state.rendez; in RunInternal()
859 run_state->rendez = new IntraProcessRendezvous(device_mgr_.get()); in PRunSetup()
874 num_executors, run_state->rendez, [run_state](const Status& ret) { in PRunSetup()
882 args.rendezvous = run_state->rendez; in PRunSetup()
969 Status s = SendPRunInputs(inputs, executors_and_keys, run_state->rendez); in PRun()
1041 IntraProcessRendezvous* rendez) { in SendPRunInputs() argument
1056 rendez->StartAbort(s); in SendPRunInputs()
1064 s = rendez->Send(parsed, Rendezvous::Args(), tensor_from_handle, false); in SendPRunInputs()
[all …]
|
| D | kernel_benchmark_testlib.cc | 47 Rendezvous* rendez, const char* executor_type) { in Benchmark() argument
69 if (rendez == nullptr) { in Benchmark()
72 rendez_ = rendez; in Benchmark()
|
| D | kernel_benchmark_testlib.h | 42 Rendezvous* rendez = nullptr, const char* executor_type = "");
|
| D | direct_session.h | 183 IntraProcessRendezvous* rendez = nullptr; member
265 IntraProcessRendezvous* rendez);
|
| /external/icu/icu4c/source/data/lang/ |
| D | hu.txt | 7 colAlternate{"Szimbólumokat figyelmen kívül hagyó rendezés"}
8 colBackwards{"Ékezetek fordított rendezése"}
10 colCaseLevel{"Kisbetű-nagybetű érzékeny rendezés"}
11 colNormalization{"Normalizált rendezés"}
12 colNumeric{"Numerikus rendezés"}
728 non-ignorable{"Szimbólumok rendezése"}
732 no{"Ékezetek normál rendezése"}
733 yes{"Ékezetek szerinti fordított rendezés"}
736 lower{"Kisbetűs szavak rendezése előre"}
737 no{"Kisbetűs-nagybetűs szavak normál rendezése"}
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | partitioned_function_ops.cc | 228 Rendezvous* rendez = new IntraProcessRendezvous(lib->device_mgr()); in RunFunction() local
229 run_opts.rendezvous = rendez; in RunFunction()
234 [rets, rendez, done, ctx, func_name](const Status& status) { in RunFunction()
246 rendez->Unref(); in RunFunction()
|
| /external/tensorflow/tensorflow/core/common_runtime/eager/ |
| D | kernel_and_device.h | 133 tensorflow::Rendezvous* rendez, bool log_memory, in KernelAndDeviceOp() argument
140 rendez_(rendez), in KernelAndDeviceOp()
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | single_threaded_executor_test.cc | 75 Status Run(Rendezvous* rendez) { in Run() argument
77 args.rendezvous = rendez; in Run()
|