/third_party/python/Modules/_io/ |
H A D | bufferedio.c | 20 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 D | bufferedio.c.h | 109 _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 D | writable.js | 135 // 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 D | test-stream2-readable-legacy-drain.js | 40 let buffered = 0; 42 buffered += c.length; 48 assert(buffered <= 3); 49 buffered = 0;
|
/third_party/skia/client_utils/android/ |
H A D | FrontBufferedStream.cpp | 44 // 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 D | parse-proxy-response.js | 42 const buffered = Buffer.concat(buffers, buffersLength); 43 const endOfHeaders = buffered.indexOf('\r\n\r\n'); 50 const headerParts = buffered 92 buffered,
|
H A D | index.js | 116 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 D | ops-raw-proxy.c | 32 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 D | cjson_read_fuzzer.c | 19 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 D | StreamBufferTest.cpp | 36 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 D | jitter.c | 141 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 D | service.c | 251 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 D | genmap_support.py | 12 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 D | decklink_enc.cpp | 441 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 D | ops-raw-skt.c | 86 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 D | ops-mqtt.c | 34 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 D | client-mqtt.c | 194 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 D | node_dtrace.cc | 111 SLURP_INT(_##conn, bufferSize, &conn.buffered); 123 SLURP_INT(_##conn, bufferSize, &conn.buffered); 137 SLURP_INT(_##conn, bufferSize, &conn.buffered); \
|
H A D | node_dtrace.h | 42 int32_t buffered; member
|
/third_party/libwebsockets/lib/roles/http/client/ |
H A D | client-http.c | 404 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 D | ops-h2.c | 103 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 D | usertiming.js | 28 obs.observe({ entryTypes, buffered: true });
|
H A D | resourcetiming.js | 72 obs.observe({ entryTypes: [observe], buffered: true });
|
/third_party/libwebsockets/lib/roles/h1/ |
H A D | ops-h1.c | 335 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 D | ucbuf.h | 55 * @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);
|