Lines Matching refs:Rendezvous
20 #include "tensorflow/core/framework/rendezvous.h"
39 // Rendezvous* rendezvous = NewNaiveRendezvous();
40 // TF_CHECK_OK(rendezvous->Send("input", some_input_tensor));
41 // TF_CHECK_OK(executor->Run({ExecutorOpts, rendezvous, nullptr}));
42 // TF_CHECK_OK(rendezvous->Recv("output", &output_tensor));
55 // ensure objects passed in Args (rendezvous, stats_collector, etc.)
64 // RunAsync() uses the given "rendezvous", if not null, as the
85 Rendezvous* rendezvous = nullptr;
159 // 'r' is the shared Rendezvous object that is used to communicate
161 // rendezvous object will be aborted exactly once.
165 ExecutorBarrier(size_t num, Rendezvous* r, StatusCallback done)
177 Rendezvous* rendez_ = nullptr;
186 Rendezvous* error_rendez = nullptr;
192 // appropriately and later trigger an abort of the Rendezvous
