Searched refs:GrpcServer (Results 1 – 11 of 11) sorted by relevance
78 GrpcServer::GrpcServer(const ServerDef& server_def, Env* env) in GrpcServer() function in tensorflow::GrpcServer81 GrpcServer::~GrpcServer() { in ~GrpcServer()113 void GrpcServer::MaybeMutateBuilder(::grpc::ServerBuilder* builder) {} in MaybeMutateBuilder()115 Status GrpcServer::Init(const GrpcServerOptions& opts) { in Init()282 Status GrpcServer::ParseChannelSpec(const WorkerCacheFactoryOptions& options, in ParseChannelSpec()305 Status GrpcServer::WorkerCacheFactory(const WorkerCacheFactoryOptions& options, in WorkerCacheFactory()345 Status GrpcServer::Start() { in Start()372 Status GrpcServer::Stop() { in Stop()389 Status GrpcServer::Join() { in Join()407 const string GrpcServer::target() const { in target()[all …]
72 class GrpcServer : public ServerInterface {74 GrpcServer(const ServerDef& server_def, Env* env);83 std::unique_ptr<GrpcServer>* out_server);87 virtual ~GrpcServer();
48 : GrpcServer(server_def, env) {} in MPIServer()60 Status s = GrpcServer::Init(opts); in Init()65 Status s = GrpcServer::Start(); in Start()70 Status s = GrpcServer::Join(); in Join()
28 class MPIServer : public GrpcServer {
30 : GrpcServer(server_def, env) { in GdrServer()89 return GrpcServer::Init(opts); in Init()99 return GrpcServer::Start(); in Start()104 return GrpcServer::Stop(); in Stop()112 return GrpcServer::Join(); in Join()
24 class GdrServer : public GrpcServer {
41 : GrpcServer(server_def, env), verbs_state_(DISCONNECTED) {} in VerbsServer()87 Status s = GrpcServer::Init(opts); in Init()102 Status s = GrpcServer::Start(); in Start()121 Status s = GrpcServer::Join(); in Join()
27 class VerbsServer : public GrpcServer {
141 std::unique_ptr<tensorflow::GrpcServer> worker_server; in TestRemoteExecute()142 ASSERT_TRUE(tensorflow::GrpcServer::Create( in TestRemoteExecute()218 std::unique_ptr<tensorflow::GrpcServer> worker_server1; in TestRemoteExecuteSilentCopies()219 ASSERT_TRUE(tensorflow::GrpcServer::Create( in TestRemoteExecuteSilentCopies()225 std::unique_ptr<tensorflow::GrpcServer> worker_server2; in TestRemoteExecuteSilentCopies()226 ASSERT_TRUE(tensorflow::GrpcServer::Create( in TestRemoteExecuteSilentCopies()357 std::unique_ptr<tensorflow::GrpcServer> worker_server; in TestRemoteExecuteChangeServerDef()358 ASSERT_TRUE(tensorflow::GrpcServer::Create( in TestRemoteExecuteChangeServerDef()392 tensorflow::Status s = tensorflow::GrpcServer::Create( in TestRemoteExecuteChangeServerDef()
179 tensorflow::GrpcServer* grpc_server = in UpdateTFE_ContextWithServerDef()180 dynamic_cast<tensorflow::GrpcServer*>(server.get()); in UpdateTFE_ContextWithServerDef()
8933 tensorflow::GrpcServer* grpc_server = in EnableCollectiveOps()8934 dynamic_cast<tensorflow::GrpcServer*>(server.get()); in EnableCollectiveOps()