Home
last modified time | relevance | path

Searched refs:dataQueue_ (Results 1 - 25 of 32) sorted by relevance

12

/foundation/multimedia/media_foundation/src/filter/
H A Dfilter_loop.cpp109 if (dataQueue_.find(msgProcessTime) != dataQueue_.end()) { in SendAsyncMsg()
110 MEDIA_LOG_W("DUPLICATIVE dataQueue_ TIMESTAMP!!!"); in SendAsyncMsg()
113 dataQueue_[msgProcessTime] = MsgInfo {what, arg, false}; in SendAsyncMsg()
122 for (auto msg = dataQueue_.begin(); msg != dataQueue_.end(); msg++) { in SendAsyncMsg()
142 return threadNeedStop_ || !commandQueue_.empty() || (!dataQueue_.empty() && dataQueueRunning_); in MainLoop()
146 commandQueue_.size(), dataQueue_.size()); in MainLoop()
153 processUs = dataQueue_.begin()->first; in MainLoop()
155 } else if (dataQueue_ in MainLoop()
[all...]
/foundation/communication/netstack/interfaces/innerkits/websocket_client/include/
H A Dclient_context.h83 dataQueue_.push(SendData(data, length, protocol)); in Push()
89 if (dataQueue_.empty()) { in Pop()
93 SendData data = dataQueue_.front(); in Pop()
94 dataQueue_.pop(); in Pop()
139 std::queue<SendData> dataQueue_; member in OHOS::NetStack::WebSocketClient::ClientContext
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_input/dsoftbus_input_audio/
H A Ddsoftbus_input_audio_plugin.cpp118 DataQueueClear(dataQueue_); in Reset()
132 DataQueueClear(dataQueue_); in Start()
150 DataQueueClear(dataQueue_); in Stop()
297 while (dataQueue_.size() >= DATA_QUEUE_MAX_SIZE) { in DataEnqueue()
299 dataQueue_.pop(); in DataEnqueue()
301 dataQueue_.push(buffer); in DataEnqueue()
316 [this]() { return !dataQueue_.empty(); }); in HandleData()
317 if (dataQueue_.empty()) { in HandleData()
320 buffer = dataQueue_.front(); in HandleData()
321 dataQueue_ in HandleData()
[all...]
H A Ddsoftbus_input_audio_plugin.h99 std::queue<std::shared_ptr<Buffer>> dataQueue_; member in OHOS::DistributedHardware::DsoftbusInputAudioPlugin
/foundation/distributedhardware/distributed_audio/services/audioclient/spkclient/src/
H A Ddspeaker_client.cpp124 if (dataQueue_.empty()) { in OnWriteData()
128 audioData = dataQueue_.front(); in OnWriteData()
129 dataQueue_.pop(); in OnWriteData()
130 uint64_t queueSize = static_cast<uint64_t>(dataQueue_.size()); in OnWriteData()
281 [this]() { return !dataQueue_.empty(); }); in PlayThreadRunning()
282 if (dataQueue_.empty()) { in PlayThreadRunning()
285 audioData = dataQueue_.front(); in PlayThreadRunning()
286 dataQueue_.pop(); in PlayThreadRunning()
287 uint64_t queueSize = static_cast<uint64_t>(dataQueue_.size()); in PlayThreadRunning()
320 if (dataQueue_ in FillJitterQueue()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/protocol/rtp/src/
H A Drtp_codec_ts.cpp84 dataQueue_.emplace(rtp); in InputRtp()
175 while (dataQueue_.empty()) { in ReadPacket()
184 auto &rtp = dataQueue_.front(); in ReadPacket()
196 dataQueue_.pop(); in ReadPacket()
228 while (!dataQueue_.empty()) { in Release()
229 dataQueue_.pop(); in Release()
354 dataQueue_.emplace(frame); in SaveFrame()
363 while (dataQueue_.empty()) { in ReadFrame()
372 Frame::Ptr frame = dataQueue_.front(); in ReadFrame()
373 dataQueue_ in ReadFrame()
[all...]
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/output_control/src/
H A Doutput_controller.cpp38 if (dataQueue_.size() > QUEUE_MAX_SIZE) { in PushData()
40 dataQueue_.pop(); in PushData()
48 dataQueue_.push(data); in PushData()
49 AVTRANS_LOGD("Push Data, dataQueue size is %{public}zu.", dataQueue_.size()); in PushData()
94 ClearQueue(dataQueue_); in StopControl()
120 ClearQueue(dataQueue_); in ReleaseControl()
229 return ((!dataQueue_.empty() && GetControlStatus() == ControlStatus::START) in LooperControl()
235 data = dataQueue_.front(); in LooperControl()
279 ClearQueue(dataQueue_); in CheckSyncInfo()
288 ClearQueue(dataQueue_); in CheckSyncInfo()
[all...]
/foundation/distributedhardware/distributed_audio/services/audiomanager/managersource/src/
H A Ddmic_dev.cpp357 uint32_t queSize = dataQueue_.size(); in ReadStreamData()
366 dataQueue_.pop(); in ReadStreamData()
369 data = dataQueue_.front(); in ReadStreamData()
370 dataQueue_.pop(); in ReadStreamData()
447 if (dataQueue_.empty()) { in EnqueueThread()
451 audioData = dataQueue_.front(); in EnqueueThread()
452 dataQueue_.pop(); in EnqueueThread()
483 if (dataQueue_.size() >= (LOW_LATENCY_JITTER_TIME_MS / paramHDF_.period)) { in FillJitterQueue()
565 while (dataQueue_.size() > dataQueSize_) { in OnDecodeTransDataDone()
566 queueSize = static_cast<uint64_t>(dataQueue_ in OnDecodeTransDataDone()
[all...]
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/dsoftbus_output_audio/
H A Ddsoftbus_output_audio_plugin.cpp116 DataQueueClear(dataQueue_); in Reset()
136 DataQueueClear(dataQueue_); in Start()
155 DataQueueClear(dataQueue_); in Stop()
254 while (dataQueue_.size() >= DATA_QUEUE_MAX_SIZE) { in PushData()
256 dataQueue_.pop(); in PushData()
265 dataQueue_.push(tempBuffer); in PushData()
277 [this]() { return !dataQueue_.empty(); }); in FeedChannelData()
281 if (dataQueue_.empty()) { in FeedChannelData()
284 buffer = dataQueue_.front(); in FeedChannelData()
285 dataQueue_ in FeedChannelData()
[all...]
H A Ddsoftbus_output_audio_plugin.h98 std::queue<std::shared_ptr<Buffer>> dataQueue_; member in OHOS::DistributedHardware::DsoftbusOutputAudioPlugin
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/dsoftbus_output/
H A Ddsoftbus_output_plugin.cpp114 DataQueueClear(dataQueue_); in Reset()
133 DataQueueClear(dataQueue_); in Start()
152 DataQueueClear(dataQueue_); in Stop()
272 while (dataQueue_.size() >= DATA_QUEUE_MAX_SIZE) { in PushData()
274 dataQueue_.pop(); in PushData()
276 dataQueue_.push(buffer); in PushData()
288 [this]() { return !dataQueue_.empty(); }); in FeedChannelData()
292 if (dataQueue_.empty()) { in FeedChannelData()
295 buffer = dataQueue_.front(); in FeedChannelData()
296 dataQueue_ in FeedChannelData()
[all...]
H A Ddsoftbus_output_plugin.h104 std::queue<std::shared_ptr<Buffer>> dataQueue_; member in OHOS::DistributedHardware::DsoftbusOutputPlugin
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_input/dsoftbus_input/
H A Ddsoftbus_input_plugin.cpp128 DataQueueClear(dataQueue_); in Reset()
142 DataQueueClear(dataQueue_); in Start()
163 DataQueueClear(dataQueue_); in Stop()
340 while (dataQueue_.size() >= DATA_QUEUE_MAX_SIZE) { in DataEnqueue()
342 dataQueue_.pop(); in DataEnqueue()
344 dataQueue_.push(buffer); in DataEnqueue()
359 [this]() { return !dataQueue_.empty(); }); in HandleData()
360 if (dataQueue_.empty()) { in HandleData()
363 buffer = dataQueue_.front(); in HandleData()
364 dataQueue_ in HandleData()
[all...]
H A Ddsoftbus_input_plugin.h106 std::queue<std::shared_ptr<Buffer>> dataQueue_; member in OHOS::DistributedHardware::DsoftbusInputPlugin
/foundation/distributedhardware/distributed_screen/services/screentransport/screensourcetrans/src/
H A Dscreen_source_trans.cpp96 while (!dataQueue_.empty()) { in Release()
97 dataQueue_.pop(); in Release()
390 while (dataQueue_.size() >= DATA_QUEUE_MAX_SIZE) { in OnImageProcessDone()
392 dataQueue_.pop(); in OnImageProcessDone()
394 dataQueue_.push(data); in OnImageProcessDone()
420 lock, std::chrono::seconds(DATA_WAIT_SECONDS), [this]() { return !dataQueue_.empty(); }); in FeedChannelData()
426 if (dataQueue_.empty()) { in FeedChannelData()
430 screenData = dataQueue_.front(); in FeedChannelData()
431 dataQueue_.pop(); in FeedChannelData()
/foundation/CastEngine/castengine_wifi_display/services/protocol/rtp/include/
H A Drtp_codec_ts.h57 std::queue<RtpPacket::Ptr> dataQueue_; member in OHOS::Sharing::RtpDecoderTs
94 std::queue<Frame::Ptr> dataQueue_; member in OHOS::Sharing::RtpEncoderTs
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcameradata/feedingsmoother/base/
H A Difeeding_smoother.cpp44 dataQueue_.push(data); in PushData()
76 return (!dataQueue_.empty() || this->state_ == SMOOTH_STOP); in LooperSmooth()
81 data = dataQueue_.front(); in LooperSmooth()
91 dataQueue_.pop(); in LooperSmooth()
245 std::queue<std::shared_ptr<IFeedableData>>().swap(dataQueue_); in StopSmooth()
/foundation/distributedhardware/distributed_screen/services/screentransport/test/unittest/screensourcetrans/src/
H A Dscreen_source_trans_test.cpp558 uint32_t queueSize = trans->dataQueue_.size(); in HWTEST_F()
561 EXPECT_NE(queueSize, trans->dataQueue_.size()); in HWTEST_F()
573 uint32_t queueSize = trans->dataQueue_.size(); in HWTEST_F()
575 trans->dataQueue_.push(data); in HWTEST_F()
579 EXPECT_NE(queueSize, trans->dataQueue_.size()); in HWTEST_F()
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/test/av_trans_output/output_control_test/
H A Doutput_controller_test.cpp48 controller->dataQueue_.push(data); in HWTEST_F()
177 controller->dataQueue_.push(data); in HWTEST_F()
254 controller->dataQueue_.push(data); in HWTEST_F()
/foundation/communication/netstack/utils/napi_utils/src/
H A Devent_manager.cpp132 dataQueue_.push(data); in SetQueueData()
138 if (!dataQueue_.empty()) { in GetQueueData()
139 auto data = dataQueue_.front(); in GetQueueData()
140 dataQueue_.pop(); in GetQueueData()
/foundation/communication/netstack/utils/napi_utils/include/
H A Devent_manager.h126 std::queue<void *> dataQueue_; member in OHOS::NetStack::EventManager
165 [[maybe_unused]] std::queue<void *> dataQueue_; member in OHOS::NetStack::EventManagerForHttp
/foundation/multimedia/media_foundation/interface/inner_api/filter/
H A Dfilter_loop.h83 std::map<TimeUs, MsgInfo> dataQueue_; // msg will be sorted by timeUs member in OHOS::Media::Pipeline::FilterLoop
/foundation/distributedhardware/distributed_audio/services/audiomanager/test/unittest/sourcedevice/src/
H A Ddmic_dev_test.cpp183 mic_->dataQueue_.push(audioData); in HWTEST_F()
324 mic_->dataQueue_.push(writeData); in HWTEST_F()
328 mic_->dataQueue_.push(data); in HWTEST_F()
/foundation/distributedhardware/distributed_audio/services/audioclient/spkclient/include/
H A Ddspeaker_client.h106 std::queue<std::shared_ptr<AudioData>> dataQueue_; member in OHOS::DistributedHardware::DSpeakerClient
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/include/distributedcameramgr/dcameradata/feedingsmoother/base/
H A Difeeding_smoother.h73 std::queue<std::shared_ptr<IFeedableData>> dataQueue_; member in OHOS::DistributedHardware::IFeedingSmoother

Completed in 22 milliseconds

12