Home
last modified time | relevance | path

Searched refs:read_buffer (Results 1 – 25 of 81) sorted by relevance

1234

/third_party/grpc/src/core/lib/channel/
Dhandshaker.cc45 args->read_buffer != nullptr ? args->read_buffer->length : 0; in HandshakerArgsString()
50 grpc_channel_args_string(args->args), args->read_buffer, in HandshakerArgsString()
153 grpc_slice_buffer_destroy_internal(args_.read_buffer); in CallNextHandshakerLocked()
154 gpr_free(args_.read_buffer); in CallNextHandshakerLocked()
155 args_.read_buffer = nullptr; in CallNextHandshakerLocked()
222 args_.read_buffer = in DoHandshake()
223 static_cast<grpc_slice_buffer*>(gpr_malloc(sizeof(*args_.read_buffer))); in DoHandshake()
224 grpc_slice_buffer_init(args_.read_buffer); in DoHandshake()
227 grpc_slice_buffer_swap(args_.read_buffer, in DoHandshake()
/third_party/grpc/src/core/ext/filters/client_channel/
Dhttp_connect_handshaker.cc102 read_buffer_to_destroy_ = args_->read_buffer; in CleanupArgsForFailureLocked()
103 args_->read_buffer = nullptr; in CleanupArgsForFailureLocked()
160 handshaker->args_->endpoint, handshaker->args_->read_buffer, in OnWriteDone()
191 for (size_t i = 0; i < handshaker->args_->read_buffer->count; ++i) { in OnReadDone()
192 if (GRPC_SLICE_LENGTH(handshaker->args_->read_buffer->slices[i]) > 0) { in OnReadDone()
195 handshaker->args_->read_buffer->slices[i], in OnReadDone()
207 GRPC_SLICE_LENGTH(handshaker->args_->read_buffer->slices[i])) { in OnReadDone()
210 grpc_slice_split_tail(&handshaker->args_->read_buffer->slices[i], in OnReadDone()
214 &handshaker->args_->read_buffer->slices[i + 1], in OnReadDone()
215 handshaker->args_->read_buffer->count - i - 1); in OnReadDone()
[all …]
/third_party/boringssl/src/ssl/
Dssl_buffer.cc106 SSLBuffer *buf = &ssl->s3->read_buffer; in dtls_read_buffer_next_packet()
127 SSLBuffer *buf = &ssl->s3->read_buffer; in tls_read_buffer_extend_to()
152 ssl->s3->read_buffer.DiscardConsumed(); in ssl_read_buffer_extend_to()
163 if (!ssl->s3->read_buffer.EnsureCap(ssl_record_prefix_len(ssl), len)) { in ssl_read_buffer_extend_to()
183 ssl->s3->read_buffer.DiscardConsumed(); in ssl_read_buffer_extend_to()
192 ssl->s3->read_buffer.Consume(consumed); in ssl_handle_open_record()
196 ssl->s3->read_buffer.DiscardConsumed(); in ssl_handle_open_record()
/third_party/grpc/test/core/util/
Dmock_endpoint.cc41 grpc_slice_buffer read_buffer; member
51 if (m->read_buffer.count > 0) { in me_read()
52 grpc_slice_buffer_swap(&m->read_buffer, slices); in me_read()
95 grpc_slice_buffer_destroy(&m->read_buffer); in me_destroy()
132 grpc_slice_buffer_init(&m->read_buffer); in grpc_mock_endpoint_create()
147 grpc_slice_buffer_add(&m->read_buffer, slice); in grpc_mock_endpoint_put_read()
Dpassthru_endpoint.cc45 grpc_slice_buffer read_buffer; member
68 } else if (m->read_buffer.count > 0) { in me_read()
69 grpc_slice_buffer_swap(&m->read_buffer, slices); in me_read()
99 grpc_slice_buffer_add(&m->read_buffer, in me_write()
145 grpc_slice_buffer_destroy_internal(&p->client.read_buffer); in me_destroy()
146 grpc_slice_buffer_destroy_internal(&p->server.read_buffer); in me_destroy()
190 grpc_slice_buffer_init(&m->read_buffer); in half_init()
/third_party/libsnd/ossfuzz/
Dsndfile_fuzzer.cc103 float* read_buffer = NULL; in LLVMFuzzerTestOneInput() local
134 read_buffer = (float*)malloc(sizeof(float) * sndfile_info.channels); in LLVMFuzzerTestOneInput()
135 if (read_buffer == NULL) in LLVMFuzzerTestOneInput()
140 while (sf_readf_float(sndfile, read_buffer, 1)) in LLVMFuzzerTestOneInput()
152 free(read_buffer); in LLVMFuzzerTestOneInput()
/third_party/ltp/testcases/kernel/syscalls/sync/
Dsync02.c94 char read_buffer[BUFSIZ]; /* buffer used to read data from file */ in main() local
121 if (read(fildes, read_buffer, in main()
122 sizeof(read_buffer)) > 0) { in main()
123 if (strcmp(read_buffer, write_buffer)) { in main()
/third_party/grpc/src/core/lib/security/transport/
Dsecure_endpoint.cc92 grpc_slice_buffer* read_buffer = nullptr; member
151 grpc_slice_buffer_add(ep->read_buffer, ep->read_staging_buffer); in flush_read_staging_buffer()
160 for (i = 0; i < ep->read_buffer->count; i++) { in call_read_cb()
161 char* data = grpc_dump_slice(ep->read_buffer->slices[i], in call_read_cb()
167 ep->read_buffer = nullptr; in call_read_cb()
181 grpc_slice_buffer_reset_and_unref_internal(ep->read_buffer); in on_read()
190 ep->zero_copy_protector, &ep->source_buffer, ep->read_buffer); in on_read()
234 ep->read_buffer, in on_read()
247 grpc_slice_buffer_reset_and_unref_internal(ep->read_buffer); in on_read()
261 ep->read_buffer = slices; in endpoint_read()
[all …]
Dsecurity_handshaker.cc145 size_t bytes_in_read_buffer = args_->read_buffer->length; in MoveReadBufferIntoHandshakeBuffer()
152 while (args_->read_buffer->count > 0) { in MoveReadBufferIntoHandshakeBuffer()
153 grpc_slice* next_slice = grpc_slice_buffer_peek_first(args_->read_buffer); in MoveReadBufferIntoHandshakeBuffer()
157 grpc_slice_buffer_remove_first(args_->read_buffer); in MoveReadBufferIntoHandshakeBuffer()
167 read_buffer_to_destroy_ = args_->read_buffer; in CleanupArgsForFailureLocked()
168 args_->read_buffer = nullptr; in CleanupArgsForFailureLocked()
295 args_->endpoint, args_->read_buffer, in OnHandshakeNextDoneLocked()
328 args_->endpoint, args_->read_buffer, in OnHandshakeNextDoneLocked()
435 h->args_->endpoint, h->args_->read_buffer, in OnHandshakeDataSentToPeerFn()
/third_party/boost/libs/asio/example/cpp03/services/
Ddaytime_client.cpp18 char read_buffer[1024]; variable
25 std::cout.write(read_buffer, bytes_transferred); in read_handler()
27 s->async_read_some(boost::asio::buffer(read_buffer), in read_handler()
53 s->async_read_some(boost::asio::buffer(read_buffer), in connect_handler()
/third_party/boost/doc/html/boost_asio/example/cpp03/services/
Ddaytime_client.cpp18 char read_buffer[1024]; variable
25 std::cout.write(read_buffer, bytes_transferred); in read_handler()
27 s->async_read_some(boost::asio::buffer(read_buffer), in read_handler()
53 s->async_read_some(boost::asio::buffer(read_buffer), in connect_handler()
/third_party/grpc/test/core/iomgr/ios/CFStreamTests/
DCFStreamEndpointTests.mm163 char read_buffer[kBufferSize];
176 ssize_t size = recv(svr_fd_, read_buffer, kBufferSize, 0);
182 XCTAssertEqual(memcmp(read_buffer, write_buffer, kBufferSize), 0);
183 ssize_t send_size = send(svr_fd_, read_buffer, kBufferSize, 0);
196 XCTAssertTrue(compare_slice_buffer_with_buffer(&read_slices, read_buffer, kBufferSize));
216 char read_buffer[kBufferSize];
233 ssize_t size = recv(svr_fd_, read_buffer, kBufferSize, 0);
239 XCTAssertEqual(memcmp(read_buffer, write_buffer, kBufferSize), 0);
265 char read_buffer[kBufferSize];
282 ssize_t size = recv(svr_fd_, read_buffer, kBufferSize, 0);
[all …]
/third_party/grpc/test/core/transport/chttp2/
Dsettings_timeout_test.cc130 grpc_slice_buffer read_buffer; in ReadUntilError() local
131 grpc_slice_buffer_init(&read_buffer); in ReadUntilError()
138 grpc_endpoint_read(endpoint_, &read_buffer, state.closure(), in ReadUntilError()
145 gpr_log(GPR_INFO, "client read %" PRIuPTR " bytes", read_buffer.length); in ReadUntilError()
146 grpc_slice_buffer_reset_and_unref_internal(&read_buffer); in ReadUntilError()
150 grpc_slice_buffer_destroy_internal(&read_buffer); in ReadUntilError()
/third_party/skia/third_party/externals/microhttpd/src/microspdy/
Dstream.c51 memcpy(&stream_id, session->read_buffer + session->read_buffer_beginning, 4); in SPDYF_stream_new()
77 memcpy(&assoc_stream_id, session->read_buffer + session->read_buffer_beginning, 4); in SPDYF_stream_new()
83 priority = *(uint8_t *)(session->read_buffer + session->read_buffer_beginning) >> 5; in SPDYF_stream_new()
87 slot = *(uint8_t *)(session->read_buffer + session->read_buffer_beginning); in SPDYF_stream_new()
Dsession.c108 session->read_buffer + session->read_buffer_beginning, in spdyf_handler_read_syn_stream()
219 memcpy(&last_good_stream_id, session->read_buffer + session->read_buffer_beginning, 4); in spdyf_handler_read_goaway()
223 memcpy(&status_int, session->read_buffer + session->read_buffer_beginning, 4); in spdyf_handler_read_goaway()
289 memcpy(&stream_id, session->read_buffer + session->read_buffer_beginning, 4); in spdyf_handler_read_rst_stream()
293 memcpy(&status_int, session->read_buffer + session->read_buffer_beginning, 4); in spdyf_handler_read_rst_stream()
383 session->read_buffer + session->read_buffer_beginning, in spdyf_handler_read_data()
924 memmove(session->read_buffer, in SPDYF_session_read()
925 session->read_buffer + session->read_buffer_beginning, in SPDYF_session_read()
943 session->read_buffer + session->read_buffer_offset, in SPDYF_session_read()
1186 if(0x80 == *(uint8_t *)(session->read_buffer + session->read_buffer_beginning) in SPDYF_session_idle()
[all …]
/third_party/ltp/testcases/kernel/syscalls/mount/
Dmount03.c69 static char read_buffer[BUFSIZ]; variable
226 if (read(fildes, read_buffer, sizeof(read_buffer)) > 0) { in test_rwflag()
227 if (strcmp(read_buffer, write_buffer)) { in test_rwflag()
/third_party/grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc126 char* read_buffer = nullptr; member
292 if (s->state.rs.read_buffer && in null_and_maybe_free_read_buffer()
293 s->state.rs.read_buffer != s->state.rs.grpc_header_bytes) { in null_and_maybe_free_read_buffer()
294 gpr_free(s->state.rs.read_buffer); in null_and_maybe_free_read_buffer()
296 s->state.rs.read_buffer = nullptr; in null_and_maybe_free_read_buffer()
300 s->state.rs.read_buffer = s->state.rs.grpc_header_bytes; in read_grpc_header()
305 bidirectional_stream_read(s->cbs, s->state.rs.read_buffer, in read_grpc_header()
607 bidirectional_stream_read(s->cbs, s->state.rs.read_buffer, in on_read_completed()
617 s->cbs, s->state.rs.read_buffer + s->state.rs.received_bytes, in on_read_completed()
1226 reinterpret_cast<const uint8_t*>(stream_state->rs.read_buffer), in execute_stream_op()
[all …]
/third_party/grpc/src/core/ext/transport/chttp2/client/
Dchttp2_connector.cc159 grpc_slice_buffer_destroy_internal(args->read_buffer); in OnHandshakeDone()
160 gpr_free(args->read_buffer); in OnHandshakeDone()
180 args->read_buffer, in OnHandshakeDone()
/third_party/uboot/u-boot-2020.01/fs/ext4/
Dext4_write.c443 char *read_buffer = NULL; in ext4fs_delete_file() local
540 read_buffer = zalloc(fs->blksz); in ext4fs_delete_file()
541 if (!read_buffer) in ext4fs_delete_file()
543 start_block_address = read_buffer; in ext4fs_delete_file()
545 0, fs->blksz, read_buffer); in ext4fs_delete_file()
549 if (ext4fs_log_journal(read_buffer, blkno)) in ext4fs_delete_file()
552 read_buffer = read_buffer + blkoff; in ext4fs_delete_file()
553 inode_buffer = (struct ext2_inode *)read_buffer; in ext4fs_delete_file()
/third_party/glib/gio/
Dgdbusprivate.c371 gchar *read_buffer; member
468 g_free (worker->read_buffer); in _g_dbus_worker_unref()
729 message_len = g_dbus_message_bytes_needed ((guchar *) worker->read_buffer, in _g_dbus_worker_do_read_cb()
750 message = g_dbus_message_new_from_blob ((guchar *) worker->read_buffer, in _g_dbus_worker_do_read_cb()
757 s = _g_dbus_hexdump (worker->read_buffer, worker->read_buffer_cur_size, 2); in _g_dbus_worker_do_read_cb()
793 s = _g_dbus_hexdump (worker->read_buffer, worker->read_buffer_cur_size, 2); in _g_dbus_worker_do_read_cb()
841 …if (worker->read_buffer == NULL || worker->read_buffer_bytes_wanted > worker->read_buffer_allocate… in _g_dbus_worker_do_read_unlocked()
845 worker->read_buffer = g_realloc (worker->read_buffer, worker->read_buffer_allocated_size); in _g_dbus_worker_do_read_unlocked()
850 worker->read_buffer + worker->read_buffer_cur_size, in _g_dbus_worker_do_read_unlocked()
861 worker->read_buffer + worker->read_buffer_cur_size, in _g_dbus_worker_do_read_unlocked()
[all …]
/third_party/grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc268 grpc_slice_buffer_destroy_internal(args->read_buffer); in OnHandshakeDone()
269 gpr_free(args->read_buffer); in OnHandshakeDone()
295 grpc_chttp2_transport_start_reading(transport, args->read_buffer, in OnHandshakeDone()
311 grpc_slice_buffer_destroy_internal(args->read_buffer); in OnHandshakeDone()
312 gpr_free(args->read_buffer); in OnHandshakeDone()
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.h49 grpc_transport* transport, grpc_slice_buffer* read_buffer,
/third_party/python/Modules/
D_winapi.c97 PyObject *read_buffer; member
142 Py_CLEAR(self->read_buffer); in overlapped_dealloc()
238 if (self->completed && self->read_buffer != NULL) { in _winapi_Overlapped_GetOverlappedResult_impl()
239 assert(PyBytes_CheckExact(self->read_buffer)); in _winapi_Overlapped_GetOverlappedResult_impl()
240 if (transferred != PyBytes_GET_SIZE(self->read_buffer) && in _winapi_Overlapped_GetOverlappedResult_impl()
241 _PyBytes_Resize(&self->read_buffer, transferred)) in _winapi_Overlapped_GetOverlappedResult_impl()
262 res = self->read_buffer ? self->read_buffer : Py_None; in _winapi_Overlapped_getbuffer_impl()
357 self->read_buffer = NULL; in new_overlapped()
1535 overlapped->read_buffer = buf; in _winapi_ReadFile_impl()
/third_party/grpc/test/core/handshake/
Dreadahead_handshaker_server_ssl.cc62 grpc_endpoint_read(args->endpoint, args->read_buffer, on_handshake_done, in DoHandshake()
/third_party/libuv/src/win/
Dtcp.c490 handle->tcp.conn.read_buffer = uv_buf_init(NULL, 0); in uv__tcp_queue_read()
491 handle->alloc_cb((uv_handle_t*) handle, 65536, &handle->tcp.conn.read_buffer); in uv__tcp_queue_read()
492 if (handle->tcp.conn.read_buffer.base == NULL || in uv__tcp_queue_read()
493 handle->tcp.conn.read_buffer.len == 0) { in uv__tcp_queue_read()
494 handle->read_cb((uv_stream_t*) handle, UV_ENOBUFS, &handle->tcp.conn.read_buffer); in uv__tcp_queue_read()
497 assert(handle->tcp.conn.read_buffer.base != NULL); in uv__tcp_queue_read()
498 buf = handle->tcp.conn.read_buffer; in uv__tcp_queue_read()
1014 uv_buf_init(NULL, 0) : handle->tcp.conn.read_buffer; in uv__process_tcp_read_req()
1036 &handle->tcp.conn.read_buffer); in uv__process_tcp_read_req()
1038 if (req->u.io.overlapped.InternalHigh < handle->tcp.conn.read_buffer.len) { in uv__process_tcp_read_req()
[all …]

1234