Searched refs:request_call (Results 1 – 16 of 16) sorted by relevance
| /external/grpc-grpc/src/ruby/spec/generic/ |
| D | active_call_spec.rb | 108 recvd_rpc = @server.request_call
133 recvd_rpc = @server.request_call
163 recvd_rpc = @server.request_call
324 recvd_rpc = @server.request_call
342 recvd_rpc = @server.request_call
408 recvd_rpc = @server.request_call
578 recvd_rpc = @server.request_call
657 recvd_rpc = @server.request_call
|
| D | client_stub_spec.rb | 247 expect { @server.request_call }.to raise_error(GRPC::Core::CallError)
683 recvd_rpc = @server.request_call
788 recvd_rpc = @server.request_call
826 recvd_rpc = @server.request_call
916 recvd_rpc = @server.request_call
1076 recvd_rpc = @server.request_call
|
| /external/grpc-grpc/test/core/fling/ |
| D | server.cc | 79 static void request_call(void) { in request_call() function
228 request_call(); in main()
295 if (!shutdown_started) request_call(); in main()
308 if (!shutdown_started) request_call(); in main()
|
| /external/grpc-grpc/src/ruby/spec/ |
| D | client_server_spec.rb | 28 recvd_rpc = @server.request_call
370 recvd_rpc = @server.request_call
426 recvd_rpc = @server.request_call
456 recvd_rpc = @server.request_call
500 recvd_rpc = @server.request_call
610 recvd_rpc = @server.request_call
|
| /external/grpc-grpc/test/core/end2end/fixtures/ |
| D | proxy.cc | 85 static void request_call(grpc_end2end_proxy* proxy);
112 request_call(proxy); in grpc_end2end_proxy_create()
402 request_call(proxy); in on_new_call()
413 static void request_call(grpc_end2end_proxy* proxy) { in request_call() function
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| D | _server_test.py | 35 server_request_call_start_batch_result = server.request_call(
|
| D | _no_messages_single_server_completion_queue_test.py | 33 server_request_call_start_batch_result = self.server.request_call(
|
| D | _no_messages_server_completion_queue_per_call_test.py | 38 server_request_call_start_batch_result = self.server.request_call(
|
| D | cygrpc_test.py | 184 request_call_result = self.server.request_call(
322 self.server.request_call(self.server_completion_queue,
|
| D | _read_some_but_not_all_responses_test.py | 151 request_call_result = server.request_call(server_call_completion_queue,
|
| D | _cancel_many_calls_test.py | 97 server.request_call(call_completion_queue, server_completion_queue,
|
| /external/tensorflow/tensorflow/contrib/mpi/ |
| D | mpi_rendezvous_mgr.h | 149 std::function<void()> request_call, in QueueRequest() argument
152 request_queue_.push(RequestQueueEntry(key, std::move(request_call))); in QueueRequest()
|
| D | mpi_rendezvous_mgr.cc | 87 std::function<void()> request_call = [parsed, dst, rendezvous_call]() { in RecvFromRemoteAsync() local
139 mgr->QueueRequest(string(parsed.FullKey()), step_id_, std::move(request_call), in RecvFromRemoteAsync()
|
| /external/grpc-grpc/src/ruby/lib/grpc/generic/ |
| D | rpc_server.rb | 392 an_rpc = @server.request_call
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | server.pyx.pxi | 43 def request_call( member in Server
|
| /external/grpc-grpc/src/python/grpcio/grpc/ |
| D | _server.py | 686 state.server.request_call(state.completion_queue, state.completion_queue,
|