| /third_party/node/test/parallel/ |
| D | test-file-write-stream.js | 39 drain: -2, property
50 console.error('drain!', callbacks.drain);
51 callbacks.drain++;
52 if (callbacks.drain === -1) {
55 } else if (callbacks.drain === 0) {
|
| D | test-http-header-owstext.js | 21 client.write('GET / HTTP/1.1\r\n' + hdr + ':', drain);
24 function drain() { function
28 client.write(snd.shift(), drain);
|
| D | test-stream2-readable-legacy-drain.js | 43 process.nextTick(drain);
47 function drain() { function
|
| /third_party/gstreamer/gstplugins_bad/tests/check/elements/ |
| D | mpegtsmux.c | 150 GstQuery *drain; in check_tsmux_pad_given_muxer() local
181 drain = gst_query_new_drain (); in check_tsmux_pad_given_muxer()
182 gst_pad_peer_query (mysrcpad, drain); in check_tsmux_pad_given_muxer()
183 gst_query_unref (drain); in check_tsmux_pad_given_muxer()
506 GstQuery *drain; in GST_START_TEST() local
525 drain = gst_query_new_drain (); in GST_START_TEST()
526 gst_pad_peer_query (mysrcpad, drain); in GST_START_TEST()
527 gst_query_unref (drain); in GST_START_TEST()
|
| /third_party/ffmpeg/libavcodec/ |
| D | pcm_rechunk_bsf.c | 120 int drain = FFMIN(s->in_pkt->size, data_size - s->out_pkt->size); in rechunk_filter() local
132 memcpy(s->out_pkt->data + s->out_pkt->size, s->in_pkt->data, drain); in rechunk_filter()
133 s->out_pkt->size += drain; in rechunk_filter()
134 drain_packet(s->in_pkt, drain, drain / s->sample_size); in rechunk_filter()
|
| /third_party/skia/tools/ |
| D | AutoreleasePool.h | 21 void drain();
32 void drain() {} in drain() function
|
| D | AutoreleasePool.mm | 22 void AutoreleasePool::drain() { function
23 [(NSAutoreleasePool*)fPool drain];
|
| /third_party/pulseaudio/src/utils/ |
| D | pasuspender.c | 64 static void drain(void) { in drain() function
117 drain(); /* drain and quit */ in resume_complete()
133 drain(); in resume()
172 drain(); in context_state_callback()
|
| /third_party/ffmpeg/libavfilter/ |
| D | f_loop.c | 140 int drain = 0; in afilter_frame() local
146 drain = FFMAX(0, s->start - s->ignored_samples); in afilter_frame()
148 av_audio_fifo_drain(s->fifo, drain); in afilter_frame()
151 s->nb_samples += ret - drain; in afilter_frame()
152 drain = frame->nb_samples - written; in afilter_frame()
153 if (s->nb_samples == s->size && drain > 0) { in afilter_frame()
159 av_audio_fifo_drain(s->left, drain); in afilter_frame()
|
| /third_party/python/Doc/library/ |
| D | asyncio-stream.rst | 30 await writer.drain()
260 The method should be used along with the ``drain()`` method::
263 await stream.drain()
272 The method should be used along with the ``drain()`` method::
275 await stream.drain()
305 .. coroutinemethod:: drain()
311 await writer.drain()
315 the high watermark, *drain()* blocks until the size of the
317 be resumed. When there is nothing to wait for, the :meth:`drain`
389 await writer.drain()
|
| /third_party/node/deps/undici/src/docs/api/ |
| D | BalancedPool.md | 97 ### Event: `'drain'`
99 See [Dispatcher Event: `'drain'`](Dispatcher.md#event-drain).
|
| D | Pool.md | 82 ### Event: `'drain'`
84 See [Dispatcher Event: `'drain'`](Dispatcher.md#event-drain).
|
| D | Client.md | 233 ### Event: `'drain'`
237 See [Dispatcher Event: `'drain'`](Dispatcher.md#event-drain).
239 #### Example - Client drain event argument
254 client.on('drain', () => {
255 console.log('drain event')
|
| /third_party/nghttp2/src/ |
| D | shrpx_client_handler.cc | 371 rb_.drain(nread); in upstream_http2_connhd_read()
409 rb_.drain(nread); in upstream_http1_connhd_read()
1372 rb_.drain(HEADER.size()); in proxy_protocol_read()
1405 rb_.drain(5); in proxy_protocol_read()
1420 rb_.drain(end + 2 - rb_.pos()); in proxy_protocol_read()
1445 rb_.drain(token_end - rb_.pos() + 1); in proxy_protocol_read()
1466 rb_.drain(token_end - rb_.pos() + 1); in proxy_protocol_read()
1481 rb_.drain(n + 1); in proxy_protocol_read()
1494 rb_.drain(end + 2 - rb_.pos()); in proxy_protocol_read()
1608 rb_.drain(PROXY_PROTO_V2_HDLEN + len); in proxy_protocol_v2_read()
[all …]
|
| D | shrpx_connection.cc | 488 tls.wbuf.drain(nwrite); in tls_handshake()
532 tls.wbuf.drain(nwrite); in tls_handshake()
771 tls.wbuf.drain(nwrite); in write_tls_pending_handshake()
984 wlimit.drain(rv); in write_tls()
1112 wlimit.drain(nwrite); in write_clear()
1139 wlimit.drain(nwrite); in writev_clear()
1168 rlimit.drain(nread); in read_clear()
|
| D | memchunk.h | 303 size_t drain(size_t count) { in drain() function
512 void disable_peek(bool drain) { in disable_peek()
516 if (drain) { in disable_peek()
518 memchunks.drain(n); in disable_peek()
639 size_t drain(size_t count) { in drain() function
|
| D | shrpx_rate_limit.h | 46 void drain(size_t n);
|
| D | buffer_test.cc | 50 b.drain(3); in test_buffer_write()
|
| /third_party/rust/crates/regex/regex-syntax/src/hir/ |
| D | interval.rs | 136 self.ranges.drain(..drain_end); in intersect()
228 self.ranges.drain(..drain_end); in difference()
278 self.ranges.drain(..drain_end); in negate()
306 self.ranges.drain(..drain_end); in canonicalize()
|
| /third_party/gstreamer/gstplugins_base/tests/check/elements/ |
| D | audiomixer.c | 817 GstQuery *drain = gst_query_new_drain (); in GST_START_TEST() local
879 gst_pad_query (sinkpad, drain); in GST_START_TEST()
890 gst_pad_query (sinkpad, drain); in GST_START_TEST()
904 gst_pad_query (sinkpad, drain); in GST_START_TEST()
921 gst_pad_query (sinkpad, drain); in GST_START_TEST()
930 gst_query_unref (drain); in GST_START_TEST()
1875 GstQuery *drain = gst_query_new_drain (); in GST_START_TEST() local
1931 gst_pad_query (sinkpad, drain); in GST_START_TEST()
1960 gst_query_unref (drain); in GST_START_TEST()
1986 GstQuery *drain; in GST_START_TEST() local
[all …]
|
| /third_party/rust/crates/cxx/syntax/ |
| D | report.rs | 23 let mut iter = self.errors.drain(..); in propagate()
|
| /third_party/gstreamer/gstplugins_good/gst/audioparsers/ |
| D | gstaacparse.c | 428 const guint8 * data, const guint avail, gboolean drain, in gst_aac_parse_check_adts_frame() argument
473 if (drain || !GST_BASE_PARSE_LOST_SYNC (aacparse)) { in gst_aac_parse_check_adts_frame()
792 const guint8 * data, const guint avail, gboolean drain, in gst_aac_parse_check_loas_frame() argument
813 if (drain || !GST_BASE_PARSE_LOST_SYNC (aacparse)) { in gst_aac_parse_check_loas_frame()
886 const guint8 * data, const guint avail, gboolean drain, in gst_aac_parse_detect_stream() argument
927 if (gst_aac_parse_check_adts_frame (aacparse, data, avail, drain, in gst_aac_parse_detect_stream()
953 if (gst_aac_parse_check_loas_frame (aacparse, data, avail, drain, in gst_aac_parse_detect_stream()
|
| /third_party/mesa3d/src/vulkan/runtime/ |
| D | vk_sync_timeline.c | 125 bool drain);
250 bool drain) in vk_sync_timeline_gc_locked() argument
270 if (point->refcount > 0 && !drain) in vk_sync_timeline_gc_locked()
|
| /third_party/node/doc/api/ |
| D | tty.md | 134 for the `'drain'` event to be emitted before continuing to write additional
152 for the `'drain'` event to be emitted before continuing to write additional
181 for the `'drain'` event to be emitted before continuing to write additional
289 for the `'drain'` event to be emitted before continuing to write additional
|
| /third_party/FreeBSD/sys/compat/linuxkpi/common/src/ |
| D | linux_usb.c | 466 struct urb *urb, uint8_t drain) in usb_unlink_bsd() argument
473 if (drain) { in usb_unlink_bsd()
485 usb_unlink_urb_sub(struct urb *urb, uint8_t drain) in usb_unlink_urb_sub() argument
499 if (drain) in usb_unlink_urb_sub()
531 usb_unlink_bsd(uhe->bsd_xfer[0], urb, drain); in usb_unlink_urb_sub()
532 usb_unlink_bsd(uhe->bsd_xfer[1], urb, drain); in usb_unlink_urb_sub()
536 if (drain) in usb_unlink_urb_sub()
|