opensm/complib/cl_event.c

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