Lines Matching refs:BufferDispatcher
86 MEDIA_LOGD("BufferDispatcher NotifyThreadWorker before wait, receiverId: %{public}u.", GetReceiverId());
112 MEDIA_LOGD("BufferDispatcher NotifyThreadWorker after wait start read, receiverId: %{public}u.", GetReceiverId());
242 using DataNotifier = BufferDispatcher::DataNotifier;
430 BufferDispatcher::BufferDispatcher(uint32_t maxCapacity, uint32_t capacityIncrement)
432 SHARING_LOGD("BufferDispatcher ctor, set capacity: %{public}u.", maxCapacity);
456 BufferDispatcher::~BufferDispatcher()
458 SHARING_LOGI("BufferDispatcher dtor.");
466 void BufferDispatcher::StartDispatch()
470 notifyThread_ = std::thread(&BufferDispatcher::NotifyThreadWorker, this);
475 void BufferDispatcher::StopDispatch()
491 void BufferDispatcher::SetBufferCapacity(size_t capacity)
498 void BufferDispatcher::SetDataMode(MediaDispacherMode dataMode)
504 void BufferDispatcher::ReleaseIdleBuffer()
506 SHARING_LOGD("BufferDispatcher idle Release Start.");
522 SHARING_LOGD("BufferDispatcher idle Release End.");
525 void BufferDispatcher::FlushBuffer()
527 SHARING_LOGI("BufferDispatcher Start flushing, dispatcherId: %{public}u.", GetDispatcherId());
555 SHARING_LOGD("BufferDispatcher Dispatcher flushing end, dispatcherId: %{public}u.", GetDispatcherId());
558 MediaData::Ptr BufferDispatcher::RequestDataBuffer(MediaType type, uint32_t size)
597 void BufferDispatcher::ReturnIdleBuffer(DataSpec::Ptr &data)
619 size_t BufferDispatcher::GetBufferSize()
625 uint32_t BufferDispatcher::FindReceiverIndex(uint32_t receiverId)
635 bool BufferDispatcher::IsRecevierExist(uint32_t receiverId)
646 void BufferDispatcher::EnableKeyMode(bool enable)
652 int32_t BufferDispatcher::AttachReceiver(BufferReceiver::Ptr receiver)
694 SHARING_LOGD("BufferDispatcher Attach when buffer empty RecvId: %{public}d.", receiver->GetReceiverId());
705 SHARING_LOGD("BufferDispatcher Attach when Keyindex List empty RecvId: %{public}d.",
709 SHARING_LOGD("BufferDispatcher Attach with Keyindex RecvId: %{public}d KeyIndex:%{public}d.",
721 SHARING_LOGD("BufferDispatcher Attach with Non Keyindex Exist RecvId: %{public}d.",
737 int32_t BufferDispatcher::DetachReceiver(BufferReceiver::Ptr receiver)
746 SHARING_LOGE("BufferDispatcher AttachReceiver No Vaild Recevier Exist.");
767 int32_t BufferDispatcher::DetachReceiver(uint32_t receiverId, DataNotifier::Ptr notifier)
784 void BufferDispatcher::ReleaseAllReceiver()
816 void BufferDispatcher::SetBufferDispatcherListener(BufferDispatcherListener::Ptr listener)
838 DataNotifier::Ptr BufferDispatcher::GetNotifierByReceiverPtr(BufferReceiver::Ptr receiver)
845 DataNotifier::Ptr BufferDispatcher::GetNotifierByReceiverId(uint32_t receiverId)
856 int32_t BufferDispatcher::ReadBufferData(uint32_t receiverId, MediaType type,
892 SHARING_LOGE("BufferDispatcher Read data nullptr.");
917 int32_t BufferDispatcher::InputData(const MediaData::Ptr &data)
956 void BufferDispatcher::PreProcessDataSpec(const DataSpec::Ptr &dataSpec)
962 SHARING_LOGD("BufferDispatcher Waiting First Key Video Frame.");
965 SHARING_LOGD("BufferDispatcher received first key video frame and restore from uncontinuous...Flushing.");
980 int32_t BufferDispatcher::WriteDataIntoBuffer(const DataSpec::Ptr &data)
989 SHARING_LOGD("BufferDispatcher buffer Extended to %{public}d CRTL_SIZE.", doubleBufferCapacity_);
1017 SHARING_LOGD("BufferDispatcher buffer Extended to %{public}d NORMALSIZE.", baseBufferCapacity_);
1079 MEDIA_LOGD("BufferDispatcher ActivateReceiverIndex By AudioData.");
1090 MEDIA_LOGD("BufferDispatcher ActivateReceiverIndex By KeyVideo Frame index: %{public}d.", keyIndex);
1104 void BufferDispatcher::EraseOldGopDatas()
1106 MEDIA_LOGD("BufferDispatcher Delete old datas In.");
1140 void BufferDispatcher::DeleteHeadDatas(uint32_t size, bool forceDelete)
1157 MEDIA_LOGD("BufferDispatcher pop out headtype %{public}d.", retBuff->mediaData->mediaType);
1183 void BufferDispatcher::UpdateIndex()
1189 MEDIA_LOGD("BufferDispatcher pop out first 0 keyIndex after listsize %{public}zu.", keyIndexList_.size());
1216 uint32_t BufferDispatcher::FindNextDeleteVideoIndex()
1228 uint32_t BufferDispatcher::FindLastIndex(MediaType type)
1238 void BufferDispatcher::UpdateReceiverReadIndex(uint32_t receiverId, const uint32_t readIndex, MediaType type)
1255 SHARING_LOGD("BufferDispatcher SendAccelerationDone.");
1274 uint32_t BufferDispatcher::FindNextIndex(uint32_t index, MediaType type)
1298 uint32_t BufferDispatcher::FindNextIndex(uint32_t index, MediaType type, uint32_t receiverId)
1336 void BufferDispatcher::ResetAllIndex()
1352 bool BufferDispatcher::IsDataReaded(uint32_t receiverId, DataSpec::Ptr &dataSpec)
1363 bool BufferDispatcher::IsVideoData(const DataSpec::Ptr &dataSpec)
1367 SHARING_LOGE("BufferDispatcher EMPTY dataSpec OR mediadata.");
1374 bool BufferDispatcher::IsAudioData(const DataSpec::Ptr &dataSpec)
1378 SHARING_LOGE("BufferDispatcher EMPTY dataSpec OR mediadata.");
1385 bool BufferDispatcher::IsKeyVideoFrame(const DataSpec::Ptr &dataSpec)
1389 SHARING_LOGE("BufferDispatcher EMPTY dataSpec OR mediadata.");
1396 bool BufferDispatcher::HeadFrameNeedReserve()
1409 bool BufferDispatcher::NeedExtendToDBCapacity()
1417 bool BufferDispatcher::NeedRestoreToNormalCapacity()
1424 void BufferDispatcher::ReCalculateCapacity(bool keyFrame)
1429 SHARING_LOGE("BufferDispatcher too many Audiodata need Set Capacity to default.");
1437 SHARING_LOGD("BufferDispatcher buffer Extended to %{public}d in adaptive capacity calculating.", tmpSize);
1457 "The gop is %{public}d and BufferDispatcher buffer Extended to %{public}d on base capacity confirmed.",
1462 int32_t BufferDispatcher::NotifyThreadWorker(void *userParam)
1464 SHARING_LOGI("BufferDispatcher DataNotifier thread in.");
1466 BufferDispatcher *dispatcher = (BufferDispatcher *)userParam;
1497 void BufferDispatcher::NotifyReadReady(uint32_t receiverId, MediaType type)
1533 void BufferDispatcher::SetDataRef(uint32_t bitref)
1539 uint32_t BufferDispatcher::GetDataRef()
1545 void BufferDispatcher::SetReadRef(uint32_t bitref)
1551 uint32_t BufferDispatcher::GetReadRef()
1557 void BufferDispatcher::ActiveDataRef(MediaType type, bool keyFrame)
1583 void BufferDispatcher::SetReceiverDataRef(uint32_t receiverId, MediaType type, bool ready)
1614 void BufferDispatcher::SetReceiverReadRef(uint32_t receiverId, MediaType type, bool ready)
1647 uint32_t BufferDispatcher::GetReceiverDataRef(uint32_t receiverId)
1653 uint32_t BufferDispatcher::GetReceiverReadRef(uint32_t receiverId)
1661 uint32_t BufferDispatcher::GetReceiverIndexRef(uint32_t receiverId)
1673 void BufferDispatcher::ClearReadBit(uint32_t receiverId, MediaType type)
1685 void BufferDispatcher::ClearDataBit(uint32_t receiverId, MediaType type)
1697 bool BufferDispatcher::IsRead(uint32_t receiverId, uint32_t index)
1707 void BufferDispatcher::ActivateReceiverIndex(uint32_t index, MediaType type)
1727 void BufferDispatcher::UnlockWaitingReceiverIndex(MediaType type)
1732 void BufferDispatcher::SetReceiverReadFlag(uint32_t receiverId, DataSpec::Ptr &dataSpec)
1746 void BufferDispatcher::CancelReserve()
1754 void BufferDispatcher::SetSpsNalu(MediaData::Ptr spsbuf)
1760 const MediaData::Ptr BufferDispatcher::GetSPS()
1766 void BufferDispatcher::SetPpsNalu(MediaData::Ptr ppsbuf)
1772 const MediaData::Ptr BufferDispatcher::GetPPS()
1778 uint32_t BufferDispatcher::GetCurrentGop()
1784 void BufferDispatcher::OnKeyRedirect()
1813 void BufferDispatcher::EnableRapidMode(bool enable)