Searched refs:queue_init (Results 1 – 7 of 7) sorted by relevance
161 static struct queue *queue_init(void) in queue_init() function288 wa[i].q = queue_init(); in spawn_workers()
174 struct queue *queue_init(int size) in queue_init() function2303 to_reader = queue_init(max_files + data_buffer_size); in initialise_threads()2304 to_inflate = queue_init(max_files + data_buffer_size); in initialise_threads()2305 to_writer = queue_init(max_files * 2 + data_buffer_size); in initialise_threads()2319 to_reader = queue_init(all_buffers_size); in initialise_threads()2320 to_inflate = queue_init(all_buffers_size); in initialise_threads()2321 to_writer = queue_init(all_buffers_size * 2); in initialise_threads()2324 from_writer = queue_init(1); in initialise_threads()
175 extern struct queue *queue_init(int);
39 struct queue *queue_init(int size) in queue_init() function
4463 to_reader = queue_init(1); in initialise_threads()4464 to_deflate = queue_init(reader_size); in initialise_threads()4465 to_process_frag = queue_init(reader_size); in initialise_threads()4466 to_writer = queue_init(bwriter_size + fwriter_size); in initialise_threads()4467 from_writer = queue_init(1); in initialise_threads()4468 to_frag = queue_init(fragment_size); in initialise_threads()4469 locked_fragment = queue_init(fragment_size); in initialise_threads()
53 void queue_init(queue* q) { in queue_init() function176 queue_init(&m->q); in test_new()
195 void queue_init(queue *q) {