Home
last modified time | relevance | path

Searched refs:timeout (Results 1 - 25 of 702) sorted by relevance

12345678910>>...29

/foundation/arkui/ace_engine/frameworks/core/gestures/
H A Dtimeout_gesture.cpp20 TimeoutGesture::TimeoutGesture(const std::chrono::duration<float>& timeout) in TimeoutGesture() argument
21 : timeout_(timeout) in TimeoutGesture()
27 auto timeout = AceType::MakeRefPtr<OHOS::Ace::TimeoutRecognizer>( in CreateRecognizer() local
32 timeout->SetPriority(priority_); in CreateRecognizer()
33 timeout->SetPriorityMask(gestureMask_); in CreateRecognizer()
35 return timeout; in CreateRecognizer()
/foundation/multimedia/media_foundation/src/osal/task/pthread/
H A Dcondition_variable.cpp101 struct timespec timeout = {0, 0}; in WaitFor() local
103 clock_gettime(CLOCK_REALTIME, &timeout); in WaitFor()
105 clock_gettime(CLOCK_MONOTONIC, &timeout); in WaitFor()
107 timeout = NsToTm(TmToNs(timeout) + timeoutMs * std::mega::num); in WaitFor()
108 return pthread_cond_timedwait(&cond_, &(lock.mutex_->nativeHandle_), &timeout) == 0; in WaitFor()
117 struct timespec timeout = {0, 0}; in WaitFor() local
119 clock_gettime(CLOCK_REALTIME, &timeout); in WaitFor()
121 clock_gettime(CLOCK_MONOTONIC, &timeout); in WaitFor()
123 timeout in WaitFor()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/
H A Dievent.cpp22 IEvent *IEvent::CreateEvent(EventTime timeout, int &errCode) in CreateEvent() argument
24 if (timeout < 0) { in CreateEvent()
29 IEvent *event = new (std::nothrow) EventImpl(timeout); in CreateEvent()
39 EventTime timeout, int &errCode) in CreateEvent()
45 if ((events & ET_TIMEOUT) && (timeout < 0)) { in CreateEvent()
52 IEvent *event = new (std::nothrow) EventImpl(fd, events, timeout); in CreateEvent()
38 CreateEvent(EventFd fd, EventsMask events, EventTime timeout, int &errCode) CreateEvent() argument
H A Devent_impl.cpp22 EventImpl::EventImpl(EventTime timeout) in EventImpl() argument
25 timeout_(timeout), in EventImpl()
47 EventImpl::EventImpl(const EventFd &fd, EventsMask events, EventTime timeout) in EventImpl() argument
51 timeout_(timeout), in EventImpl()
163 int EventImpl::SetTimeout(EventTime timeout) in SetTimeout() argument
165 if (!IsValidArg(timeout)) { in SetTimeout()
173 timeout_ = timeout; in SetTimeout()
180 int errCode = loop->Modify(this, timeout); in SetTimeout()
183 LOGE("ev set timeout failed, err: '%d'.", errCode); in SetTimeout()
313 void EventImpl::SetTimeoutPeriod(EventTime timeout) in SetTimeoutPeriod() argument
[all...]
H A Devent_impl.h28 explicit EventImpl(EventTime timeout);
29 EventImpl(const EventFd &fd, EventsMask events, EventTime timeout);
35 int SetTimeout(EventTime timeout) override;
49 void SetTimeoutPeriod(EventTime timeout);
55 bool IsValidArg(EventTime timeout) const;
H A Dievent.h44 virtual int SetTimeout(EventTime timeout) = 0;
50 static IEvent *CreateEvent(EventTime timeout, int &errCode);
51 static IEvent *CreateEvent(EventFd fd, EventsMask events, EventTime timeout, int &errCode);
/foundation/systemabilitymgr/samgr_lite/samgr/adapter/cmsis/
H A Dqueue_adapter.c26 int QUEUE_Put(MQueueId queueId, const void *element, uint8 pri, int timeout) in QUEUE_Put() argument
28 uint32_t waitTime = (timeout <= 0) ? 0 : (uint32_t)timeout; in QUEUE_Put()
36 int QUEUE_Pop(MQueueId queueId, void *element, uint8 *pri, int timeout) in QUEUE_Pop() argument
38 uint32_t waitTime = (timeout <= 0) ? osWaitForever : (uint32_t)timeout; in QUEUE_Pop()
/foundation/graphic/graphic_2d/rosen/modules/render_service_profiler/
H A Drs_profiler_socket.cpp35 timeval timeout = {}; in GetTimeoutDesc() local
36 timeout.tv_sec = milliseconds / millisecondsInSecond; in GetTimeoutDesc()
37 timeout.tv_usec = (milliseconds % millisecondsInSecond) * millisecondsInSecond; in GetTimeoutDesc()
38 return timeout; in GetTimeoutDesc()
43 timeval timeout = {}; in GetTimeout() local
44 socklen_t size = sizeof(timeout); in GetTimeout()
45 getsockopt(socket, SOL_SOCKET, SO_SNDTIMEO, reinterpret_cast<char*>(&timeout), &size); in GetTimeout()
46 return timeout; in GetTimeout()
49 static void SetTimeout(int32_t socket, const timeval& timeout) in SetTimeout() argument
51 setsockopt(socket, SOL_SOCKET, SO_SNDTIMEO, reinterpret_cast<const char*>(&timeout), sizeo in SetTimeout()
226 const uint32_t timeout = size / bandwitdth + timeoutPad; ReceiveWhenReady() local
266 timeval timeout = GetTimeoutDesc(timeoutMilliseconds); GetStatus() local
[all...]
/foundation/multimedia/media_foundation/engine/include/foundation/osal/thread/
H A Dcondition_variable.h58 struct timespec timeout = {0, 0}; in WaitFor() local
60 clock_gettime(CLOCK_REALTIME, &timeout); in WaitFor()
62 clock_gettime(CLOCK_MONOTONIC, &timeout); in WaitFor()
64 timeout.tv_sec += timeoutMs / 1000; // 1000 in WaitFor()
65 timeout.tv_nsec += (timeoutMs % 1000) * 1000000; // 1000 1000000 in WaitFor()
69 &timeout); in WaitFor()
/foundation/multimedia/player_framework/services/utils/include/
H A Dplayer_xcollie.h28 int32_t SetTimer(const std::string &name, bool recovery = false, uint32_t timeout = 10); // 10s
29 int32_t SetTimerByLog(const std::string &name, uint32_t timeout = 10); // 10s
45 XcollieTimer(const std::string &name, bool recovery = false, uint32_t timeout = 10) in XcollieTimer()
47 id_ = PlayerXCollie::GetInstance().SetTimer(name, recovery, timeout); in XcollieTimer()
50 XcollieTimer(const std::string &name, uint32_t timeout) in XcollieTimer() argument
52 id_ = PlayerXCollie::GetInstance().SetTimerByLog(name, timeout); in XcollieTimer()
/foundation/resourceschedule/ffrt/src/dfx/watchdog/
H A Dwatchdog_util.cpp40 // 当前有效的并行任务timeout时间范围是10-30s in IsValidTimeout()
42 FFRT_LOGI("task gid=%llu with timeout [%llu ms] is valid", gid, timeout_ms); in IsValidTimeout()
45 FFRT_LOGE("task gid=%llu with timeout [%llu ms] is invalid", gid, timeout_ms); in IsValidTimeout()
62 bool SendTimeoutWatchdog(uint64_t gid, uint64_t timeout, uint64_t delay) in SendTimeoutWatchdog() argument
65 FFRT_LOGI("start to set watchdog for task gid=%llu with timeout [%llu ms] ", gid, timeout); in SendTimeoutWatchdog()
69 we->cb = ([gid, timeout](WaitEntry* we) { in SendTimeoutWatchdog()
72 RunTimeOutCallback(gid, timeout); in SendTimeoutWatchdog()
79 std::chrono::microseconds timeoutTime(timeout * CONVERT_TIME_UNIT); in SendTimeoutWatchdog()
84 FFRT_LOGE("failed to set watchdog for task gid=%llu with timeout [ in SendTimeoutWatchdog()
91 RunTimeOutCallback(uint64_t gid, uint64_t timeout) RunTimeOutCallback() argument
95 ss << "parallel task gid=" << gid << " execution time exceeds " << timeout << " ms"; RunTimeOutCallback() local
[all...]
/foundation/multimedia/audio_framework/services/audio_service/common/src/
H A Dfutex_tool.cpp36 // FUTEX_WAIT using relative timeout value.
37 void TimeoutToRelativeTime(int64_t timeout, struct timespec &realtime) in TimeoutToRelativeTime() argument
39 int64_t timeoutNanoSec = timeout % SEC_TO_NANOSEC; in TimeoutToRelativeTime()
40 int64_t timeoutSec = timeout / SEC_TO_NANOSEC; in TimeoutToRelativeTime()
46 FutexCode FutexTool::FutexWait(std::atomic<uint32_t> *futexPtr, int64_t timeout) in FutexWait() argument
56 if (timeout > 0) { in FutexWait()
57 TimeoutToRelativeTime(timeout, waitTime); in FutexWait()
75 res = syscall(__NR_futex, futexPtr, FUTEX_WAIT, IS_NOT_READY, (timeout <= 0 ? NULL : &waitTime), NULL, 0); in FutexWait()
80 AUDIO_WARNING_LOG("wait:%{public}" PRId64"ns timeout, result:%{public}ld errno[%{public}d]:%{public}s", in FutexWait()
81 timeout, re in FutexWait()
[all...]
/foundation/multimodalinput/input/util/socket/test/
H A Duds_socket_test.cpp99 int32_t timeout = -1; in HWTEST_F() local
102 int32_t retResult = socObj.EpollWait(*events, MAX_EVENT_SIZE, timeout); in HWTEST_F()
109 int32_t timeout = 1001; in HWTEST_F() local
112 int32_t retResult = socObj.EpollWait(*events, MAX_EVENT_SIZE, timeout); in HWTEST_F()
119 int32_t timeout = -1001; in HWTEST_F() local
122 int32_t retResult = socObj.EpollWait(*events, MAX_EVENT_SIZE, timeout); in HWTEST_F()
129 int32_t timeout = -1001; in HWTEST_F() local
132 int32_t retResult = socObj.EpollWait(*events, MAX_EVENT_SIZE, timeout); in HWTEST_F()
/foundation/multimedia/media_foundation/engine/foundation/osal/thread/
H A Dcondition_variable.cpp93 struct timespec timeout = {0, 0}; in WaitFor() local
95 clock_gettime(CLOCK_REALTIME, &timeout); in WaitFor()
97 clock_gettime(CLOCK_MONOTONIC, &timeout); in WaitFor()
99 timeout = NsToTm(TmToNs(timeout) + timeoutMs * std::mega::num); in WaitFor()
101 &timeout) == 0; in WaitFor()
/foundation/bundlemanager/bundle_framework/services/bundlemgr/src/
H A Dxcollie_helper.cpp26 int XCollieHelper::SetTimer(const std::string &name, unsigned int timeout, std::function<void(void *)> func, void *arg) in SetTimer() argument
29 return HiviewDFX::XCollie::GetInstance().SetTimer(name, timeout, func, arg, HiviewDFX::XCOLLIE_FLAG_LOG); in SetTimer()
44 int32_t XCollieHelper::SetRecoveryTimer(const std::string &methodName, unsigned int timeout) in SetRecoveryTimer() argument
46 return SetTimer(methodName, timeout, nullptr, nullptr); in SetRecoveryTimer()
/foundation/ability/ability_runtime/frameworks/native/runtime/
H A Dohos_loop_handler.cpp44 int32_t timeout = uv_backend_timeout(uvLoop_); in OnTriggered() local
45 if (timeout < 0) { in OnTriggered()
52 int64_t timeStamp = static_cast<int64_t>(uv_now(uvLoop_)) + timeout; in OnTriggered()
72 eventHandler->PostTask(callback, TIMER_TASK, timeout); in OnTriggered()
/foundation/multimedia/av_codec/test/unittest/hcodec_test/unittest/
H A Dhencoder_buffer_unit_test.cpp83 .timeout = 100, in HWTEST_F()
103 .timeout = 100, in HWTEST_F()
123 .timeout = 100, in HWTEST_F()
146 .timeout = 100, in HWTEST_F()
165 .timeout = 100, in HWTEST_F()
184 .timeout = 100, in HWTEST_F()
203 .timeout = 100, in HWTEST_F()
228 .timeout = 100, in HWTEST_F()
247 .timeout = 100, in HWTEST_F()
270 .timeout in HWTEST_F()
[all...]
H A Dhdecoder_buffer_unit_test.cpp38 .timeout = TIME_OUT, in HWTEST()
58 .timeout = TIME_OUT, in HWTEST()
77 .timeout = TIME_OUT, in HWTEST()
96 .timeout = TIME_OUT, in HWTEST()
115 .timeout = TIME_OUT, in HWTEST()
134 .timeout = TIME_OUT, in HWTEST()
/foundation/systemabilitymgr/samgr/test/autotest/testcases/level0/
H A Dcase26_init001.py25 def run_command_with_timeout(command, timeout):
30 if time.monotonic() - start_time > timeout:
58 timeout = 3
63 return_code = run_command_with_timeout(command, timeout)
75 return_code = run_command_with_timeout(command, timeout)
/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/
H A Dmod.rs170 /// Enables a request timeout.
172 /// The timeout is applied from when the request starts connecting until the
186 pub fn request_timeout(self, timeout: Timeout) -> Self { in request_timeout()
187 match timeout.inner() { in request_timeout()
188 Some(duration) => Self(self.0.timeout(duration)), in request_timeout()
193 /// Sets a timeout for only the connect phase of a `Client`.
206 pub fn connect_timeout(self, timeout: Timeout) -> Self { in connect_timeout()
207 match timeout.inner() { in connect_timeout()
/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/
H A Dbuilder.rs166 /// Sets the timeout for downloading body.
177 /// let builder = DownloaderBuilder::new().body(body).console().timeout(Timeout::none());
180 pub fn timeout(mut self, timeout: Timeout) -> Self { in timeout() functions
181 self.state.config.timeout = timeout; in timeout()
/foundation/resourceschedule/ffrt/src/sync/
H A Dpoller.h67 TimerDataWithCb(void *dataVal, void (*cbVal)(void *), CPUEUTask *taskVal, bool repeat, uint64_t timeout) in TimerDataWithCb()
68 : data(dataVal), cb(cbVal), task(taskVal), repeat(repeat), timeout(timeout) in TimerDataWithCb()
76 uint64_t timeout = 0; member
100 int WaitFdEvent(struct epoll_event *eventsVec, int maxevents, int timeout) noexcept;
102 PollerRet PollOnce(int timeout = -1) noexcept;
105 int RegisterTimer(uint64_t timeout, void* data, ffrt_timer_cb cb, bool repeat = false) noexcept;
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/distributed_stream/
H A Ddistributed_stream_test.cpp338 struct timespec timeout; in OpenAllSession() local
339 clock_gettime(CLOCK_REALTIME, &timeout); in OpenAllSession()
340 timeout.tv_sec += 10; // 10: over time 10 seconds in OpenAllSession()
341 while ((ret = sem_timedwait(&localSem_, &timeout)) == -1 && errno == EINTR) { in OpenAllSession()
364 struct timespec timeout; in OpenCtrlSession() local
365 clock_gettime(CLOCK_REALTIME, &timeout); in OpenCtrlSession()
366 timeout.tv_sec += 10; // 10: over time 10 seconds in OpenCtrlSession()
367 while ((ret = sem_timedwait(&localSem_, &timeout)) == -1 && errno == EINTR) { in OpenCtrlSession()
390 struct timespec timeout; in SendCreateSessionServerMessage() local
391 clock_gettime(CLOCK_REALTIME, &timeout); in SendCreateSessionServerMessage()
416 struct timespec timeout; SendRemoveSessionServerMessage() local
[all...]
/foundation/communication/dsoftbus/sdk/transmission/session/cpp/src/
H A Dsession_set_timer_virtual.c18 int SetTimer(const char *name, unsigned int timeout) in SetTimer() argument
21 (void)timeout; in SetTimer()
/foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/
H A Dqueue_adapter.c46 int QUEUE_Put(MQueueId queueId, const void *element, uint8 pri, int timeout) in QUEUE_Put() argument
48 if (queueId == NULL || element == NULL || timeout > 0) { in QUEUE_Put()
61 int QUEUE_Pop(MQueueId queueId, void *element, uint8 *pri, int timeout) in QUEUE_Pop() argument
63 if (queueId == NULL || element == NULL || timeout > 0) { in QUEUE_Pop()

Completed in 9 milliseconds

12345678910>>...29