/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/tensorflow/tensorflow/compiler/xla/service/gpu/ |
D | nccl_all_to_all_thunk.cc | 82 const uint8* send_buffer = static_cast<uint8*>( in RunNcclCollective() local 100 XLA_CUDA_RETURN_IF_ERROR(ncclSend(send_buffer + rank * chunk_bytes, in RunNcclCollective() 114 const uint8* send_buffer = static_cast<uint8*>( in RunNcclCollective() local 125 XLA_CUDA_RETURN_IF_ERROR(ncclSend(send_buffer, buffer.element_count, in RunNcclCollective()
|
D | nccl_all_gather_thunk.cc | 82 const void* send_buffer = in RunNcclCollective() local 95 send_buffer, recv_buffer, buffer.element_count, in RunNcclCollective() 98 XLA_CUDA_RETURN_IF_ERROR(ncclAllGather(send_buffer, recv_buffer, in RunNcclCollective()
|
D | nccl_all_reduce_thunk.cc | 133 const void* send_buffer = in RunNcclCollective() local 146 send_buffer, recv_buffer, buffer.element_count, in RunNcclCollective() 149 XLA_CUDA_RETURN_IF_ERROR(ncclAllReduce(send_buffer, recv_buffer, in RunNcclCollective()
|
/external/rust/crates/criterion/src/ |
D | connection.rs | 66 send_buffer: Vec<u8>, field 100 send_buffer: vec![], in new() 117 self.send_buffer.truncate(0); in send() 118 serde_cbor::to_writer(&mut self.send_buffer, message)?; in send() 119 let size = u32::try_from(self.send_buffer.len()).unwrap(); in send() 122 self.socket.write_all(&self.send_buffer)?; in send()
|
/external/walt/arduino/walt/ |
D | walt.ino | 86 String send_buffer; 121 void send(char c) { send_buffer += c; } 122 void send(String s) { send_buffer += s; } 143 usbMIDI.sendSysEx(send_buffer.length(), (const uint8_t *)send_buffer.c_str()); 145 send_buffer = MIDI_SYSEX_BEGIN; 147 Serial.write(send_buffer.c_str(), send_buffer.length()); 149 send_buffer = String(); 472 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/rust/crates/grpcio-sys/grpc/src/core/tsi/alts/handshaker/ |
D | alts_handshaker_client.cc | 72 grpc_byte_buffer* send_buffer; member 114 grpc_byte_buffer_destroy(client->send_buffer); in handshaker_client_send_buffer_destroy() 115 client->send_buffer = nullptr; in handshaker_client_send_buffer_destroy() 133 grpc_byte_buffer_destroy(client->send_buffer); in alts_grpc_handshaker_client_unref() 135 client->send_buffer = nullptr; in alts_grpc_handshaker_client_unref() 331 op->data.send_message.send_message = client->send_buffer; in continue_make_grpc_call() 537 client->send_buffer = buffer; in handshaker_client_start_client() 594 client->send_buffer = buffer; in handshaker_client_start_server() 632 client->send_buffer = buffer; in handshaker_client_next() 706 client->send_buffer = nullptr; in alts_grpc_handshaker_client_create() [all …]
|
/external/tensorflow/tensorflow/stream_executor/tpu/ |
D | tpu_stream.h | 66 stream_executor::DeviceMemoryBase send_buffer, in EnqueueOnTpuDeviceSendRecvLocal() argument 71 stream_, ApiConverter::ToC(send_buffer), in EnqueueOnTpuDeviceSendRecvLocal()
|
D | tpu_stream_interface.h | 32 stream_executor::DeviceMemoryBase send_buffer,
|
/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/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/rust/crates/grpcio-sys/ |
D | grpc_wrap.cc | 471 grpc_call* call, grpcwrap_batch_context* ctx, grpc_slice* send_buffer, in grpcwrap_call_start_unary() argument 486 ctx->send_message = grpc_raw_byte_buffer_create(send_buffer, 1); in grpcwrap_call_start_unary() 561 grpc_call* call, grpcwrap_batch_context* ctx, grpc_slice* send_buffer, in grpcwrap_call_start_server_streaming() argument 576 ctx->send_message = grpc_raw_byte_buffer_create(send_buffer, 1); in grpcwrap_call_start_server_streaming() 643 grpc_call* call, grpcwrap_batch_context* ctx, grpc_slice* send_buffer, in grpcwrap_call_send_message() argument 650 ctx->send_message = grpc_raw_byte_buffer_create(send_buffer, 1); in grpcwrap_call_send_message()
|
/external/webrtc/rtc_base/ |
D | virtual_socket_unittest.cc | 540 char send_buffer[kDataSize], recv_buffer[kDataSize]; in TcpSendTest() local 542 send_buffer[i] = static_cast<char>(i % 256); in TcpSendTest() 547 int result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 556 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 565 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 579 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 609 result = a->Send(send_buffer + send_pos, kDataSize - send_pos); in TcpSendTest() 633 EXPECT_EQ(0, memcmp(recv_buffer, send_buffer, kDataSize)); in TcpSendTest()
|
D | socket_unittest.cc | 743 rtc::Buffer send_buffer(0, data_size); in TcpInternal() local 747 send_buffer.AppendData(&ch, sizeof(ch)); in TcpInternal() 757 while (recv_buffer.size() < send_buffer.size()) { in TcpInternal() 759 while (writable && sent_size < send_buffer.size()) { in TcpInternal() 760 int unsent_size = static_cast<int>(send_buffer.size() - sent_size); in TcpInternal() 761 int sent = sender->Send(send_buffer.data() + sent_size, unsent_size); in TcpInternal() 828 EXPECT_EQ(recv_buffer, send_buffer); in TcpInternal()
|
/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/curl/lib/ |
D | http.h | 138 struct dynbuf send_buffer; /* used if the request couldn't be sent in one member
|