opensm/complib/cl_timer.c

126 	cl_timer_t *p_timer;
150 			p_timer =
155 						   &p_timer->timeout);
170 			if (p_timer->timer_state != CL_TIMER_QUEUED)
178 			p_timer->timer_state = CL_TIMER_RUNNING;
182 					     &p_timer->list_item);
185 			p_timer->pfn_callback((void *)p_timer->context);
193 			if (p_timer->timer_state == CL_TIMER_RUNNING)
194 				p_timer->timer_state = CL_TIMER_IDLE;
200 			pthread_cond_signal(&p_timer->cond);
209 void cl_timer_construct(IN cl_timer_t * const p_timer)
211 	memset(p_timer, 0, sizeof(cl_timer_t));
212 	p_timer->state = CL_UNINITIALIZED;
216 cl_timer_init(IN cl_timer_t * const p_timer,
220 	CL_ASSERT(p_timer);
223 	cl_timer_construct(p_timer);
229 	p_timer->pfn_callback = pfn_callback;
230 	p_timer->context = context;
233 	p_timer->timer_state = CL_TIMER_IDLE;
236 	pthread_cond_init(&p_timer->cond, NULL);
238 	p_timer->state = CL_INITIALIZED;
243 void cl_timer_destroy(IN cl_timer_t * const p_timer)
245 	CL_ASSERT(p_timer);
246 	CL_ASSERT(cl_is_state_valid(p_timer->state));
248 	if (p_timer->state == CL_INITIALIZED)
249 		cl_timer_stop(p_timer);
251 	p_timer->state = CL_UNINITIALIZED;
254 	pthread_cond_broadcast(&p_timer->cond);
255 	pthread_cond_destroy(&p_timer->cond);
301 cl_timer_start(IN cl_timer_t * const p_timer, IN const uint32_t time_ms)
307 	CL_ASSERT(p_timer);
308 	CL_ASSERT(p_timer->state == CL_INITIALIZED);
315 	if (p_timer->timer_state == CL_TIMER_QUEUED)
317 				     &p_timer->list_item);
330 	p_timer->timeout.tv_sec = curtime.tv_sec + (delta_time / 1000);
331 	p_timer->timeout.tv_nsec =
338 				     &p_timer->list_item);
342 						      __cl_timer_find, p_timer);
346 				     &p_timer->list_item);
349 	p_timer->timer_state = CL_TIMER_QUEUED;
355 void cl_timer_stop(IN cl_timer_t * const p_timer)
357 	CL_ASSERT(p_timer);
358 	CL_ASSERT(p_timer->state == CL_INITIALIZED);
361 	switch (p_timer->timer_state) {
364 		pthread_cond_wait(&p_timer->cond, &gp_timer_prov->mutex);
366 		if (p_timer->timer_state != CL_TIMER_QUEUED)
371 		p_timer->timer_state = CL_TIMER_IDLE;
374 				     &p_timer->list_item);
389 cl_timer_trim(IN cl_timer_t * const p_timer, IN const uint32_t time_ms)
395 	CL_ASSERT(p_timer);
396 	CL_ASSERT(p_timer->state == CL_INITIALIZED);
408 	if (p_timer->timer_state == CL_TIMER_QUEUED) {
410 		if (__cl_timer_is_earlier(&p_timer->timeout, &newtime)) {
419 	status = cl_timer_start(p_timer, time_ms);