/foundation/multimedia/media_foundation/engine/scene/recorder/internal/ |
H A D | state_machine.cpp | 28 curState_(std::make_shared<InitState>(StateId::INIT, executor)), in StateMachine() 32 AddState(std::make_shared<ErrorState>(StateId::ERROR, executor)); in StateMachine() 33 AddState(std::make_shared<RecordingSettingState>(StateId::RECORDING_SETTING, executor)); in StateMachine() 34 AddState(std::make_shared<ReadyState>(StateId::READY, executor)); in StateMachine() 35 AddState(std::make_shared<RecordingState>(StateId::RECORDING, executor)); in StateMachine() 36 AddState(std::make_shared<PauseState>(StateId::PAUSE, executor)); in StateMachine() 59 StateId StateMachine::GetCurrentStateId() const in GetCurrentStateId() 168 nextState = states_[StateId::INIT]; in ProcAction() 171 nextState = states_[StateId::RECORDING_SETTING]; in ProcAction() 174 nextState = states_[StateId in ProcAction() [all...] |
H A D | state_machine.h | 44 virtual void OnStateChanged(StateId state) = 0; 59 StateId GetCurrentStateId() const; 88 std::map<StateId, std::shared_ptr<State>> states_ {};
|
H A D | state.h | 33 enum class StateId { class 74 State(StateId stateId, std::string name, RecorderExecutor& executor); 80 StateId GetStateId(); 101 const StateId stateId_;
|
H A D | error_state.h | 30 explicit ErrorState(StateId stateId, RecorderExecutor& executor) : State(stateId, "ErrorState", executor) in ErrorState()
|
H A D | ready_state.h | 29 explicit ReadyState(StateId stateId, RecorderExecutor& executor) : State(stateId, "ReadyState", executor) in ReadyState()
|
/foundation/multimedia/media_foundation/engine/scene/player/internal/ |
H A D | state.cpp | 24 const char* State::GetStateName(StateId state) in GetStateName() 26 static const std::map<StateId, const char*> stateDesc = { in GetStateName() 27 {StateId::IDLE, "IDLE"}, in GetStateName() 28 {StateId::INIT, "INIT"}, in GetStateName() 29 {StateId::PREPARING, "PREPARING"}, in GetStateName() 30 {StateId::READY, "READY"}, in GetStateName() 31 {StateId::PAUSE, "PAUSE"}, in GetStateName() 32 {StateId::PLAYING, "PLAYING"}, in GetStateName() 33 {StateId::STOPPED, "STOPPED"}, in GetStateName() 34 {StateId in GetStateName() [all...] |
H A D | state_machine.cpp | 35 curState_(std::make_shared<IdleState>(StateId::IDLE, executor)), in StateMachine() 39 AddState(std::make_shared<InitState>(StateId::INIT, executor)); in StateMachine() 40 AddState(std::make_shared<PreparingState>(StateId::PREPARING, executor)); in StateMachine() 41 AddState(std::make_shared<ReadyState>(StateId::READY, executor)); in StateMachine() 42 AddState(std::make_shared<PlayingState>(StateId::PLAYING, executor)); in StateMachine() 43 AddState(std::make_shared<PauseState>(StateId::PAUSE, executor)); in StateMachine() 44 AddState(std::make_shared<StoppedState>(StateId::STOPPED, executor)); in StateMachine() 45 AddState(std::make_shared<EosState>(StateId::EOS, executor)); in StateMachine() 68 StateId StateMachine::GetCurrentStateId() const in GetCurrentStateId() 181 nextState = states_[StateId in ProcAction() [all...] |
H A D | state.h | 30 enum class StateId { class 73 State(StateId stateId, std::string name, PlayExecutor& executor); 79 StateId GetStateId(); 93 static const char* GetStateName(StateId state); 100 const StateId stateId_;
|
H A D | state_machine.h | 38 virtual void OnStateChanged(StateId state) = 0; 53 StateId GetCurrentStateId() const; 84 std::map<StateId, std::shared_ptr<State>> states_ {};
|
H A D | stopped_state.h | 23 explicit StoppedState(StateId stateId, PlayExecutor& executor) : State(stateId, "StoppedState", executor) {} in StoppedState()
|
H A D | idle_state.h | 24 explicit IdleState(StateId stateId, PlayExecutor& executor) : State(stateId, "IdleState", executor) {} in IdleState()
|
/foundation/multimedia/media_foundation/engine/scene/player/standard/ |
H A D | media_utils.cpp | 60 PlayerStates TransStateId2PlayerState(StateId state) in TransStateId2PlayerState() 64 case StateId::IDLE: in TransStateId2PlayerState() 67 case StateId::INIT: in TransStateId2PlayerState() 70 case StateId::PREPARING: in TransStateId2PlayerState() 73 case StateId::READY: in TransStateId2PlayerState() 76 case StateId::PAUSE: in TransStateId2PlayerState() 79 case StateId::PLAYING: in TransStateId2PlayerState() 82 case StateId::STOPPED: in TransStateId2PlayerState() 85 case StateId::EOS: in TransStateId2PlayerState()
|
H A D | media_utils.h | 26 PlayerStates TransStateId2PlayerState(StateId state);
|
H A D | hiplayer_impl.cpp | 91 HiPlayerImpl::OnStateChanged(StateId::STOPPED); in ~HiPlayerImpl() 162 OnStateChanged(StateId::INIT); in SetSource() 179 OnStateChanged(StateId::INIT); in SetSource() 205 OnStateChanged(StateId::PREPARING); in Prepare() 245 OnStateChanged(StateId::PREPARING); in PrepareAsync() 265 OnStateChanged(StateId::PLAYING); in Play() 279 OnStateChanged(StateId::PAUSE); in Pause() 293 OnStateChanged(StateId::STOPPED); in Stop() 307 OnStateChanged(StateId::STOPPED); in StopAsync() 493 OnStateChanged(StateId in HandleReadyEvent() [all...] |
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/av_sender/src/ |
H A D | av_sender_engine.cpp | 68 SetCurrentState(StateId::INITIALIZED); in Initialize() 156 bool isErrState = (GetCurrentState() != StateId::CH_CREATED); in Start() 173 SetCurrentState(StateId::STARTED); in Start() 187 SetCurrentState(StateId::STOPPED); in Stop() 213 SetCurrentState(StateId::IDLE); in Release() 528 StateId currentState = GetCurrentState(); in PushData() 529 bool isErrState = (currentState != StateId::STARTED) && (currentState != StateId::PLAYING); in PushData() 533 if (currentState == StateId::STARTED) { in PushData() 544 SetCurrentState(StateId in PushData() [all...] |
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/av_receiver/src/ |
H A D | av_receiver_engine.cpp | 67 SetCurrentState(StateId::INITIALIZED); in Initialize() 155 StateId currentState = GetCurrentState(); in PreparePipeline() 156 bool isErrState = ((currentState != StateId::INITIALIZED) && (currentState != StateId::CH_CREATED)); in PreparePipeline() 182 SetCurrentState(StateId::CH_CREATED); in PreparePipeline() 190 bool isErrState = (GetCurrentState() != StateId::CH_CREATED); in Start() 200 SetCurrentState(StateId::STARTED); in Start() 213 SetCurrentState(StateId::STOPPED); in Stop() 220 TRUE_RETURN_V(GetCurrentState() == StateId::IDLE, DH_AVT_SUCCESS); in Release() 237 SetCurrentState(StateId in Release() [all...] |
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/av_receiver/test/unittest/av_receiver_engine/src/ |
H A D | av_receiver_engine_test.cpp | 155 receiver->currentState_ = StateId::IDLE; in HWTEST_F() 166 receiver->currentState_ = StateId::CH_CREATED; in HWTEST_F() 178 receiver->currentState_ = StateId::CH_CREATED; in HWTEST_F() 239 receiver->currentState_ = StateId::STARTED; in HWTEST_F() 250 receiver->currentState_ = StateId::INITIALIZED; in HWTEST_F() 261 receiver->currentState_ = StateId::INITIALIZED; in HWTEST_F() 273 receiver->currentState_ = StateId::INITIALIZED; in HWTEST_F() 288 receiver->currentState_ = StateId::INITIALIZED; in HWTEST_F() 354 EXPECT_EQ(StateId::CH_CREATED, receiver->currentState_); in HWTEST_F() 368 EXPECT_EQ(StateId in HWTEST_F() [all...] |
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/av_sender/test/unittest/av_sender_engine/src/ |
H A D | av_sender_engine_test.cpp | 153 sender->currentState_ = StateId::IDLE; in HWTEST_F() 164 sender->currentState_ = StateId::CH_CREATED; in HWTEST_F() 176 sender->currentState_ = StateId::CH_CREATED; in HWTEST_F() 189 sender->currentState_ = StateId::CH_CREATED; in HWTEST_F() 393 sender->currentState_ = StateId::IDLE; in HWTEST_F() 405 sender->currentState_ = StateId::IDLE; in HWTEST_F() 417 sender->currentState_ = StateId::STARTED; in HWTEST_F() 429 sender->currentState_ = StateId::STARTED; in HWTEST_F() 442 sender->currentState_ = StateId::STARTED; in HWTEST_F() 454 sender->currentState_ = StateId in HWTEST_F() [all...] |
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/av_sender/include/ |
H A D | av_sender_engine.h | 102 StateId GetCurrentState() in GetCurrentState() 108 void SetCurrentState(StateId stateId) in SetCurrentState() 122 std::atomic<StateId> currentState_ = StateId::IDLE;
|
/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/av_receiver/include/ |
H A D | av_receiver_engine.h | 102 StateId GetCurrentState() in GetCurrentState() 108 void SetCurrentState(StateId stateId) in SetCurrentState() 121 std::atomic<StateId> currentState_ = StateId::IDLE;
|
/foundation/multimedia/media_foundation/engine/scene/player/lite/ |
H A D | hiplayer_impl.cpp | 33 curFsmState_(StateId::IDLE), in HiPlayerImpl() 158 if (curFsmState_ == StateId::PREPARING) { // Wait state change to ready in Prepare() 159 cond_.Wait(lock, [this] { return curFsmState_ != StateId::PREPARING; }); in Prepare() 163 if (curFsmState_ == StateId::READY) { in Prepare() 620 void HiPlayerImpl::OnStateChanged(StateId state) in OnStateChanged() 781 PlayerStates HiPlayerImpl::TransStateId2PlayerState(StateId state) in TransStateId2PlayerState() 785 case StateId::IDLE: in TransStateId2PlayerState() 788 case StateId::INIT: in TransStateId2PlayerState() 791 case StateId::PREPARING: in TransStateId2PlayerState() 794 case StateId in TransStateId2PlayerState() [all...] |
H A D | hiplayer_impl.h | 93 void OnStateChanged(StateId state) override; 113 PlayerStates TransStateId2PlayerState(StateId state); 137 std::atomic<StateId> curFsmState_;
|
/foundation/multimedia/player_framework/services/engine/histreamer/recorder/ |
H A D | hirecorder_impl.cpp | 152 OnStateChanged(StateId::RECORDING_SETTING);
in SetVideoSource() 182 OnStateChanged(StateId::RECORDING_SETTING);
in SetMetaSource() 210 OnStateChanged(StateId::RECORDING_SETTING);
in SetAudioSource() 232 OnStateChanged(StateId::RECORDING_SETTING);
in SetAudioDataSource() 241 OnStateChanged(StateId::RECORDING_SETTING);
in SetOutputFormat() 294 OnStateChanged(StateId::RECORDING_SETTING);
in Configure() 395 if (curState_ == StateId::PAUSE) {
in Start() 401 OnStateChanged(StateId::RECORDING);
in Start() 411 if (curState_ != StateId::READY) {
in Pause() 415 OnStateChanged(StateId in Pause() [all...] |
H A D | hirecorder_impl.h | 41 enum class StateId {
class 93 void OnStateChanged(StateId state);
130 std::atomic<StateId> curState_;
|
/foundation/multimedia/media_foundation/engine/scene/recorder/standard/ |
H A D | hirecorder_impl.cpp | 38 fsm_(*this), curFsmState_(StateId::INIT) in HiRecorderImpl() 192 if (curFsmState_ == StateId::RECORDING_SETTING) { // Wait state change to ready in Prepare() 193 cond_.Wait(lock, [this] { return curFsmState_ != StateId::RECORDING_SETTING; }); in Prepare() 197 if (curFsmState_ == StateId::READY) { in Prepare() 211 if (curFsmState_ == StateId::PAUSE) { in Start() 253 return curFsmState_ == StateId::ERROR || curFsmState_ == StateId::INIT; in Stop() 255 FALSE_RETURN_V_MSG_E(curFsmState_ == StateId::INIT, ERR_UNKNOWN_REASON, "stop fail"); in Stop() 264 if (curFsmState_ == StateId::RECORDING) { in Reset() 305 void HiRecorderImpl::OnStateChanged(StateId stat [all...] |