kinit/nfsmount/mount.c

#include <sys/mount.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <linux/nfs.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>

#include "nfsmount.h"
#include "sunrpc.h"

static uint32_t mount_port;

struct mount_call {
	struct rpc_call rpc;
	uint32_t path_len;
	char path[0];
};

/*
 * The following structure is the NFS v3 on-the-wire file handle,
 * as defined in rfc1813.
 * This differs from the structure used by the kernel,
 * defined in <linux/nfh3.h>: rfc has a long in network order,
 * kernel has a short in native order.
 * Both kernel and rfc use the name nfs_fh; kernel name is
 * visible to user apps in some versions of libc.
 * Use different name to avoid clashes.
 */
#define NFS_MAXFHSIZE_WIRE 64
struct nfs_fh_wire {
	uint32_t size;
	char data[NFS_MAXFHSIZE_WIRE];
} __attribute__ ((packed));

struct mount_reply {
	struct rpc_reply reply;
	uint32_t status;
	struct nfs_fh_wire fh;
} __attribute__ ((packed));

#define MNT_REPLY_MINSIZE (sizeof(struct rpc_reply) + sizeof(uint32_t))

static int get_ports(uint32_t server, const struct nfs_mount_data *data)
{
	uint32_t nfs_ver, mount_ver;
	uint32_t proto;

	if (data->flags & NFS_MOUNT_VER3) {
		nfs_ver = NFS3_VERSION;
		mount_ver = NFS_MNT3_VERSION;
	} else {
		nfs_ver = NFS2_VERSION;
		mount_ver = NFS_MNT_VERSION;
	}

	proto = (data->flags & NFS_MOUNT_TCP) ? IPPROTO_TCP : IPPROTO_UDP;

	if (nfs_port == 0) {
		nfs_port = portmap(server, NFS_PROGRAM, nfs_ver, proto);
		if (nfs_port == 0) {
			if (proto == IPPROTO_TCP) {
				struct in_addr addr = { server };
				fprintf(stderr, "NFS over TCP not "
					"available from %s\n", inet_ntoa(addr));
				return -1;
			}
			nfs_port = NFS_PORT;
		}
	}

	if (mount_port == 0) {
		mount_port = portmap(server, NFS_MNT_PROGRAM, mount_ver, proto);
		if (mount_port == 0)
			mount_port = MOUNT_PORT;
	}
	return 0;
}

static inline int pad_len(int len)
{
	return (len + 3) & ~3;
}

static inline void dump_params(uint32_t server,
			       const char *path,
			       const struct nfs_mount_data *data)
{
	(void)server;
	(void)path;
	(void)data;

#ifdef NFS_DEBUG
	struct in_addr addr = { server };

	printf("NFS params:\n");
	printf("  server = %s, path = \"%s\", ", inet_ntoa(addr), path);
	printf("version = %d, proto = %s\n",
	       data->flags & NFS_MOUNT_VER3 ? 3 : 2,
	       (data->flags & NFS_MOUNT_TCP) ? "tcp" : "udp");
	printf("  mount_port = %d, nfs_port = %d, flags = %08x\n",
	       mount_port, nfs_port, data->flags);
	printf("  rsize = %d, wsize = %d, timeo = %d, retrans = %d\n",
	       data->rsize, data->wsize, data->timeo, data->retrans);
	printf("  acreg (min, max) = (%d, %d), acdir (min, max) = (%d, %d)\n",
	       data->acregmin, data->acregmax, data->acdirmin, data->acdirmax);
	printf("  soft = %d, intr = %d, posix = %d, nocto = %d, noac = %d\n",
	       (data->flags & NFS_MOUNT_SOFT) != 0,
	       (data->flags & NFS_MOUNT_INTR) != 0,
	       (data->flags & NFS_MOUNT_POSIX) != 0,
	       (data->flags & NFS_MOUNT_NOCTO) != 0,
	       (data->flags & NFS_MOUNT_NOAC) != 0);
#endif
}

static inline void dump_fh(const char *data, int len)
{
	(void)data;
	(void)len;

#ifdef NFS_DEBUG
	int i = 0;
	int max = len - (len % 8);

	printf("Root file handle: %d bytes\n", NFS2_FHSIZE);

	while (i < max) {
		int j;

		printf("  %4d:  ", i);
		for (j = 0; j < 4; j++) {
			printf("%02x %02x %02x %02x  ",
			       data[i] & 0xff, data[i + 1] & 0xff,
			       data[i + 2] & 0xff, data[i + 3] & 0xff);
		}
		i += j;
		printf("\n");
	}
#endif
}

