1df930be7Sderaadt /*
2df930be7Sderaadt * Copyright (c) 1990 Jan-Simon Pendry
3df930be7Sderaadt * Copyright (c) 1990 Imperial College of Science, Technology & Medicine
4df930be7Sderaadt * Copyright (c) 1990, 1993
5df930be7Sderaadt * The Regents of the University of California. All rights reserved.
6df930be7Sderaadt *
7df930be7Sderaadt * This code is derived from software contributed to Berkeley by
8df930be7Sderaadt * Jan-Simon Pendry at Imperial College, London.
9df930be7Sderaadt *
10df930be7Sderaadt * Redistribution and use in source and binary forms, with or without
11df930be7Sderaadt * modification, are permitted provided that the following conditions
12df930be7Sderaadt * are met:
13df930be7Sderaadt * 1. Redistributions of source code must retain the above copyright
14df930be7Sderaadt * notice, this list of conditions and the following disclaimer.
15df930be7Sderaadt * 2. Redistributions in binary form must reproduce the above copyright
16df930be7Sderaadt * notice, this list of conditions and the following disclaimer in the
17df930be7Sderaadt * documentation and/or other materials provided with the distribution.
1829295d1cSmillert * 3. Neither the name of the University nor the names of its contributors
19df930be7Sderaadt * may be used to endorse or promote products derived from this software
20df930be7Sderaadt * without specific prior written permission.
21df930be7Sderaadt *
22df930be7Sderaadt * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
23df930be7Sderaadt * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
24df930be7Sderaadt * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
25df930be7Sderaadt * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
26df930be7Sderaadt * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
27df930be7Sderaadt * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
28df930be7Sderaadt * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
29df930be7Sderaadt * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
30df930be7Sderaadt * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
31df930be7Sderaadt * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
32df930be7Sderaadt * SUCH DAMAGE.
33df930be7Sderaadt *
34df930be7Sderaadt * from: @(#)amq.c 8.1 (Berkeley) 6/7/93
35*10a7b758Smillert * $Id: amq.c,v 1.22 2021/11/15 15:14:24 millert Exp $
36df930be7Sderaadt */
37df930be7Sderaadt
38df930be7Sderaadt /*
39df930be7Sderaadt * Automounter query tool
40df930be7Sderaadt */
41df930be7Sderaadt
42df930be7Sderaadt #include "am.h"
43df930be7Sderaadt #include "amq.h"
44df930be7Sderaadt #include <stdio.h>
45df930be7Sderaadt #include <fcntl.h>
46df930be7Sderaadt #include <netdb.h>
479ad2d6d5Spvalchev #include <unistd.h>
48df930be7Sderaadt
49072e3d80Sderaadt static int privsock(int);
50df930be7Sderaadt
51df930be7Sderaadt static int flush_flag;
52df930be7Sderaadt static int minfo_flag;
53df930be7Sderaadt static int unmount_flag;
54df930be7Sderaadt static int stats_flag;
55df930be7Sderaadt static int getvers_flag;
56df930be7Sderaadt static char *debug_opts;
57df930be7Sderaadt static char *logfile;
58df930be7Sderaadt static char *xlog_optstr;
59df930be7Sderaadt static char localhost[] = "localhost";
60df930be7Sderaadt static char *def_server = localhost;
61df930be7Sderaadt
62df930be7Sderaadt static struct timeval tmo = { 10, 0 };
63df930be7Sderaadt #define TIMEOUT tmo
64df930be7Sderaadt
65df930be7Sderaadt enum show_opt { Full, Stats, Calc, Short, ShowDone };
66df930be7Sderaadt
67df930be7Sderaadt /*
68df930be7Sderaadt * If (e) is Calc then just calculate the sizes
69df930be7Sderaadt * Otherwise display the mount node on stdout
70df930be7Sderaadt */
719ad2d6d5Spvalchev static void
show_mti(amq_mount_tree * mt,enum show_opt e,int * mwid,int * dwid,int * twid)729ad2d6d5Spvalchev show_mti(amq_mount_tree *mt, enum show_opt e, int *mwid, int *dwid,
739ad2d6d5Spvalchev int *twid)
74df930be7Sderaadt {
75df930be7Sderaadt switch (e) {
76df930be7Sderaadt case Calc: {
77df930be7Sderaadt int mw = strlen(mt->mt_mountinfo);
78df930be7Sderaadt int dw = strlen(mt->mt_directory);
79df930be7Sderaadt int tw = strlen(mt->mt_type);
80072e3d80Sderaadt
81072e3d80Sderaadt if (mw > *mwid)
82072e3d80Sderaadt *mwid = mw;
83072e3d80Sderaadt if (dw > *dwid)
84072e3d80Sderaadt *dwid = dw;
85072e3d80Sderaadt if (tw > *twid)
86072e3d80Sderaadt *twid = tw;
87072e3d80Sderaadt break;
88072e3d80Sderaadt }
89df930be7Sderaadt
90df930be7Sderaadt case Full: {
913f49765fSguenther time_t t = mt->mt_mounttime;
925cab1010Sderaadt
935cab1010Sderaadt struct tm *tp = localtime(&t);
94df930be7Sderaadt
95072e3d80Sderaadt printf("%-*.*s %-*.*s %-*.*s %s\n\t%-5d %-7d %-6d"
96072e3d80Sderaadt " %-7d %-7d %-6d %02d/%02d/%02d %02d:%02d:%02d\n",
97072e3d80Sderaadt *dwid, *dwid, *mt->mt_directory ? mt->mt_directory : "/",
98072e3d80Sderaadt *twid, *twid, mt->mt_type, *mwid, *mwid,
99072e3d80Sderaadt mt->mt_mountinfo, mt->mt_mountpoint, mt->mt_mountuid,
100072e3d80Sderaadt mt->mt_getattr, mt->mt_lookup, mt->mt_readdir,
101072e3d80Sderaadt mt->mt_readlink, mt->mt_statfs,
102df930be7Sderaadt tp->tm_year > 99 ? tp->tm_year - 100 : tp->tm_year,
103df930be7Sderaadt tp->tm_mon+1, tp->tm_mday,
104df930be7Sderaadt tp->tm_hour, tp->tm_min, tp->tm_sec);
105072e3d80Sderaadt break;
106072e3d80Sderaadt }
107df930be7Sderaadt
108df930be7Sderaadt case Stats: {
1093f49765fSguenther time_t t = mt->mt_mounttime;
1105cab1010Sderaadt
1115cab1010Sderaadt struct tm *tp = localtime(&t);
112df930be7Sderaadt
113072e3d80Sderaadt printf("%-*.*s %-5d %-7d %-6d %-7d %-7d %-6d"
114072e3d80Sderaadt " %02d/%02d/%02d %02d:%02d:%02d\n",
115072e3d80Sderaadt *dwid, *dwid, *mt->mt_directory ? mt->mt_directory : "/",
116072e3d80Sderaadt mt->mt_mountuid, mt->mt_getattr, mt->mt_lookup,
117072e3d80Sderaadt mt->mt_readdir, mt->mt_readlink, mt->mt_statfs,
118df930be7Sderaadt tp->tm_year > 99 ? tp->tm_year - 100 : tp->tm_year,
119df930be7Sderaadt tp->tm_mon+1, tp->tm_mday,
120df930be7Sderaadt tp->tm_hour, tp->tm_min, tp->tm_sec);
121072e3d80Sderaadt break;
122072e3d80Sderaadt }
123df930be7Sderaadt
124df930be7Sderaadt case Short: {
125df930be7Sderaadt printf("%-*.*s %-*.*s %-*.*s %s\n",
126072e3d80Sderaadt *dwid, *dwid, *mt->mt_directory ? mt->mt_directory : "/",
127072e3d80Sderaadt *twid, *twid, mt->mt_type, *mwid, *mwid,
128072e3d80Sderaadt mt->mt_mountinfo, mt->mt_mountpoint);
129072e3d80Sderaadt break;
130072e3d80Sderaadt }
1319313a659Skrw
1329313a659Skrw default:
1339313a659Skrw break;
134df930be7Sderaadt }
135df930be7Sderaadt }
136df930be7Sderaadt
137df930be7Sderaadt /*
138df930be7Sderaadt * Display a mount tree.
139df930be7Sderaadt */
1409ad2d6d5Spvalchev static void
show_mt(amq_mount_tree * mt,enum show_opt e,int * mwid,int * dwid,int * pwid)1419ad2d6d5Spvalchev show_mt(amq_mount_tree *mt, enum show_opt e, int *mwid, int *dwid,
1429ad2d6d5Spvalchev int *pwid)
143df930be7Sderaadt {
144df930be7Sderaadt while (mt) {
145df930be7Sderaadt show_mti(mt, e, mwid, dwid, pwid);
146df930be7Sderaadt show_mt(mt->mt_next, e, mwid, dwid, pwid);
147df930be7Sderaadt mt = mt->mt_child;
148df930be7Sderaadt }
149df930be7Sderaadt }
150df930be7Sderaadt
1519ad2d6d5Spvalchev static void
show_mi(amq_mount_info_list * ml,enum show_opt e,int * mwid,int * dwid,int * twid)1529ad2d6d5Spvalchev show_mi(amq_mount_info_list *ml, enum show_opt e, int *mwid,
1539ad2d6d5Spvalchev int *dwid, int *twid)
154df930be7Sderaadt {
155df930be7Sderaadt int i;
1569ad2d6d5Spvalchev
157df930be7Sderaadt switch (e) {
158df930be7Sderaadt case Calc: {
159df930be7Sderaadt for (i = 0; i < ml->amq_mount_info_list_len; i++) {
160df930be7Sderaadt amq_mount_info *mi = &ml->amq_mount_info_list_val[i];
161df930be7Sderaadt int mw = strlen(mi->mi_mountinfo);
162df930be7Sderaadt int dw = strlen(mi->mi_mountpt);
163df930be7Sderaadt int tw = strlen(mi->mi_type);
164072e3d80Sderaadt
165072e3d80Sderaadt if (mw > *mwid)
166072e3d80Sderaadt *mwid = mw;
167072e3d80Sderaadt if (dw > *dwid)
168072e3d80Sderaadt *dwid = dw;
169072e3d80Sderaadt if (tw > *twid)
170072e3d80Sderaadt *twid = tw;
171df930be7Sderaadt }
172072e3d80Sderaadt break;
173072e3d80Sderaadt }
174df930be7Sderaadt
175df930be7Sderaadt case Full: {
176df930be7Sderaadt for (i = 0; i < ml->amq_mount_info_list_len; i++) {
177df930be7Sderaadt amq_mount_info *mi = &ml->amq_mount_info_list_val[i];
178df930be7Sderaadt printf("%-*.*s %-*.*s %-*.*s %-3d %s is %s",
179df930be7Sderaadt *mwid, *mwid, mi->mi_mountinfo,
180df930be7Sderaadt *dwid, *dwid, mi->mi_mountpt,
181df930be7Sderaadt *twid, *twid, mi->mi_type,
182df930be7Sderaadt mi->mi_refc, mi->mi_fserver,
183df930be7Sderaadt mi->mi_up > 0 ? "up" :
184df930be7Sderaadt mi->mi_up < 0 ? "starting" : "down");
185df930be7Sderaadt if (mi->mi_error > 0) {
186df930be7Sderaadt printf(" (%s)", strerror(mi->mi_error));
187df930be7Sderaadt } else if (mi->mi_error < 0) {
188df930be7Sderaadt fputs(" (in progress)", stdout);
189df930be7Sderaadt }
190df930be7Sderaadt fputc('\n', stdout);
191df930be7Sderaadt }
192072e3d80Sderaadt break;
193072e3d80Sderaadt }
1949313a659Skrw default:
1959313a659Skrw break;
196df930be7Sderaadt }
197df930be7Sderaadt }
198df930be7Sderaadt
199df930be7Sderaadt /*
200df930be7Sderaadt * Display general mount statistics
201df930be7Sderaadt */
2029ad2d6d5Spvalchev static void
show_ms(amq_mount_stats * ms)2039ad2d6d5Spvalchev show_ms(amq_mount_stats *ms)
204df930be7Sderaadt {
205072e3d80Sderaadt printf("requests stale mount mount unmount\n"
206072e3d80Sderaadt "deferred fhandles ok failed failed\n"
207072e3d80Sderaadt "%-9d %-9d %-9d %-9d %-9d\n",
208df930be7Sderaadt ms->as_drops, ms->as_stale, ms->as_mok, ms->as_merr, ms->as_uerr);
209df930be7Sderaadt }
210df930be7Sderaadt
211df930be7Sderaadt static bool_t
xdr_pri_free(xdrproc_t xdr_args,void * args_ptr)212587ddfa4Sderaadt xdr_pri_free(xdrproc_t xdr_args, void *args_ptr)
213df930be7Sderaadt {
214df930be7Sderaadt XDR xdr;
215072e3d80Sderaadt
216df930be7Sderaadt xdr.x_op = XDR_FREE;
217df930be7Sderaadt return ((*xdr_args)(&xdr, args_ptr));
218df930be7Sderaadt }
219df930be7Sderaadt
220df930be7Sderaadt /*
221df930be7Sderaadt * MAIN
222df930be7Sderaadt */
2239ad2d6d5Spvalchev int
main(int argc,char * argv[])2249ad2d6d5Spvalchev main(int argc, char *argv[])
225df930be7Sderaadt {
226072e3d80Sderaadt int nodefault = 0, opt_ch, errs = 0, s;
227df930be7Sderaadt struct sockaddr_in server_addr;
228df930be7Sderaadt struct hostent *hp;
229072e3d80Sderaadt CLIENT *clnt;
230072e3d80Sderaadt char *server;
231df930be7Sderaadt
232df930be7Sderaadt /*
233df930be7Sderaadt * Parse arguments
234df930be7Sderaadt */
23535e2d75aSguenther while ((opt_ch = getopt(argc, argv, "fh:l:msuvx:D:")) != -1)
236df930be7Sderaadt switch (opt_ch) {
237df930be7Sderaadt case 'f':
238df930be7Sderaadt flush_flag = 1;
239df930be7Sderaadt nodefault = 1;
240df930be7Sderaadt break;
241df930be7Sderaadt
242df930be7Sderaadt case 'h':
243df930be7Sderaadt def_server = optarg;
244df930be7Sderaadt break;
245df930be7Sderaadt
246df930be7Sderaadt case 'l':
247df930be7Sderaadt logfile = optarg;
248df930be7Sderaadt nodefault = 1;
249df930be7Sderaadt break;
250df930be7Sderaadt
251df930be7Sderaadt case 'm':
252df930be7Sderaadt minfo_flag = 1;
253df930be7Sderaadt nodefault = 1;
254df930be7Sderaadt break;
255df930be7Sderaadt
256df930be7Sderaadt case 's':
257df930be7Sderaadt stats_flag = 1;
258df930be7Sderaadt nodefault = 1;
259df930be7Sderaadt break;
260df930be7Sderaadt
261df930be7Sderaadt case 'u':
262df930be7Sderaadt unmount_flag = 1;
263df930be7Sderaadt nodefault = 1;
264df930be7Sderaadt break;
265df930be7Sderaadt
266df930be7Sderaadt case 'v':
267df930be7Sderaadt getvers_flag = 1;
268df930be7Sderaadt nodefault = 1;
269df930be7Sderaadt break;
270df930be7Sderaadt
271df930be7Sderaadt case 'x':
272df930be7Sderaadt xlog_optstr = optarg;
273df930be7Sderaadt nodefault = 1;
274df930be7Sderaadt break;
275df930be7Sderaadt
276df930be7Sderaadt case 'D':
277df930be7Sderaadt debug_opts = optarg;
278df930be7Sderaadt nodefault = 1;
279df930be7Sderaadt break;
280df930be7Sderaadt
281df930be7Sderaadt default:
282df930be7Sderaadt errs = 1;
283df930be7Sderaadt break;
284df930be7Sderaadt }
285df930be7Sderaadt
286df930be7Sderaadt if (optind == argc) {
287df930be7Sderaadt if (unmount_flag)
288df930be7Sderaadt errs = 1;
289df930be7Sderaadt }
290df930be7Sderaadt
291df930be7Sderaadt if (errs) {
292df930be7Sderaadt show_usage:
29397452568Sjmc fprintf(stderr, "usage: %s [-fmsuv] [-h hostname] "
29497452568Sjmc "[directory ...]\n", __progname);
295df930be7Sderaadt exit(1);
296df930be7Sderaadt }
297df930be7Sderaadt
298df930be7Sderaadt server = def_server;
299df930be7Sderaadt
300df930be7Sderaadt /*
301df930be7Sderaadt * Get address of server
302df930be7Sderaadt */
303df930be7Sderaadt if ((hp = gethostbyname(server)) == 0 && strcmp(server, localhost) != 0) {
3049ad2d6d5Spvalchev fprintf(stderr, "%s: Can't get address of %s\n", __progname, server);
305df930be7Sderaadt exit(1);
306df930be7Sderaadt }
307df930be7Sderaadt bzero(&server_addr, sizeof server_addr);
308df930be7Sderaadt server_addr.sin_family = AF_INET;
309df930be7Sderaadt if (hp) {
31026d0c865Sguenther bcopy(hp->h_addr, &server_addr.sin_addr,
311df930be7Sderaadt sizeof(server_addr.sin_addr));
312df930be7Sderaadt } else {
313df930be7Sderaadt /* fake "localhost" */
314df930be7Sderaadt server_addr.sin_addr.s_addr = htonl(0x7f000001);
315df930be7Sderaadt }
316df930be7Sderaadt
317df930be7Sderaadt /*
318df930be7Sderaadt * Create RPC endpoint
319df930be7Sderaadt */
320df930be7Sderaadt s = privsock(SOCK_STREAM);
321df930be7Sderaadt clnt = clnttcp_create(&server_addr, AMQ_PROGRAM, AMQ_VERSION, &s, 0, 0);
322df930be7Sderaadt if (clnt == 0) {
323df930be7Sderaadt close(s);
324df930be7Sderaadt s = privsock(SOCK_DGRAM);
325072e3d80Sderaadt clnt = clntudp_create(&server_addr, AMQ_PROGRAM,
326072e3d80Sderaadt AMQ_VERSION, TIMEOUT, &s);
327df930be7Sderaadt }
328df930be7Sderaadt if (clnt == 0) {
3299ad2d6d5Spvalchev fprintf(stderr, "%s: ", __progname);
330df930be7Sderaadt clnt_pcreateerror(server);
331df930be7Sderaadt exit(1);
332df930be7Sderaadt }
333df930be7Sderaadt
334df930be7Sderaadt /*
335df930be7Sderaadt * Control debugging
336df930be7Sderaadt */
337df930be7Sderaadt if (debug_opts) {
338df930be7Sderaadt int *rc;
339df930be7Sderaadt amq_setopt opt;
340df930be7Sderaadt opt.as_opt = AMOPT_DEBUG;
341df930be7Sderaadt opt.as_str = debug_opts;
34235e2d75aSguenther rc = amqproc_setopt_57(&opt, clnt);
343df930be7Sderaadt if (rc && *rc < 0) {
344072e3d80Sderaadt fprintf(stderr,
345072e3d80Sderaadt "%s: daemon not compiled for debug", __progname);
346df930be7Sderaadt errs = 1;
347df930be7Sderaadt } else if (!rc || *rc > 0) {
348072e3d80Sderaadt fprintf(stderr,
349072e3d80Sderaadt "%s: debug setting for \"%s\" failed\n",
350072e3d80Sderaadt __progname, debug_opts);
351df930be7Sderaadt errs = 1;
352df930be7Sderaadt }
353df930be7Sderaadt }
354df930be7Sderaadt
355df930be7Sderaadt /*
356df930be7Sderaadt * Control logging
357df930be7Sderaadt */
358df930be7Sderaadt if (xlog_optstr) {
359df930be7Sderaadt int *rc;
360df930be7Sderaadt amq_setopt opt;
361df930be7Sderaadt opt.as_opt = AMOPT_XLOG;
362df930be7Sderaadt opt.as_str = xlog_optstr;
36335e2d75aSguenther rc = amqproc_setopt_57(&opt, clnt);
364df930be7Sderaadt if (!rc || *rc) {
365072e3d80Sderaadt fprintf(stderr, "%s: setting log level to \"%s\" failed\n",
366072e3d80Sderaadt __progname, xlog_optstr);
367df930be7Sderaadt errs = 1;
368df930be7Sderaadt }
369df930be7Sderaadt }
370df930be7Sderaadt
371df930be7Sderaadt /*
372df930be7Sderaadt * Control log file
373df930be7Sderaadt */
374df930be7Sderaadt if (logfile) {
375df930be7Sderaadt int *rc;
376df930be7Sderaadt amq_setopt opt;
377df930be7Sderaadt opt.as_opt = AMOPT_LOGFILE;
378df930be7Sderaadt opt.as_str = logfile;
37935e2d75aSguenther rc = amqproc_setopt_57(&opt, clnt);
380df930be7Sderaadt if (!rc || *rc) {
381072e3d80Sderaadt fprintf(stderr, "%s: setting logfile to \"%s\" failed\n",
382072e3d80Sderaadt __progname, logfile);
383df930be7Sderaadt errs = 1;
384df930be7Sderaadt }
385df930be7Sderaadt }
386df930be7Sderaadt
387df930be7Sderaadt /*
388df930be7Sderaadt * Flush map cache
389df930be7Sderaadt */
390df930be7Sderaadt if (flush_flag) {
391df930be7Sderaadt int *rc;
392df930be7Sderaadt amq_setopt opt;
393df930be7Sderaadt opt.as_opt = AMOPT_FLUSHMAPC;
394df930be7Sderaadt opt.as_str = "";
39535e2d75aSguenther rc = amqproc_setopt_57(&opt, clnt);
396df930be7Sderaadt if (!rc || *rc) {
397072e3d80Sderaadt fprintf(stderr,
398072e3d80Sderaadt "%s: amd on %s cannot flush the map cache\n",
399072e3d80Sderaadt __progname, server);
400df930be7Sderaadt errs = 1;
401df930be7Sderaadt }
402df930be7Sderaadt }
403df930be7Sderaadt
404df930be7Sderaadt /*
405df930be7Sderaadt * Mount info
406df930be7Sderaadt */
407df930be7Sderaadt if (minfo_flag) {
408df930be7Sderaadt int dummy;
40935e2d75aSguenther amq_mount_info_list *ml = amqproc_getmntfs_57(&dummy, clnt);
410df930be7Sderaadt if (ml) {
411df930be7Sderaadt int mwid = 0, dwid = 0, twid = 0;
412df930be7Sderaadt show_mi(ml, Calc, &mwid, &dwid, &twid);
413df930be7Sderaadt mwid++; dwid++; twid++;
414df930be7Sderaadt show_mi(ml, Full, &mwid, &dwid, &twid);
415df930be7Sderaadt } else {
416072e3d80Sderaadt fprintf(stderr, "%s: amd on %s cannot provide mount info\n",
417072e3d80Sderaadt __progname, server);
418df930be7Sderaadt }
419df930be7Sderaadt }
420df930be7Sderaadt
421df930be7Sderaadt /*
422df930be7Sderaadt * Get Version
423df930be7Sderaadt */
424df930be7Sderaadt if (getvers_flag) {
42535e2d75aSguenther amq_string *spp = amqproc_getvers_57(NULL, clnt);
426df930be7Sderaadt if (spp && *spp) {
427df930be7Sderaadt printf("%s.\n", *spp);
428df930be7Sderaadt free(*spp);
429df930be7Sderaadt } else {
430072e3d80Sderaadt fprintf(stderr, "%s: failed to get version information\n",
431072e3d80Sderaadt __progname);
432df930be7Sderaadt errs = 1;
433df930be7Sderaadt }
434df930be7Sderaadt }
435df930be7Sderaadt
436df930be7Sderaadt /*
437df930be7Sderaadt * Apply required operation to all remaining arguments
438df930be7Sderaadt */
439df930be7Sderaadt if (optind < argc) {
440df930be7Sderaadt do {
441df930be7Sderaadt char *fs = argv[optind++];
442df930be7Sderaadt if (unmount_flag) {
443df930be7Sderaadt /*
444df930be7Sderaadt * Unmount request
445df930be7Sderaadt */
44635e2d75aSguenther amqproc_umnt_57(&fs, clnt);
447df930be7Sderaadt } else {
448df930be7Sderaadt /*
449df930be7Sderaadt * Stats request
450df930be7Sderaadt */
45135e2d75aSguenther amq_mount_tree_p *mtp = amqproc_mnttree_57(&fs, clnt);
452df930be7Sderaadt if (mtp) {
453df930be7Sderaadt amq_mount_tree *mt = *mtp;
454df930be7Sderaadt if (mt) {
455df930be7Sderaadt int mwid = 0, dwid = 0, twid = 0;
456072e3d80Sderaadt
457df930be7Sderaadt show_mt(mt, Calc, &mwid, &dwid, &twid);
458072e3d80Sderaadt mwid++;
459072e3d80Sderaadt dwid++;
460072e3d80Sderaadt twid++;
461072e3d80Sderaadt
462072e3d80Sderaadt printf("%-*.*s Uid Getattr "
463072e3d80Sderaadt "Lookup RdDir RdLnk "
464072e3d80Sderaadt "Statfs Mounted@\n",
465df930be7Sderaadt dwid, dwid, "What");
466df930be7Sderaadt show_mt(mt, Stats, &mwid, &dwid, &twid);
467df930be7Sderaadt } else {
468072e3d80Sderaadt fprintf(stderr,
469072e3d80Sderaadt "%s: %s not automounted\n",
470072e3d80Sderaadt __progname, fs);
471df930be7Sderaadt }
472587ddfa4Sderaadt xdr_pri_free(xdr_amq_mount_tree_p, mtp);
473df930be7Sderaadt } else {
4749ad2d6d5Spvalchev fprintf(stderr, "%s: ", __progname);
475df930be7Sderaadt clnt_perror(clnt, server);
476df930be7Sderaadt errs = 1;
477df930be7Sderaadt }
478df930be7Sderaadt }
479df930be7Sderaadt } while (optind < argc);
480df930be7Sderaadt } else if (unmount_flag) {
481df930be7Sderaadt goto show_usage;
482df930be7Sderaadt } else if (stats_flag) {
48335e2d75aSguenther amq_mount_stats *ms = amqproc_stats_57(NULL, clnt);
484df930be7Sderaadt if (ms) {
485df930be7Sderaadt show_ms(ms);
486df930be7Sderaadt } else {
4879ad2d6d5Spvalchev fprintf(stderr, "%s: ", __progname);
488df930be7Sderaadt clnt_perror(clnt, server);
489df930be7Sderaadt errs = 1;
490df930be7Sderaadt }
491df930be7Sderaadt } else if (!nodefault) {
49235e2d75aSguenther amq_mount_tree_list *mlp = amqproc_export_57(NULL, clnt);
493df930be7Sderaadt if (mlp) {
494df930be7Sderaadt enum show_opt e = Calc;
495df930be7Sderaadt int mwid = 0, dwid = 0, pwid = 0;
496045fe502Sderaadt
497df930be7Sderaadt while (e != ShowDone) {
498df930be7Sderaadt int i;
499045fe502Sderaadt
500df930be7Sderaadt for (i = 0; i < mlp->amq_mount_tree_list_len; i++) {
501df930be7Sderaadt show_mt(mlp->amq_mount_tree_list_val[i],
502df930be7Sderaadt e, &mwid, &dwid, &pwid);
503df930be7Sderaadt }
504045fe502Sderaadt mwid++;
505045fe502Sderaadt dwid++;
506045fe502Sderaadt pwid++;
507045fe502Sderaadt if (e == Calc)
508045fe502Sderaadt e = Short;
509045fe502Sderaadt else if (e == Short)
510045fe502Sderaadt e = ShowDone;
511df930be7Sderaadt }
512df930be7Sderaadt } else {
5139ad2d6d5Spvalchev fprintf(stderr, "%s: ", __progname);
514df930be7Sderaadt clnt_perror(clnt, server);
515df930be7Sderaadt errs = 1;
516df930be7Sderaadt }
517df930be7Sderaadt }
518df930be7Sderaadt
519df930be7Sderaadt exit(errs);
520df930be7Sderaadt }
521df930be7Sderaadt
522df930be7Sderaadt /*
523df930be7Sderaadt * udpresport creates a datagram socket and attempts to bind it to a
524df930be7Sderaadt * secure port.
525df930be7Sderaadt * returns: The bound socket, or -1 to indicate an error.
526df930be7Sderaadt */
527072e3d80Sderaadt static int
inetresport(int ty)528072e3d80Sderaadt inetresport(int ty)
529df930be7Sderaadt {
530db4d2d4dSderaadt struct sockaddr_in addr;
531072e3d80Sderaadt int alport, sock;
532df930be7Sderaadt
533db4d2d4dSderaadt /* Use internet address family */
534db4d2d4dSderaadt addr.sin_family = AF_INET;
535db4d2d4dSderaadt addr.sin_addr.s_addr = INADDR_ANY;
536db4d2d4dSderaadt if ((sock = socket(AF_INET, ty, 0)) < 0)
537db4d2d4dSderaadt return -1;
538db4d2d4dSderaadt for (alport = IPPORT_RESERVED-1; alport > IPPORT_RESERVED/2 + 1; alport--) {
539db4d2d4dSderaadt addr.sin_port = htons((u_short)alport);
540db4d2d4dSderaadt if (bind(sock, (struct sockaddr *)&addr, sizeof (addr)) >= 0)
541db4d2d4dSderaadt return sock;
542db4d2d4dSderaadt if (errno != EADDRINUSE) {
543db4d2d4dSderaadt close(sock);
544df930be7Sderaadt return -1;
545df930be7Sderaadt }
546db4d2d4dSderaadt }
547db4d2d4dSderaadt close(sock);
548db4d2d4dSderaadt errno = EAGAIN;
549db4d2d4dSderaadt return -1;
55054c16646Sderaadt }
551df930be7Sderaadt
552df930be7Sderaadt /*
553df930be7Sderaadt * Privsock() calls inetresport() to attempt to bind a socket to a secure
554df930be7Sderaadt * port. If inetresport() fails, privsock returns a magic socket number which
555df930be7Sderaadt * indicates to RPC that it should make its own socket.
556df930be7Sderaadt * returns: A privileged socket # or RPC_ANYSOCK.
557df930be7Sderaadt */
558072e3d80Sderaadt static int
privsock(int ty)559072e3d80Sderaadt privsock(int ty)
560df930be7Sderaadt {
561df930be7Sderaadt int sock = inetresport(ty);
562df930be7Sderaadt
563df930be7Sderaadt if (sock < 0) {
564df930be7Sderaadt errno = 0;
565df930be7Sderaadt /* Couldn't get a secure port, let RPC make an insecure one */
566df930be7Sderaadt sock = RPC_ANYSOCK;
567df930be7Sderaadt }
568df930be7Sderaadt return sock;
569df930be7Sderaadt }
570