/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 in benchmarks.flow.TakeBenchmark
|
/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/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/kotlinx.coroutines/integration/kotlinx-coroutines-jdk8/src/stream/ |
D | Stream.kt | 20 private val consumed = atomic(false) in consumeAsFlow() constant in kotlinx.coroutines.stream.StreamFlow
|
/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/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/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/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/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/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 | 126 private val consumed = atomic(false) in receiveAsFlow() constant
|
/external/kotlinx.coroutines/kotlinx-coroutines-core/common/src/flow/operators/ |
D | Limit.kt | 53 var consumed = 0 in take() variable
|
/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/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/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/flow/ |
D | SharedFlowStressTest.kt | 75 val consumed = totalConsumed.value in <lambda>() constant
|
/external/minijail/ |
D | minijail0.c | 27 int consumed = parse_args(j, argc, argv, environ, in main() local
|
/external/pdfium/core/fxcodec/ |
D | cfx_codec_memory.cpp | 44 void CFX_CodecMemory::Consume(size_t consumed) { in Consume()
|
/external/libxml2/fuzz/ |
D | html.c | 31 size_t docSize, consumed, chunkSize; in LLVMFuzzerTestOneInput() local
|
/external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/strings/internal/ |
D | cord_rep_ring_reader.h | 55 size_t consumed() const { in consumed() function
|
/external/openscreen/osp/public/ |
D | message_demuxer.h | 92 size_t consumed; member
|
/external/libwebsockets/include/libwebsockets/ |
D | lws-ring.h | 266 ___count, /* count of payload objects being consumed */ \ argument 301 ___count /* count of payload objects being consumed */ \ argument
|
/external/kotlinx.coroutines/kotlinx-coroutines-core/jvm/test/internal/ |
D | LockFreeTaskQueueStressTest.kt | 34 private val consumed = atomic(0L) in <lambda>() constant in kotlinx.coroutines.internal.LockFreeTaskQueueStressTest
|
/external/abseil-cpp/absl/strings/internal/ |
D | cord_rep_ring_reader.h | 59 size_t consumed() const { in consumed() function
|