| /third_party/grpc/test/cpp/end2end/ |
| D | filter_end2end_test.cc | 191 std::unique_ptr<ByteBuffer> send_buffer = in SendRpc() local
193 call->Write(*send_buffer, tag(2)); in SendRpc()
195 send_buffer.reset(); in SendRpc()
213 send_buffer = SerializeToByteBuffer(&send_response); in SendRpc()
214 stream.Write(*send_buffer, tag(6)); in SendRpc()
215 send_buffer.reset(); in SendRpc()
293 std::unique_ptr<ByteBuffer> send_buffer = in TEST_F() local
295 cli_stream->Write(*send_buffer, tag(3)); in TEST_F()
296 send_buffer.reset(); in TEST_F()
306 send_buffer = SerializeToByteBuffer(&send_response); in TEST_F()
[all …]
|
| D | generic_end2end_test.cc | 145 std::unique_ptr<ByteBuffer> send_buffer = in SendRpc() local
147 call->Write(*send_buffer, tag(2)); in SendRpc()
149 send_buffer.reset(); in SendRpc()
173 send_buffer = SerializeToByteBuffer(&send_response); in SendRpc()
174 stream.Write(*send_buffer, tag(6)); in SendRpc()
175 send_buffer.reset(); in SendRpc()
352 std::unique_ptr<ByteBuffer> send_buffer = in TEST_F() local
354 cli_stream->Write(*send_buffer, tag(3)); in TEST_F()
355 send_buffer.reset(); in TEST_F()
365 send_buffer = SerializeToByteBuffer(&send_response); in TEST_F()
[all …]
|
| D | hybrid_end2end_test.cc | 100 auto send_buffer = SerializeToByteBuffer(&send_response); in HandleRawEcho() local
101 response_writer.Finish(*send_buffer, Status::OK, tag(2)); in HandleRawEcho()
142 auto send_buffer = SerializeToByteBuffer(&send_response); in HandleRawClientStreaming() local
143 srv_stream.Finish(*send_buffer, Status::OK, tag(100)); in HandleRawClientStreaming()
178 auto send_buffer = SerializeToByteBuffer(&send_response); in HandleGenericEcho() local
179 stream->Write(*send_buffer, tag(3)); in HandleGenericEcho()
200 auto send_buffer = SerializeToByteBuffer(&send_response); in HandleGenericRequestStream() local
201 stream->Write(*send_buffer, tag(99)); in HandleGenericRequestStream()
|
| D | server_interceptors_end2end_test.cc | 543 std::unique_ptr<ByteBuffer> send_buffer = in TEST_F() local
545 call->Write(*send_buffer, tag(2)); in TEST_F()
547 send_buffer.reset(); in TEST_F()
566 send_buffer = SerializeToByteBuffer(&send_response); in TEST_F()
567 stream.Write(*send_buffer, tag(6)); in TEST_F()
568 send_buffer.reset(); in TEST_F()
|
| /third_party/libuv/test/ |
| D | test-tcp-writealot.c | 38 static char* send_buffer; variable
129 send_bufs[j] = uv_buf_init(send_buffer + bytes_sent, CHUNK_SIZE); in connect_cb()
154 send_buffer = calloc(1, TOTAL_BYTES); in TEST_IMPL()
155 ASSERT_NOT_NULL(send_buffer); in TEST_IMPL()
176 free(send_buffer); in TEST_IMPL()
|
| /third_party/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 | 113 ByteBuffer send_buffer; in TEST_F() local
118 buffer, &send_buffer, &owned); in TEST_F()
121 EXPECT_TRUE(send_buffer.Valid()); in TEST_F()
|
| /third_party/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();
|
| /third_party/grpc/src/core/tsi/alts/handshaker/ |
| D | alts_handshaker_client.cc | 72 grpc_byte_buffer* send_buffer = nullptr; 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()
330 op->data.send_message.send_message = client->send_buffer; in continue_make_grpc_call()
536 client->send_buffer = buffer; in handshaker_client_start_client()
593 client->send_buffer = buffer; in handshaker_client_start_server()
631 client->send_buffer = buffer; in handshaker_client_next()
748 return client->send_buffer; in alts_handshaker_client_get_send_buffer_for_testing()
|
| /third_party/ffmpeg/libavformat/ |
| D | ipmovie.c | 94 uint8_t send_buffer; member
183 AV_WL8(pkt->data + 1, s->send_buffer); in load_ipmovie_packet()
189 s->send_buffer = 0; in load_ipmovie_packet()
476 s->send_buffer = 1; in process_ipmovie_chunk()
655 ipmovie->send_buffer = ipmovie->frame_format = 0; in ipmovie_read_header()
|
| /third_party/NuttX/drivers/usbdev/gadget/ |
| D | cdcacm.c | 82 char *send_buffer; /* Record the offset of the sent data */ member
374 …data_size = (RING_BUFFER_SIZE + (wrcontainer->receive_buffer - wrcontainer->send_buffer)) % RING_B… in cdcacm_sndpacket()
378 length = RING_BUFFER_SIZE - (wrcontainer->send_buffer - wrcontainer->data_buffer); in cdcacm_sndpacket()
389 ret = memcpy_s(req->buf, reqlen, wrcontainer->send_buffer, length); in cdcacm_sndpacket()
401 wrcontainer->send_buffer = wrcontainer->data_buffer + data_size - length; in cdcacm_sndpacket()
405 ret = memcpy_s(req->buf, data_size, wrcontainer->send_buffer, data_size); in cdcacm_sndpacket()
411 wrcontainer->send_buffer += data_size; in cdcacm_sndpacket()
1219 wrcontainer->send_buffer = wrcontainer->data_buffer; in cdcacm_bind()
|
| /third_party/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));
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_chttp2_transport.cc | 446 grpc_slice_buffer send_buffer; in BM_TransportStreamSend() local
447 grpc_slice_buffer_init(&send_buffer); in BM_TransportStreamSend()
448 grpc_slice_buffer_add(&send_buffer, grpc_slice_ref(send_slice)); in BM_TransportStreamSend()
449 send_stream.Init(&send_buffer, 0); in BM_TransportStreamSend()
450 grpc_slice_buffer_destroy(&send_buffer); in BM_TransportStreamSend()
|
| /third_party/grpc/src/csharp/ext/ |
| D | grpc_csharp_ext.c | 604 grpc_slice_buffer* send_buffer, uint32_t write_flags, in grpcsharp_call_start_unary() argument
620 grpcsharp_create_byte_buffer_from_stolen_slices(send_buffer); in grpcsharp_call_start_unary()
660 grpc_slice_buffer* send_buffer, uint32_t write_flags, in grpcsharp_test_call_start_unary_echo() argument
667 grpcsharp_create_byte_buffer_from_stolen_slices(send_buffer); in grpcsharp_test_call_start_unary_echo()
724 grpc_slice_buffer* send_buffer, uint32_t write_flags, in grpcsharp_call_start_server_streaming() argument
740 grpcsharp_create_byte_buffer_from_stolen_slices(send_buffer); in grpcsharp_call_start_server_streaming()
812 grpc_slice_buffer* send_buffer, uint32_t write_flags, in grpcsharp_call_send_message() argument
820 grpcsharp_create_byte_buffer_from_stolen_slices(send_buffer); in grpcsharp_call_send_message()
|
| /third_party/curl/lib/ |
| D | http.h | 192 struct dynbuf send_buffer; /* used if the request couldn't be sent in one member
|
| D | http.c | 1400 http->send_buffer = *in; /* copy the whole struct */ in Curl_buffer_send()
1646 Curl_dyn_free(&http->send_buffer); in Curl_http_done()
|
| /third_party/ffmpeg/libavcodec/ |
| D | interplayvideo.c | 1199 int send_buffer; in ipvideo_decode_frame() local
1226 send_buffer = AV_RL8(buf + 1); in ipvideo_decode_frame()
1342 *got_frame = send_buffer; in ipvideo_decode_frame()
|
| /third_party/gstreamer/gstreamer/tests/check/generic/ |
| D | sinks.c | 1034 send_buffer (GstPad * sinkpad) in send_buffer() function
1106 g_thread_try_new ("gst-check", (GThreadFunc) send_buffer, sinkpad, NULL); in GST_START_TEST()
|
| /third_party/libcoap/src/ |
| D | coap_mbedtls.c | 183 coap_dgram_write(void *ctx, const unsigned char *send_buffer, in coap_dgram_write() argument
191 result = coap_session_send(c_session, send_buffer, send_buffer_length); in coap_dgram_write()
|
| D | coap_gnutls.c | 1963 coap_dgram_write(gnutls_transport_ptr_t context, const void *send_buffer, in coap_dgram_write() argument
1969 result = coap_session_send(c_session, send_buffer, send_buffer_length); in coap_dgram_write()
|
| /third_party/gstreamer/gstreamer/ |
| D | ChangeLog | 97014 * tests/check/generic/sinks.c: (send_buffer):
98171 (async_done_handoff), (async_done_func), (send_buffer),
|