| 122 |
|
network_data_list_t *network_data_list; |
| 123 |
|
long long network_io_total_tx; |
| 124 |
|
long long network_io_total_rx; |
| 125 |
+ |
long long network_io_total; |
| 126 |
|
|
| 127 |
|
diskio_data_list_t *diskio_data_list; |
| 128 |
|
long long disk_io_total_write; |
| 129 |
|
long long disk_io_total_read; |
| 130 |
+ |
long long disk_io_total; |
| 131 |
|
|
| 132 |
|
/* Maybe in the future */ |
| 133 |
|
/* |
| 140 |
|
|
| 141 |
|
typedef struct machine_data_t machine_data_list_t; |
| 142 |
|
|
| 143 |
+ |
#define SORTBYMAXNAME 128 |
| 144 |
|
typedef struct{ |
| 145 |
|
int cpu_user; |
| 146 |
|
int cpu_idle; |
| 182 |
|
|
| 183 |
|
int disk_total_used; |
| 184 |
|
int disk_all_stats; |
| 185 |
+ |
|
| 186 |
+ |
char sortby[SORTBYMAXNAME]; |
| 187 |
|
}display_config_t; |
| 188 |
|
|
| 189 |
|
GENERIC_MERGE_SORT(static, sort_machine_stats, machine_data_list_t, next) |
| 195 |
|
|
| 196 |
|
MKCMP(cpu_used) |
| 197 |
|
MKCMP(load_1) |
| 198 |
+ |
MKCMP(network_io_total) |
| 199 |
|
MKCMP(network_io_total_tx) |
| 200 |
|
MKCMP(network_io_total_rx) |
| 201 |
+ |
MKCMP(disk_io_total) |
| 202 |
|
MKCMP(disk_io_total_write) |
| 203 |
|
MKCMP(disk_io_total_read) |
| 204 |
|
MKCMP(memory_used_pecent) |
| 205 |
|
MKCMP(swap_used_pecent) |
| 206 |
|
|
| 207 |
+ |
#define CPU_USED "CPU used" |
| 208 |
+ |
#define LOAD "Load (1)" |
| 209 |
+ |
#define NETIORX "total Network RX for all interfaces" |
| 210 |
+ |
#define NETIOTX "total Network TX for all interfaces" |
| 211 |
+ |
#define NETIO "total Network IO for all interfaces (rx+tx)" |
| 212 |
+ |
#define MEM "Memory usage" |
| 213 |
+ |
#define SWAP "Swap usage" |
| 214 |
+ |
#define DISKIOR "DiskIO reads" |
| 215 |
+ |
#define DISKIOW "DiskIO writes" |
| 216 |
+ |
#define DISKIO "Total DiskIO (reads+writes)" |
| 217 |
+ |
|
| 218 |
+ |
|
| 219 |
|
/* |
| 220 |
|
int cmp_cpu(machine_data_list_t *a, machine_data_list_t *b){ |
| 221 |
|
|
| 583 |
|
machine_data_list->network_io_total_rx+=ndl_ptr->rx; |
| 584 |
|
ndl_ptr=ndl_ptr->next; |
| 585 |
|
} |
| 586 |
+ |
machine_data_list->network_io_total=machine_data_list->network_io_total_rx+machine_data_list->network_io_total_tx; |
| 587 |
|
|
| 588 |
|
didl_ptr=machine_data_list->diskio_data_list; |
| 589 |
|
machine_data_list->disk_io_total_read=0; |
| 593 |
|
machine_data_list->disk_io_total_write+=didl_ptr->write; |
| 594 |
|
didl_ptr=didl_ptr->next; |
| 595 |
|
} |
| 596 |
+ |
machine_data_list->disk_io_total=machine_data_list->disk_io_total_read+machine_data_list->disk_io_total_write; |
| 597 |
|
|
| 598 |
|
xmlFreeDoc(doc); |
| 599 |
|
|
| 604 |
|
|
| 605 |
|
void display(machine_data_list_t *machine_data_list, display_config_t *display_config, int num_lines, int *title){ |
| 606 |
|
int line_num=4; |
| 607 |
+ |
int counter; |
| 608 |
|
int x=1; |
| 609 |
|
|
| 610 |
|
if(*title){ |
| 611 |
< |
// printf("\033[2J"); |
| 612 |
< |
// printf("\033[1;1HHostname CPU Load Page Page Mem Swap Net Net Disk Disk"); |
| 613 |
< |
// printw("\033[2;1H used%% (1m) ins outs used used rx tx read write"); |
| 611 |
> |
move (num_lines-3, 1); |
| 612 |
> |
printw("Sorting by %-64s", display_config->sortby); |
| 613 |
> |
|
| 614 |
|
move(1,1); |
| 615 |
|
printw("%-11s", "Hostname"); |
| 616 |
|
x=x+11+1; |
| 688 |
|
*title=0; |
| 689 |
|
} |
| 690 |
|
|
| 691 |
< |
for(;num_lines;num_lines--){ |
| 691 |
> |
/* Counter starts at 8, for padding (eg, headers, borders etc) */ |
| 692 |
> |
for(counter=8;counter<num_lines;counter++){ |
| 693 |
|
if(machine_data_list==NULL) break; |
| 694 |
|
move(line_num++, 1); |
| 695 |
|
printw("%-11s", machine_data_list->sysname); |
| 716 |
|
int main(int argc, char **argv){ |
| 717 |
|
WINDOW *window; |
| 718 |
|
fd_set infds; |
| 719 |
+ |
int maxx, maxy; |
| 720 |
|
|
| 721 |
|
FILE *control; |
| 722 |
|
FILE *data; |
| 732 |
|
|
| 733 |
|
int num_hosts; |
| 734 |
|
int max_display=0; |
| 735 |
< |
int title; |
| 735 |
> |
int title=1; |
| 736 |
|
|
| 737 |
|
int cmdopt; |
| 738 |
|
extern int optind; |
| 795 |
|
case 's': |
| 796 |
|
if(!strcmp(optarg, "cpu")){ |
| 797 |
|
sortby_ptr=cmp_cpu_used; |
| 798 |
+ |
strlcpy(display_config.sortby, CPU_USED, SORTBYMAXNAME); |
| 799 |
|
} |
| 800 |
|
if(!strcmp(optarg, "load")){ |
| 801 |
|
sortby_ptr=cmp_load_1; |
| 802 |
+ |
strlcpy(display_config.sortby, LOAD, SORTBYMAXNAME); |
| 803 |
|
} |
| 804 |
|
if(!strcmp(optarg, "mem")){ |
| 805 |
|
sortby_ptr=cmp_memory_used_pecent; |
| 806 |
+ |
strlcpy(display_config.sortby, MEM, SORTBYMAXNAME); |
| 807 |
|
} |
| 808 |
+ |
if(!strcmp(optarg, "swap")){ |
| 809 |
+ |
sortby_ptr=cmp_swap_used_pecent; |
| 810 |
+ |
strlcpy(display_config.sortby, SWAP, SORTBYMAXNAME); |
| 811 |
+ |
} |
| 812 |
|
if(sortby_ptr==NULL){ |
| 813 |
|
errf("Invalid sort type"); |
| 814 |
|
exit(1); |
| 817 |
|
} |
| 818 |
|
} |
| 819 |
|
|
| 820 |
< |
if(sortby_ptr==NULL) sortby_ptr=cmp_cpu_used; |
| 820 |
> |
if(sortby_ptr==NULL){ |
| 821 |
> |
sortby_ptr=cmp_cpu_used; |
| 822 |
> |
strlcpy(display_config.sortby, "CPU Used", SORTBYMAXNAME); |
| 823 |
> |
} |
| 824 |
|
|
| 825 |
|
if(argc<(optind+2)){ |
| 826 |
|
printf("Usage is %s <-d lines> hostname port <machine list>\n", argv[0]); |
| 889 |
|
cbreak(); |
| 890 |
|
echo(); |
| 891 |
|
window=newwin(0, 0, 0, 0); |
| 892 |
+ |
getmaxyx(window, maxy, maxx); |
| 893 |
|
|
| 894 |
|
stdin_fileno=fileno(stdin); |
| 895 |
|
data_fileno=fileno(data); |
| 896 |
|
biggest_fileno=(data_fileno>stdin_fileno) ? (data_fileno+1) : (stdin_fileno+1); |
| 897 |
< |
|
| 897 |
> |
|
| 898 |
|
for(;;){ |
| 899 |
|
FD_ZERO(&infds); |
| 900 |
|
FD_SET(stdin_fileno, &infds); |
| 904 |
|
if(FD_ISSET(stdin_fileno, &infds)){ |
| 905 |
|
|
| 906 |
|
ch=getc(stdin); |
| 907 |
+ |
switch(ch){ |
| 908 |
+ |
case 'Q': |
| 909 |
+ |
case 'q': |
| 910 |
+ |
endwin(); |
| 911 |
+ |
exit(0); |
| 912 |
+ |
break; |
| 913 |
|
|
| 914 |
< |
if(ch=='q'){ |
| 915 |
< |
endwin(); |
| 916 |
< |
exit(0); |
| 914 |
> |
case 'C': |
| 915 |
> |
sortby_ptr=cmp_cpu_used; |
| 916 |
> |
strlcpy(display_config.sortby, CPU_USED, SORTBYMAXNAME); |
| 917 |
> |
break; |
| 918 |
> |
|
| 919 |
> |
case 'M': |
| 920 |
> |
sortby_ptr=cmp_memory_used_pecent; |
| 921 |
> |
strlcpy(display_config.sortby, MEM, SORTBYMAXNAME); |
| 922 |
> |
break; |
| 923 |
> |
|
| 924 |
> |
case 'L': |
| 925 |
> |
sortby_ptr=cmp_load_1; |
| 926 |
> |
strlcpy(display_config.sortby, LOAD, SORTBYMAXNAME); |
| 927 |
> |
break; |
| 928 |
> |
|
| 929 |
> |
case 'S': |
| 930 |
> |
sortby_ptr=cmp_swap_used_pecent; |
| 931 |
> |
strlcpy(display_config.sortby, SWAP, SORTBYMAXNAME); |
| 932 |
> |
break; |
| 933 |
> |
|
| 934 |
> |
case 'N': |
| 935 |
> |
if(sortby_ptr==cmp_network_io_total){ |
| 936 |
> |
strlcpy(display_config.sortby, NETIORX, SORTBYMAXNAME); |
| 937 |
> |
sortby_ptr=cmp_network_io_total_rx; |
| 938 |
> |
}else if(sortby_ptr==cmp_network_io_total_rx){ |
| 939 |
> |
strlcpy(display_config.sortby, NETIOTX, SORTBYMAXNAME); |
| 940 |
> |
sortby_ptr=cmp_network_io_total_tx; |
| 941 |
> |
}else{ |
| 942 |
> |
strlcpy(display_config.sortby, NETIO, SORTBYMAXNAME); |
| 943 |
> |
sortby_ptr=cmp_network_io_total; |
| 944 |
> |
} |
| 945 |
> |
break; |
| 946 |
> |
|
| 947 |
|
} |
| 948 |
+ |
|
| 949 |
+ |
title=1; |
| 950 |
+ |
|
| 951 |
|
} |
| 952 |
|
if(FD_ISSET(data_fileno, &infds)){ |
| 953 |
|
response=fpgetline(data); |
| 962 |
|
if(num_hosts==-1) continue; |
| 963 |
|
machine_data_list=sort_machine_stats(machine_data_list, num_hosts, sortby_ptr); |
| 964 |
|
if(max_display==0){ |
| 965 |
< |
display(machine_data_list, &display_config, num_hosts, &title); |
| 965 |
> |
display(machine_data_list, &display_config, maxy, &title); |
| 966 |
|
}else{ |
| 967 |
|
display(machine_data_list, &display_config, max_display, &title); |
| 968 |
|
} |