| /kernel/liteos_m/testsuites/unittest/fuzz/src/semaphore/ |
| D | sem_timedwait_fuzz.c | 53 struct timespec absTimeout; in SemTimedWaitFuzzTest() local
66 absTimeout.tv_sec = (*(int *)DT_SetGetS32(&g_element[elemSecIndex], 0)) % SEC_MODE_VALUE; in SemTimedWaitFuzzTest()
67 absTimeout.tv_nsec = (*(int *)DT_SetGetS32(&g_element[elemNsecIndex], 0) % NSEC_MODE_VALUE); in SemTimedWaitFuzzTest()
77 sem_timedwait(&sem, &absTimeout); in SemTimedWaitFuzzTest()
|
| /kernel/liteos_a/syscall/ |
| D | ipc_syscall.c | 151 const struct timespec *absTimeout) in SysMqTimedSend() argument
157 if (absTimeout != NULL) { in SysMqTimedSend()
158 ret = LOS_ArchCopyFromUser(&timeout, absTimeout, sizeof(struct timespec)); in SysMqTimedSend()
176 ret = mq_timedsend(personal, msgIntr, msgLen, msgPrio, absTimeout ? &timeout : NULL); in SysMqTimedSend()
185 const struct timespec *absTimeout) in SysMqTimedReceive() argument
192 if (absTimeout != NULL) { in SysMqTimedReceive()
193 ret = LOS_ArchCopyFromUser(&timeout, absTimeout, sizeof(struct timespec)); in SysMqTimedReceive()
206 … receiveLen = mq_timedreceive(personal, msgIntr, msgLen, &kMsgPrio, absTimeout ? &timeout : NULL); in SysMqTimedReceive()
|
| D | los_syscall.h | 129 const struct timespec *absTimeout);
131 const struct timespec *absTimeout);
|
| /kernel/liteos_m/kal/posix/src/ |
| D | pthread_mutex.c | 329 int pthread_mutex_timedlock(pthread_mutex_t *mutex, const struct timespec *absTimeout) in pthread_mutex_timedlock() argument
346 …if ((absTimeout == NULL) || (absTimeout->tv_nsec < 0) || (absTimeout->tv_nsec >= OS_SYS_NS_PER_SEC… in pthread_mutex_timedlock()
369 …timeoutNs = (absTimeout->tv_sec - curTime.tv_sec) * OS_SYS_NS_PER_SECOND + (absTimeout->tv_nsec - … in pthread_mutex_timedlock()
|
| D | mqueue.c | 490 STATIC INT32 ConvertTimeout(long flags, const struct timespec *absTimeout, UINT64 *ticks) in ConvertTimeout() argument
497 if (absTimeout == NULL) { in ConvertTimeout()
502 if (!ValidTimeSpec(absTimeout)) { in ConvertTimeout()
507 *ticks = OsTimeSpec2Tick(absTimeout); in ConvertTimeout()
535 const struct timespec *absTimeout) in mq_timedsend() argument
557 …OS_MQ_GOTO_ERROUT_UNLOCK_IF(ConvertTimeout(privateMqPersonal->mq_flags, absTimeout, &absTicks) == … in mq_timedsend()
573 const struct timespec *absTimeout) in mq_timedreceive() argument
607 if (ConvertTimeout(privateMqPersonal->mq_flags, absTimeout, &absTicks) == -1) { in mq_timedreceive()
|
| /kernel/liteos_m/kal/libc/newlib/porting/include/ |
| D | mqueue.h | 56 … unsigned *__restrict msg_prio, const struct timespec *__restrict absTimeout);
57 …t personal, const char *msg, size_t msg_len, unsigned msg_prio, const struct timespec *absTimeout);
|
| /kernel/liteos_m/testsuites/sample/posix/mqueue/ |
| D | It_posix_queue_018.c | 41 struct timespec absTimeout = {0}; in Testcase() local
53 ret = mq_timedsend(mqueue, "1234567890123456789", QUEUE_MSG_SIZE, 0, &absTimeout); in Testcase()
|
| /kernel/liteos_a/compat/posix/include/ |
| D | mqueue.h | 385 unsigned int msgPrio, const struct timespec *absTimeout);
427 unsigned int *msgPrio, const struct timespec *absTimeout);
|
| /kernel/liteos_a/testsuites/unittest/libc/posix/mqueue/smoke/ |
| D | It_posix_queue_028.cpp | 42 struct timespec absTimeout = {0}; in Testcase() local
54 ret = mq_timedsend(mqueue, "1234567890123456789", queue_msg_size, 0, &absTimeout); in Testcase()
|
| /kernel/liteos_a/compat/posix/src/ |
| D | mqueue.c | 704 STATIC INT32 ConvertTimeout(long flags, const struct timespec *absTimeout, UINT64 *ticks) in ConvertTimeout() argument
711 if (absTimeout == NULL) { in ConvertTimeout()
716 if (!ValidTimeSpec(absTimeout)) { in ConvertTimeout()
721 *ticks = OsTimeSpec2Tick(absTimeout); in ConvertTimeout()
778 const struct timespec *absTimeout) in mq_timedsend() argument
800 …OS_MQ_GOTO_ERROUT_UNLOCK_IF(ConvertTimeout(privateMqPersonal->mq_flags, absTimeout, &absTicks) == … in mq_timedsend()
820 const struct timespec *absTimeout) in mq_timedreceive() argument
854 if (ConvertTimeout(privateMqPersonal->mq_flags, absTimeout, &absTicks) == -1) { in mq_timedreceive()
|