Lines Matching refs:statusMsg
73 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
74 statusMsg->eventMsg = msg;
75 statusMsg->errorCode = ERR_INTAKE_TIMEOUT;
76 statusMsg->agentId = GetSinkAgentId();
77 statusMsg->prosumerId = consumer_ ? consumer_->GetId() : INVALID_ID;
79 SendAgentEvent(statusMsg, EVENT_AGENT_STATE_WRITE_WARNING);
372 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
373 statusMsg->eventMsg = channelMsg;
376 statusMsg->errorCode = ERR_OK;
377 statusMsg->prosumerId = consumer_->GetId();
378 statusMsg->agentId = consumer_->GetSinkAgentId();
379 SendAgentEvent(statusMsg, EVENT_AGENT_STATE_CHANNEL_APPENDSURFACE);
383 statusMsg->errorCode = ERR_INVALID_SURFACE_ID;
387 statusMsg->errorCode = ERR_PLAY_START;
390 statusMsg->prosumerId = channelMsg->prosumerId;
391 statusMsg->agentId = channelMsg->agentId;
392 SendAgentEvent(statusMsg, EVENT_AGENT_STATE_CHANNEL_APPENDSURFACE);
416 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
417 statusMsg->eventMsg = channelMsg;
418 statusMsg->errorCode = ERR_OK;
419 statusMsg->prosumerId = consumer_->GetId();
420 statusMsg->agentId = consumer_->GetSinkAgentId();
421 statusMsg->surfaceId = channelMsg->surfaceId;
422 SendAgentEvent(statusMsg, EVENT_AGENT_STATE_CHANNEL_REMOVESURFACE);
494 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
495 statusMsg->eventMsg = channelMsg;
496 statusMsg->prosumerId = consumer_ ? consumer_->GetId() : channelMsg->prosumerId;
497 statusMsg->agentId = channelMsg->agentId;
501 statusMsg->errorCode = ERR_OK;
504 statusMsg->errorCode = ERR_PLAY_START;
507 SendAgentEvent(statusMsg, EVENT_AGENT_STATE_PLAY_START);
520 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
521 statusMsg->eventMsg = channelMsg;
522 statusMsg->prosumerId = consumer_ ? consumer_->GetId() : channelMsg->prosumerId;
523 statusMsg->agentId = channelMsg->agentId;
527 statusMsg->errorCode = ERR_OK;
530 statusMsg->errorCode = ERR_PLAY_STOP;
533 SendAgentEvent(statusMsg, EVENT_AGENT_STATE_PLAY_STOP);
545 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
546 statusMsg->eventMsg = channelMsg;
552 statusMsg->status = PROSUMER_INIT;
554 consumer_->UpdateOperation(statusMsg);
559 statusMsg->errorCode = ERR_PROSUMER_CREATE;
560 statusMsg->prosumerId = INVALID_ID;
561 statusMsg->agentId = channelMsg->agentId;
562 SendAgentEvent(statusMsg, EVENT_AGENT_PROSUMER_ERROR);
576 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
577 statusMsg->eventMsg = channelMsg;
581 statusMsg->errorCode = ERR_OK;
582 statusMsg->prosumerId = INVALID_ID;
583 statusMsg->agentId = channelMsg->agentId;
584 SendAgentEvent(statusMsg, EVENT_AGENT_STATE_PROSUMER_DESTROY);
590 statusMsg->errorCode = ERR_PROSUMER_DESTROY;
591 statusMsg->prosumerId = consumer_ ? consumer_->GetId() : INVALID_ID;
592 statusMsg->agentId = channelMsg->agentId;
593 SendAgentEvent(statusMsg, EVENT_AGENT_PROSUMER_ERROR);
596 statusMsg->status = PROSUMER_DESTROY;
597 consumer_->UpdateOperation(statusMsg);
612 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
613 statusMsg->eventMsg = channelMsg;
616 statusMsg->status = PROSUMER_START;
617 consumer_->UpdateOperation(statusMsg);
622 statusMsg->errorCode = ERR_PROSUMER_START;
623 statusMsg->prosumerId = INVALID_ID;
624 statusMsg->agentId = channelMsg->agentId;
625 SendAgentEvent(statusMsg, EVENT_AGENT_PROSUMER_ERROR);
639 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
640 statusMsg->eventMsg = channelMsg;
650 statusMsg->status = PROSUMER_STOP;
651 consumer_->UpdateOperation(statusMsg);
655 statusMsg->errorCode = ERR_OK;
656 statusMsg->prosumerId = INVALID_ID;
657 statusMsg->agentId = channelMsg->agentId;
658 SendAgentEvent(statusMsg, EVENT_AGENT_STATE_PROSUMER_STOP);
673 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
674 statusMsg->eventMsg = channelMsg;
675 statusMsg->mediaType = channelMsg->mediaType;
678 statusMsg->status = PROSUMER_PAUSE;
679 consumer_->UpdateOperation(statusMsg);
696 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
697 statusMsg->eventMsg = channelMsg;
698 statusMsg->mediaType = channelMsg->mediaType;
701 statusMsg->status = PROSUMER_RESUME;
702 consumer_->UpdateOperation(statusMsg);
719 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
720 statusMsg->eventMsg = channelMsg;
726 statusMsg->status = PROSUMER_INIT;
727 producers_[retId]->UpdateOperation(statusMsg);
731 statusMsg->errorCode = ERR_PROSUMER_CREATE;
732 statusMsg->prosumerId = INVALID_ID;
733 statusMsg->agentId = channelMsg->agentId;
734 SendAgentEvent(statusMsg, EVENT_AGENT_PROSUMER_ERROR);
748 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
749 statusMsg->eventMsg = channelMsg;
764 statusMsg->errorCode = ERR_OK;
765 statusMsg->prosumerId = id;
766 statusMsg->agentId = channelMsg->agentId;
767 SendAgentEvent(statusMsg, EVENT_AGENT_STATE_PROSUMER_DESTROY);
773 statusMsg->errorCode = ERR_PROSUMER_DESTROY;
774 statusMsg->prosumerId = id;
775 statusMsg->agentId = channelMsg->agentId;
776 SendAgentEvent(statusMsg, EVENT_AGENT_PROSUMER_ERROR);
778 statusMsg->status = PROSUMER_DESTROY;
779 pProducer->UpdateOperation(statusMsg);
795 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
796 statusMsg->eventMsg = channelMsg;
804 statusMsg->status = PROSUMER_START;
805 producer->UpdateOperation(statusMsg);
812 statusMsg->errorCode = ERR_PROSUMER_START;
813 statusMsg->prosumerId = channelMsg->prosumerId;
814 statusMsg->agentId = channelMsg->agentId;
815 SendAgentEvent(statusMsg, EVENT_AGENT_PROSUMER_ERROR);
832 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
833 statusMsg->eventMsg = channelMsg;
839 statusMsg->status = PROSUMER_STOP;
840 iter->second->UpdateOperation(statusMsg);
846 statusMsg->errorCode = ERR_OK;
847 statusMsg->prosumerId = channelMsg->prosumerId;
848 statusMsg->agentId = channelMsg->agentId;
849 SendAgentEvent(statusMsg, EVENT_AGENT_STATE_PROSUMER_STOP);
866 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
867 statusMsg->eventMsg = channelMsg;
868 statusMsg->mediaType = channelMsg->mediaType;
874 statusMsg->status = PROSUMER_PAUSE;
875 iter->second->UpdateOperation(statusMsg);
896 auto statusMsg = std::make_shared<ProsumerStatusMsg>();
897 statusMsg->eventMsg = channelMsg;
898 statusMsg->mediaType = channelMsg->mediaType;
904 statusMsg->status = PROSUMER_RESUME;
905 iter->second->UpdateOperation(statusMsg);