Lines Matching refs:queues
221 int auxtrace_queues__init(struct auxtrace_queues *queues) in auxtrace_queues__init() argument
223 queues->nr_queues = AUXTRACE_INIT_NR_QUEUES; in auxtrace_queues__init()
224 queues->queue_array = auxtrace_alloc_queue_array(queues->nr_queues); in auxtrace_queues__init()
225 if (!queues->queue_array) in auxtrace_queues__init()
230 static int auxtrace_queues__grow(struct auxtrace_queues *queues, in auxtrace_queues__grow() argument
233 unsigned int nr_queues = queues->nr_queues; in auxtrace_queues__grow()
243 if (nr_queues < queues->nr_queues || nr_queues < new_nr_queues) in auxtrace_queues__grow()
250 for (i = 0; i < queues->nr_queues; i++) { in auxtrace_queues__grow()
251 list_splice_tail(&queues->queue_array[i].head, in auxtrace_queues__grow()
253 queue_array[i].tid = queues->queue_array[i].tid; in auxtrace_queues__grow()
254 queue_array[i].cpu = queues->queue_array[i].cpu; in auxtrace_queues__grow()
255 queue_array[i].set = queues->queue_array[i].set; in auxtrace_queues__grow()
256 queue_array[i].priv = queues->queue_array[i].priv; in auxtrace_queues__grow()
259 queues->nr_queues = nr_queues; in auxtrace_queues__grow()
260 queues->queue_array = queue_array; in auxtrace_queues__grow()
287 static int auxtrace_queues__queue_buffer(struct auxtrace_queues *queues, in auxtrace_queues__queue_buffer() argument
294 if (idx >= queues->nr_queues) { in auxtrace_queues__queue_buffer()
295 err = auxtrace_queues__grow(queues, idx + 1); in auxtrace_queues__queue_buffer()
300 queue = &queues->queue_array[idx]; in auxtrace_queues__queue_buffer()
308 buffer->buffer_nr = queues->next_buffer_nr++; in auxtrace_queues__queue_buffer()
312 queues->new_data = true; in auxtrace_queues__queue_buffer()
313 queues->populated = true; in auxtrace_queues__queue_buffer()
321 static int auxtrace_queues__split_buffer(struct auxtrace_queues *queues, in auxtrace_queues__split_buffer() argument
336 err = auxtrace_queues__queue_buffer(queues, idx, b); in auxtrace_queues__split_buffer()
359 static int auxtrace_queues__add_buffer(struct auxtrace_queues *queues, in auxtrace_queues__add_buffer() argument
384 err = auxtrace_queues__split_buffer(queues, idx, buffer); in auxtrace_queues__add_buffer()
389 err = auxtrace_queues__queue_buffer(queues, idx, buffer); in auxtrace_queues__add_buffer()
404 int auxtrace_queues__add_event(struct auxtrace_queues *queues, in auxtrace_queues__add_event() argument
420 return auxtrace_queues__add_buffer(queues, session, idx, &buffer, in auxtrace_queues__add_event()
424 static int auxtrace_queues__add_indexed_event(struct auxtrace_queues *queues, in auxtrace_queues__add_indexed_event() argument
444 err = auxtrace_queues__add_event(queues, session, event, in auxtrace_queues__add_indexed_event()
451 void auxtrace_queues__free(struct auxtrace_queues *queues) in auxtrace_queues__free() argument
455 for (i = 0; i < queues->nr_queues; i++) { in auxtrace_queues__free()
456 while (!list_empty(&queues->queue_array[i].head)) { in auxtrace_queues__free()
459 buffer = list_entry(queues->queue_array[i].head.next, in auxtrace_queues__free()
466 zfree(&queues->queue_array); in auxtrace_queues__free()
467 queues->nr_queues = 0; in auxtrace_queues__free()
989 static int auxtrace_queues__process_index_entry(struct auxtrace_queues *queues, in auxtrace_queues__process_index_entry() argument
993 return auxtrace_queues__add_indexed_event(queues, session, in auxtrace_queues__process_index_entry()
997 int auxtrace_queues__process_index(struct auxtrace_queues *queues, in auxtrace_queues__process_index() argument
1011 err = auxtrace_queues__process_index_entry(queues, in auxtrace_queues__process_index()
1037 struct auxtrace_queue *auxtrace_queues__sample_queue(struct auxtrace_queues *queues, in auxtrace_queues__sample_queue() argument
1055 if (idx >= queues->nr_queues) in auxtrace_queues__sample_queue()
1058 return &queues->queue_array[idx]; in auxtrace_queues__sample_queue()
1061 int auxtrace_queues__add_sample(struct auxtrace_queues *queues, in auxtrace_queues__add_sample() argument
1087 return auxtrace_queues__add_buffer(queues, session, idx, &buffer, NULL); in auxtrace_queues__add_sample()