Home
last modified time | relevance | path

Searched refs:timeoutMs (Results 1 - 25 of 116) sorted by relevance

12345

/foundation/multimedia/media_foundation/src/osal/task/pthread/
H A Dcondition_variable.cpp95 bool ConditionVariable::WaitFor(AutoLock& lock, int64_t timeoutMs) in WaitFor() argument
97 FALSE_RETURN_V_MSG_E(timeoutMs >= 0, in WaitFor()
98 false, "ConditionVariable WaitUntil invalid timeoutMs: " PUBLIC_LOG_D64, timeoutMs); in WaitFor()
107 timeout = NsToTm(TmToNs(timeout) + timeoutMs * std::mega::num); in WaitFor()
111 bool ConditionVariable::WaitFor(AutoLock& lock, int64_t timeoutMs, std::function<bool()> pred) in WaitFor() argument
113 FALSE_RETURN_V_MSG_E(timeoutMs >= 0, in WaitFor()
114 false, "ConditionVariable WaitUntil invalid timeoutMs: " PUBLIC_LOG_D64, timeoutMs); in WaitFor()
123 timeout = NsToTm(TmToNs(timeout) + timeoutMs * st in WaitFor()
[all...]
/foundation/multimedia/media_foundation/engine/include/foundation/osal/thread/
H A Dcondition_variable.h50 bool WaitFor(ScopedLock& lock, int timeoutMs);
53 bool WaitFor(ScopedLock& lock, int timeoutMs, Predicate pred) in WaitFor() argument
55 if (timeoutMs < 0) { in WaitFor()
64 timeout.tv_sec += timeoutMs / 1000; // 1000 in WaitFor()
65 timeout.tv_nsec += (timeoutMs % 1000) * 1000000; // 1000 1000000 in WaitFor()
/foundation/multimedia/media_foundation/src/osal/task/ffrt/
H A Dcondition_variable.cpp52 bool ConditionVariable::WaitFor(AutoLock& lock, int64_t timeoutMs) in WaitFor() argument
54 auto status = cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs)); in WaitFor()
62 bool ConditionVariable::WaitFor(AutoLock& lock, int64_t timeoutMs, std::function<bool()> pred) in WaitFor() argument
64 return cond_.wait_for(lock, std::chrono::milliseconds(timeoutMs), pred); in WaitFor()
/foundation/multimedia/media_foundation/test/unittest/
H A DTestSynchronizer.cpp69 int timeoutMs = 100; in HWTEST_F() local
72 syncId, [] {}, timeoutMs); in HWTEST_F()
76 EXPECT_TRUE((std::abs(static_cast<int>(diff) - timeoutMs) < 25) || (diff < 5)); in HWTEST_F()
88 int timeoutMs = 1000; in HWTEST_F() local
90 syncId, [] {}, timeoutMs); in HWTEST_F()
103 int timeoutMs = 1000; in HWTEST_F() local
106 syncId, [] { return true; }, timeoutMs, result); in HWTEST_F()
H A DTestFFmpegVideoDecoder.cpp74 int32_t timeoutMs = 100; in HWTEST() local
75 ASSERT_EQ(Status::ERROR_INVALID_DATA, videoDecoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs)); in HWTEST()
78 ASSERT_EQ(Status::ERROR_WRONG_STATE, videoDecoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs)); in HWTEST()
80 ASSERT_EQ(Status::ERROR_WRONG_STATE, videoDecoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs)); in HWTEST()
H A DTestFFmpegAudioDecoder.cpp85 int32_t timeoutMs = 100; in HWTEST() local
86 ASSERT_EQ(Status::ERROR_INVALID_DATA, aDecoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs)); in HWTEST()
89 ASSERT_EQ(Status::ERROR_WRONG_STATE, aDecoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs)); in HWTEST()
91 ASSERT_EQ(Status::ERROR_WRONG_STATE, aDecoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs)); in HWTEST()
H A DTestFFmpegAudioEncoder.cpp86 int32_t timeoutMs = 100; in HWTEST() local
87 ASSERT_EQ(Status::ERROR_INVALID_DATA, aEncoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs)); in HWTEST()
90 ASSERT_EQ(Status::ERROR_WRONG_STATE, aEncoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs)); in HWTEST()
92 ASSERT_EQ(Status::ERROR_WRONG_STATE, aEncoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs)); in HWTEST()
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/
H A Dblocking_queue.h66 bool Push(const T& value, int timeoutMs) in Push() argument
69 auto ret = CanPush(lock, timeoutMs); in Push()
76 bool Push(T&& value, int timeoutMs) in Push() argument
79 auto ret = CanPush(lock, timeoutMs); in Push()
118 T Pop(int timeoutMs) in Pop() argument
125 cvEmpty_.wait_for(lock, timeoutMs, [this] { return !isActive_ || !que_.empty(); }); in Pop()
135 std::optional<T> GetBackElement(int timeoutMs) in GetBackElement() argument
142 cvEmpty_.wait_for(lock, std::chrono::milliseconds(timeoutMs), in GetBackElement()
202 bool CanPush(std::unique_lock<std::mutex>& lock, int timeoutMs) in CanPush() argument
208 cvFull_.wait(lock, timeoutMs, [thi in CanPush()
[all...]
/foundation/multimedia/media_foundation/engine/plugin/core/
H A Dcodec.cpp29 Status Codec::QueueInputBuffer(const std::shared_ptr<Buffer>& inputBuffer, int32_t timeoutMs) in QueueInputBuffer() argument
31 return codec_->QueueInputBuffer(inputBuffer, timeoutMs); in QueueInputBuffer()
34 Status Codec::QueueOutputBuffer(const std::shared_ptr<Buffer>& outputBuffers, int32_t timeoutMs) in QueueOutputBuffer() argument
36 return codec_->QueueOutputBuffer(outputBuffers, timeoutMs); in QueueOutputBuffer()
/foundation/communication/netstack/utils/http_over_curl/include/
H A Dtimeout_timer.h75 void SetTimeoutMs(long timeoutMs) in SetTimeoutMs()
80 if (timeoutMs > 0) { in SetTimeoutMs()
81 its.it_value.tv_sec = timeoutMs / MILLISECONDS_IN_SECOND; in SetTimeoutMs()
82 its.it_value.tv_nsec = (timeoutMs % MILLISECONDS_IN_SECOND) * NANOSECONDS_IN_MILLISECOND; in SetTimeoutMs()
/foundation/multimedia/media_foundation/engine/foundation/osal/thread/
H A Dcondition_variable.cpp87 bool ConditionVariable::WaitFor(ScopedLock& lock, int timeoutMs) in WaitFor() argument
89 if (timeoutMs < 0) { in WaitFor()
90 MEDIA_LOG_E("ConditionVariable WaitUntil invalid timeoutMs: " PUBLIC_LOG_D32, timeoutMs); in WaitFor()
99 timeout = NsToTm(TmToNs(timeout) + timeoutMs * std::mega::num); in WaitFor()
/foundation/multimedia/media_lite/services/player_lite/impl/player_control/decoder/
H A Ddecoder.h79 int32_t QueueInputBuffer(CodecBuffer* inputData, uint32_t timeoutMs);
81 int32_t DequeInputBuffer(CodecBuffer* inputData, uint32_t timeoutMs);
83 int32_t QueueOutputBuffer(CodecBuffer* outInfo, uint32_t timeoutMs);
85 int32_t DequeueOutputBuffer(CodecBuffer* outInfo, uint32_t timeoutMs);
H A Ddecoder.cpp230 int32_t Decoder::QueueInputBuffer(CodecBuffer* inputData, uint32_t timeoutMs) in QueueInputBuffer() argument
232 int32_t ret = CodecQueueInput(codecHandle_, inputData, timeoutMs, 0); in QueueInputBuffer()
236 int32_t Decoder::DequeInputBuffer(CodecBuffer* inputData, uint32_t timeoutMs) in DequeInputBuffer() argument
238 int32_t ret = CodecDequeueInput(codecHandle_, timeoutMs, nullptr, inputData); in DequeInputBuffer()
245 int32_t Decoder::QueueOutputBuffer(CodecBuffer* outInfo, uint32_t timeoutMs) in QueueOutputBuffer() argument
247 int32_t ret = CodecQueueOutput(codecHandle_, outInfo, timeoutMs, -1); in QueueOutputBuffer()
254 int32_t Decoder::DequeueOutputBuffer(CodecBuffer* outInfo, uint32_t timeoutMs) in DequeueOutputBuffer() argument
256 int32_t ret = CodecDequeueOutput(codecHandle_, timeoutMs, nullptr, outInfo); in DequeueOutputBuffer()
/foundation/multimedia/media_foundation/engine/include/foundation/osal/base/
H A Dsynchronizer.h57 bool WaitFor(SyncIdType syncId, const std::function<void()>& asyncOps, int timeoutMs) in WaitFor() argument
60 name_.c_str(), static_cast<int>(syncId), timeoutMs); in WaitFor()
67 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in WaitFor()
90 bool WaitFor(SyncIdType syncId, const std::function<bool()>& asyncOps, int timeoutMs, ResultType& result) in WaitFor() argument
93 name_.c_str(), static_cast<int>(syncId), timeoutMs); in WaitFor()
103 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in WaitFor()
/foundation/multimedia/media_foundation/src/osal/base/
H A Dsynchronizer.h56 bool WaitFor(SyncIdType syncId, const std::function<void()>& asyncOps, int timeoutMs) in WaitFor() argument
59 name_.c_str(), static_cast<int>(syncId), timeoutMs); in WaitFor()
66 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in WaitFor()
89 bool WaitFor(SyncIdType syncId, const std::function<bool()>& asyncOps, int timeoutMs, ResultType& result) in WaitFor() argument
92 name_.c_str(), static_cast<int>(syncId), timeoutMs); in WaitFor()
102 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in WaitFor()
/foundation/ability/ability_runtime/frameworks/native/appkit/ability_delegator/
H A Diability_stage_monitor.cpp54 std::shared_ptr<DelegatorAbilityStageProperty> IAbilityStageMonitor::WaitForAbilityStage(const int64_t timeoutMs) in WaitForAbilityStage() argument
56 auto realTime = timeoutMs; in WaitForAbilityStage()
57 if (timeoutMs <= 0) { in WaitForAbilityStage()
/foundation/communication/dsoftbus/components/nstackx/nstackx_core/platform/liteos/dfile/
H A Dsys_dfile_session.c21 int32_t WaitSocketEvent(const DFileSession *session, SocketDesc fd, uint32_t timeoutMs, in WaitSocketEvent() argument
60 tv.tv_sec = timeoutMs / NSTACKX_MILLI_TICKS; in WaitSocketEvent()
61 tv.tv_usec = (timeoutMs % NSTACKX_MILLI_TICKS) * NSTACKX_MICRO_SEC_PER_MILLI_SEC; in WaitSocketEvent()
/foundation/communication/dsoftbus/components/nstackx/nstackx_core/platform/unix/dfile/
H A Dsys_dfile_session.c21 int32_t WaitSocketEvent(const DFileSession *session, SocketDesc fd, uint32_t timeoutMs, in WaitSocketEvent() argument
60 tv.tv_sec = timeoutMs / NSTACKX_MILLI_TICKS; in WaitSocketEvent()
61 tv.tv_usec = (timeoutMs % NSTACKX_MILLI_TICKS) * NSTACKX_MICRO_SEC_PER_MILLI_SEC; in WaitSocketEvent()
/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/
H A Dsys_timer.c92 int32_t TimerSetTimeout(Timer *timer, uint32_t timeoutMs, uint8_t repeated) in TimerSetTimeout() argument
102 if (timeoutMs) { in TimerSetTimeout()
103 ts.it_value.tv_sec = timeoutMs / NSTACKX_MILLI_TICKS; in TimerSetTimeout()
104 ts.it_value.tv_nsec = (timeoutMs % NSTACKX_MILLI_TICKS) * NSTACKX_NANO_SEC_PER_MILLI_SEC; in TimerSetTimeout()
/foundation/ability/ability_runtime/tools/aa/src/
H A Dtest_observer.cpp74 bool TestObserver::WaitForFinish(const int64_t& timeoutMs) in WaitForFinish() argument
78 auto realTime = timeoutMs > 0 ? timeoutMs : 0; in WaitForFinish()
/foundation/multimedia/media_foundation/test/unittest/plugins/
H A DUtCodecTest1.h32 Status QueueInputBuffer(const std::shared_ptr<Buffer> &inputBuffer, int32_t timeoutMs) override;
34 Status QueueOutputBuffer(const std::shared_ptr<Buffer> &outputBuffers, int32_t timeoutMs) override;
H A DUtCodecTest2.h32 Status QueueInputBuffer(const std::shared_ptr<Buffer> &inputBuffer, int32_t timeoutMs) override;
34 Status QueueOutputBuffer(const std::shared_ptr<Buffer> &outputBuffers, int32_t timeoutMs) override;
/foundation/multimedia/media_foundation/interface/inner_api/osal/task/
H A Dcondition_variable.h42 bool WaitFor(AutoLock& lock, int64_t timeoutMs);
44 bool WaitFor(AutoLock& lock, int64_t timeoutMs, std::function<bool()> pred);
/foundation/multimedia/player_framework/services/utils/include/
H A Dwatchdog.h34 explicit WatchDog(uint32_t timeoutMs) : timeoutMs_(timeoutMs) {}; in WatchDog() argument
/foundation/filemanagement/app_file_service/tests/mock/timer/
H A Dtimer_mock.cpp24 Timer::Timer(const std::string &name, int timeoutMs) in Timer() argument
26 GTEST_LOG_(INFO) << "Timer " << name << " ,timeoutMs " << timeoutMs; in Timer() local

Completed in 7 milliseconds

12345