Home
last modified time | relevance | path

Searched refs:delayUs (Results 1 - 25 of 32) sorted by relevance

12

/foundation/multimedia/media_foundation/interface/inner_api/filter/
H A Dfilter_loop.h44 void SendAsyncMsg(int32_t what, int arg, int64_t delayUs = 0, bool isDataMsg = false);
48 void InitAsync(int arg = 0, int64_t delayUs = 0);
50 void PrepareAsync(int arg = 0, int64_t delayUs = 0);
52 void StartAsync(int arg = 0, int64_t delayUs = 0);
54 void ResumeAsync(int arg = 0, int64_t delayUs = 0);
56 void PauseAsync(int arg = 0, int64_t delayUs = 0);
58 void StopAsync(int arg = 0, int64_t delayUs = 0);
60 void FlushAsync(int arg = 0, int64_t delayUs = 0);
62 void ReleaseAsync(int arg = 0, int64_t delayUs = 0);
64 void ProcessInputBufferAsync(int arg = 0, int64_t delayUs
[all...]
/foundation/multimedia/media_foundation/src/filter/
H A Dfilter_loop.cpp47 void FilterLoop::InitAsync(int arg, int64_t delayUs) in InitAsync() argument
49 SendAsyncMsg(FilterPlaybackCommand::INIT, arg, delayUs); in InitAsync()
52 void FilterLoop::PrepareAsync(int arg, int64_t delayUs) in PrepareAsync() argument
54 SendAsyncMsg(FilterPlaybackCommand::PREPARE, arg, delayUs); in PrepareAsync()
57 void FilterLoop::StartAsync(int arg, int64_t delayUs) in StartAsync() argument
59 SendAsyncMsg(FilterPlaybackCommand::START, arg, delayUs); in StartAsync()
62 void FilterLoop::ResumeAsync(int arg, int64_t delayUs) in ResumeAsync() argument
64 SendAsyncMsg(FilterPlaybackCommand::RESUME, arg, delayUs); in ResumeAsync()
67 void FilterLoop::PauseAsync(int arg, int64_t delayUs) in PauseAsync() argument
69 SendAsyncMsg(FilterPlaybackCommand::PAUSE, arg, delayUs); in PauseAsync()
72 StopAsync(int arg, int64_t delayUs) StopAsync() argument
77 FlushAsync(int arg, int64_t delayUs) FlushAsync() argument
82 ReleaseAsync(int arg, int64_t delayUs) ReleaseAsync() argument
87 ProcessInputBufferAsync(int arg, int64_t delayUs) ProcessInputBufferAsync() argument
92 ProcessOutBufferAsync(int arg, int64_t delayUs) ProcessOutBufferAsync() argument
97 SendAsyncMsg(int32_t what, int arg, int64_t delayUs, bool isDataMsg) SendAsyncMsg() argument
[all...]
H A Dfilter.cpp373 Status Filter::ProcessInputBuffer(int sendArg, int64_t delayUs) in ProcessInputBuffer() argument
381 }, delayUs, false); in ProcessInputBuffer()
383 Task::SleepInTask(delayUs / 1000); // 1000 convert to ms in ProcessInputBuffer()
389 Status Filter::ProcessOutputBuffer(int sendArg, int64_t delayUs, bool byIdx, uint32_t idx, int64_t renderTime) in ProcessOutputBuffer() argument
399 }, delayUs, false); in ProcessOutputBuffer()
401 Task::SleepInTask(delayUs / 1000); // 1000 convert to ms in ProcessOutputBuffer()
/foundation/multimedia/media_foundation/src/osal/task/
H A Dtask.cpp75 void Task::SubmitJobOnce(const std::function<void()>& job, int64_t delayUs, bool wait) in SubmitJobOnce() argument
77 taskInner_->SubmitJobOnce(job, delayUs, wait); in SubmitJobOnce()
80 void Task::SubmitJob(const std::function<void()>& job, int64_t delayUs, bool wait) in SubmitJob() argument
82 taskInner_->SubmitJob(job, delayUs, wait); in SubmitJob()
90 void Task::UpdateDelayTime(int64_t delayUs) in UpdateDelayTime() argument
92 taskInner_->UpdateDelayTime(delayUs); in UpdateDelayTime()
/foundation/ai/intelligent_voice_framework/utils/
H A Dtimer_mgr.h31 explicit TimerCfg(int type = 0, int64_t delayUs = 0, int cookie = 0) in TimerCfg()
32 : type(type), delayUs(delayUs), cookie(cookie) in TimerCfg()
37 int64_t delayUs; member
64 int64_t delayUs = static_cast<long long>(0), ITimerObserver *observer = nullptr);
88 int SetTimer(int type, int64_t delayUs, int cookie = 0, ITimerObserver *currObserver = nullptr);
89 int ResetTimer(int timerId, int type, int64_t delayUs, int cookie, ITimerObserver *currObserver);
H A Dtimer_mgr.cpp59 TimerItem::TimerItem(int id, int type, int cookie, int64_t delayUs, ITimerObserver *observer) in TimerItem() argument
62 tgtUs = NowTimeUs() + delayUs; in TimerItem()
116 int TimerMgr::SetTimer(int type, int64_t delayUs, int cookie, ITimerObserver *currObserver) in SetTimer() argument
137 shared_ptr<TimerItem> addItem = make_shared<TimerItem>(id, type, cookie, delayUs, observer); in SetTimer()
157 oss << "set timer id " << id << " type " << type << " delay " << delayUs << " cookie " << cookie << " time "; in SetTimer()
163 int TimerMgr::ResetTimer(int timerId, int type, int64_t delayUs, int cookie, ITimerObserver *currObserver) in ResetTimer() argument
174 (*it)->tgtUs = NowTimeUs() + delayUs; in ResetTimer()
180 return SetTimer(type, delayUs, cookie, currObserver); in ResetTimer()
H A Dstate_manager.cpp99 if (action->cfg.delayUs != 0) { in ToState()
100 action->timerId = SetTimer(action->cfg.type, action->cfg.delayUs, action->cfg.cookie, this); in ToState()
157 if ((action->timerId == INVALID_ID) || (action->cfg.delayUs == 0)) { in ResetTimerDelay()
161 action->timerId = ResetTimer(action->timerId, action->cfg.type, action->cfg.delayUs, action->cfg.cookie, this); in ResetTimerDelay()
H A Dstate_manager.h99 StateActions& WaitUntil(int type, HandleMsg handler, int64_t delayUs, int cookie = 0) in WaitUntil()
102 cfg.delayUs = delayUs; in WaitUntil()
/foundation/multimedia/media_foundation/interface/inner_api/osal/task/
H A Dtask.h62 virtual void SubmitJobOnce(const std::function<void()>& job, int64_t delayUs = 0, bool wait = false);
64 virtual void SubmitJob(const std::function<void()>& job, int64_t delayUs = 0, bool wait = false);
68 virtual void UpdateDelayTime(int64_t delayUs = 0);
H A DtaskInner.h68 virtual void UpdateDelayTime(int64_t delayUs);
105 int64_t InsertJob(const std::function<void()>& job, int64_t delayUs, bool inJobQueue);
/foundation/multimedia/media_lite/services/player_lite/impl/player_control/player/fsm/src/
H A Dfsm_common.cpp51 int32_t FsmCondTimewait(pthread_cond_t &cond, pthread_mutex_t &mutex, uint32_t delayUs) in FsmCondTimewait() argument
61 if (delayUs >= UINT_MAX / USEC2NSEC) { in FsmCondTimewait()
64 uint64_t delayNs = delayUs * USEC2NSEC; in FsmCondTimewait()
H A Dmessage_looper.cpp204 uint32_t delayUs = (uint32_t)(whenUs - nowUs); in QueueHandlr() local
205 ret = FsmCondTimewait(m_queueCondition, m_queueLock, delayUs); in QueueHandlr()
250 int32_t MessageLooper::Post(const MsgInfo &msg, uint64_t delayUs) in Post() argument
267 InsertQueue(*msgInfo, delayUs); in Post()
272 void MessageLooper::InsertQueue(MsgInfo &msg, uint64_t delayUs) in InsertQueue() argument
275 uint64_t whenUs = (delayUs > 0) ? (curUs + delayUs) : curUs; in InsertQueue()
H A Dmessage_looper.h41 int32_t Post(const MsgInfo &msg, uint64_t delayUs);
51 void InsertQueue(MsgInfo &msg, uint64_t delayUs);
H A Dhi_state_machine.h58 int32_t Post(const MsgInfo &msg, uint64_t delayUs);
61 int32_t Post(int32_t what, uint64_t delayUs);
H A Dhi_state_machine.cpp212 int32_t HiStateMachine::Post(const MsgInfo &msg, uint64_t delayUs) in Post() argument
222 return m_looper->Post(msg, delayUs); in Post()
225 int32_t HiStateMachine::Post(int32_t what, uint64_t delayUs) in Post() argument
244 return m_looper->Post(msg, delayUs); in Post()
H A Dfsm_common.h67 int32_t FsmCondTimewait(pthread_cond_t &cond, pthread_mutex_t &mutex, uint32_t delayUs);
/foundation/multimedia/media_foundation/src/osal/task/pthread/
H A DtaskInner.cpp87 void TaskInner::UpdateDelayTime(int64_t delayUs) in UpdateDelayTime() argument
94 ", delayUs:" PUBLIC_LOG_D64, name_.c_str(), topProcessUs_, delayUs); in UpdateDelayTime()
101 topProcessUs_ = GetNowUs() + delayUs; in UpdateDelayTime()
234 void TaskInner::SubmitJobOnce(const std::function<void()>& job, int64_t delayUs, bool wait) in SubmitJobOnce() argument
237 int64_t time = InsertJob(job, delayUs, false); in SubmitJobOnce()
244 void TaskInner::SubmitJob(const std::function<void()>& job, int64_t delayUs, bool wait) in SubmitJob() argument
246 MEDIA_LOG_D(PUBLIC_LOG_S " SubmitJob delayUs:%{public}" PRId64, name_.c_str(), delayUs); in SubmitJob()
247 int64_t time = InsertJob(job, delayUs, tru in SubmitJob()
326 InsertJob(const std::function<void()>& job, int64_t delayUs, bool inJobQueue) InsertJob() argument
[all...]
/foundation/resourceschedule/ffrt/src/queue/
H A Deventhandler_interactive_queue.cpp30 int delayUs = static_cast<int>(task->GetDelay()); in Push() local
40 task->label, delayUs / msPerSecond, static_cast<Priority>(prio), static_cast<uintptr_t>(task->gid)); in Push()
/foundation/multimedia/player_framework/services/utils/
H A Dtask_queue.cpp97 // cancelNotExecuted = false, delayUs = 0ULL.
99 bool cancelNotExecuted, uint64_t delayUs) in EnqueueTask()
108 CHECK_AND_RETURN_RET_LOG(delayUs < MAX_DELAY_US, MSERR_INVALID_VAL, in EnqueueTask()
109 "Enqueue task when taskqueue delayUs[%{public}" PRIu64 "] is >= max delayUs[ %{public}" PRIu64 in EnqueueTask()
111 delayUs, MAX_DELAY_US, name_.c_str()); in EnqueueTask()
124 CHECK_AND_RETURN_RET_LOG(curTimeNs < UINT64_MAX - delayUs * US_TO_NS, MSERR_INVALID_OPERATION, in EnqueueTask()
127 uint64_t executeTimeNs = delayUs * US_TO_NS + curTimeNs; in EnqueueTask()
98 EnqueueTask(const std::shared_ptr<ITaskHandler> &task, bool cancelNotExecuted, uint64_t delayUs) EnqueueTask() argument
/foundation/multimedia/av_codec/services/engine/codec/video/hcodec/
H A Dmsg_handle_loop.cpp49 void MsgHandleLoop::SendAsyncMsg(MsgType type, const ParamSP &msg, uint32_t delayUs) in SendAsyncMsg() argument
53 TimeUs msgProcessTime = (delayUs > INT64_MAX - nowUs) ? INT64_MAX : (nowUs + static_cast<int64_t>(delayUs)); in SendAsyncMsg()
H A Dmsg_handle_loop.h41 void SendAsyncMsg(MsgType type, const ParamSP &msg, uint32_t delayUs = 0);
/foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/hardware/imagecodec/
H A Dmsg_handle_loop.cpp50 void MsgHandleLoop::SendAsyncMsg(MsgType type, const ParamSP &msg, uint32_t delayUs) in SendAsyncMsg() argument
54 TimeUs msgProcessTime = (delayUs > INT64_MAX - nowUs) ? INT64_MAX : (nowUs + delayUs); in SendAsyncMsg()
/foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/include/hardware/imagecodec/
H A Dmsg_handle_loop.h40 void SendAsyncMsg(MsgType type, const ParamSP &msg, uint32_t delayUs = 0);
/foundation/multimedia/media_lite/services/player_lite/impl/player_control/player/fsm/include/
H A Dhi_fsm.h71 int32_t HI_FSM_SendAsync(void *stateMachine, const MsgInfo *msg, uint64_t delayUs);
/foundation/multimedia/player_framework/services/engine/histreamer/transcoder/
H A Dhitranscoder_callback_looper.cpp202 int64_t delayUs = (event->whenMs - SteadyClock::GetCurrentTimeMs()) * 1000; in Enqueue() local
205 }, delayUs); in Enqueue()

Completed in 10 milliseconds

12