Home
last modified time | relevance | path

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

1234

/external/libchrome/mojo/core/
Dmultiprocess_message_pipe_unittest.cc151 std::string read_buffer(1000, '\0'); in DEFINE_TEST_CLIENT_WITH_PIPE() local
152 uint32_t read_buffer_size = static_cast<uint32_t>(read_buffer.size()); in DEFINE_TEST_CLIENT_WITH_PIPE()
153 CHECK_EQ(MojoReadMessage(h, &read_buffer[0], &read_buffer_size, nullptr, 0, in DEFINE_TEST_CLIENT_WITH_PIPE()
156 read_buffer.resize(read_buffer_size); in DEFINE_TEST_CLIENT_WITH_PIPE()
157 VLOG(2) << "Child got: " << read_buffer; in DEFINE_TEST_CLIENT_WITH_PIPE()
159 if (read_buffer == quitquitquit) { in DEFINE_TEST_CLIENT_WITH_PIPE()
164 std::string write_buffer = read_buffer + read_buffer; in DEFINE_TEST_CLIENT_WITH_PIPE()
191 std::string read_buffer(1000, '\0'); in TEST_P() local
192 uint32_t read_buffer_size = static_cast<uint32_t>(read_buffer.size()); in TEST_P()
193 CHECK_EQ(MojoReadMessage(h, &read_buffer[0], &read_buffer_size, nullptr, 0, in TEST_P()
[all …]
Dplatform_handle_dispatcher_unittest.cc53 char read_buffer[1000] = {}; in TEST() local
55 fread(read_buffer, 1, sizeof(read_buffer), fp.get())); in TEST()
56 EXPECT_STREQ(kHelloWorld, read_buffer); in TEST()
115 char read_buffer[1000] = {}; in TEST() local
117 fread(read_buffer, 1, sizeof(read_buffer), fp.get())); in TEST()
118 EXPECT_STREQ(kFooBar, read_buffer); in TEST()
Ddata_pipe_unittest.cc406 const void* read_buffer = nullptr; in TEST_F() local
408 ASSERT_EQ(MOJO_RESULT_OK, BeginReadData(&read_buffer, &num_bytes)); in TEST_F()
409 EXPECT_TRUE(read_buffer); in TEST_F()
412 ASSERT_EQ(456, static_cast<const int32_t*>(read_buffer)[0]); in TEST_F()
703 const void* read_buffer = nullptr; in TEST_F() local
704 ASSERT_EQ(MOJO_RESULT_OK, BeginReadData(&read_buffer, &num_bytes)); in TEST_F()
705 EXPECT_TRUE(read_buffer); in TEST_F()
707 const int32_t* read_elements = static_cast<const int32_t*>(read_buffer); in TEST_F()
723 read_buffer = nullptr; in TEST_F()
725 ASSERT_EQ(MOJO_RESULT_OK, BeginReadData(&read_buffer, &num_bytes)); in TEST_F()
[all …]
Dchannel_unittest.cc147 char* read_buffer = channel->GetReadBufferTest(&buffer_size); in TEST() local
151 memcpy(read_buffer, message->data(), message->data_num_bytes()); in TEST()
169 char* read_buffer = channel->GetReadBufferTest(&buffer_size); in TEST() local
173 memcpy(read_buffer, message->data(), message->data_num_bytes()); in TEST()
/external/pdfium/core/fpdfapi/parser/
Dcpdf_read_validator_unittest.cpp75 std::vector<uint8_t> read_buffer(100); in TEST() local
77 validator->ReadBlock(read_buffer.data(), 5000, read_buffer.size())); in TEST()
84 file_avail.SetAvailableRange(5000, 5000 + read_buffer.size()); in TEST()
87 validator->ReadBlock(read_buffer.data(), 5000, read_buffer.size())); in TEST()
102 std::vector<uint8_t> read_buffer(100); in TEST() local
105 validator->ReadBlock(read_buffer.data(), 5000, read_buffer.size())); in TEST()
117 validator->ReadBlock(read_buffer.data(), 5000, read_buffer.size())); in TEST()
125 EXPECT_FALSE(validator->ReadBlock(read_buffer.data(), in TEST()
126 validator->GetSize() - read_buffer.size(), in TEST()
127 read_buffer.size())); in TEST()
[all …]
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dhttp_connect_handshaker.cc89 handshaker->read_buffer_to_destroy = handshaker->args->read_buffer; in cleanup_args_for_failure_locked()
90 handshaker->args->read_buffer = nullptr; in cleanup_args_for_failure_locked()
137 handshaker->args->read_buffer, in on_write_done()
155 for (size_t i = 0; i < handshaker->args->read_buffer->count; ++i) { in on_read_done()
156 if (GRPC_SLICE_LENGTH(handshaker->args->read_buffer->slices[i]) > 0) { in on_read_done()
159 handshaker->args->read_buffer->slices[i], in on_read_done()
171 GRPC_SLICE_LENGTH(handshaker->args->read_buffer->slices[i])) { in on_read_done()
174 grpc_slice_split_tail(&handshaker->args->read_buffer->slices[i], in on_read_done()
178 &handshaker->args->read_buffer->slices[i + 1], in on_read_done()
179 handshaker->args->read_buffer->count - i - 1); in on_read_done()
[all …]
/external/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()
/external/grpc-grpc/test/core/util/
Dmock_endpoint.cc37 grpc_slice_buffer read_buffer; member
47 if (m->read_buffer.count > 0) { in me_read()
48 grpc_slice_buffer_swap(&m->read_buffer, slices); in me_read()
90 grpc_slice_buffer_destroy(&m->read_buffer); in me_destroy()
127 grpc_slice_buffer_init(&m->read_buffer); in grpc_mock_endpoint_create()
142 grpc_slice_buffer_add(&m->read_buffer, slice); in grpc_mock_endpoint_put_read()
Dpassthru_endpoint.cc41 grpc_slice_buffer read_buffer; member
63 } else if (m->read_buffer.count > 0) { in me_read()
64 grpc_slice_buffer_swap(&m->read_buffer, slices); in me_read()
94 grpc_slice_buffer_add(&m->read_buffer, in me_write()
139 grpc_slice_buffer_destroy_internal(&p->client.read_buffer); in me_destroy()
140 grpc_slice_buffer_destroy_internal(&p->server.read_buffer); in me_destroy()
181 grpc_slice_buffer_init(&m->read_buffer); in half_init()
/external/grpc-grpc/src/core/lib/security/transport/
Dsecure_endpoint.cc53 grpc_slice_buffer* read_buffer; member
124 grpc_slice_buffer_add(ep->read_buffer, ep->read_staging_buffer); in flush_read_staging_buffer()
133 for (i = 0; i < ep->read_buffer->count; i++) { in call_read_cb()
134 char* data = grpc_dump_slice(ep->read_buffer->slices[i], in call_read_cb()
140 ep->read_buffer = nullptr; in call_read_cb()
154 grpc_slice_buffer_reset_and_unref_internal(ep->read_buffer); in on_read()
163 ep->zero_copy_protector, &ep->source_buffer, ep->read_buffer); in on_read()
207 ep->read_buffer, in on_read()
220 grpc_slice_buffer_reset_and_unref_internal(ep->read_buffer); in on_read()
234 ep->read_buffer = slices; in endpoint_read()
[all …]
Dsecurity_handshaker.cc71 size_t bytes_in_read_buffer = h->args->read_buffer->length; in move_read_buffer_into_handshake_buffer()
78 while (h->args->read_buffer->count > 0) { in move_read_buffer_into_handshake_buffer()
79 grpc_slice next_slice = grpc_slice_buffer_take_first(h->args->read_buffer); in move_read_buffer_into_handshake_buffer()
113 h->read_buffer_to_destroy = h->args->read_buffer; in cleanup_args_for_failure_locked()
114 h->args->read_buffer = nullptr; in cleanup_args_for_failure_locked()
242 grpc_endpoint_read(h->args->endpoint, h->args->read_buffer, in on_handshake_next_done_locked()
265 grpc_endpoint_read(h->args->endpoint, h->args->read_buffer, in on_handshake_next_done_locked()
354 grpc_endpoint_read(h->args->endpoint, h->args->read_buffer, in on_handshake_data_sent_to_peer()
/external/grpc-grpc/src/core/lib/channel/
Dhandshaker.cc194 args->read_buffer != nullptr ? args->read_buffer->length : 0; in handshaker_args_string()
200 args->read_buffer, read_buffer_length, args->exit_early); in handshaker_args_string()
239 grpc_slice_buffer_destroy_internal(mgr->args.read_buffer); in call_next_handshaker_locked()
240 gpr_free(mgr->args.read_buffer); in call_next_handshaker_locked()
241 mgr->args.read_buffer = nullptr; in call_next_handshaker_locked()
309 mgr->args.read_buffer = static_cast<grpc_slice_buffer*>( in grpc_handshake_manager_do_handshake()
310 gpr_malloc(sizeof(*mgr->args.read_buffer))); in grpc_handshake_manager_do_handshake()
311 grpc_slice_buffer_init(mgr->args.read_buffer); in grpc_handshake_manager_do_handshake()
/external/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()
/external/grpc-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 …]
/external/grpc-grpc/test/core/transport/chttp2/
Dsettings_timeout_test.cc128 grpc_slice_buffer read_buffer; in ReadUntilError() local
129 grpc_slice_buffer_init(&read_buffer); in ReadUntilError()
136 grpc_endpoint_read(endpoint_, &read_buffer, state.closure()); in ReadUntilError()
142 gpr_log(GPR_INFO, "client read %" PRIuPTR " bytes", read_buffer.length); in ReadUntilError()
143 grpc_slice_buffer_reset_and_unref_internal(&read_buffer); in ReadUntilError()
147 grpc_slice_buffer_destroy_internal(&read_buffer); in ReadUntilError()
/external/webrtc/webrtc/modules/audio_processing/transient/
Dfile_utils_unittest.cc373 rtc::scoped_ptr<int16_t[]> read_buffer(new int16_t[kBufferLength]); in TEST_F() local
394 read_buffer.get())); in TEST_F()
396 read_buffer.get(), in TEST_F()
420 rtc::scoped_ptr<float[]> read_buffer(new float[kBufferLength]); in TEST_F() local
441 read_buffer.get())); in TEST_F()
443 read_buffer.get(), in TEST_F()
467 rtc::scoped_ptr<double[]> read_buffer(new double[kBufferLength]); in TEST_F() local
488 read_buffer.get())); in TEST_F()
490 read_buffer.get(), in TEST_F()
/external/squashfs-tools/squashfs-tools/
Dmksquashfs.c2649 struct file_buffer *read_buffer, int *duplicate_file) in write_file_process() argument
2665 read_size = read_buffer->file_size; in write_file_process()
2666 if(read_buffer->fragment) in write_file_process()
2667 fragment_buffer = read_buffer; in write_file_process()
2673 block_list[block ++] = read_buffer->c_byte; in write_file_process()
2674 if(read_buffer->c_byte) { in write_file_process()
2675 read_buffer->block = bytes; in write_file_process()
2676 bytes += read_buffer->size; in write_file_process()
2677 cache_hash(read_buffer, read_buffer->block); in write_file_process()
2678 file_bytes += read_buffer->size; in write_file_process()
[all …]
/external/grpc-grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc115 char* read_buffer; member
271 if (s->state.rs.read_buffer && in null_and_maybe_free_read_buffer()
272 s->state.rs.read_buffer != s->state.rs.grpc_header_bytes) { in null_and_maybe_free_read_buffer()
273 gpr_free(s->state.rs.read_buffer); in null_and_maybe_free_read_buffer()
275 s->state.rs.read_buffer = nullptr; in null_and_maybe_free_read_buffer()
291 s->state.rs.read_buffer = in maybe_flush_read()
295 bidirectional_stream_read(s->cbs, s->state.rs.read_buffer, in maybe_flush_read()
554 s->state.rs.read_buffer = s->state.rs.grpc_header_bytes; in on_response_headers_received()
559 bidirectional_stream_read(s->cbs, s->state.rs.read_buffer, in on_response_headers_received()
598 bidirectional_stream_read(s->cbs, s->state.rs.read_buffer, in on_read_completed()
[all …]
/external/puffin/src/
Dextent_stream.cc94 bool ExtentStream::DoReadOrWrite(void* read_buffer, in DoReadOrWrite() argument
104 if (read_buffer != nullptr) { in DoReadOrWrite()
106 stream_->Read(reinterpret_cast<uint8_t*>(read_buffer) + bytes_passed, in DoReadOrWrite()
/external/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()
/external/u-boot/fs/ext4/
Dext4_write.c443 char *read_buffer = NULL; in ext4fs_delete_file() local
531 read_buffer = zalloc(fs->blksz); in ext4fs_delete_file()
532 if (!read_buffer) in ext4fs_delete_file()
534 start_block_address = read_buffer; in ext4fs_delete_file()
536 0, fs->blksz, read_buffer); in ext4fs_delete_file()
540 if (ext4fs_log_journal(read_buffer, blkno)) in ext4fs_delete_file()
543 read_buffer = read_buffer + blkoff; in ext4fs_delete_file()
544 inode_buffer = (struct ext2_inode *)read_buffer; in ext4fs_delete_file()
/external/grpc-grpc/src/core/ext/transport/chttp2/client/
Dchttp2_connector.cc109 grpc_slice_buffer_destroy_internal(args->read_buffer); in on_handshake_done()
110 gpr_free(args->read_buffer); in on_handshake_done()
145 grpc_chttp2_transport_start_reading(c->result->transport, args->read_buffer, in on_handshake_done()
/external/python/cpython3/Modules/
D_winapi.c97 PyObject *read_buffer; member
142 Py_CLEAR(self->read_buffer); in overlapped_dealloc()
227 if (self->completed && self->read_buffer != NULL) { in _winapi_Overlapped_GetOverlappedResult_impl()
228 assert(PyBytes_CheckExact(self->read_buffer)); in _winapi_Overlapped_GetOverlappedResult_impl()
229 if (transferred != PyBytes_GET_SIZE(self->read_buffer) && in _winapi_Overlapped_GetOverlappedResult_impl()
230 _PyBytes_Resize(&self->read_buffer, transferred)) in _winapi_Overlapped_GetOverlappedResult_impl()
251 res = self->read_buffer ? self->read_buffer : Py_None; in _winapi_Overlapped_getbuffer_impl()
346 self->read_buffer = NULL; in new_overlapped()
1399 overlapped->read_buffer = buf; in _winapi_ReadFile_impl()
/external/grpc-grpc/test/core/iomgr/
Dudp_server_test.cc71 char read_buffer[512]; in Read() local
76 recv(grpc_fd_wrapped_fd(emfd()), read_buffer, sizeof(read_buffer), 0); in Read()
/external/grpc-grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc124 grpc_slice_buffer_destroy_internal(args->read_buffer); in on_handshake_done()
125 gpr_free(args->read_buffer); in on_handshake_done()
146 transport, args->read_buffer, &connection_state->on_receive_settings); in on_handshake_done()

1234