opensm/complib/cl_event_wheel.c

65 	cl_event_wheel_t *p_event_wheel = (cl_event_wheel_t *) context;
75 	if (p_event_wheel->closing)
80 	if (NULL != p_event_wheel->p_external_lock)
85 		cl_spinlock_acquire(p_event_wheel->p_external_lock);
87 	cl_spinlock_acquire(&p_event_wheel->lock);
89 	p_list_item = cl_qlist_head(&p_event_wheel->events_wheel);
90 	if (p_list_item == cl_qlist_end(&p_event_wheel->events_wheel))
114 			cl_qmap_remove_item(&p_event_wheel->events_map,
118 			cl_qlist_remove_head(&p_event_wheel->events_wheel);
131 			cl_qlist_remove_head(&p_event_wheel->events_wheel);
135 			    cl_qlist_find_from_tail(&p_event_wheel->
141 			cl_qlist_insert_next(&p_event_wheel->events_wheel,
147 			    cl_qlist_head(&p_event_wheel->events_wheel);
152 		if (p_list_item == cl_qlist_end(&p_event_wheel->events_wheel))
163 	if (p_list_item != cl_qlist_end(&p_event_wheel->events_wheel)) {
175 		cl_status = cl_timer_start(&p_event_wheel->timer, new_timeout);
184 	cl_spinlock_release(&p_event_wheel->lock);
185 	if (NULL != p_event_wheel->p_external_lock)
186 		cl_spinlock_release(p_event_wheel->p_external_lock);
192 void cl_event_wheel_construct(IN cl_event_wheel_t * const p_event_wheel)
194 	cl_spinlock_construct(&(p_event_wheel->lock));
195 	cl_timer_construct(&(p_event_wheel->timer));
199 cl_event_wheel_init(IN cl_event_wheel_t * const p_event_wheel)
204 	p_event_wheel->p_external_lock = NULL;
205 	p_event_wheel->closing = FALSE;
206 	cl_status = cl_spinlock_init(&(p_event_wheel->lock));
209 	cl_qlist_init(&p_event_wheel->events_wheel);
210 	cl_qmap_init(&p_event_wheel->events_map);
213 	cl_status = cl_timer_init(&p_event_wheel->timer, __cl_event_wheel_callback, p_event_wheel);	/* cb context */
219 cl_event_wheel_init_ex(IN cl_event_wheel_t * const p_event_wheel,
224 	cl_status = cl_event_wheel_init(p_event_wheel);
228 	p_event_wheel->p_external_lock = p_external_lock;
232 void cl_event_wheel_dump(IN cl_event_wheel_t * const p_event_wheel)
237 	p_list_item = cl_qlist_head(&p_event_wheel->events_wheel);
239 	while (p_list_item != cl_qlist_end(&p_event_wheel->events_wheel)) {
250 void cl_event_wheel_destroy(IN cl_event_wheel_t * const p_event_wheel)
257 	cl_spinlock_acquire(&p_event_wheel->lock);
259 	cl_event_wheel_dump(p_event_wheel);
262 	p_list_item = cl_qlist_remove_head(&p_event_wheel->events_wheel);
263 	while (p_list_item != cl_qlist_end(&p_event_wheel->events_wheel)) {
273 		cl_qmap_remove_item(&p_event_wheel->events_map, p_map_item);
276 		    cl_qlist_remove_head(&p_event_wheel->events_wheel);
280 	cl_timer_destroy(&p_event_wheel->timer);
284 	cl_spinlock_release(&p_event_wheel->lock);
285 	cl_spinlock_destroy(&(p_event_wheel->lock));
289 cl_event_wheel_reg(IN cl_event_wheel_t * const p_event_wheel,
303 	cl_spinlock_acquire(&(p_event_wheel->lock));
305 	cl_event_wheel_dump(p_event_wheel);
308 	p_map_item = cl_qmap_get(&p_event_wheel->events_map, key);
309 	if (p_map_item != cl_qmap_end(&p_event_wheel->events_map)) {
319 		cl_qlist_remove_item(&p_event_wheel->events_wheel,
322 		cl_qmap_remove_item(&p_event_wheel->events_map,
343 	if (cl_is_qlist_empty(&p_event_wheel->events_wheel)) {
360 		 * to TRUE and then blocks on p_event_wheel->lock. Following this,
364 		 * cl_timer_stop(&p_event_wheel->timer);
377 		cl_status = cl_timer_start(&p_event_wheel->timer, to);
389 	    cl_qlist_find_from_tail(&p_event_wheel->events_wheel,
393 	cl_qlist_insert_next(&p_event_wheel->events_wheel,
396 	cl_qmap_insert(&p_event_wheel->events_map, key, &(p_event->map_item));
399 	cl_spinlock_release(&p_event_wheel->lock);
405 cl_event_wheel_unreg(IN cl_event_wheel_t * const p_event_wheel, IN uint64_t key)
412 	cl_spinlock_acquire(&p_event_wheel->lock);
413 	p_map_item = cl_qmap_get(&p_event_wheel->events_map, key);
414 	if (p_map_item != cl_qmap_end(&p_event_wheel->events_map)) {
421 		cl_qlist_remove_item(&p_event_wheel->events_wheel,
424 		cl_qmap_remove_item(&p_event_wheel->events_map,
437 	cl_spinlock_release(&p_event_wheel->lock);
441 cl_event_wheel_num_regs(IN cl_event_wheel_t * const p_event_wheel,
453 	cl_spinlock_acquire(&p_event_wheel->lock);
454 	p_map_item = cl_qmap_get(&p_event_wheel->events_map, key);
455 	if (p_map_item != cl_qmap_end(&p_event_wheel->events_map)) {
463 	cl_spinlock_release(&p_event_wheel->lock);
470 void __cl_event_wheel_dump(IN cl_event_wheel_t * const p_event_wheel)
478 	       cl_qlist_count(&p_event_wheel->events_wheel));
480 	p_list_item = cl_qlist_head(&p_event_wheel->events_wheel);
481 	while (p_list_item != cl_qlist_end(&p_event_wheel->events_wheel)) {
494 	       cl_qmap_count(&p_event_wheel->events_map));
496 	p_map_item = cl_qmap_head(&p_event_wheel->events_map);
497 	while (p_map_item != cl_qmap_end(&p_event_wheel->events_map)) {