| /foundation/multimedia/player_framework/services/engine/gstreamer/plugins/sink/audiosink/src/ |
| D | gst_audio_server_sink.cpp | 80 static void gst_audio_server_sink_clear_cache_buffer(GstAudioServerSink *sink);
209 static void gst_audio_server_sink_init(GstAudioServerSink *sink) in gst_audio_server_sink_init() argument
212 g_return_if_fail(sink != nullptr); in gst_audio_server_sink_init()
213 sink->audio_sink = nullptr; in gst_audio_server_sink_init()
214 sink->bits_per_sample = DEFAULT_BITS_PER_SAMPLE; in gst_audio_server_sink_init()
215 sink->channels = 0; in gst_audio_server_sink_init()
216 sink->sample_rate = 0; in gst_audio_server_sink_init()
217 sink->appuid = 0; in gst_audio_server_sink_init()
218 sink->apppid = 0; in gst_audio_server_sink_init()
219 sink->volume = DEFAULT_VOLUME; in gst_audio_server_sink_init()
[all …]
|
| D | audio_sink_factory.cpp | 32 std::unique_ptr<AudioSink> AudioSinkFactory::CreateAudioSink(GstBaseSink *sink) in CreateAudioSink() argument
35 return std::make_unique<AudioSinkBypass>(sink); in CreateAudioSink()
37 return std::make_unique<AudioSinkSvImpl>(sink); in CreateAudioSink()
|
| /foundation/multimedia/media_lite/services/player_lite/impl/player_control/sink/ |
| D | player_sink_manager.cpp | 41 audioSinkInfo_[i].sink = nullptr; in SinkManager()
43 videoSinkInfo_[i].sink = nullptr; in SinkManager()
66 audioSinkInfo_[audioSinkNum_].sink = std::make_shared<AudioSink>(); in AddNewSink()
67 ret = audioSinkInfo_[audioSinkNum_].sink->Init(attr); in AddNewSink()
69 audioSinkInfo_[audioSinkNum_].sink.reset(); in AddNewSink()
70 audioSinkInfo_[audioSinkNum_].sink = nullptr; in AddNewSink()
74 audioSinkInfo_[audioSinkNum_].sink->SetSync(sync_.get()); in AddNewSink()
81 videoSinkInfo_[videoSinkNum_].sink = std::make_shared<VideoSink>(); in AddNewSink()
82 ret = videoSinkInfo_[videoSinkNum_].sink->Init(attr); in AddNewSink()
84 videoSinkInfo_[videoSinkNum_].sink.reset(); in AddNewSink()
[all …]
|
| /foundation/multimedia/audio_framework/frameworks/native/pulseaudio/modules/capturer/ |
| D | module_receiver_sink.c | 51 pa_sink *sink; member
86 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in SinkPorcessMsg()
94 pa_sink_get_latency_within_thread(u->sink_input->sink, true) + in SinkPorcessMsg()
98 &u->sink_input->sink->sample_spec); in SinkPorcessMsg()
149 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in SinkRequestRewind()
165 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in SinkUpdateRequestedLatency()
184 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state)) { in SinkInputPopCb()
189 pa_sink_process_rewind(u->sink, 0); in SinkInputPopCb()
191 pa_sink_render(u->sink, nbytes, chunk); in SinkInputPopCb()
205 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state)) { in SinkInputProcessRewindCb()
[all …]
|
| D | module_inner_capturer_sink.c | 64 pa_sink *sink; member
171 rewindNbytes = u->sink->thread_info.rewind_nbytes; in ProcessRewind()
172 if (!PA_SINK_IS_OPENED(u->sink->thread_info.state) || rewindNbytes <= 0) { in ProcessRewind()
182 inBuffer = pa_usec_to_bytes(delay, &u->sink->sample_spec); in ProcessRewind()
191 pa_sink_process_rewind(u->sink, rewindNbytes); in ProcessRewind()
192 u->timestamp -= pa_bytes_to_usec(rewindNbytes, &u->sink->sample_spec); in ProcessRewind()
198 pa_sink_process_rewind(u->sink, 0); in ProcessRewind()
216 pa_sink_render(u->sink, u->sink->thread_info.max_request, &chunk); in ProcessRender()
219 u->timestamp += pa_bytes_to_usec(chunk.length, &u->sink->sample_spec); in ProcessRender()
222 if (ate >= u->sink->thread_info.max_request) { in ProcessRender()
[all …]
|
| /foundation/multimedia/audio_framework/frameworks/native/pulseaudio/modules/effect/ |
| D | module_effect_sink.c | 46 pa_sink *sink; member
74 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in SinkProcessMsg()
81 pa_sink_get_latency_within_thread(u->sinkInput->sink, true) + in SinkProcessMsg()
83 … pa_bytes_to_usec(pa_memblockq_get_length(u->bufInQ), &u->sinkInput->sink->sample_spec) + in SinkProcessMsg()
85 &u->sinkInput->sink->sample_spec); in SinkProcessMsg()
136 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in SinkRequestRewind()
153 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state) || in SinkUpdateRequestedLatency()
339 if (!PA_SINK_IS_LINKED(u->sink->thread_info.state)) { in SinkInputPopCb()
345 pa_sink_render(u->sink, bytesMissing, &nchunk); in SinkInputPopCb()
355 chunk->memblock = pa_memblock_new(si->sink->core->mempool, chunk->length); in SinkInputPopCb()
[all …]
|
| /foundation/multimedia/audio_framework/frameworks/native/pulseaudio/modules/hdi/ |
| D | module_hdi_sink.c | 103 pa_sink *sink = NULL; in pa__get_n_used() local
106 pa_assert_se(sink = m->userdata); in pa__get_n_used()
108 return pa_sink_linked_by(sink); in pa__get_n_used()
113 pa_sink *sink = NULL; in pa__done() local
117 if ((sink = m->userdata)) { in pa__done()
118 PaHdiSinkFree(sink); in pa__done()
|
| D | hdi_sink.c | 78 pa_sink *sink; member
195 pa_sink_render_full(u->sink, u->sink->thread_info.max_request, &chunk); in ProcessRenderUseTiming()
199 u->timestamp += pa_bytes_to_usec(chunk.length, &u->sink->sample_spec); in ProcessRenderUseTiming()
219 bool flag = (u->render_in_idle_state && PA_SINK_IS_OPENED(u->sink->thread_info.state)) || in ThreadFuncRendererTimer()
220 (!u->render_in_idle_state && PA_SINK_IS_RUNNING(u->sink->thread_info.state)); in ThreadFuncRendererTimer()
225 if (PA_UNLIKELY(u->sink->thread_info.rewind_requested)) { in ThreadFuncRendererTimer()
226 pa_sink_process_rewind(u->sink, 0); in ThreadFuncRendererTimer()
234 … pa_usec_t blockTime = pa_bytes_to_usec(u->sink->thread_info.max_request, &u->sink->sample_spec); in ThreadFuncRendererTimer()
580 pa_sink *sink = NULL; in PaHdiSinkInit() local
615 sink = pa_sink_new(m->core, &data, in PaHdiSinkInit()
[all …]
|
| D | BUILD.gn | 31 "../../../hdiadapter/sink/bluetooth",
32 "../../../hdiadapter/sink/common",
33 "../../../hdiadapter/sink/file",
34 "../../../hdiadapter/sink/primary",
35 "../../../hdiadapter/sink/remote",
54 ohos_shared_library("module-hdi-sink") {
80 "../../../hdiadapter/sink:renderer_sink_adapter",
|
| /foundation/multimedia/player_framework/services/engine/gstreamer/player/ |
| D | player_sinkprovider.cpp | 110 …auto sink = GST_ELEMENT_CAST(gst_object_ref_sink(gst_element_factory_make("audioserversink", nullp… in DoCreateAudioSink() local
111 CHECK_AND_RETURN_RET_LOG(sink != nullptr, nullptr, "gst_element_factory_make failed.."); in DoCreateAudioSink()
113 g_object_set(G_OBJECT(sink), "app-uid", uid_, nullptr); in DoCreateAudioSink()
114 g_object_set(G_OBJECT(sink), "app-pid", pid_, nullptr); in DoCreateAudioSink()
115 g_object_set(G_OBJECT(sink), "app-token-id", tokenId_, nullptr); in DoCreateAudioSink()
118 g_object_set(G_OBJECT(sink), "enable-opt-render-delay", enable, nullptr); in DoCreateAudioSink()
120 GstPad *pad = gst_element_get_static_pad(sink, "sink"); in DoCreateAudioSink()
122 gst_object_unref(sink); in DoCreateAudioSink()
130 return sink; in DoCreateAudioSink()
179 …auto sink = GST_ELEMENT_CAST(gst_object_ref_sink(gst_element_factory_make("videodisplaysink", "sin… in DoCreateVideoSink() local
[all …]
|
| /foundation/multimedia/media_lite/services/recorder_lite/impl/src/ |
| D | recorder_sink.cpp | 274 RecorderSink *sink = reinterpret_cast<RecorderSink *>(privateDataHandle); in SinkOnError() local
275 if (sink == nullptr) { in SinkOnError()
283 sink->messageQueue.push(data); in SinkOnError()
284 sem_post(&sink->sem); in SinkOnError()
291 RecorderSink *sink = reinterpret_cast<RecorderSink *>(privateDataHandle); in SinkOnInfo() local
292 if (sink == nullptr) { in SinkOnInfo()
300 sink->messageQueue.push(data); in SinkOnInfo()
301 sem_post(&sink->sem); in SinkOnInfo()
314 RecorderSink *sink = (RecorderSink *)arg; in MessageThread() local
315 sink->threadRunning = true; in MessageThread()
[all …]
|
| /foundation/distributedhardware/distributed_input/ |
| D | README_zh.md | 12 **被控端(sink)**：分布式输入被控制端设备，接受主控端发送的指令并且完成对应操作，提供本地外设供主控端设备使用。
81 │ └── sink # 分布式输入的sink侧SA实现
83 │ │ ├── sinkmanager # 分布式输入sink侧业务管理，响应主控端相关业务调用
84 │ │ └── transport # 分布式输入sink侧事件发送
90 ├── sinkhandler # 分布式输入实现的分布式硬件管理框架定义的sink侧部件接入接口
|
| /foundation/multimedia/audio_framework/frameworks/native/pulseaudio/modules/ |
| D | BUILD.gn | 19 "capturer:module-inner-capturer-sink",
20 "capturer:module-receiver-sink",
21 "cluster:module-cluster-sink",
22 "effect:module-effect-sink",
23 "hdi:module-hdi-sink",
|
| /foundation/multimedia/audio_framework/frameworks/native/pulseaudio/modules/abstract/ |
| D | module_loopback.c | 253 static void UpdateMinimumLatency(struct userdata *u, pa_sink *sink, bool printMsg) in UpdateMinimumLatency() argument
291 if (sink) { in UpdateMinimumLatency()
292 …pa_asyncmsgq_send(sink->asyncmsgq, PA_MSGOBJECT(u->sink_input), SINK_INPUT_MESSAGE_UPDATE_MIN_LATE… in UpdateMinimumLatency()
362 pa_asyncmsgq_send(u->sink_input->sink->asyncmsgq, PA_MSGOBJECT(u->sink_input), in CalculateAdjustTime()
404 UpdateMinimumLatency(u, u->sink_input->sink, false); in AdjustRates()
429 …AUDIO_DEBUG_LOG("[%s] Updated sampling rate to %lu Hz.", u->sink_input->sink->name, (unsigned long… in AdjustRates()
445 pa_asyncmsgq_send(u->sink_input->sink->asyncmsgq, in TimeCallback()
504 static void UpdateLatencyBoundaries(struct userdata *u, pa_source *source, pa_sink *sink) in UpdateLatencyBoundaries() argument
525 if (sink) { in UpdateLatencyBoundaries()
527 if (sink->flags & PA_SINK_DYNAMIC_LATENCY) { in UpdateLatencyBoundaries()
[all …]
|
| /foundation/multimedia/player_framework/services/engine/gstreamer/avcodec/ |
| D | avcodec_engine_factory.cpp | 59 std::unique_ptr<SinkBase> sink; in CreateSink() local
62 sink = std::make_unique<SinkBytebufferImpl>(); in CreateSink()
65 sink = std::make_unique<SinkSurfaceImpl>(); in CreateSink()
71 return sink; in CreateSink()
|
| /foundation/multimedia/audio_framework/services/audio_service/ |
| D | BUILD.gn | 186 "../../frameworks/native/hdiadapter/sink/bluetooth",
187 "../../frameworks/native/hdiadapter/sink/common",
188 "../../frameworks/native/hdiadapter/sink/file",
189 "../../frameworks/native/hdiadapter/sink/fast",
190 "../../frameworks/native/hdiadapter/sink/remote",
191 "../../frameworks/native/hdiadapter/sink/remote_fast",
192 "../../frameworks/native/hdiadapter/sink/primary",
232 "../../frameworks/native/hdiadapter/sink:fast_audio_renderer_sink",
233 "../../frameworks/native/hdiadapter/sink:remote_audio_renderer_sink",
234 "../../frameworks/native/hdiadapter/sink:remote_fast_audio_renderer_sink",
[all …]
|
| /foundation/multimedia/audio_framework/ |
| D | cfi_blocklist.txt | 2 src:*frameworks/native/hdiadapter/sink/primary/audio_renderer_sink.cpp
5 src:*frameworks/native/hdiadapter/sink/remote/remote_audio_renderer_sink.cpp
9 src:*frameworks/native/hdiadapter/sink/bluetooth/bluetooth_renderer_sink.cpp
10 src:*frameworks/native/hdiadapter/sink/fast/fast_audio_renderer_sink.cpp
11 src:*frameworks/native/hdiadapter/sink/remote_fast/remote_fast_audio_renderer_sink.cpp
|
| /foundation/multimedia/player_framework/services/engine/gstreamer/plugins/sink/memsink/ |
| D | gst_surface_mem_sink.cpp | 64 static GstFlowReturn gst_surface_mem_sink_subclass_do_app_render(GstSurfaceMemSink *sink,
137 static void gst_surface_mem_sink_init(GstSurfaceMemSink *sink) in gst_surface_mem_sink_init() argument
139 g_return_if_fail(sink != nullptr); in gst_surface_mem_sink_init()
140 GST_DEBUG_OBJECT(sink, "Init, id = %d", static_cast<int32_t>(FAKE_POINTER(sink))); in gst_surface_mem_sink_init()
142 …iv = reinterpret_cast<GstSurfaceMemSinkPrivate *>(gst_surface_mem_sink_get_instance_private(sink)); in gst_surface_mem_sink_init()
144 sink->priv = priv; in gst_surface_mem_sink_init()
145 sink->priv->surface = nullptr; in gst_surface_mem_sink_init()
146 sink->priv->pool = GST_PRODUCER_SURFACE_POOL_CAST(gst_producer_surface_pool_new()); in gst_surface_mem_sink_init()
147 sink->priv->rotation = 0; in gst_surface_mem_sink_init()
148 sink->prerollBuffer = nullptr; in gst_surface_mem_sink_init()
[all …]
|
| D | gst_mem_sink.h | 63 gboolean (*do_propose_allocation) (GstMemSink *sink, GstQuery *query);
64 GstFlowReturn (*do_stream_render) (GstMemSink *sink, GstBuffer **buffer);
65 GstFlowReturn (*do_app_render) (GstMemSink *sink, GstBuffer *buffer, bool isPreroll);
|
| /foundation/multimedia/audio_framework/frameworks/native/hdiadapter/sink/remote/ |
| D | remote_audio_renderer_sink.cpp | 231 RemoteAudioRendererSinkInner* sink = reinterpret_cast<RemoteAudioRendererSinkInner*>(cookie); in ParamEventCallback() local
232 std::string networkId = sink->GetNetworkId(); in ParamEventCallback()
245 if ((sink->audioRender_ != nullptr) && (sink->audioAdapter_ != nullptr)) { in ParamEventCallback()
246 sink->audioAdapter_->DestroyRender(sink->audioAdapter_, sink->audioRender_); in ParamEventCallback()
248 sink->audioRender_ = nullptr; in ParamEventCallback()
249 sink->isRenderCreated_.store(false); in ParamEventCallback()
252 IAudioSinkCallback* callback = sink->GetParamCallback(); in ParamEventCallback()
634 static int32_t SetOutputPortPin(DeviceType outputDevice, AudioRouteNode &sink) in SetOutputPortPin() argument
640 sink.ext.device.type = PIN_OUT_SPEAKER; in SetOutputPortPin()
641 sink.ext.device.desc = "pin_out_speaker"; in SetOutputPortPin()
[all …]
|
| /foundation/multimedia/histreamer/engine/plugin/plugins/sink/file_sink/ |
| D | file_fd_sink_plugin.cpp | 59 Status FileFdSinkPlugin::SetSink(const MediaSink& sink) in SetSink() argument
61 …FALSE_RETURN_V((sink.GetProtocolType() == ProtocolType::FD && sink.GetFd() != -1), Status::ERROR_I… in SetSink()
62 fd_ = sink.GetFd(); in SetSink()
|
| /foundation/multimedia/audio_framework/frameworks/native/hdiadapter/sink/primary/ |
| D | audio_renderer_sink.cpp | 670 static int32_t SetOutputPortPin(DeviceType outputDevice, AudioRouteNode &sink) in SetOutputPortPin() argument
676 sink.ext.device.type = PIN_OUT_EARPIECE; in SetOutputPortPin()
677 sink.ext.device.desc = (char *)"pin_out_earpiece"; in SetOutputPortPin()
680 sink.ext.device.type = PIN_OUT_SPEAKER; in SetOutputPortPin()
681 sink.ext.device.desc = (char *)"pin_out_speaker"; in SetOutputPortPin()
684 sink.ext.device.type = PIN_OUT_HEADSET; in SetOutputPortPin()
685 sink.ext.device.desc = (char *)"pin_out_headset"; in SetOutputPortPin()
688 sink.ext.device.type = PIN_OUT_USB_EXT; in SetOutputPortPin()
689 sink.ext.device.desc = (char *)"pin_out_usb_ext"; in SetOutputPortPin()
692 sink.ext.device.type = PIN_OUT_BLUETOOTH_SCO; in SetOutputPortPin()
[all …]
|
| /foundation/multimedia/player_framework/services/engine/gstreamer/plugins/ |
| D | BUILD.gn | 25 "sink/audiosink:gst_audio_server_sink",
26 "sink/memsink:gst_mem_sink",
27 "sink/subtitlesink:gst_subtitle_sink",
|
| /foundation/multimedia/player_framework/services/engine/gstreamer/plugins/bin/codecbin/src/ |
| D | gst_codec_bin.cpp | 170 bin->sink = nullptr; in gst_codec_bin_init()
241 bin->sink = static_cast<GstElement *>(g_value_get_pointer(value)); in gst_codec_bin_set_property()
332 if (bin->sink != nullptr) { in add_dump_probe()
333 OHOS::Media::Dumper::AddDumpGstBufferProbe(bin->sink, "sink"); in add_dump_probe()
340 g_return_val_if_fail(bin->coder != nullptr && bin->sink != nullptr, FALSE); in connect_element()
361 …ret = gst_element_link_pads_full(bin->sink_convert, "src", bin->sink, "sink", GST_PAD_LINK_CHECK_N… in connect_element()
364 …ret = gst_element_link_pads_full(bin->coder, "src", bin->sink, "sink", GST_PAD_LINK_CHECK_NOTHING); in connect_element()
436 … g_return_val_if_fail(bin->src != nullptr && bin->coder != nullptr && bin->sink != nullptr, FALSE); in add_element_to_bin()
450 return gst_bin_add(GST_BIN_CAST(bin), bin->sink); in add_element_to_bin()
456 g_return_val_if_fail(bin->sink != nullptr, FALSE); in operate_element()
[all …]
|
| /foundation/multimedia/histreamer/engine/plugin/core/ |
| D | output_sink.cpp | 24 Status OutputSink::SetSink(const MediaSink &sink) in SetSink() argument
26 return outputSink_->SetSink(sink); in SetSink()
|