/ohos5.0/foundation/multimedia/media_foundation/src/osal/task/pthread/ |
H A D | condition_variable.cpp | 101 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 = NsToTm(TmToNs(timeout) + timeoutMs * std::mega::num); in WaitFor() 126 status = pthread_cond_timedwait(&cond_, &(lock.mutex_->nativeHandle_), &timeout); in WaitFor()
|
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service_profiler/ |
H A D | rs_profiler_socket.cpp | 35 timeval timeout = {}; in GetTimeoutDesc() local 36 timeout.tv_sec = milliseconds / millisecondsInSecond; in GetTimeoutDesc() 38 return timeout; in GetTimeoutDesc() 43 timeval timeout = {}; in GetTimeout() local 44 socklen_t size = sizeof(timeout); in GetTimeout() 46 return timeout; in GetTimeout() 49 static void SetTimeout(int32_t socket, const timeval& timeout) in SetTimeout() argument 51 …sockopt(socket, SOL_SOCKET, SO_SNDTIMEO, reinterpret_cast<const char*>(&timeout), sizeof(timeout)); in SetTimeout() 226 const uint32_t timeout = size / bandwitdth + timeoutPad; in ReceiveWhenReady() local 229 SetTimeout(client_, timeout); in ReceiveWhenReady() [all …]
|
/ohos5.0/base/telephony/ril_adapter/services/hril/src/ |
H A D | hril_event.cpp | 50 …"next = %{public}ds + %{public}dus", (int32_t)eventIt->timeout.tv_sec, (int32_t)eventIt->timeout.t… in GetNextTimeOut() 51 if (timercmp(&eventIt->timeout, &now, >)) { in GetNextTimeOut() 52 timersub(&eventIt->timeout, &now, &tv); in GetNextTimeOut() 74 evMsg.timeout = eventIt->timeout; in ProcessTimerList() 91 eventMsg->timeout = eventIt->timeout; in HasEventMessageFromPendingList() 162 timeradd(&now, &tv, &eventMsg.timeout); in AddTimerEvent() 166 if (timercmp(&it->timeout, &eventMsg.timeout, >)) { in AddTimerEvent() 224 struct timeval timeout; in EventMessageLoop() local 230 if (!GetNextTimeOut(timeout)) { in EventMessageLoop() 236 …"Setting timeout for %{public}ds + %{public}dus", (int32_t)timeout.tv_sec, (int32_t)timeout.tv_use… in EventMessageLoop() [all …]
|
H A D | hril_timer_callback.cpp | 71 struct timeval timeout; in HRilSetTimerCallbackInfo() local 81 (void)memset_s(&timeout, sizeof(timeout), 0, sizeof(timeout)); in HRilSetTimerCallbackInfo() 83 (void)memcpy_s(&timeout, sizeof(timeout), tv, sizeof(timeout)); in HRilSetTimerCallbackInfo() 90 event_->AddTimerEvent(eventMsg, timeout); in HRilSetTimerCallbackInfo()
|
/ohos5.0/base/hiviewdfx/faultloggerd/test/unittest/common/ |
H A D | common_cutil_test.cpp | 119 uint64_t timeout; variable 124 ParseSiValue(&si, &timeout, &tid); 126 ASSERT_EQ(timeout, 0); 130 ParseSiValue(&si, &timeout, &tid); 134 ASSERT_EQ(timeout, 0); 140 ASSERT_EQ(timeout, 100); 144 ParseSiValue(&si, &timeout, &tid); 146 ASSERT_EQ(timeout, 0); 150 ParseSiValue(&si, &timeout, &tid); 152 ASSERT_EQ(timeout, data & ~(1ULL << flagOffset));
|
/ohos5.0/foundation/ability/ability_runtime/services/abilitymgr/src/ |
H A D | ability_event_handler.cpp | 78 uint32_t timeout = event.GetTimeout(); in ProcessLoadTimeOut() local 79 if (timeout == 0) { in ProcessLoadTimeOut() 80 timeout = 3000; // 3000 : default timeout in ProcessLoadTimeOut() 84 eventWrap.SetTimeout(timeout); in ProcessLoadTimeOut() 85 SendEvent(eventWrap, timeout); in ProcessLoadTimeOut() 112 uint32_t timeout = event.GetTimeout(); in ProcessForegroundTimeOut() local 113 if (timeout == 0) { in ProcessForegroundTimeOut() 114 timeout = 3000; // 3000 : default timeout in ProcessForegroundTimeOut() 119 eventWrap.SetTimeout(timeout); in ProcessForegroundTimeOut() 120 SendEvent(eventWrap, timeout); in ProcessForegroundTimeOut()
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/ |
H A D | happy_eyeballs.rs | 36 timeout: Option<Duration>, field 46 timeout: Option<Duration>, field 101 Self { timeout, delay } in new() 106 fn new(addrs: Vec<SocketAddr>, timeout: Option<Duration>) -> Self { in new() 109 timeout, in new() 116 match connect(addr, self.timeout).await { in connect() 144 .timeout in new() 159 .timeout in new() 167 .timeout in new() 236 timeout: Option<Duration>, in connect() [all …]
|
/ohos5.0/foundation/arkui/ace_engine/frameworks/core/gestures/ |
H A D | timeout_gesture.cpp | 20 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()
|
/ohos5.0/drivers/hdf_core/adapter/platform/watchdog/ |
H A D | watchdog_stm32f4xx.c | 28 int timeout; // Maximum interval between watchdog feeding, unit: ms member 67 device->timeout = HCS_PROP(node, timeout); \ 115 HDF_LOGI("timeout = %dms\n", device->timeout); in GetWatchdogDeviceInfoResource() 253 int32_t timeout = 0; local 263 timeout = watchdogdeviceinfo->timeout; 265 if (timeout < WATCHDOG_MIN_TIMEOUT) { 267 timeout = WATCHDOG_MIN_TIMEOUT; 269 if (timeout > WATCHDOG_MAX_TIMEOUT) { 271 timeout = WATCHDOG_MAX_TIMEOUT; 313 watchdogdeviceinfo->timeout = seconds; [all …]
|
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/ |
H A D | event_impl.cpp | 22 EventImpl::EventImpl(EventTime timeout) in EventImpl() argument 25 timeout_(timeout), in EventImpl() 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() 313 void EventImpl::SetTimeoutPeriod(EventTime timeout) in SetTimeoutPeriod() argument 315 if (timeout < 0) { in SetTimeoutPeriod() 318 timeout_ = timeout; in SetTimeoutPeriod() [all …]
|
H A D | ievent.cpp | 22 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() argument 45 if ((events & ET_TIMEOUT) && (timeout < 0)) { in CreateEvent() 52 IEvent *event = new (std::nothrow) EventImpl(fd, events, timeout); in CreateEvent()
|
/ohos5.0/base/startup/init/services/param/linux/ |
H A D | param_request.c | 107 if (diff >= timeout) { in ReadMessage() 129 static int GetClientSocket(int timeout) in GetClientSocket() argument 132 time.tv_sec = timeout; in GetClientSocket() 157 if (timeout <= 0) { in StartRequest() 199 ret = StartRequest(g_clientFd, request, timeout); in SystemSetParameter_() 257 if (timeout <= 0) { in SystemWaitParameter() 258 timeout = DEFAULT_PARAM_WAIT_TIMEOUT; in SystemWaitParameter() 280 *((uint32_t *)(content->content)) = timeout; in SystemWaitParameter() 286 timeout = 1; in SystemWaitParameter() 288 int fd = GetClientSocket(timeout); in SystemWaitParameter() [all …]
|
/ohos5.0/docs/en/application-dev/reference/apis-ability-kit/ |
H A D | js-apis-inner-application-loopObserver.md | 3 …timeout. It can be used as an input parameter in [ErrorManager.on](./js-apis-app-ability-errorMana… 17 onLoopTimeOut?(timeout: number): void 19 Called when a timeout occurs for the main thread to process an event in the JS runtime. 29 | timeout | number | Yes| Actual execution time of the main thread.| 37 onLoopTimeOut(timeout: number) { 38 console.log('Duration timeout: ' + timeout);
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
H A D | timeout.rs | 24 pub(crate) timeout: Option<Pin<Box<Sleep>>>, 29 pub(crate) fn new(future: T, timeout: Duration) -> Self { in new() 31 timeout: Some(Box::pin(sleep(timeout))), in new() 46 if let Some(delay) = this.timeout.as_mut() { in poll() 53 response.body_mut().set_sleep(this.timeout.take()); in poll() 71 use crate::async_impl::timeout::TimeoutFuture; 109 timeout: None, in ut_timeout_future() 114 timeout: None, in ut_timeout_future()
|
/ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr/adapter/cmsis/ |
H A D | queue_adapter.c | 26 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()
|
/ohos5.0/foundation/multimedia/audio_framework/services/audio_service/common/src/ |
H A D | futex_tool.cpp | 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), N… in FutexWait() 81 timeout, res, errno, strerror(errno)); in FutexWait()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
H A D | timeout.rs | 44 pub fn timeout<F>(duration: Duration, future: F) -> Timeout<F> in timeout() function 73 let timeout = unsafe { self.get_unchecked_mut() }; in poll() localVariable 75 let value = unsafe { Pin::new_unchecked(&mut timeout.value) }; in poll() 80 let sleep = unsafe { Pin::new_unchecked(&mut timeout.sleep) }; in poll() 92 use crate::time::timeout; 110 timeout(Duration::from_millis(10), rx).await.is_ok() in ut_timeout_test() 117 timeout(Duration::from_millis(10), rx).await.is_ok() in ut_timeout_test() 137 let result = timeout(Duration::from_millis(100), async { 1 }).await; in ut_timeout_test_002()
|
/ohos5.0/base/usb/usb_manager/test/native/js_unittest/ |
H A D | UsbDevicePipeJsunit.test.js | 359 function callControlTransfer(pip, controlParam, timeout, caseName) { 360 usb.controlTransfer(pip, controlParam, timeout).then(data => { 385 var timeout = 5000; 404 var timeout = 5000; 423 var timeout = 5000; 442 var timeout = 5000; 461 var timeout = 5000; 480 var timeout = 5000; 499 var timeout = 5000; 518 var timeout = 5000; [all …]
|
/ohos5.0/foundation/multimodalinput/input/util/socket/test/ |
H A D | uds_socket_test.cpp | 99 int32_t timeout = -1; variable 102 int32_t retResult = socObj.EpollWait(*events, MAX_EVENT_SIZE, timeout); 109 int32_t timeout = 1001; variable 112 int32_t retResult = socObj.EpollWait(*events, MAX_EVENT_SIZE, timeout); 119 int32_t timeout = -1001; variable 122 int32_t retResult = socObj.EpollWait(*events, MAX_EVENT_SIZE, timeout); 129 int32_t timeout = -1001; variable 132 int32_t retResult = socObj.EpollWait(*events, MAX_EVENT_SIZE, timeout);
|
/ohos5.0/foundation/multimedia/media_foundation/engine/include/foundation/osal/thread/ |
H A D | condition_variable.h | 58 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()
|
/ohos5.0/foundation/multimedia/player_framework/services/utils/include/ |
H A D | player_xcollie.h | 28 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) 47 id_ = PlayerXCollie::GetInstance().SetTimer(name, recovery, timeout); 50 XcollieTimer(const std::string &name, uint32_t timeout) in XcollieTimer() argument 52 id_ = PlayerXCollie::GetInstance().SetTimerByLog(name, timeout); in XcollieTimer()
|
/ohos5.0/docs/zh-cn/application-dev/reference/apis-ability-kit/ |
H A D | js-apis-inner-application-loopObserver.md | 17 onLoopTimeOut?(timeout: number): void 29 | timeout | number | 是 | 返回应用主线程消息实际执行时间。 | 37 onLoopTimeOut(timeout: number) { 38 console.log('Duration timeout: ' + timeout);
|
/ohos5.0/foundation/multimedia/media_foundation/engine/foundation/osal/thread/ |
H A D | condition_variable.cpp | 93 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()
|
/ohos5.0/docs/en/device-dev/subsystems/ |
H A D | subsys-dfx-hicollie.md | 6 …u locate software timeout faults resulting from system service deadlock, application main thread b… 24 …timeout, std::function<void(void*)> func, void *arg, unsigned int flag) | Adds timers.<br>In… 25 …teTimer(int id, unsigned int timeout) | Updates timers.<br>Input arguments:<br>- **id**: timer ID.…
|
/ohos5.0/docs/zh-cn/device-dev/reference/hdi-apis/usb/ |
H A D | _o_h_o_s_1_1_u_s_b_1_1_usbd_client.md | 149 int32_t UsbdClient::BulkTransferRead (const UsbDev & dev, const UsbPipe & pipe, int32_t timeout, st… 165 | timeout | 输入参数,超时时间。 | 194 | timeout | 输入参数,超时时间。 | 521 …InterruptTransferRead (const UsbDev & dev, const UsbPipe & pipe, int32_t timeout, std::vector< uin… 537 | timeout | 输入参数,超时时间。 | 566 | timeout | 输入参数,超时时间。 | 579 int32_t UsbdClient::IsoTransferRead (const UsbDev & dev, const UsbPipe & pipe, int32_t timeout, std… 595 | timeout | 输入参数,超时时间。 | 608 int32_t UsbdClient::IsoTransferWrite (const UsbDev & dev, const UsbPipe & pipe, int32_t timeout, st… 624 | timeout | 输入参数,超时时间。 | [all …]
|