| /external/grpc-grpc/test/cpp/end2end/ |
| D | filter_end2end_test.cc | 180 std::unique_ptr<ByteBuffer> send_buffer = in SendRpc() local
182 call->Write(*send_buffer, tag(2)); in SendRpc()
184 send_buffer.reset(); in SendRpc()
202 send_buffer = SerializeToByteBuffer(&send_response); in SendRpc()
203 stream.Write(*send_buffer, tag(6)); in SendRpc()
204 send_buffer.reset(); in SendRpc()
282 std::unique_ptr<ByteBuffer> send_buffer = in TEST_F() local
284 cli_stream->Write(*send_buffer, tag(3)); in TEST_F()
285 send_buffer.reset(); in TEST_F()
295 send_buffer = SerializeToByteBuffer(&send_response); in TEST_F()
[all …]
|
| D | generic_end2end_test.cc | 130 std::unique_ptr<ByteBuffer> send_buffer = in SendRpc() local
132 call->Write(*send_buffer, tag(2)); in SendRpc()
134 send_buffer.reset(); in SendRpc()
158 send_buffer = SerializeToByteBuffer(&send_response); in SendRpc()
159 stream.Write(*send_buffer, tag(6)); in SendRpc()
160 send_buffer.reset(); in SendRpc()
285 std::unique_ptr<ByteBuffer> send_buffer = in TEST_F() local
287 cli_stream->Write(*send_buffer, tag(3)); in TEST_F()
288 send_buffer.reset(); in TEST_F()
298 send_buffer = SerializeToByteBuffer(&send_response); in TEST_F()
[all …]
|
| D | hybrid_end2end_test.cc | 93 auto send_buffer = SerializeToByteBuffer(&send_response); in HandleRawEcho() local
94 response_writer.Finish(*send_buffer, Status::OK, tag(2)); in HandleRawEcho()
135 auto send_buffer = SerializeToByteBuffer(&send_response); in HandleRawClientStreaming() local
136 srv_stream.Finish(*send_buffer, Status::OK, tag(100)); in HandleRawClientStreaming()
171 auto send_buffer = SerializeToByteBuffer(&send_response); in HandleGenericEcho() local
172 stream->Write(*send_buffer, tag(3)); in HandleGenericEcho()
193 auto send_buffer = SerializeToByteBuffer(&send_response); in HandleGenericRequestStream() local
194 stream->Write(*send_buffer, tag(99)); in HandleGenericRequestStream()
|
| /external/walt/arduino/walt/ |
| D | walt.ino | 83 String send_buffer;
118 void send(char c) { send_buffer += c; }
119 void send(String s) { send_buffer += s; }
140 usbMIDI.sendSysEx(send_buffer.length(), (const uint8_t *)send_buffer.c_str());
142 send_buffer = MIDI_SYSEX_BEGIN;
144 Serial.write(send_buffer.c_str(), send_buffer.length());
146 send_buffer = String();
445 send_buffer = (serial_over_midi ? MIDI_SYSEX_BEGIN : String());
|
| /external/grpc-grpc/test/cpp/util/ |
| D | cli_call.cc | 83 grpc::ByteBuffer send_buffer(&req_slice, 1); in Write() local
84 call_->Write(send_buffer, tag(2)); in Write()
125 grpc::ByteBuffer send_buffer(&req_slice, 1); in WriteAndWait() local
128 call_->Write(send_buffer, tag(2)); in WriteAndWait()
|
| D | byte_buffer_test.cc | 108 ByteBuffer send_buffer; in TEST_F() local
113 buffer, &send_buffer, &owned); in TEST_F()
116 EXPECT_TRUE(send_buffer.Valid()); in TEST_F()
|
| /external/grpc-grpc/test/cpp/cocoapods/generic/ |
| D | generic.mm | 186 std::unique_ptr<ByteBuffer> send_buffer =
188 call->Write(*send_buffer, tag(2));
190 send_buffer.reset();
211 send_buffer = std::unique_ptr<ByteBuffer>(new ByteBuffer(recv_buffer));
212 stream.Write(*send_buffer, tag(6));
213 send_buffer.reset();
|
| /external/grpc-grpc/src/core/tsi/alts/handshaker/ |
| D | alts_handshaker_client.cc | 67 op->data.send_message.send_message = event->send_buffer; in make_grpc_call()
130 event->send_buffer = buffer; in handshaker_client_start_client()
178 event->send_buffer = buffer; in handshaker_client_start_server()
216 event->send_buffer = buffer; in handshaker_client_next()
|
| D | alts_tsi_event.h | 45 grpc_byte_buffer* send_buffer; member
|
| D | alts_tsi_event.cc | 67 grpc_byte_buffer_destroy(event->send_buffer); in alts_tsi_event_destroy()
|
| /external/grpc-grpc/test/core/tsi/alts/handshaker/ |
| D | alts_handshaker_client_test.cc | 124 ok &= (op->data.send_message.send_message == event->send_buffer); in validate_op()
170 deserialize_handshaker_req(CLIENT_START_REQ, event->send_buffer); in check_client_start_success()
213 deserialize_handshaker_req(SERVER_START_REQ, event->send_buffer); in check_server_start_success()
248 deserialize_handshaker_req(NEXT_REQ, event->send_buffer); in check_next_success()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_chttp2_transport.cc | 428 grpc_slice_buffer send_buffer; in BM_TransportStreamSend() local
429 grpc_slice_buffer_init(&send_buffer); in BM_TransportStreamSend()
430 grpc_slice_buffer_add(&send_buffer, grpc_slice_ref(send_slice)); in BM_TransportStreamSend()
431 send_stream.Init(&send_buffer, 0); in BM_TransportStreamSend()
432 grpc_slice_buffer_destroy(&send_buffer); in BM_TransportStreamSend()
|
| /external/webrtc/webrtc/base/ |
| D | virtualsocket_unittest.cc | 503 char send_buffer[kDataSize], recv_buffer[kDataSize]; in TcpSendTest() local
505 send_buffer[i] = static_cast<char>(i % 256); in TcpSendTest()
510 int result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest()
519 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest()
528 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest()
542 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest()
572 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest()
596 EXPECT_EQ(0, memcmp(recv_buffer, send_buffer, kDataSize)); in TcpSendTest()
|
| D | socket_unittest.cc | 680 scoped_ptr<char[]> send_buffer(new char[kDataSize]); in TcpInternal() local
684 send_buffer[i] = static_cast<char>(i % 256); in TcpInternal()
725 int sent = accepted->Send(send_buffer.get() + send_pos, tosend); in TcpInternal()
785 EXPECT_EQ(0, memcmp(recv_buffer.get(), send_buffer.get(), kDataSize)); in TcpInternal()
|
| /external/grpc-grpc/examples/cpp/helloworld/cocoapods/HelloWorldCpp/ |
| D | ViewController.mm | 60 std::unique_ptr<grpc::ByteBuffer> send_buffer(new grpc::ByteBuffer(&send_slice, 1));
61 call->Write(*send_buffer, tag(2));
|
| /external/tensorflow/tensorflow/compiler/xla/service/gpu/ |
| D | nccl_all_reduce_thunk.cc | 290 void* send_buffer = participant.source_data.opaque(); in DoAllReduce() local
292 ncclResult_t result = ncclAllReduce(send_buffer, recv_buffer, in DoAllReduce()
|
| /external/grpc-grpc/src/csharp/ext/ |
| D | grpc_csharp_ext.c | 563 grpc_call* call, grpcsharp_batch_context* ctx, const char* send_buffer, in grpcsharp_call_start_unary() argument
579 ctx->send_message = string_to_byte_buffer(send_buffer, send_buffer_len); in grpcsharp_call_start_unary()
654 grpc_call* call, grpcsharp_batch_context* ctx, const char* send_buffer, in grpcsharp_call_start_server_streaming() argument
670 ctx->send_message = string_to_byte_buffer(send_buffer, send_buffer_len); in grpcsharp_call_start_server_streaming()
737 grpc_call* call, grpcsharp_batch_context* ctx, const char* send_buffer, in grpcsharp_call_send_message() argument
745 ctx->send_message = string_to_byte_buffer(send_buffer, send_buffer_len); in grpcsharp_call_send_message()
|
| /external/ppp/pppd/plugins/radius/ |
| D | sendserver.c | 212 char send_buffer[BUFFER_LEN]; in rc_send_server() local
262 auth = (AUTH_HDR *) send_buffer; in rc_send_server()
|
| /external/curl/lib/ |
| D | http.h | 161 Curl_send_buffer *send_buffer; /* used if the request couldn't be sent in member
|
| D | http.c | 1265 http->send_buffer = in; in Curl_add_buffer_send()
1582 if(http->send_buffer) { in Curl_http_done()
1583 Curl_add_buffer_free(&http->send_buffer); in Curl_http_done()
|