| /third_party/node/deps/npm/node_modules/through2/ |
| D | through2.js | 33 return function (options, transform, flush) { argument
35 flush = transform
43 if (typeof flush != 'function')
44 flush = null
46 return construct(options, transform, flush)
52 module.exports = through2(function (options, transform, flush) { argument
57 if (flush)
58 t2._flush = flush
66 module.exports.ctor = through2(function (options, transform, flush) { argument
80 if (flush) argument
[all …]
|
| /third_party/boost/libs/log/src/ |
| D | date_time_format_parser.cpp | 90 flush(callback);
103 void flush(callback_type& callback)
132 this->flush(callback);
153 this->flush(callback);
158 this->flush(callback);
163 this->flush(callback);
168 this->flush(callback);
173 this->flush(callback);
178 this->flush(callback);
183 this->flush(callback);
[all …]
|
| /third_party/boost/boost/iostreams/ |
| D | flush.hpp | 40 bool flush(T& t) in flush() function
41 { return detail::flush_device_impl<T>::flush(detail::unwrap(t)); } in flush()
44 bool flush(T& t, Sink& snk) in flush() function
45 { return detail::flush_filter_impl<T>::flush(detail::unwrap(t), snk); } in flush()
68 static bool flush(T& t) in flush() function
75 static bool flush(T& t) in flush() function
82 static bool flush(T& t) { return t.flush(); } in flush() function
88 static bool flush(T&) { return true; } in flush() function
110 static bool flush(T& t, Sink& snk) { return t.flush(snk); } in flush() function
116 static bool flush(T&, Sink&) { return false; } in flush() function
|
| /third_party/grpc/src/core/lib/compression/ |
| D | stream_compression_gzip.cc | 34 int (*flate)(z_stream* zs, int flush);
39 size_t* output_size, size_t max_output_size, int flush, in gzip_flate() argument
41 GPR_ASSERT(flush == 0 || flush == Z_SYNC_FLUSH || flush == Z_FINISH); in gzip_flate()
43 GPR_ASSERT(!(ctx->flate == inflate && (flush == Z_FINISH))); in gzip_flate()
49 while (max_output_size > 0 && (in->length > 0 || flush) && !eoc) { in gzip_flate()
76 if (flush != 0 && ctx->zs.avail_out > 0 && !eoc) { in gzip_flate()
78 r = ctx->flate(&ctx->zs, flush); in gzip_flate()
79 if (flush == Z_SYNC_FLUSH) { in gzip_flate()
84 flush = 0; in gzip_flate()
89 flush = 0; in gzip_flate()
[all …]
|
| /third_party/flutter/skia/tests/ |
| D | GrFinishedFlushTest.cpp | 51 ctx->flush(flushInfoSyncCpu); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
59 surface->flush(SkSurface::BackendSurfaceAccess::kNoAccess, flushInfoFinishedProc); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
66 surface->flush(SkSurface::BackendSurfaceAccess::kNoAccess, flushInfoFinishedProc); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
78 ctx->flush(flushInfoSyncCpu); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
83 image->flush(ctx, flushInfoFinishedProc); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
91 ctx->flush(flushInfoSyncCpu); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
96 ctx->flush(flushInfoFinishedProc); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
104 ctx->flush(flushInfoSyncCpu); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
108 ctx->flush(flushInfoFinishedProc); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
115 surface->flush(SkSurface::BackendSurfaceAccess::kNoAccess, flushInfoFinishedProc); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
[all …]
|
| /third_party/node/deps/npm/node_modules/flush-write-stream/ |
| D | README.md | 1 # flush-write-stream
3 A write stream constructor that supports a flush function that is called before `finish` is emitted
6 npm install flush-write-stream
9 …(http://img.shields.io/travis/mafintosh/flush-write-stream.svg?style=flat)](http://travis-ci.org/m…
14 var writer = require('flush-write-stream')
16 var ws = writer(write, flush)
32 function flush (cb) {
49 #### `var ws = writer([options], write, [flush])`
53 #### `var ws = writer.obj([options], write, [flush])`
|
| D | index.js | 10 function WriteStream (opts, write, flush) { argument
11 if (!(this instanceof WriteStream)) return new WriteStream(opts, write, flush)
14 flush = write
23 this._flush = flush || null
28 WriteStream.obj = function (opts, worker, flush) { argument
32 return new WriteStream(opts, worker, flush)
|
| /third_party/skia/tests/ |
| D | GrFinishedFlushTest.cpp | 50 dContext->flush(); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
59 surface->flush(flushInfoFinishedProc); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
67 surface->flush(flushInfoFinishedProc); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
84 dContext->flush(); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
90 image->flush(dContext, flushInfoFinishedProc); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
99 dContext->flush(); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
105 dContext->flush(flushInfoFinishedProc); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
114 dContext->flush(); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
119 dContext->flush(flushInfoFinishedProc); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
127 surface->flush(flushInfoFinishedProc); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
[all …]
|
| D | GrSubmittedFlushTest.cpp | 46 ctx->flush(flushInfo); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
54 surface->flush(SkSurface::BackendSurfaceAccess::kNoAccess, flushInfo); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
60 ctx->flush(flushInfo); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
69 surface->flush(SkSurface::BackendSurfaceAccess::kNoAccess, flushInfo); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
72 surface->flush(SkSurface::BackendSurfaceAccess::kNoAccess, flushInfo); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
82 surface->flush(SkSurface::BackendSurfaceAccess::kNoAccess, flushInfo); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
85 ctx->flush(flushInfo); in DEF_GPUTEST_FOR_RENDERING_CONTEXTS()
|
| /third_party/python/Lib/test/ |
| D | test_zlib.py | 120 self.assertRaises(ValueError, zlib.decompressobj().flush, 0)
121 self.assertRaises(ValueError, zlib.decompressobj().flush, -1)
130 zlib.decompressobj().flush(sys.maxsize + 1)
244 x2 = co.flush()
245 self.assertRaises(zlib.error, co.flush) # second flush should not work
250 y2 = dco.flush()
272 x = co.compress(HAMLET_SCENE) + co.flush()
273 y = do.decompress(x, max_length=len(HAMLET_SCENE)) + do.flush()
285 x2 = co.flush()
288 y2 = dco.flush()
[all …]
|
| /third_party/ffmpeg/libavcodec/ |
| D | mpegaudiodec_float.c | 85 .flush = flush,
103 .flush = flush,
121 .flush = flush,
139 .flush = flush,
158 .flush = flush_mp3on4,
|
| D | mpegaudiodec_fixed.c | 72 .flush = flush,
90 .flush = flush,
108 .flush = flush,
126 .flush = flush,
145 .flush = flush_mp3on4,
|
| /third_party/python/Lib/unittest/ |
| D | runner.py | 56 self.stream.flush()
62 self.stream.flush()
65 self.stream.flush()
71 self.stream.flush()
74 self.stream.flush()
80 self.stream.flush()
83 self.stream.flush()
89 self.stream.flush()
92 self.stream.flush()
98 self.stream.flush()
[all …]
|
| /third_party/boost/libs/iostreams/test/ |
| D | flush_test.cpp | 34 iostreams::flush(null), in flush_test()
48 iostreams::flush(null), in flush_test()
62 iostreams::flush(null), in flush_test()
77 iostreams::flush(null), in flush_test()
97 out.flush(); in flush_test()
103 out.flush(); in flush_test()
123 out.flush(); in flush_test()
129 out.flush(); in flush_test()
|
| /third_party/node/deps/npm/node_modules/es6-promise/lib/es6-promise/ |
| D | asap.js | 14 customSchedulerFn(flush);
43 return () => process.nextTick(flush);
50 vertxNext(flush);
59 const observer = new BrowserMutationObserver(flush);
71 channel.port1.onmessage = flush;
79 return () => globalSetTimeout(flush, 1);
83 function flush() { function
|
| /third_party/node/deps/npm/node_modules/minizlib/ |
| D | index.js | 55 this[_flushFlag] = opts.flush
92 flush (flushFlag) { method in ZlibBase
104 this.flush(this[_finishFlushFlag])
186 opts.flush = opts.flush || constants.Z_NO_FLUSH
208 this.flush(constants.Z_SYNC_FLUSH)
213 const origFlush = this[_handle].flush
214 this[_handle].flush = (flushFlag, cb) => {
215 this.flush(flushFlag)
221 this[_handle].flush = origFlush
282 opts.flush = opts.flush || constants.BROTLI_OPERATION_PROCESS
|
| /third_party/icu/icu4j/main/classes/charset/src/com/ibm/icu/charset/ |
| D | CharsetDecoderICU.java | 270 … abstract CoderResult decodeLoop(ByteBuffer in, CharBuffer out, IntBuffer offsets, boolean flush); in decodeLoop() argument
282 … final CoderResult decode(ByteBuffer source, CharBuffer target, IntBuffer offsets, boolean flush) { in decode() argument
338 if (!flush && !source.hasRemaining() && toULength == 0 && preToULength >= 0) { in decode()
351 return toUnicodeWithCallback(source, target, offsets, flush); in decode()
396 …sult toUnicodeWithCallback(ByteBuffer source, CharBuffer target, IntBuffer offsets, boolean flush){ in toUnicodeWithCallback() argument
426 realFlush=flush; in toUnicodeWithCallback()
433 flush=false; in toUnicodeWithCallback()
453 cr = decodeLoop(source, target, offsets, flush); in toUnicodeWithCallback()
462 … converterSawEndOfInput= (cr.isUnderflow() && flush && source.remaining()==0 && toULength == 0); in toUnicodeWithCallback()
512 realFlush=flush; in toUnicodeWithCallback()
[all …]
|
| D | CharsetASCII.java | 41 boolean flush) { in decodeLoop() argument
191 boolean flush) { in encodeLoop() argument
211 cr = encodeTrail(source, (char) fromUChar32, flush); in encodeLoop()
238 …codeLoopCoreOptimized(source, target, sourceArray, targetArray, sourceIndex, offset, limit, flush); in encodeLoop()
253 cr = encodeLoopCoreUnoptimized(source, target, flush); in encodeLoop()
273 boolean flush) { in encodeLoopCoreOptimized() argument
291 return encodeMalformedOrUnmappable(source, ch, flush); in encodeLoopCoreOptimized()
296 …tected CoderResult encodeLoopCoreUnoptimized(CharBuffer source, ByteBuffer target, boolean flush) { in encodeLoopCoreUnoptimized() argument
317 return encodeMalformedOrUnmappable(source, ch, flush); in encodeLoopCoreUnoptimized()
324 …protected final CoderResult encodeMalformedOrUnmappable(CharBuffer source, int ch, boolean flush) { in encodeMalformedOrUnmappable() argument
[all …]
|
| /third_party/boost/boost/beast/zlib/detail/ |
| D | deflate_stream.hpp | 246 typedef block_state(self::*compress_func)(z_params& zs, Flush flush);
624 …BOOST_BEAST_DECL void doWrite (z_params& zs, boost::optional<Flush> flush, error_code&…
650 BOOST_BEAST_DECL void tr_tally_dist (std::uint16_t dist, std::uint8_t len, bool& flush);
651 BOOST_BEAST_DECL void tr_tally_lit (std::uint8_t c, bool& flush);
660 BOOST_BEAST_DECL block_state f_stored (z_params& zs, Flush flush);
661 BOOST_BEAST_DECL block_state f_fast (z_params& zs, Flush flush);
662 BOOST_BEAST_DECL block_state f_slow (z_params& zs, Flush flush);
663 BOOST_BEAST_DECL block_state f_rle (z_params& zs, Flush flush);
664 BOOST_BEAST_DECL block_state f_huff (z_params& zs, Flush flush);
667 deflate_stored(z_params& zs, Flush flush) in deflate_stored() argument
[all …]
|
| /third_party/boost/libs/beast/include/boost/beast/zlib/detail/ |
| D | deflate_stream.hpp | 246 typedef block_state(self::*compress_func)(z_params& zs, Flush flush);
624 …BOOST_BEAST_DECL void doWrite (z_params& zs, boost::optional<Flush> flush, error_code&…
650 BOOST_BEAST_DECL void tr_tally_dist (std::uint16_t dist, std::uint8_t len, bool& flush);
651 BOOST_BEAST_DECL void tr_tally_lit (std::uint8_t c, bool& flush);
660 BOOST_BEAST_DECL block_state f_stored (z_params& zs, Flush flush);
661 BOOST_BEAST_DECL block_state f_fast (z_params& zs, Flush flush);
662 BOOST_BEAST_DECL block_state f_slow (z_params& zs, Flush flush);
663 BOOST_BEAST_DECL block_state f_rle (z_params& zs, Flush flush);
664 BOOST_BEAST_DECL block_state f_huff (z_params& zs, Flush flush);
667 deflate_stored(z_params& zs, Flush flush) in deflate_stored() argument
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-zlib-flush-drain.js | 19 const flush = deflater.flush; constant
20 deflater.flush = function(kind, callback) { function in deflater
22 flush.call(this, kind, callback);
31 deflater.flush(function(err) {
|
| /third_party/boost/tools/boost_install/test/iostreams/zlib-1.2.11/examples/ |
| D | fitblk.c | 75 int ret, flush; in partcompress() local
78 flush = Z_NO_FLUSH; in partcompress()
85 flush = Z_FINISH; in partcompress()
86 ret = deflate(def, flush); in partcompress()
88 } while (def->avail_out != 0 && flush == Z_NO_FLUSH); in partcompress()
98 int ret, flush; in recompress() local
101 flush = Z_NO_FLUSH; in recompress()
116 flush = Z_FINISH; in recompress()
117 ret = deflate(def, flush); in recompress()
|
| /third_party/zlib/examples/ |
| D | fitblk.c | 75 int ret, flush; in partcompress() local
78 flush = Z_NO_FLUSH; in partcompress()
85 flush = Z_FINISH; in partcompress()
86 ret = deflate(def, flush); in partcompress()
88 } while (def->avail_out != 0 && flush == Z_NO_FLUSH); in partcompress()
98 int ret, flush; in recompress() local
101 flush = Z_NO_FLUSH; in recompress()
116 flush = Z_FINISH; in recompress()
117 ret = deflate(def, flush); in recompress()
|
| /third_party/boost/libs/beast/test/extern/zlib-1.2.11/examples/ |
| D | fitblk.c | 75 int ret, flush; in partcompress() local
78 flush = Z_NO_FLUSH; in partcompress()
85 flush = Z_FINISH; in partcompress()
86 ret = deflate(def, flush); in partcompress()
88 } while (def->avail_out != 0 && flush == Z_NO_FLUSH); in partcompress()
98 int ret, flush; in recompress() local
101 flush = Z_NO_FLUSH; in recompress()
116 flush = Z_FINISH; in recompress()
117 ret = deflate(def, flush); in recompress()
|
| /third_party/boost/boost/iostreams/filter/ |
| D | symmetric.hpp | 114 bool flush = status == f_eof; in read() local
115 if (buf.ptr() != buf.eptr() || flush) { in read()
118 !filter().filter(next, buf.eptr(), next_s, end_s, flush); in read()
149 if (buf.ptr() == buf.eptr() && !flush(snk)) in write()
152 flush(snk); in write()
177 flush(snk); in close()
218 bool flush(Sink& snk) in flush() function in boost::iostreams::symmetric_filter
222 return flush(snk, can_write()); in flush()
226 bool flush(Sink& snk, mpl::true_) in flush() function in boost::iostreams::symmetric_filter
239 bool flush(Sink&, mpl::false_) { return true;} in flush() function in boost::iostreams::symmetric_filter
|