Home
last modified time | relevance | path

Searched refs:timeoutMs (Results 1 – 25 of 212) sorted by relevance

123456789

/ohos5.0/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 * std::mega::num); in WaitFor()
/ohos5.0/foundation/multimedia/media_foundation/test/unittest/
H A DTestSynchronizer.cpp69 int timeoutMs = 100; variable
72 syncId, [] {}, timeoutMs); in __anon43a178830202()
76 EXPECT_TRUE((std::abs(static_cast<int>(diff) - timeoutMs) < 20) || (diff < 5));
88 int timeoutMs = 1000; variable
90 syncId, [] {}, timeoutMs); in __anon43a178830402()
103 int timeoutMs = 1000; variable
106 syncId, [] { return true; }, timeoutMs, result); in __anon43a178830602()
H A DTestFFmpegVideoDecoder.cpp74 int32_t timeoutMs = 100; variable
75 …SSERT_EQ(Status::ERROR_INVALID_DATA, videoDecoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs));
78 …ASSERT_EQ(Status::ERROR_WRONG_STATE, videoDecoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs));
80 …ASSERT_EQ(Status::ERROR_WRONG_STATE, videoDecoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs));
H A DTestFFmpegAudioDecoder.cpp85 int32_t timeoutMs = 100; variable
86 ASSERT_EQ(Status::ERROR_INVALID_DATA, aDecoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs));
89 ASSERT_EQ(Status::ERROR_WRONG_STATE, aDecoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs));
91 ASSERT_EQ(Status::ERROR_WRONG_STATE, aDecoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs));
H A DTestFFmpegAudioEncoder.cpp86 int32_t timeoutMs = 100; variable
87 ASSERT_EQ(Status::ERROR_INVALID_DATA, aEncoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs));
90 ASSERT_EQ(Status::ERROR_WRONG_STATE, aEncoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs));
92 ASSERT_EQ(Status::ERROR_WRONG_STATE, aEncoderPlugin->QueueInputBuffer(inputBuffer, timeoutMs));
/ohos5.0/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, [this] { return !isActive_ || que_.size() < capacity_; }); in CanPush()
/ohos5.0/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()
/ohos5.0/base/powermgr/power_manager/test/unittest/src/
H A Drunning_lock_mock_test.cpp83 int32_t timeoutMs = 100; variable
137 int32_t timeoutMs = 100; variable
181 int32_t timeoutMs = -1; variable
196 EXPECT_EQ(param.timeoutMs, timeoutMs); in __anoncd1def9a0802()
238 int32_t timeoutMs = -1; variable
253 EXPECT_EQ(param.timeoutMs, timeoutMs); in __anoncd1def9a0b02()
295 int32_t timeoutMs = -1; variable
310 EXPECT_EQ(param.timeoutMs, timeoutMs); in __anoncd1def9a0e02()
687 EXPECT_EQ(param.timeoutMs, timeoutMs); in __anoncd1def9a1e02()
742 EXPECT_EQ(param.timeoutMs, timeoutMs); in __anoncd1def9a2002()
[all …]
/ohos5.0/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()
/ohos5.0/commonlibrary/c_utils/docs/zh-cn/
H A Dc_utils_timer.md17 …onst std::string& name, int timeoutMs = 1000)<br>Timer构造函数。在性能敏感的场景下，输入更大的timeoutMs。timeoutMs默认值是1…
21 …n = true)<br>停止Timer。可配置阻塞式停止或者非阻塞式停止。阻塞式停止会等待Timer所有任务结束后停止Timer。 如果配置了timeoutMs为-1可以使用非阻塞式停止防止当前…
/ohos5.0/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()
/ohos5.0/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_.… in WaitFor()
89 …bool WaitFor(SyncIdType syncId, const std::function<bool()>& asyncOps, int timeoutMs, ResultType& … 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_.… in WaitFor()
/ohos5.0/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_.… in WaitFor()
90 …bool WaitFor(SyncIdType syncId, const std::function<bool()>& asyncOps, int timeoutMs, ResultType& … 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_.… in WaitFor()
/ohos5.0/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()
/ohos5.0/base/powermgr/power_manager/services/native/src/runninglock/
H A Drunning_lock_inner.h69 void SetTimeOutMs(int32_t timeoutMs) in SetTimeOutMs() argument
71 runningLockParam_.timeoutMs = timeoutMs; in SetTimeOutMs()
75 return runningLockParam_.timeoutMs; in GetTimeOutMs()
/ohos5.0/foundation/multimedia/media_lite/services/player_lite/impl/player_control/decoder/
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()
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);
/ohos5.0/drivers/peripheral/power/test/unittest/src/
H A Dhdf_power_runninglock_test.cpp58 runinglockInfo.timeoutMs = RUNNINGLOCK_TIMEOUT_NONE;
75 runinglockInfo.timeoutMs = RUNNINGLOCK_TIMEOUT_NONE;
91 runinglockInfo.timeoutMs = RUNNINGLOCK_TIMEOUT_NONE;
812 runinglockInfo.timeoutMs += timeoutIntervalMs;
818 runinglockInfo.timeoutMs += timeoutIntervalMs;
824 runinglockInfo.timeoutMs += timeoutIntervalMs;
830 runinglockInfo.timeoutMs += timeoutIntervalMs;
836 runinglockInfo.timeoutMs += timeoutIntervalMs;
842 runinglockInfo.timeoutMs += timeoutIntervalMs;
908 runinglockInfo.timeoutMs = updateTimeOutMs;
[all …]
/ohos5.0/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()
/ohos5.0/drivers/peripheral/codec/interfaces/include/
H A Dcodec_interface.h231 int32_t CodecQueueInput(CODEC_HANDLETYPE handle, const CodecBuffer *inputData, uint32_t timeoutMs, …
243 int32_t CodecDequeueInput(CODEC_HANDLETYPE handle, uint32_t timeoutMs, int *acquireFd, CodecBuffer …
258 int32_t CodecQueueOutput(CODEC_HANDLETYPE handle, CodecBuffer *outInfo, uint32_t timeoutMs, int rel…
273 int32_t CodecDequeueOutput(CODEC_HANDLETYPE handle, uint32_t timeoutMs, int *acquireFd, CodecBuffer…
/ohos5.0/docs/zh-cn/device-dev/reference/hdi-apis/power/
H A D_running_lock_info_v11.md22 | int [timeoutMs](#timeoutms) | 运行锁的超时时间，单位毫秒。值小于 0 表示没有超时。默认为3000 |
50 ### timeoutMs subsection
53 int RunningLockInfo::timeoutMs
/ohos5.0/foundation/multimedia/media_lite/test/
H A Dtest_play_file_h265.cpp33 constexpr uint32_t timeoutMs = 100; // timeout:100ms in Display() local
34 int32_t ret = CodecDequeueOutput(decoderHdl, timeoutMs, nullptr, &outInfo); in Display()
49 ret = CodecQueueOutput(decoderHdl, &outInfo, timeoutMs, -1); in Display()
196 uint32_t timeoutMs = 100; // 100ms timeout in DecodePack() local
197 int32_t ret = CodecDequeInput(decoderHdl_, timeoutMs, &inputData); in DecodePack()
210 … while ((ret = CodecQueueInput(decoderHdl_, &inputData, timeoutMs)) == CODEC_ERR_STREAM_BUF_FULL) { in DecodePack()
211 this_thread::sleep_for(chrono::milliseconds(timeoutMs)); in DecodePack()
/ohos5.0/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()
/ohos5.0/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()
/ohos5.0/foundation/ability/ability_runtime/frameworks/native/appkit/ability_delegator/
H A Diability_stage_monitor.cpp54 …r<DelegatorAbilityStageProperty> IAbilityStageMonitor::WaitForAbilityStage(const int64_t timeoutMs) in WaitForAbilityStage() argument
56 auto realTime = timeoutMs; in WaitForAbilityStage()
57 if (timeoutMs <= 0) { in WaitForAbilityStage()

123456789