Lines Matching refs:queue
303 // separate queue.
306 fixed_queue_t *queue = fixed_queue_new(SIZE_MAX);
309 alarm_register_processing_queue(queue, thread);
319 alarm_set_on_queue(alarms[i], 100, ordered_cb, INT_TO_PTR(i), queue);
334 alarm_unregister_processing_queue(queue);
335 fixed_queue_free(queue, NULL);
339 // Test whether unregistering a processing queue cancels all timers using
340 // that queue.
343 fixed_queue_t *queue = fixed_queue_new(SIZE_MAX);
347 alarm_register_processing_queue(queue, thread);
358 alarm_set_on_queue(alarms[i], 100, ordered_cb, INT_TO_PTR(i), queue);
361 alarm_set_on_queue(alarms[i], 1000 * 1000, ordered_cb, INT_TO_PTR(i), queue);
380 alarm_unregister_processing_queue(queue);
393 fixed_queue_free(queue, NULL);
397 // Test whether unregistering a processing queue cancels all periodic timers
398 // using that queue.
401 fixed_queue_t *queue = fixed_queue_new(SIZE_MAX);
405 alarm_register_processing_queue(queue, thread);
416 alarm_set_on_queue(alarms[i], 20 + i, cb, INT_TO_PTR(i), queue);
432 alarm_unregister_processing_queue(queue);
451 fixed_queue_free(queue, NULL);