Lines Matching refs:qe
882 ret = ordered_events__queue(top->qe.in, event, last_timestamp, 0); in perf_top__mmap_read_idx()
888 if (top->qe.rotate) { in perf_top__mmap_read_idx()
889 pthread_mutex_lock(&top->qe.mutex); in perf_top__mmap_read_idx()
890 top->qe.rotate = false; in perf_top__mmap_read_idx()
891 pthread_cond_signal(&top->qe.cond); in perf_top__mmap_read_idx()
892 pthread_mutex_unlock(&top->qe.mutex); in perf_top__mmap_read_idx()
1073 struct ordered_events *in = top->qe.in; in rotate_queues()
1075 if (top->qe.in == &top->qe.data[1]) in rotate_queues()
1076 top->qe.in = &top->qe.data[0]; in rotate_queues()
1078 top->qe.in = &top->qe.data[1]; in rotate_queues()
1088 struct ordered_events *out, *in = top->qe.in; in process_thread()
1097 pthread_mutex_lock(&top->qe.mutex); in process_thread()
1098 top->qe.rotate = true; in process_thread()
1099 pthread_cond_wait(&top->qe.cond, &top->qe.mutex); in process_thread()
1100 pthread_mutex_unlock(&top->qe.mutex); in process_thread()
1124 static int deliver_event(struct ordered_events *qe, in deliver_event() argument
1127 struct perf_top *top = qe->data; in deliver_event()
1209 ordered_events__init(&top->qe.data[0], deliver_event, top); in init_process_thread()
1210 ordered_events__init(&top->qe.data[1], deliver_event, top); in init_process_thread()
1211 ordered_events__set_copy_on_queue(&top->qe.data[0], true); in init_process_thread()
1212 ordered_events__set_copy_on_queue(&top->qe.data[1], true); in init_process_thread()
1213 top->qe.in = &top->qe.data[0]; in init_process_thread()
1214 pthread_mutex_init(&top->qe.mutex, NULL); in init_process_thread()
1215 pthread_cond_init(&top->qe.cond, NULL); in init_process_thread()
1333 pthread_cond_signal(&top->qe.cond); in __cmd_top()