ref: 440ccbc06007422f04943378260f250f9efa5331
dir: /sys/src/cmd/aux/nfsmount.c/
/* Copyright © 2003 Russ Cox, MIT; see /sys/src/libsunrpc/COPYING */
#include <u.h>
#include <libc.h>
#include <thread.h>
#include <sunrpc.h>
#include <nfs3.h>
int chatty;
SunClient *client;
void
usage(void)
{
fprint(2, "usage: nfsmount address [cmd]\n"
"cmd is one of:\n"
"\tnull\n"
"\tmnt path\n"
"\tdump\n"
"\tumnt path\n"
"\tumntall\n"
"\texport (default)\n");
threadexitsall("usage");
}
void
portCall(SunCall *c, PortCallType type)
{
c->rpc.prog = PortProgram;
c->rpc.vers = PortVersion;
c->rpc.proc = type>>1;
c->rpc.iscall = !(type&1);
c->type = type;
}
int
getport(SunClient *client, uint prog, uint vers, uint prot, uint *port)
{
PortTGetport tx;
PortRGetport rx;
memset(&tx, 0, sizeof tx);
portCall(&tx.call, PortCallTGetport);
tx.map.prog = prog;
tx.map.vers = vers;
tx.map.prot = prot;
memset(&rx, 0, sizeof rx);
portCall(&rx.call, PortCallRGetport);
if(sunClientRpc(client, 0, &tx.call, &rx.call, nil) < 0)
return -1;
*port = rx.port;
return 0;
}
uchar unixauth[] = {
0x12, 0x23, 0x34, 0x45, /* stamp */
0x00, 0x00, 0x00, 0x04, /* gnot */
0x67, 0x6e, 0x6f, 0x74,
0x00, 0x00, 0x03, 0xE9, /* 1001 */
0x00, 0x00, 0x03, 0xE9, /* 1001 */
0x00, 0x00, 0x00, 0x00, /* gid list */
};
void
mountCall(SunCall *c, NfsMount3CallType type)
{
c->rpc.prog = NfsMount3Program;
c->rpc.vers = NfsMount3Version;
c->rpc.proc = type>>1;
c->rpc.iscall = !(type&1);
if(c->rpc.iscall){
c->rpc.cred.flavor = SunAuthSys;
c->rpc.cred.data = unixauth;
c->rpc.cred.ndata = sizeof unixauth;
}
c->type = type;
}
void
tnull(char **argv)
{
NfsMount3TNull tx;
NfsMount3RNull rx;
USED(argv);
memset(&tx, 0, sizeof tx);
mountCall(&tx.call, NfsMount3CallTNull);
memset(&rx, 0, sizeof rx);
mountCall(&rx.call, NfsMount3CallRNull);
if(sunClientRpc(client, 0, &tx.call, &rx.call, nil) < 0)
sysfatal("rpc: %r");
}
void
tmnt(char **argv)
{
int i;
NfsMount3TMnt tx;
NfsMount3RMnt rx;
memset(&tx, 0, sizeof tx);
mountCall(&tx.call, NfsMount3CallTMnt);
tx.path = argv[0];
memset(&rx, 0, sizeof rx);
mountCall(&rx.call, NfsMount3CallRMnt);
if(sunClientRpc(client, 0, &tx.call, &rx.call, nil) < 0)
sysfatal("rpc: %r");
if(rx.status != 0){
nfs3Errstr(rx.status);
sysfatal("mnt: %r");
}
print("handle %.*H\n", rx.len, rx.handle);
print("auth:");
for(i=0; i<rx.nauth; i++)
print(" %ud", (uint)rx.auth[i]);
print("\n");
}
void
tdump(char **argv)
{
uchar *p, *ep;
NfsMount3TDump tx;
NfsMount3RDump rx;
NfsMount3Entry e;
memset(&tx, 0, sizeof tx);
mountCall(&tx.call, NfsMount3CallTDump);
USED(argv);
memset(&rx, 0, sizeof rx);
mountCall(&rx.call, NfsMount3CallRDump);
if(sunClientRpc(client, 0, &tx.call, &rx.call, nil) < 0)
sysfatal("rpc: %r");
p = rx.data;
ep = p+rx.count;
while(p < ep){
if(nfsMount3EntryUnpack(p, ep, &p, &e) < 0)
sysfatal("unpack entry structure failed");
print("%s %s\n", e.host, e.path);
}
}
void
tumnt(char **argv)
{
NfsMount3TUmnt tx;
NfsMount3RUmnt rx;
memset(&tx, 0, sizeof tx);
mountCall(&tx.call, NfsMount3CallTUmnt);
tx.path = argv[0];
memset(&rx, 0, sizeof rx);
mountCall(&rx.call, NfsMount3CallRUmnt);
if(sunClientRpc(client, 0, &tx.call, &rx.call, nil) < 0)
sysfatal("rpc: %r");
print("\n");
}
void
tumntall(char **argv)
{
NfsMount3TUmntall tx;
NfsMount3RUmntall rx;
memset(&tx, 0, sizeof tx);
mountCall(&tx.call, NfsMount3CallTUmntall);
USED(argv);
memset(&rx, 0, sizeof rx);
mountCall(&rx.call, NfsMount3CallRUmntall);
if(sunClientRpc(client, 0, &tx.call, &rx.call, nil) < 0)
sysfatal("rpc: %r");
print("\n");
}
void
texport(char **argv)
{
uchar *p, *ep, *tofree;
char **g, **gg;
int ng, i, n;
NfsMount3TDump tx;
NfsMount3RDump rx;
NfsMount3Export e;
memset(&tx, 0, sizeof tx);
mountCall(&tx.call, NfsMount3CallTExport);
USED(argv);
memset(&rx, 0, sizeof rx);
mountCall(&rx.call, NfsMount3CallRExport);
if(sunClientRpc(client, 0, &tx.call, &rx.call, &tofree) < 0)
sysfatal("rpc: %r");
p = rx.data;
ep = p+rx.count;
g = nil;
ng = 0;
while(p < ep){
n = nfsMount3ExportGroupSize(p);
if(n > ng){
ng = n;
g = erealloc(g, sizeof(g[0])*ng);
}
if(nfsMount3ExportUnpack(p, ep, &p, g, &gg, &e) < 0)
sysfatal("unpack export structure failed");
print("%s", e.path);
for(i=0; i<e.ng; i++)
print(" %s", e.g[i]);
print("\n");
}
free(tofree);
}
static struct {
char *cmd;
int narg;
void (*fn)(char**);
} tab[] = {
"null", 0, tnull,
"mnt", 1, tmnt,
"dump", 0, tdump,
"umnt", 1, tumnt,
"umntall", 1, tumntall,
"export", 0, texport,
};
char*
netchangeport(char *addr, char *port)
{
static char buf[256];
char *r;
strecpy(buf, buf+sizeof buf, addr);
r = strrchr(buf, '!');
if(r == nil)
return nil;
r++;
strecpy(r, buf+sizeof buf, port);
return buf;
}
void
threadmain(int argc, char **argv)
{
char *dflt[] = { "export", };
char *addr, *cmd;
int i, proto;
uint port;
char buf[32];
int mapit;
mapit = 1;
ARGBEGIN{
case 'R':
chatty++;
break;
case 'm':
mapit = 0;
break;
}ARGEND
if(argc < 1)
usage();
fmtinstall('B', sunRpcFmt);
fmtinstall('C', sunCallFmt);
fmtinstall('H', encodefmt);
sunFmtInstall(&portProg);
sunFmtInstall(&nfsMount3Prog);
addr = netmkaddr(argv[0], "udp", "portmap");
if(mapit){
/* translate with port mapper */
fprint(2, "connecting to %s\n", addr);
if((client = sunDial(addr)) == nil)
sysfatal("dial %s: %r", addr);
client->chatty = chatty;
sunClientProg(client, &portProg);
if(strstr(addr, "udp!"))
proto = PortProtoUdp;
else
proto = PortProtoTcp;
if(getport(client, NfsMount3Program, NfsMount3Version, proto, &port) < 0)
sysfatal("getport: %r");
snprint(buf, sizeof buf, "%ud!r", port);
addr = netchangeport(addr, buf);
sunClientClose(client);
}
fprint(2, "connecting to %s\n", addr);
if((client = sunDial(addr)) == nil)
sysfatal("dial %s: %r", addr);
client->chatty = chatty;
sunClientProg(client, &nfsMount3Prog);
argv++;
argc--;
if(argc == 0){
argc = 1;
argv = dflt;
}
cmd = argv[0];
argv++;
argc--;
for(i=0; i<nelem(tab); i++){
if(strcmp(tab[i].cmd, cmd) == 0){
if(tab[i].narg != argc)
usage();
(*tab[i].fn)(argv);
threadexitsall(nil);
}
}
usage();
}