/third_party/skia/third_party/externals/dng_sdk/source/ |
H A D | dng_preview.h | 50 dng_stream &stream) const = 0; 78 dng_stream &stream) const; 118 dng_stream &stream) const; 120 void SpoolAdobeThumbnail (dng_stream &stream) const; 160 dng_stream &stream) const; 198 dng_stream &stream) const;
|
H A D | dng_read_image.h | 33 bool DecodePackBits (dng_stream &stream, 101 /// \param stream Stream to read image data from. 106 dng_stream &stream, 115 dng_stream &stream, 134 dng_stream &stream, 144 dng_stream &stream, 166 dng_stream &stream,
|
H A D | dng_bad_pixels.cpp | 47 (dng_stream &stream) in dng_opcode_FixBadPixelsConstant() 50 stream, in dng_opcode_FixBadPixelsConstant() 58 if (stream.Get_uint32 () != 8) in dng_opcode_FixBadPixelsConstant() 63 fConstant = stream.Get_uint32 (); in dng_opcode_FixBadPixelsConstant() 64 fBayerPhase = stream.Get_uint32 (); in dng_opcode_FixBadPixelsConstant() 83 void dng_opcode_FixBadPixelsConstant::PutData (dng_stream &stream) const in PutData() 86 stream.Put_uint32 (8); in PutData() 88 stream.Put_uint32 (fConstant ); in PutData() 89 stream.Put_uint32 (fBayerPhase); in PutData() 593 dng_opcode_FixBadPixelsList::dng_opcode_FixBadPixelsList (dng_stream &stream) in dng_opcode_FixBadPixelsList() argument 46 dng_opcode_FixBadPixelsConstant(dng_stream &stream) dng_opcode_FixBadPixelsConstant() argument [all...] |
/third_party/mesa3d/src/gallium/drivers/radeonsi/ |
H A D | gfx10_shader_ngg.c | 226 LLVMValueRef *wg_offset_dw, unsigned stream, in build_streamout_vertex() 246 if (so->output[i].stream != stream) in build_streamout_vertex() 267 LLVMValueRef prim_enable[4]; /* i1 per stream */ 271 LLVMValueRef emit[4]; /* per-stream emitted primitives (only valid for used streams) */ 309 unsigned stream = so->output[i].stream; in build_streamout() local 310 assert(stream_for_buffer[buf] < 0 || stream_for_buffer[buf] == stream); in build_streamout() 311 stream_for_buffer[buf] = stream; in build_streamout() 312 bufmask_for_stream[stream] | in build_streamout() 225 build_streamout_vertex(struct si_shader_context *ctx, LLVMValueRef *so_buffer, LLVMValueRef *wg_offset_dw, unsigned stream, LLVMValueRef offset_vtx, LLVMValueRef vertexptr) build_streamout_vertex() argument 1839 ngg_gs_get_emit_primflag_ptr(struct si_shader_context *ctx, LLVMValueRef vertexptr, unsigned stream) ngg_gs_get_emit_primflag_ptr() argument 1850 gfx10_ngg_gs_emit_vertex(struct si_shader_context *ctx, unsigned stream, LLVMValueRef *addrs) gfx10_ngg_gs_emit_vertex() argument [all...] |
/foundation/filemanagement/app_file_service/tests/mock/library_func_mock/ |
H A D | library_func_mock.h | 32 virtual int fseeko(FILE *stream, off_t offset, int whence) = 0; 33 virtual off_t ftello(FILE *stream) = 0; 42 MOCK_METHOD3(fseeko, int(FILE *stream, off_t offset, int whence)); 43 MOCK_METHOD1(ftello, off_t(FILE *stream));
|
/third_party/lzma/CPP/7zip/Archive/Common/ |
H A D | InStreamWithCRC.h | 28 void SetStream(ISequentialInStream *stream) { _stream = stream; }
in SetStream() argument 54 void SetStream(IInStream *stream) { _stream = stream; }
|
/third_party/node/lib/internal/streams/ |
H A D | lazy_transform.js | 1 // LazyTransform is a special type of Transform stream that is lazily loaded. 3 // for the stream, one conventional and one non-conventional. 12 const stream = require('stream'); 23 ObjectSetPrototypeOf(LazyTransform.prototype, stream.Transform.prototype); 24 ObjectSetPrototypeOf(LazyTransform, stream.Transform); 28 stream.Transform.call(this, this._options);
|
/third_party/node/lib/internal/util/ |
H A D | colors.js | 17 shouldColorize(stream) { 21 return stream?.isTTY && ( 22 typeof stream.getColorDepth === 'function' ? 23 stream.getColorDepth() > 2 : true);
|
/third_party/node/test/parallel/ |
H A D | test-http2-server-shutdown-before-respond.js | 11 server.on('stream', common.mustCall(onStream)); 13 function onStream(stream, headers, flags) { 14 stream.session.goaway(1); 15 stream.respond(); 16 stream.end('data');
|
H A D | test-http2-status-code-invalid.js | 19 server.on('stream', common.mustCall((stream) => { 23 assert.throws(() => stream.respond({ ':status': i }), expectsError(i)); 26 stream.respond(); 27 stream.end();
|
H A D | test-fs-read-stream-inherit.js | 129 const stream = fs.createReadStream(rangeFile, options); 130 assert.strictEqual(stream.start, 0); 131 assert.strictEqual(stream.end, 0); 132 stream.data = ''; 134 stream.on('data', function(chunk) { 135 stream.data += chunk; 138 stream.on('end', common.mustCall(function() { 139 assert.strictEqual(stream.data, 'x'); 182 // Just to make sure autoClose won't close the stream because of error. 195 // Make sure stream i [all...] |
/third_party/node/benchmark/http2/ |
H A D | simple.js | 19 server.on('stream', (stream) => { 21 stream.respond(); 22 out.pipe(stream); 23 stream.on('error', (err) => {});
|
/third_party/rust/crates/syn/tests/repo/ |
H A D | progress.rs | 7 stream: R, 11 pub fn new(stream: R) -> Self { in new() 15 stream, in new() 22 let num = self.stream.read(buf)?; in read()
|
/third_party/node/test/fixtures/wpt/streams/writable-streams/ |
H A D | write.any.js | 169 }, 'when sink\'s write throws an error, the stream should become errored and the promise should reject'); 229 const stream = recordingWritableStream(); 230 const w = stream.getWriter(); 233 const writer = new WritableStreamDefaultWriter(stream); 236 assert_array_equals(stream.events, ['write', 'a'], 'write() should be passed to sink'); 256 const stream = new WritableStream(); 257 const writer = stream.getWriter(); 259 assert_throws_js(TypeError, () => new WritableStreamDefaultWriter(stream), 260 'should not be able to construct on locked stream'); 261 // If stream [all...] |
/third_party/ltp/utils/sctp/func_tests/ |
H A D | test_inaddr_any.c | 85 uint32_t stream; in main() local 169 stream = 1; in main() 171 sinfo->sinfo_stream = stream; in main() 202 MSG_EOR, stream, ppid); in main() 217 stream++; in main() 219 sinfo->sinfo_stream = stream; in main() 232 MSG_EOR, stream, ppid); in main() 237 MSG_EOR, stream, ppid); in main()
|
H A D | test_sctp_sendrecvmsg.c | 83 uint32_t stream; in main() local 171 stream = 1; in main() 174 ppid, 0, stream, 0, 0); in main() 224 strlen(message) + 1, MSG_EOR, stream, ppid); in main() 245 stream++; in main() 248 ppid, 0, stream, 0, 0); in main() 253 ppid, 0, stream, 2000, 0); in main() 260 ppid, 0, stream, 0, 0); in main() 269 ppid, 0, stream, 2000, 0); in main() 295 strlen(nottlmsg) + 1, MSG_EOR, stream, ppi in main() [all...] |
/third_party/python/Lib/test/ |
H A D | test_getpass.py | 57 stream = mock.Mock(spec=StringIO) 59 getpass._raw_input('some_prompt', stream, input=input) 60 stream.flush.assert_called_once_with() 72 getpass._raw_input(stream=StringIO()) 77 stream = TextIOWrapper(BytesIO(), encoding="ascii") 79 getpass._raw_input(prompt="Hasło: ",stream=stream) 149 getpass.unix_getpass(stream=mock_stream)
|
/device/soc/rockchip/common/sdk_linux/drivers/media/usb/uvc/ |
H A D | uvc_driver.c | 525 struct uvc_streaming *stream;
in uvc_stream_by_id() local 527 list_for_each_entry(stream, &dev->streams, list)
in uvc_stream_by_id() 529 if (stream->header.bTerminalLink == id) {
in uvc_stream_by_id() 530 return stream;
in uvc_stream_by_id() 541 static void uvc_stream_delete(struct uvc_streaming *stream)
in uvc_stream_delete() argument 543 if (stream->async_wq) {
in uvc_stream_delete() 544 destroy_workqueue(stream->async_wq);
in uvc_stream_delete() 547 mutex_destroy(&stream->mutex);
in uvc_stream_delete() 549 usb_put_intf(stream->intf);
in uvc_stream_delete() 551 kfree(stream in uvc_stream_delete() 558 struct uvc_streaming *stream; uvc_stream_new() local 2127 struct uvc_streaming *stream = video_get_drvdata(vdev); uvc_release() local 2138 struct uvc_streaming *stream; uvc_unregister_video() local 2164 uvc_register_video_device(struct uvc_device *dev, struct uvc_streaming *stream, struct video_device *vdev, struct uvc_video_queue *queue, enum v4l2_buf_type type, const struct v4l2_file_operations *fops, const struct v4l2_ioctl_ops *ioctl_ops) uvc_register_video_device() argument 2228 uvc_register_video(struct uvc_device *dev, struct uvc_streaming *stream) uvc_register_video() argument 2257 struct uvc_streaming *stream; uvc_register_terms() local 2485 struct uvc_streaming *stream; uvc_suspend() local 2514 struct uvc_streaming *stream; uvc_resume_ext() local [all...] |
/device/soc/rockchip/common/vendor/drivers/media/platform/rockchip/cif/ |
H A D | procfs.c | 245 struct rkcif_stream *stream = &dev->stream[0]; in rkcif_show_format() local 294 seq_printf(f, "\tformat:%s/%ux%u@%d\n", rkcif_pixelcode_to_string(stream->cif_fmt_in->mbus_code), rect->width, in rkcif_show_format() 299 spin_lock_irqsave(&stream->fps_lock, flags); in rkcif_show_format() 300 timestamp0 = stream->fps_stats.frm0_timestamp; in rkcif_show_format() 301 timestamp1 = stream->fps_stats.frm1_timestamp; in rkcif_show_format() 302 spin_unlock_irqrestore(&stream->fps_lock, flags); in rkcif_show_format() 307 seq_printf(f, "\tformat:%s/%ux%u(%u,%u)\n", rkcif_pixelcode_to_string(stream->cif_fmt_out->fourcc), in rkcif_show_format() 310 seq_printf(f, "\tcompact:%s\n", stream->is_compact ? "enable" : "disabled"); in rkcif_show_format() 311 seq_printf(f, "\tframe amount:%d\n", stream in rkcif_show_format() [all...] |
/device/soc/rockchip/rk3588/kernel/drivers/media/platform/rockchip/cif/ |
H A D | procfs.c | 246 struct rkcif_stream *stream = &dev->stream[0]; in rkcif_show_format() local 296 rkcif_pixelcode_to_string(stream->cif_fmt_in->mbus_code), in rkcif_show_format() 304 spin_lock_irqsave(&stream->fps_lock, flags); in rkcif_show_format() 305 timestamp0 = stream->fps_stats.frm0_timestamp; in rkcif_show_format() 306 timestamp1 = stream->fps_stats.frm1_timestamp; in rkcif_show_format() 307 spin_unlock_irqrestore(&stream->fps_lock, flags); in rkcif_show_format() 314 rkcif_pixelcode_to_string(stream->cif_fmt_out->fourcc), in rkcif_show_format() 317 seq_printf(f, "\tcompact:%s\n", stream->is_compact ? "enable" : "disabled"); in rkcif_show_format() 318 seq_printf(f, "\tframe amount:%d\n", stream in rkcif_show_format() [all...] |
/foundation/multimedia/media_foundation/engine/plugin/plugins/source/http_source/hls/ |
H A D | m3u8.cpp | 196 auto stream = std::make_shared<M3U8VariantStream>(uri_, uri_, m3u8); in UpdateMediaPlaylist() local 197 variants_.emplace_back(stream); in UpdateMediaPlaylist() 198 defaultVariant_ = stream; in UpdateMediaPlaylist() 219 auto stream = std::make_shared<M3U8VariantStream>(name, uri, std::make_shared<M3U8>(uri, name)); in UpdateMasterPlaylist() 221 stream->iframe_ = true; in UpdateMasterPlaylist() 225 stream->bandWidth_ = bandWidthAttribute->Decimal(); in UpdateMasterPlaylist() 229 stream->width_ = resolutionAttribute->GetResolution().first; in UpdateMasterPlaylist() 230 stream->height_ = resolutionAttribute->GetResolution().second; in UpdateMasterPlaylist() 232 variants_.emplace_back(stream); in UpdateMasterPlaylist() 233 defaultVariant_ = stream; // pla in UpdateMasterPlaylist() [all...] |
/third_party/libuv/test/ |
H A D | echo-server.c | 108 * If we get QS it means close the stream. in after_read() 109 * If we get QSS it means shutdown the stream. in after_read() 170 uv_stream_t* stream; in on_connection() local 180 stream = malloc(sizeof(uv_tcp_t)); in on_connection() 181 ASSERT_NOT_NULL(stream); in on_connection() 182 r = uv_tcp_init(loop, (uv_tcp_t*)stream); in on_connection() 187 stream = malloc(sizeof(uv_pipe_t)); in on_connection() 188 ASSERT_NOT_NULL(stream); in on_connection() 189 r = uv_pipe_init(loop, (uv_pipe_t*)stream, 0); in on_connection() 198 /* associate server with stream */ in on_connection() [all...] |
H A D | runner.c | 386 void print_tests(FILE* stream) { in print_tests() argument 415 void print_lines(const char* buffer, size_t size, FILE* stream) { in print_lines() argument 421 fputs("# ", stream); in print_lines() 422 fwrite(start, 1, (int)(end - start), stream); in print_lines() 423 fputs("\n", stream); in print_lines() 424 fflush(stream); in print_lines() 430 fputs("# ", stream); in print_lines() 431 fwrite(start, 1, (int)(end - start), stream); in print_lines() 432 fputs("\n", stream); in print_lines() 433 fflush(stream); in print_lines() [all...] |
/third_party/node/deps/npm/node_modules/npmlog/lib/ |
H A D | log.js | 12 var stream = process.stderr 13 Object.defineProperty(log, 'stream', { 15 stream = newStream 17 this.gauge.setWriteTo(stream, stream) 21 return stream 28 return colorEnabled != null ? colorEnabled : stream.isTTY 43 log.gauge = new Gauge(stream, { 309 if (!stream) { 354 if (!stream) { [all...] |
/third_party/skia/third_party/externals/angle2/src/libGLESv2/ |
H A D | entry_points_egl_ext_autogen.h | 108 EGLStreamKHR stream, 111 EGLStreamKHR stream, 211 ANGLE_EXPORT EGLBoolean EGLAPIENTRY EGL_DestroyStreamKHR(EGLDisplay dpy, EGLStreamKHR stream); 213 EGLStreamKHR stream, 217 EGLStreamKHR stream, 221 EGLStreamKHR stream, 227 EGLStreamKHR stream); 229 EGLStreamKHR stream); 231 EGLStreamKHR stream); 253 EGLStreamKHR stream, [all...] |