Home
last modified time | relevance | path

Searched refs:waitTime (Results 1 - 25 of 95) sorted by relevance

1234

/foundation/communication/ipc/ipc/native/src/core/source/
H A Dmessage_option.cpp20 MessageOption::MessageOption(int flags, int waitTime) : flags_(static_cast<uint32_t>(flags)), waitTime_(waitTime) {} in MessageOption() argument
31 void MessageOption::SetWaitTime(int waitTime) in SetWaitTime() argument
33 if (waitTime <= 0) { in SetWaitTime()
35 } else if (waitTime > MAX_WAIT_TIME) { in SetWaitTime()
38 waitTime_ = waitTime; in SetWaitTime()
/foundation/window/window_manager/wm/test/unittest/
H A Dpattern_detach_callback_test.cpp68 auto waitTime = endTime - startTime; in HWTEST_F() local
69 GTEST_LOG_(INFO) << "GetResult waitTime:" << waitTime; in HWTEST_F()
70 ASSERT_TRUE(waitTime >= maxWaitTime); in HWTEST_F()
91 auto waitTime = endTime - startTime; in HWTEST_F() local
92 GTEST_LOG_(INFO) << "GetResultAndOnPatternDetach waitTime:" << waitTime; in HWTEST_F()
93 ASSERT_TRUE(waitTime >= sleepTime && waitTime < maxWaitTime); in HWTEST_F()
114 auto waitTime in HWTEST_F() local
[all...]
/foundation/systemabilitymgr/samgr_lite/samgr/adapter/cmsis/
H A Dqueue_adapter.c28 uint32_t waitTime = (timeout <= 0) ? 0 : (uint32_t)timeout; in QUEUE_Put() local
29 osStatus_t ret = osMessageQueuePut(queueId, element, pri, waitTime); in QUEUE_Put()
38 uint32_t waitTime = (timeout <= 0) ? osWaitForever : (uint32_t)timeout; in QUEUE_Pop() local
39 osStatus_t evt = osMessageQueueGet(queueId, element, pri, waitTime); in QUEUE_Pop()
/foundation/communication/ipc/ipc/native/src/jni/source/
H A Dohos_rpc_message_option.cpp67 void JavaOhosRpcMessageOptionSetWaitTime(JNIEnv *env, jobject object, int waitTime) in JavaOhosRpcMessageOptionSetWaitTime() argument
69 ZLOGD(LABEL, "waitTime:%{public}s", waitTime); in JavaOhosRpcMessageOptionSetWaitTime()
71 env->SetIntField(object, g_jMessageOption.waitTimeField, waitTime); in JavaOhosRpcMessageOptionSetWaitTime()
78 jobject JavaOhosRpcMessageOptionNewJavaObject(JNIEnv *env, int flags, int waitTime) in JavaOhosRpcMessageOptionNewJavaObject() argument
83 option = env->NewObject(g_jMessageOption.klazz, g_jMessageOption.initMethod, flags, waitTime); in JavaOhosRpcMessageOptionNewJavaObject()
95 int waitTime = JavaOhosRpcMessageOptionGetWaitTime(env, object); in JavaOhosRpcMessageOptionGetNative() local
98 option->SetWaitTime(waitTime); in JavaOhosRpcMessageOptionGetNative()
/foundation/communication/ipc/utils/src/
H A Drpc_session_handle.c25 static int32_t GetWaitTime(struct timespec *waitTime) in GetWaitTime() argument
33 waitTime->tv_sec = now.tv_sec + CONNECT_WAIT_TIME_SECONDS; in GetWaitTime()
34 waitTime->tv_nsec = now.tv_usec * USECTONSEC; in GetWaitTime()
95 struct timespec waitTime; in WaitForSessionIdReady() local
96 if (GetWaitTime(&waitTime) != ERR_NONE) { in WaitForSessionIdReady()
102 &sessionIdObject->mutex, &waitTime) == ETIMEDOUT) { in WaitForSessionIdReady()
/foundation/graphic/graphic_2d/rosen/modules/platform/ipc_core/
H A Dmessage_option.cpp19 MessageOption::MessageOption(int flags, int waitTime) {} in MessageOption() argument
30 void MessageOption::SetWaitTime(int waitTime) in SetWaitTime() argument
H A Dmessage_option.h30 MessageOption(int flags = TF_SYNC, int waitTime = TF_WAIT_TIME);
34 void SetWaitTime(int waitTime);
/foundation/resourceschedule/ffrt/src/dfx/trace_record/
H A Dffrt_trace_record.h36 std::atomic<uint64_t> waitTime{0};
148 auto waitTime = task->executeTime - task->createTime; in TaskDone() local
149 g_recordTaskTime_[taskType][qos].waitTime += waitTime; in TaskDone()
150 if (g_recordTaskTime_[taskType][qos].maxWaitTime < waitTime) { in TaskDone()
151 g_recordTaskTime_[taskType][qos].maxWaitTime = waitTime; in TaskDone()
H A Dffrt_trace_record.cpp59 << std::setw(COLUMN_WIDTH_16) << (g_recordTaskTime_[ffrt_normal_task][i].waitTime/doneCount) in DumpNormalTaskStatisticInfo()
61 << std::setw(COLUMN_WIDTH_18) << g_recordTaskTime_[ffrt_normal_task][i].waitTime in DumpNormalTaskStatisticInfo()
89 << std::setw(COLUMN_WIDTH_16) << (g_recordTaskTime_[ffrt_queue_task][i].waitTime/doneCount) in DumpQueueTaskStatisticInfo()
91 << std::setw(COLUMN_WIDTH_18) << g_recordTaskTime_[ffrt_queue_task][i].waitTime in DumpQueueTaskStatisticInfo()
/foundation/multimedia/av_codec/services/media_engine/modules/sink/
H A Dvideo_sink.cpp66 void VideoSink::UpdateTimeAnchorIfNeeded(int64_t nowCt, int64_t waitTime, in UpdateTimeAnchorIfNeeded() argument
78 syncCenter->UpdateTimeAnchor(nowCt + waitTime, latency, iMediaTime, this); in UpdateTimeAnchorIfNeeded()
97 int64_t waitTime = 0; in DoSyncWrite() local
108 waitTime = CheckBufferLatenessMayWait(buffer); in DoSyncWrite()
110 UpdateTimeAnchorIfNeeded(nowCt, waitTime, buffer); in DoSyncWrite()
119 if ((render && waitTime >= 0) || lastFrameDropped_) { in DoSyncWrite()
122 return waitTime > 0 ? waitTime : 0; in DoSyncWrite()
/foundation/window/window_manager/test/fuzztest/dms/displaymanageripc_fuzzer/
H A Ddisplaymanageripc_fuzzer.cpp65 int flags, waitTime; in IPCFuzzTest() local
66 if (data == nullptr || size < sizeof(code) + sizeof(flags) + sizeof(waitTime)) { in IPCFuzzTest()
76 startPos += GetObject<int>(waitTime, data + startPos, size - startPos); in IPCFuzzTest()
79 MessageOption option(flags, waitTime); in IPCFuzzTest()
191 int flags, waitTime; in IPCInterfaceFuzzTest() local
192 if (data == nullptr || size < sizeof(flags) + sizeof(waitTime)) { in IPCInterfaceFuzzTest()
201 startPos += GetObject<int>(waitTime, data + startPos, size - startPos); in IPCInterfaceFuzzTest()
204 MessageOption option(flags, waitTime); in IPCInterfaceFuzzTest()
/foundation/window/window_manager/test/fuzztest/wms/windowipc_fuzzer/
H A Dwindowipc_fuzzer.cpp64 int flags, waitTime; in IPCFuzzTest() local
65 if (data == nullptr || size < sizeof(code) + sizeof(flags) + sizeof(waitTime)) { in IPCFuzzTest()
75 startPos += GetObject<int>(waitTime, data + startPos, size - startPos); in IPCFuzzTest()
78 MessageOption option(flags, waitTime); in IPCFuzzTest()
154 int flags, waitTime; in IPCInterfaceFuzzTest() local
155 if (data == nullptr || size < sizeof(flags) + sizeof(waitTime)) { in IPCInterfaceFuzzTest()
164 startPos += GetObject<int>(waitTime, data + startPos, size - startPos); in IPCInterfaceFuzzTest()
167 MessageOption option(flags, waitTime); in IPCInterfaceFuzzTest()
/foundation/communication/ipc/ipc/native/src/napi/src/
H A Dnapi_message_option.cpp148 int32_t waitTime = 0; in NapiOhosRpcMessageOptionSetWaittime() local
149 napi_status status = napi_get_value_int32(env, argv[ARGV_INDEX_0], &waitTime); in NapiOhosRpcMessageOptionSetWaittime()
154 option->SetWaitTime(waitTime); in NapiOhosRpcMessageOptionSetWaittime()
168 int waitTime = 0; in NAPIMessageOption_JS_Constructor() local
171 waitTime = MessageOption::TF_WAIT_TIME; in NAPIMessageOption_JS_Constructor()
185 waitTime = MessageOption::TF_WAIT_TIME; in NAPIMessageOption_JS_Constructor()
197 waitTime = jsWaitTime; in NAPIMessageOption_JS_Constructor()
200 auto messageOption = new MessageOption(flags, waitTime); in NAPIMessageOption_JS_Constructor()
/foundation/communication/ipc/ipc/native/src/jni/include/
H A Dohos_rpc_message_option.h42 void JavaOhosRpcMessageOptionSetWaitTime(JNIEnv *env, jobject object, int waitTime);
47 jobject JavaOhosRpcMessageOptionNewJavaObject(JNIEnv *env, int flags, int waitTime);
/foundation/communication/ipc/interfaces/innerkits/ipc_core/include/
H A Dmessage_option.h31 MessageOption(int flags = TF_SYNC, int waitTime = TF_WAIT_TIME);
51 * @param waitTime Indicates the wait time to set.
55 void SetWaitTime(int waitTime);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dstorage_engine.cpp134 StorageExecutor *StorageEngine::FindExecutor(bool writable, OperatePerm perm, int &errCode, int waitTime) in FindExecutor() argument
144 bool result = initCondition_.wait_for(lock, std::chrono::seconds(waitTime), [this]() { in FindExecutor()
155 return FindWriteExecutor(perm, errCode, waitTime); in FindExecutor()
158 return FindReadExecutor(perm, errCode, waitTime); in FindExecutor()
161 StorageExecutor *StorageEngine::FindWriteExecutor(OperatePerm perm, int &errCode, int waitTime) in FindWriteExecutor() argument
170 if (waitTime <= 0) { // non-blocking. in FindWriteExecutor()
178 bool result = writeCondition_.wait_for(lock, std::chrono::seconds(waitTime), in FindWriteExecutor()
197 StorageExecutor *StorageEngine::FindReadExecutor(OperatePerm perm, int &errCode, int waitTime) in FindReadExecutor() argument
206 if (waitTime <= 0) { // non-blocking. in FindReadExecutor()
215 bool result = readCondition_.wait_for(lock, std::chrono::seconds(waitTime), in FindReadExecutor()
[all...]
H A Dstorage_engine.h50 StorageExecutor *FindExecutor(bool writable, OperatePerm perm, int &errCode, int waitTime = MAX_WAIT_TIME);
137 StorageExecutor *FindWriteExecutor(OperatePerm perm, int &errCode, int waitTime);
138 StorageExecutor *FindReadExecutor(OperatePerm perm, int &errCode, int waitTime);
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/src/
H A Ddatashare_helper.cpp78 const sptr<IRemoteObject> &token, const std::string &strUri, const std::string &extUri, const int waitTime) in Creator()
98 helper = CreateExtHelper(ext, token, waitTime); in Creator()
100 helper = CreateExtHelper(uri, token, waitTime); in Creator()
106 const std::string &bundleName, const int waitTime) in Creator()
114 return options.isProxy_ ? CreateServiceHelper("", bundleName) : CreateExtHelper(uri, options.token_, waitTime); in Creator()
118 const std::string &strUri, const std::string &extUri, const int waitTime) in Create()
145 auto helper = CreateExtHelper(uri, token, waitTime); in Create()
179 const int waitTime) in CreateExtHelper()
181 sptr<DataShareConnection> connection = new (std::nothrow) DataShareConnection(uri, token, waitTime); in CreateExtHelper()
77 Creator( const sptr<IRemoteObject> &token, const std::string &strUri, const std::string &extUri, const int waitTime) Creator() argument
105 Creator(const string &strUri, const CreateOptions &options, const std::string &bundleName, const int waitTime) Creator() argument
117 Create(const sptr<IRemoteObject> &token, const std::string &strUri, const std::string &extUri, const int waitTime) Create() argument
178 CreateExtHelper(Uri &uri, const sptr<IRemoteObject> &token, const int waitTime) CreateExtHelper() argument
/foundation/multimedia/audio_framework/services/audio_service/common/src/
H A Dfutex_tool.cpp55 struct timespec waitTime; in FutexWait() local
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()
/foundation/communication/dsoftbus/core/connection/br/src/
H A Dsoftbus_conn_br_send_queue.c145 SoftBusSysTime waitTime = {0}; in ConnBrDequeueBlock() local
146 int32_t ret = SoftBusGetTime(&waitTime); in ConnBrDequeueBlock()
148 waitTime.sec += BR_WAIT_TIME_SEC; in ConnBrDequeueBlock()
175 int32_t ret = SoftBusCondWait(&g_sendCond, &g_brQueueLock, &waitTime); in ConnBrDequeueBlock()
/foundation/communication/dsoftbus/core/connection/ble/src/
H A Dsoftbus_conn_ble_send_queue.c139 SoftBusSysTime waitTime = {0}; in ConnBleDequeueBlock() local
140 int32_t ret = SoftBusGetTime(&waitTime); in ConnBleDequeueBlock()
142 waitTime.sec += BLE_WAIT_TIME_SEC; in ConnBleDequeueBlock()
168 int32_t ret = SoftBusCondWait(&g_sendCond, &g_bleQueueLock, &waitTime); in ConnBleDequeueBlock()
/foundation/arkui/ace_engine_lite/frameworks/tools/qt/simulator/jsfwk/targets/simulator/mock/amsthread/
H A Dams_thread.h42 const uint32_t waitTime = 20; in ~JSAppRecord() local
44 QThread::msleep(waitTime); in ~JSAppRecord()
/foundation/distributeddatamgr/data_share/frameworks/native/consumer/include/
H A Ddatashare_connection.h35 DataShareConnection(const Uri &uri, const sptr<IRemoteObject> &token, int32_t waitTime = 2) : uri_(uri), in DataShareConnection()
36 token_(token), waitTime_(waitTime) {} in DataShareConnection()
/foundation/multimedia/player_framework/services/services/monitor/server/
H A Dmonitor_server.cpp275 int32_t waitTime; in MonitorThread() local
301 waitTime = static_cast<int32_t>(GetTimeMS() - timeStart); in MonitorThread()
304 MEDIA_LOGD("pid %{public}d, waitTime %{public}d, timeout %{public}d, trigger %{public}d", in MonitorThread()
305 it->first, waitTime, it->second.time, it->second.triggerFlag); in MonitorThread()
309 it->second.time -= waitTime; in MonitorThread()
/foundation/window/window_manager/test/fuzztest/window_scene/sessioninterface_fuzzer/
H A Dsessioninterface_fuzzer.cpp89 int waitTime = source.GetObject<int>(); in IPCFuzzTest() local
93 MessageOption option(flags, waitTime); in IPCFuzzTest()
169 int waitTime = source.GetObject<int>(); in IPCInterfaceFuzzTest() local
173 MessageOption option(flags, waitTime); in IPCInterfaceFuzzTest()

Completed in 11 milliseconds

1234