/base/update/updater/services/diffpatch/patch_shared/ |
H A D | patch_shared.cpp | 133 LOG(ERROR) << "Error to create output stream"; in ExtractFileByNameFunc() 266 Hpackage::PkgManager::StreamPtr stream = nullptr; in UnpackNewDataFunc() local 282 int32_t ret = env->GetPkgManager()->CreatePkgStream(stream, info->newPatch, ExtractNewDataFunc, info); in UnpackNewDataFunc() 283 if (ret != Hpackage::PKG_SUCCESS || stream == nullptr) { in UnpackNewDataFunc() 288 ret = env->GetPkgManager()->ExtractFile(info->newPatch, stream); in UnpackNewDataFunc() 289 env->GetPkgManager()->ClosePkgStream(stream); in UnpackNewDataFunc()
|
/kernel/linux/linux-5.10/drivers/media/platform/cadence/ |
H A D | cdns-csi2tx.c | 332 unsigned int stream; in csi2tx_start() local 354 stream = pad_idx - CSI2TX_PAD_SINK_STREAM0; in csi2tx_start() 357 * We use the stream ID there, but it's wrong. in csi2tx_start() 359 * A stream could very well send a data type that is in csi2tx_start() 360 * not equal to its stream ID. We need to find a in csi2tx_start() 364 csi2tx->base + CSI2TX_DT_CFG_REG(stream)); in csi2tx_start() 368 csi2tx->base + CSI2TX_DT_FORMAT_REG(stream)); in csi2tx_start() 375 csi2tx->base + CSI2TX_STREAM_IF_CFG_REG(stream)); in csi2tx_start()
|
/kernel/linux/linux-5.10/sound/soc/amd/raven/ |
H A D | acp3x-pcm-dma.c | 227 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) in acp3x_dma_open() 266 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in acp3x_dma_hw_params() 293 config_acp3x_dma(rtd, substream->stream); in acp3x_dma_hw_params() 309 bytescount = acp_get_byte_count(rtd, substream->stream); in acp3x_dma_pointer() 346 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in acp3x_dma_close()
|
/kernel/linux/linux-5.10/sound/soc/ |
H A D | soc-generic-dmaengine-pcm.c | 27 if (!pcm->chan[substream->stream]) in dmaengine_dma_dev() 30 return pcm->chan[substream->stream]->device->dev; in dmaengine_dma_dev() 111 struct dma_chan *chan = pcm->chan[substream->stream]; in dmaengine_pcm_set_runtime_hwparams() 157 struct dma_chan *chan = pcm->chan[substream->stream]; in dmaengine_pcm_open() 262 "Missing dma channel for stream: %d\n", i); in dmaengine_pcm_new() 307 bool is_playback = substream->stream == SNDRV_PCM_STREAM_PLAYBACK; in dmaengine_copy_user()
|
/kernel/linux/linux-5.10/drivers/media/usb/as102/ |
H A D | as102_usb_drv.c | 238 dev->stream, in as102_free_usb_stream_buffer() 246 dev->stream = usb_alloc_coherent(dev->bus_adap.usb_dev, in as102_alloc_usb_stream_buffer() 250 if (!dev->stream) { in as102_alloc_usb_stream_buffer() 256 memset(dev->stream, 0, MAX_STREAM_URB * AS102_USB_BUF_SIZE); in as102_alloc_usb_stream_buffer() 268 urb->transfer_buffer = dev->stream + (i * AS102_USB_BUF_SIZE); in as102_alloc_usb_stream_buffer()
|
/kernel/linux/linux-6.6/drivers/media/platform/cadence/ |
H A D | cdns-csi2tx.c | 333 unsigned int stream; in csi2tx_start() local 355 stream = pad_idx - CSI2TX_PAD_SINK_STREAM0; in csi2tx_start() 358 * We use the stream ID there, but it's wrong. in csi2tx_start() 360 * A stream could very well send a data type that is in csi2tx_start() 361 * not equal to its stream ID. We need to find a in csi2tx_start() 365 csi2tx->base + CSI2TX_DT_CFG_REG(stream)); in csi2tx_start() 369 csi2tx->base + CSI2TX_DT_FORMAT_REG(stream)); in csi2tx_start() 376 csi2tx->base + CSI2TX_STREAM_IF_CFG_REG(stream)); in csi2tx_start()
|
/kernel/linux/linux-6.6/sound/soc/ |
H A D | soc-generic-dmaengine-pcm.c | 31 if (!pcm->chan[substream->stream]) in dmaengine_dma_dev() 34 return pcm->chan[substream->stream]->device->dev; in dmaengine_dma_dev() 104 struct dma_chan *chan = pcm->chan[substream->stream]; in dmaengine_pcm_set_runtime_hwparams() 152 struct dma_chan *chan = pcm->chan[substream->stream]; in dmaengine_pcm_open() 255 "Missing dma channel for stream: %d\n", i); in dmaengine_pcm_new() 300 bool is_playback = substream->stream == SNDRV_PCM_STREAM_PLAYBACK; in dmaengine_copy()
|
/kernel/linux/linux-6.6/sound/soc/amd/vangogh/ |
H A D | acp5x-pcm-dma.c | 220 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) in acp5x_dma_open() 258 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in acp5x_dma_hw_params() 286 config_acp5x_dma(rtd, substream->stream); in acp5x_dma_hw_params() 301 bytescount = acp_get_byte_count(rtd, substream->stream); in acp5x_dma_pointer() 331 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in acp5x_dma_close()
|
/kernel/linux/linux-6.6/sound/soc/amd/raven/ |
H A D | acp3x-pcm-dma.c | 225 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) in acp3x_dma_open() 264 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in acp3x_dma_hw_params() 291 config_acp3x_dma(rtd, substream->stream); in acp3x_dma_hw_params() 307 bytescount = acp_get_byte_count(rtd, substream->stream); in acp3x_dma_pointer() 337 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in acp3x_dma_close()
|
/kernel/linux/linux-6.6/sound/soc/fsl/ |
H A D | fsl_dma.c | 169 if (dma_private->substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in fsl_dma_update_pointers() 398 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) in fsl_dma_open() 476 mr |= (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) ? in fsl_dma_open() 487 * This function obtains hardware parameters about the opened stream and 636 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in fsl_dma_hw_params() 664 * stream buffer the hardware currently is. 686 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in fsl_dma_pointer() 712 dev_err(dev, "dma pointer is out of range, halting stream\n"); in fsl_dma_pointer() 768 * fsl_dma_close: close the stream.
|
/test/testfwk/arkxtest/jsunit/src/module/report/ |
H A D | OhReport.js | 52 let message = '\n' + `${PrintTag.OHOS_REPORT_RESULT}: stream=Tests run: ` + summary.total + ', Failure: ' + summary.failure; 149 message += '\n' + `${PrintTag.OHOS_REPORT_STATUS}: stream=`; 174 messageCode += `${PrintTag.OHOS_REPORT_STATUS}: stream=`; 183 messageCode += `${PrintTag.OHOS_REPORT_STATUS}: stream=`; 190 messageStack += `${PrintTag.OHOS_REPORT_STATUS}: stream=`;
|
/third_party/alsa-lib/src/pcm/ |
H A D | pcm_lfloat.c | 280 if (pcm->stream == SND_PCM_STREAM_PLAYBACK) { in snd_pcm_lfloat_hw_params() 404 err = snd_pcm_new(&pcm, SND_PCM_TYPE_LINEAR_FLOAT, name, slave->stream, slave->mode); in snd_pcm_lfloat_open() 459 * \param stream Stream type 468 snd_pcm_stream_t stream, int mode) in _snd_pcm_lfloat_open() 503 err = snd_pcm_open_slave(&spcm, root, sconf, stream, mode, conf); in _snd_pcm_lfloat_open() 532 snd_pcm_stream_t stream ATTRIBUTE_UNUSED, in _snd_pcm_lfloat_open() 466 _snd_pcm_lfloat_open(snd_pcm_t **pcmp, const char *name, snd_config_t *root, snd_config_t *conf, snd_pcm_stream_t stream, int mode) _snd_pcm_lfloat_open() argument
|
H A D | pcm_linear.c | 315 if (pcm->stream == SND_PCM_STREAM_PLAYBACK) { in snd_pcm_linear_hw_params() 323 if (pcm->stream == SND_PCM_STREAM_PLAYBACK) in snd_pcm_linear_hw_params() 448 err = snd_pcm_new(&pcm, SND_PCM_TYPE_LINEAR, name, slave->stream, slave->mode); in snd_pcm_linear_open() 502 * \param stream Stream type 511 snd_pcm_stream_t stream, int mode) in _snd_pcm_linear_open() 545 err = snd_pcm_open_slave(&spcm, root, sconf, stream, mode, conf); in _snd_pcm_linear_open() 509 _snd_pcm_linear_open(snd_pcm_t **pcmp, const char *name, snd_config_t *root, snd_config_t *conf, snd_pcm_stream_t stream, int mode) _snd_pcm_linear_open() argument
|
H A D | pcm_mmap_emul.c | 281 /* HACK: don't start stream automatically at commit in mmap mode */ in sync_slave_write() 326 if (pcm->stream == SND_PCM_STREAM_PLAYBACK) in snd_pcm_mmap_emul_mmap_commit() 336 if (!map->mmap_emul || pcm->stream == SND_PCM_STREAM_PLAYBACK) in snd_pcm_mmap_emul_avail_update() 421 slave->stream, slave->mode); in __snd_pcm_mmap_emul_open() 465 * \param stream PCM Stream 474 snd_pcm_stream_t stream, int mode) in _snd_pcm_mmap_emul_open() 502 err = snd_pcm_open_slave(&spcm, root, sconf, stream, mode, conf); in _snd_pcm_mmap_emul_open() 471 _snd_pcm_mmap_emul_open(snd_pcm_t **pcmp, const char *name, snd_config_t *root ATTRIBUTE_UNUSED, snd_config_t *conf, snd_pcm_stream_t stream, int mode) _snd_pcm_mmap_emul_open() argument
|
/third_party/node/test/fixtures/wpt/streams/readable-streams/ |
H A D | async-iterator.any.js | 160 }, 'Async-iterating an errored stream throws'); 172 }, 'Async-iterating a closed stream never executes the loop body, but works fine'); 188 }, 'Async-iterating an empty but not closed/errored stream never executes the loop body and stalls the async function'); 210 }, 'Async-iterating a partially consumed stream'); 285 }, 'next() rejects if the stream errors'); 304 }, 'return() does not rejects if the stream has not errored yet'); 319 }, 'return() rejects if the stream has errored'); 540 }, 'Acquiring a reader after exhaustively async-iterating a stream'); 565 // i.e. it should not reject with a generic "this stream is locked" TypeError. 568 }, 'Acquiring a reader after return()ing from a stream tha [all...] |
/third_party/node/deps/undici/src/lib/cache/ |
H A D | cache.js | 360 if (innerResponse.body && (isDisturbed(innerResponse.body.stream) || innerResponse.body.stream.locked)) { 376 const stream = innerResponse.body.stream 379 const reader = stream.getReader()
|
/third_party/node/deps/undici/src/lib/fetch/ |
H A D | util.js | 944 // 4. Let reader be the result of getting a reader for body’s stream. 950 reader = body.stream.getReader() 968 function isReadableStreamLike (stream) { 970 ReadableStream = require('stream/web').ReadableStream 973 return stream instanceof ReadableStream || ( 974 stream[Symbol.toStringTag] === 'ReadableStream' && 975 typeof stream.tee === 'function'
|
/third_party/libphonenumber/metadata/src/main/java/com/google/i18n/phonenumbers/metadata/finitestatematcher/compiler/ |
H A D | Operation.java | 23 import static java.util.stream.Collectors.joining; 394 this.nodeMap = outMasks.entrySet().stream() in Mapping() 396 Entry::getKey, e -> Digit.fromMask(e.getValue()).stream())); in Mapping() 420 getOuts().stream().map(offsetMap::get).collect(toImmutableList()); in writeImpl() 426 return format(nodeMap.asMap().values().stream() in toString()
|
/third_party/skia/src/images/ |
H A D | SkPngEncoder.cpp | 42 SkWStream* stream = (SkWStream*)png_get_io_ptr(png_ptr); in sk_write_fn() local 43 if (!stream->write(data, len)) { in sk_write_fn() 44 png_error(png_ptr, "sk_write_fn cannot write to stream"); in sk_write_fn() 53 * Does not take ownership of stream 55 static std::unique_ptr<SkPngEncoderMgr> Make(SkWStream* stream); 84 std::unique_ptr<SkPngEncoderMgr> SkPngEncoderMgr::Make(SkWStream* stream) { in Make() argument 97 png_set_write_fn(pngPtr, (void*)stream, sk_write_fn, nullptr); in Make()
|
/third_party/skia/third_party/externals/oboe/apps/OboeTester/app/src/main/java/com/google/sample/oboe/manualtest/ |
H A D | TestDisconnectActivity.java | 306 // Give previous stream time to close and release resources. Avoid race conditions. in testConfiguration() 310 AudioStreamBase stream = null; in testConfiguration() 318 stream = (isInput) in testConfiguration() 347 // poll for stream disconnected in testConfiguration() 349 stream.getState() == StreamConfiguration.STREAM_STATE_STARTING) { in testConfiguration() 356 // Wait for Java plug count to change or stream to disconnect. in testConfiguration() 358 stream.getState() == StreamConfiguration.STREAM_STATE_STARTED) { in testConfiguration() 365 // Wait for timeout or stream to disconnect. in testConfiguration() 367 stream.getState() == StreamConfiguration.STREAM_STATE_STARTED) { in testConfiguration()
|
/third_party/skia/src/pdf/ |
H A D | SkPDFMetadata.cpp | 218 void emitObject(SkWStream* stream) const override { 222 dict.emitObject(stream); 223 static const char streamBegin[] = " stream\n"; 224 stream->writeText(streamBegin); 228 stream->write(fXML.c_str(), fXML.size()); 230 stream->writeText(streamEnd);
|
/third_party/skia/third_party/externals/freetype/src/pfr/ |
H A D | pfrgload.c | 723 FT_Stream stream, in pfr_glyph_load_rec() 737 p = (FT_Byte*)stream->cursor; in pfr_glyph_load_rec() 776 error = pfr_glyph_load_rec( glyph, stream, gps_offset, in pfr_glyph_load_rec() 836 FT_Stream stream, in FT_LOCAL_DEF() 847 return pfr_glyph_load_rec( glyph, stream, gps_offset, offset, size ); in FT_LOCAL_DEF() 722 pfr_glyph_load_rec( PFR_Glyph glyph, FT_Stream stream, FT_ULong gps_offset, FT_ULong offset, FT_ULong size ) pfr_glyph_load_rec() argument
|
/third_party/python/Lib/test/libregrtest/ |
H A D | runtest.py | 199 stream = io.StringIO() 207 sys.stdout = stream 208 sys.stderr = stream 209 # print_warning() writes into the temporary stream to preserve 212 print_warning.orig_stderr = stream 217 output = stream.getvalue()
|
/base/security/security_guard/services/data_collect/sa/ |
H A D | data_collect_manager_service.cpp | 563 std::ifstream stream(trustListFile, std::ios::in);
in ParseTrustListFile() 564 if (!stream.is_open()) {
in ParseTrustListFile() 565 SGLOGE("stream error");
in ParseTrustListFile() 568 stream.seekg(0, std::ios::end);
in ParseTrustListFile() 570 std::ios::pos_type len = stream.tellg();
in ParseTrustListFile() 572 SGLOGE("stream is empty or too large");
in ParseTrustListFile() 573 stream.close();
in ParseTrustListFile() 576 stream.seekg(0, std::ios_base::beg);
in ParseTrustListFile() 577 nlohmann::json jsonObj = nlohmann::json::parse(stream, nullptr, false);
in ParseTrustListFile() 578 stream in ParseTrustListFile() [all...] |
/kernel/linux/linux-5.10/sound/core/oss/ |
H A D | pcm_plugin.c | 57 if (plugin->stream == SNDRV_PCM_STREAM_PLAYBACK) { in snd_pcm_plugin_alloc() 168 plugin->stream = snd_pcm_plug_stream(plug); in snd_pcm_plugin_build() 176 if (plugin->stream == SNDRV_PCM_STREAM_PLAYBACK) in snd_pcm_plugin_build() 380 int stream = snd_pcm_plug_stream(plug); in snd_pcm_plug_format_plugins() local 384 switch (stream) { in snd_pcm_plug_format_plugins() 565 int stream = snd_pcm_plug_stream(plug); in snd_pcm_plug_client_channels_buf() local 569 if (stream == SNDRV_PCM_STREAM_PLAYBACK) { in snd_pcm_plug_client_channels_buf() 587 v->wanted = (stream == SNDRV_PCM_STREAM_CAPTURE); in snd_pcm_plug_client_channels_buf()
|