Home
last modified time | relevance | path

Searched refs:stream (Results 1551 - 1575 of 4260) sorted by relevance

1...<<61626364656667686970>>...171

/foundation/resourceschedule/background_task_mgr/services/transient_task/src/
H A Dbg_transient_task_mgr.cpp740 std::stringstream stream; in DumpAllRequestId() local
743 stream.clear(); in DumpAllRequestId()
744 stream.str(""); in DumpAllRequestId()
745 stream << "No." << std::to_string(index++) << "\n"; in DumpAllRequestId()
746 stream << "\tRequestId: " << record.first << "\n"; in DumpAllRequestId()
747 stream << "\tAppName: " << record.second->GetPkg() << "\n"; in DumpAllRequestId()
748 stream << "\tAppUid: " << record.second->GetUid() << "\n"; in DumpAllRequestId()
749 stream << "\tAppPid: " << record.second->GetPid() << "\n"; in DumpAllRequestId()
750 stream << "\tActualDelayTime: " << decisionMaker_->GetRemainingDelayTime(record.second, record.first) << "\n"; in DumpAllRequestId()
751 stream << "\tRemainingQuot in DumpAllRequestId()
[all...]
/third_party/node/deps/uv/src/
H A Duv-common.c521 static void uv__print_handles(uv_loop_t* loop, int only_active, FILE* stream) { in uv__print_handles() argument
542 fprintf(stream, in uv__print_handles()
553 void uv_print_all_handles(uv_loop_t* loop, FILE* stream) { in uv_print_all_handles() argument
554 uv__print_handles(loop, 0, stream); in uv_print_all_handles()
558 void uv_print_active_handles(uv_loop_t* loop, FILE* stream) { in uv_print_active_handles() argument
559 uv__print_handles(loop, 1, stream); in uv_print_active_handles()
851 int uv_read_start(uv_stream_t* stream, in uv_read_start() argument
854 if (stream == NULL || alloc_cb == NULL || read_cb == NULL) in uv_read_start()
857 if (stream->flags & UV_HANDLE_CLOSING) in uv_read_start()
860 if (stream in uv_read_start()
[all...]
/third_party/skia/third_party/externals/angle2/src/libANGLE/renderer/vulkan/
H A DProgramVk.cpp165 gl::BinaryInputStream *stream, in load()
174 mOriginalShaderInfo.load(stream); in load()
175 mExecutable.load(stream); in load()
180 const size_t uniformCount = stream->readInt<size_t>(); in load()
184 gl::LoadBlockMemberInfo(stream, &blockInfo); in load()
192 requiredBufferSize[shaderType] = stream->readInt<size_t>(); in load()
206 void ProgramVk::save(const gl::Context *context, gl::BinaryOutputStream *stream) in save() argument
208 mOriginalShaderInfo.save(stream); in save()
209 mExecutable.save(stream); in save()
215 stream in save()
164 load(const gl::Context *context, gl::BinaryInputStream *stream, gl::InfoLog &infoLog) load() argument
[all...]
/third_party/protobuf/src/google/protobuf/compiler/
H A Dplugin.pb.cc394 ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { in _InternalSerialize()
402 target = stream->EnsureSpace(target); in _InternalSerialize()
408 target = stream->EnsureSpace(target); in _InternalSerialize()
414 target = stream->EnsureSpace(target); in _InternalSerialize()
424 target = stream->WriteStringMaybeAliased( in _InternalSerialize()
430 _internal_metadata_.unknown_fields<::PROTOBUF_NAMESPACE_ID::UnknownFieldSet>(::PROTOBUF_NAMESPACE_ID::UnknownFieldSet::default_instance), target, stream); in _InternalSerialize()
746 ::PROTOBUF_NAMESPACE_ID::uint8* target, ::PROTOBUF_NAMESPACE_ID::io::EpsCopyOutputStream* stream) const { in _InternalSerialize()
758 target = stream->WriteString(1, s, target); in _InternalSerialize()
768 target = stream->WriteStringMaybeAliased( in _InternalSerialize()
774 target = stream in _InternalSerialize()
[all...]
/third_party/mesa3d/src/imagination/vulkan/pds/
H A Dpvr_pds.c781 for (uint32_t stream = 0; stream < program->num_streams; stream++) { in pvr_pds_vertex_shader()
783 8 * program->streams[stream].num_elements, in pvr_pds_vertex_shader()
799 /* Evaluate what config of DDMAD should be used for each stream. */ in pvr_pds_vertex_shader()
800 for (uint32_t stream = 0; stream < program->num_streams; stream++) { in pvr_pds_vertex_shader()
801 vertex_stream = &program->streams[stream]; in pvr_pds_vertex_shader()
804 ddmadt_enables |= (1 << stream); in pvr_pds_vertex_shader()
[all...]
/kernel/linux/linux-5.10/sound/soc/xilinx/
H A Dxlnx_formatter_pcm.c91 * struct xlnx_pcm_stream_param - stream configuration
96 * @buffer_size: stream ring buffer size
268 static void xlnx_formatter_disable_irqs(void __iomem *mmio_base, int stream) in xlnx_formatter_disable_irqs() argument
274 if (stream == SNDRV_PCM_STREAM_CAPTURE) in xlnx_formatter_disable_irqs()
337 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK && in xlnx_formatter_pcm_open()
340 else if (substream->stream == SNDRV_PCM_STREAM_CAPTURE && in xlnx_formatter_pcm_open()
348 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in xlnx_formatter_pcm_open()
375 "stream %d : format = %d mode = %d ch_limit = %d\n", in xlnx_formatter_pcm_open()
376 substream->stream, stream_data->interleaved, in xlnx_formatter_pcm_open()
431 xlnx_formatter_disable_irqs(stream_data->mmio, substream->stream); in xlnx_formatter_pcm_close()
[all...]
/kernel/linux/linux-6.6/sound/soc/bcm/
H A Dcygnus-pcm.c255 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in configure_ringbuf_regs()
302 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) in get_ringbuf()
320 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in enable_intr()
357 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in disable_intr()
407 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in cygnus_pcm_period_elapsed()
600 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) in cygnus_pcm_open()
618 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) in cygnus_pcm_close()
655 is_play = (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) ? 1 : 0; in cygnus_pcm_prepare()
677 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) in cygnus_pcm_pointer()
/kernel/linux/linux-6.6/sound/soc/xilinx/
H A Dxlnx_formatter_pcm.c91 * struct xlnx_pcm_stream_param - stream configuration
96 * @buffer_size: stream ring buffer size
268 static void xlnx_formatter_disable_irqs(void __iomem *mmio_base, int stream) in xlnx_formatter_disable_irqs() argument
274 if (stream == SNDRV_PCM_STREAM_CAPTURE) in xlnx_formatter_disable_irqs()
337 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK && in xlnx_formatter_pcm_open()
340 else if (substream->stream == SNDRV_PCM_STREAM_CAPTURE && in xlnx_formatter_pcm_open()
348 if (substream->stream == SNDRV_PCM_STREAM_PLAYBACK) { in xlnx_formatter_pcm_open()
375 "stream %d : format = %d mode = %d ch_limit = %d\n", in xlnx_formatter_pcm_open()
376 substream->stream, stream_data->interleaved, in xlnx_formatter_pcm_open()
431 xlnx_formatter_disable_irqs(stream_data->mmio, substream->stream); in xlnx_formatter_pcm_close()
[all...]
/third_party/ffmpeg/libavdevice/
H A Dkmsgrab.c417 AVStream *stream; in kmsgrab_read_header() local
622 stream = avformat_new_stream(avctx, NULL); in kmsgrab_read_header()
623 if (!stream) { in kmsgrab_read_header()
628 stream->codecpar->codec_type = AVMEDIA_TYPE_VIDEO; in kmsgrab_read_header()
629 stream->codecpar->codec_id = AV_CODEC_ID_WRAPPED_AVFRAME; in kmsgrab_read_header()
630 stream->codecpar->width = ctx->width; in kmsgrab_read_header()
631 stream->codecpar->height = ctx->height; in kmsgrab_read_header()
632 stream->codecpar->format = AV_PIX_FMT_DRM_PRIME; in kmsgrab_read_header()
634 avpriv_set_pts_info(stream, 64, 1, 1000000); in kmsgrab_read_header()
/third_party/alsa-lib/src/rawmidi/
H A Drawmidi.c38 MIDI stream. The buffer size is tunable and drivers report underruns for incoming
39 stream as well.
400 * \brief get stream (direction) of RawMidi handle
402 * \return stream of RawMidi handle
404 * Returns the stream #snd_rawmidi_stream_t of given RawMidi handle.
409 return rawmidi->stream; in snd_rawmidi_stream()
435 pfds->events = rawmidi->stream == SND_RAWMIDI_STREAM_OUTPUT ? (POLLOUT|POLLERR|POLLNVAL) : (POLLIN|POLLERR|POLLNVAL); in snd_rawmidi_poll_descriptors()
465 * The nonblock mode cannot be used when the stream is in
555 * \brief get rawmidi stream identification
557 * \return rawmidi stream identificatio
[all...]
/third_party/libphonenumber/metadata/src/test/java/com/google/i18n/phonenumbers/metadata/testing/
H A DTestNumberingScheme.java61 import java.util.stream.Stream;
116 this.regionMap = Stream.concat(Stream.of(main), others.stream()) in TestNumberingScheme()
165 this.carrierPrefixes = RangeTree.from(Arrays.stream(prefix).map(RangeSpecification::parse)); in setCarrierPrefixes()
272 shortcodes.entrySet().stream() in build()
277 xmlTable.getAssignedValues(XmlRangesSchema.FORMAT).stream(), in build()
278 shortcodeMap.values().stream() in build()
279 .flatMap(t -> t.getAssignedValues(ShortcodesTableSchema.FORMAT).stream())) in build()
281 ImmutableMap<String, FormatSpec> formatMap = formats.entrySet().stream() in build()
464 RangeTree ranges = RangeTree.from(Arrays.stream(specs).map(RangeSpecification::parse)); in rangesOf()
/third_party/skia/src/codec/
H A DSkWebpCodec.cpp43 std::unique_ptr<SkCodec> SkWebpCodec::MakeFromStream(std::unique_ptr<SkStream> stream, in MakeFromStream() argument
47 if (stream->getMemoryBase()) { in MakeFromStream()
48 // It is safe to make without copy because we'll hold onto the stream. in MakeFromStream()
49 data = SkData::MakeWithoutCopy(stream->getMemoryBase(), stream->getLength()); in MakeFromStream()
51 data = SkCopyStreamToData(stream.get()); in MakeFromStream()
53 // If we are forced to copy the stream to a data, we can go ahead and delete the stream. in MakeFromStream()
54 stream.reset(nullptr); in MakeFromStream()
174 return std::unique_ptr<SkCodec>(new SkWebpCodec(std::move(info), std::move(stream), in MakeFromStream()
550 SkWebpCodec(SkEncodedInfo&& info, std::unique_ptr<SkStream> stream, WebPDemuxer* demux, sk_sp<SkData> data, SkEncodedOrigin origin) SkWebpCodec() argument
[all...]
/third_party/skia/third_party/externals/libwebp/imageio/
H A Dimage_enc.c60 int write_to_mem, IStream** stream) { in CreateOutputStream()
63 // Output to a memory buffer. This is freed when 'stream' is released. in CreateOutputStream()
64 IFS(CreateStreamOnHGlobal(NULL, TRUE, stream)); in CreateOutputStream()
67 STGM_WRITE | STGM_CREATE, stream)); in CreateOutputStream()
84 IStream* stream = NULL; in WriteUsingWIC() local
101 IFS(CreateOutputStream(out_file_name, use_stdout, &stream)); in WriteUsingWIC()
104 IFS(IWICBitmapEncoder_Initialize(encoder, stream, in WriteUsingWIC()
117 IFS(GetHGlobalFromStream(stream, &image)); in WriteUsingWIC()
140 if (stream != NULL) IUnknown_Release(stream); in WriteUsingWIC()
59 CreateOutputStream(const char* out_file_name, int write_to_mem, IStream** stream) CreateOutputStream() argument
[all...]
/third_party/skia/tests/
H A DTypefaceTest.cpp87 std::unique_ptr<SkStreamAsset> stream(GetResourceAsStream("fonts/Em.ttf")); in DEF_TEST()
88 if (!stream) { in DEF_TEST()
92 sk_sp<SkData> data(SkData::MakeFromStream(stream.get(), stream->getLength())); in DEF_TEST()
127 std::unique_ptr<SkStreamAsset> stream = typeface->openStream(&fontIndex); in DEF_TEST() local
130 sk_sp<SkTypeface> typeface2 = fm->makeFromStream(std::move(stream), fontIndex); in DEF_TEST()
139 SkDynamicMemoryWStream stream; in DEF_TEST() local
140 desc.serialize(&stream); in DEF_TEST()
142 SkFontDescriptor::Deserialize(stream.detachAsStream().get(), &descD); in DEF_TEST()
/foundation/multimedia/audio_framework/services/audio_service/server/include/
H A Dpa_adapter_manager.h64 int32_t CreateRender(AudioProcessConfig processConfig, std::shared_ptr<IRendererStream> &stream) override;
71 int32_t CreateCapturer(AudioProcessConfig processConfig, std::shared_ptr<ICapturerStream> &stream) override;
107 static void PAStreamStateCb(pa_stream *stream, void *userdata);
110 static void PAStreamUpdateStreamIndexSuccessCb(pa_stream *stream, int32_t success, void *userdata);
/foundation/multimedia/audio_framework/services/audio_service/client/src/
H A Daudio_stream_manager.cpp125 for (j = 0; j < supportedEffectConfig.postProcessNew.stream[i].streamEffectMode.size(); j++) { in UpdateEffectInfoArray()
126 audioEffectMode = effectModeMap.at(supportedEffectConfig.postProcessNew.stream[i].streamEffectMode[j].mode); in UpdateEffectInfoArray()
147 uint32_t streamNum = supportedEffectConfig.postProcessNew.stream.size(); in GetEffectInfoArray()
151 if (effectScene == supportedEffectConfig.postProcessNew.stream[i].scene) { in GetEffectInfoArray()
/foundation/graphic/graphic_2d/rosen/samples/2d_graphics/
H A Ddrawing_sample_replayer.cpp116 SkFILEWStream stream(outputFile.c_str()); in FinilizeCapturingSKP()
117 if (stream.isValid()) { in FinilizeCapturingSKP()
118 stream.write(data->data(), data->size()); in FinilizeCapturingSKP()
119 stream.flush(); in FinilizeCapturingSKP()
122 std::cout << "Failed to create stream" << std::endl; in FinilizeCapturingSKP()
/foundation/resourceschedule/device_standby/services/notification/src/
H A Dstandby_state_subscriber.cpp220 std::stringstream stream; in ShellDump() local
222 stream << "\tobserverName: " << (*iter)->GetSubscriberName() << "\n"; in ShellDump()
223 result += stream.str(); in ShellDump()
224 stream.clear(); in ShellDump()
/kernel/linux/linux-5.10/sound/soc/sof/intel/
H A Dhda-ipc.c270 /* The stream might already be closed */ in hda_ipc_msg_data()
272 sof_mailbox_read(sdev, hda_stream->stream.posn_offset, in hda_ipc_msg_data()
294 hda_stream->stream.posn_offset = sdev->stream_box.offset + posn_offset; in hda_ipc_pcm_params()
296 dev_dbg(sdev->dev, "pcm: stream dir %d, posn mailbox offset is %zu", in hda_ipc_pcm_params()
297 substream->stream, hda_stream->stream.posn_offset); in hda_ipc_pcm_params()
/kernel/linux/linux-5.10/include/sound/
H A Dhda_register.h80 /* stream register offsets from stream base */
155 #define SD_CTL_STREAM_RESET 0x01 /* stream reset bit */
156 #define SD_CTL_DMA_START 0x02 /* stream DMA start bit */
159 #define SD_CTL_DIR (1 << 19) /* bi-directional stream */
175 #define AZX_INT_ALL_STREAM 0xff /* all stream interrupts */
308 * helpers to read the stream position
311 snd_hdac_stream_get_pos_lpib(struct hdac_stream *stream) in snd_hdac_stream_get_pos_lpib() argument
313 return snd_hdac_stream_readl(stream, SD_LPIB); in snd_hdac_stream_get_pos_lpib()
317 snd_hdac_stream_get_pos_posbuf(struct hdac_stream *stream) in snd_hdac_stream_get_pos_posbuf() argument
[all...]
/third_party/curl/docs/examples/
H A Dsynctime.c133 void *stream) in SyncTime_CURL_WriteOutput()
135 fwrite(ptr, size, nmemb, stream); in SyncTime_CURL_WriteOutput()
140 void *stream) in SyncTime_CURL_WriteHeader()
144 (void)stream; in SyncTime_CURL_WriteHeader()
132 SyncTime_CURL_WriteOutput(void *ptr, size_t size, size_t nmemb, void *stream) SyncTime_CURL_WriteOutput() argument
139 SyncTime_CURL_WriteHeader(void *ptr, size_t size, size_t nmemb, void *stream) SyncTime_CURL_WriteHeader() argument
/third_party/icu/tools/cldr/cldr-to-icu/src/main/java/org/unicode/icu/tool/cldrtoicu/regex/
H A DRegexTransformer.java63 rules.stream().collect(toImmutableSetMultimap(Rule::getDataType, Rule::getPathPrefix)); in RegexTransformer()
65 rules.stream().collect(toImmutableListMultimap(Rule::getPathPrefix, identity())); in RegexTransformer()
67 rules.stream().flatMap(Rule::getFallbackFunctions).collect(toImmutableList()); in RegexTransformer()
136 return fallbackFunctions.stream() in getFallbackResultsFor()
/third_party/node/test/parallel/
H A Dtest-crypto-authenticated-stream.js11 const stream = require('stream');
14 class Sink extends stream.Writable {
49 const plain = new stream.PassThrough();
60 const crypt = new stream.PassThrough();
H A Dtest-stream2-objects.js25 const { Readable, Writable } = require('stream');
29 const stream = new Writable({ objectMode: true });
31 stream.write = function(chunk) {
35 stream.end = common.mustCall(function() {
39 return stream;
54 // Verify that objects can be read from the stream
67 // Verify that objects can be piped into the stream
216 // Verify that objects can be written to stream
230 // Verify that multiple objects can be written to stream
276 // Verify that stream buffer
[all...]
/third_party/nghttp2/src/
H A DHttpServer.h172 int submit_file_response(const StringRef &status, Stream *stream,
186 int submit_push_promise(Stream *stream, const StringRef &push_path);
188 int submit_rst_stream(Stream *stream, uint32_t error_code);
190 void add_stream(int32_t stream_id, std::unique_ptr<Stream> stream);

Completed in 23 milliseconds

1...<<61626364656667686970>>...171