| /external/okio/okio/src/commonTest/kotlin/okio/ |
| D | CommonOkioKotlinTest.kt | 25 val buffered = (source as Source).buffer() in sourceBuffer() constant
32 val buffered = (sink as Sink).buffer() in sinkBuffer() constant
|
| /external/libaom/common/ |
| D | obudec.c | 43 uint64_t *value, bool buffered) { in obudec_read_leb128()
77 size_t *bytes_read, bool buffered) { in obudec_read_obu_header()
117 size_t *bytes_read, bool buffered) { in obudec_read_obu_payload()
133 ObuHeader *obu_header, bool buffered) { in obudec_read_obu_header_and_size()
231 bool buffered) { in obudec_read_one_obu()
|
| /external/rust/crates/futures-util/src/io/ |
| D | line_writer.rs | 96 let buffered = this.buf_writer.as_mut().write_to_buf(tail); in poll_write() localVariable
136 let buffered: usize = tail in poll_write_vectored() localVariable
|
| /external/skia/client_utils/android/ |
| D | FrontBufferedStream.cpp | 154 const size_t buffered = fStream->read(buffer, bytesToBuffer); in bufferAndWriteTo() local
224 const size_t buffered = this->bufferAndWriteTo(dst, size); in read() local
|
| /external/liburing/test/ |
| D | read-write.c | 46 int buffered, int sqthread, int fixed, int nonvec, in __test_io()
230 static int test_io(const char *file, int write, int buffered, int sqthread, in test_io()
756 int buffered = (i & 2) != 0; in main() local
851 int buffered = (i & 2) != 0; in main() local
|
| D | file-verify.c | 59 static int test_truncate(struct io_uring *ring, const char *fname, int buffered, in test_truncate()
306 static int test(struct io_uring *ring, const char *fname, int buffered, in test()
|
| /external/cronet/net/third_party/quiche/src/quiche/http2/adapter/ |
| D | window_manager_test.cc | 19 int64_t buffered() { return wm_.buffered_; } in buffered() function in http2::adapter::test::WindowManagerPeer
70 int64_t buffered = std::min<int64_t>(kDefaultLimit - total_buffered, in TEST_F() local
314 const int64_t buffered = 42; in TEST() local
|
| /external/libwebsockets/lib/roles/raw-skt/ |
| D | ops-raw-skt.c | 35 int n = 0, buffered = 0; in rops_handle_POLLIN_raw_skt() local
|
| /external/libwebsockets/lib/roles/raw-proxy/ |
| D | ops-raw-proxy.c | 32 int n, buffered; in rops_handle_POLLIN_raw_proxy() local
|
| /external/jackson-databind/src/main/java/com/fasterxml/jackson/databind/deser/impl/ |
| D | UnwrappedPropertyHandler.java | 55 Object bean, TokenBuffer buffered) in processUnwrapped()
|
| D | PropertyValueBuffer.java | 265 protected PropertyValue buffered() { return _buffered; } in buffered() method in PropertyValueBuffer
|
| /external/jackson-core/src/main/java/com/fasterxml/jackson/core/format/ |
| D | DataFormatMatcher.java | 42 protected DataFormatMatcher(InputStream in, byte[] buffered, in DataFormatMatcher()
|
| /external/libwebsockets/lib/core-net/ |
| D | service.c | 251 uint8_t *buffered; in lws_rxflow_cache() local
473 int used, int buffered, const char *hint) in lws_buflist_aware_finished_consuming()
|
| /external/libwebsockets/lib/roles/h2/ |
| D | ops-h2.c | 103 char buffered = 0; in rops_handle_POLLIN_h2() local
801 uint8_t *buffered; in lws_h2_bind_for_post_before_action() local
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/batch_writer/ |
| D | quic_batch_writer_base.cc | 61 bool buffered = false; in InternalWritePacket() local
|
| /external/rust/crates/futures-util/src/sink/ |
| D | send_all.rs | 20 buffered: Option<St::Ok>, field
|
| /external/libwebsockets/lib/roles/mqtt/client/ |
| D | client-mqtt.c | 194 int buffered = 0; in lws_mqtt_client_socket_service() local
|
| /external/libwebsockets/lib/roles/http/client/ |
| D | client-http.c | 404 int n, m, buffered; in lws_http_client_socket_service() local
1330 int buffered, n, consumed = 0; in lws_http_client_read() local
|
| /external/conscrypt/repackaged/common/src/main/java/com/android/org/conscrypt/ |
| D | OpenSSLEvpCipher.java | 175 final int buffered = NativeCrypto.get_EVP_CIPHER_CTX_buf_len(cipherCtx); in getOutputSizeForFinal() local
|
| /external/conscrypt/common/src/main/java/org/conscrypt/ |
| D | OpenSSLEvpCipher.java | 171 final int buffered = NativeCrypto.get_EVP_CIPHER_CTX_buf_len(cipherCtx); in getOutputSizeForFinal() local
|
| /external/libwebsockets/lib/roles/mqtt/ |
| D | ops-mqtt.c | 34 char buffered = 0; in rops_handle_POLLIN_mqtt() local
|
| /external/apache-commons-io/src/test/java/org/apache/commons/io/output/ |
| D | ByteArrayOutputStreamTest.java | 237 try (InputStream buffered = toBufferedInputStreamFunction.apply(bain)) { in testToBufferedInputStream()
253 try (InputStream buffered = toBufferedInputStreamFunction.apply(bain)) { in testToBufferedInputStreamEmpty()
|
| /external/cronet/net/third_party/quiche/src/quiche/http2/hpack/decoder/ |
| D | hpack_decoder_string_buffer_test.cc | 141 absl::string_view buffered = buf_.str(); in TEST_F() local
|
| /external/libwebsockets/lib/roles/h1/ |
| D | ops-h1.c | 333 int n, buffered; in lws_h1_server_socket_service() local
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | CallSafeHandle.cs | 208 private static uint GetFlags(bool buffered) in GetFlags()
|