| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | rpc_rendezvous_mgr_test.cc | 145 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local
146 TF_ASSERT_OK(rendez->Initialize(&worker_session_)); in TEST_F()
147 core::ScopedUnref unref(rendez); in TEST_F()
149 TF_ASSERT_OK(rendez->Send(key, args, V("peach"), false)); in TEST_F()
166 RemoteRendezvous* rendez = rmgr_.Find(step_id); in TEST_F() local
167 core::ScopedUnref unref(rendez); in TEST_F()
168 SchedClosure([this, rendez]() { in TEST_F()
170 rendez->StartAbort(errors::Aborted("")); in TEST_F()
175 TF_ASSERT_OK(rendez->Initialize(&worker_session_)); in TEST_F()
176 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 | 41 static void StartAbortRendevous(Rendezvous* rendez, const Status& s) { in StartAbortRendevous() argument
42 rendez->StartAbort(s); in StartAbortRendevous()
43 rendez->Unref(); in StartAbortRendevous()
51 auto rendez = p.second; in ~BaseRendezvousMgr() local
52 StartAbortRendevous(rendez, errors::Aborted("Shutdown")); in ~BaseRendezvousMgr()
74 auto rendez = FindOrCreate(step_id); in RecvLocalAsync() local
75 auto done_cb = [rendez, done = std::move(done)]( in RecvLocalAsync()
79 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 | 109 Rendezvous* rendez = env_->rendezvous_mgr->Find(step_id); in AbortStep() local
110 SchedNonBlockingClosureAfter(1000000, [rendez, step_id]() { in AbortStep()
114 rendez->StartAbort(errors::Aborted("Step ", step_id, in AbortStep()
116 rendez->Unref(); in AbortStep()
|
| /external/tensorflow/tensorflow/core/framework/ |
| D | rendezvous_test.cc | 438 Rendezvous* rendez = NewLocalRendezvous(); in BM_SendRecv() local
445 TF_CHECK_OK(rendez->Send(KeyFoo(), args, orig, is_dead)); in BM_SendRecv()
446 TF_CHECK_OK(rendez->Recv(KeyFoo(), args, &val, &is_dead)); in BM_SendRecv()
450 rendez->Unref(); in BM_SendRecv()
455 Rendezvous* rendez = NewLocalRendezvous(); in BM_RecvSend() local
463 rendez->RecvAsync( in BM_RecvSend()
472 TF_CHECK_OK(rendez->Send(KeyFoo(), args, orig, is_dead)); in BM_RecvSend()
477 rendez->Unref(); in BM_RecvSend()
492 Rendezvous* rendez = NewLocalRendezvous(); in BM_PingPong() local
493 pool->Schedule([rendez, messages_count]() { in BM_PingPong()
[all …]
|
| D | rendezvous.h | 156 Rendezvous** rendez) const { in operator()
157 return create_fn_(step_id, device_mgr, rendez); in operator()
|
| /external/icu/icu4c/source/data/lang/ |
| D | hu.txt | 8 colAlternate{"Szimbólumokat figyelmen kívül hagyó rendezés"}
9 colBackwards{"Ékezetek fordított rendezése"}
11 colCaseLevel{"Kisbetű-nagybetű érzékeny rendezés"}
12 colNormalization{"Normalizált rendezés"}
13 colNumeric{"Numerikus rendezés"}
746 non-ignorable{"Szimbólumok rendezése"}
750 no{"Ékezetek normál rendezése"}
751 yes{"Ékezetek szerinti fordított rendezés"}
754 lower{"Kisbetűs szavak rendezése előre"}
755 no{"Kisbetűs-nagybetűs szavak normál rendezése"}
[all …]
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | executor_test.cc | 89 Status Run(Rendezvous* rendez) { in Run() argument
91 args.rendezvous = rendez; in Run()
281 Rendezvous* rendez = NewLocalRendezvous(); in TEST_F() local
282 TF_ASSERT_OK(Run(rendez)); in TEST_F()
286 TF_ASSERT_OK(rendez->Recv(Key(ALICE, kIncarnation, BOB, "out"), args, &out, in TEST_F()
290 rendez->Unref(); in TEST_F()
397 Rendezvous* rendez = NewLocalRendezvous(); in TEST_F() local
399 TF_ASSERT_OK(rendez->Send(Key(ALICE, 1, BOB, "one"), Rendezvous::Args(), in TEST_F()
402 EXPECT_TRUE(errors::IsInternal(Run(rendez))); in TEST_F()
405 EXPECT_TRUE(errors::IsInternal(rendez->Recv( in TEST_F()
[all …]
|
| D | graph_runner.cc | 129 SimpleRendezvous rendez; in Run() local
140 TF_RETURN_IF_ERROR(rendez.Send(parsed, Rendezvous::Args(), in.second, in Run()
180 args.rendezvous = &rendez; in Run()
201 rendez.Recv(parsed, Rendezvous::Args(), &output_tensor, &is_dead)); in Run()
|
| D | kernel_benchmark_testlib.cc | 51 Rendezvous* rendez, const char* executor_type, in Benchmark() argument
82 if (rendez == nullptr) { in Benchmark()
85 rendez_ = rendez; in Benchmark()
|
| D | direct_session.cc | 965 run_state->rendez.reset(new IntraProcessRendezvous(device_mgr_.get())); in PRunSetup()
980 num_executors, run_state->rendez.get(), [run_state](const Status& ret) { in PRunSetup()
988 args.rendezvous = run_state->rendez.get(); in PRunSetup()
1076 SendPRunInputs(inputs, executors_and_keys, run_state->rendez.get()); in PRun()
1148 IntraProcessRendezvous* rendez) { in SendPRunInputs() argument
1163 rendez->StartAbort(s); in SendPRunInputs()
1171 s = rendez->Send(parsed, Rendezvous::Args(), tensor_from_handle, false); in SendPRunInputs()
1174 s = rendez->Send(parsed, Rendezvous::Args(), input.second, false); in SendPRunInputs()
1178 rendez->StartAbort(s); in SendPRunInputs()
1212 s = run_state->rendez->Recv(parsed, Rendezvous::Args(), &output_tensor, in RecvPRunOutputs()
[all …]
|
| D | kernel_benchmark_testlib.h | 58 Rendezvous* rendez = nullptr, const char* executor_type = "",
|
| D | direct_session.h | 218 core::RefCountPtr<IntraProcessRendezvous> rendez = nullptr; member
287 IntraProcessRendezvous* rendez);
|
| /external/tensorflow/tensorflow/core/kernels/data/ |
| D | single_threaded_executor_test.cc | 77 Status Run(Rendezvous* rendez) { in Run() argument
79 args.rendezvous = rendez; in Run()
|
| /external/libwebsockets/minimal-examples/api-tests/api-test-fts/ |
| D | les-mis-utf8.txt | 5114 --Monsieur, reprit l'enfant, rendez-moi ma pièce.
6647 lettre vous déchire, rendez-le-lui. Adieu.
|