/foundation/multimedia/av_codec/services/engine/codec/video/hcodec/ |
H A D | msg_handle_loop.cpp | 52 TimeUs nowUs = GetNowUs(); in SendAsyncMsg() local 53 TimeUs msgProcessTime = (delayUs > INT64_MAX - nowUs) ? INT64_MAX : (nowUs + static_cast<int64_t>(delayUs)); in SendAsyncMsg() 129 TimeUs nowUs = GetNowUs(); in MainLoop() local 130 if (processUs > nowUs) { in MainLoop() 131 m_threadCond.wait_for(lock, chrono::microseconds(processUs - nowUs)); in MainLoop()
|
/foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/hardware/imagecodec/ |
H A D | msg_handle_loop.cpp | 53 TimeUs nowUs = GetNowUs(); in SendAsyncMsg() local 54 TimeUs msgProcessTime = (delayUs > INT64_MAX - nowUs) ? INT64_MAX : (nowUs + delayUs); in SendAsyncMsg() 131 TimeUs nowUs = GetNowUs(); in MainLoop() local 132 if (processUs > nowUs) { in MainLoop() 133 m_threadCond.wait_for(lock, chrono::microseconds(processUs - nowUs)); in MainLoop()
|
/foundation/multimedia/media_foundation/src/filter/ |
H A D | filter_loop.cpp | 103 TimeUs nowUs = GetNowUs(); in SendAsyncMsg() local 107 TimeUs msgProcessTime = (delayUs > INT64_MAX - nowUs) ? INT64_MAX : (nowUs + delayUs); in SendAsyncMsg() 149 TimeUs nowUs = GetNowUs(); in MainLoop() local 164 if (commandTime <= nowUs && (commandInfo.what == FilterPlaybackCommand::PAUSE in MainLoop() 171 processUs = nowUs; in MainLoop() 178 processUs = dataInfo.flushed ? nowUs : dataTime; in MainLoop() 182 MEDIA_LOG_D("Check message what:%{public}d at processUs:%{public}" PRId64 " nowUs:%{public}" PRId64, in MainLoop() 184 nowUs); in MainLoop() 185 if (processUs > nowUs) { in MainLoop() [all...] |
/foundation/multimedia/media_lite/services/player_lite/impl/player_control/sink/ |
H A D | player_sync.cpp | 280 void PlayerSync::UpdateCurTimeWithAudio(int64_t& nowUs) in UpdateCurTimeWithAudio() argument 286 nowUs = lastAudioTsUs_ + (GetCurTimeUs() - lastAudioRealTsUs_); in UpdateCurTimeWithAudio() 307 int64_t nowUs; in ProcVidFrame() local 347 nowUs = GetCurTimeUs() - vidTimeSourceDelta_; in ProcVidFrame() 348 UpdateCurTimeWithAudio(nowUs); in ProcVidFrame() 349 diffAvRenderTime_ = (nowUs - ptsUs) / MS_SCALE; in ProcVidFrame() 399 int64_t nowUs; in ProcAudFrame() local 414 nowUs = GetCurTimeUs() - audTimeSourceDelta_; in ProcAudFrame() 415 int64_t latenessMs = (nowUs - timeUs) / MS_SCALE; in ProcAudFrame()
|
H A D | player_sync.h | 91 void UpdateCurTimeWithAudio(int64_t& nowUs);
|
/foundation/filemanagement/app_file_service/utils/src/b_utils/ |
H A D | b_time.cpp | 40 std::chrono::microseconds nowUs = std::chrono::duration_cast<std::chrono::microseconds>( in GetTimeUS() local 42 return nowUs.count(); in GetTimeUS()
|
/foundation/multimedia/media_foundation/src/osal/task/pthread/ |
H A D | pipeline_threadpool.cpp | 182 int64_t nowUs = GetNowUs(); in Run() local 183 if (nextJobUs > (nowUs + ADJUST_US)) { in Run() 184 syncCond_.WaitFor(lock, (nextJobUs - nowUs + ADJUST_US) / US_PER_MS); in Run()
|
H A D | taskInner.cpp | 269 int64_t nowUs = GetNowUs(); in UpdateTop() local 270 if (msgProcessTime <= nowUs || msgProcessTime <= jobProcessTime) { in UpdateTop() 330 int64_t nowUs = GetNowUs(); in InsertJob() local 334 int64_t processTime = nowUs + delayUs; in InsertJob()
|
/foundation/multimedia/av_codec/services/media_engine/modules/sink/ |
H A D | audio_sink.cpp | 614 int64_t nowUs = 0; in OnNewAudioMediaTime() local 617 nowUs = syncCenter->GetClockTimeNow(); in OnNewAudioMediaTime() 619 int64_t pendingTimeUs = getPendingAudioPlayoutDurationUs(nowUs); in OnNewAudioMediaTime() 620 render = syncCenter->UpdateTimeAnchor(nowUs, pendingTimeUs, {mediaTimeUs, mediaTimeUs, mediaTimeUs}, this); in OnNewAudioMediaTime() 624 int64_t AudioSink::getPendingAudioPlayoutDurationUs(int64_t nowUs) in getPendingAudioPlayoutDurationUs() argument 627 const int64_t numFramesPlayed = plugin_->GetPlayedOutDurationUs(nowUs); in getPendingAudioPlayoutDurationUs()
|
/foundation/multimedia/media_lite/services/player_lite/impl/player_control/player/fsm/src/ |
H A D | message_looper.cpp | 202 uint64_t nowUs = FsmGetCurTimeUs(); in QueueHandlr() local 203 if (whenUs > nowUs) { in QueueHandlr() 204 uint32_t delayUs = (uint32_t)(whenUs - nowUs); in QueueHandlr()
|
/foundation/multimedia/av_codec/interfaces/plugin/ |
H A D | audio_sink_plugin.h | 230 virtual int64_t GetPlayedOutDurationUs(int64_t nowUs) = 0;
|
/foundation/multimedia/av_codec/test/unittest/media_sink_test/ |
H A D | audio_server_sink_plugin_test.cpp | 117 int64_t nowUs = 0;
in HWTEST() local 118 auto durationUs = audioServerSinkPlugin->GetPlayedOutDurationUs(nowUs);
in HWTEST() 153 int64_t nowUs = 0;
in HWTEST() local 154 auto durationUs = audioServerSinkPlugin->GetPlayedOutDurationUs(nowUs);
in HWTEST()
|
H A D | audio_sink_test.cpp | 97 int64_t GetPlayedOutDurationUs(int64_t nowUs) override 99 (void)nowUs; variable 982 int64_t nowUs = 0; in HWTEST() local 983 ASSERT_EQ(100000000, audioSink->getPendingAudioPlayoutDurationUs(nowUs)); in HWTEST() 993 int64_t nowUs = 0; in HWTEST() local 994 ASSERT_EQ(0, audioSink->getPendingAudioPlayoutDurationUs(nowUs)); in HWTEST()
|
/foundation/distributedhardware/distributed_camera/common/src/utils/ |
H A D | dcamera_utils_tools.cpp | 77 std::chrono::microseconds nowUs = std::chrono::duration_cast<std::chrono::microseconds>( in GetNowTimeStampUs() local 79 return nowUs.count(); in GetNowTimeStampUs()
|
/foundation/multimedia/av_codec/interfaces/inner_api/native/ |
H A D | audio_sink.h | 89 int64_t getPendingAudioPlayoutDurationUs(int64_t nowUs);
|
/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/transport/ |
H A D | dsched_softbus_session.cpp | 409 std::chrono::microseconds nowUs = std::chrono::duration_cast<std::chrono::microseconds>( in GetNowTimeStampUs() local 411 return nowUs.count(); in GetNowTimeStampUs()
|
/foundation/multimedia/av_codec/services/media_engine/plugins/sink/ |
H A D | audio_server_sink_plugin.h | 107 int64_t GetPlayedOutDurationUs(int64_t nowUs) override;
|
H A D | audio_server_sink_plugin.cpp | 1008 int64_t AudioServerSinkPlugin::GetPlayedOutDurationUs(int64_t nowUs) in GetPlayedOutDurationUs() argument
|
/foundation/distributedhardware/distributed_audio/common/src/ |
H A D | daudio_util.cpp | 217 std::chrono::microseconds nowUs = in GetNowTimeUs() local 219 return nowUs.count(); in GetNowTimeUs()
|
/foundation/distributedhardware/distributed_audio/services/test_example/ |
H A D | distributedaudiotest.cpp | 149 std::chrono::microseconds nowUs = in GetNowTimeUs() local 151 return nowUs.count(); in GetNowTimeUs()
|
/foundation/multimedia/audio_framework/services/audio_service/test/example/ |
H A D | audio_process_client_test.cpp | 337 std::chrono::microseconds nowUs = in GetNowTimeUs() local 339 return nowUs.count(); in GetNowTimeUs()
|