| /external/libaom/test/ |
| D | aom_integer_test.cc | 53 uint8_t write_buffer[kWriteBufferSize] = { 0 }; in TEST() local
55 ASSERT_EQ(aom_uleb_encode(test_value, kWriteBufferSize, &write_buffer[0], in TEST()
60 ASSERT_EQ(write_buffer[i], expected_bytes[i]); in TEST()
67 uint8_t write_buffer[kWriteBufferSize] = { 0 }; in TEST() local
69 ASSERT_EQ(aom_uleb_encode(value, kWriteBufferSize, &write_buffer[0], in TEST()
75 aom_uleb_decode(&write_buffer[0], bytes_written, &decoded_value, in TEST()
85 uint8_t write_buffer[kWriteBufferSize] = { 0 }; in TEST() local
88 kWriteBufferSize, &write_buffer[0], in TEST()
92 ASSERT_EQ(write_buffer[i], expected_bytes[i]); in TEST()
99 uint8_t write_buffer[kWriteBufferSize] = { 0 }; in TEST() local
[all …]
|
| /external/openscreen/platform/impl/ |
| D | tls_write_buffer_unittest.cc | 18 uint8_t write_buffer[write_size]; in TEST() local
19 std::fill_n(write_buffer, write_size, uint8_t{1}); in TEST()
21 EXPECT_TRUE(buffer.Push(write_buffer, write_size)); in TEST()
43 EXPECT_TRUE(buffer.Push(write_buffer, write_size)); in TEST()
44 EXPECT_TRUE(buffer.Push(write_buffer, write_size)); in TEST()
47 EXPECT_FALSE(buffer.Push(write_buffer, write_size)); in TEST()
48 EXPECT_FALSE(buffer.Push(write_buffer, 1)); in TEST()
54 uint8_t write_buffer[buffer_size]; in TEST() local
55 std::fill_n(write_buffer, buffer_size, uint8_t{1}); in TEST()
58 EXPECT_TRUE(buffer.Push(write_buffer, partial_buffer_size)); in TEST()
[all …]
|
| /external/compiler-rt/lib/profile/ |
| D | GCDAProfiling.c | 81 static char *write_buffer = NULL; variable
120 write_buffer = realloc(write_buffer, size); in resize_write_buffer()
126 memcpy(&write_buffer[cur_pos], s, len); in write_bytes()
155 val = *(uint32_t*)&write_buffer[cur_pos]; in read_32bit_value()
166 val = *(uint64_t*)&write_buffer[cur_pos]; in read_64bit_value()
224 write_buffer = mmap(0, file_size, PROT_READ | PROT_WRITE, in map_file()
226 if (write_buffer == (void *)-1) { in map_file()
236 if (msync(write_buffer, file_size, MS_SYNC) == -1) { in unmap_file()
245 (void)munmap(write_buffer, file_size); in unmap_file()
246 write_buffer = NULL; in unmap_file()
[all …]
|
| /external/webrtc/rtc_base/ |
| D | byte_buffer_unittest.cc | 196 ByteBufferWriter write_buffer; in TEST() local
198 EXPECT_EQ(size, write_buffer.Length()); in TEST()
200 write_buffer.WriteUVarint(1u); in TEST()
202 EXPECT_EQ(size, write_buffer.Length()); in TEST()
204 write_buffer.WriteUVarint(2u); in TEST()
206 EXPECT_EQ(size, write_buffer.Length()); in TEST()
208 write_buffer.WriteUVarint(27u); in TEST()
210 EXPECT_EQ(size, write_buffer.Length()); in TEST()
212 write_buffer.WriteUVarint(149u); in TEST()
214 EXPECT_EQ(size, write_buffer.Length()); in TEST()
[all …]
|
| /external/grpc-grpc/test/core/util/ |
| D | trickle_endpoint.cc | 42 grpc_slice_buffer write_buffer; member
58 te->write_buffer.length <= WRITE_BUFFER_SIZE)) { in maybe_call_write_cb_locked()
69 if (te->write_buffer.length == 0) { in te_write()
73 grpc_slice_buffer_add(&te->write_buffer, in te_write()
113 grpc_slice_buffer_destroy_internal(&te->write_buffer); in te_destroy()
162 grpc_slice_buffer_init(&te->write_buffer); in grpc_trickle_endpoint_create()
176 if (!te->writing && te->write_buffer.length > 0) { in grpc_trickle_endpoint_trickle()
182 grpc_slice_buffer_move_first(&te->write_buffer, in grpc_trickle_endpoint_trickle()
183 GPR_MIN(bytes, te->write_buffer.length), in grpc_trickle_endpoint_trickle()
194 size_t backlog = te->write_buffer.length; in grpc_trickle_endpoint_trickle()
[all …]
|
| /external/pigweed/pw_spi/public/pw_spi/ |
| D | device.h | 61 Status Write(ConstByteSpan write_buffer) { in Write() argument
62 return WriteRead(write_buffer, {}); in Write()
79 Status WriteRead(ConstByteSpan write_buffer, ByteSpan read_buffer) { in WriteRead() argument
81 .WriteRead(write_buffer, read_buffer); in WriteRead()
134 Status Write(ConstByteSpan write_buffer) { in Write() argument
135 return WriteRead(write_buffer, {}); in Write()
149 Status WriteRead(ConstByteSpan write_buffer, ByteSpan read_buffer) { in WriteRead() argument
162 auto status = initiator_->WriteRead(write_buffer, read_buffer); in WriteRead()
|
| D | initiator_mock.h | 32 ConstByteSpan write_buffer, in MockTransaction() argument
36 write_buffer_(write_buffer) {} in MockTransaction()
42 ConstByteSpan write_buffer() const { return write_buffer_; } in write_buffer() function
61 ConstByteSpan write_buffer) { in MockWriteTransaction() argument
62 return MockTransaction(expected_return_value, write_buffer, ConstByteSpan()); in MockWriteTransaction()
|
| /external/cronet/net/spdy/ |
| D | bidirectional_stream_spdy_impl_unittest.cc | 328 scoped_refptr<StringIOBuffer> write_buffer = in TEST_F() local
331 delegate->SendData(write_buffer.get(), write_buffer->size(), true); in TEST_F()
484 scoped_refptr<StringIOBuffer> write_buffer = in TEST_P() local
487 delegate->SendData(write_buffer.get(), write_buffer->size(), false); in TEST_P()
497 write_buffer.get(), write_buffer.get(), write_buffer.get()}; in TEST_P()
499 write_buffer->size(), write_buffer->size(), write_buffer->size()}; in TEST_P()
504 delegate->SendData(write_buffer.get(), write_buffer->size(), in TEST_P()
527 std::vector<scoped_refptr<IOBuffer>> buffer = {write_buffer.get()}; in TEST_P()
528 std::vector<int> buffer_size = {write_buffer->size()}; in TEST_P()
531 delegate->SendData(write_buffer.get(), write_buffer->size(), true); in TEST_P()
[all …]
|
| /external/ltp/testcases/kernel/syscalls/pipe2/ |
| D | pipe2_04.c | 61 char *write_buffer; in setup() local
85 write_buffer = SAFE_MALLOC(pipe_size); in setup()
86 memset(write_buffer, 'x', pipe_size); in setup()
87 SAFE_WRITE(SAFE_WRITE_ALL, fds[1], write_buffer, pipe_size); in setup()
88 free(write_buffer); in setup()
|
| /external/cronet/net/socket/ |
| D | transport_client_socket_test_util.cc | 76 scoped_refptr<DrainableIOBuffer> write_buffer = in SendServerResponse() local
79 memcpy(write_buffer->data(), kServerReply, reply_len); in SendServerResponse()
81 while (write_buffer->BytesRemaining() > 0) { in SendServerResponse()
84 socket->Write(write_buffer.get(), write_buffer->BytesRemaining(), in SendServerResponse()
89 write_buffer->DidConsume(write_result); in SendServerResponse()
|
| D | tcp_socket_unittest.cc | 206 scoped_refptr<IOBufferWithSize> write_buffer = in TestSPWNotifications() local
208 memmove(write_buffer->data(), message.data(), message.size()); in TestSPWNotifications()
212 write_buffer.get(), write_buffer->size(), write_callback.callback(), in TestSPWNotifications()
426 scoped_refptr<IOBufferWithSize> write_buffer = in TEST_F() local
428 memmove(write_buffer->data(), message.data() + bytes_written, in TEST_F()
433 write_buffer.get(), write_buffer->size(), write_callback.callback(), in TEST_F()
528 scoped_refptr<IOBufferWithDestructionCallback> write_buffer( in TEST_F() local
531 memset(write_buffer->data(), '1', write_buffer->size()); in TEST_F()
534 result = connecting_socket->Write(write_buffer.get(), write_buffer->size(), in TEST_F()
544 write_buffer = nullptr; in TEST_F()
[all …]
|
| D | unix_domain_client_socket_posix_unittest.cc | 355 scoped_refptr<IOBuffer> write_buffer = in TEST_F() local
359 WriteSynchronously(&client_socket, write_buffer.get(), kWriteDataSize)); in TEST_F()
370 EXPECT_EQ(std::string(write_buffer->data(), kWriteDataSize), in TEST_F()
376 accepted_socket.get(), write_buffer.get(), kWriteDataSize)); in TEST_F()
385 EXPECT_EQ(std::string(write_buffer->data(), kSmallReadBufferSize), in TEST_F()
393 EXPECT_EQ(std::string(write_buffer->data() + kSmallReadBufferSize, in TEST_F()
436 scoped_refptr<IOBuffer> write_buffer = in TEST_F() local
440 WriteSynchronously(&client_socket, write_buffer.get(), kWriteDataSize)); in TEST_F()
|
| D | tcp_client_socket_unittest.cc | 228 auto write_buffer = base::MakeRefCounted<StringIOBuffer>(kRequest); in TEST_F() local
230 socket.Write(write_buffer.get(), write_buffer->size(), in TEST_F()
287 auto write_buffer = base::MakeRefCounted<StringIOBuffer>(kRequest); in TEST_F() local
289 socket.Write(write_buffer.get(), write_buffer->size(), in TEST_F()
682 scoped_refptr<IOBuffer> write_buffer = in TEST_F() local
684 memset(write_buffer->data(), '1', kBufferSize); in TEST_F()
688 client_socket->Write(write_buffer.get(), kBufferSize, in TEST_F()
702 EXPECT_THAT(client_socket->Read(write_buffer.get(), 1, callback.callback()), in TEST_F()
704 EXPECT_THAT(client_socket->Write(write_buffer.get(), 1, callback.callback(), in TEST_F()
766 scoped_refptr<IOBuffer> write_buffer = in TEST_F() local
[all …]
|
| /external/pigweed/pw_i2c/public/pw_i2c/ |
| D | initiator_mock.h | 34 ConstByteSpan write_buffer,
39 write_buffer_(write_buffer), in return_value_()
58 ConstByteSpan write_buffer() const { return write_buffer_; } in write_buffer() function
97 ConstByteSpan write_buffer,
101 write_buffer,
|
| /external/webrtc/test/fuzzers/ |
| D | rtp_video_layers_allocation_fuzzer.cc | 46 rtc::ArrayView<uint8_t> write_buffer(some_memory, value_size); in FuzzOneInput() local
48 RtpVideoLayersAllocationExtension::Write(write_buffer, allocation1)); in FuzzOneInput()
54 RtpVideoLayersAllocationExtension::Parse(write_buffer, &allocation2)); in FuzzOneInput()
|
| D | rtp_dependency_descriptor_fuzzer.cc | 61 rtc::ArrayView<uint8_t> write_buffer(some_memory, value_size); in FuzzOneInput() local
62 RTC_CHECK(RtpDependencyDescriptorExtension::Write(write_buffer, structure1, in FuzzOneInput()
69 write_buffer, structure2.get(), &descriptor2)); in FuzzOneInput()
|
| /external/ltp/testcases/kernel/syscalls/vmsplice/ |
| D | vmsplice04.c | 21 static char *write_buffer; variable
75 write_buffer = tst_alloc(pipe_max_size); in setup()
77 iov.iov_base = write_buffer; in setup()
|
| /external/pigweed/pw_spi/ |
| D | linux_spi.cc | 79 Status LinuxInitiator::WriteRead(ConstByteSpan write_buffer, in WriteRead() argument
84 transaction[0].tx_buf = reinterpret_cast<uintptr_t>(write_buffer.data()); in WriteRead()
85 transaction[0].len = write_buffer.size(); in WriteRead()
|
| /external/grpc-grpc/test/core/iomgr/ios/CFStreamTests/ |
| D | CFStreamEndpointTests.mm | 162 char write_buffer[kBufferSize];
167 slice = grpc_slice_from_static_buffer(write_buffer, kBufferSize);
182 XCTAssertEqual(memcmp(read_buffer, write_buffer, kBufferSize), 0);
215 char write_buffer[kBufferSize];
224 slice = grpc_slice_from_static_buffer(write_buffer, kBufferSize);
239 XCTAssertEqual(memcmp(read_buffer, write_buffer, kBufferSize), 0);
264 char write_buffer[kBufferSize];
273 slice = grpc_slice_from_static_buffer(write_buffer, kBufferSize);
288 XCTAssertEqual(memcmp(read_buffer, write_buffer, kBufferSize), 0);
|
| /external/tensorflow/tensorflow/lite/delegates/gpu/gl/ |
| D | gl_buffer.cc | 27 const GlBuffer& write_buffer) { in CopyBuffer() argument
28 if (read_buffer.bytes_size() != write_buffer.bytes_size()) { in CopyBuffer()
35 write_buffer.id()); in CopyBuffer()
38 write_buffer.offset(), read_buffer.bytes_size()); in CopyBuffer()
|
| /external/puffin/src/ |
| D | extent_stream.cc | 95 const void* write_buffer, in DoReadOrWrite() argument
108 } else if (write_buffer != nullptr) { in DoReadOrWrite()
110 reinterpret_cast<const uint8_t*>(write_buffer) + bytes_passed, in DoReadOrWrite()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | http_connect_handshaker.cc | 58 grpc_slice_buffer write_buffer; member
76 grpc_slice_buffer_destroy_internal(&handshaker->write_buffer); in http_connect_handshaker_unref()
313 grpc_slice_buffer_add(&handshaker->write_buffer, request_slice); in http_connect_handshaker_do_handshake()
322 grpc_endpoint_write(args->endpoint, &handshaker->write_buffer, in http_connect_handshaker_do_handshake()
338 grpc_slice_buffer_init(&handshaker->write_buffer); in grpc_http_connect_handshaker_create()
|
| /external/ltp/testcases/kernel/fs/mongo/ |
| D | reiser_fract_tree.c | 55 char *write_buffer; /* buffer from which we write */ variable
202 write(fd, write_buffer, in make_file()
472 write_buffer = malloc(write_buffer_size); in main()
473 memset(write_buffer, 'a', write_buffer_size); in main()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 149 char* write_buffer = nullptr; member
450 if (s->state.ws.write_buffer) { in on_failed()
451 gpr_free(s->state.ws.write_buffer); in on_failed()
452 s->state.ws.write_buffer = nullptr; in on_failed()
477 if (s->state.ws.write_buffer) { in on_canceled()
478 gpr_free(s->state.ws.write_buffer); in on_canceled()
479 s->state.ws.write_buffer = nullptr; in on_canceled()
584 if (s->state.ws.write_buffer) { in on_write_completed()
585 gpr_free(s->state.ws.write_buffer); in on_write_completed()
586 s->state.ws.write_buffer = nullptr; in on_write_completed()
[all …]
|
| /external/grpc-grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 138 char* write_buffer; member
439 if (s->state.ws.write_buffer) { in on_failed()
440 gpr_free(s->state.ws.write_buffer); in on_failed()
441 s->state.ws.write_buffer = nullptr; in on_failed()
465 if (s->state.ws.write_buffer) { in on_canceled()
466 gpr_free(s->state.ws.write_buffer); in on_canceled()
467 s->state.ws.write_buffer = nullptr; in on_canceled()
575 if (s->state.ws.write_buffer) { in on_write_completed()
576 gpr_free(s->state.ws.write_buffer); in on_write_completed()
577 s->state.ws.write_buffer = nullptr; in on_write_completed()
[all …]
|