Home
last modified time | relevance | path

Searched refs:server_call (Results 1 – 15 of 15) sorted by relevance

/external/grpc-grpc/src/ruby/spec/generic/
Dactive_call_spec.rb29 def send_and_receive_close_and_status(client_call, server_call) argument
31 server_call.run_batch(CallOps::RECV_CLOSE_ON_SERVER => nil,
113 server_call = ActiveCall.new(recvd_call, @pass_through,
117 expect(server_call.remote_read).to eq(msg)
119 server_call.send_initial_metadata
139 server_call = ActiveCall.new(recvd_call, @pass_through,
142 expect(server_call.remote_read).to eq('marshalled:' + msg)
169 server_call = ActiveCall.new(recvd_call, @pass_through,
172 expect(server_call.remote_read).to eq('marshalled:' + msg)
174 server_call.send_status(OK, '', true)
[all …]
Dclient_stub_spec.rb685 server_call = GRPC::ActiveCall.new(
688 server_call.send_initial_metadata
689 server_call.remote_send('server response')
691 m = server_call.remote_read
695 server_call.send_status(@pass, 'OK', true)
696 close_active_server_call(server_call)
790 server_call = GRPC::ActiveCall.new(
793 expect(server_call.remote_read).to eq('first message')
828 server_call = GRPC::ActiveCall.new(
831 server_call.send_initial_metadata
[all …]
/external/grpc-grpc/src/ruby/spec/
Dclient_server_spec.rb30 server_call = recvd_rpc.call
32 server_batch = server_call.run_batch(ops)
34 server_call
69 server_call = nil
72 server_call = server_allows_client_to_proceed
92 server_batch = server_call.run_batch(server_ops)
107 server_call = nil
110 server_call = server_allows_client_to_proceed
131 server_batch = server_call.run_batch(server_ops)
149 server_call = nil
[all …]
/external/grpc-grpc/src/php/tests/unit_tests/
DEndToEndTest.php55 $server_call = $event->call;
57 $event = $server_call->startBatch([
82 unset($server_call);
106 $server_call = $event->call;
108 $event = $server_call->startBatch([
128 unset($server_call);
154 $server_call = $event->call;
156 $event = $server_call->startBatch([
188 unset($server_call);
282 $server_call = $event->call;
[all …]
DSecureEndToEndTest.php70 $server_call = $event->call;
72 $event = $server_call->startBatch([
98 unset($server_call);
123 $server_call = $event->call;
125 $event = $server_call->startBatch([
146 unset($server_call);
173 $server_call = $event->call;
175 $event = $server_call->startBatch([
207 unset($server_call);
DInterceptorTest.php250 unset($server_call);
282 unset($server_call);
308 unset($server_call);
327 $server_call = $event->call;
328 $event = $server_call->startBatch([
344 $server_call = $event->call;
345 $event = $server_call->startBatch([
359 unset($server_call);
383 unset($server_call);
DCallCredentialsTest.php93 $server_call = $event->call;
95 $event = $server_call->startBatch([
121 unset($server_call);
DCallInvokerTest.php211 $server_call = $event->call;
212 $event = $server_call->startBatch([
225 unset($server_call);
DCallCredentials2Test.php91 $server_call = $event->call;
93 $event = $server_call->startBatch([
119 unset($server_call);
/external/grpc-grpc/test/core/end2end/
Dinvalid_call_argument_test.cc47 grpc_call* server_call; member
105 grpc_server_request_call(g_state.server, &g_state.server_call, in prepare_test()
126 grpc_call_unref(g_state.server_call); in cleanup_test()
443 grpc_call_start_batch(g_state.server_call, g_state.ops, in test_send_close_from_client_on_server()
465 grpc_call_start_batch(g_state.server_call, g_state.ops, in test_recv_status_on_client_from_server()
487 grpc_call_start_batch(g_state.server_call, g_state.ops, in test_send_status_from_server_with_invalid_flags()
510 grpc_call_start_batch(g_state.server_call, g_state.ops, in test_too_many_trailing_metadata()
539 grpc_call_start_batch(g_state.server_call, g_state.ops, in test_send_server_status_twice()
558 grpc_call_start_batch(g_state.server_call, g_state.ops, in test_recv_close_on_server_with_invalid_flags()
582 grpc_call_start_batch(g_state.server_call, g_state.ops, in test_recv_close_on_server_twice()
/external/grpc-grpc/src/python/grpcio_tests/tests/unit/_cython/
Dcygrpc_test.py235 server_call = request_event.call
244 server_start_batch_result = server_call.start_server_batch([
311 del server_call
344 server_call = request_event.call
347 return self._perform_queue_operations(operations, server_call,
/external/pigweed/pw_rpc/
DBUILD.bazel94 "public/pw_rpc/internal/server_call.h",
99 "server_call.cc",
DCMakeLists.txt51 public/pw_rpc/internal/server_call.h
56 server_call.cc
DBUILD.gn94 "public/pw_rpc/internal/server_call.h",
96 "server_call.cc",
DAndroid.bp71 "server_call.cc",