Home
last modified time | relevance | path

Searched refs:request_call (Results 1 – 17 of 17) sorted by relevance

/external/rust/crates/grpcio/src/task/
Dcallback.rs25 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/
Dactive_call_spec.rb108 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
Dclient_stub_spec.rb247 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/
Dserver.cc79 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/
Dclient_server_spec.rb28 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/
Dserver.rs76 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.py35 server_request_call_start_batch_result = server.request_call(
D_no_messages_server_completion_queue_per_call_test.py38 server_request_call_start_batch_result = self.server.request_call(
D_no_messages_single_server_completion_queue_test.py33 server_request_call_start_batch_result = self.server.request_call(
Dcygrpc_test.py184 request_call_result = self.server.request_call(
322 self.server.request_call(self.server_completion_queue,
D_cancel_many_calls_test.py97 server.request_call(call_completion_queue, server_completion_queue,
D_read_some_but_not_all_responses_test.py151 request_call_result = server.request_call(server_call_completion_queue,
/external/grpc-grpc/test/core/end2end/fixtures/
Dproxy.cc85 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/
Dserver.rs497 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/
Drpc_server.rb392 an_rpc = @server.request_call
/external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/
Dserver.pyx.pxi43 def request_call( member in Server
/external/grpc-grpc/src/python/grpcio/grpc/
D_server.py686 state.server.request_call(state.completion_queue, state.completion_queue,