Lines Matching refs:qe
894 ret = ordered_events__queue(top->qe.in, event, last_timestamp, 0, NULL); in perf_top__mmap_read_idx()
900 if (top->qe.rotate) { in perf_top__mmap_read_idx()
901 mutex_lock(&top->qe.mutex); in perf_top__mmap_read_idx()
902 top->qe.rotate = false; in perf_top__mmap_read_idx()
903 cond_signal(&top->qe.cond); in perf_top__mmap_read_idx()
904 mutex_unlock(&top->qe.mutex); in perf_top__mmap_read_idx()
1084 struct ordered_events *in = top->qe.in; in rotate_queues()
1086 if (top->qe.in == &top->qe.data[1]) in rotate_queues()
1087 top->qe.in = &top->qe.data[0]; in rotate_queues()
1089 top->qe.in = &top->qe.data[1]; in rotate_queues()
1099 struct ordered_events *out, *in = top->qe.in; in process_thread()
1108 mutex_lock(&top->qe.mutex); in process_thread()
1109 top->qe.rotate = true; in process_thread()
1110 cond_wait(&top->qe.cond, &top->qe.mutex); in process_thread()
1111 mutex_unlock(&top->qe.mutex); in process_thread()
1135 static int deliver_event(struct ordered_events *qe, in deliver_event() argument
1138 struct perf_top *top = qe->data; in deliver_event()
1220 ordered_events__init(&top->qe.data[0], deliver_event, top); in init_process_thread()
1221 ordered_events__init(&top->qe.data[1], deliver_event, top); in init_process_thread()
1222 ordered_events__set_copy_on_queue(&top->qe.data[0], true); in init_process_thread()
1223 ordered_events__set_copy_on_queue(&top->qe.data[1], true); in init_process_thread()
1224 top->qe.in = &top->qe.data[0]; in init_process_thread()
1225 mutex_init(&top->qe.mutex); in init_process_thread()
1226 cond_init(&top->qe.cond); in init_process_thread()
1231 ordered_events__free(&top->qe.data[0]); in exit_process_thread()
1232 ordered_events__free(&top->qe.data[1]); in exit_process_thread()
1233 mutex_destroy(&top->qe.mutex); in exit_process_thread()
1234 cond_destroy(&top->qe.cond); in exit_process_thread()
1365 cond_signal(&top->qe.cond); in __cmd_top()