Lines Matching defs:channelMsg
313 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
314 if (channelMsg) {
315 if (consumer_ && (consumer_->GetId() == channelMsg->prosumerId)) {
318 } else if (producers_.find(channelMsg->prosumerId) != producers_.end()) {
320 producers_[channelMsg->prosumerId]->HandleEvent(event);
323 SHARING_LOGW("unknow prosumerId: %{public}u.", channelMsg->prosumerId);
366 auto channelMsg = ConvertEventMsg<ChannelAppendSurfaceEventMsg>(event);
367 if (channelMsg == nullptr) {
373 statusMsg->eventMsg = channelMsg;
374 if ((nullptr != channelMsg->surface) && playController_) {
375 if (playController_->AppendSurface(channelMsg->surface, channelMsg->sceneType)) {
390 statusMsg->prosumerId = channelMsg->prosumerId;
391 statusMsg->agentId = channelMsg->agentId;
404 auto channelMsg = ConvertEventMsg<ChannelRemoveSurfaceEventMsg>(event);
405 if (channelMsg == nullptr) {
411 playController_->RemoveSurface(channelMsg->surfaceId);
417 statusMsg->eventMsg = channelMsg;
421 statusMsg->surfaceId = channelMsg->surfaceId;
430 auto channelMsg = ConvertEventMsg<ChannelSetSceneTypeEventMsg>(event);
431 if (channelMsg == nullptr) {
437 if (channelMsg->sceneType == OHOS::Sharing::SceneType::FOREGROUND) {
438 playController_->SetKeyMode(channelMsg->surfaceId, false);
439 } else if (channelMsg->sceneType == OHOS::Sharing::SceneType::BACKGROUND) {
440 playController_->SetKeyMode(channelMsg->surfaceId, true);
451 auto channelMsg = ConvertEventMsg<ChannelSetKeyRedirectEventMsg>(event);
452 if (channelMsg == nullptr) {
458 playController_->SetKeyRedirect(channelMsg->surfaceId, channelMsg->keyRedirect);
469 auto channelMsg = ConvertEventMsg<ChannelSetVolumeEventMsg>(event);
470 if (channelMsg == nullptr) {
475 float volume = channelMsg->volume;
488 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
489 if (channelMsg == nullptr) {
495 statusMsg->eventMsg = channelMsg;
496 statusMsg->prosumerId = consumer_ ? consumer_->GetId() : channelMsg->prosumerId;
497 statusMsg->agentId = channelMsg->agentId;
514 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
515 if (channelMsg == nullptr) {
521 statusMsg->eventMsg = channelMsg;
522 statusMsg->prosumerId = consumer_ ? consumer_->GetId() : channelMsg->prosumerId;
523 statusMsg->agentId = channelMsg->agentId;
540 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
541 if (channelMsg == nullptr) {
546 statusMsg->eventMsg = channelMsg;
548 if (CreateConsumer(channelMsg->className) == ERR_OK) {
553 consumer_->SetSinkAgentId(channelMsg->agentId);
561 statusMsg->agentId = channelMsg->agentId;
570 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
571 if (channelMsg == nullptr) {
577 statusMsg->eventMsg = channelMsg;
583 statusMsg->agentId = channelMsg->agentId;
592 statusMsg->agentId = channelMsg->agentId;
606 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
607 if (channelMsg == nullptr) {
613 statusMsg->eventMsg = channelMsg;
624 statusMsg->agentId = channelMsg->agentId;
633 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
634 if (channelMsg == nullptr) {
640 statusMsg->eventMsg = channelMsg;
657 statusMsg->agentId = channelMsg->agentId;
667 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
668 if (channelMsg == nullptr) {
674 statusMsg->eventMsg = channelMsg;
675 statusMsg->mediaType = channelMsg->mediaType;
690 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
691 if (channelMsg == nullptr) {
697 statusMsg->eventMsg = channelMsg;
698 statusMsg->mediaType = channelMsg->mediaType;
713 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
714 if (channelMsg == nullptr) {
720 statusMsg->eventMsg = channelMsg;
722 uint32_t retId = CreateProducer(channelMsg->className);
725 producers_[retId]->SetSrcAgentId(channelMsg->agentId);
733 statusMsg->agentId = channelMsg->agentId;
742 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
743 if (channelMsg == nullptr) {
749 statusMsg->eventMsg = channelMsg;
751 uint32_t id = channelMsg->prosumerId;
766 statusMsg->agentId = channelMsg->agentId;
775 statusMsg->agentId = channelMsg->agentId;
789 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
790 if (channelMsg == nullptr) {
796 statusMsg->eventMsg = channelMsg;
800 auto iter = producers_.find(channelMsg->prosumerId);
811 channelMsg->prosumerId, GetId(), channelMsg->agentId);
813 statusMsg->prosumerId = channelMsg->prosumerId;
814 statusMsg->agentId = channelMsg->agentId;
826 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
827 if (channelMsg == nullptr) {
833 statusMsg->eventMsg = channelMsg;
836 auto iter = producers_.find(channelMsg->prosumerId);
845 channelMsg->prosumerId, GetId(), channelMsg->agentId);
847 statusMsg->prosumerId = channelMsg->prosumerId;
848 statusMsg->agentId = channelMsg->agentId;
860 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
861 if (channelMsg == nullptr) {
867 statusMsg->eventMsg = channelMsg;
868 statusMsg->mediaType = channelMsg->mediaType;
872 auto iter = producers_.find(channelMsg->prosumerId);
879 channelMsg->prosumerId, GetId(), channelMsg->agentId);
890 auto channelMsg = ConvertEventMsg<ChannelEventMsg>(event);
891 if (channelMsg == nullptr) {
897 statusMsg->eventMsg = channelMsg;
898 statusMsg->mediaType = channelMsg->mediaType;
902 auto iter = producers_.find(channelMsg->prosumerId);
909 channelMsg->prosumerId, GetId(), channelMsg->agentId);