Hi,
I''ve modified xentop.c code alittle, just I removed the interactive
functionalities of it and the format of it''s output.
but it gives me 0''s for any network related information, I can see that
it
happens because number of networks as "xenstat_domain_num_networks" is
returned as 0, I don''t know why!!!
Here''s the modified code:
/*
* Copyright (C) International Business Machines Corp., 2005
* Author(s): Judy Fischbach <jfisch@cs.pdx.edu>
* David Hendricks <cro_marmot@comcast.net>
* Josh Triplett <josh@kernel.org>
* based on code from Anthony Liguori <aliguori@us.ibm.com>
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; under version 2 of the License.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
USA
*/
/* Include output from configure */
//#include <config.h>
/* get curses header from configure */
//#include INCLUDE_CURSES_H
#include "xenstat_priv.h"//added by Mina
#include <ctype.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <stdarg.h>
#include <string.h>
#include <sys/time.h>
#include <time.h>
#include <unistd.h>
#include <signal.h>
#if defined(__linux__)
#include <linux/kdev_t.h>
#endif
#include <xenstat.h>
#define XENTOP_VERSION "1.0"
#define XENTOP_DISCLAIMER \
"Copyright (C) 2005 International Business Machines Corp\n"\
"This is free software; see the source for copying conditions.There is
NO\n"\
"warranty; not even for MERCHANTABILITY or FITNESS FOR A PARTICULAR
PURPOSE.\n"
#define XENTOP_BUGSTO "Report bugs to
<xen-devel@lists.xen.org>.\n"
#define _GNU_SOURCE
#include <getopt.h>
#if !defined(__GNUC__) && !defined(__GNUG__)
#define __attribute__(arg) /* empty */
#endif
#define KEY_ESCAPE ''\x1B''
#define KEY_REPAINT ''\x0C''
#ifdef HOST_SunOS
/* Old curses library on Solaris takes non-const strings. Also, ERR
interferes
* with curse''s definition.
*/
#undef ERR
#define ERR (-1)
#define curses_str_t char *
#else
#define curses_str_t const char *
#endif
#define TRUE 1
#define FALSE 0
/*
* Function prototypes
*/
/* Utility functions */
static void usage(const char *);
static void version(void);
static void cleanup(void);
static void fail(const char *);
static int current_row(void);
static int lines(void);
static void set_delay(char *value);
static void set_prompt(char *new_prompt, void (*func)(char *));
static int handle_key(int);
static int compare(unsigned long long, unsigned long long);
static int compare_domains(xenstat_domain **, xenstat_domain **);
static unsigned long long tot_net_bytes( xenstat_domain *, int);
static unsigned long long tot_vbd_reqs( xenstat_domain *, int);
/* Field functions */
static int compare_state(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_state(xenstat_domain *domain);
static int compare_cpu(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_cpu(xenstat_domain *domain);
static int compare_cpu_pct(xenstat_domain *domain1, xenstat_domain
*domain2);
static void print_cpu_pct(xenstat_domain *domain);
static int compare_mem(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_mem(xenstat_domain *domain);
static void print_mem_pct(xenstat_domain *domain);
static int compare_maxmem(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_maxmem(xenstat_domain *domain);
static void print_max_pct(xenstat_domain *domain);
static int compare_vcpus(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_vcpus(xenstat_domain *domain);
static int compare_nets(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_nets(xenstat_domain *domain);
static int compare_net_tx(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_net_tx(xenstat_domain *domain);
static int compare_net_rx(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_net_rx(xenstat_domain *domain);
static int compare_ssid(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_ssid(xenstat_domain *domain);
static int compare_name(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_name(xenstat_domain *domain);
static int compare_vbds(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_vbds(xenstat_domain *domain);
static int compare_vbd_oo(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_vbd_oo(xenstat_domain *domain);
static int compare_vbd_rd(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_vbd_rd(xenstat_domain *domain);
static int compare_vbd_wr(xenstat_domain *domain1, xenstat_domain *domain2);
static void print_vbd_wr(xenstat_domain *domain);
static int compare_vbd_rsect(xenstat_domain *domain1, xenstat_domain
*domain2);
static void print_vbd_rsect(xenstat_domain *domain);
static int compare_vbd_wsect(xenstat_domain *domain1, xenstat_domain
*domain2);
static void print_vbd_wsect(xenstat_domain *domain);
/* Section printing functions */
static void do_summary(void);
static void do_header(void);
static void do_bottom_line(void);
static void do_domain(xenstat_domain *);
static void do_vcpu(xenstat_domain *);
static void do_network(xenstat_domain *);
static void do_vbd(xenstat_domain *);
static void top(void);
/* Field types */
typedef enum field_id {
FIELD_DOMID,
FIELD_NAME,
FIELD_STATE,
FIELD_CPU,
FIELD_CPU_PCT,
FIELD_MEM,
FIELD_MEM_PCT,
FIELD_MAXMEM,
FIELD_MAX_PCT,
FIELD_VCPUS,
FIELD_NETS,
FIELD_NET_TX,
FIELD_NET_RX,
FIELD_VBDS,
FIELD_VBD_OO,
FIELD_VBD_RD,
FIELD_VBD_WR,
FIELD_VBD_RSECT,
FIELD_VBD_WSECT,
FIELD_SSID
} field_id;
typedef struct field {
field_id num;
const char *header;
unsigned int default_width;
int (*compare)(xenstat_domain *domain1, xenstat_domain *domain2);
void (*print)(xenstat_domain *domain);
} field;
field fields[] = {
{ FIELD_NAME, "NAME", 10, compare_name, print_name
},
{ FIELD_STATE, "STATE", 6, compare_state, print_state
},
{ FIELD_CPU, "CPU(sec)", 10, compare_cpu, print_cpu
},
{ FIELD_CPU_PCT, "CPU(%)", 6, compare_cpu_pct, print_cpu_pct
},
{ FIELD_MEM, "MEM(k)", 10, compare_mem, print_mem
},
{ FIELD_MEM_PCT, "MEM(%)", 6, compare_mem, print_mem_pct
},
{ FIELD_MAXMEM, "MAXMEM(k)", 10, compare_maxmem, print_maxmem
},
{ FIELD_MAX_PCT, "MAXMEM(%)", 9, compare_maxmem, print_max_pct
},
{ FIELD_VCPUS, "VCPUS", 5, compare_vcpus, print_vcpus
},
{ FIELD_NETS, "NETS", 4, compare_nets, print_nets
},
{ FIELD_NET_TX, "NETTX(k)", 8, compare_net_tx, print_net_tx
},
{ FIELD_NET_RX, "NETRX(k)", 8, compare_net_rx, print_net_rx
},
{ FIELD_VBDS, "VBDS", 4, compare_vbds, print_vbds
},
{ FIELD_VBD_OO, "VBD_OO", 8, compare_vbd_oo, print_vbd_oo
},
{ FIELD_VBD_RD, "VBD_RD", 8, compare_vbd_rd, print_vbd_rd
},
{ FIELD_VBD_WR, "VBD_WR", 8, compare_vbd_wr, print_vbd_wr
},
{ FIELD_VBD_RSECT, "VBD_RSECT", 10, compare_vbd_rsect, print_vbd_rsect
},
{ FIELD_VBD_WSECT, "VBD_WSECT", 10, compare_vbd_wsect, print_vbd_wsect
},
{ FIELD_SSID, "SSID", 4, compare_ssid, print_ssid }
};
const unsigned int NUM_FIELDS = sizeof(fields)/sizeof(field);
/* Globals */
struct timeval curtime, oldtime;
xenstat_handle *xhandle = NULL;
xenstat_node *prev_node = NULL;
xenstat_node *cur_node = NULL;
field_id sort_field = FIELD_DOMID;
unsigned int first_domain_index = 0;
unsigned int delay = 3;
unsigned int batch = 0;
unsigned int loop = 1;
unsigned int iterations = 0;
int show_vcpus = 0;
int show_networks = 0;
int show_vbds = 0;
int show_tmem = 0;
int repeat_header = 0;
int show_full_name = 0;
#define PROMPT_VAL_LEN 80
char *prompt = NULL;
char prompt_val[PROMPT_VAL_LEN];
int prompt_val_len = 0;
void (*prompt_complete_func)(char *);
/*
* Function definitions
*/
/* Utility functions */
/* Print usage message, using given program name */
static void usage(const char *program)
{
printf("Usage: %s [OPTION]\n"
"Displays ongoing information about xen vm resources \n\n"
"-h, --help display this help and exit\n"
"-V, --version output version information and exit\n"
"-d, --delay=SECONDS seconds between updates (default 3)\n"
"-n, --networks output vif network data\n"
"-x, --vbds output vbd block device data\n"
"-r, --repeat-header repeat table header before each domain\n"
"-v, --vcpus output vcpu data\n"
"-b, --batch output in batch mode, no user input
accepted\n"
"-i, --iterations number of iterations before exiting\n"
"-f, --full-name output the full domain name (not
truncated)\n"
"\n" XENTOP_BUGSTO,
program);
return;
}
/* Print program version information */
static void version(void)
{
printf("xentop " XENTOP_VERSION "\n"
"Written by Judy Fischbach, David Hendricks, Josh Triplett\n"
"\n" XENTOP_DISCLAIMER);
}
/* Clean up any open resources */
static void cleanup(void)
{
if(prev_node != NULL)
xenstat_free_node(prev_node);
if(cur_node != NULL)
xenstat_free_node(cur_node);
if(xhandle != NULL)
xenstat_uninit(xhandle);
}
/* Display the given message and gracefully exit */
static void fail(const char *str)
{
fprintf(stderr, "%s", str);
exit(1);
}
/* Handle setting the delay from the user-supplied value in prompt_val */
static void set_delay(char *value)
{
int new_delay;
new_delay = atoi(value);
if(new_delay > 0)
delay = new_delay;
}
/* Enable prompting mode with the given prompt string; call the given
function
* when a value is available. */
static void set_prompt(char *new_prompt, void (*func)(char *))
{
prompt = new_prompt;
prompt_val[0] = ''\0'';
prompt_val_len = 0;
prompt_complete_func = func;
}
/* Compares two integers, returning -1,0,1 for <,=,> */
static int compare(unsigned long long i1, unsigned long long i2)
{
if(i1 < i2)
return -1;
if(i1 > i2)
return 1;
return 0;
}
/* Comparison function for use with qsort. Compares two domains using the
* current sort field. */
static int compare_domains(xenstat_domain **domain1, xenstat_domain
**domain2)
{
return fields[sort_field].compare(*domain1, *domain2);
}
/* Field functions */
/* Compare domain names, returning -1,0,1 for <,=,> */
int compare_name(xenstat_domain *domain1, xenstat_domain *domain2)
{
return strcasecmp(xenstat_domain_name(domain1),
xenstat_domain_name(domain2));
}
/* Prints domain name */
void print_name(xenstat_domain *domain)
{
if(show_full_name)
printf("%10s", xenstat_domain_name(domain));
else
printf("%10.10s", xenstat_domain_name(domain));
}
struct {
unsigned int (*get)(xenstat_domain *);
char ch;
} state_funcs[] = {
{ xenstat_domain_dying, ''d'' },
{ xenstat_domain_shutdown, ''s'' },
{ xenstat_domain_blocked, ''b'' },
{ xenstat_domain_crashed, ''c'' },
{ xenstat_domain_paused, ''p'' },
{ xenstat_domain_running, ''r'' }
};
const unsigned int NUM_STATES = sizeof(state_funcs)/sizeof(*state_funcs);
/* Compare states of two domains, returning -1,0,1 for <,=,> */
static int compare_state(xenstat_domain *domain1, xenstat_domain *domain2)
{
unsigned int i, d1s, d2s;
for(i = 0; i < NUM_STATES; i++) {
d1s = state_funcs[i].get(domain1);
d2s = state_funcs[i].get(domain2);
if(d1s && !d2s)
return -1;
if(d2s && !d1s)
return 1;
}
return 0;
}
/* Prints domain state in abbreviated letter format */
static void print_state(xenstat_domain *domain)
{
unsigned int i;
for(i = 0; i < NUM_STATES; i++)
printf("%c", state_funcs[i].get(domain) ? state_funcs[i].ch
: ''-'');
}
/* Compares cpu usage of two domains, returning -1,0,1 for <,=,> */
static int compare_cpu(xenstat_domain *domain1, xenstat_domain *domain2)
{
return -compare(xenstat_domain_cpu_ns(domain1),
xenstat_domain_cpu_ns(domain2));
}
/* Prints domain cpu usage in seconds */
static void print_cpu(xenstat_domain *domain)
{
printf("%10llu", xenstat_domain_cpu_ns(domain)/1000000000);
}
/* Computes the CPU percentage used for a specified domain */
static double get_cpu_pct(xenstat_domain *domain)
{
xenstat_domain *old_domain;
double us_elapsed;
/* Can''t calculate CPU percentage without a previous sample. */
if(prev_node == NULL)
return 0.0;
old_domain = xenstat_node_domain(prev_node, xenstat_domain_id(domain));
if(old_domain == NULL)
return 0.0;
/* Calculate the time elapsed in microseconds */
us_elapsed = ((curtime.tv_sec-oldtime.tv_sec)*1000000.0
+(curtime.tv_usec - oldtime.tv_usec));
/* In the following, nanoseconds must be multiplied by 1000.0 to
* convert to microseconds, then divided by 100.0 to get a percentage,
* resulting in a multiplication by 10.0 */
return ((xenstat_domain_cpu_ns(domain)
-xenstat_domain_cpu_ns(old_domain))/10.0)/us_elapsed;
}
static int compare_cpu_pct(xenstat_domain *domain1, xenstat_domain *domain2)
{
return -compare(get_cpu_pct(domain1), get_cpu_pct(domain2));
}
/* Prints cpu percentage statistic */
static void print_cpu_pct(xenstat_domain *domain)
{
printf("%6.1f", get_cpu_pct(domain));
}
/* Compares current memory of two domains, returning -1,0,1 for <,=,> */
static int compare_mem(xenstat_domain *domain1, xenstat_domain *domain2)
{
return -compare(xenstat_domain_cur_mem(domain1),
xenstat_domain_cur_mem(domain2));
}
/* Prints current memory statistic */
static void print_mem(xenstat_domain *domain)
{
printf("%10llu", xenstat_domain_cur_mem(domain)/1024);
}
/* Prints memory percentage statistic, ratio of current domain memory to
total
* node memory */
static void print_mem_pct(xenstat_domain *domain)
{
printf("%6.1f", (double)xenstat_domain_cur_mem(domain) /
(double)xenstat_node_tot_mem(cur_node) * 100);
}
/* Compares maximum memory of two domains, returning -1,0,1 for <,=,> */
static int compare_maxmem(xenstat_domain *domain1, xenstat_domain *domain2)
{
return -compare(xenstat_domain_max_mem(domain1),
xenstat_domain_max_mem(domain2));
}
/* Prints maximum domain memory statistic in KB */
static void print_maxmem(xenstat_domain *domain)
{
unsigned long long max_mem = xenstat_domain_max_mem(domain);
if(max_mem == ((unsigned long long)-1))
printf("%10s", "no limit");
else
printf("%10llu", max_mem/1024);
}
/* Prints memory percentage statistic, ratio of current domain memory to
total
* node memory */
static void print_max_pct(xenstat_domain *domain)
{
if (xenstat_domain_max_mem(domain) == (unsigned long long)-1)
printf("%9s", "n/a");
else
printf("%9.1f", (double)xenstat_domain_max_mem(domain) /
(double)xenstat_node_tot_mem(cur_node) * 100);
}
/* Compares number of virtual CPUs of two domains, returning -1,0,1 for
* <,=,> */
static int compare_vcpus(xenstat_domain *domain1, xenstat_domain *domain2)
{
return -compare(xenstat_domain_num_vcpus(domain1),
xenstat_domain_num_vcpus(domain2));
}
/* Prints number of virtual CPUs statistic */
static void print_vcpus(xenstat_domain *domain)
{
printf("%5u", xenstat_domain_num_vcpus(domain));
}
/* Compares number of virtual networks of two domains, returning -1,0,1 for
* <,=,> */
static int compare_nets(xenstat_domain *domain1, xenstat_domain *domain2)
{
return -compare(xenstat_domain_num_networks(domain1),
xenstat_domain_num_networks(domain2));
}
/* Prints number of virtual networks statistic */
static void print_nets(xenstat_domain *domain)
{
printf("%4u", xenstat_domain_num_networks(domain));
}
/* Compares number of total network tx bytes of two domains, returning
-1,0,1
* for <,=,> */
static int compare_net_tx(xenstat_domain *domain1, xenstat_domain *domain2)
{
return -compare(tot_net_bytes(domain1, FALSE),
tot_net_bytes(domain2, FALSE));
}
/* Prints number of total network tx bytes statistic */
static void print_net_tx(xenstat_domain *domain)
{
printf("%8llu", tot_net_bytes(domain, FALSE)/1024);
}
/* Compares number of total network rx bytes of two domains, returning
-1,0,1
* for <,=,> */
static int compare_net_rx(xenstat_domain *domain1, xenstat_domain *domain2)
{
return -compare(tot_net_bytes(domain1, TRUE),
tot_net_bytes(domain2, TRUE));
}
/* Prints number of total network rx bytes statistic */
static void print_net_rx(xenstat_domain *domain)
{
printf("%8llu", tot_net_bytes(domain, TRUE)/1024);
}
/* Gets number of total network bytes statistic, if rx true, then rx bytes
* otherwise tx bytes
*/
static unsigned long long tot_net_bytes(xenstat_domain *domain, int rx_flag)
{
int i = 0;
xenstat_network *network;
unsigned num_networks = 0;
unsigned long long total = 0;
/* How many networks? */
num_networks = xenstat_domain_num_networks(domain);
/* Dump information for each network */
for (i=0; i < num_networks; i++) {
/* Next get the network information */
network = xenstat_domain_network(domain,i);
if (rx_flag)
total += xenstat_network_rbytes(network);
else
total += xenstat_network_tbytes(network);
}
return total;
}
/* Compares number of virtual block devices of two domains,
returning -1,0,1 for * <,=,> */
static int compare_vbds(xenstat_domain *domain1, xenstat_domain *domain2)
{
return -compare(xenstat_domain_num_vbds(domain1),
xenstat_domain_num_vbds(domain2));
}
/* Prints number of virtual block devices statistic */
static void print_vbds(xenstat_domain *domain)
{
printf("%4u", xenstat_domain_num_vbds(domain));
}
/* Compares number of total VBD OO requests of two domains,
returning -1,0,1 * for <,=,> */
static int compare_vbd_oo(xenstat_domain *domain1, xenstat_domain *domain2)
{
return -compare(tot_vbd_reqs(domain1, FIELD_VBD_OO),
tot_vbd_reqs(domain2, FIELD_VBD_OO));
}
/* Prints number of total VBD OO requests statistic */
static void print_vbd_oo(xenstat_domain *domain)
{
printf("%8llu", tot_vbd_reqs(domain, FIELD_VBD_OO));
}
/* Compares number of total VBD READ requests of two domains,
returning -1,0,1 * for <,=,> */
static int compare_vbd_rd(xenstat_domain *domain1, xenstat_domain *domain2)
{
return -compare(tot_vbd_reqs(domain1, FIELD_VBD_RD),
tot_vbd_reqs(domain2, FIELD_VBD_RD));
}
/* Prints number of total VBD READ requests statistic */
static void print_vbd_rd(xenstat_domain *domain)
{
printf("%8llu", tot_vbd_reqs(domain, FIELD_VBD_RD));
}
/* Compares number of total VBD WRITE requests of two domains,
returning -1,0,1 * for <,=,> */
static int compare_vbd_wr(xenstat_domain *domain1, xenstat_domain *domain2)
{
return -compare(tot_vbd_reqs(domain1, FIELD_VBD_WR),
tot_vbd_reqs(domain2, FIELD_VBD_WR));
}
/* Prints number of total VBD WRITE requests statistic */
static void print_vbd_wr(xenstat_domain *domain)
{
printf("%8llu", tot_vbd_reqs(domain, FIELD_VBD_WR));
}
/* Compares number of total VBD READ sectors of two domains,
returning -1,0,1 * for <,=,> */
static int compare_vbd_rsect(xenstat_domain *domain1, xenstat_domain
*domain2)
{
return -compare(tot_vbd_reqs(domain1, FIELD_VBD_RSECT),
tot_vbd_reqs(domain2, FIELD_VBD_RSECT));
}
/* Prints number of total VBD READ sectors statistic */
static void print_vbd_rsect(xenstat_domain *domain)
{
printf("%10llu", tot_vbd_reqs(domain, FIELD_VBD_RSECT));
}
/* Compares number of total VBD WRITE sectors of two domains,
returning -1,0,1 * for <,=,> */
static int compare_vbd_wsect(xenstat_domain *domain1, xenstat_domain
*domain2)
{
return -compare(tot_vbd_reqs(domain1, FIELD_VBD_WSECT),
tot_vbd_reqs(domain2, FIELD_VBD_WSECT));
}
/* Prints number of total VBD WRITE sectors statistic */
static void print_vbd_wsect(xenstat_domain *domain)
{
printf("%10llu", tot_vbd_reqs(domain, FIELD_VBD_WSECT));
}
/* Gets number of total VBD requests statistic,
* if flag is FIELD_VBD_OO, then OO requests,
* if flag is FIELD_VBD_RD, then READ requests,
* if flag is FIELD_VBD_WR, then WRITE requests,
* if flag is FIELD_VBD_RSECT, then READ sectors,
* if flag is FIELD_VBD_WSECT, then WRITE sectors.
*/
static unsigned long long tot_vbd_reqs(xenstat_domain *domain, int flag)
{
int i = 0;
xenstat_vbd *vbd;
unsigned num_vbds = 0;
unsigned long long total = 0;
num_vbds = xenstat_domain_num_vbds(domain);
for ( i=0 ; i < num_vbds ; i++) {
vbd = xenstat_domain_vbd(domain,i);
switch(flag) {
case FIELD_VBD_OO:
total += xenstat_vbd_oo_reqs(vbd);
break;
case FIELD_VBD_RD:
total += xenstat_vbd_rd_reqs(vbd);
break;
case FIELD_VBD_WR:
total += xenstat_vbd_wr_reqs(vbd);
break;
case FIELD_VBD_RSECT:
total += xenstat_vbd_rd_sects(vbd);
break;
case FIELD_VBD_WSECT:
total += xenstat_vbd_wr_sects(vbd);
break;
default:
break;
}
}
return total;
}
/* Compares security id (ssid) of two domains, returning -1,0,1 for <,=,>
*/
static int compare_ssid(xenstat_domain *domain1, xenstat_domain *domain2)
{
return compare(xenstat_domain_ssid(domain1),
xenstat_domain_ssid(domain2));
}
/* Prints ssid statistic */
static void print_ssid(xenstat_domain *domain)
{
printf("%4u", xenstat_domain_ssid(domain));
}
/* Section printing functions */
/* Prints the top summary, above the domain table */
void do_summary(void)
{
#define TIME_STR_LEN 9
const char *TIME_STR_FORMAT = "%H:%M:%S";
char time_str[TIME_STR_LEN];
const char *ver_str;
unsigned run = 0, block = 0, pause = 0,
crash = 0, dying = 0, shutdown = 0;
unsigned i, num_domains = 0;
unsigned long long used = 0;
long freeable_mb = 0;
xenstat_domain *domain;
time_t curt;
/* Print program name, current time, and number of domains */
curt = curtime.tv_sec;
strftime(time_str, TIME_STR_LEN, TIME_STR_FORMAT, localtime(&curt));
num_domains = xenstat_node_num_domains(cur_node);
ver_str = xenstat_node_xen_version(cur_node);
printf("xentop - %s Xen %s\n", time_str, ver_str);
/* Tabulate what states domains are in for summary */
for (i=0; i < num_domains; i++) {
domain = xenstat_node_domain_by_index(cur_node,i);
if (xenstat_domain_running(domain)) run++;
else if (xenstat_domain_blocked(domain)) block++;
else if (xenstat_domain_paused(domain)) pause++;
else if (xenstat_domain_shutdown(domain)) shutdown++;
else if (xenstat_domain_crashed(domain)) crash++;
else if (xenstat_domain_dying(domain)) dying++;
}
printf("%u domains: %u running, %u blocked, %u paused, "
"%u crashed, %u dying, %u shutdown \n",
num_domains, run, block, pause, crash, dying, shutdown);
used = xenstat_node_tot_mem(cur_node)-xenstat_node_free_mem(cur_node);
freeable_mb = xenstat_node_freeable_mb(cur_node);
/* Dump node memory and cpu information */
if ( freeable_mb <= 0 )
printf("Mem: %lluk total, %lluk used, %lluk free ",
xenstat_node_tot_mem(cur_node)/1024, used/1024,
xenstat_node_free_mem(cur_node)/1024);
else
printf("Mem: %lluk total, %lluk used, %lluk free, %ldk freeable,
",
xenstat_node_tot_mem(cur_node)/1024, used/1024,
xenstat_node_free_mem(cur_node)/1024, freeable_mb*1024);
printf("CPUs: %u @ %lluMHz\n",
xenstat_node_num_cpus(cur_node),
xenstat_node_cpu_hz(cur_node)/1000000);
}
/* Output all vcpu information */
void do_vcpu(xenstat_domain
*domain)//*******************************Mina:CPU usage
ns*****************************
{
int i = 0;
unsigned num_vcpus = 0;
xenstat_vcpu *vcpu;
printf("VCPUs(sec): ");
num_vcpus = xenstat_domain_num_vcpus(domain);
/* for all online vcpus dump out values */
for (i=0; i< num_vcpus; i++) {
vcpu = xenstat_domain_vcpu(domain,i);
if (xenstat_vcpu_online(vcpu) > 0) {
if (i != 0 && (i%5)==0)
printf("\n ");
printf(" %2u: %10llus", i,
xenstat_vcpu_ns(vcpu)/1000000000);
}
}
printf("\n");
}
/* Output all network information */
void do_network(xenstat_domain *domain)
{
int i = 0;
xenstat_network *network;
unsigned num_networks = 0;
/* How many networks? */
num_networks = xenstat_domain_num_networks(domain);
printf("%d\n",num_networks);
/* Dump information for each network */
for (i=0; i < num_networks; i++) {
/* Next get the network information */
network = xenstat_domain_network(domain,i);
printf("Net%d RX: %8llubytes %8llupkts %8lluerr %8lludrop",
i,
xenstat_network_rbytes(network),
xenstat_network_rpackets(network),
xenstat_network_rerrs(network),
xenstat_network_rdrop(network));
printf("TX: %8llubytes %8llupkts %8lluerr %8lludrop\n",
xenstat_network_tbytes(network),
xenstat_network_tpackets(network),
xenstat_network_terrs(network),
xenstat_network_tdrop(network));
}
}
/* Output all VBD information */
void do_vbd(xenstat_domain *domain)
{
int i = 0;
xenstat_vbd *vbd;
unsigned num_vbds = 0;
const char *vbd_type[] = {
"Unidentified", /* number 0 */
"BlkBack", /* number 1 */
"BlkTap", /* number 2 */
};
num_vbds = xenstat_domain_num_vbds(domain);
for (i=0 ; i< num_vbds; i++) {
char details[20];
vbd = xenstat_domain_vbd(domain,i);
#if !defined(__linux__)
details[0] = ''\0'';
#else
snprintf(details, 20, "[%2x:%2x] ",
MAJOR(xenstat_vbd_dev(vbd)),
MINOR(xenstat_vbd_dev(vbd)));
#endif
printf("VBD %s %4d %s OO: %8llu RD: %8llu WR: %8llu RSECT: %10llu
WSECT: %10llu\n",
vbd_type[xenstat_vbd_type(vbd)],
xenstat_vbd_dev(vbd), details,
xenstat_vbd_oo_reqs(vbd),
xenstat_vbd_rd_reqs(vbd),
xenstat_vbd_wr_reqs(vbd),
xenstat_vbd_rd_sects(vbd),
xenstat_vbd_wr_sects(vbd));
}
}
/* Output all tmem information */
void do_tmem(xenstat_domain *domain)
{
xenstat_tmem *tmem = xenstat_domain_tmem(domain);
unsigned long long curr_eph_pages = xenstat_tmem_curr_eph_pages(tmem);
unsigned long long succ_eph_gets = xenstat_tmem_succ_eph_gets(tmem);
unsigned long long succ_pers_puts = xenstat_tmem_succ_pers_puts(tmem);
unsigned long long succ_pers_gets = xenstat_tmem_succ_pers_gets(tmem);
if (curr_eph_pages | succ_eph_gets | succ_pers_puts | succ_pers_gets)
printf("Tmem: Curr eph pages: %8llu Succ eph gets: %8llu "
"Succ pers puts: %8llu Succ pers gets: %8llu\n",
curr_eph_pages, succ_eph_gets,
succ_pers_puts, succ_pers_gets);
}
static void top(void)
{
xenstat_domain **domains;
unsigned int i, num_domains = 0 ,num_networks;
/* Now get the node information */
if (prev_node != NULL)
xenstat_free_node(prev_node);
prev_node = cur_node;
cur_node = xenstat_get_node(xhandle, XENSTAT_ALL);
if (cur_node == NULL)
fail("Failed to retrieve statistics from libxenstat\n");
/* Count the number of domains for which to report data */
num_domains = xenstat_node_num_domains(cur_node);
domains = calloc(num_domains, sizeof(xenstat_domain *));
if(domains == NULL)
fail("Failed to allocate memory\n");
for (i=0; i < num_domains; i++)
domains[i] = xenstat_node_domain_by_index(cur_node, i);
/* Sort */
qsort(domains, num_domains, sizeof(xenstat_domain *),
(int(*)(const void *, const void *))compare_domains);
if(first_domain_index >= num_domains)
first_domain_index = num_domains-1;
for (i = first_domain_index; i < num_domains; i++) {
do_vcpu(domains[i]);
printf("%s\n",domains[i]->name);
printf("%d\n",domains[i]->num_networks);
printf("%lx\n",domains[i]->cpu_ns);
do_network(domains[i]);
do_vbd(domains[i]);
do_tmem(domains[i]);
}
free(domains);
}
int main(int argc, char **argv)
{
/* Get xenstat handle */
xhandle = xenstat_init();
if (xhandle == NULL)
fail("Failed to initialize xenstat library\n");
top();
return 0;
}
_______________________________________________
Xen-devel mailing list
Xen-devel@lists.xen.org
http://lists.xen.org/xen-devel