Lines Matching refs:receiver
248 SHARING_LOGE("target receiver NOT exist.");
282 auto receiver = receiver_.lock();
283 if (receiver == nullptr) {
284 SHARING_LOGE("target receiver NOT exist.");
288 return receiver->GetReceiverId();
297 void DataNotifier::SetNotifyReceiver(BufferReceiver::Ptr receiver)
300 receiver_ = receiver;
345 auto receiver = receiver_.lock();
346 if (receiver == nullptr) {
347 SHARING_LOGE("target receiver NOT exist.");
351 return receiver->IsMixedReceiver();
386 auto receiver = receiver_.lock();
387 if (receiver) {
388 return receiver->IsKeyMode();
397 auto receiver = receiver_.lock();
398 if (receiver) {
399 return receiver->IsKeyRedirect();
408 auto receiver = receiver_.lock();
409 if (receiver == nullptr) {
410 SHARING_LOGE("target receiver NOT exist.");
414 return receiver->NeedAcceleration();
420 auto receiver = receiver_.lock();
421 if (receiver == nullptr) {
422 SHARING_LOGE("target receiver NOT exist.");
426 receiver->SendAccelerationDone();
427 receiver->DisableAcceleration();
652 int32_t BufferDispatcher::AttachReceiver(BufferReceiver::Ptr receiver)
655 if (receiver == nullptr) {
659 if (IsRecevierExist(receiver->GetReceiverId())) {
664 receiver->NotifyReadStart();
673 notifier->SetNotifyReceiver(receiver);
685 receiver->GetReceiverId(), notifier->GetReadIndex(), usableRef, readRefFlag_);
686 receiver->SetSource(shared_from_this());
687 notifiers_.emplace(receiver->GetReceiverId(), notifier);
692 SetReceiverDataRef(receiver->GetReceiverId(), MEDIA_TYPE_AUDIO, false);
693 SetReceiverDataRef(receiver->GetReceiverId(), MEDIA_TYPE_VIDEO, false);
694 SHARING_LOGD("BufferDispatcher Attach when buffer empty RecvId: %{public}d.", receiver->GetReceiverId());
702 SetReceiverDataRef(receiver->GetReceiverId(), MEDIA_TYPE_AUDIO, true);
704 SetReceiverDataRef(receiver->GetReceiverId(), MEDIA_TYPE_VIDEO, false);
706 receiver->GetReceiverId());
710 receiver->GetReceiverId(), keyIndexList_.back());
715 SetReceiverDataRef(receiver->GetReceiverId(), MEDIA_TYPE_AUDIO, isAudioReady);
716 SetReceiverDataRef(receiver->GetReceiverId(), MEDIA_TYPE_VIDEO, true);
722 receiver->GetReceiverId());
726 SetReceiverDataRef(receiver->GetReceiverId(), MEDIA_TYPE_AUDIO, true);
727 SetReceiverDataRef(receiver->GetReceiverId(), MEDIA_TYPE_VIDEO, false);
737 int32_t BufferDispatcher::DetachReceiver(BufferReceiver::Ptr receiver)
739 SHARING_LOGI("buffer dispatcher: Detach receiver in.");
740 if (receiver == nullptr) {
741 SHARING_LOGE("buffer dispatcher: Detach receiver failed - null receiver.");
745 if (!IsRecevierExist(receiver->GetReceiverId())) {
750 auto notifier = GetNotifierByReceiverPtr(receiver);
752 SHARING_LOGE("buffer dispatcher: Detach receiver failed - no find receiver in notifiers.");
758 SetReceiverReadRef(receiver->GetReceiverId(), MEDIA_TYPE_AUDIO, false);
759 SetReceiverReadRef(receiver->GetReceiverId(), MEDIA_TYPE_VIDEO, false);
762 notifiers_.erase(receiver->GetReceiverId());
771 SHARING_LOGE("buffer dispatcher: Detach receiver failed - null notifier.");
795 auto receiver = notifier->GetBufferReceiver();
796 if (receiver == nullptr) {
801 auto receiverId = receiver->GetReceiverId();
808 SHARING_LOGE("buffer dispatcher: Detach receiver failed - no find receiver in notifiers.");
813 SHARING_LOGD("release all receiver out.");
838 DataNotifier::Ptr BufferDispatcher::GetNotifierByReceiverPtr(BufferReceiver::Ptr receiver)
842 return GetNotifierByReceiverId(receiver->GetReceiverId());
1804 auto receiver = notifier->GetBufferReceiver();
1805 if (receiver != nullptr) {
1806 receiver->EnableKeyRedirect(false);