| /foundation/resourceschedule/ffrt/src/sync/ |
| H A D | wait_queue.cpp | 49 const TimePoint& tp, bool legacyMode, CPUEUTask* task) in ThreadWaitUntil()
63 if (wn->cv.wait_until(nl, tp) == std::cv_status::timeout) { in ThreadWaitUntil()
122 bool WaitQueue::SuspendAndWaitUntil(mutexPrivate* lk, const TimePoint& tp) noexcept
128 return ThreadWaitUntil(&ctx->wn, lk, tp, LegacyMode(task), task);
132 task->wue->tp = tp;
151 if (DelayedWakeup(we->tp, we, we->cb)) {
182 if (!DelayedRemove(we->tp, dwe)) { in WeNotifyProc()
48 ThreadWaitUntil(WaitUntilEntry* wn, mutexPrivate* lk, const TimePoint& tp, bool legacyMode, CPUEUTask* task) ThreadWaitUntil() argument
|
| H A D | condition_variable.cpp | 93 auto tp = ffrt::TimePoint { in ffrt_cond_timedwait() local
97 return pc->SuspendAndWaitUntil(pm, tp) ? ffrt_error_timedout : ffrt_success; in ffrt_cond_timedwait()
|
| H A D | wait_queue.h | 69 bool SuspendAndWaitUntil(mutexPrivate* lk, const TimePoint& tp) noexcept;
94 bool ThreadWaitUntil(WaitUntilEntry* wn, mutexPrivate* lk, const TimePoint& tp, bool legacyMode, CPUEUTask* task);
|
| /foundation/graphic/graphic_3d/lume/metaobject/src/ |
| H A D | proxy_object.cpp | 147 if (auto tp = target->GetPropertyByName(p.first)) { in RefreshProperties()
149 res.first->second.Bind(tp); in RefreshProperties()
204 if (auto tp = GetPointer<IObject>(p)) { in ReflectTargetForProperty()
205 proxy->SetTarget(tp); in ReflectTargetForProperty()
263 IProperty::Ptr ProxyObject::AddProxyProperty(const IProperty::ConstPtr& tp) in AddProxyProperty() argument
265 auto p = DuplicatePropertyType(META_NS::GetObjectRegistry(), tp); in AddProxyProperty()
268 res.first->second.Bind(tp); in AddProxyProperty()
278 if (auto tp = target->GetPropertyByName(name)) { in AddProxyProperty()
279 p = AddProxyProperty(tp); in AddProxyProperty()
|
| /foundation/resourceschedule/ffrt/interfaces/kits/cpp/ |
| H A D | condition_variable.h | 51 std::unique_lock<mutex>& lk, const std::chrono::time_point<Clock, Duration>& tp, Pred&& pred) noexcept
54 if (wait_until(lk, tp) == cv_status::timeout) {
62 cv_status wait_until(std::unique_lock<mutex>& lk, const std::chrono::time_point<Clock, Duration>& tp) noexcept
64 return _wait_for(lk, tp - Clock::now());
|
| /foundation/resourceschedule/ffrt/src/util/ |
| H A D | time_format.h | 39 auto tp = std::chrono::time_point_cast<std::chrono::microseconds>(timePoint);
in FormatDateString() local
40 auto us = tp.time_since_epoch().count() % UsPerSecond;
in FormatDateString()
46 auto tp = std::chrono::time_point_cast<std::chrono::milliseconds>(timePoint);
in FormatDateString() local
47 auto ms = tp.time_since_epoch().count() % MsPerSecond;
in FormatDateString()
|
| H A D | worker_monitor.cpp | 106 watchdogWaitEntry_.tp = std::chrono::steady_clock::now() + std::chrono::microseconds(MONITOR_SAMPLING_CYCLE_US); in SubmitSamplingTask()
108 if (!DelayedWakeup(watchdogWaitEntry_.tp, &watchdogWaitEntry_, watchdogWaitEntry_.cb)) { in SubmitSamplingTask()
118 memReleaseWaitEntry_.tp = std::chrono::steady_clock::now() + std::chrono::microseconds(TIMEOUT_MEMSHRINK_CYCLE_US); in SubmitMemReleaseTask()
146 if (!DelayedWakeup(memReleaseWaitEntry_.tp, &memReleaseWaitEntry_, memReleaseWaitEntry_.cb)) { in SubmitMemReleaseTask()
|
| /foundation/resourceschedule/ffrt/test/ut/testcase/ |
| H A D | delay_work_deinit_test.cpp | 60 g_delayWorkerThreadTestWe.tp = delay; in SendDelayedWorker()
62 DelayedWorker::GetInstance().dispatch(g_delayWorkerThreadTestWe.tp, in SendDelayedWorker()
|
| /foundation/communication/netstack/frameworks/native/http/http_client/ |
| H A D | http_client_time.cpp | 59 auto tp = std::chrono::system_clock::from_time_t(std::mktime(&tm)); in GetNowTimeGMT() local
61 auto tmp = std::chrono::duration_cast<std::chrono::seconds>(tp.time_since_epoch()); in GetNowTimeGMT()
|
| /foundation/distributeddatamgr/kv_store/test/fuzztest/taskscheduler_fuzzer/ |
| H A D | taskscheduler_fuzzer.cpp | 29 std::chrono::steady_clock::time_point tp = std::chrono::steady_clock::now() + in AtFuzz() local
31 auto task = taskScheduler.At(tp, []() { }); in AtFuzz()
|
| /foundation/resourceschedule/ffrt/src/queue/ |
| H A D | queue_monitor.cpp | 64 while (!DelayedRemove(we_->tp, we_) && !abortSendTimer_.load()) { in ~QueueMonitor()
150 we_->tp = delay; in SendDelayedWorker()
153 bool result = DelayedWakeup(we_->tp, we_, we_->cb); in SendDelayedWorker()
157 we_->tp = GetDelayedTimeStamp(ALLOW_TIME_ACC_ERROR_US); in SendDelayedWorker()
158 result = DelayedWakeup(we_->tp, we_, we_->cb); in SendDelayedWorker()
|
| H A D | queue_handler.cpp | 300 timeoutWe_->tp = std::chrono::time_point_cast<std::chrono::steady_clock::duration>(now + timeout); in SetTimeoutMonitor()
302 if (!DelayedWakeup(timeoutWe_->tp, timeoutWe_, timeoutWe_->cb)) { in SetTimeoutMonitor()
321 if (DelayedRemove(timeoutWe_->tp, dwe)) { in RemoveTimeoutMonitor()
|
| /foundation/resourceschedule/ffrt/src/dfx/watchdog/ |
| H A D | watchdog_util.cpp | 81 we->tp = (now + timeoutTime + delayTime); in SendTimeoutWatchdog()
82 if (!DelayedWakeup(we->tp, we, we->cb)) { in SendTimeoutWatchdog()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/liteos/ |
| H A D | sys_util.c | 86 void ClockGetTime(clockid_t id, struct timespec *tp) in ClockGetTime() argument
88 if (clock_gettime(id, tp) != 0) { in ClockGetTime()
|
| /foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/ |
| H A D | obex_utils.cpp | 223 struct timespec tp; in MakeNonce() local
224 clock_gettime(CLOCK_REALTIME, &tp); in MakeNonce()
227 (void)sprintf_s(secBuf, sizeof(secBuf), "%ld", tp.tv_sec); in MakeNonce()
231 (void)sprintf_s(nsecBuf, sizeof(nsecBuf), "%ld", tp.tv_nsec); in MakeNonce()
|
| /foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/transaction/ |
| H A D | rs_transaction_metric_collector.cpp | 49 auto tp = std::chrono::system_clock::time_point( in MsToString() local
51 std::time_t t = std::chrono::system_clock::to_time_t(tp); in MsToString()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/ |
| H A D | sys_util.c | 139 void ClockGetTime(clockid_t id, struct timespec *tp) in ClockGetTime() argument
141 if (clock_gettime(id, tp) != 0) { in ClockGetTime()
|
| /foundation/resourceschedule/ffrt/src/sched/ |
| H A D | load_tracking.h | 38 std::chrono::time_point<std::chrono::steady_clock> tp; member
|
| H A D | execute_ctx.h | 78 TimePoint tp; member
|
| /foundation/multimodalinput/input/service/module_loader/src/ |
| H A D | mmi_service.cpp | 662 TOUCHPOINT tp; in PointerEventHandler() local
663 tp.InKeyboard = insideVKeyboardArea; in PointerEventHandler()
664 // When track pad is integrated the tp should be set as tp.InTrackpad = insideVTrackPadArea; in PointerEventHandler()
665 tp.ScreenX = physicalX; in PointerEventHandler()
666 tp.ScreenY = physicalY; in PointerEventHandler()
667 tp.TouchId = pointerId; in PointerEventHandler()
669 tp.TipDown = (pointerAction != MMI::PointerEvent::POINTER_ACTION_UP); in PointerEventHandler()
682 bayesianengine_mapTouchToButton_(tp.ScreenX, tp in PointerEventHandler()
[all...] |
| /foundation/resourceschedule/ffrt/interfaces/inner_api/cpp/ |
| H A D | future.h | 51 future_status wait_until(const std::chrono::time_point<Clock, Duration>& tp) const noexcept
54 return m_cv.wait_until(lk, tp, [this] { return get_derived().has_value(); }) ? future_status::ready :
187 future_status wait_until(const std::chrono::time_point<Clock, Duration>& tp) const noexcept
189 return m_state->wait_until(tp);
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/interface/ |
| H A D | nstackx_util.h | 60 NSTACKX_EXPORT void ClockGetTime(clockid_t id, struct timespec *tp);
|
| /foundation/ability/dmsfwk/services/dtbschedmgr/src/distributedWant/ |
| H A D | distributed_want.cpp | 112 auto tp = AAFwk::WantParams::GetDataType(it->second); in DistributedWant() local
113 if ((tp == DistributedWantParams::VALUE_TYPE_BOOLEAN) || in DistributedWant()
114 (tp == DistributedWantParams::VALUE_TYPE_BYTE) || in DistributedWant()
115 (tp == DistributedWantParams::VALUE_TYPE_CHAR) || in DistributedWant()
116 (tp == DistributedWantParams::VALUE_TYPE_SHORT) || in DistributedWant()
117 (tp == DistributedWantParams::VALUE_TYPE_INT) || in DistributedWant()
118 (tp == DistributedWantParams::VALUE_TYPE_LONG) || in DistributedWant()
119 (tp == DistributedWantParams::VALUE_TYPE_FLOAT) || in DistributedWant()
120 (tp == DistributedWantParams::VALUE_TYPE_DOUBLE) || in DistributedWant()
121 (tp in DistributedWant()
[all...] |
| /foundation/multimodalinput/input/service/touch_event_normalize/test/src/ |
| H A D | transform_point_test.cpp | 140 struct input_event* tp = sp + nevents; in SendEvents() local
141 for (; sp < tp; ++sp) { in SendEvents()
148 return (sp >= tp); in SendEvents()
|
| /foundation/window/window_manager/window_scene/screen_session_manager/src/fold_screen_controller/ |
| H A D | dual_display_fold_policy.cpp | 315 std::string tp = MAIN_TP; in ChangeScreenDisplayModeInner() local
317 tp = SUB_TP; in ChangeScreenDisplayModeInner()
320 RSInterfaces::GetInstance().SetTpFeatureConfig(TP_TYPE, tp.c_str()); in ChangeScreenDisplayModeInner()
|