Lines Matching refs:data
66 int32_t BufferReceiver::RequestRead(MediaType type, std::function<void(const MediaData::Ptr &data)> cb)
508 for (auto &data : idleAudioBuffer_) {
509 if (data != nullptr && data->buff != nullptr) {
510 data->buff.reset();
515 for (auto &data : idleVideoBuffer_) {
516 if (data != nullptr && data->buff != nullptr) {
517 data->buff.reset();
543 for (auto &data : circularBuffer_) {
544 if (data->mediaData != nullptr && data->mediaData->buff != nullptr) {
545 data->mediaData->buff.reset();
597 void BufferDispatcher::ReturnIdleBuffer(DataSpec::Ptr &data)
601 if (data == nullptr || data->mediaData == nullptr) {
604 if (data->mediaData->mediaType == MEDIA_TYPE_VIDEO) {
606 idleVideoBuffer_.push_back(data->mediaData);
607 MEDIA_LOGD("data: push_back in idleVideoBuffer_, size: %{public}zu.", idleVideoBuffer_.size());
611 idleAudioBuffer_.push_back(data->mediaData);
612 MEDIA_LOGD("data: push_back in idleAudioBuffer_, size: %{public}zu.", idleAudioBuffer_.size());
616 data.reset();
822 WRITING_TIMTOUT, "waiting for continuous data inputs",
857 std::function<void(const MediaData::Ptr &data)> cb)
890 auto data = circularBuffer_.at(readIndex);
891 if (data == nullptr) {
892 SHARING_LOGE("BufferDispatcher Read data nullptr.");
896 if (IsKeyVideoFrame(data)) {
905 SetReceiverReadFlag(receiverId, data);
907 cb(data->mediaData);
910 MEDIA_LOGD("Current data readed, Recvid:%{public}d, remain %{public}zu data, readIndex: %{public}u, "
917 int32_t BufferDispatcher::InputData(const MediaData::Ptr &data)
919 if (data == nullptr || data->buff == nullptr) {
920 SHARING_LOGE("data nullptr.");
923 MEDIA_LOGD("inputmediatype: %{public}d, keyFrame: %{public}d, pts: %{public}" PRIu64 ".", data->mediaType,
924 data->keyFrame, data->pts);
931 dataSpec->mediaData = data;
945 if (data->keyFrame) {
948 "keyFrame: %{public}s, data size: %{public}d, adataCount:%{public}d.",
950 data->keyFrame ? "true" : "false", data->buff->Size(), audioFrameCnt_);
980 int32_t BufferDispatcher::WriteDataIntoBuffer(const DataSpec::Ptr &data)
983 if (data->mediaData == nullptr || data->mediaData->buff == nullptr) {
984 SHARING_LOGE("null data.");
1005 MEDIA_LOGW("dispatcherId: %{public}u, delete data, mediaType: %{public}d, keyFrame: "
1021 if (IsKeyVideoFrame(data) && !keyOnly_) {
1033 if (IsVideoData(data)) {
1047 MEDIA_LOGW("dispatcherId: %{public}u, delete data, mediaType: %{public}d, "
1060 data->reserveFlag = 0;
1061 MEDIA_LOGD("WriteDataIntoBuffer data type: %{public}d, keyFrame: %{public}s, pts: %{public}" PRIu64
1063 int32_t(data->mediaData->mediaType), data->mediaData->keyFrame ? "true" : "false", data->mediaData->pts,
1065 circularBuffer_.push_back(data);
1066 if (IsAudioData(data)) {
1072 if (!keyOnly_ || (keyOnly_ && IsKeyVideoFrame(data))) {
1073 ActiveDataRef(MEDIA_TYPE_VIDEO, IsKeyVideoFrame(data));
1078 if (audioNeedActivate_ && IsAudioData(data)) {
1083 if (IsKeyVideoFrame(data)) {
1167 "dispatcherId: %{public}u, delete data, mediaType: %{public}d, keyFrame: %{public}s, pts: %{public}" PRIu64
1749 for (auto &data : circularBuffer_) {
1750 data->reserveFlag = 0xff;