| /third_party/node/test/parallel/ |
| H A D | test-file-write-stream.js | 39 drain: -2,
49 .on('drain', function() {
50 console.error('drain!', callbacks.drain);
51 callbacks.drain++;
52 if (callbacks.drain === -1) {
55 } else if (callbacks.drain === 0) {
|
| H A D | test-http-header-owstext.js | 21 client.write('GET / HTTP/1.1\r\n' + hdr + ':', drain);
24 function drain() {
28 client.write(snd.shift(), drain);
|
| H A D | test-stream2-readable-legacy-drain.js | 43 process.nextTick(drain);
47 function drain() { function
50 w.emit('drain');
|
| H A D | test-fs-write-stream.js | 49 stream.on('drain', function() {
50 assert.fail('\'drain\' event must not be emitted before ' +
|
| /third_party/ffmpeg/libavcodec/ |
| H A D | pcm_rechunk_bsf.c | 121 int drain = FFMIN(s->in_pkt->size, data_size - s->out_pkt->size); in rechunk_filter() local
133 memcpy(s->out_pkt->data + s->out_pkt->size, s->in_pkt->data, drain); in rechunk_filter()
134 s->out_pkt->size += drain; in rechunk_filter()
135 drain_packet(s->in_pkt, drain, drain / s->sample_size); in rechunk_filter()
|
| /third_party/skia/tools/ |
| H A D | AutoreleasePool.h | 21 void drain();
32 void drain() {} in drain() function in AutoreleasePool
|
| /third_party/ffmpeg/libavfilter/ |
| H A D | f_loop.c | 141 int drain = 0; in afilter_frame() local
147 drain = FFMAX(0, s->start - s->ignored_samples); in afilter_frame()
149 av_audio_fifo_drain(s->fifo, drain); in afilter_frame()
152 s->nb_samples += ret - drain; in afilter_frame()
153 drain = frame->nb_samples - written; in afilter_frame()
154 if (s->nb_samples == s->size && drain > 0) { in afilter_frame()
160 av_audio_fifo_drain(s->left, drain); in afilter_frame()
|
| /third_party/pulseaudio/src/utils/ |
| H A 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/nghttp2/src/ |
| H A 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()
1065 rlimit.drain(nread); in read_tls()
1101 rlimit.drain(rv); in read_tls()
1125 wlimit.drain(nwrite); in write_clear()
1152 wlimit.drain(nwrite); in writev_clear()
1181 rlimit.drain(nread); in read_clear()
|
| H A 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_HDLE in proxy_protocol_v2_read()
[all...] |
| H A 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
|
| H A D | shrpx_rate_limit.h | 46 void drain(size_t n);
|
| H A D | buffer_test.cc | 50 b.drain(3); in test_buffer_write()
|
| H A D | buffer.h | 56 size_t drain(size_t count) { in drain() function
|
| H A D | shrpx_rate_limit.cc | 66 void RateLimit::drain(size_t n) { in drain() function in shrpx::RateLimit
|
| /third_party/rust/crates/regex/regex-syntax/src/hir/ |
| H A D | interval.rs | 113 // the intersection to the end of this range, and then drain it before in intersect()
136 self.ranges.drain(..drain_end); in intersect()
228 self.ranges.drain(..drain_end);
259 // the negation to the end of this range, and then drain it before in negate()
278 self.ranges.drain(..drain_end); in negate()
291 // the end of this range, and then drain it before we're done. in canonicalize()
306 self.ranges.drain(..drain_end); in canonicalize()
|
| /third_party/rust/crates/cxx/gen/build/src/syntax/ |
| H A D | report.rs | 23 let mut iter = self.errors.drain(..); in propagate()
|
| /third_party/rust/crates/cxx/gen/cmd/src/syntax/ |
| H A D | report.rs | 23 let mut iter = self.errors.drain(..); in propagate()
|
| /third_party/rust/crates/cxx/macro/src/syntax/ |
| H A D | report.rs | 23 let mut iter = self.errors.drain(..); in propagate()
|
| /third_party/rust/crates/cxx/gen/lib/src/syntax/ |
| H A D | report.rs | 23 let mut iter = self.errors.drain(..); in propagate()
|
| /third_party/rust/crates/cxx/syntax/ |
| H A D | report.rs | 23 let mut iter = self.errors.drain(..); in propagate()
|
| /third_party/FreeBSD/sys/compat/linuxkpi/common/src/ |
| H A D | linux_usb.c | 465 struct urb *urb, uint8_t drain) in usb_unlink_bsd()
472 if (drain) { in usb_unlink_bsd()
484 usb_unlink_urb_sub(struct urb *urb, uint8_t drain) in usb_unlink_urb_sub() argument
498 if (drain) in usb_unlink_urb_sub()
530 usb_unlink_bsd(uhe->bsd_xfer[0], urb, drain); in usb_unlink_urb_sub()
531 usb_unlink_bsd(uhe->bsd_xfer[1], urb, drain); in usb_unlink_urb_sub()
535 if (drain) in usb_unlink_urb_sub()
464 usb_unlink_bsd(struct usb_xfer *xfer, struct urb *urb, uint8_t drain) usb_unlink_bsd() argument
|
| /third_party/mesa3d/src/vulkan/runtime/ |
| H A D | vk_sync_timeline.c | 125 bool drain);
250 bool drain) in vk_sync_timeline_gc_locked()
270 if (point->refcount > 0 && !drain) in vk_sync_timeline_gc_locked()
248 vk_sync_timeline_gc_locked(struct vk_device *device, struct vk_sync_timeline *timeline, bool drain) vk_sync_timeline_gc_locked() argument
|
| /third_party/alsa-lib/src/rawmidi/ |
| H A D | rawmidi_local.h | 34 int (*drain)(snd_rawmidi_t *rawmidi); member
|
| /third_party/rust/crates/regex/regex-syntax/src/ast/ |
| H A D | mod.rs | 1397 stack.extend(x.asts.drain(..)); in drop()
1400 stack.extend(x.asts.drain(..)); in drop()
1455 stack.extend(x.items.drain(..).map(ClassSet::Item)); in drop()
|