projects / lttngtop.git / blob
? search:


8c1a3baf6069508e71e628fbef40bfb28c5c592e
[lttngtop.git] / src / cursesdisplay.c
1 /*
2 * Copyright (C) 2011-2012 Julien Desfossez
3 *
4 * This program is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License Version 2 as
6 * published by the Free Software Foundation;
7 *
8 * This program is distributed in the hope that it will be useful,
9 * but WITHOUT ANY WARRANTY; without even the implied warranty of
10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11 * GNU General Public License for more details.
12 *
13 * You should have received a copy of the GNU General Public License along
14 * with this program; if not, write to the Free Software Foundation, Inc.,
15 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
16 */
17
18 #include <stdio.h>
19 #include <stdlib.h>
20 #include <signal.h>
21 #include <string.h>
22 #include <ncurses.h>
23 #include <panel.h>
24 #include <pthread.h>
25 #include <semaphore.h>
26
27 #include "cursesdisplay.h"
28 #include "lttngtoptypes.h"
29 #include "iostreamtop.h"
30 #include "common.h"
31
32 #define DEFAULT_DELAY 15
33 #define MAX_LINE_LENGTH 50
34 #define MAX_LOG_LINES 4
35
36 /* to prevent concurrent updates of the different windows */
37 sem_t update_display_sem;
38
39 char *termtype;
40 WINDOW *footer, *header, *center, *status;
41 WINDOW *pref_panel_window = NULL;
42 PANEL *pref_panel, *main_panel;
43
44 int pref_panel_visible = 0;
45 int pref_line_selected = 0;
46 int pref_current_sort = 0;
47
48 int last_display_index, currently_displayed_index;
49
50 struct processtop *selected_process = NULL;
51 int selected_ret;
52
53 int selected_line = 0; /* select bar position */
54 int selected_in_list = 0; /* selection relative to the whole list */
55 int list_offset = 0; /* first index in the list to display (scroll) */
56 int nb_log_lines = 0;
57 char log_lines[MAX_LINE_LENGTH * MAX_LOG_LINES + MAX_LOG_LINES];
58
59 int max_elements = 80;
60
61 int toggle_threads = 1;
62 int toggle_pause = -1;
63
64 int max_center_lines;
65 GPtrArray *selected_processes;
66
67 pthread_t keyboard_thread;
68
69 struct header_view cputopview[4];
70 struct header_view iostreamtopview[3];
71 struct header_view fileview[3];
72
73 void reset_ncurses()
74 {
75 curs_set(1);
76 endwin();
77 exit(0);
78 }
79
80 static void handle_sigterm(int signal)
81 {
82 reset_ncurses();
83 }
84
85 void init_screen()
86 {
87 initscr();
88 noecho();
89 halfdelay(DEFAULT_DELAY);
90 nonl();
91 intrflush(stdscr, false);
92 keypad(stdscr, true);
93 curs_set(0);
94
95 if (has_colors()) {
96 start_color();
97 init_pair(1, COLOR_RED, COLOR_BLACK); /* - */
98 init_pair(2, COLOR_GREEN, COLOR_BLACK); /* + */
99 init_pair(3, COLOR_BLACK, COLOR_WHITE); /* keys */
100 init_pair(4, COLOR_WHITE, COLOR_GREEN); /* keys activated */
101 init_pair(5, COLOR_WHITE, COLOR_BLUE); /* select line */
102 init_pair(6, COLOR_WHITE, COLOR_GREEN); /* selected process */
103 }
104 termtype = getenv("TERM");
105 if (!strcmp(termtype, "xterm") || !strcmp(termtype, "xterm-color") ||
106 !strcmp(termtype, "vt220")) {
107 define_key("\033[H", KEY_HOME);
108 define_key("\033[F", KEY_END);
109 define_key("\033OP", KEY_F(1));
110 define_key("\033OQ", KEY_F(2));
111 define_key("\033OR", KEY_F(3));
112 define_key("\033OS", KEY_F(4));
113 define_key("\0330U", KEY_F(6));
114 define_key("\033[11~", KEY_F(1));
115 define_key("\033[12~", KEY_F(2));
116 define_key("\033[13~", KEY_F(3));
117 define_key("\033[14~", KEY_F(4));
118 define_key("\033[16~", KEY_F(6));
119 define_key("\033[17;2~", KEY_F(18));
120 }
121 signal(SIGTERM, handle_sigterm);
122 mousemask(BUTTON1_CLICKED, NULL);
123 refresh();
124 }
125
126 WINDOW *create_window(int height, int width, int startx, int starty)
127 {
128 WINDOW *win;
129 win = newwin(height, width, startx, starty);
130 box(win, 0 , 0);
131 wrefresh(win);
132 return win;
133 }
134
135 WINDOW *create_window_no_border(int height, int width, int startx, int starty)
136 {
137 WINDOW *win;
138 win = newwin(height, width, startx, starty);
139 wrefresh(win);
140 return win;
141 }
142
143 void print_digit(WINDOW *win, int digit)
144 {
145 if (digit < 0) {
146 wattron(win, COLOR_PAIR(1));
147 wprintw(win, "%d", digit);
148 wattroff(win, COLOR_PAIR(1));
149 } else if (digit > 0) {
150 wattron(win, COLOR_PAIR(2));
151 wprintw(win, "+%d", digit);
152 wattroff(win, COLOR_PAIR(2));
153 } else {
154 wprintw(win, "0");
155 }
156 }
157
158 void print_digits(WINDOW *win, int first, int second)
159 {
160 wprintw(win, "(");
161 print_digit(win, first);
162 wprintw(win, ", ");
163 print_digit(win, second);
164 wprintw(win, ")");
165 }
166
167 void print_headers(int line, char *desc, int value, int first, int second)
168 {
169 wattron(header, A_BOLD);
170 mvwprintw(header, line, 4, "%s", desc);
171 wattroff(header, A_BOLD);
172 mvwprintw(header, line, 16, "%d", value);
173 wmove(header, line, 24);
174 print_digits(header, first, second);
175 wmove(header, line, 40);
176 }
177
178 void set_window_title(WINDOW *win, char *title)
179 {
180 wattron(win, A_BOLD);
181 mvwprintw(win, 0, 1, title);
182 wattroff(win, A_BOLD);
183 }
184
185 void print_log(char *str)
186 {
187 int i;
188 int current_line = 1;
189 int current_char = 1;
190 char *tmp, *tmp2;
191 /* rotate the line buffer */
192 if (nb_log_lines >= MAX_LOG_LINES) {
193 tmp = strndup(log_lines, MAX_LINE_LENGTH * MAX_LOG_LINES + MAX_LOG_LINES);
194 tmp2 = strchr(tmp, '\n');
195 memset(log_lines, '\0', strlen(log_lines));
196 strncat(log_lines, tmp2 + 1, strlen(tmp2) - 1);
197 log_lines[strlen(log_lines)] = '\n';
198 log_lines[strlen(log_lines)] = '\0';
199 free(tmp);
200 }
201 nb_log_lines++;
202
203 strncat(log_lines, str, MAX_LINE_LENGTH - 1);
204
205 if (nb_log_lines < MAX_LOG_LINES)
206 log_lines[strlen(log_lines)] = '\n';
207 log_lines[strlen(log_lines)] = '\0';
208
209 werase(status);
210 box(status, 0 , 0);
211 set_window_title(status, "Status");
212 for (i = 0; i < strlen(log_lines); i++) {
213 if (log_lines[i] == '\n') {
214 wmove(status, ++current_line, 1);
215 current_char = 1;
216 } else {
217 mvwprintw(status, current_line, current_char++, "%c",
218 log_lines[i]);
219 }
220 }
221 wrefresh(status);
222 }
223
224 int process_selected(struct processtop *process)
225 {
226 int i;
227 struct processtop *stored_process;
228
229 for (i = 0; i < selected_processes->len; i++) {
230 stored_process = g_ptr_array_index(selected_processes, i);
231 if (!stored_process)
232 return 0;
233 if (stored_process->tid == process->tid)
234 return 1;
235 }
236 return 0;
237 }
238
239 void update_selected_processes()
240 {
241 int i;
242 struct processtop *stored_process;
243
244 if (process_selected(selected_process)) {
245 for (i = 0; i < selected_processes->len; i++) {
246 stored_process = g_ptr_array_index(selected_processes, i);
247 if (!stored_process)
248 return;
249 if (stored_process->tid == selected_process->tid)
250 g_ptr_array_remove(selected_processes,
251 stored_process);
252 print_log("Process removed");
253 }
254 } else {
255 g_ptr_array_add(selected_processes, selected_process);
256 print_log("Process added");
257 }
258 }
259
260 void print_key(WINDOW *win, char *key, char *desc, int toggle)
261 {
262 int pair;
263 if (toggle > 0)
264 pair = 4;
265 else
266 pair = 3;
267 wattron(win, COLOR_PAIR(pair));
268 wprintw(footer, "%s", key);
269 wattroff(win, COLOR_PAIR(pair));
270 wprintw(footer, ":%s", desc);
271 }
272
273 void update_footer()
274 {
275 sem_wait(&update_display_sem);
276 werase(footer);
277 wmove(footer, 1, 1);
278 print_key(footer, "F2", "CPUtop ", current_view == cpu);
279 print_key(footer, "F3", "PerfTop ", current_view == perf);
280 print_key(footer, "F4", "IOTop ", current_view == iostream);
281 print_key(footer, "Enter", "Details ", current_view == process_details);
282 print_key(footer, "Space", "Highlight ", 0);
283 print_key(footer, "q", "Quit ", 0);
284 print_key(footer, "r", "Pref ", 0);
285 print_key(footer, "t", "Threads ", toggle_threads);
286 print_key(footer, "p", "Pause ", toggle_pause);
287
288 wrefresh(footer);
289 sem_post(&update_display_sem);
290 }
291
292 void basic_header()
293 {
294 werase(header);
295 box(header, 0 , 0);
296 set_window_title(header, "Statistics for interval [gathering data...[");
297 wattron(header, A_BOLD);
298 mvwprintw(header, 1, 4, "CPUs");
299 mvwprintw(header, 2, 4, "Threads");
300 mvwprintw(header, 3, 4, "FDs");
301 wattroff(header, A_BOLD);
302 wrefresh(header);
303 }
304
305 struct tm format_timestamp(uint64_t timestamp)
306 {
307 struct tm tm;
308 uint64_t ts_sec = 0, ts_nsec;
309 time_t time_s;
310
311 ts_nsec = timestamp;
312 ts_sec += ts_nsec / NSEC_PER_SEC;
313 ts_nsec = ts_nsec % NSEC_PER_SEC;
314
315 time_s = (time_t) ts_sec;
316
317 localtime_r(&time_s, &tm);
318
319 return tm;
320 }
321
322 static void scale_unit(uint64_t bytes, char *ret)
323 {
324 if (bytes >= 1000000000)
325 sprintf(ret, "%" PRIu64 "G", bytes/1000000000);
326 if (bytes >= 1000000)
327 sprintf(ret, "%" PRIu64 "M", bytes/1000000);
328 else if (bytes >= 1000)
329 sprintf(ret, "%" PRIu64 "K", bytes/1000);
330 else
331 sprintf(ret, "%" PRIu64, bytes);
332 }
333
334 uint64_t total_io()
335 {
336 int i;
337 struct processtop *tmp;
338 uint64_t total = 0;
339
340 for (i = 0; i < data->process_table->len; i++) {
341 tmp = g_ptr_array_index(data->process_table, i);
342 total += tmp->fileread;
343 total += tmp->filewrite;
344 }
345
346 return total;
347 }
348
349 void update_header()
350 {
351 struct tm start, end;
352 uint64_t ts_nsec_start, ts_nsec_end;
353 char io[4];
354
355 ts_nsec_start = data->start % NSEC_PER_SEC;
356 start = format_timestamp(data->start);
357
358 ts_nsec_end = data->end % NSEC_PER_SEC;
359 end = format_timestamp(data->end);
360
361 werase(header);
362 box(header, 0 , 0);
363 set_window_title(header, "Statistics for interval ");
364 wattron(header, A_BOLD);
365
366 wprintw(header, "[%02d:%02d:%02d.%09" PRIu64 ", %02d:%02d:%02d.%09" PRIu64 "[",
367 start.tm_hour, start.tm_min, start.tm_sec, ts_nsec_start,
368 end.tm_hour, end.tm_min, end.tm_sec, ts_nsec_end);
369 mvwprintw(header, 1, 4, "CPUs");
370 wattroff(header, A_BOLD);
371 wprintw(header, "\t%d\t(max/cpu : %0.2f%)", data->cpu_table->len,
372 100.0/data->cpu_table->len);
373 print_headers(2, "Threads", data->nbthreads, data->nbnewthreads,
374 -1*(data->nbdeadthreads));
375 print_headers(3, "FDs", data->nbfiles, data->nbnewfiles,
376 -1*(data->nbclosedfiles));
377 scale_unit(total_io(), io);
378 mvwprintw(header, 3, 43, "%sB/sec", io);
379 wrefresh(header);
380 }
381
382 gint sort_by_cpu_desc(gconstpointer p1, gconstpointer p2)
383 {
384 struct processtop *n1 = *(struct processtop **)p1;
385 struct processtop *n2 = *(struct processtop **)p2;
386 unsigned long totaln1 = n1->totalcpunsec;
387 unsigned long totaln2 = n2->totalcpunsec;
388
389 if (totaln1 < totaln2)
390 return 1;
391 if (totaln1 == totaln2)
392 return 0;
393 return -1;
394 }
395
396 gint sort_by_tid_desc(gconstpointer p1, gconstpointer p2)
397 {
398 struct processtop *n1 = *(struct processtop **)p1;
399 struct processtop *n2 = *(struct processtop **)p2;
400 unsigned long totaln1 = n1->tid;
401 unsigned long totaln2 = n2->tid;
402
403 if (totaln1 < totaln2)
404 return 1;
405 if (totaln1 == totaln2)
406 return 0;
407 return -1;
408 }
409
410 gint sort_by_pid_desc(gconstpointer p1, gconstpointer p2)
411 {
412 struct processtop *n1 = *(struct processtop **)p1;
413 struct processtop *n2 = *(struct processtop **)p2;
414 unsigned long totaln1 = n1->pid;
415 unsigned long totaln2 = n2->pid;
416
417 if (totaln1 < totaln2)
418 return 1;
419 if (totaln1 == totaln2)
420 return 0;
421 return -1;
422 }
423
424 gint sort_by_process_read_desc(gconstpointer p1, gconstpointer p2)
425 {
426 struct processtop *n1 = *(struct processtop **)p1;
427 struct processtop *n2 = *(struct processtop **)p2;
428 unsigned long totaln1 = n1->fileread;
429 unsigned long totaln2 = n2->fileread;
430
431 if (totaln1 < totaln2)
432 return 1;
433 if (totaln1 == totaln2)
434 return 0;
435 return -1;
436 }
437
438 gint sort_by_process_write_desc(gconstpointer p1, gconstpointer p2)
439 {
440 struct processtop *n1 = *(struct processtop **)p1;
441 struct processtop *n2 = *(struct processtop **)p2;
442 unsigned long totaln1 = n1->filewrite;
443 unsigned long totaln2 = n2->filewrite;
444
445 if (totaln1 < totaln2)
446 return 1;
447 if (totaln1 == totaln2)
448 return 0;
449 return -1;
450 }
451
452 gint sort_by_process_total_desc(gconstpointer p1, gconstpointer p2)
453 {
454 struct processtop *n1 = *(struct processtop **)p1;
455 struct processtop *n2 = *(struct processtop **)p2;
456 unsigned long totaln1 = n1->totalfilewrite + n1->totalfileread;
457 unsigned long totaln2 = n2->totalfilewrite + n2->totalfileread;
458
459 if (totaln1 < totaln2)
460 return 1;
461 if (totaln1 == totaln2)
462 return 0;
463 return -1;
464 }
465
466 gint sort_by_file_read_desc(gconstpointer p1, gconstpointer p2)
467 {
468 struct files *n1 = *(struct files **)p1;
469 struct files *n2 = *(struct files **)p2;
470 unsigned long totaln1;
471 unsigned long totaln2;
472
473 totaln1 = n1->read;
474 totaln2 = n2->read;
475
476 if (totaln1 < totaln2)
477 return 1;
478 if (totaln1 == totaln2)
479 return 0;
480 return -1;
481 }
482
483 gint sort_by_file_write_desc(gconstpointer p1, gconstpointer p2)
484 {
485 struct files *n1 = *(struct files **)p1;
486 struct files *n2 = *(struct files **)p2;
487 unsigned long totaln1;
488 unsigned long totaln2;
489
490 totaln1 = n1->write;
491 totaln2 = n2->write;
492
493 if (totaln1 < totaln2)
494 return 1;
495 if (totaln1 == totaln2)
496 return 0;
497 return -1;
498 }
499
500 gint sort_by_file_fd_desc(gconstpointer p1, gconstpointer p2)
501 {
502 struct files *n1 = *(struct files **)p1;
503 struct files *n2 = *(struct files **)p2;
504 unsigned long totaln1;
505 unsigned long totaln2;
506
507 totaln1 = n1->fd;
508 totaln2 = n2->fd;
509
510 if (totaln1 < totaln2)
511 return 1;
512 if (totaln1 == totaln2)
513 return 0;
514 return -1;
515 }
516
517 gint sort_by_cpu_group_by_threads_desc(gconstpointer p1, gconstpointer p2)
518 {
519 struct processtop *n1 = *(struct processtop **)p1;
520 struct processtop *n2 = *(struct processtop **)p2;
521 unsigned long totaln1 = n1->threadstotalcpunsec;
522 unsigned long totaln2 = n2->threadstotalcpunsec;
523
524 if (totaln1 < totaln2)
525 return 1;
526 if (totaln1 == totaln2)
527 return 0;
528 return -1;
529 }
530
531 void update_cputop_display()
532 {
533 int i;
534 int header_offset = 2;
535 struct processtop *tmp;
536 unsigned long elapsed;
537 double maxcputime;
538 int nblinedisplayed = 0;
539 int current_line = 0;
540 int column;
541
542 elapsed = data->end - data->start;
543 maxcputime = elapsed * data->cpu_table->len / 100.0;
544
545 if (cputopview[0].sort == 1)
546 g_ptr_array_sort(data->process_table, sort_by_cpu_desc);
547 else if (cputopview[1].sort == 1)
548 g_ptr_array_sort(data->process_table, sort_by_pid_desc);
549 else if (cputopview[2].sort == 1)
550 g_ptr_array_sort(data->process_table, sort_by_tid_desc);
551 else if (cputopview[3].sort == 1)
552 g_ptr_array_sort(data->process_table, sort_by_cpu_desc);
553 else
554 g_ptr_array_sort(data->process_table, sort_by_cpu_desc);
555
556 set_window_title(center, "CPU Top");
557 wattron(center, A_BOLD);
558 column = 1;
559 for (i = 0; i < 4; i++) {
560 if (cputopview[i].sort) {
561 wattron(center, A_UNDERLINE);
562 pref_current_sort = i;
563 }
564 mvwprintw(center, 1, column, cputopview[i].title);
565 wattroff(center, A_UNDERLINE);
566 column += 10;
567 }
568 wattroff(center, A_BOLD);
569
570 max_center_lines = LINES - 5 - 7 - 1 - header_offset;
571
572 /* iterate the process (thread) list */
573 for (i = list_offset; i < data->process_table->len &&
574 nblinedisplayed < max_center_lines; i++) {
575 tmp = g_ptr_array_index(data->process_table, i);
576 if (tmp->pid != tmp->tid)
577 if (toggle_threads == -1)
578 continue;
579
580 if (process_selected(tmp)) {
581 wattron(center, COLOR_PAIR(6));
582 mvwhline(center, current_line + header_offset, 1, ' ', COLS-3);
583 }
584 if (current_line == selected_line) {
585 selected_process = tmp;
586 wattron(center, COLOR_PAIR(5));
587 mvwhline(center, current_line + header_offset, 1, ' ', COLS-3);
588 }
589 /* CPU(%) */
590 mvwprintw(center, current_line + header_offset, 1, "%1.2f",
591 tmp->totalcpunsec / maxcputime);
592 /* PID */
593 mvwprintw(center, current_line + header_offset, 11, "%d", tmp->pid);
594 /* TID */
595 mvwprintw(center, current_line + header_offset, 21, "%d", tmp->tid);
596 /* NAME */
597 mvwprintw(center, current_line + header_offset, 31, "%s", tmp->comm);
598 wattroff(center, COLOR_PAIR(6));
599 wattroff(center, COLOR_PAIR(5));
600 nblinedisplayed++;
601 current_line++;
602 }
603 }
604
605 gint sort_perf(gconstpointer p1, gconstpointer p2, gpointer key)
606 {
607 struct processtop *n1 = *(struct processtop **) p1;
608 struct processtop *n2 = *(struct processtop **) p2;
609
610 struct perfcounter *tmp1, *tmp2;
611 unsigned long totaln2 = 0;
612 unsigned long totaln1 = 0;
613
614 if (!key)
615 return 0;
616
617 tmp1 = g_hash_table_lookup(n1->perf, key);
618 if (!tmp1)
619 totaln1 = 0;
620 else
621 totaln1 = tmp1->count;
622
623 tmp2 = g_hash_table_lookup(n2->perf, key);
624 if (!tmp2)
625 totaln2 = 0;
626 else
627 totaln2 = tmp2->count;
628
629 if (totaln1 < totaln2)
630 return 1;
631 if (totaln1 == totaln2) {
632 totaln1 = n1->tid;
633 totaln2 = n2->tid;
634 if (totaln1 < totaln2)
635 return 1;
636 return -1;
637 }
638 return -1;
639 }
640
641 void print_key_title(char *key, int line)
642 {
643 wattron(center, A_BOLD);
644 mvwprintw(center, line, 1, "%s", key);
645 mvwprintw(center, line, 30, " ");
646 wattroff(center, A_BOLD);
647 }
648
649 void update_process_details()
650 {
651 unsigned long elapsed;
652 double maxcputime;
653 struct processtop *tmp;
654 struct files *file_tmp;
655 int i, j = 0;
656 char unit[4];
657 char filename_buf[COLS];
658 int line = 1;
659 int column;
660 GPtrArray *newfilearray = g_ptr_array_new();
661 GHashTableIter iter;
662 struct perfcounter *perfn1, *perfn2;
663 gpointer key;
664
665 set_window_title(center, "Process details");
666
667
668 tmp = find_process_tid(data,
669 selected_process->tid,
670 selected_process->comm);
671 elapsed = data->end - data->start;
672 maxcputime = elapsed * data->cpu_table->len / 100.0;
673
674 print_key_title("Name", line++);
675 wprintw(center, "%s", selected_process->comm);
676 print_key_title("TID", line++);
677 wprintw(center, "%d", selected_process->tid);
678 if (!tmp) {
679 print_key_title("Does not exit at this time", 3);
680 return;
681 }
682
683 print_key_title("PID", line++);
684 wprintw(center, "%d", tmp->pid);
685 print_key_title("PPID", line++);
686 wprintw(center, "%d", tmp->ppid);
687 print_key_title("CPU", line++);
688 wprintw(center, "%1.2f %%", tmp->totalcpunsec/maxcputime);
689
690 print_key_title("READ B/s", line++);
691 scale_unit(tmp->fileread, unit);
692 wprintw(center, "%s", unit);
693
694 print_key_title("WRITE B/s", line++);
695 scale_unit(tmp->filewrite, unit);
696 wprintw(center, "%s", unit);
697
698 g_hash_table_iter_init(&iter, global_perf_liszt);
699 while (g_hash_table_iter_next (&iter, &key, (gpointer) &perfn1)) {
700 print_key_title((char *) key, line++);
701 perfn2 = g_hash_table_lookup(tmp->perf, (char *) key);
702 wprintw(center, "%d", perfn2 ? perfn2->count : 0);
703 }
704 line++;
705
706 wattron(center, A_BOLD);
707 column = 1;
708 for (i = 0; i < 3; i++) {
709 if (fileview[i].sort) {
710 pref_current_sort = i;
711 wattron(center, A_UNDERLINE);
712 }
713 mvwprintw(center, line, column, fileview[i].title);
714 wattroff(center, A_UNDERLINE);
715 column += 10;
716 }
717 mvwprintw(center, line++, column, "FILENAME");
718 wattroff(center, A_BOLD);
719
720 /*
721 * since the process_files_table array could contain NULL file structures,
722 * and that the positions inside the array is important (it is the FD), we
723 * need to create a temporary array that we can sort.
724 */
725 for (i = 0; i < tmp->process_files_table->len; i++) {
726 file_tmp = g_ptr_array_index(tmp->process_files_table, i);
727 if (file_tmp)
728 g_ptr_array_add(newfilearray, file_tmp);
729 }
730
731 if (fileview[0].sort == 1)
732 g_ptr_array_sort(newfilearray, sort_by_file_fd_desc);
733 else if (fileview[1].sort == 1)
734 g_ptr_array_sort(newfilearray, sort_by_file_read_desc);
735 else if (fileview[2].sort == 1)
736 g_ptr_array_sort(newfilearray, sort_by_file_write_desc);
737 else
738 g_ptr_array_sort(newfilearray, sort_by_file_read_desc);
739
740 for (i = selected_line; i < newfilearray->len &&
741 i < (selected_line + max_center_lines - line + 2); i++) {
742 file_tmp = g_ptr_array_index(newfilearray, i);
743 if (!file_tmp)
744 continue;
745 mvwprintw(center, line + j, 1, "%d", file_tmp->fd);
746 scale_unit(file_tmp->read, unit);
747 mvwprintw(center, line + j, 11, "%s", unit);
748 scale_unit(file_tmp->write, unit);
749 mvwprintw(center, line + j, 21, "%s", unit);
750 snprintf(filename_buf, COLS - 25, "%s", file_tmp->name);
751 mvwprintw(center, line + j, 31, "%s", filename_buf);
752 j++;
753 }
754 g_ptr_array_free(newfilearray, TRUE);
755 }
756
757 void update_perf()
758 {
759 int i;
760 int nblinedisplayed = 0;
761 int current_line = 0;
762 struct processtop *tmp;
763 int header_offset = 2;
764 int perf_row = 40;
765 struct perfcounter *perfn1, *perfn2;
766 char *perf_key = NULL;
767 int value;
768 GHashTableIter iter;
769 gpointer key;
770
771 set_window_title(center, "Perf Top");
772 wattron(center, A_BOLD);
773 mvwprintw(center, 1, 1, "PID");
774 mvwprintw(center, 1, 11, "TID");
775 mvwprintw(center, 1, 22, "NAME");
776
777 perf_row = 40;
778 g_hash_table_iter_init(&iter, global_perf_liszt);
779 while (g_hash_table_iter_next (&iter, &key, (gpointer) &perfn1)) {
780 if (perfn1->visible) {
781 if (perfn1->sort) {
782 /* pref_current_sort = i; */
783 wattron(center, A_UNDERLINE);
784 }
785 /* + 5 to strip the "perf_" prefix */
786 mvwprintw(center, 1, perf_row, "%s",
787 (char *) key + 5);
788 wattroff(center, A_UNDERLINE);
789 perf_row += 20;
790 }
791 if (perfn1->sort) {
792 perf_key = (char *) key;
793 }
794 }
795 wattroff(center, A_BOLD);
796
797 g_ptr_array_sort_with_data(data->process_table, sort_perf, perf_key);
798
799 for (i = 0; i < data->process_table->len &&
800 nblinedisplayed < max_center_lines; i++) {
801 tmp = g_ptr_array_index(data->process_table, i);
802 if (tmp->pid != tmp->tid)
803 if (toggle_threads == -1)
804 continue;
805
806 if (process_selected(tmp)) {
807 wattron(center, COLOR_PAIR(6));
808 mvwhline(center, current_line + header_offset, 1, ' ', COLS-3);
809 }
810 if (current_line == selected_line) {
811 selected_process = tmp;
812 wattron(center, COLOR_PAIR(5));
813 mvwhline(center, current_line + header_offset, 1, ' ', COLS-3);
814 }
815
816 mvwprintw(center, current_line + header_offset, 1, "%d", tmp->pid);
817 mvwprintw(center, current_line + header_offset, 11, "%d", tmp->tid);
818 mvwprintw(center, current_line + header_offset, 22, "%s", tmp->comm);
819
820 g_hash_table_iter_init(&iter, global_perf_liszt);
821
822 perf_row = 40;
823 while (g_hash_table_iter_next (&iter, &key, (gpointer) &perfn1)) {
824 if (perfn1->visible) {
825 perfn2 = g_hash_table_lookup(tmp->perf, (char *) key);
826 if (perfn2)
827 value = perfn2->count;
828 else
829 value = 0;
830 mvwprintw(center, current_line + header_offset,
831 perf_row, "%d", value);
832 perf_row += 20;
833 }
834 }
835
836 wattroff(center, COLOR_PAIR(6));
837 wattroff(center, COLOR_PAIR(5));
838 nblinedisplayed++;
839 current_line++;
840 }
841 }
842
843 void update_iostream()
844 {
845 int i;
846 int header_offset = 2;
847 struct processtop *tmp;
848 int nblinedisplayed = 0;
849 int current_line = 0;
850 int total = 0;
851 char unit[4];
852 int column;
853
854 set_window_title(center, "IO Top");
855 wattron(center, A_BOLD);
856 mvwprintw(center, 1, 1, "PID");
857 mvwprintw(center, 1, 11, "TID");
858 mvwprintw(center, 1, 22, "NAME");
859 column = 40;
860 for (i = 0; i < 3; i++) {
861 if (iostreamtopview[i].sort) {
862 pref_current_sort = i;
863 wattron(center, A_UNDERLINE);
864 }
865 mvwprintw(center, 1, column, iostreamtopview[i].title);
866 wattroff(center, A_UNDERLINE);
867 column += 12;
868 }
869 wattroff(center, A_BOLD);
870 wattroff(center, A_UNDERLINE);
871
872 if (iostreamtopview[0].sort == 1)
873 g_ptr_array_sort(data->process_table, sort_by_process_read_desc);
874 else if (iostreamtopview[1].sort == 1)
875 g_ptr_array_sort(data->process_table, sort_by_process_write_desc);
876 else if (iostreamtopview[2].sort == 1)
877 g_ptr_array_sort(data->process_table, sort_by_process_total_desc);
878 else
879 g_ptr_array_sort(data->process_table, sort_by_process_total_desc);
880
881 for (i = list_offset; i < data->process_table->len &&
882 nblinedisplayed < max_center_lines; i++) {
883 tmp = g_ptr_array_index(data->process_table, i);
884 if (tmp->pid != tmp->tid)
885 if (toggle_threads == -1)
886 continue;
887
888 if (process_selected(tmp)) {
889 wattron(center, COLOR_PAIR(6));
890 mvwhline(center, current_line + header_offset, 1, ' ', COLS-3);
891 }
892 if (current_line == selected_line) {
893 selected_process = tmp;
894 wattron(center, COLOR_PAIR(5));
895 mvwhline(center, current_line + header_offset, 1, ' ', COLS-3);
896 }
897 /* TGID */
898 mvwprintw(center, current_line + header_offset, 1, "%d", tmp->pid);
899 /* PID */
900 mvwprintw(center, current_line + header_offset, 11, "%d", tmp->tid);
901 /* NAME */
902 mvwprintw(center, current_line + header_offset, 22, "%s", tmp->comm);
903
904 /* READ (bytes/sec) */
905 scale_unit(tmp->fileread, unit);
906 mvwprintw(center, current_line + header_offset, 40, "%s", unit);
907
908 /* WRITE (bytes/sec) */
909 scale_unit(tmp->filewrite, unit);
910 mvwprintw(center, current_line + header_offset, 52, "%s", unit);
911
912 /* TOTAL STREAM */
913 total = tmp->totalfileread + tmp->totalfilewrite;
914
915 scale_unit(total, unit);
916 mvwprintw(center, current_line + header_offset, 64, "%s", unit);
917
918 wattroff(center, COLOR_PAIR(6));
919 wattroff(center, COLOR_PAIR(5));
920 nblinedisplayed++;
921 current_line++;
922 }
923 }
924
925 void update_current_view()
926 {
927 sem_wait(&update_display_sem);
928 if (!data)
929 return;
930 update_header();
931
932 werase(center);
933 box(center, 0, 0);
934 switch (current_view) {
935 case cpu:
936 update_cputop_display();
937 break;
938 case perf:
939 update_perf();
940 break;
941 case process_details:
942 update_process_details();
943 break;
944 case iostream:
945 update_iostream();
946 break;
947 case tree:
948 update_cputop_display();
949 break;
950 default:
951 break;
952 }
953 update_panels();
954 doupdate();
955 sem_post(&update_display_sem);
956 }
957
958 void update_process_detail_sort(int *line_selected)
959 {
960 int i;
961 int size;
962
963 size = 3;
964
965 if (*line_selected > (size - 1))
966 *line_selected = size - 1;
967 else if (*line_selected < 0)
968 *line_selected = 0;
969
970 if (fileview[*line_selected].sort == 1)
971 fileview[*line_selected].reverse = 1;
972 for (i = 0; i < size; i++)
973 fileview[i].sort = 0;
974 fileview[*line_selected].sort = 1;
975 }
976
977 void update_process_detail_pref(int *line_selected, int toggle_view, int toggle_sort)
978 {
979 int i;
980 int size;
981
982 if (!data)
983 return;
984 if (pref_panel_window) {
985 del_panel(pref_panel);
986 delwin(pref_panel_window);
987 }
988 size = 3;
989
990 pref_panel_window = create_window(size + 2, 30, 10, 10);
991 pref_panel = new_panel(pref_panel_window);
992
993 werase(pref_panel_window);
994 box(pref_panel_window, 0 , 0);
995 set_window_title(pref_panel_window, "Process Detail Preferences ");
996 wattron(pref_panel_window, A_BOLD);
997 mvwprintw(pref_panel_window, size + 1, 1,
998 " 's' : sort, space : toggle");
999 wattroff(pref_panel_window, A_BOLD);
1000
1001 if (*line_selected > (size - 1))
1002 *line_selected = size - 1;
1003 else if (*line_selected < 0)
1004 *line_selected = 0;
1005 if (toggle_sort == 1) {
1006 update_process_detail_sort(line_selected);
1007 update_current_view();
1008 }
1009
1010 for (i = 0; i < size; i++) {
1011 if (i == *line_selected) {
1012 wattron(pref_panel_window, COLOR_PAIR(5));
1013 mvwhline(pref_panel_window, i + 1, 1, ' ', 30 - 2);
1014 }
1015 if (fileview[i].sort == 1)
1016 wattron(pref_panel_window, A_BOLD);
1017 mvwprintw(pref_panel_window, i + 1, 1, "[-] %s",
1018 fileview[i].title);
1019 wattroff(pref_panel_window, A_BOLD);
1020 wattroff(pref_panel_window, COLOR_PAIR(5));
1021
1022 }
1023 update_panels();
1024 doupdate();
1025 }
1026
1027 void update_iostream_sort(int *line_selected)
1028 {
1029 int i;
1030 int size;
1031
1032 size = 3;
1033 if (*line_selected > (size - 1))
1034 *line_selected = size - 1;
1035 else if (*line_selected < 0)
1036 *line_selected = 0;
1037 if (iostreamtopview[*line_selected].sort == 1)
1038 iostreamtopview[*line_selected].reverse = 1;
1039 for (i = 0; i < size; i++)
1040 iostreamtopview[i].sort = 0;
1041 iostreamtopview[*line_selected].sort = 1;
1042
1043 }
1044
1045 void update_iostream_pref(int *line_selected, int toggle_view, int toggle_sort)
1046 {
1047 int i;
1048 int size;
1049
1050 if (!data)
1051 return;
1052 if (pref_panel_window) {
1053 del_panel(pref_panel);
1054 delwin(pref_panel_window);
1055 }
1056 size = 3;
1057
1058 pref_panel_window = create_window(size + 2, 30, 10, 10);
1059 pref_panel = new_panel(pref_panel_window);
1060
1061 werase(pref_panel_window);
1062 box(pref_panel_window, 0 , 0);
1063 set_window_title(pref_panel_window, "IOTop Preferences ");
1064 wattron(pref_panel_window, A_BOLD);
1065 mvwprintw(pref_panel_window, size + 1, 1,
1066 " 's' : sort, space : toggle");
1067 wattroff(pref_panel_window, A_BOLD);
1068
1069 if (*line_selected > (size - 1))
1070 *line_selected = size - 1;
1071 else if (*line_selected < 0)
1072 *line_selected = 0;
1073 if (toggle_sort == 1) {
1074 update_iostream_sort(line_selected);
1075 update_current_view();
1076 }
1077
1078 for (i = 0; i < size; i++) {
1079 if (i == *line_selected) {
1080 wattron(pref_panel_window, COLOR_PAIR(5));
1081 mvwhline(pref_panel_window, i + 1, 1, ' ', 30 - 2);
1082 }
1083 if (iostreamtopview[i].sort == 1)
1084 wattron(pref_panel_window, A_BOLD);
1085 mvwprintw(pref_panel_window, i + 1, 1, "[-] %s",
1086 iostreamtopview[i].title);
1087 wattroff(pref_panel_window, A_BOLD);
1088 wattroff(pref_panel_window, COLOR_PAIR(5));
1089
1090 }
1091 update_panels();
1092 doupdate();
1093 }
1094
1095 void update_cpu_sort(int *line_selected)
1096 {
1097 int i;
1098 int size = 3;
1099
1100 if (*line_selected > (size - 1))
1101 *line_selected = size - 1;
1102 else if (*line_selected < 0)
1103 *line_selected = 0;
1104
1105 /* special case, we don't support sorting by procname for now */
1106 if (*line_selected != 3) {
1107 if (cputopview[*line_selected].sort == 1)
1108 cputopview[*line_selected].reverse = 1;
1109 for (i = 0; i < size; i++)
1110 cputopview[i].sort = 0;
1111 cputopview[*line_selected].sort = 1;
1112 }
1113 }
1114
1115 void update_cpu_pref(int *line_selected, int toggle_view, int toggle_sort)
1116 {
1117 int i;
1118 int size;
1119
1120 if (!data)
1121 return;
1122 if (pref_panel_window) {
1123 del_panel(pref_panel);
1124 delwin(pref_panel_window);
1125 }
1126 size = 4;
1127
1128 pref_panel_window = create_window(size + 2, 30, 10, 10);
1129 pref_panel = new_panel(pref_panel_window);
1130
1131 werase(pref_panel_window);
1132 box(pref_panel_window, 0 , 0);
1133 set_window_title(pref_panel_window, "CPUTop Preferences ");
1134 wattron(pref_panel_window, A_BOLD);
1135 mvwprintw(pref_panel_window, size + 1, 1,
1136 " 's' : sort, space : toggle");
1137 wattroff(pref_panel_window, A_BOLD);
1138
1139 if (*line_selected > (size - 1))
1140 *line_selected = size - 1;
1141 else if (*line_selected < 0)
1142 *line_selected = 0;
1143 if (toggle_sort == 1) {
1144 update_cpu_sort(line_selected);
1145 update_current_view();
1146 }
1147
1148 for (i = 0; i < size; i++) {
1149 if (i == *line_selected) {
1150 wattron(pref_panel_window, COLOR_PAIR(5));
1151 mvwhline(pref_panel_window, i + 1, 1, ' ', 30 - 2);
1152 }
1153 if (cputopview[i].sort == 1)
1154 wattron(pref_panel_window, A_BOLD);
1155 mvwprintw(pref_panel_window, i + 1, 1, "[-] %s",
1156 cputopview[i].title);
1157 wattroff(pref_panel_window, A_BOLD);
1158 wattroff(pref_panel_window, COLOR_PAIR(5));
1159
1160 }
1161 update_panels();
1162 doupdate();
1163 }
1164
1165 void update_perf_sort(int *line_selected)
1166 {
1167 int i;
1168 struct perfcounter *perf;
1169 GList *perflist;
1170 int size;
1171
1172 size = g_hash_table_size(global_perf_liszt);
1173 if (*line_selected > (size - 1))
1174 *line_selected = size - 1;
1175 else if (*line_selected < 0)
1176 *line_selected = 0;
1177
1178 i = 0;
1179 perflist = g_list_first(g_hash_table_get_keys(global_perf_liszt));
1180 while (perflist) {
1181 perf = g_hash_table_lookup(global_perf_liszt, perflist->data);
1182 if (i != *line_selected)
1183 perf->sort = 0;
1184 else
1185 perf->sort = 1;
1186 i++;
1187 perflist = g_list_next(perflist);
1188 }
1189 }
1190
1191 void update_perf_pref(int *line_selected, int toggle_view, int toggle_sort)
1192 {
1193 int i;
1194 struct perfcounter *perf;
1195 GList *perflist;
1196 int size;
1197
1198 if (!data)
1199 return;
1200 if (pref_panel_window) {
1201 del_panel(pref_panel);
1202 delwin(pref_panel_window);
1203 }
1204 size = g_hash_table_size(global_perf_liszt);
1205
1206 pref_panel_window = create_window(size + 2, 30, 10, 10);
1207 pref_panel = new_panel(pref_panel_window);
1208
1209 werase(pref_panel_window);
1210 box(pref_panel_window, 0 , 0);
1211 set_window_title(pref_panel_window, "Perf Preferences ");
1212 wattron(pref_panel_window, A_BOLD);
1213 mvwprintw(pref_panel_window, g_hash_table_size(global_perf_liszt) + 1, 1,
1214 " 's' : sort, space : toggle");
1215 wattroff(pref_panel_window, A_BOLD);
1216
1217 if (*line_selected > (size - 1))
1218 *line_selected = size - 1;
1219 else if (*line_selected < 0)
1220 *line_selected = 0;
1221
1222 if (toggle_sort == 1) {
1223 update_perf_sort(line_selected);
1224 update_current_view();
1225 }
1226
1227 i = 0;
1228 perflist = g_list_first(g_hash_table_get_keys(global_perf_liszt));
1229 while (perflist) {
1230 perf = g_hash_table_lookup(global_perf_liszt, perflist->data);
1231 if (i == *line_selected && toggle_view == 1) {
1232 perf->visible = perf->visible == 1 ? 0:1;
1233 update_current_view();
1234 }
1235 if (i == *line_selected) {
1236 wattron(pref_panel_window, COLOR_PAIR(5));
1237 mvwhline(pref_panel_window, i + 1, 1, ' ', 30 - 2);
1238 }
1239 if (perf->sort == 1)
1240 wattron(pref_panel_window, A_BOLD);
1241 mvwprintw(pref_panel_window, i + 1, 1, "[%c] %s",
1242 perf->visible == 1 ? 'x' : ' ',
1243 (char *) perflist->data + 5);
1244 wattroff(pref_panel_window, A_BOLD);
1245 wattroff(pref_panel_window, COLOR_PAIR(5));
1246 i++;
1247 perflist = g_list_next(perflist);
1248 }
1249 update_panels();
1250 doupdate();
1251 }
1252
1253 int update_preference_panel(int *line_selected, int toggle_view, int toggle_sort)
1254 {
1255 int ret = 0;
1256
1257 switch(current_view) {
1258 case perf:
1259 update_perf_pref(line_selected, toggle_view, toggle_sort);
1260 break;
1261 case cpu:
1262 update_cpu_pref(line_selected, toggle_view, toggle_sort);
1263 break;
1264 case iostream:
1265 update_iostream_pref(line_selected, toggle_view, toggle_sort);
1266 break;
1267 case process_details:
1268 update_process_detail_pref(line_selected, toggle_view, toggle_sort);
1269 break;
1270 default:
1271 ret = -1;
1272 break;
1273 }
1274
1275 return ret;
1276 }
1277
1278 int update_sort(int *line_selected)
1279 {
1280 int ret = 0;
1281
1282 switch(current_view) {
1283 case perf:
1284 update_perf_sort(line_selected);
1285 break;
1286 case cpu:
1287 update_cpu_sort(line_selected);
1288 break;
1289 case iostream:
1290 update_iostream_sort(line_selected);
1291 break;
1292 case process_details:
1293 update_process_detail_sort(line_selected);
1294 break;
1295 default:
1296 ret = -1;
1297 break;
1298 }
1299
1300 return ret;
1301 }
1302
1303
1304 void toggle_pref_panel(void)
1305 {
1306 int ret;
1307
1308 if (pref_panel_visible) {
1309 hide_panel(pref_panel);
1310 pref_panel_visible = 0;
1311 } else {
1312 ret = update_preference_panel(&pref_line_selected, 0, 0);
1313 if (ret < 0)
1314 return;
1315 show_panel(pref_panel);
1316 pref_panel_visible = 1;
1317 }
1318 update_panels();
1319 doupdate();
1320 }
1321
1322 void display(unsigned int index)
1323 {
1324 last_display_index = index;
1325 currently_displayed_index = index;
1326 data = g_ptr_array_index(copies, index);
1327 if (!data)
1328 return;
1329 max_elements = data->process_table->len;
1330 update_current_view();
1331 update_footer();
1332 update_panels();
1333 doupdate();
1334 }
1335
1336 void pause_display()
1337 {
1338 toggle_pause = 1;
1339 print_log("Pause");
1340 sem_wait(&pause_sem);
1341 }
1342
1343 void resume_display()
1344 {
1345 toggle_pause = -1;
1346 print_log("Resume");
1347 sem_post(&pause_sem);
1348 }
1349
1350 void *handle_keyboard(void *p)
1351 {
1352 int ch;
1353 while((ch = getch())) {
1354 switch(ch) {
1355 /* Move the cursor and scroll */
1356 case 'j':
1357 case KEY_DOWN:
1358 if (pref_panel_visible) {
1359 pref_line_selected++;
1360 update_preference_panel(&pref_line_selected, 0, 0);
1361 } else {
1362 if (selected_line < (max_center_lines - 1) &&
1363 selected_line < max_elements - 1) {
1364 selected_line++;
1365 selected_in_list++;
1366 } else if (selected_in_list < (max_elements - 1)
1367 && (list_offset < (max_elements - max_center_lines))) {
1368 selected_in_list++;
1369 list_offset++;
1370 }
1371 update_current_view();
1372 }
1373 break;
1374 case KEY_NPAGE:
1375 break;
1376 case 'k':
1377 case KEY_UP:
1378 if (pref_panel_visible) {
1379 if (pref_line_selected > 0)
1380 pref_line_selected--;
1381 update_preference_panel(&pref_line_selected, 0, 0);
1382 } else {
1383 if (selected_line > 0) {
1384 selected_line--;
1385 selected_in_list--;
1386 } else if (selected_in_list > 0 && list_offset > 0) {
1387 selected_in_list--;
1388 list_offset--;
1389 }
1390 update_current_view();
1391 }
1392 break;
1393 case KEY_PPAGE:
1394 break;
1395
1396 /* Navigate the history with arrows */
1397 case KEY_LEFT:
1398 if (currently_displayed_index > 0) {
1399 currently_displayed_index--;
1400 print_log("Going back in time");
1401 } else {
1402 print_log("Cannot rewind, last data is already displayed");
1403 }
1404 data = g_ptr_array_index(copies, currently_displayed_index);
1405 max_elements = data->process_table->len;
1406
1407 /* we force to pause the display when moving in time */
1408 if (toggle_pause < 0)
1409 pause_display();
1410
1411 update_current_view();
1412 update_footer();
1413 break;
1414 case KEY_RIGHT:
1415 if (currently_displayed_index < last_display_index) {
1416 currently_displayed_index++;
1417 print_log("Going forward in time");
1418 data = g_ptr_array_index(copies, currently_displayed_index);
1419 max_elements = data->process_table->len;
1420 update_current_view();
1421 update_footer();
1422 } else {
1423 print_log("Manually moving forward");
1424 sem_post(&timer);
1425 if (toggle_pause > 0) {
1426 sem_post(&pause_sem);
1427 update_current_view();
1428 sem_wait(&pause_sem);
1429 }
1430 }
1431
1432 break;
1433 case ' ':
1434 if (pref_panel_visible) {
1435 update_preference_panel(&pref_line_selected, 1, 0);
1436 } else {
1437 update_selected_processes();
1438 update_current_view();
1439 }
1440 break;
1441 case 's':
1442 if (pref_panel_visible)
1443 update_preference_panel(&pref_line_selected, 0, 1);
1444 break;
1445 case '>':
1446 /* perf uses a hashtable, it is ordered backward */
1447 if (current_view == perf) {
1448 pref_current_sort--;
1449 } else if (!pref_panel_visible) {
1450 pref_current_sort++;
1451 }
1452 update_sort(&pref_current_sort);
1453 update_current_view();
1454 break;
1455 case '<':
1456 /* perf uses a hashtable, it is ordered backward */
1457 if (current_view == perf) {
1458 pref_current_sort++;
1459 } else if (!pref_panel_visible) {
1460 pref_current_sort--;
1461 }
1462 update_sort(&pref_current_sort);
1463 update_current_view();
1464 break;
1465
1466 case 13: /* FIXME : KEY_ENTER ?? */
1467 if (pref_panel_visible)
1468 break;
1469 if (current_view != process_details) {
1470 previous_view = current_view;
1471 current_view = process_details;
1472 } else {
1473 current_view = previous_view;
1474 previous_view = process_details;
1475 }
1476 selected_line = 0;
1477 update_current_view();
1478 break;
1479
1480 case KEY_F(1):
1481 if (pref_panel_visible)
1482 toggle_pref_panel();
1483 current_view = cpu;
1484 selected_line = 0;
1485 update_current_view();
1486 break;
1487 case KEY_F(2):
1488 if (pref_panel_visible)
1489 toggle_pref_panel();
1490 current_view = cpu;
1491 selected_line = 0;
1492 update_current_view();
1493 break;
1494 case KEY_F(3):
1495 if (pref_panel_visible)
1496 toggle_pref_panel();
1497 current_view = perf;
1498 selected_line = 0;
1499 update_current_view();
1500 break;
1501 case KEY_F(4):
1502 if (pref_panel_visible)
1503 toggle_pref_panel();
1504 current_view = iostream;
1505 selected_line = 0;
1506 update_current_view();
1507 break;
1508 case KEY_F(10):
1509 case 'q':
1510 reset_ncurses();
1511 break;
1512 case 't':
1513 toggle_threads *= -1;
1514 update_current_view();
1515 break;
1516 case 'p':
1517 if (toggle_pause < 0) {
1518 pause_display();
1519 } else {
1520 resume_display();
1521 }
1522 break;
1523 case 'r':
1524 toggle_pref_panel();
1525 break;
1526 /* ESCAPE, but slow to process, don't know why */
1527 case 27:
1528 if (pref_panel_visible)
1529 toggle_pref_panel();
1530 else if (current_view == process_details) {
1531 current_view = previous_view;
1532 previous_view = process_details;
1533 }
1534 update_current_view();
1535 break;
1536 default:
1537 if (data)
1538 update_current_view();
1539 break;
1540 }
1541 update_footer();
1542 }
1543 return NULL;
1544 }
1545
1546 void init_view_headers()
1547 {
1548 cputopview[0].title = strdup("CPU(%)");
1549 cputopview[0].sort = 1;
1550 cputopview[1].title = strdup("PID");
1551 cputopview[2].title = strdup("TID");
1552 cputopview[3].title = strdup("NAME");
1553
1554 iostreamtopview[0].title = strdup("R (B/sec)");
1555 iostreamtopview[1].title = strdup("W (B/sec)");
1556 iostreamtopview[2].title = strdup("Total (B)");
1557 iostreamtopview[2].sort = 1;
1558
1559 fileview[0].title = strdup("FD");
1560 fileview[1].title = strdup("READ");
1561 fileview[1].sort = 1;
1562 fileview[2].title = strdup("WRITE");
1563 }
1564
1565 void init_ncurses()
1566 {
1567 selected_processes = g_ptr_array_new();
1568 sem_init(&update_display_sem, 0, 1);
1569 init_view_headers();
1570 init_screen();
1571
1572 header = create_window(5, COLS - 1, 0, 0);
1573 center = create_window(LINES - 5 - 7, COLS - 1, 5, 0);
1574 status = create_window(MAX_LOG_LINES + 2, COLS - 1, LINES - 7, 0);
1575 footer = create_window(1, COLS - 1, LINES - 1, 0);
1576
1577 print_log("Starting display");
1578
1579 main_panel = new_panel(center);
1580
1581 current_view = cpu;
1582
1583 basic_header();
1584 update_footer();
1585
1586 pthread_create(&keyboard_thread, NULL, handle_keyboard, (void *)NULL);
1587 }
LTTngTop ncurse top like application showing statistics
This page took 0.063797 seconds and 3 git commands to generate.