Lines Matching defs:queues
45 struct auxtrace_queues queues;
474 queue = &etmq->etm->queues.queue_array[etmq->queue_nr];
778 * Pass tid = -1 to process all queues. But likely they will have
843 struct auxtrace_queues *queues = &aux->queues;
845 for (i = 0; i < queues->nr_queues; i++) {
846 cs_etm__free_queue(queues->queue_array[i].priv);
847 queues->queue_array[i].priv = NULL;
850 auxtrace_queues__free(queues);
1151 * queues before looking for another timestamp packet, either
1163 * queues of each etmq, redenring and decoding can start in
1327 queue = &etmq->etm->queues.queue_array[etmq->queue_nr];
2511 struct auxtrace_queues *queues = &etm->queues;
2513 for (i = 0; i < queues->nr_queues; i++) {
2514 struct auxtrace_queue *queue = &etm->queues.queue_array[i];
2549 * start processing in time order across all queues.
2551 for (i = 0; i < etm->queues.nr_queues; i++) {
2552 etmq = etm->queues.queue_array[i].priv;
2569 queue = &etm->queues.queue_array[queue_nr];
2625 * encountered on any of the traceID queues. Since we
2628 * flush all traceID queues.
2774 * Find all buffers with same reference in the queues and dump them.
2775 * This is because the queues can contain multiple entries of the same
2778 for (i = 0; i < etm->queues.nr_queues; ++i)
2779 list_for_each_entry(buf, &etm->queues.queue_array[i].head, list)
2781 cs_etm__dump_event(etm->queues.queue_array[i].priv, buf);
2807 err = auxtrace_queues__add_event(&etm->queues, session,
2818 err = cs_etm__setup_queue(etm, &etm->queues.queue_array[idx],
2825 cs_etm__dump_event(etm->queues.queue_array[idx].priv, buffer);
2921 * Puts a fragment of an auxtrace buffer into the auxtrace queues based
3017 err = auxtrace_queues__add_event(&etm->queues, session, &auxtrace_fragment,
3024 return cs_etm__setup_queue(etm, &etm->queues.queue_array[idx],
3305 err = auxtrace_queues__init(&etm->queues);
3401 etm->data_queued = etm->queues.populated;
3405 auxtrace_queues__free(&etm->queues);