Lines Matching refs:p_event

45 void cl_event_construct(IN cl_event_t * p_event)  in cl_event_construct()  argument
47 CL_ASSERT(p_event); in cl_event_construct()
49 p_event->state = CL_UNINITIALIZED; in cl_event_construct()
52 cl_status_t cl_event_init(IN cl_event_t * const p_event, in cl_event_init() argument
55 CL_ASSERT(p_event); in cl_event_init()
57 cl_event_construct(p_event); in cl_event_init()
59 pthread_cond_init(&p_event->condvar, NULL); in cl_event_init()
60 pthread_mutex_init(&p_event->mutex, NULL); in cl_event_init()
61 p_event->signaled = FALSE; in cl_event_init()
62 p_event->manual_reset = manual_reset; in cl_event_init()
63 p_event->state = CL_INITIALIZED; in cl_event_init()
68 void cl_event_destroy(IN cl_event_t * const p_event) in cl_event_destroy() argument
70 CL_ASSERT(cl_is_state_valid(p_event->state)); in cl_event_destroy()
73 if (p_event->state == CL_INITIALIZED) { in cl_event_destroy()
74 pthread_cond_broadcast(&p_event->condvar); in cl_event_destroy()
75 pthread_cond_destroy(&p_event->condvar); in cl_event_destroy()
76 pthread_mutex_destroy(&p_event->mutex); in cl_event_destroy()
79 p_event->state = CL_UNINITIALIZED; in cl_event_destroy()
82 cl_status_t cl_event_signal(IN cl_event_t * const p_event) in cl_event_signal() argument
85 CL_ASSERT(p_event->state == CL_INITIALIZED); in cl_event_signal()
87 pthread_mutex_lock(&p_event->mutex); in cl_event_signal()
88 p_event->signaled = TRUE; in cl_event_signal()
90 if (p_event->manual_reset) in cl_event_signal()
91 pthread_cond_broadcast(&p_event->condvar); in cl_event_signal()
93 pthread_cond_signal(&p_event->condvar); in cl_event_signal()
95 pthread_mutex_unlock(&p_event->mutex); in cl_event_signal()
100 cl_status_t cl_event_reset(IN cl_event_t * const p_event) in cl_event_reset() argument
103 CL_ASSERT(p_event->state == CL_INITIALIZED); in cl_event_reset()
105 pthread_mutex_lock(&p_event->mutex); in cl_event_reset()
106 p_event->signaled = FALSE; in cl_event_reset()
107 pthread_mutex_unlock(&p_event->mutex); in cl_event_reset()
112 cl_status_t cl_event_wait_on(IN cl_event_t * const p_event, in cl_event_wait_on() argument
122 CL_ASSERT(p_event->state == CL_INITIALIZED); in cl_event_wait_on()
124 pthread_mutex_lock(&p_event->mutex); in cl_event_wait_on()
127 if (p_event->signaled) { in cl_event_wait_on()
128 if (!p_event->manual_reset) in cl_event_wait_on()
129 p_event->signaled = FALSE; in cl_event_wait_on()
131 pthread_mutex_unlock(&p_event->mutex); in cl_event_wait_on()
137 pthread_mutex_unlock(&p_event->mutex); in cl_event_wait_on()
143 if (pthread_cond_wait(&p_event->condvar, &p_event->mutex)) in cl_event_wait_on()
156 wait_ret = pthread_cond_timedwait(&p_event->condvar, in cl_event_wait_on()
157 &p_event->mutex, in cl_event_wait_on()
161 (p_event-> in cl_event_wait_on()
170 if (!p_event->manual_reset) in cl_event_wait_on()
171 p_event->signaled = FALSE; in cl_event_wait_on()
173 pthread_mutex_unlock(&p_event->mutex); in cl_event_wait_on()