Lines Matching refs:timeout
558 static rt_err_t _rt_sem_take(rt_sem_t sem, rt_int32_t timeout, int suspend_flag) in _rt_sem_take() argument
589 if (timeout == 0) in _rt_sem_take()
615 if (timeout > 0) in _rt_sem_take()
622 &timeout); in _rt_sem_take()
1326 static rt_err_t _rt_mutex_take(rt_mutex_t mutex, rt_int32_t timeout, int suspend_flag) in _rt_mutex_take() argument
1388 if (timeout == 0) in _rt_mutex_take()
1434 if (timeout > 0) in _rt_mutex_take()
1442 &timeout); in _rt_mutex_take()
2099 rt_int32_t timeout, in _rt_event_recv() argument
2162 else if (timeout == 0) in _rt_event_recv()
2187 if (timeout > 0) in _rt_event_recv()
2192 &timeout); in _rt_event_recv()
2225 rt_int32_t timeout, in rt_event_recv() argument
2228 return _rt_event_recv(event, set, option, timeout, recved, RT_UNINTERRUPTIBLE); in rt_event_recv()
2235 rt_int32_t timeout, in rt_event_recv_interruptible() argument
2238 return _rt_event_recv(event, set, option, timeout, recved, RT_INTERRUPTIBLE); in rt_event_recv_interruptible()
2245 rt_int32_t timeout, in rt_event_recv_killable() argument
2248 return _rt_event_recv(event, set, option, timeout, recved, RT_KILLABLE); in rt_event_recv_killable()
2565 rt_int32_t timeout, in _rt_mb_send_wait() argument
2578 RT_DEBUG_SCHEDULER_AVAILABLE(timeout != 0); in _rt_mb_send_wait()
2591 if (mb->entry == mb->size && timeout == 0) in _rt_mb_send_wait()
2604 if (timeout == 0) in _rt_mb_send_wait()
2622 if (timeout > 0) in _rt_mb_send_wait()
2633 &timeout); in _rt_mb_send_wait()
2651 if (timeout > 0) in _rt_mb_send_wait()
2654 timeout -= tick_delta; in _rt_mb_send_wait()
2655 if (timeout < 0) in _rt_mb_send_wait()
2656 timeout = 0; in _rt_mb_send_wait()
2696 rt_int32_t timeout) in rt_mb_send_wait() argument
2698 return _rt_mb_send_wait(mb, value, timeout, RT_UNINTERRUPTIBLE); in rt_mb_send_wait()
2704 rt_int32_t timeout) in rt_mb_send_wait_interruptible() argument
2706 return _rt_mb_send_wait(mb, value, timeout, RT_INTERRUPTIBLE); in rt_mb_send_wait_interruptible()
2712 rt_int32_t timeout) in rt_mb_send_wait_killable() argument
2714 return _rt_mb_send_wait(mb, value, timeout, RT_KILLABLE); in rt_mb_send_wait_killable()
2845 static rt_err_t _rt_mb_recv(rt_mailbox_t mb, rt_ubase_t *value, rt_int32_t timeout, int suspend_fla… in _rt_mb_recv() argument
2857 RT_DEBUG_SCHEDULER_AVAILABLE(timeout != 0); in _rt_mb_recv()
2869 if (mb->entry == 0 && timeout == 0) in _rt_mb_recv()
2883 if (timeout == 0) in _rt_mb_recv()
2902 if (timeout > 0) in _rt_mb_recv()
2913 &timeout); in _rt_mb_recv()
2931 if (timeout > 0) in _rt_mb_recv()
2934 timeout -= tick_delta; in _rt_mb_recv()
2935 if (timeout < 0) in _rt_mb_recv()
2936 timeout = 0; in _rt_mb_recv()
2974 rt_err_t rt_mb_recv(rt_mailbox_t mb, rt_ubase_t *value, rt_int32_t timeout) in rt_mb_recv() argument
2976 return _rt_mb_recv(mb, value, timeout, RT_UNINTERRUPTIBLE); in rt_mb_recv()
2980 rt_err_t rt_mb_recv_interruptible(rt_mailbox_t mb, rt_ubase_t *value, rt_int32_t timeout) in rt_mb_recv_interruptible() argument
2982 return _rt_mb_recv(mb, value, timeout, RT_INTERRUPTIBLE); in rt_mb_recv_interruptible()
2986 rt_err_t rt_mb_recv_killable(rt_mailbox_t mb, rt_ubase_t *value, rt_int32_t timeout) in rt_mb_recv_killable() argument
2988 return _rt_mb_recv(mb, value, timeout, RT_KILLABLE); in rt_mb_recv_killable()
3380 rt_int32_t timeout, in _rt_mq_send_wait() argument
3398 RT_DEBUG_SCHEDULER_AVAILABLE(timeout != 0); in _rt_mq_send_wait()
3416 if (msg == RT_NULL && timeout == 0) in _rt_mq_send_wait()
3430 if (timeout == 0) in _rt_mq_send_wait()
3447 if (timeout > 0) in _rt_mq_send_wait()
3458 &timeout); in _rt_mq_send_wait()
3476 if (timeout > 0) in _rt_mq_send_wait()
3479 timeout -= tick_delta; in _rt_mq_send_wait()
3480 if (timeout < 0) in _rt_mq_send_wait()
3481 timeout = 0; in _rt_mq_send_wait()
3571 rt_int32_t timeout) in rt_mq_send_wait() argument
3573 return _rt_mq_send_wait(mq, buffer, size, 0, timeout, RT_UNINTERRUPTIBLE); in rt_mq_send_wait()
3580 rt_int32_t timeout) in rt_mq_send_wait_interruptible() argument
3582 return _rt_mq_send_wait(mq, buffer, size, 0, timeout, RT_INTERRUPTIBLE); in rt_mq_send_wait_interruptible()
3589 rt_int32_t timeout) in rt_mq_send_wait_killable() argument
3591 return _rt_mq_send_wait(mq, buffer, size, 0, timeout, RT_KILLABLE); in rt_mq_send_wait_killable()
3762 rt_int32_t timeout, in _rt_mq_recv() argument
3781 RT_DEBUG_SCHEDULER_AVAILABLE(timeout != 0); in _rt_mq_recv()
3792 if (mq->entry == 0 && timeout == 0) in _rt_mq_recv()
3806 if (timeout == 0) in _rt_mq_recv()
3826 if (timeout > 0) in _rt_mq_recv()
3837 &timeout); in _rt_mq_recv()
3856 if (timeout > 0) in _rt_mq_recv()
3859 timeout -= tick_delta; in _rt_mq_recv()
3860 if (timeout < 0) in _rt_mq_recv()
3861 timeout = 0; in _rt_mq_recv()
3923 rt_int32_t timeout) in rt_mq_recv() argument
3925 return _rt_mq_recv(mq, buffer, size, 0, timeout, RT_UNINTERRUPTIBLE); in rt_mq_recv()
3932 rt_int32_t timeout) in rt_mq_recv_interruptible() argument
3934 return _rt_mq_recv(mq, buffer, size, 0, timeout, RT_INTERRUPTIBLE); in rt_mq_recv_interruptible()
3941 rt_int32_t timeout) in rt_mq_recv_killable() argument
3943 return _rt_mq_recv(mq, buffer, size, 0, timeout, RT_KILLABLE); in rt_mq_recv_killable()
3950 rt_int32_t timeout, in rt_mq_send_wait_prio() argument
3953 return _rt_mq_send_wait(mq, buffer, size, prio, timeout, suspend_flag); in rt_mq_send_wait_prio()
3959 rt_int32_t timeout, in rt_mq_recv_prio() argument
3962 return _rt_mq_recv(mq, buffer, size, prio, timeout, suspend_flag); in rt_mq_recv_prio()