static struct mount_reply mnt_reply;

static int mount_call(uint32_t proc, uint32_t version,
		      const char *path, struct client *clnt)
{
	struct mount_call *mnt_call = NULL;
	size_t path_len, call_len;
	struct rpc rpc;
	int ret = 0;

	path_len = strlen(path);
	call_len = sizeof(*mnt_call) + pad_len(path_len);

	if ((mnt_call = malloc(call_len)) == NULL) {
		perror("malloc");
		goto bail;
	}

	memset(mnt_call, 0, sizeof(*mnt_call));

	mnt_call->rpc.program = htonl(NFS_MNT_PROGRAM);
	mnt_call->rpc.prog_vers = htonl(version);
	mnt_call->rpc.proc = htonl(proc);
	mnt_call->path_len = htonl(path_len);
	memcpy(mnt_call->path, path, path_len);

	rpc.call = (struct rpc_call *)mnt_call;
	rpc.call_len = call_len;
	rpc.reply = (struct rpc_reply *)&mnt_reply;
	rpc.reply_len = sizeof(mnt_reply);

	if (rpc_call(clnt, &rpc) < 0)
		goto bail;

	if (proc != MNTPROC_MNT) {
		goto done;
	}

	if (rpc.reply_len < MNT_REPLY_MINSIZE) {
		fprintf(stderr, "incomplete reply: %zu < %zu\n",
			rpc.reply_len, MNT_REPLY_MINSIZE);
		goto bail;
	}

	if (mnt_reply.status != 0) {
		fprintf(stderr, "mount call failed - server replied: %s.\n",
			strerror(ntohl(mnt_reply.status)));
		goto bail;
	}

	goto done;

bail:
	ret = -1;

done:
	if (mnt_call) {
		free(mnt_call);
	}

	return ret;
}

static int mount_v2(const char *path,
		    struct nfs_mount_data *data, struct client *clnt)
{
	int ret = mount_call(MNTPROC_MNT, NFS_MNT_VERSION, path, clnt);

	if (ret == 0) {
		dump_fh((const char *)&mnt_reply.fh, NFS2_FHSIZE);

		data->root.size = NFS_FHSIZE;
		memcpy(data->root.data, &mnt_reply.fh, NFS_FHSIZE);
		memcpy(data->old_root.data, &mnt_reply.fh, NFS_FHSIZE);
	}

	return ret;
}

static inline int umount_v2(const char *path, struct client *clnt)
{
	return mount_call(MNTPROC_UMNT, NFS_MNT_VERSION, path, clnt);
}

static int mount_v3(const char *path,
		    struct nfs_mount_data *data, struct client *clnt)
{
	int ret = mount_call(MNTPROC_MNT, NFS_MNT3_VERSION, path, clnt);

	if (ret == 0) {
		size_t fhsize = ntohl(mnt_reply.fh.size);

		dump_fh((const char *)&mnt_reply.fh.data, fhsize);

		memset(data->old_root.data, 0, NFS_FHSIZE);
		memset(&data->root, 0, sizeof(data->root));
		data->root.size = fhsize;
		memcpy(&data->root.data, mnt_reply.fh.data, fhsize);
		data->flags |= NFS_MOUNT_VER3;
	}

	return ret;
}

static inline int umount_v3(const char *path, struct client *clnt)
{
	return mount_call(MNTPROC_UMNT, NFS_MNT3_VERSION, path, clnt);
}

int nfs_mount(const char *pathname, const char *hostname,
	      uint32_t server, const char *rem_path, const char *path,
	      struct nfs_mount_data *data)
{
	struct client *clnt = NULL;
	struct sockaddr_in addr;
	char mounted = 0;
	int sock = -1;
	int ret = 0;
	int mountflags;

	if (get_ports(server, data) != 0) {
		goto bail;
	}

	dump_params(server, rem_path, data);

	if (data->flags & NFS_MOUNT_TCP) {
		clnt = tcp_client(server, mount_port, CLI_RESVPORT);
	} else {
		clnt = udp_client(server, mount_port, CLI_RESVPORT);
	}

	if (clnt == NULL) {
		goto bail;
	}

	if (data->flags & NFS_MOUNT_VER3) {
		ret = mount_v3(rem_path, data, clnt);
	} else {
		ret = mount_v2(rem_path, data, clnt);
	}

	if (ret == -1) {
		goto bail;
	}
	mounted = 1;

