| /third_party/grpc/src/core/ext/filters/http/message_compress/ |
| D | message_compress_filter.cc | 180 send_message_batch_->payload->send_message.send_message->flags(); in SkipMessageCompression()
307 send_message_batch_->payload->send_message.send_message->flags(); in FinishSendMessage()
342 send_message_batch_->payload->send_message.send_message.reset( in FinishSendMessage()
365 send_message_batch_->payload->send_message.send_message->Pull( in PullSliceFromSendMessage()
379 send_message_batch_->payload->send_message.send_message->length()) { in ContinueReadingSendMessage()
383 while (send_message_batch_->payload->send_message.send_message->Next( in ContinueReadingSendMessage()
393 send_message_batch_->payload->send_message.send_message->length()) { in ContinueReadingSendMessage()
416 if (calld->slices_.length == calld->send_message_batch_->payload->send_message in OnSendMessageNextDone()
417 .send_message->length()) { in OnSendMessageNextDone()
449 send_message_batch_->payload->send_message.send_message->Shutdown( in CompressStartTransportStreamOpBatch()
[all …]
|
| /third_party/grpc/src/core/lib/transport/ |
| D | transport_op_string.cc | 77 if (op->send_message) { in grpc_transport_stream_op_batch_string()
78 if (op->payload->send_message.send_message != nullptr) { in grpc_transport_stream_op_batch_string()
81 op->payload->send_message.send_message->flags(), in grpc_transport_stream_op_batch_string()
82 op->payload->send_message.send_message->length())); in grpc_transport_stream_op_batch_string()
|
| D | transport.h | 167 send_message(false), in grpc_transport_stream_op_batch()
195 bool send_message : 1; member
227 (void)send_message.send_message.release(); in ~grpc_transport_stream_op_batch_payload()
258 grpc_core::OrphanablePtr<grpc_core::ByteStream> send_message; member
271 } send_message; member
|
| /third_party/grpc/src/cpp/common/ |
| D | channel_filter.h | 185 grpc_core::OrphanablePtr<grpc_core::ByteStream>* send_message() const { in send_message() function
186 return op_->send_message ? &op_->payload->send_message.send_message in send_message()
190 grpc_core::OrphanablePtr<grpc_core::ByteStream> send_message) { in set_send_message() argument
191 op_->send_message = true; in set_send_message()
192 op_->payload->send_message.send_message = std::move(send_message); in set_send_message()
|
| /third_party/grpc/src/core/ext/filters/workarounds/ |
| D | workaround_cronet_compression_filter.cc | 93 if (op->send_message) { in cronet_compression_start_transport_stream_op_batch()
97 op->payload->send_message.send_message->set_flags( in cronet_compression_start_transport_stream_op_batch()
98 op->payload->send_message.send_message->flags() | in cronet_compression_start_transport_stream_op_batch()
|
| /third_party/grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 315 batch->payload->send_message.send_message->length(), in update_path_for_get()
329 batch->payload->send_message.send_message->length(), in update_path_for_get()
387 if (batch->send_message && in http_client_start_transport_stream_op_batch()
390 batch->payload->send_message.send_message->length() < in http_client_start_transport_stream_op_batch()
394 std::move(batch->payload->send_message.send_message)); in http_client_start_transport_stream_op_batch()
396 batch->payload->send_message.send_message.reset( in http_client_start_transport_stream_op_batch()
409 batch->send_message = false; in http_client_start_transport_stream_op_batch()
|
| /third_party/grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 498 s->send_message_op->payload->send_message.send_message.reset(); in fail_helper_locked()
541 sender->send_message_op->payload->send_message.send_message->length(); in message_transfer_locked()
551 sender->send_message_op->payload->send_message.send_message->Next( in message_transfer_locked()
554 sender->send_message_op->payload->send_message.send_message->Pull( in message_transfer_locked()
564 sender->send_message_op->payload->send_message.send_message.reset(); in message_transfer_locked()
617 s->send_message_op->payload->send_message.send_message.reset(); in op_state_machine_locked()
779 s->send_message_op->payload->send_message.send_message.reset(); in op_state_machine_locked()
780 s->send_message_op->payload->send_message.stream_write_closed = true; in op_state_machine_locked()
866 s->send_message_op->payload->send_message.send_message.reset(); in op_state_machine_locked()
989 op->send_message ? " send_message" : "", in perform_stream_op()
[all …]
|
| /third_party/grpc/test/core/end2end/tests/ |
| D | retry_streaming_after_commit.cc | 190 op->data.send_message.send_message = request_payload; in test_retry_streaming_after_commit()
232 op->data.send_message.send_message = response_payload; in test_retry_streaming_after_commit()
245 op->data.send_message.send_message = request2_payload; in test_retry_streaming_after_commit()
272 op->data.send_message.send_message = response2_payload; in test_retry_streaming_after_commit()
|
| D | cancel_after_round_trip.cc | 168 op->data.send_message.send_message = request_payload; in test_cancel_after_round_trip()
206 op->data.send_message.send_message = response_payload1; in test_cancel_after_round_trip()
251 op->data.send_message.send_message = response_payload2; in test_cancel_after_round_trip()
|
| D | retry_streaming_succeeds_before_replay_finished.cc | 196 op->data.send_message.send_message = request_payload; in test_retry_streaming_succeeds_before_replay_finished()
235 op->data.send_message.send_message = request2_payload; in test_retry_streaming_succeeds_before_replay_finished()
257 op->data.send_message.send_message = request3_payload; in test_retry_streaming_succeeds_before_replay_finished()
347 op->data.send_message.send_message = response_payload; in test_retry_streaming_succeeds_before_replay_finished()
|
| D | retry_streaming.cc | 213 op->data.send_message.send_message = request_payload; in test_retry_streaming()
252 op->data.send_message.send_message = request2_payload; in test_retry_streaming()
346 op->data.send_message.send_message = request3_payload; in test_retry_streaming()
377 op->data.send_message.send_message = response_payload; in test_retry_streaming()
|
| D | retry_recv_message.cc | 170 op->data.send_message.send_message = request_payload; in test_retry_recv_message()
210 op->data.send_message.send_message = response_payload; in test_retry_recv_message()
|
| D | cancel_after_client_done.cc | 147 op->data.send_message.send_message = request_payload; in test_cancel_after_accept_and_writes_closed()
193 op->data.send_message.send_message = response_payload; in test_cancel_after_accept_and_writes_closed()
|
| D | cancel_after_accept.cc | 173 op->data.send_message.send_message = request_payload; in test_cancel_after_accept()
210 op->data.send_message.send_message = response_payload; in test_cancel_after_accept()
|
| D | stream_compression_compressed_payload.cc | 172 op->data.send_message.send_message = request_payload; in request_for_disabled_algorithm()
343 op->data.send_message.send_message = request_payload; in request_with_payload_template()
430 op->data.send_message.send_message = request_payload; in request_with_payload_template()
460 op->data.send_message.send_message = response_payload; in request_with_payload_template()
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_call_create.cc | 195 op->data.send_message.send_message = request_payload_send; in BM_LameChannelCallCreateCore()
269 op->data.send_message.send_message = request_payload_send; in BM_LameChannelCallCreateCoreSeparateBatch()
741 grpc_byte_buffer* send_message = grpc_raw_byte_buffer_create(&slice, 1); in BM_IsolatedCall_Unary() local
753 ops[1].data.send_message.send_message = send_message; in BM_IsolatedCall_Unary()
777 grpc_byte_buffer_destroy(send_message); in BM_IsolatedCall_Unary()
787 grpc_byte_buffer* send_message = grpc_raw_byte_buffer_create(&slice, 1); in BM_IsolatedCall_StreamingSend() local
806 ops[0].data.send_message.send_message = send_message; in BM_IsolatedCall_StreamingSend()
817 grpc_byte_buffer_destroy(send_message); in BM_IsolatedCall_StreamingSend()
|
| /third_party/grpc/examples/python/debug/ |
| D | BUILD.bazel | 30 name = "send_message",
32 srcs = ["send_message.py"],
59 ":send_message",
|
| /third_party/grpc/src/csharp/ext/ |
| D | grpc_csharp_ext.c | 61 grpc_byte_buffer* send_message; member
212 grpc_byte_buffer_destroy(ctx->send_message); in grpcsharp_batch_context_reset()
619 ctx->send_message = in grpcsharp_call_start_unary()
621 ops[1].data.send_message.send_message = ctx->send_message; in grpcsharp_call_start_unary()
666 grpc_byte_buffer* send_message = in grpcsharp_test_call_start_unary_echo() local
669 ctx->recv_message = send_message; // echo message sent by the client as if in grpcsharp_test_call_start_unary_echo()
739 ctx->send_message = in grpcsharp_call_start_server_streaming()
741 ops[1].data.send_message.send_message = ctx->send_message; in grpcsharp_call_start_server_streaming()
819 ctx->send_message = in grpcsharp_call_send_message()
821 ops[0].data.send_message.send_message = ctx->send_message; in grpcsharp_call_send_message()
[all …]
|
| /third_party/grpc/examples/python/debug/test/ |
| D | _debug_example_test.py | 24 from examples.python.debug import send_message
45 send_message.run(addr=address, n=_NUMBER_OF_MESSAGES)
|
| /third_party/grpc/src/ruby/spec/ |
| D | client_server_spec.rb | 82 expect(client_batch.send_message).to be true
120 expect(client_batch.send_message).to be true
134 expect(server_batch.send_message).to be true
165 expect(client_batch.send_message).to be true
179 expect(server_batch.send_message).to be true
208 expect(client_batch.send_message).to be true
242 expect(client_batch.send_message).to be true
255 expect(server_batch.send_message).to be true
|
| /third_party/grpc/test/core/fling/ |
| D | client.cc | 60 op->data.send_message.send_message = the_buffer; in init_ping_pong_request()
114 stream_step_ops[0].data.send_message.send_message = the_buffer; in init_ping_pong_stream()
|
| D | server.cc | 104 op->data.send_message.send_message = payload_buffer; in handle_unary_method()
149 write_op.data.send_message.send_message = payload_buffer; in start_write_op()
|
| /third_party/grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 338 if (op->send_message) { in add_to_storage()
970 } else if (curr_op->send_message && in op_can_be_run()
974 } else if (curr_op->send_message && in op_can_be_run()
1067 if (!stream_op->send_message && !stream_op->send_trailing_metadata) { in execute_stream_op()
1072 } else if (stream_op->send_message && in execute_stream_op()
1086 stream_op->payload->send_message.send_message->length()) { in execute_stream_op()
1090 if (!stream_op->payload->send_message.send_message->Next( in execute_stream_op()
1091 stream_op->payload->send_message.send_message->length(), in execute_stream_op()
1097 stream_op->payload->send_message.send_message->Pull(&slice)) { in execute_stream_op()
1106 stream_op->payload->send_message.send_message->flags()); in execute_stream_op()
[all …]
|
| /third_party/grpc/src/php/tests/unit_tests/ |
| D | EndToEndTest.php | 150 $this->assertTrue($event->send_message);
170 $this->assertTrue($event->send_message);
270 $this->assertTrue($event->send_message);
309 $this->assertTrue($event->send_message);
348 $this->assertTrue($event->send_message);
386 $this->assertTrue($event->send_message);
425 $this->assertTrue($event->send_message);
|
| /third_party/grpc/src/core/ext/filters/message_size/ |
| D | message_size_filter.cc | 259 if (op->send_message && calld->limits.max_send_size >= 0 && in message_size_start_transport_stream_op_batch()
260 op->payload->send_message.send_message->length() > in message_size_start_transport_stream_op_batch()
268 op->payload->send_message.send_message->length(), in message_size_start_transport_stream_op_batch()
|