Home
last modified time | relevance | path

Searched refs:ENQUEUE_REQUEST (Results 1 – 4 of 4) sorted by relevance

/external/tensorflow/tensorflow/core/distributed_runtime/rpc/
Dgrpc_master_service.cc91 #define ENQUEUE_REQUEST(method, supports_cancel) \ macro
105 ENQUEUE_REQUEST(CreateSession, true); in HandleRPCsLoop()
106 ENQUEUE_REQUEST(ExtendSession, false); in HandleRPCsLoop()
108 ENQUEUE_REQUEST(PartialRunSetup, false); in HandleRPCsLoop()
109 ENQUEUE_REQUEST(RunStep, true); in HandleRPCsLoop()
111 ENQUEUE_REQUEST(CloseSession, false); in HandleRPCsLoop()
112 ENQUEUE_REQUEST(ListDevices, false); in HandleRPCsLoop()
113 ENQUEUE_REQUEST(Reset, false); in HandleRPCsLoop()
114 ENQUEUE_REQUEST(MakeCallable, false); in HandleRPCsLoop()
116 ENQUEUE_REQUEST(RunCallable, true); in HandleRPCsLoop()
[all …]
Dgrpc_worker_service.cc74 #define ENQUEUE_REQUEST(method, supports_cancel) \ macro
93 ENQUEUE_REQUEST(method, supports_cancel); \
197 ENQUEUE_REQUEST(method, false); \
221 ENQUEUE_REQUEST(GetStepSequence, true); in GetStepSequenceHandler()
259 ENQUEUE_REQUEST(RunGraph, true); in RunGraphHandler()
307 ENQUEUE_REQUEST(RecvBuf, true); in RecvBufHandler()
326 ENQUEUE_REQUEST(CompleteGroup, true); in CompleteGroupHandler()
345 ENQUEUE_REQUEST(CompleteInstance, false); in CompleteInstanceHandler()
347 #undef ENQUEUE_REQUEST
/external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/
Dgrpc_eager_service_impl.cc36 #define ENQUEUE_REQUEST(method) \ in HandleRPCsLoop() macro
45 ENQUEUE_REQUEST(CreateContext); in HandleRPCsLoop()
46 ENQUEUE_REQUEST(Enqueue); in HandleRPCsLoop()
47 ENQUEUE_REQUEST(WaitQueueDone); in HandleRPCsLoop()
48 ENQUEUE_REQUEST(KeepAlive); in HandleRPCsLoop()
49 ENQUEUE_REQUEST(CloseContext); in HandleRPCsLoop()
50 ENQUEUE_REQUEST(RegisterFunction); in HandleRPCsLoop()
51 ENQUEUE_REQUEST(SendTensor); in HandleRPCsLoop()
52 #undef ENQUEUE_REQUEST in HandleRPCsLoop()
/external/tensorflow/tensorflow/contrib/verbs/
Dgrpc_verbs_service.cc67 #define ENQUEUE_REQUEST(method, supports_cancel) \ macro
83 ENQUEUE_REQUEST(GetRemoteAddress, false); in HandleRPCsLoop()
104 ENQUEUE_REQUEST(GetRemoteAddress, false); in GetRemoteAddressHandler()