| /external/kotlinx.coroutines/benchmarks/src/jmh/kotlin/benchmarks/flow/ |
| D | TakeBenchmark.kt | 56 var consumed = 0 in <lambda>() variable
77 var consumed = 0 in <lambda>() variable
109 private var consumed = 0 in <lambda>() variable
|
| /external/python/cpython3/Modules/ |
| D | _codecsmodule.c | 267 Py_ssize_t consumed = data->len; in _codecs_utf_7_decode_impl() local
287 Py_ssize_t consumed = data->len; in _codecs_utf_8_decode_impl() local
309 Py_ssize_t consumed = data->len; in _codecs_utf_16_decode_impl() local
331 Py_ssize_t consumed = data->len; in _codecs_utf_16_le_decode_impl() local
353 Py_ssize_t consumed = data->len; in _codecs_utf_16_be_decode_impl() local
382 Py_ssize_t consumed = data->len; in _codecs_utf_16_ex_decode_impl() local
407 Py_ssize_t consumed = data->len; in _codecs_utf_32_decode_impl() local
429 Py_ssize_t consumed = data->len; in _codecs_utf_32_le_decode_impl() local
451 Py_ssize_t consumed = data->len; in _codecs_utf_32_be_decode_impl() local
479 Py_ssize_t consumed = data->len; in _codecs_utf_32_ex_decode_impl() local
[all …]
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jdk8/src/stream/ |
| D | Stream.kt | 20 private val consumed = atomic(false) in consumeAsFlow() constant in kotlinx.coroutines.stream.StreamFlow
|
| /external/rust/crates/quiche/src/ |
| D | flowcontrol.rs | 41 consumed: u64, field
155 let consumed = 95; in max_data_next() localVariable
166 let consumed = 95; in update_max_data() localVariable
183 let consumed = 95; in autotune_window() localVariable
|
| /external/libwebm/m2ts/ |
| D | vpxpes_parser.cc | 129 std::size_t consumed = 0; in ParsePesOptionalHeader() local
204 std::size_t consumed = 0; in ParseBcmvHeader() local
290 std::size_t consumed = 0; in AccumulateFragmentedPayload() local
385 std::size_t consumed = 0; in ParseNextPacket() local
|
| /external/python/cpython2/Modules/ |
| D | _codecsmodule.c | 182 Py_ssize_t consumed, len; in escape_encode() local
239 Py_ssize_t consumed; in utf_7_decode() local
262 Py_ssize_t consumed; in utf_8_decode() local
286 Py_ssize_t consumed; in utf_16_decode() local
309 Py_ssize_t consumed; in utf_16_le_decode() local
333 Py_ssize_t consumed; in utf_16_be_decode() local
366 Py_ssize_t consumed; in utf_16_ex_decode() local
390 Py_ssize_t consumed; in utf_32_decode() local
413 Py_ssize_t consumed; in utf_32_le_decode() local
436 Py_ssize_t consumed; in utf_32_be_decode() local
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/ |
| D | quic_packet_creator_test.cc | 383 size_t consumed = frame.stream_frame.data_length; in TEST_P() local
397 size_t consumed = frame.stream_frame.data_length; in TEST_P() local
410 size_t consumed = frame.stream_frame.data_length; in TEST_P() local
1394 size_t consumed = frame.stream_frame.data_length; in TEST_P() local
1442 size_t consumed = frame.stream_frame.data_length; in TEST_P() local
2787 const bool consumed = in TEST_F() local
2817 const bool consumed = in TEST_F() local
2841 const bool consumed = in TEST_F() local
2906 QuicConsumedData consumed = creator_.ConsumeData( in TEST_F() local
2920 QuicConsumedData consumed = creator_.ConsumeData( in TEST_F() local
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/strings/ |
| D | cord_ring_reader_test.cc | 99 size_t consumed = reader.consumed(); in TEST() local
125 size_t consumed = 0; in TEST() local
150 size_t consumed = ring->length; in TEST() local
|
| /external/tensorflow/third_party/absl/abseil-cpp/absl/strings/ |
| D | cord_ring_reader_test.cc | 100 size_t consumed = reader.consumed(); in TEST() local
128 size_t consumed = 0; in TEST() local
155 size_t consumed = ring->length; in TEST() local
|
| /external/webrtc/third_party/abseil-cpp/absl/strings/ |
| D | cord_ring_reader_test.cc | 100 size_t consumed = reader.consumed(); in TEST() local
128 size_t consumed = 0; in TEST() local
155 size_t consumed = ring->length; in TEST() local
|
| /external/abseil-cpp/absl/strings/ |
| D | cord_ring_reader_test.cc | 100 size_t consumed = reader.consumed(); in TEST() local
128 size_t consumed = 0; in TEST() local
155 size_t consumed = ring->length; in TEST() local
|
| /external/cronet/third_party/abseil-cpp/absl/strings/ |
| D | cord_ring_reader_test.cc | 100 size_t consumed = reader.consumed(); in TEST() local
128 size_t consumed = 0; in TEST() local
155 size_t consumed = ring->length; in TEST() local
|
| /external/angle/third_party/abseil-cpp/absl/strings/ |
| D | cord_ring_reader_test.cc | 100 size_t consumed = reader.consumed(); in TEST() local
128 size_t consumed = 0; in TEST() local
155 size_t consumed = ring->length; in TEST() local
|
| /external/cronet/components/cronet/android/test/javatests/src/org/chromium/net/urlconnection/ |
| D | CronetInputStreamTest.java | 79 int consumed = 3; in testAvailable_partiallyRead() local
94 int consumed = 3; in testRead_afterDataCompleted() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/test/channels/ |
| D | ProduceConsumeTest.kt | 52 var consumed = 0 in testProducer() variable
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/ |
| D | Channels.kt | 101 private val consumed = atomic(false) in receiveAsFlow() constant
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/test_tools/ |
| D | simple_session_notifier.cc | 63 QuicConsumedData consumed = in WriteOrBufferData() local
212 QuicConsumedData consumed = connection_->SendStreamData( in OnCanWrite() local
358 size_t consumed = connection_->SendCryptoData(frame.crypto_frame->level, in RetransmitFrames() local
399 QuicConsumedData consumed(0, false); in RetransmitFrames() local
629 QuicConsumedData consumed = connection_->SendStreamData( in RetransmitLostCryptoData() local
646 QuicConsumedData consumed(0, false); in RetransmitLostStreamData() local
|
| /external/ltp/testcases/kernel/uevents/ |
| D | uevent.h | 47 int consumed = 0; in print_uevent() local
77 int consumed = 0; in uevent_match() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
| D | Limit.kt | 53 var consumed = 0 in take() variable
|
| /external/cronet/net/websockets/ |
| D | websocket_frame_parser.cc | 63 const size_t consumed = DecodeFrameHeader(incomplete_header_buffer_); in Decode() local
78 const size_t consumed = DecodeFrameHeader(data_span); in Decode() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/channels/ |
| D | ProduceConsumeJvmTest.kt | 38 var consumed = 0 in <lambda>() variable
|
| /external/apache-commons-bcel/src/main/java/org/apache/bcel/generic/ |
| D | Type.java | 341 static int consumed(final int coded) { in consumed() method in Type
345 static int encode(final int size, final int consumed) { in encode()
378 final int consumed = consumed(getTypeSize(signature.substring(dim))); in getTypeSize() local
|
| /external/rust/crates/tokio/tests/ |
| D | io_fill_buf.rs | 21 let consumed = { in fill_buf_file() localVariable
|
| /external/apache-commons-lang/src/main/java/org/apache/commons/lang3/text/translate/ |
| D | AggregateTranslator.java | 55 final int consumed = translator.translate(input, index, out); in translate() local
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
| D | SharedFlowStressTest.kt | 75 val consumed = totalConsumed.value in <lambda>() constant
|