| /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/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/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/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 | 118 self.assertRaises(ValueError, zlib.decompressobj().flush, 0)
119 self.assertRaises(ValueError, zlib.decompressobj().flush, -1)
128 zlib.decompressobj().flush(sys.maxsize + 1)
236 x2 = co.flush()
237 self.assertRaises(zlib.error, co.flush) # second flush should not work
242 y2 = dco.flush()
264 x = co.compress(HAMLET_SCENE) + co.flush()
265 y = do.decompress(x, max_length=len(HAMLET_SCENE)) + do.flush()
277 x2 = co.flush()
280 y2 = dco.flush()
[all …]
|
| /third_party/ffmpeg/libavcodec/ |
| D | mpegaudiodec_fixed.c | 51 .flush = flush,
67 .flush = flush,
83 .flush = flush,
99 .flush = flush,
116 .flush = flush_mp3on4,
|
| D | mpegaudiodec_float.c | 52 .flush = flush,
69 .flush = flush,
86 .flush = flush,
103 .flush = flush,
120 .flush = flush_mp3on4,
|
| /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/uboot/u-boot-2020.01/board/armadeus/apf27/ |
| D | fpga.h | 14 extern int fpga_pgm_fn(int assert_pgm, int flush, int cookie);
15 extern int fpga_cs_fn(int assert_cs, int flush, int cookie);
18 extern int fpga_clk_fn(int assert_clk, int flush, int cookie);
19 extern int fpga_wr_fn(int assert_write, int flush, int cookie);
21 extern int fpga_wdata_fn(unsigned char data, int flush, int cookie);
|
| /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/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/uboot/u-boot-2020.01/include/ |
| D | xilinx.h | 72 typedef int (*xilinx_pgm_fn)(int assert_pgm, int flush, int cookie);
76 typedef int (*xilinx_clk_fn)(int assert_clk, int flush, int cookie);
77 typedef int (*xilinx_cs_fn)(int assert_cs, int flush, int cookie);
78 typedef int (*xilinx_wr_fn)(int assert_write, int flush, int cookie);
80 typedef int (*xilinx_wdata_fn)(unsigned char data, int flush, int cookie);
85 typedef int (*xilinx_bwr_fn)(void *buf, size_t len, int flush, int cookie);
|
| /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/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/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/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/miniz/ |
| D | miniz.c | 233 int mz_deflate(mz_streamp pStream, int flush) in mz_deflate() argument
239 … if ((!pStream) || (!pStream->state) || (flush < 0) || (flush > MZ_FINISH) || (!pStream->next_out)) in mz_deflate()
244 if (flush == MZ_PARTIAL_FLUSH) in mz_deflate()
245 flush = MZ_SYNC_FLUSH; in mz_deflate()
248 return (flush == MZ_FINISH) ? MZ_STREAM_END : MZ_BUF_ERROR; in mz_deflate()
258 … *)pStream->state, pStream->next_in, &in_bytes, pStream->next_out, &out_bytes, (tdefl_flush)flush); in mz_deflate()
280 else if ((!pStream->avail_in) && (flush != MZ_FINISH)) in mz_deflate()
282 … if ((flush) || (pStream->total_in != orig_total_in) || (pStream->total_out != orig_total_out)) in mz_deflate()
426 int mz_inflate(mz_streamp pStream, int flush) in mz_inflate() argument
435 if (flush == MZ_PARTIAL_FLUSH) in mz_inflate()
[all …]
|
| /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
|
| /third_party/libwebsockets/win32port/zlib/ |
| D | deflate.h | 319 # define _tr_tally_lit(s, c, flush) \ argument
324 flush = (s->last_lit == s->lit_bufsize-1); \
326 # define _tr_tally_dist(s, distance, length, flush) \ argument
334 flush = (s->last_lit == s->lit_bufsize-1); \
337 # define _tr_tally_lit(s, c, flush) flush = _tr_tally(s, 0, c) argument
338 # define _tr_tally_dist(s, distance, length, flush) \ argument
339 flush = _tr_tally(s, distance, length)
|