| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| call_options.cc | 22 CallOptions::CallOptions() {}
24 void CallOptions::StartCancel() {
34 void CallOptions::SetCancelCallback(CancelFunction cancel_func) {
39 void CallOptions::ClearCancelCallback() {
44 int64 CallOptions::GetTimeout() {
49 void CallOptions::SetTimeout(int64 ms) {
|
| call_options.h | 33 // TODO(zhifengc): Maybe change all RPC methods to take CallOptions.
34 class CallOptions {
36 CallOptions();
41 // CallOptions object is alive. The callee may or may not receive
74 TF_DISALLOW_COPY_AND_ASSIGN(CallOptions);
|
| master_interface.h | 35 virtual Status CreateSession(CallOptions* call_options,
39 virtual Status ExtendSession(CallOptions* call_options,
43 virtual Status PartialRunSetup(CallOptions* call_options,
49 virtual Status RunStep(CallOptions* call_options,
53 virtual Status RunStep(CallOptions* call_options,
81 virtual Status CloseSession(CallOptions* call_options,
85 virtual Status ListDevices(CallOptions* call_options,
89 virtual Status Reset(CallOptions* call_options, const ResetRequest* request,
|
| local_master.h | 37 // TODO(mrry): Make all potentially blocking Master methods take CallOptions
43 Status CreateSession(CallOptions* call_options,
47 Status ExtendSession(CallOptions* call_options,
51 Status PartialRunSetup(CallOptions* call_options,
55 Status RunStep(CallOptions* call_options, RunStepRequestWrapper* request,
62 Status CloseSession(CallOptions* call_options,
66 Status ListDevices(CallOptions* call_options,
71 Status Reset(CallOptions* call_options, const ResetRequest* request,
|
| call_options_test.cc | 22 TEST(CallOptions, Cancel) {
24 CallOptions opts;
|
| worker.h | 67 void RunGraphAsync(CallOptions* opts, RunGraphRequestWrapper* request,
83 void RecvTensorAsync(CallOptions* opts, const RecvTensorRequest* request,
110 void DoRunGraph(CallOptions* opts, RunGraphRequestWrapper* request,
114 void DoPartialRunGraph(CallOptions* opts, RunGraphRequestWrapper* request,
|
| local_master.cc | 26 Status WaitForNotification(CallOptions* call_options,
53 Status LocalMaster::CreateSession(CallOptions* call_options,
67 Status LocalMaster::ExtendSession(CallOptions* call_options,
81 Status LocalMaster::PartialRunSetup(CallOptions* call_options,
95 Status LocalMaster::RunStep(CallOptions* call_options,
118 Status LocalMaster::CloseSession(CallOptions* call_options,
132 Status LocalMaster::ListDevices(CallOptions* call_options,
146 Status LocalMaster::Reset(CallOptions* call_options,
|
| master_session.h | 87 Status Run(CallOptions* opts, const RunStepRequestWrapper& req,
212 Status DoRunWithLocalExecution(CallOptions* opts,
215 Status DoPartialRun(CallOptions* opts, const RunStepRequestWrapper& req,
|
| worker_interface.h | 59 virtual void RunGraphAsync(CallOptions* opts, RunGraphRequestWrapper* request,
63 virtual void RunGraphAsync(CallOptions* opts, const RunGraphRequest* request,
104 virtual void RecvTensorAsync(CallOptions* opts,
|
| master.h | 52 void RunStep(CallOptions* opts, const RunStepRequestWrapper* req,
|
| worker.cc | 109 void Worker::RunGraphAsync(CallOptions* opts, RunGraphRequestWrapper* request,
133 void Worker::DoRunGraph(CallOptions* opts, RunGraphRequestWrapper* request,
205 void Worker::DoPartialRunGraph(CallOptions* opts,
331 void Worker::RecvTensorAsync(CallOptions* opts,
|
| cluster_function_library_runtime.cc | 197 CallOptions* call_options = new CallOptions();
|
| /external/tensorflow/tensorflow/contrib/verbs/ |
| grpc_verbs_client.cc | 24 Status GrpcVerbsClient::GetRemoteAddress(CallOptions* call_options,
35 CallOptions call_options;
|
| grpc_verbs_client.h | 34 Status GetRemoteAddress(CallOptions* call_options,
|
| /external/tensorflow/tensorflow/contrib/gdr/ |
| gdr_worker.h | 35 virtual void GrpcRecvTensorAsync(CallOptions* opts,
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| grpc_remote_master.cc | 43 Status CreateSession(CallOptions* call_options,
51 Status ExtendSession(CallOptions* call_options,
59 Status PartialRunSetup(CallOptions* call_options,
67 Status RunStep(CallOptions* call_options, RunStepRequestWrapper* request,
75 Status CloseSession(CallOptions* call_options,
83 Status ListDevices(CallOptions* call_options,
91 Status Reset(CallOptions* call_options, const ResetRequest* request,
114 Status Call(::grpc::ClientContext* ctx, CallOptions* call_options,
|
| grpc_state.h | 39 Response* response, StatusCallback done, CallOptions* call_opts)
46 Response* response, StatusCallback done, CallOptions* call_opts,
87 CallOptions* call_opts_;
|
| grpc_worker_service.h | 38 virtual void GrpcRecvTensorAsync(CallOptions* opts,
|
| grpc_session.cc | 93 Status GrpcSession::CreateImpl(CallOptions* call_options,
117 CallOptions call_options;
124 CallOptions call_options;
129 Status GrpcSession::ExtendImpl(CallOptions* call_options,
154 CallOptions call_options;
161 CallOptions call_options;
209 CallOptions call_options;
273 Status GrpcSession::RunProto(CallOptions* call_options,
294 CallOptions call_options;
339 CallOptions call_options
[all...] |
| grpc_session.h | 121 Status RunProto(CallOptions* call_options, MutableRunStepRequestWrapper* req,
125 Status CreateImpl(CallOptions* call_options, const GraphDef& graph);
126 Status ExtendImpl(CallOptions* call_options, const GraphDef& graph);
|
| grpc_remote_worker.cc | 93 void RunGraphAsync(CallOptions* call_opts, const RunGraphRequest* request,
97 void RunGraphAsync(CallOptions* call_opts, RunGraphRequestWrapper* request,
116 void RecvTensorAsync(CallOptions* call_opts, const RecvTensorRequest* request,
189 StatusCallback done, CallOptions* call_opts = nullptr) {
195 CallOptions* call_opts = nullptr) {
|
| grpc_worker_service.cc | 263 CallOptions* call_opts = new CallOptions;
285 CallOptions* call_opts = new CallOptions;
363 void GrpcWorker::GrpcRecvTensorAsync(CallOptions* opts,
|
| grpc_master_service.cc | 177 CallOptions* call_opts = new CallOptions;
|
| /packages/apps/Dialer/java/com/android/voicemail/impl/ |
| VoicemailTranscriptionServiceGrpc.java | 204 io.grpc.CallOptions callOptions) {
205 super(channel, callOptions);
210 io.grpc.CallOptions callOptions) {
211 return new VoicemailTranscriptionServiceStub(channel, callOptions);
273 io.grpc.CallOptions callOptions) {
274 super(channel, callOptions);
279 io.grpc.CallOptions callOptions)
[all...] |
| /packages/apps/Dialer/java/com/android/voicemail/impl/transcribe/grpc/ |
| TranscriptionClientFactory.java | 26 import io.grpc.CallOptions;
163 MethodDescriptor<ReqT, RespT> method, CallOptions callOptions, Channel next) {
166 ClientCall<ReqT, RespT> call = next.newCall(method, callOptions);
|
