Lines Matching refs:Rendezvous
16 #include "tensorflow/core/framework/rendezvous.h"
40 const string key = Rendezvous::CreateKey(
49 Rendezvous::ParsedKey parsed;
50 TF_EXPECT_OK(Rendezvous::ParseKey(key, &parsed));
57 EXPECT_FALSE(Rendezvous::ParseKey("foo;bar;baz", &parsed).ok());
58 EXPECT_FALSE(Rendezvous::ParseKey("/job:mnist/replica:1/task:2/CPU:0;"
63 Rendezvous::ParseKey(strings::StrCat(key, ";", key), &parsed).ok());
78 Rendezvous* rendez_;
98 Rendezvous::ParsedKey MakeKey(const string& name) {
99 string s = Rendezvous::CreateKey("/job:mnist/replica:1/task:2/CPU:0", 7890,
102 Rendezvous::ParsedKey k;
103 TF_EXPECT_OK(Rendezvous::ParseKey(s, &k));
107 const Rendezvous::ParsedKey& KeyFoo() {
112 const Rendezvous::ParsedKey& KeyBar() {
118 Rendezvous::Args args;
129 Rendezvous::Args args;
134 Rendezvous::Args args;
143 Rendezvous::Args args;
150 Rendezvous::Args args;
180 Rendezvous::Args args;
185 const Rendezvous::Args& sender_args,
186 const Rendezvous::Args& recver_args,
204 rendez_->RecvAsync(MakeKey(strings::StrCat(i)), Rendezvous::Args(),
221 Rendezvous::Args args;
244 Rendezvous::Args args;
260 Rendezvous::Args args;
269 Rendezvous::Args args;
286 Rendezvous::Args args;
292 Rendezvous::Args args1;
296 [&n](const Status& s, const Rendezvous::Args& send_args,
297 const Rendezvous::Args& recv_args, const Tensor& val, bool is_dead) {
310 Rendezvous* rendez = NewLocalRendezvous();
314 Rendezvous::Args args;
334 Rendezvous* rendez = NewLocalRendezvous();
339 Rendezvous::Args args;
350 Rendezvous::Args args;
