Home
last modified time | relevance | path

Searched refs:buffered (Results 1 - 25 of 46) sorted by relevance

12

/third_party/python/Modules/_io/
H A Dbufferedio.c20 class _io._Buffered "buffered *" "&PyBufferedIOBase_Type"
21 class _io.BufferedReader "buffered *" "&PyBufferedReader_Type"
22 class _io.BufferedWriter "buffered *" "&PyBufferedWriter_Type"
24 class _io.BufferedRandom "buffered *" "&PyBufferedRandom_Type"
32 "Base class for buffered IO objects.\n"
210 /* Just after the last buffered byte in the buffer, or -1 if the buffer
228 } buffered; typedef
253 /* These macros protect the buffered object against concurrent operations. */
256 _enter_buffered_busy(buffered *self) in _enter_buffered_busy()
367 buffered_dealloc(buffered *sel
[all...]
/third_party/python/Modules/_io/clinic/
H A Dbufferedio.c.h109 _io__Buffered_peek_impl(buffered *self, Py_ssize_t size);
112 _io__Buffered_peek(buffered *self, PyObject *const *args, Py_ssize_t nargs) in _io__Buffered_peek()
151 _io__Buffered_read_impl(buffered *self, Py_ssize_t n);
154 _io__Buffered_read(buffered *self, PyObject *const *args, Py_ssize_t nargs) in _io__Buffered_read()
184 _io__Buffered_read1_impl(buffered *self, Py_ssize_t n);
187 _io__Buffered_read1(buffered *self, PyObject *const *args, Py_ssize_t nargs) in _io__Buffered_read1()
226 _io__Buffered_readinto_impl(buffered *self, Py_buffer *buffer);
229 _io__Buffered_readinto(buffered *self, PyObject *arg) in _io__Buffered_readinto()
263 _io__Buffered_readinto1_impl(buffered *self, Py_buffer *buffer);
266 _io__Buffered_readinto1(buffered *sel
[all...]
/third_party/node/lib/internal/streams/
H A Dwritable.js135 // When true all writes will be buffered until .uncork() call.
144 // A flag to know if we're processing previously buffered items, which
203 state.buffered = [];
210 return ArrayPrototypeSlice(this.buffered, this.bufferedIndex);
216 return this.buffered.length - this.bufferedIndex;
380 state.buffered.push({ chunk, encoding, callback });
421 // it's related to one specific write, not to the buffered
463 if (state.buffered.length > state.bufferedIndex) {
516 for (let n = state.bufferedIndex; n < state.buffered.length; ++n) {
517 const { chunk, callback } = state.buffered[
[all...]
/third_party/node/test/parallel/
H A Dtest-stream2-readable-legacy-drain.js40 let buffered = 0;
42 buffered += c.length;
48 assert(buffered <= 3);
49 buffered = 0;
/third_party/skia/client_utils/android/
H A DFrontBufferedStream.cpp44 // Amount that has been buffered by calls to read. Will always be less than
53 // Read up to size bytes from already buffered data, and copy to
64 // nullptr. Updates fOffset. Assumes fOffset is at or beyond the buffered
131 // lesser of the size requested and the remainder of the buffered in readFromBuffer()
139 // within the buffered data. in readFromBuffer()
150 // Data needs to be buffered. Buffer up to the lesser of the size requested
154 const size_t buffered = fStream->read(buffer, bytesToBuffer); local
156 fBufferedSoFar += buffered;
162 memcpy(dst, buffer, buffered);
165 return buffered;
224 const size_t buffered = this->bufferAndWriteTo(dst, size); read() local
[all...]
/third_party/node/deps/npm/node_modules/https-proxy-agent/dist/
H A Dparse-proxy-response.js42 const buffered = Buffer.concat(buffers, buffersLength);
43 const endOfHeaders = buffered.indexOf('\r\n\r\n');
50 const headerParts = buffered
92 buffered,
H A Dindex.js116 const { connect, buffered } = await proxyResponsePromise;
151 // Replay the "buffered" Buffer onto the fake `socket`, since at
154 s.push(buffered);
/third_party/libwebsockets/lib/roles/raw-proxy/
H A Dops-raw-proxy.c32 int n, buffered; in rops_handle_POLLIN_raw_proxy() local
62 buffered = lws_buflist_aware_read(pt, wsi, &ebuf, 1, __func__); in rops_handle_POLLIN_raw_proxy()
63 if (buffered < 0) in rops_handle_POLLIN_raw_proxy()
98 buffered, __func__)) in rops_handle_POLLIN_raw_proxy()
/third_party/cJSON/fuzzing/
H A Dcjson_read_fuzzer.c19 int minify, require_termination, formatted, buffered; in LLVMFuzzerTestOneInput() local
32 buffered = data[3] == '1' ? 1 : 0; in LLVMFuzzerTestOneInput()
38 if(buffered) in LLVMFuzzerTestOneInput()
/third_party/skia/tests/
H A DStreamBufferTest.cpp36 size_t buffered = length / 2; in test_buffer_from_beginning() local
37 REPORTER_ASSERT(r, buffer.buffer(buffered)); in test_buffer_from_beginning()
38 REPORTER_ASSERT(r, !memcmp(buffer.get(), gText, buffered)); in test_buffer_from_beginning()
41 REPORTER_ASSERT(r, buffer.buffer(buffered / 2)); in test_buffer_from_beginning()
/third_party/pulseaudio/speex/libspeexdsp/
H A Djitter.c141 spx_int32_t buffered; /**< Amount of data we think is still buffered by the application (timestamp units)*/ member
314 jitter->buffered = 0; in jitter_buffer_reset()
513 jitter->buffered = packet->span - desired_span; in jitter_buffer_get()
624 jitter->buffered = packet->span - desired_span; in jitter_buffer_get()
627 jitter->buffered += *start_offset; in jitter_buffer_get()
655 jitter->buffered = packet->span - desired_span; in jitter_buffer_get()
668 jitter->buffered = packet->span - desired_span; in jitter_buffer_get()
756 if (jitter->buffered >= 0) in jitter_buffer_tick()
758 jitter->next_stop = jitter->pointer_timestamp - jitter->buffered; in jitter_buffer_tick()
[all...]
/third_party/libwebsockets/lib/core-net/
H A Dservice.c251 uint8_t *buffered; in lws_rxflow_cache() local
256 blen = lws_buflist_next_segment_len(&wsi->buflist, &buffered); in lws_rxflow_cache()
258 if (buf >= buffered && buf + len <= buffered + blen && in lws_rxflow_cache()
357 * 4) If there is any wsi with rxflow buffered and in a state to process in lws_service_adjust_timeout()
473 int used, int buffered, const char *hint) in lws_buflist_aware_finished_consuming()
480 if (!used && buffered) in lws_buflist_aware_finished_consuming()
483 if (used && buffered) { in lws_buflist_aware_finished_consuming()
603 * 2) For all guys with buffered SSL read data already saved up, if they in lws_service_flag_pending()
605 * service to use up the buffered incomin in lws_service_flag_pending()
472 lws_buflist_aware_finished_consuming(struct lws *wsi, struct lws_tokens *ebuf, int used, int buffered, const char *hint) lws_buflist_aware_finished_consuming() argument
[all...]
/third_party/python/Tools/unicode/
H A Dgenmap_support.py12 self.buffered = []
30 self.buffered.append(''.join(self.cline))
36 for l in self.buffered:
38 del self.buffered[:]
/third_party/ffmpeg/libavdevice/
H A Ddecklink_enc.cpp441 uint32_t buffered; in decklink_write_video_packet() local
481 /* Always keep at most one second of frames buffered. */ in decklink_write_video_packet()
501 ctx->dlo->GetBufferedVideoFrameCount(&buffered); in decklink_write_video_packet()
502 av_log(avctx, AV_LOG_DEBUG, "Buffered video frames: %d.\n", (int) buffered); in decklink_write_video_packet()
503 if (pkt->pts > 2 && buffered <= 2) in decklink_write_video_packet()
504 av_log(avctx, AV_LOG_WARNING, "There are not enough buffered video frames." in decklink_write_video_packet()
530 uint32_t buffered; in decklink_write_audio_packet() local
532 ctx->dlo->GetBufferedAudioSampleFrameCount(&buffered); in decklink_write_audio_packet()
533 if (pkt->pts > 1 && !buffered) in decklink_write_audio_packet()
534 av_log(avctx, AV_LOG_WARNING, "There's no buffered audi in decklink_write_audio_packet()
[all...]
/third_party/libwebsockets/lib/roles/raw-skt/
H A Dops-raw-skt.c86 int n = 0, buffered = 0; local
177 buffered = lws_buflist_aware_read(pt, wsi, &ebuf, 1, __func__);
221 buffered, __func__))
/third_party/libwebsockets/lib/roles/mqtt/
H A Dops-mqtt.c34 char buffered = 0; in rops_handle_POLLIN_mqtt() local
96 buffered = 1; in rops_handle_POLLIN_mqtt()
120 buffered = 0; in rops_handle_POLLIN_mqtt()
168 buffered, __func__)) in rops_handle_POLLIN_mqtt()
182 if (buffered && /* were draining, now nothing left */ in rops_handle_POLLIN_mqtt()
/third_party/libwebsockets/lib/roles/mqtt/client/
H A Dclient-mqtt.c194 int buffered = 0; in lws_mqtt_client_socket_service() local
309 buffered = 0; in lws_mqtt_client_socket_service()
349 buffered, in lws_mqtt_client_socket_service()
/third_party/node/src/
H A Dnode_dtrace.cc111 SLURP_INT(_##conn, bufferSize, &conn.buffered);
123 SLURP_INT(_##conn, bufferSize, &conn.buffered);
137 SLURP_INT(_##conn, bufferSize, &conn.buffered); \
H A Dnode_dtrace.h42 int32_t buffered; member
/third_party/libwebsockets/lib/roles/http/client/
H A Dclient-http.c404 int n, m, buffered; in lws_http_client_socket_service() local
408 buffered = lws_buflist_aware_read(pt, wsi, &eb, 0, __func__); in lws_http_client_socket_service()
410 buffered, eb.len); in lws_http_client_socket_service()
413 if (buffered < 0 || eb.len < 0) { in lws_http_client_socket_service()
444 buffered, in lws_http_client_socket_service()
1330 int buffered, n, consumed = 0; in lws_http_client_read() local
1343 buffered = lws_buflist_aware_read(pt, wsi, &eb, 0, __func__); in lws_http_client_read()
1359 if (buffered < 0) { in lws_http_client_read()
1564 if (lws_buflist_aware_finished_consuming(wsi, &eb, consumed, buffered, in lws_http_client_read()
/third_party/libwebsockets/lib/roles/h2/
H A Dops-h2.c103 char buffered = 0; in rops_handle_POLLIN_h2() local
187 lwsl_info("%s: has buffered out\n", __func__); in rops_handle_POLLIN_h2()
207 buffered = 1; in rops_handle_POLLIN_h2()
305 if (n && buffered) { in rops_handle_POLLIN_h2()
802 uint8_t *buffered; in lws_h2_bind_for_post_before_action() local
884 (blen = lws_buflist_next_segment_len(&wsi->buflist, &buffered))) { in lws_h2_bind_for_post_before_action()
890 wsi->user_space, buffered, blen)) in lws_h2_bind_for_post_before_action()
977 /* priority 1: post compression-transform buffered output */ in rops_perform_user_POLLOUT_h2()
993 /* priority 2: pre compression-transform buffered output */ in rops_perform_user_POLLOUT_h2()
1016 /* priority 3: if no buffered ou in rops_perform_user_POLLOUT_h2()
[all...]
/third_party/node/benchmark/perf_hooks/
H A Dusertiming.js28 obs.observe({ entryTypes, buffered: true });
H A Dresourcetiming.js72 obs.observe({ entryTypes: [observe], buffered: true });
/third_party/libwebsockets/lib/roles/h1/
H A Dops-h1.c335 int n, buffered; in lws_h1_server_socket_service() local
394 buffered = lws_buflist_aware_read(pt, wsi, &ebuf, 0, __func__); in lws_h1_server_socket_service()
430 // lwsl_notice("stashing: wsi %p: bd %d\n", wsi, buffered); in lws_h1_server_socket_service()
432 buffered, __func__)) in lws_h1_server_socket_service()
454 buffered, __func__)) in lws_h1_server_socket_service()
/third_party/node/deps/icu-small/source/tools/toolutil/
H A Ducbuf.h55 * @param buffered If true performs a buffered read of the input file. If false reads
63 ucbuf_open(const char* fileName,const char** codepage,UBool showWarning, UBool buffered, UErrorCode* err);

Completed in 15 milliseconds

12