Searched refs:server_call (Results 1 – 11 of 11) sorted by relevance
| /external/grpc-grpc/src/ruby/spec/generic/ |
| D | active_call_spec.rb | 29 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 …]
|
| D | client_stub_spec.rb | 685 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/ |
| D | client_server_spec.rb | 30 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/ |
| D | EndToEndTest.php | 55 $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 …]
|
| D | SecureEndToEndTest.php | 70 $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);
|
| D | InterceptorTest.php | 250 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);
|
| D | CallCredentialsTest.php | 93 $server_call = $event->call;
95 $event = $server_call->startBatch([
121 unset($server_call);
|
| D | CallCredentials2Test.php | 91 $server_call = $event->call;
93 $event = $server_call->startBatch([
119 unset($server_call);
|
| D | CallInvokerTest.php | 211 $server_call = $event->call;
212 $event = $server_call->startBatch([
225 unset($server_call);
|
| /external/grpc-grpc/test/core/end2end/ |
| D | invalid_call_argument_test.cc | 47 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/ |
| D | cygrpc_test.py | 235 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,
|