	if (data->flags & NFS_MOUNT_TCP) {
		sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
	} else {
		sock = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP);
	}

	if (sock == -1) {
		perror("socket");
		goto bail;
	}

	if (bindresvport(sock, 0) == -1) {
		perror("bindresvport");
		goto bail;
	}

	addr.sin_family = AF_INET;
	addr.sin_addr.s_addr = server;
	addr.sin_port = htons(nfs_port);
	memcpy(&data->addr, &addr, sizeof(data->addr));

	strncpy(data->hostname, hostname, sizeof(data->hostname));

	data->fd = sock;

	mountflags = (data->flags & NFS_MOUNT_KLIBC_RONLY) ? MS_RDONLY : 0;
	data->flags = data->flags & NFS_MOUNT_FLAGMASK;
	ret = mount(pathname, path, "nfs", mountflags, data);

	if (ret == -1) {
		if (errno == ENODEV) {
			fprintf(stderr, "mount: the kernel lacks NFS v%d "
				"support\n",
				(data->flags & NFS_MOUNT_VER3) ? 3 : 2);
		} else {
			perror("mount");
		}
		goto bail;
	}

	DEBUG(("Mounted %s on %s\n", pathname, path));

	goto done;

      bail:
	if (mounted) {
		if (data->flags & NFS_MOUNT_VER3) {
			umount_v3(path, clnt);
		} else {
			umount_v2(path, clnt);
		}
	}

	ret = -1;

      done:
	if (clnt) {
		client_free(clnt);
	}

	if (sock != -1) {
		close(sock);
	}

	return ret;
}
1	niro	532	#include <sys/mount.h>
2			#include <sys/types.h>
3			#include <sys/socket.h>
4			#include <arpa/inet.h>
5			#include <netinet/in.h>
6			#include <linux/nfs.h>
7			#include <stdio.h>
8			#include <stdlib.h>
9			#include <string.h>
10			#include <errno.h>
11
12			#include "nfsmount.h"
13			#include "sunrpc.h"
14
15			static uint32_t mount_port;
16
17			struct mount_call {
18			struct rpc_call rpc;
19			uint32_t path_len;
20			char path[0];
21			};
22
23			/*
24			* The following structure is the NFS v3 on-the-wire file handle,
25			* as defined in rfc1813.
26			* This differs from the structure used by the kernel,
27			* defined in <linux/nfh3.h>: rfc has a long in network order,
28			* kernel has a short in native order.
29			* Both kernel and rfc use the name nfs_fh; kernel name is
30			* visible to user apps in some versions of libc.
31			* Use different name to avoid clashes.
32			*/
33			#define NFS_MAXFHSIZE_WIRE 64
34			struct nfs_fh_wire {
35			uint32_t size;
36			char data[NFS_MAXFHSIZE_WIRE];
37			} __attribute__ ((packed));
38
39			struct mount_reply {
40			struct rpc_reply reply;
41			uint32_t status;
42			struct nfs_fh_wire fh;
43			} __attribute__ ((packed));
44
45			#define MNT_REPLY_MINSIZE (sizeof(struct rpc_reply) + sizeof(uint32_t))
46
47			static int get_ports(uint32_t server, const struct nfs_mount_data *data)
48			{
49			uint32_t nfs_ver, mount_ver;
50			uint32_t proto;
51
52			if (data->flags & NFS_MOUNT_VER3) {
53			nfs_ver = NFS3_VERSION;
54			mount_ver = NFS_MNT3_VERSION;
55			} else {
56			nfs_ver = NFS2_VERSION;
57			mount_ver = NFS_MNT_VERSION;
58			}
59
60			proto = (data->flags & NFS_MOUNT_TCP) ? IPPROTO_TCP : IPPROTO_UDP;
61
62			if (nfs_port == 0) {
63			nfs_port = portmap(server, NFS_PROGRAM, nfs_ver, proto);
64			if (nfs_port == 0) {
65			if (proto == IPPROTO_TCP) {
66			struct in_addr addr = { server };
67			fprintf(stderr, "NFS over TCP not "
68			"available from %s\n", inet_ntoa(addr));
69			return -1;
70			}
71			nfs_port = NFS_PORT;
72			}
73			}
74
75			if (mount_port == 0) {
76			mount_port = portmap(server, NFS_MNT_PROGRAM, mount_ver, proto);
77			if (mount_port == 0)
78			mount_port = MOUNT_PORT;
79			}
80			return 0;
81			}
82
83			static inline int pad_len(int len)
84			{
85			return (len + 3) & ~3;
86			}
87
88			static inline void dump_params(uint32_t server,
89			const char *path,
90			const struct nfs_mount_data *data)
91			{
92			(void)server;
93			(void)path;
94			(void)data;
95
96			#ifdef NFS_DEBUG
97			struct in_addr addr = { server };
98
99			printf("NFS params:\n");
100			printf(" server = %s, path = \"%s\", ", inet_ntoa(addr), path);
101			printf("version = %d, proto = %s\n",
102			data->flags & NFS_MOUNT_VER3 ? 3 : 2,
103			(data->flags & NFS_MOUNT_TCP) ? "tcp" : "udp");
104			printf(" mount_port = %d, nfs_port = %d, flags = %08x\n",
105			mount_port, nfs_port, data->flags);
106			printf(" rsize = %d, wsize = %d, timeo = %d, retrans = %d\n",
107			data->rsize, data->wsize, data->timeo, data->retrans);
108			printf(" acreg (min, max) = (%d, %d), acdir (min, max) = (%d, %d)\n",
109			data->acregmin, data->acregmax, data->acdirmin, data->acdirmax);
110			printf(" soft = %d, intr = %d, posix = %d, nocto = %d, noac = %d\n",
111			(data->flags & NFS_MOUNT_SOFT) != 0,
112			(data->flags & NFS_MOUNT_INTR) != 0,
113			(data->flags & NFS_MOUNT_POSIX) != 0,
114			(data->flags & NFS_MOUNT_NOCTO) != 0,
115			(data->flags & NFS_MOUNT_NOAC) != 0);
116			#endif
117			}
118
119			static inline void dump_fh(const char *data, int len)
120			{
121			(void)data;
122			(void)len;
123
124			#ifdef NFS_DEBUG
125			int i = 0;
126			int max = len - (len % 8);
127
128			printf("Root file handle: %d bytes\n", NFS2_FHSIZE);
129
130			while (i < max) {
131			int j;
132
133			printf(" %4d: ", i);
134			for (j = 0; j < 4; j++) {
135			printf("%02x %02x %02x %02x ",
136			data[i] & 0xff, data[i + 1] & 0xff,
137			data[i + 2] & 0xff, data[i + 3] & 0xff);
138			}
139			i += j;
140			printf("\n");
141			}
142			#endif
143			}
144
145			static struct mount_reply mnt_reply;
146
147			static int mount_call(uint32_t proc, uint32_t version,
148			const char path, struct client clnt)
149			{
150			struct mount_call *mnt_call = NULL;
151			size_t path_len, call_len;
152			struct rpc rpc;
153			int ret = 0;
154
155			path_len = strlen(path);
156			call_len = sizeof(*mnt_call) + pad_len(path_len);
157
158			if ((mnt_call = malloc(call_len)) == NULL) {
159			perror("malloc");
160			goto bail;
161			}
162
163			memset(mnt_call, 0, sizeof(*mnt_call));
164
165			mnt_call->rpc.program = htonl(NFS_MNT_PROGRAM);
166			mnt_call->rpc.prog_vers = htonl(version);
167			mnt_call->rpc.proc = htonl(proc);
168			mnt_call->path_len = htonl(path_len);
169			memcpy(mnt_call->path, path, path_len);
170
171			rpc.call = (struct rpc_call *)mnt_call;
172			rpc.call_len = call_len;
173			rpc.reply = (struct rpc_reply *)&mnt_reply;
174			rpc.reply_len = sizeof(mnt_reply);
175
176			if (rpc_call(clnt, &rpc) < 0)
177			goto bail;
178
179			if (proc != MNTPROC_MNT) {
180			goto done;
181			}
182
183			if (rpc.reply_len < MNT_REPLY_MINSIZE) {
184			fprintf(stderr, "incomplete reply: %zu < %zu\n",
185			rpc.reply_len, MNT_REPLY_MINSIZE);
186			goto bail;
187			}
188
189			if (mnt_reply.status != 0) {
190	niro	815	fprintf(stderr, "mount call failed - server replied: %s.\n",
191			strerror(ntohl(mnt_reply.status)));
192	niro	532	goto bail;
193			}
194
195			goto done;
196
197			bail:
198			ret = -1;
199
200			done:
201			if (mnt_call) {
202			free(mnt_call);
203			}
204
205			return ret;
206			}
207
208			static int mount_v2(const char *path,
209			struct nfs_mount_data data, struct client clnt)
210			{
211			int ret = mount_call(MNTPROC_MNT, NFS_MNT_VERSION, path, clnt);
212
213			if (ret == 0) {
214			dump_fh((const char *)&mnt_reply.fh, NFS2_FHSIZE);
215
216			data->root.size = NFS_FHSIZE;
217			memcpy(data->root.data, &mnt_reply.fh, NFS_FHSIZE);
218			memcpy(data->old_root.data, &mnt_reply.fh, NFS_FHSIZE);
219			}
220
221			return ret;
222			}
223
224			static inline int umount_v2(const char path, struct client clnt)
225			{
226			return mount_call(MNTPROC_UMNT, NFS_MNT_VERSION, path, clnt);
227			}
228
229			static int mount_v3(const char *path,
230			struct nfs_mount_data data, struct client clnt)
231			{
232			int ret = mount_call(MNTPROC_MNT, NFS_MNT3_VERSION, path, clnt);
233
234			if (ret == 0) {
235			size_t fhsize = ntohl(mnt_reply.fh.size);
236
237			dump_fh((const char *)&mnt_reply.fh.data, fhsize);
238
239			memset(data->old_root.data, 0, NFS_FHSIZE);
240			memset(&data->root, 0, sizeof(data->root));
241			data->root.size = fhsize;
242			memcpy(&data->root.data, mnt_reply.fh.data, fhsize);
243			data->flags \|= NFS_MOUNT_VER3;
244			}
245
246			return ret;
247			}
248
249			static inline int umount_v3(const char path, struct client clnt)
250			{
251			return mount_call(MNTPROC_UMNT, NFS_MNT3_VERSION, path, clnt);
252			}
253
254			int nfs_mount(const char pathname, const char hostname,
255			uint32_t server, const char rem_path, const char path,
256			struct nfs_mount_data *data)
257			{
258			struct client *clnt = NULL;
259			struct sockaddr_in addr;
260			char mounted = 0;
261			int sock = -1;
262			int ret = 0;
263			int mountflags;
264
265			if (get_ports(server, data) != 0) {
266			goto bail;
267			}
268
269			dump_params(server, rem_path, data);
270
271			if (data->flags & NFS_MOUNT_TCP) {
272			clnt = tcp_client(server, mount_port, CLI_RESVPORT);
273			} else {
274			clnt = udp_client(server, mount_port, CLI_RESVPORT);
275			}
276
277			if (clnt == NULL) {
278			goto bail;
279			}
280
281			if (data->flags & NFS_MOUNT_VER3) {
282			ret = mount_v3(rem_path, data, clnt);
283			} else {
284			ret = mount_v2(rem_path, data, clnt);
285			}
286
287			if (ret == -1) {
288			goto bail;
289			}
290			mounted = 1;
291
292			if (data->flags & NFS_MOUNT_TCP) {
293			sock = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);
294			} else {
295			sock = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP);
296			}
297
298			if (sock == -1) {
299			perror("socket");
300			goto bail;
301			}
302
303			if (bindresvport(sock, 0) == -1) {
304			perror("bindresvport");
305			goto bail;
306			}
307
308			addr.sin_family = AF_INET;
309			addr.sin_addr.s_addr = server;
310			addr.sin_port = htons(nfs_port);
311			memcpy(&data->addr, &addr, sizeof(data->addr));
312
313			strncpy(data->hostname, hostname, sizeof(data->hostname));
314
315			data->fd = sock;
316
317			mountflags = (data->flags & NFS_MOUNT_KLIBC_RONLY) ? MS_RDONLY : 0;
318			data->flags = data->flags & NFS_MOUNT_FLAGMASK;
319			ret = mount(pathname, path, "nfs", mountflags, data);
320
321			if (ret == -1) {
322			if (errno == ENODEV) {
323			fprintf(stderr, "mount: the kernel lacks NFS v%d "
324			"support\n",
325			(data->flags & NFS_MOUNT_VER3) ? 3 : 2);
326			} else {
327			perror("mount");
328			}
329			goto bail;
330			}
331
332			DEBUG(("Mounted %s on %s\n", pathname, path));
333
334			goto done;
335
336			bail:
337			if (mounted) {
338			if (data->flags & NFS_MOUNT_VER3) {
339			umount_v3(path, clnt);
340			} else {
341			umount_v2(path, clnt);
342			}
343			}
344
345			ret = -1;
346
347			done:
348			if (clnt) {
349			client_free(clnt);
350			}
351
352			if (sock != -1) {
353			close(sock);
354			}
355
356			return ret;
357			}