summaryrefslogtreecommitdiff
path: root/usr.sbin/amd/amq
diff options
context:
space:
mode:
authorTheo de Raadt <deraadt@cvs.openbsd.org>2002-09-10 05:34:40 +0000
committerTheo de Raadt <deraadt@cvs.openbsd.org>2002-09-10 05:34:40 +0000
commit3e5da38900c4b3fd49ddf4cbf760d7b8e21a6bed (patch)
tree2557498200aadde243b6477f07d6d822de62dd11 /usr.sbin/amd/amq
parent03b213a22525ec025e74c13039d1284607f80b2e (diff)
various cleanups
Diffstat (limited to 'usr.sbin/amd/amq')
-rw-r--r--usr.sbin/amd/amq/amq.c239
1 files changed, 108 insertions, 131 deletions
diff --git a/usr.sbin/amd/amq/amq.c b/usr.sbin/amd/amq/amq.c
index 320f02ec48a..a39f24eea76 100644
--- a/usr.sbin/amd/amq/amq.c
+++ b/usr.sbin/amd/amq/amq.c
@@ -36,7 +36,7 @@
* SUCH DAMAGE.
*
* from: @(#)amq.c 8.1 (Berkeley) 6/7/93
- * $Id: amq.c,v 1.8 2002/08/05 07:24:26 pvalchev Exp $
+ * $Id: amq.c,v 1.9 2002/09/10 05:34:39 deraadt Exp $
*/
/*
@@ -52,7 +52,7 @@ char copyright[] = "\
#endif /* not lint */
#ifndef lint
-static char rcsid[] = "$Id: amq.c,v 1.8 2002/08/05 07:24:26 pvalchev Exp $";
+static char rcsid[] = "$Id: amq.c,v 1.9 2002/09/10 05:34:39 deraadt Exp $";
static char sccsid[] = "@(#)amq.c 8.1 (Berkeley) 6/7/93";
#endif /* not lint */
@@ -63,7 +63,7 @@ static char sccsid[] = "@(#)amq.c 8.1 (Berkeley) 6/7/93";
#include <netdb.h>
#include <unistd.h>
-static int privsock();
+static int privsock(int);
static int flush_flag;
static int minfo_flag;
@@ -98,62 +98,53 @@ show_mti(amq_mount_tree *mt, enum show_opt e, int *mwid, int *dwid,
int mw = strlen(mt->mt_mountinfo);
int dw = strlen(mt->mt_directory);
int tw = strlen(mt->mt_type);
- if (mw > *mwid) *mwid = mw;
- if (dw > *dwid) *dwid = dw;
- if (tw > *twid) *twid = tw;
- } break;
+
+ if (mw > *mwid)
+ *mwid = mw;
+ if (dw > *dwid)
+ *dwid = dw;
+ if (tw > *twid)
+ *twid = tw;
+ break;
+ }
case Full: {
struct tm *tp = localtime((time_t *) &mt->mt_mounttime);
-printf("%-*.*s %-*.*s %-*.*s %s\n\t%-5d %-7d %-6d %-7d %-7d %-6d %02d/%02d/%02d %02d:%02d:%02d\n",
- *dwid, *dwid,
- *mt->mt_directory ? mt->mt_directory : "/", /* XXX */
- *twid, *twid,
- mt->mt_type,
- *mwid, *mwid,
- mt->mt_mountinfo,
- mt->mt_mountpoint,
-
- mt->mt_mountuid,
- mt->mt_getattr,
- mt->mt_lookup,
- mt->mt_readdir,
- mt->mt_readlink,
- mt->mt_statfs,
-
- tp->tm_year > 99 ? tp->tm_year - 100 : tp->tm_year,
- tp->tm_mon+1, tp->tm_mday,
- tp->tm_hour, tp->tm_min, tp->tm_sec);
- } break;
+
+ printf("%-*.*s %-*.*s %-*.*s %s\n\t%-5d %-7d %-6d"
+ " %-7d %-7d %-6d %02d/%02d/%02d %02d:%02d:%02d\n",
+ *dwid, *dwid, *mt->mt_directory ? mt->mt_directory : "/",
+ *twid, *twid, mt->mt_type, *mwid, *mwid,
+ mt->mt_mountinfo, mt->mt_mountpoint, mt->mt_mountuid,
+ mt->mt_getattr, mt->mt_lookup, mt->mt_readdir,
+ mt->mt_readlink, mt->mt_statfs,
+ tp->tm_year > 99 ? tp->tm_year - 100 : tp->tm_year,
+ tp->tm_mon+1, tp->tm_mday,
+ tp->tm_hour, tp->tm_min, tp->tm_sec);
+ break;
+ }
case Stats: {
struct tm *tp = localtime((time_t *) &mt->mt_mounttime);
-printf("%-*.*s %-5d %-7d %-6d %-7d %-7d %-6d %02d/%02d/%02d %02d:%02d:%02d\n",
- *dwid, *dwid,
- *mt->mt_directory ? mt->mt_directory : "/", /* XXX */
-
- mt->mt_mountuid,
- mt->mt_getattr,
- mt->mt_lookup,
- mt->mt_readdir,
- mt->mt_readlink,
- mt->mt_statfs,
-
- tp->tm_year > 99 ? tp->tm_year - 100 : tp->tm_year,
- tp->tm_mon+1, tp->tm_mday,
- tp->tm_hour, tp->tm_min, tp->tm_sec);
- } break;
+
+ printf("%-*.*s %-5d %-7d %-6d %-7d %-7d %-6d"
+ " %02d/%02d/%02d %02d:%02d:%02d\n",
+ *dwid, *dwid, *mt->mt_directory ? mt->mt_directory : "/",
+ mt->mt_mountuid, mt->mt_getattr, mt->mt_lookup,
+ mt->mt_readdir, mt->mt_readlink, mt->mt_statfs,
+ tp->tm_year > 99 ? tp->tm_year - 100 : tp->tm_year,
+ tp->tm_mon+1, tp->tm_mday,
+ tp->tm_hour, tp->tm_min, tp->tm_sec);
+ break;
+ }
case Short: {
printf("%-*.*s %-*.*s %-*.*s %s\n",
- *dwid, *dwid,
- *mt->mt_directory ? mt->mt_directory : "/",
- *twid, *twid,
- mt->mt_type,
- *mwid, *mwid,
- mt->mt_mountinfo,
- mt->mt_mountpoint);
- } break;
+ *dwid, *dwid, *mt->mt_directory ? mt->mt_directory : "/",
+ *twid, *twid, mt->mt_type, *mwid, *mwid,
+ mt->mt_mountinfo, mt->mt_mountpoint);
+ break;
+ }
}
}
@@ -184,28 +175,34 @@ show_mi(amq_mount_info_list *ml, enum show_opt e, int *mwid,
int mw = strlen(mi->mi_mountinfo);
int dw = strlen(mi->mi_mountpt);
int tw = strlen(mi->mi_type);
- if (mw > *mwid) *mwid = mw;
- if (dw > *dwid) *dwid = dw;
- if (tw > *twid) *twid = tw;
+
+ if (mw > *mwid)
+ *mwid = mw;
+ if (dw > *dwid)
+ *dwid = dw;
+ if (tw > *twid)
+ *twid = tw;
}
- } break;
+ break;
+ }
case Full: {
for (i = 0; i < ml->amq_mount_info_list_len; i++) {
amq_mount_info *mi = &ml->amq_mount_info_list_val[i];
printf("%-*.*s %-*.*s %-*.*s %-3d %s is %s",
- *mwid, *mwid, mi->mi_mountinfo,
- *dwid, *dwid, mi->mi_mountpt,
- *twid, *twid, mi->mi_type,
- mi->mi_refc, mi->mi_fserver,
- mi->mi_up > 0 ? "up" :
- mi->mi_up < 0 ? "starting" : "down");
+ *mwid, *mwid, mi->mi_mountinfo,
+ *dwid, *dwid, mi->mi_mountpt,
+ *twid, *twid, mi->mi_type,
+ mi->mi_refc, mi->mi_fserver,
+ mi->mi_up > 0 ? "up" :
+ mi->mi_up < 0 ? "starting" : "down");
if (mi->mi_error > 0) {
#ifdef HAS_STRERROR
printf(" (%s)", strerror(mi->mi_error));
#else
extern char *sys_errlist[];
extern int sys_nerr;
+
if (mi->mi_error < sys_nerr)
printf(" (%s)", sys_errlist[mi->mi_error]);
else
@@ -216,7 +213,8 @@ show_mi(amq_mount_info_list *ml, enum show_opt e, int *mwid,
}
fputc('\n', stdout);
}
- } break;
+ break;
+ }
}
}
@@ -226,61 +224,32 @@ show_mi(amq_mount_info_list *ml, enum show_opt e, int *mwid,
static void
show_ms(amq_mount_stats *ms)
{
- printf("\
-requests stale mount mount unmount\n\
-deferred fhandles ok failed failed\n\
-%-9d %-9d %-9d %-9d %-9d\n",
- ms->as_drops, ms->as_stale, ms->as_mok, ms->as_merr, ms->as_uerr);
+ printf("requests stale mount mount unmount\n"
+ "deferred fhandles ok failed failed\n"
+ "%-9d %-9d %-9d %-9d %-9d\n",
+ ms->as_drops, ms->as_stale, ms->as_mok, ms->as_merr, ms->as_uerr);
}
static bool_t
xdr_pri_free(xdrproc_t xdr_args, void *args_ptr)
{
XDR xdr;
+
xdr.x_op = XDR_FREE;
return ((*xdr_args)(&xdr, args_ptr));
}
-#ifdef hpux
-#include <cluster.h>
-static char *
-cluster_server()
-{
- struct cct_entry *cp;
-
- if (cnodeid() == 0) {
- /*
- * Not clustered
- */
- return def_server;
- }
-
- while (cp = getccent())
- if (cp->cnode_type == 'r')
- return cp->cnode_name;
-
-
- return def_server;
-}
-#endif /* hpux */
-
/*
* MAIN
*/
int
main(int argc, char *argv[])
{
- int opt_ch;
- int errs = 0;
- char *server;
+ int nodefault = 0, opt_ch, errs = 0, s;
struct sockaddr_in server_addr;
-
- /* In order to pass the Amd security check, we must use a priv port. */
- int s;
-
- CLIENT *clnt;
struct hostent *hp;
- int nodefault = 0;
+ CLIENT *clnt;
+ char *server;
/*
* Parse arguments
@@ -348,20 +317,13 @@ main(int argc, char *argv[])
if (errs) {
show_usage:
- fprintf(stderr, "\
-Usage: %s [-h host] [[-f] [-m] [-v] [-s]] | [[-u] directory ...]] |\n\
-\t[-l logfile|\"syslog\"] [-x log_flags] [-D dbg_opts] [-M mapent]\n", __progname);
+ fprintf(stderr, "usage: %s [-h host] [[-f] [-m] [-v] [-s]]"
+ " | [[-u] directory ...]] |\n"
+ "\t[-l logfile|\"syslog\"] [-x log_flags] "
+ "[-D dbg_opts] [-M mapent]\n", __progname);
exit(1);
}
-#ifdef hpux
- /*
- * Figure out root server of cluster
- */
- if (def_server == localhost)
- server = cluster_server();
- else
-#endif /* hpux */
server = def_server;
/*
@@ -389,7 +351,8 @@ Usage: %s [-h host] [[-f] [-m] [-v] [-s]] | [[-u] directory ...]] |\n\
if (clnt == 0) {
close(s);
s = privsock(SOCK_DGRAM);
- clnt = clntudp_create(&server_addr, AMQ_PROGRAM, AMQ_VERSION, TIMEOUT, &s);
+ clnt = clntudp_create(&server_addr, AMQ_PROGRAM,
+ AMQ_VERSION, TIMEOUT, &s);
}
if (clnt == 0) {
fprintf(stderr, "%s: ", __progname);
@@ -407,10 +370,13 @@ Usage: %s [-h host] [[-f] [-m] [-v] [-s]] | [[-u] directory ...]] |\n\
opt.as_str = debug_opts;
rc = amqproc_setopt_1(&opt, clnt);
if (rc && *rc < 0) {
- fprintf(stderr, "%s: daemon not compiled for debug", __progname);
+ fprintf(stderr,
+ "%s: daemon not compiled for debug", __progname);
errs = 1;
} else if (!rc || *rc > 0) {
- fprintf(stderr, "%s: debug setting for \"%s\" failed\n", __progname, debug_opts);
+ fprintf(stderr,
+ "%s: debug setting for \"%s\" failed\n",
+ __progname, debug_opts);
errs = 1;
}
}
@@ -425,7 +391,8 @@ Usage: %s [-h host] [[-f] [-m] [-v] [-s]] | [[-u] directory ...]] |\n\
opt.as_str = xlog_optstr;
rc = amqproc_setopt_1(&opt, clnt);
if (!rc || *rc) {
- fprintf(stderr, "%s: setting log level to \"%s\" failed\n", __progname, xlog_optstr);
+ fprintf(stderr, "%s: setting log level to \"%s\" failed\n",
+ __progname, xlog_optstr);
errs = 1;
}
}
@@ -440,7 +407,8 @@ Usage: %s [-h host] [[-f] [-m] [-v] [-s]] | [[-u] directory ...]] |\n\
opt.as_str = logfile;
rc = amqproc_setopt_1(&opt, clnt);
if (!rc || *rc) {
- fprintf(stderr, "%s: setting logfile to \"%s\" failed\n", __progname, logfile);
+ fprintf(stderr, "%s: setting logfile to \"%s\" failed\n",
+ __progname, logfile);
errs = 1;
}
}
@@ -455,7 +423,9 @@ Usage: %s [-h host] [[-f] [-m] [-v] [-s]] | [[-u] directory ...]] |\n\
opt.as_str = "";
rc = amqproc_setopt_1(&opt, clnt);
if (!rc || *rc) {
- fprintf(stderr, "%s: amd on %s cannot flush the map cache\n", __progname, server);
+ fprintf(stderr,
+ "%s: amd on %s cannot flush the map cache\n",
+ __progname, server);
errs = 1;
}
}
@@ -471,9 +441,9 @@ Usage: %s [-h host] [[-f] [-m] [-v] [-s]] | [[-u] directory ...]] |\n\
show_mi(ml, Calc, &mwid, &dwid, &twid);
mwid++; dwid++; twid++;
show_mi(ml, Full, &mwid, &dwid, &twid);
-
} else {
- fprintf(stderr, "%s: amd on %s cannot provide mount info\n", __progname, server);
+ fprintf(stderr, "%s: amd on %s cannot provide mount info\n",
+ __progname, server);
}
}
@@ -504,7 +474,8 @@ Usage: %s [-h host] [[-f] [-m] [-v] [-s]] | [[-u] directory ...]] |\n\
printf("%s.\n", *spp);
free(*spp);
} else {
- fprintf(stderr, "%s: failed to get version information\n", __progname);
+ fprintf(stderr, "%s: failed to get version information\n",
+ __progname);
errs = 1;
}
}
@@ -529,13 +500,21 @@ Usage: %s [-h host] [[-f] [-m] [-v] [-s]] | [[-u] directory ...]] |\n\
amq_mount_tree *mt = *mtp;
if (mt) {
int mwid = 0, dwid = 0, twid = 0;
+
show_mt(mt, Calc, &mwid, &dwid, &twid);
- mwid++; dwid++, twid++;
- printf("%-*.*s Uid Getattr Lookup RdDir RdLnk Statfs Mounted@\n",
- dwid, dwid, "What");
+ mwid++;
+ dwid++;
+ twid++;
+
+ printf("%-*.*s Uid Getattr "
+ "Lookup RdDir RdLnk "
+ "Statfs Mounted@\n",
+ dwid, dwid, "What");
show_mt(mt, Stats, &mwid, &dwid, &twid);
} else {
- fprintf(stderr, "%s: %s not automounted\n", __progname, fs);
+ fprintf(stderr,
+ "%s: %s not automounted\n",
+ __progname, fs);
}
xdr_pri_free(xdr_amq_mount_tree_p, mtp);
} else {
@@ -586,12 +565,11 @@ Usage: %s [-h host] [[-f] [-m] [-v] [-s]] | [[-u] directory ...]] |\n\
* secure port.
* returns: The bound socket, or -1 to indicate an error.
*/
-static int inetresport(ty)
-int ty;
+static int
+inetresport(int ty)
{
- int alport;
struct sockaddr_in addr;
- int sock;
+ int alport, sock;
/* Use internet address family */
addr.sin_family = AF_INET;
@@ -618,8 +596,8 @@ int ty;
* indicates to RPC that it should make its own socket.
* returns: A privileged socket # or RPC_ANYSOCK.
*/
-static int privsock(ty)
-int ty;
+static int
+privsock(int ty)
{
int sock = inetresport(ty);
@@ -632,9 +610,8 @@ int ty;
}
#ifdef DEBUG
-xfree(f, l, p)
-char *f, *l;
-void *p;
+void
+xfree(char *f, char *l, void *p)
{
free(p);
}