Home
last modified time | relevance | path

Searched refs:consumed (Results 1 - 25 of 121) sorted by relevance

12345

/third_party/skia/third_party/externals/harfbuzz/test/api/
H A Dtest-draw.c34 unsigned consumed; member
101 if (user_data->consumed + 2 * ITOA_BUF_SIZE + 4 > user_data->size) return; in move_to()
102 user_data->str[user_data->consumed++] = 'M'; in move_to()
103 user_data->consumed += _hb_itoa (to_x, user_data->str + user_data->consumed); in move_to()
104 user_data->str[user_data->consumed++] = ','; in move_to()
105 user_data->consumed += _hb_itoa (to_y, user_data->str + user_data->consumed); in move_to()
111 if (user_data->consumed + 2 * ITOA_BUF_SIZE + 4 > user_data->size) return; in line_to()
112 user_data->str[user_data->consumed in line_to()
[all...]
/third_party/skia/third_party/externals/abseil-cpp/absl/strings/internal/
H A Dcord_rep_btree_reader_test.cc64 size_t consumed = chunk.length(); in TEST() local
65 EXPECT_THAT(reader.consumed(), Eq(consumed)); in TEST()
67 while (consumed < data.length()) { in TEST()
69 EXPECT_THAT(chunk, Eq(data.substr(consumed, chunk.length()))); in TEST()
71 consumed += chunk.length(); in TEST()
72 EXPECT_THAT(reader.consumed(), Eq(consumed)); in TEST()
75 EXPECT_THAT(consumed, Eq(data.length())); in TEST()
76 EXPECT_THAT(reader.consumed(), E in TEST()
96 size_t consumed = chunk.length(); TEST() local
253 size_t consumed = 0; TEST() local
[all...]
H A Dcord_rep_btree_reader.h35 // a `consumed` property which contains the end offset of the chunk last
46 // assumes that all data is directly 'consumed' by the caller. For example:
64 // It is important to notice that `consumed` represents the end position of the
74 // sv = reader.Init(tree); // sv = "abc", reader.consumed() = 3
75 // sv = reader.Skip(4); // sv = "hi", reader.consumed() = 9
76 // sv = reader.Skip(2); // sv = "l", reader.consumed() = 12
77 // sv = reader.Next(); // sv = "mno", reader.consumed() = 15
79 // In the above example, `reader.consumed()` reflects the data edges iterated
80 // over or skipped by the reader, not the amount of data 'consumed' by the
102 // total bytes 'consumed' relativ
169 inline size_t CordRepBtreeReader::consumed() const { consumed() function in absl::cord_internal::CordRepBtreeReader
[all...]
/third_party/skia/third_party/externals/abseil-cpp/absl/strings/
H A Dcord_ring_reader_test.cc64 EXPECT_DEATH_IF_SUPPORTED(reader.consumed(), ".*"); in TEST()
83 EXPECT_THAT(reader.consumed(), Eq(flats[0].length())); in TEST()
84 EXPECT_THAT(reader.remaining(), Eq(ring->length - reader.consumed())); in TEST()
100 size_t consumed = reader.consumed(); in TEST() local
104 consumed += flats[i].length(); in TEST()
110 ASSERT_THAT(reader.consumed(), Eq(consumed)); in TEST()
128 size_t consumed = 0; in TEST() local
132 size_t offset = consumed; in TEST()
155 size_t consumed = ring->length; TEST() local
[all...]
/third_party/ltp/testcases/kernel/uevents/
H A Duevent.h15 * the UDEV group which is consumed by various daemons in the userspace.
47 int consumed = 0; in print_uevent() local
51 while (consumed < len) { in print_uevent()
54 consumed += l; in print_uevent()
77 int consumed = 0; in uevent_match() local
85 consumed += l; in uevent_match()
88 while (consumed < len) { in uevent_match()
98 consumed += l; in uevent_match()
/third_party/node/deps/v8/src/objects/
H A Dstring-comparator.cc24 int consumed, const SharedStringAccessGuardIfNeeded& access_guard) { in Advance()
25 DCHECK(consumed <= length_); in Advance()
27 if (length_ != consumed) { in Advance()
29 buffer8_ += consumed; in Advance()
31 buffer16_ += consumed; in Advance()
33 length_ -= consumed; in Advance()
23 Advance( int consumed, const SharedStringAccessGuardIfNeeded& access_guard) Advance() argument
/third_party/ffmpeg/libavcodec/
H A Dsbcdec.c67 unsigned int consumed; in sbc_unpack_frame() local
115 consumed = 32; in sbc_unpack_frame()
121 if (len * 8 < consumed + frame->subbands) in sbc_unpack_frame()
132 consumed += frame->subbands; in sbc_unpack_frame()
136 if (len * 8 < consumed + (4 * frame->subbands * frame->channels)) in sbc_unpack_frame()
141 /* FIXME assert(consumed % 4 == 0); */ in sbc_unpack_frame()
143 (data[consumed >> 3] >> (4 - (consumed & 0x7))) & 0x0F; in sbc_unpack_frame()
147 consumed += 4; in sbc_unpack_frame()
177 if (consumed > le in sbc_unpack_frame()
[all...]
H A Dav1_parse.c59 int ret, consumed; in ff_av1_packet_split() local
83 consumed = ff_av1_extract_obu(obu, bc.buffer, bytestream2_get_bytes_left(&bc), logctx); in ff_av1_packet_split()
84 if (consumed < 0) in ff_av1_packet_split()
85 return consumed; in ff_av1_packet_split()
87 bytestream2_skip(&bc, consumed); in ff_av1_packet_split()
H A Dtak_parser.c45 int consumed = 0; in tak_parse() local
70 consumed += tmp_buf_size; in tak_parse()
105 if (consumed && !buf_size && next == END_NOT_FOUND || in tak_parse()
111 next += consumed; in tak_parse()
122 return buf_size + consumed; in tak_parse()
H A Dopus_celt.c122 int consumed, bits = f->transient ? 2 : 4; in celt_decode_tf_changes() local
124 consumed = opus_rc_tell(rc); in celt_decode_tf_changes()
125 tf_select_bit = (f->size != 0 && consumed+bits+1 <= f->framebits); in celt_decode_tf_changes()
128 if (consumed+bits+tf_select_bit <= f->framebits) { in celt_decode_tf_changes()
130 consumed = opus_rc_tell(rc); in celt_decode_tf_changes()
233 static int parse_postfilter(CeltFrame *f, OpusRangeCoder *rc, int consumed) in parse_postfilter() argument
240 if (f->start_band == 0 && consumed + 16 <= f->framebits) { in parse_postfilter()
262 consumed = opus_rc_tell(rc); in parse_postfilter()
265 return consumed; in parse_postfilter()
325 int consumed; // bit in ff_celt_decode_frame() local
[all...]
H A Dh2645_parse.c401 int consumed, ret = 0; in ff_h2645_packet_split() local
483 consumed = ff_h2645_extract_rbsp(bc.buffer, extract_length, &pkt->rbsp, nal, small_padding); in ff_h2645_packet_split()
484 if (consumed < 0) in ff_h2645_packet_split()
485 return consumed; in ff_h2645_packet_split()
487 if (is_nalff && (extract_length != consumed) && extract_length) in ff_h2645_packet_split()
490 consumed, extract_length); in ff_h2645_packet_split()
492 bytestream2_skip(&bc, consumed); in ff_h2645_packet_split()
/third_party/python/Lib/asyncio/
H A Dexceptions.py51 - consumed: total number of to be consumed bytes.
53 def __init__(self, message, consumed):
55 self.consumed = consumed
58 return type(self), (self.args[0], self.consumed)
/third_party/python/Lib/encodings/
H A Dutf_8_sig.py23 (output, consumed) = codecs.utf_8_decode(input, errors, True)
24 return (output, consumed+prefix)
66 (output, consumed) = \
68 return (output, consumed+3)
113 (output, consumed) = codecs.utf_8_decode(input[3:],errors)
114 return (output, consumed+3)
H A Dutf_16.py60 (output, consumed, byteorder) = \
66 elif consumed >= 2:
68 return (output, consumed)
134 (object, consumed, byteorder) = \
140 elif consumed>=2:
142 return (object, consumed)
H A Dutf_32.py55 (output, consumed, byteorder) = \
61 elif consumed >= 4:
63 return (output, consumed)
129 (object, consumed, byteorder) = \
135 elif consumed>=4:
137 return (object, consumed)
/third_party/curl/tests/libtest/
H A Dlib1591.c35 static size_t consumed = 0; variable
41 if(consumed == strlen(data)) { in read_callback()
45 if(amount > strlen(data)-consumed) { in read_callback()
49 consumed += amount; in read_callback()
/third_party/alsa-utils/axfer/
H A Dcontainer.c47 size_t consumed = 0; in container_recursive_read() local
49 while (consumed < byte_count && !cntr->interrupted) { in container_recursive_read()
50 result = read(cntr->fd, dst + consumed, byte_count - consumed); in container_recursive_read()
66 consumed += result; in container_recursive_read()
77 size_t consumed = 0; in container_recursive_write() local
79 while (consumed < byte_count && !cntr->interrupted) { in container_recursive_write()
80 result = write(cntr->fd, src + consumed, byte_count - consumed); in container_recursive_write()
91 consumed in container_recursive_write()
[all...]
/third_party/node/deps/openssl/openssl/crypto/
H A Dasn1_dsa.c185 * were consumed.
221 * past the data that was consumed.
227 * Returns the number of bytes of input consumed or 0 if an error occurs.
231 * were consumed.
236 size_t consumed; in ossl_decode_der_dsa_sig() local
249 consumed = PACKET_data(&pkt) - *ppin; in ossl_decode_der_dsa_sig()
250 *ppin += consumed; in ossl_decode_der_dsa_sig()
251 return consumed; in ossl_decode_der_dsa_sig()
/third_party/openssl/crypto/
H A Dasn1_dsa.c185 * were consumed.
221 * past the data that was consumed.
227 * Returns the number of bytes of input consumed or 0 if an error occurs.
231 * were consumed.
236 size_t consumed; in ossl_decode_der_dsa_sig() local
249 consumed = PACKET_data(&pkt) - *ppin; in ossl_decode_der_dsa_sig()
250 *ppin += consumed; in ossl_decode_der_dsa_sig()
251 return consumed; in ossl_decode_der_dsa_sig()
/third_party/libwebsockets/lib/roles/mqtt/
H A Dprimitives.c68 vbi->consumed = 0; in lws_mqtt_vbi_init()
76 vbi->consumed = 0; in lws_mqtt_2byte_init()
84 vbi->consumed = 0; in lws_mqtt_4byte_init()
102 vbi->consumed++; in lws_mqtt_vbi_r()
127 vbi->consumed++; in lws_mqtt_mb_parse()
148 s->len = 0; /* at COMPLETED, consumed count is s->len + 2 */ in lws_mqtt_str_init()
/third_party/rust/crates/nix/test/sys/
H A Dtest_uio.rs31 let mut consumed = 0; in test_writev() variables
32 while consumed < to_write.len() { in test_writev()
33 let left = to_write.len() - consumed; in test_writev()
39 let b = &to_write[consumed..consumed + slice_len]; in test_writev()
41 consumed += slice_len; in test_writev()
/third_party/pulseaudio/src/pulsecore/resampler/
H A Dsoxr.c33 size_t consumed = 0, produced = 0; in resampler_soxr_resample() local
46 pa_assert_se(soxr_process(state, in, in_n_frames, &consumed, out, *out_n_frames, &produced) == 0); in resampler_soxr_resample()
53 return in_n_frames - consumed; in resampler_soxr_resample()
/third_party/skia/third_party/externals/brotli/go/cbrotli/
H A Dreader.go102 var written, consumed C.size_t
110 &written, &consumed)
111 r.in = r.in[int(consumed):]
/third_party/ffmpeg/libavresample/
H A Dresample.c260 int *consumed, int src_size, int dst_size, int update_ctx, in resample()
314 if (consumed) in resample()
315 *consumed = index >> c->phase_shift; in resample()
336 int ch, in_samples, in_leftover, consumed = 0, out_samples = 0; in ff_audio_resample() local
418 (const void *)c->buffer->data[ch], &consumed, in ff_audio_resample()
427 /* drain consumed samples from the internal buffer */ in ff_audio_resample()
428 ff_audio_data_drain(c->buffer, consumed); in ff_audio_resample()
429 c->initial_padding_samples = FFMAX(c->initial_padding_samples - consumed, 0); in ff_audio_resample()
259 resample(ResampleContext *c, void *dst, const void *src, int *consumed, int src_size, int dst_size, int update_ctx, int nearest_neighbour) resample() argument
/third_party/node/deps/undici/src/lib/mock/
H A Dmock-utils.js133 let matchedMockDispatches = mockDispatches.filter(({ consumed }) => !consumed).filter(({ path }) => matchValue(safeUrl(path), resolvedPath))
160 const baseData = { timesInvoked: 0, times: 1, persist: false, consumed: false }
169 if (!dispatch.consumed) {
233 // If it's used up and not persistent, mark as consumed
234 mockDispatch.consumed = !persist && timesInvoked >= times

Completed in 14 milliseconds

12345