Searched refs:wrapped_request (Results 1 – 5 of 5) sorted by relevance
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | worker_interface.h | 67 RunGraphRequestWrapper* wrapped_request = new ProtoRunGraphRequest(request); in RunGraphAsync() local
70 RunGraphAsync(opts, wrapped_request, wrapped_response, in RunGraphAsync()
71 [wrapped_request, wrapped_response, done](const Status& s) { in RunGraphAsync()
73 delete wrapped_request; in RunGraphAsync()
|
| D | master_interface.h | 57 std::unique_ptr<RunStepRequestWrapper> wrapped_request( in RunStep()
61 return RunStep(call_options, wrapped_request.get(), wrapped_response.get()); in RunStep()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_master_service.cc | 192 RunStepRequestWrapper* wrapped_request = in RunStepHandler() local
198 call_opts, wrapped_request, wrapped_response, in RunStepHandler()
199 [call, call_opts, wrapped_request, wrapped_response, in RunStepHandler()
203 delete wrapped_request; in RunStepHandler()
|
| D | grpc_worker_service.cc | 227 ProtoRunGraphRequest* wrapped_request = in RunGraphHandler() local
232 auto done_cb = [call, call_opts, wrapped_request, in RunGraphHandler()
240 delete wrapped_request; in RunGraphHandler()
245 auto compute_fn = [this, call_opts, wrapped_request, in RunGraphHandler()
247 worker_->RunGraphAsync(call_opts, wrapped_request, wrapped_response, in RunGraphHandler()
|
| /external/python/google-api-python-client/tests/ |
| D | test_discovery.py | 1389 def wrapped_request(uri, method='GET', *args, **kwargs): function
1393 http.request = wrapped_request
|