| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/websocket_client/include/ |
| H A D | client_context.h | 83 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_; variable
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_input/dsoftbus_input_audio/ |
| H A D | dsoftbus_input_audio_plugin.cpp | 118 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_.pop(); in HandleData()
|
| H A D | dsoftbus_input_audio_plugin.h | 99 std::queue<std::shared_ptr<Buffer>> dataQueue_; variable
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/output_control/src/ |
| H A D | output_controller.cpp | 40 dataQueue_.pop(); in PushData()
48 dataQueue_.push(data); in PushData()
94 ClearQueue(dataQueue_); in StopControl()
120 ClearQueue(dataQueue_); in ReleaseControl()
235 data = dataQueue_.front(); in LooperControl()
279 ClearQueue(dataQueue_); in CheckSyncInfo()
288 ClearQueue(dataQueue_); in CheckSyncInfo()
420 ClearQueue(dataQueue_); in CheckIsProcessInDynamicBalance()
558 if (!dataQueue_.empty() && data == dataQueue_.front()) { in HandleControlResult()
567 if (!dataQueue_.empty() && data == dataQueue_.front()) { in HandleControlResult()
[all …]
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_input/dsoftbus_input/ |
| H A D | dsoftbus_input_plugin.cpp | 128 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_.pop(); in HandleData()
|
| H A D | dsoftbus_input_plugin.h | 106 std::queue<std::shared_ptr<Buffer>> dataQueue_; variable
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/dsoftbus_output/ |
| H A D | dsoftbus_output_plugin.cpp | 114 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_.pop(); in FeedChannelData()
|
| H A D | dsoftbus_output_plugin.h | 104 std::queue<std::shared_ptr<Buffer>> dataQueue_; variable
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/plugins/av_trans_output/dsoftbus_output_audio/ |
| H A D | dsoftbus_output_audio_plugin.cpp | 116 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_.pop(); in FeedChannelData()
|
| H A D | dsoftbus_output_audio_plugin.h | 98 std::queue<std::shared_ptr<Buffer>> dataQueue_; variable
|
| /ohos5.0/foundation/distributedhardware/distributed_audio/services/audiomanager/managersource/src/ |
| H A D | dmic_dev.cpp | 357 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()
565 while (dataQueue_.size() > dataQueSize_) { in OnDecodeTransDataDone()
568 dataQueue_.pop(); in OnDecodeTransDataDone()
570 dataQueue_.push(audioData); in OnDecodeTransDataDone()
[all …]
|
| /ohos5.0/foundation/distributedhardware/distributed_audio/services/audioclient/spkclient/src/ |
| H A D | dspeaker_client.cpp | 124 if (dataQueue_.empty()) { in OnWriteData()
128 audioData = dataQueue_.front(); in OnWriteData()
129 dataQueue_.pop(); in OnWriteData()
282 if (dataQueue_.empty()) { in PlayThreadRunning()
285 audioData = dataQueue_.front(); in PlayThreadRunning()
286 dataQueue_.pop(); in PlayThreadRunning()
320 if (dataQueue_.size() >= DATA_QUEUE_SIZE) { in FillJitterQueue()
333 if (dataQueue_.empty()) { in FlushJitterQueue()
348 while (dataQueue_.size() > DATA_QUEUE_MAX_SIZE) { in OnDecodeTransDataDone()
350 dataQueue_.pop(); in OnDecodeTransDataDone()
[all …]
|
| /ohos5.0/foundation/distributedhardware/distributed_screen/services/screentransport/screensourcetrans/src/ |
| H A D | screen_source_trans.cpp | 95 while (!dataQueue_.empty()) { in Release()
96 dataQueue_.pop(); in Release()
389 while (dataQueue_.size() >= DATA_QUEUE_MAX_SIZE) { in OnImageProcessDone()
391 dataQueue_.pop(); in OnImageProcessDone()
393 dataQueue_.push(data); in OnImageProcessDone()
419 … lock, std::chrono::seconds(DATA_WAIT_SECONDS), [this]() { return !dataQueue_.empty(); }); in FeedChannelData()
425 if (dataQueue_.empty()) { in FeedChannelData()
429 screenData = dataQueue_.front(); in FeedChannelData()
430 dataQueue_.pop(); in FeedChannelData()
|
| /ohos5.0/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcameradata/feedingsmoother/base/ |
| H A D | ifeeding_smoother.cpp | 44 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()
|
| /ohos5.0/foundation/distributedhardware/distributed_screen/services/screentransport/test/unittest/screensourcetrans/src/ |
| H A D | screen_source_trans_test.cpp | 558 uint32_t queueSize = trans->dataQueue_.size();
561 EXPECT_NE(queueSize, trans->dataQueue_.size());
573 uint32_t queueSize = trans->dataQueue_.size();
575 trans->dataQueue_.push(data);
579 EXPECT_NE(queueSize, trans->dataQueue_.size());
|
| /ohos5.0/foundation/communication/netstack/utils/napi_utils/src/ |
| H A D | event_manager.cpp | 140 dataQueue_.push(data); in SetQueueData()
146 if (!dataQueue_.empty()) { in GetQueueData()
147 auto data = dataQueue_.front(); in GetQueueData()
148 dataQueue_.pop(); in GetQueueData()
|
| /ohos5.0/base/sensors/medical_sensor/services/medical_sensor/src/ |
| H A D | client_info.cpp | 682 auto it = dataQueue_.find(sensorId); in UpdateDataQueue()
683 if (it == dataQueue_.end()) { in UpdateDataQueue()
686 dataQueue_.insert(std::make_pair(sensorId, q)); in UpdateDataQueue()
697 return dataQueue_; in GetDataQueue()
703 auto it = dataQueue_.find(sensorId); in ClearDataQueue()
704 if (it != dataQueue_.end()) { in ClearDataQueue()
705 dataQueue_.erase(it); in ClearDataQueue()
|
| /ohos5.0/foundation/communication/netstack/utils/napi_utils/include/ |
| H A D | event_manager.h | 119 std::queue<void *> dataQueue_; variable
157 [[maybe_unused]] std::queue<void *> dataQueue_;
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/plugin/test/av_trans_output/output_control_test/ |
| H A D | output_controller_test.cpp | 48 controller->dataQueue_.push(data);
177 controller->dataQueue_.push(data);
254 controller->dataQueue_.push(data);
|
| /ohos5.0/foundation/distributedhardware/distributed_audio/services/audiomanager/test/unittest/sourcedevice/src/ |
| H A D | dmic_dev_test.cpp | 183 mic_->dataQueue_.push(audioData);
324 mic_->dataQueue_.push(writeData);
328 mic_->dataQueue_.push(data);
|
| /ohos5.0/foundation/distributedhardware/distributed_audio/services/audioclient/test/unittest/spkclient/src/ |
| H A D | dspeaker_client_test.cpp | 167 speakerClient_->dataQueue_.push(data);
196 speakerClient_->dataQueue_.push(data);
|
| /ohos5.0/foundation/communication/netstack/frameworks/js/napi/websocket/websocket_exec/src/ |
| H A D | websocket_exec.cpp | 153 dataQueue_.emplace(data, length, protocol); in Push()
159 if (dataQueue_.empty()) { in Pop()
162 SendData data = dataQueue_.front(); in Pop()
163 dataQueue_.pop(); in Pop()
180 if (dataQueue_.empty()) { in IsEmpty()
226 std::queue<SendData> dataQueue_; member in OHOS::NetStack::Websocket::UserData
|
| /ohos5.0/foundation/distributedhardware/distributed_screen/services/screentransport/screensourcetrans/include/ |
| H A D | screen_source_trans.h | 77 std::queue<std::shared_ptr<DataBuffer>> dataQueue_; variable
|
| /ohos5.0/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/include/distributedcameramgr/dcameradata/feedingsmoother/base/ |
| H A D | ifeeding_smoother.h | 73 std::queue<std::shared_ptr<IFeedableData>> dataQueue_;
|
| /ohos5.0/foundation/distributedhardware/distributed_audio/services/audioclient/spkclient/include/ |
| H A D | dspeaker_client.h | 106 std::queue<std::shared_ptr<AudioData>> dataQueue_; variable
|