Home
last modified time | relevance | path

Searched refs:stream (Results 851 - 875 of 4208) sorted by relevance

1...<<31323334353637383940>>...169

/base/powermgr/thermal_manager/utils/native/src/
H A Dfile_operation.cpp65 FILE *stream = fopen(path.c_str(), "w+"); in WriteFile() local
66 if (stream == nullptr) { in WriteFile()
69 size_t ret = fwrite(buf.c_str(), strlen(buf.c_str()), 1, stream); in WriteFile()
73 int32_t state = fseek(stream, 0, SEEK_SET); in WriteFile()
75 fclose(stream); in WriteFile()
78 state = fclose(stream); in WriteFile()
/base/update/updater/test/unittest/diffpatch/
H A Dimage_patch_unittest.cpp45 PkgManager::StreamPtr &stream, bool memory, size_t expandedLen) in TestDecompressData()
47 return DecompressData(pkgManager, buffer, stream, memory, expandedLen); in TestDecompressData()
96 PkgManager::StreamPtr stream; in HWTEST_F() local
99 int32_t ret = test.TestDecompressData(pkgManager, buffer, stream, memory, expandedLen); in HWTEST_F()
102 ret = test.TestDecompressData(pkgManager, buffer, stream, memory, expandedLen); in HWTEST_F()
105 ret = test.TestDecompressData(pkgManager, buffer, stream, memory, expandedLen); in HWTEST_F()
44 TestDecompressData(PkgManager::PkgManagerPtr &pkgManager, PkgBuffer buffer, PkgManager::StreamPtr &stream, bool memory, size_t expandedLen) TestDecompressData() argument
/drivers/peripheral/camera/vdi_base/v4l2/src/offline_stream_operator/
H A Doffline_stream_operator_vdi_impl.cpp38 std::shared_ptr<OfflineStream> stream = FindStreamByCaptureId(captureId); in CancelCapture()
39 if (stream == nullptr) { in CancelCapture()
40 CAMERA_LOGD("can't find stream by captureId %{public}d, buffer all returned.", captureId); in CancelCapture()
43 RetCode ret = stream->CancelCapture(captureId); in CancelCapture()
62 CAMERA_LOGE("release stream %{public}d failed", it); in ReleaseStreams()
105 std::shared_ptr<OfflineStream> stream = nullptr; in FindStreamByCaptureId() local
110 stream = it->second; in FindStreamByCaptureId()
114 return stream; in FindStreamByCaptureId()
/third_party/curl/docs/examples/
H A Dftpuploadresume.c35 void *stream) in getcontentlengthfunc()
42 *((long *) stream) = len; in getcontentlengthfunc()
48 static size_t discardfunc(void *ptr, size_t size, size_t nmemb, void *stream) in discardfunc() argument
51 (void)stream; in discardfunc()
56 static size_t readfunc(char *ptr, size_t size, size_t nmemb, void *stream) in readfunc() argument
58 FILE *f = stream; in readfunc()
34 getcontentlengthfunc(void *ptr, size_t size, size_t nmemb, void *stream) getcontentlengthfunc() argument
/third_party/PyYAML/lib/yaml/
H A Ddumper.py11 def __init__(self, stream,
17 Emitter.__init__(self, stream, canonical=canonical,
29 def __init__(self, stream,
35 Emitter.__init__(self, stream, canonical=canonical,
47 def __init__(self, stream,
53 Emitter.__init__(self, stream, canonical=canonical,
/third_party/lzma/CPP/7zip/Common/
H A DStreamObjects.h52 void Create_BufInStream_WithReference(const void *data, size_t size, IUnknown *ref, ISequentialInStream **stream);
53 void Create_BufInStream_WithNewBuffer(const void *data, size_t size, ISequentialInStream **stream);
54 inline void Create_BufInStream_WithNewBuffer(const CByteBuffer &buf, ISequentialInStream **stream)
55 { Create_BufInStream_WithNewBuffer(buf, buf.Size(), stream); }
117 void SetStream(ISequentialOutStream *stream) { _stream = stream; }
/third_party/node/test/fixtures/wpt/encoding/legacy-mb-japanese/shift_jis/
H A Dsjis-decoder.js15 function sjisDecoder(stream) {
16 stream = stream.replace(/%/g, " ");
17 stream = stream.replace(/[\s]+/g, " ").trim();
18 var bytes = stream.split(" ");
/third_party/node/deps/npm/node_modules/glob/dist/commonjs/
H A Dindex.js3 exports.glob = exports.hasMagic = exports.Glob = exports.unescape = exports.escape = exports.sync = exports.iterate = exports.iterateSync = exports.stream = exports.streamSync = exports.globIterate = exports.globIterateSync = exports.globSync = exports.globStream = exports.globStreamSync = void 0;
12 return new glob_js_1.Glob(pattern, options).stream();
30 // aliases: glob.sync.stream() glob.stream.sync() glob.sync() etc
32 exports.stream = Object.assign(globStream, { sync: globStreamSync });
38 stream: globStreamSync,
55 stream: exports.stream,
/third_party/node/deps/npm/node_modules/libnpmteam/lib/
H A Dindex.js62 cmd.lsTeams = (...args) => cmd.lsTeams.stream(...args).collect()
64 cmd.lsTeams.stream = (scope, opts = {}) => {
67 return npmFetch.json.stream(uri, '.*', {
73 cmd.lsUsers = (...args) => cmd.lsUsers.stream(...args).collect()
75 cmd.lsUsers.stream = (entity, opts = {}) => {
79 return npmFetch.json.stream(uri, '.*', {
/third_party/skia/src/core/
H A DSkFontDescriptor.h21 SkFontData(std::unique_ptr<SkStreamAsset> stream, int index, const SkFixed* axis, int axisCount) in SkFontData() argument
22 : fStream(std::move(stream)), fIndex(index), fAxisCount(axisCount), fAxis(axisCount) in SkFontData()
28 SkFontData(std::unique_ptr<SkStreamAsset> stream, SkFontArguments args) in SkFontData() argument
29 : fStream(std::move(stream)), fIndex(args.getCollectionIndex()) in SkFontData()
93 void setStream(std::unique_ptr<SkStreamAsset> stream) { fStream = std::move(stream); } in setStream() argument
/third_party/skia/src/codec/
H A DSkJpegUtility.cpp42 * Fill the input buffer from the stream
62 * Skip a certain number of bytes in the stream
85 * We do not need to do anything to terminate our stream
126 * We provide skia implementations of all of the stream processing functions required by libjpeg
128 skjpeg_source_mgr::skjpeg_source_mgr(SkStream* stream) in skjpeg_source_mgr() argument
129 : fStream(stream) in skjpeg_source_mgr()
131 if (stream->hasLength() && stream->getMemoryBase()) { in skjpeg_source_mgr()
137 bytes_in_buffer = static_cast<size_t>(stream->getLength()); in skjpeg_source_mgr()
138 next_input_byte = static_cast<const JOCTET*>(stream in skjpeg_source_mgr()
[all...]
/third_party/skia/third_party/externals/oboe/apps/OboeTester/app/src/main/java/com/google/sample/oboe/manualtest/
H A DBufferSizeView.java109 OboeAudioStream stream = null; in setBufferSizeByPosition()
112 stream = (OboeAudioStream) getAudioOutTester().getCurrentAudioStream(); in setBufferSizeByPosition()
113 if (stream != null) { in setBufferSizeByPosition()
114 int capacity = stream.getBufferCapacityInFrames(); in setBufferSizeByPosition()
121 if (stream != null) { in setBufferSizeByPosition()
122 stream.setBufferSizeInFrames(sizeFrames); in setBufferSizeByPosition()
/third_party/skia/third_party/externals/dng_sdk/source/
H A Ddng_preview.h50 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 Ddng_read_image.h33 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,
/third_party/lzma/CPP/7zip/Archive/Common/
H A DInStreamWithCRC.h28 void SetStream(ISequentialInStream *stream) { _stream = stream; } in SetStream() argument
54 void SetStream(IInStream *stream) { _stream = stream; }
/third_party/node/lib/internal/streams/
H A Dlazy_transform.js1 // 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 Dcolors.js17 shouldColorize(stream) {
21 return stream?.isTTY && (
22 typeof stream.getColorDepth === 'function' ?
23 stream.getColorDepth() > 2 : true);
/third_party/node/test/parallel/
H A Dtest-http2-server-shutdown-before-respond.js11 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 Dtest-http2-status-code-invalid.js19 server.on('stream', common.mustCall((stream) => {
23 assert.throws(() => stream.respond({ ':status': i }), expectsError(i));
26 stream.respond();
27 stream.end();
/third_party/node/benchmark/http2/
H A Dsimple.js19 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 Dprogress.rs7 stream: R,
11 pub fn new(stream: R) -> Self { in new()
15 stream, in new()
22 let num = self.stream.read(buf)?; in read()
/kernel/linux/linux-6.6/drivers/net/ethernet/microchip/vcap/
H A Dvcap_api_kunit.c337 u32 stream[2] = {0}; in vcap_api_set_bit_1_test() local
339 vcap_set_bit(stream, &iter, 1); in vcap_api_set_bit_1_test()
341 KUNIT_EXPECT_EQ(test, (u32)0x0, stream[0]); in vcap_api_set_bit_1_test()
342 KUNIT_EXPECT_EQ(test, (u32)BIT(20), stream[1]); in vcap_api_set_bit_1_test()
354 u32 stream[3] = {~0, ~0, ~0}; in vcap_api_set_bit_0_test() local
356 vcap_set_bit(stream, &iter, 0); in vcap_api_set_bit_0_test()
358 KUNIT_EXPECT_EQ(test, (u32)~0, stream[0]); in vcap_api_set_bit_0_test()
359 KUNIT_EXPECT_EQ(test, (u32)~0, stream[1]); in vcap_api_set_bit_0_test()
360 KUNIT_EXPECT_EQ(test, (u32)~BIT(11), stream[2]); in vcap_api_set_bit_0_test()
428 u32 stream[1 in vcap_api_encode_typegroups_test() local
458 u32 stream[4] = {0}; vcap_api_encode_bit_test() local
484 u32 stream[16] = {0}; vcap_api_encode_field_test() local
536 u32 stream[6] = {0}; vcap_api_encode_short_field_test() local
[all...]
/kernel/linux/linux-5.10/tools/testing/selftests/mqueue/
H A Dmq_perf_tests.c153 static inline void __set(FILE *stream, int value, char *err_msg);
157 static inline int get(FILE *stream);
158 static inline void set(FILE *stream, int value);
159 static inline int try_set(FILE *stream, int value);
165 static inline void __set(FILE *stream, int value, char *err_msg) in __set() argument
167 rewind(stream); in __set()
168 if (fprintf(stream, "%d", value) < 0) in __set()
238 static inline int get(FILE *stream) in get() argument
241 rewind(stream); in get()
242 if (fscanf(stream, " in get()
247 set(FILE *stream, int value) set() argument
260 try_set(FILE *stream, int value) try_set() argument
[all...]
/kernel/linux/linux-5.10/sound/soc/codecs/
H A Drt5682-sdw.c97 struct sdw_stream_data *stream; in rt5682_set_sdw_stream() local
102 stream = kzalloc(sizeof(*stream), GFP_KERNEL); in rt5682_set_sdw_stream()
103 if (!stream) in rt5682_set_sdw_stream()
106 stream->sdw_stream = (struct sdw_stream_runtime *)sdw_stream; in rt5682_set_sdw_stream()
108 /* Use tx_mask or rx_mask to configure stream tag and set dma_data */ in rt5682_set_sdw_stream()
110 dai->playback_dma_data = stream; in rt5682_set_sdw_stream()
112 dai->capture_dma_data = stream; in rt5682_set_sdw_stream()
120 struct sdw_stream_data *stream; in rt5682_sdw_shutdown() local
122 stream in rt5682_sdw_shutdown()
136 struct sdw_stream_data *stream; rt5682_sdw_hw_params() local
262 struct sdw_stream_data *stream = rt5682_sdw_hw_free() local
[all...]
/kernel/linux/linux-6.6/tools/testing/selftests/mqueue/
H A Dmq_perf_tests.c153 static inline void __set(FILE *stream, int value, char *err_msg);
157 static inline int get(FILE *stream);
158 static inline void set(FILE *stream, int value);
159 static inline int try_set(FILE *stream, int value);
165 static inline void __set(FILE *stream, int value, char *err_msg) in __set() argument
167 rewind(stream); in __set()
168 if (fprintf(stream, "%d", value) < 0) in __set()
238 static inline int get(FILE *stream) in get() argument
241 rewind(stream); in get()
242 if (fscanf(stream, " in get()
247 set(FILE *stream, int value) set() argument
260 try_set(FILE *stream, int value) try_set() argument
[all...]

Completed in 10 milliseconds

1...<<31323334353637383940>>...169