/external/rust/crates/grpcio/src/task/ |
D | callback.rs | 25 server::request_call(rc, cq); in resolve() 30 Ok(_) => server::request_call(rc, cq), in resolve() 57 server::request_call(rc, cq); in resolve() 63 server::request_call(rc, cq); in resolve()
|
/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/rust/crates/grpcio/src/call/ |
D | server.rs | 76 request_call: Option<RequestCallContext>, field 85 request_call: Some(rc), in new() 137 self.request_call.take() in take_request_call_context() 214 request_call: Option<RequestCallContext>, field 222 request_call: Some(rc), in new() 240 self.request_call.take() in take_request_call_context()
|
/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_server_completion_queue_per_call_test.py | 38 server_request_call_start_batch_result = self.server.request_call(
|
D | _no_messages_single_server_completion_queue_test.py | 33 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 | _cancel_many_calls_test.py | 97 server.request_call(call_completion_queue, server_completion_queue,
|
D | _read_some_but_not_all_responses_test.py | 151 request_call_result = server.request_call(server_call_completion_queue,
|
/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/rust/crates/grpcio/src/ |
D | server.rs | 497 pub fn request_call(ctx: RequestCallContext, cq: &CompletionQueue) { in request_call() function 599 request_call(rc.clone(), cq); in start()
|
/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,
|