PeterHarding: New page: =rstat_cl.c=

 /* @(#)rstat.x  2.2 88/08/01 4.0 RPCSRC */ * @(#)rstat.x 1.2 87/09/18 Copyr 1987 Sun Micro */  * * Sun RPC is a product of Sun Microsystems, Inc. and is provided for * ...

2008-01-30T02:02:16Z

New page: =rstat_cl.c= <pre> @(#)rstat.x 2.2 88/08/01 4.0 RPCSRC: * @(#)rstat.x 1.2 87/09/18 Copyr 1987 Sun Micro */ * * Sun RPC is a product of Sun Microsystems, Inc. and is provided for * ...

New page

=rstat_cl.c=

<pre>
/* @(#)rstat.x 2.2 88/08/01 4.0 RPCSRC */
* @(#)rstat.x 1.2 87/09/18 Copyr 1987 Sun Micro */

*
* Sun RPC is a product of Sun Microsystems, Inc. and is provided for
* unrestricted use provided that this legend is included on all tape
* media and as a part of the software program in whole or part. Users
* may copy or modify Sun RPC without charge, but are not authorized
* to license or distribute it to anyone else except as part of a product or
* program developed by the user.
*
* SUN RPC IS PROVIDED AS IS WITH NO WARRANTIES OF ANY KIND INCLUDING THE
* WARRANTIES OF DESIGN, MERCHANTIBILITY AND FITNESS FOR A PARTICULAR
* PURPOSE, OR ARISING FROM A COURSE OF DEALING, USAGE OR TRADE PRACTICE.
*
* Sun RPC is provided with no support and without any obligation on the
* part of Sun Microsystems, Inc. to assist in its use, correction,
* modification or enhancement.
*
* SUN MICROSYSTEMS, INC. SHALL HAVE NO LIABILITY WITH RESPECT TO THE
* INFRINGEMENT OF COPYRIGHTS, TRADE SECRETS OR ANY PATENTS BY SUN RPC
* OR ANY PART THEREOF.
*
* In no event will Sun Microsystems, Inc. be liable for any lost revenue
* or profits or other special, indirect and consequential damages, even if
* Sun has been advised of the possibility of such damages.
*
* Sun Microsystems, Inc.
* 2550 Garcia Avenue
* Mountain View, California 94043
*/

/*
* Gather statistics on remote machines
*/

#ifdef RPC_HDR

%#ifndef FSCALE
%/*
% * Scale factor for scaled integers used to count load averages.
% */
%#define FSHIFT 8 /* bits to right of fixed binary point */
%#define FSCALE (1<<FSHIFT)
%
%#endif /* ndef FSCALE */

#endif /* def RPC_HDR */

const CPUSTATES = 4;
const DK_NDRIVE = 4;

/*
* GMT since 0:00, January 1, 1970
*/
struct rstat_timeval {
unsigned int tv_sec; /* seconds */
unsigned int tv_usec; /* and microseconds */
};

struct statstime { /* RSTATVERS_TIME */
int cp_time[CPUSTATES];
int dk_xfer[DK_NDRIVE];
unsigned int v_pgpgin; /* these are cumulative sum */
unsigned int v_pgpgout;
unsigned int v_pswpin;
unsigned int v_pswpout;
unsigned int v_intr;
int if_ipackets;
int if_ierrors;
int if_oerrors;
int if_collisions;
unsigned int v_swtch;
int avenrun[3]; /* scaled by FSCALE */
rstat_timeval boottime;
rstat_timeval curtime;
int if_opackets;
};

struct statsswtch { /* RSTATVERS_SWTCH */
int cp_time[CPUSTATES];
int dk_xfer[DK_NDRIVE];
unsigned int v_pgpgin; /* these are cumulative sum */
unsigned int v_pgpgout;
unsigned int v_pswpin;
unsigned int v_pswpout;
unsigned int v_intr;
int if_ipackets;
int if_ierrors;
int if_oerrors;
int if_collisions;
unsigned int v_swtch;
unsigned int avenrun[3];/* scaled by FSCALE */
rstat_timeval boottime;
int if_opackets;
};

struct stats { /* RSTATVERS_ORIG */
int cp_time[CPUSTATES];
int dk_xfer[DK_NDRIVE];
unsigned int v_pgpgin; /* these are cumulative sum */
unsigned int v_pgpgout;
unsigned int v_pswpin;
unsigned int v_pswpout;
unsigned int v_intr;
int if_ipackets;
int if_ierrors;
int if_oerrors;
int if_collisions;
int if_opackets;
};

program RSTATPROG {
/*
* Newest version includes current time and context switching info
*/
version RSTATVERS_TIME {
statstime
RSTATPROC_STATS(void) = 1;

unsigned int
RSTATPROC_HAVEDISK(void) = 2;
} = 3;
/*
* Does not have current time
*/
version RSTATVERS_SWTCH {
statsswtch
RSTATPROC_STATS(void) = 1;

unsigned int
RSTATPROC_HAVEDISK(void) = 2;
} = 2;
/*
* Old version has no info about current time or context switching
*/
version RSTATVERS_ORIG {
stats
RSTATPROC_STATS(void) = 1;

unsigned int
RSTATPROC_HAVEDISK(void) = 2;
} = 1;
} = 100001;
</pre>

=rstat_client.c=

<pre>
/*
* Please do not edit this file.
* It was generated using rpcgen.
*/

#include <rpc/rpc.h>
#if !defined(__WIN32__) && !defined(_WIN32)
#include <sys/time.h>
#endif
#include "rstat.h"

/* Default timeout can be changed using clnt_control() */
static struct timeval TIMEOUT = { 25, 0 };

statstime *
rstatproc_stats_3(argp, clnt)
void *argp;
CLIENT *clnt;
{
static statstime res;

bzero((char *)&res, sizeof(res));
if (clnt_call(clnt, RSTATPROC_STATS, xdr_void, argp, xdr_statstime, &res, TIMEOUT) != RPC_SUCCESS) {
return (NULL);
}
return (&res);
}

u_int *
rstatproc_havedisk_3(argp, clnt)
void *argp;
CLIENT *clnt;
{
static u_int res;

bzero((char *)&res, sizeof(res));
if (clnt_call(clnt, RSTATPROC_HAVEDISK, xdr_void, argp, xdr_u_int, &res, TIMEOUT) != RPC_SUCCESS) {
return (NULL);
}
return (&res);
}

statsswtch *
rstatproc_stats_2(argp, clnt)
void *argp;
CLIENT *clnt;
{
static statsswtch res;

bzero((char *)&res, sizeof(res));
if (clnt_call(clnt, RSTATPROC_STATS, xdr_void, argp, xdr_statsswtch, &res, TIMEOUT) != RPC_SUCCESS) {
return (NULL);
}
return (&res);
}

u_int *
rstatproc_havedisk_2(argp, clnt)
void *argp;
CLIENT *clnt;
{
static u_int res;

bzero((char *)&res, sizeof(res));
if (clnt_call(clnt, RSTATPROC_HAVEDISK, xdr_void, argp, xdr_u_int, &res, TIMEOUT) != RPC_SUCCESS) {
return (NULL);
}
return (&res);
}

stats *
rstatproc_stats_1(argp, clnt)
void *argp;
CLIENT *clnt;
{
static stats res;

bzero((char *)&res, sizeof(res));
if (clnt_call(clnt, RSTATPROC_STATS, xdr_void, argp, xdr_stats, &res, TIMEOUT) != RPC_SUCCESS) {
return (NULL);
}
return (&res);
}

u_int *
rstatproc_havedisk_1(argp, clnt)
void *argp;
CLIENT *clnt;
{
static u_int res;

bzero((char *)&res, sizeof(res));
if (clnt_call(clnt, RSTATPROC_HAVEDISK, xdr_void, argp, xdr_u_int, &res, TIMEOUT) != RPC_SUCCESS) {
return (NULL);
}
return (&res);
}
</pre>

=rup.c=

<pre>
/*-
* Copyright (c) 1993, John Brezak
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
* 3. All advertising materials mentioning features or use of this software
* must display the following acknowledgement:
* This product includes software developed by the University of
* California, Berkeley and its contributors.
* 4. Neither the name of the University nor the names of its contributors
* may be used to endorse or promote products derived from this software
* without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
*/

char rcsid[] = "$Id: rup.c,v 1.8 2000/07/22 19:51:40 dholland Exp $";

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <sys/param.h>
#include <sys/socket.h>
#include <netdb.h>
#include <rpc/rpc.h>
#include <arpa/inet.h>
#include <rpc/pmap_clnt.h>
#include <getopt.h>
#include <err.h>

#undef FSHIFT /* Use protocol's shift and scale values */
#undef FSCALE
#include <rpcsvc/rstat.h>

#include "../version.h"

#define HOST_WIDTH 24

static int print_rup_data(const char *host, statstime *host_stat);

static int printtime; /* print the remote host(s)'s time */
static int printseconds; /* print in seconds, not formatted */

struct host_list {
struct host_list *next;
struct in_addr addr;
} *hosts;

static
int
search_host(struct in_addr addr)
{
struct host_list *hp;

if (!hosts)
return(0);

for (hp = hosts; hp != NULL; hp = hp->next) {
if (hp->addr.s_addr == addr.s_addr)
return(1);
}
return(0);
}

static
void
remember_host(struct in_addr addr)
{
struct host_list *hp;

if (!(hp = (struct host_list *)malloc(sizeof(struct host_list)))) {
err(1, "malloc");
/* NOTREACHED */
}
hp->addr.s_addr = addr.s_addr;
hp->next = hosts;
hosts = hp;
}

struct rup_data {
char *host;
struct statstime statstime;
};
struct rup_data *rup_data;
int rup_data_idx = 0;
int rup_data_max = 0;

enum sort_type {
SORT_NONE,
SORT_HOST,
SORT_LDAV,
SORT_UPTIME
};
enum sort_type sort_type;

static int
compare(const void *a1, const void *a2)
{
const struct rup_data *d1 = (const struct rup_data *) a1;
const struct rup_data *d2 = (const struct rup_data *) a2;

switch(sort_type) {
case SORT_HOST:
return strcmp(d1->host, d2->host);
case SORT_LDAV:
return d1->statstime.avenrun[0]
- d2->statstime.avenrun[0];
case SORT_UPTIME:
return d1->statstime.boottime.tv_sec
- d2->statstime.boottime.tv_sec;
default:
/* something's really wrong here */
abort();
}
}

static
void
remember_rup_data(const char *host, const struct statstime *st)
{
if (rup_data_idx >= rup_data_max) {
rup_data_max += 16;
rup_data = realloc (rup_data,
rup_data_max * sizeof(struct rup_data));
if (rup_data == NULL) {
err (1, "realloc");
/* NOTREACHED */
}
}

rup_data[rup_data_idx].host = strdup(host);
rup_data[rup_data_idx].statstime = *st;
rup_data_idx++;
}

static
int
rstat_reply(char *replyp, struct sockaddr_in *raddrp)
{
struct hostent *hp;
const char *host;
statstime *host_stat = (statstime *)replyp;

if (!search_host(raddrp->sin_addr)) {
hp = gethostbyaddr((char *)&raddrp->sin_addr.s_addr,
sizeof(struct in_addr), AF_INET);

if (hp)
host = hp->h_name;
else
host = inet_ntoa(raddrp->sin_addr);

remember_host(raddrp->sin_addr);

if (sort_type != SORT_NONE) {
remember_rup_data(host, host_stat);
} else {
print_rup_data(host, host_stat);
}
}

return 0;
}

static
int
print_rup_data(const char *host, statstime *host_stat)
{
time_t hosttime;
long uptime;

printf("%-*.*s", HOST_WIDTH, HOST_WIDTH, host);

hosttime = host_stat->curtime.tv_sec;
host_stat->curtime.tv_sec -= host_stat->boottime.tv_sec;
uptime = host_stat->curtime.tv_sec; /* uptime in seconds */

if (printtime) {
if (printseconds) {
printf(" %-12lld", (unsigned long long) hosttime);
}
else {
struct tm *time = localtime(&hosttime);
printf(" %2d:%02d%cm", time->tm_hour % 12,
time->tm_min,
(time->tm_hour >= 12) ? 'p' : 'a');
}
}

if (printseconds) {
printf(" up %12ld", uptime);
}
else {
uptime /= 60; /* convert to minutes */
printf(" up ");
if (uptime > 24*60) { /* more than 1 day? */
int days = uptime/(24*60);
printf("%3d %s ", days, days > 1 ? "days," : "day, ");
uptime %= (24*60);
}
else {
printf(" ");
}

if (uptime > 60) {
int hours = uptime/60;
int mins = uptime%60;
printf("%2d:%02d, ", hours, mins);
}
else {
printf("%2ld mins, ", uptime);
}
}
printf(" load average: %.2f %.2f %.2f\n",
(double)host_stat->avenrun[0]/FSCALE,
(double)host_stat->avenrun[1]/FSCALE,
(double)host_stat->avenrun[2]/FSCALE);

return(0);
}

static
void
onehost(const char *host)
{
CLIENT *rstat_clnt;
statstime host_stat;
struct timeval foo;

rstat_clnt = clnt_create(host, RSTATPROG, RSTATVERS_TIME, "udp");
if (rstat_clnt == NULL) {
warnx("%s", clnt_spcreateerror(host));
return;
}

memset(&host_stat, 0, sizeof(host_stat));
if (clnt_call(rstat_clnt, RSTATPROC_STATS,
(xdrproc_t) xdr_void, NULL,
(xdrproc_t) xdr_statstime, &host_stat,
foo) != RPC_SUCCESS)
{
warnx("%s", clnt_sperror(rstat_clnt, host));
return;
}

print_rup_data(host, &host_stat);
clnt_destroy(rstat_clnt);
}

static
void
allhosts(void)
{
statstime host_stat;
enum clnt_stat clnt_stat;
int i;

if (sort_type != SORT_NONE) {
printf("collecting responses...");
fflush(stdout);
}

clnt_stat = clnt_broadcast(RSTATPROG, RSTATVERS_TIME, RSTATPROC_STATS,
(xdrproc_t) xdr_void, NULL,
(xdrproc_t) xdr_statstime,
(char *) &host_stat,
(resultproc_t) rstat_reply);
if (clnt_stat != RPC_SUCCESS && clnt_stat != RPC_TIMEDOUT) {
warnx("%s", clnt_sperrno(clnt_stat));
exit(1);
}

if (sort_type != SORT_NONE) {
putchar('\n');
qsort(rup_data, rup_data_idx, sizeof(struct rup_data), compare);

for (i = 0; i < rup_data_idx; i++) {
print_rup_data(rup_data[i].host, &rup_data[i].statstime);
}
}
}

static void usage(void)
{
fprintf(stderr, "Usage: rup [-dhlt] [hosts ...]\n");
exit(1);
}

int main(int argc, char *argv[])
{
int ch;

sort_type = SORT_NONE;
while ((ch = getopt(argc, argv, "dshlt")) != -1)
switch (ch) {
case 'd':
printtime = 1;
break;
case 's':
printseconds = 1;
break;
case 'h':
sort_type = SORT_HOST;
break;
case 'l':
sort_type = SORT_LDAV;
break;
case 't':
sort_type = SORT_UPTIME;
break;
default:
usage();
/*NOTREACHED*/
}

setlinebuf(stdout);

if (argc == optind)
allhosts();
else {
for (; optind < argc; optind++)
onehost(argv[optind]);
}

exit(0);
}
</pre>

Rstatd Clients - Revision history

PeterHarding: New page: =rstat_cl.c=
/* @(#)rstat.x 2.2 88/08/01 4.0 RPCSRC / @(#)rstat.x 1.2 87/09/18 Copyr 1987 Sun Micro / * Sun RPC is a product of Sun Microsystems, Inc. and is provided for * ...