1 /*
2 * CDDL HEADER START
3 *
4 * The contents of this file are subject to the terms of the
5 * Common Development and Distribution License (the "License").
6 * You may not use this file except in compliance with the License.
7 *
8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9 * or http://www.opensolaris.org/os/licensing.
10 * See the License for the specific language governing permissions
11 * and limitations under the License.
12 *
13 * When distributing Covered Code, include this CDDL HEADER in each
14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15 * If applicable, add the following below this CDDL HEADER, with the
16 * fields enclosed by brackets "[]" replaced with your own identifying
17 * information: Portions Copyright [yyyy] [name of copyright owner]
18 *
19 * CDDL HEADER END
20 */
21
22 /*
23 * Copyright 2008 Sun Microsystems, Inc. All rights reserved.
24 * Use is subject to license terms.
25 */
26
27 #pragma ident "%Z%%M% %I% %E% SMI"
28
29 #include <strings.h>
30 #include <rpc/rpc.h>
31 #include <stdlib.h>
32 #include <sys/param.h>
33 #include <rpcsvc/mount.h>
34
35 #include "rpcsvc/nfs_prot.h"
36
37 char sharedpath[MAXPATHLEN];
38 fhandle3 *rootfh;
39
40 /*
41 * The waiting() function returns the value passed in, until something
42 * external modifies it. In this case, the D script tst.call.d will
43 * modify the value of *a, and thus break the while loop in dotest().
44 *
45 * This serves the purpose of not making the RPC calls until tst.call.d
46 * is active. Thus, the probes in tst.call.d can fire as a result of
47 * the RPC call in dotest().
48 */
49
50 int
waiting(volatile int * a)51 waiting(volatile int *a)
52 {
53 return (*a);
54 }
55
56 static void
getattr_arginit(void * argp)57 getattr_arginit(void *argp)
58 {
59 GETATTR3args *args = argp;
60
61 args->object.data.data_len = rootfh->fhandle3_len;
62 args->object.data.data_val = rootfh->fhandle3_val;
63 }
64
65 static void
setattr_arginit(void * argp)66 setattr_arginit(void *argp)
67 {
68 SETATTR3args *args = argp;
69
70 bzero(args, sizeof (*args));
71 args->object.data.data_len = rootfh->fhandle3_len;
72 args->object.data.data_val = rootfh->fhandle3_val;
73 }
74
75 static void
lookup_arginit(void * argp)76 lookup_arginit(void *argp)
77 {
78 LOOKUP3args *args = argp;
79
80 args->what.name = "giant-skunk";
81 args->what.dir.data.data_len = rootfh->fhandle3_len;
82 args->what.dir.data.data_val = rootfh->fhandle3_val;
83 }
84
85 static void
access_arginit(void * argp)86 access_arginit(void *argp)
87 {
88 ACCESS3args *args = argp;
89
90 args->object.data.data_len = rootfh->fhandle3_len;
91 args->object.data.data_val = rootfh->fhandle3_val;
92 }
93
94 static void
commit_arginit(void * argp)95 commit_arginit(void *argp)
96 {
97 COMMIT3args *args = argp;
98
99 bzero(args, sizeof (*args));
100 args->file.data.data_len = rootfh->fhandle3_len;
101 args->file.data.data_val = rootfh->fhandle3_val;
102 }
103
104 static void
create_arginit(void * argp)105 create_arginit(void *argp)
106 {
107 CREATE3args *args = argp;
108
109 bzero(args, sizeof (*args));
110 args->where.name = "pinky-blue";
111 args->where.dir.data.data_len = rootfh->fhandle3_len;
112 args->where.dir.data.data_val = rootfh->fhandle3_val;
113 }
114
115 static void
fsinfo_arginit(void * argp)116 fsinfo_arginit(void *argp)
117 {
118 FSINFO3args *args = argp;
119
120 args->fsroot.data.data_len = rootfh->fhandle3_len;
121 args->fsroot.data.data_val = rootfh->fhandle3_val;
122 }
123
124 static void
fsstat_arginit(void * argp)125 fsstat_arginit(void *argp)
126 {
127 FSSTAT3args *args = argp;
128
129 args->fsroot.data.data_len = rootfh->fhandle3_len;
130 args->fsroot.data.data_val = rootfh->fhandle3_val;
131 }
132
133 static void
link_arginit(void * argp)134 link_arginit(void *argp)
135 {
136 LINK3args *args = argp;
137
138 args->file.data.data_len = rootfh->fhandle3_len;
139 args->file.data.data_val = rootfh->fhandle3_val;
140 args->link.dir.data.data_len = rootfh->fhandle3_len;
141 args->link.dir.data.data_val = rootfh->fhandle3_val;
142 args->link.name = "samf";
143 }
144
145 static void
mkdir_arginit(void * argp)146 mkdir_arginit(void *argp)
147 {
148 MKDIR3args *args = argp;
149
150 bzero(args, sizeof (*args));
151 args->where.dir.data.data_len = rootfh->fhandle3_len;
152 args->where.dir.data.data_val = rootfh->fhandle3_val;
153 args->where.name = "cookie";
154 }
155
156 static void
mknod_arginit(void * argp)157 mknod_arginit(void *argp)
158 {
159 MKNOD3args *args = argp;
160
161 bzero(args, sizeof (*args));
162 args->where.dir.data.data_len = rootfh->fhandle3_len;
163 args->where.dir.data.data_val = rootfh->fhandle3_val;
164 args->where.name = "pookie";
165 }
166
167 static void
null_arginit(void * argp)168 null_arginit(void *argp)
169 {
170 }
171
172 static void
pathconf_arginit(void * argp)173 pathconf_arginit(void *argp)
174 {
175 PATHCONF3args *args = argp;
176
177 args->object.data.data_len = rootfh->fhandle3_len;
178 args->object.data.data_val = rootfh->fhandle3_val;
179 }
180
181 static void
read_arginit(void * argp)182 read_arginit(void *argp)
183 {
184 READ3args *args = argp;
185
186 bzero(args, sizeof (*args));
187 args->file.data.data_len = rootfh->fhandle3_len;
188 args->file.data.data_val = rootfh->fhandle3_val;
189 }
190
191 static void
readdir_arginit(void * argp)192 readdir_arginit(void *argp)
193 {
194 READDIR3args *args = argp;
195
196 bzero(args, sizeof (*args));
197 args->dir.data.data_len = rootfh->fhandle3_len;
198 args->dir.data.data_val = rootfh->fhandle3_val;
199 args->count = 1024;
200 }
201
202 static void
readdirplus_arginit(void * argp)203 readdirplus_arginit(void *argp)
204 {
205 READDIRPLUS3args *args = argp;
206
207 bzero(args, sizeof (*args));
208 args->dir.data.data_len = rootfh->fhandle3_len;
209 args->dir.data.data_val = rootfh->fhandle3_val;
210 args->dircount = 1024;
211 args->maxcount = 1024;
212 }
213
214 static void
readlink_arginit(void * argp)215 readlink_arginit(void *argp)
216 {
217 READLINK3args *args = argp;
218
219 args->symlink.data.data_len = rootfh->fhandle3_len;
220 args->symlink.data.data_val = rootfh->fhandle3_val;
221 }
222
223 static void
remove_arginit(void * argp)224 remove_arginit(void *argp)
225 {
226 REMOVE3args *args = argp;
227
228 args->object.dir.data.data_len = rootfh->fhandle3_len;
229 args->object.dir.data.data_val = rootfh->fhandle3_val;
230 args->object.name = "antelope";
231 }
232
233 static void
rename_arginit(void * argp)234 rename_arginit(void *argp)
235 {
236 RENAME3args *args = argp;
237
238 args->from.dir.data.data_len = rootfh->fhandle3_len;
239 args->from.dir.data.data_val = rootfh->fhandle3_val;
240 args->from.name = "walter";
241 args->to.dir.data.data_len = rootfh->fhandle3_len;
242 args->to.dir.data.data_val = rootfh->fhandle3_val;
243 args->to.name = "wendy";
244 }
245
246 static void
rmdir_arginit(void * argp)247 rmdir_arginit(void *argp)
248 {
249 RMDIR3args *args = argp;
250
251 args->object.dir.data.data_len = rootfh->fhandle3_len;
252 args->object.dir.data.data_val = rootfh->fhandle3_val;
253 args->object.name = "bunny";
254 }
255
256 static void
symlink_arginit(void * argp)257 symlink_arginit(void *argp)
258 {
259 SYMLINK3args *args = argp;
260
261 bzero(args, sizeof (*args));
262 args->where.dir.data.data_len = rootfh->fhandle3_len;
263 args->where.dir.data.data_val = rootfh->fhandle3_val;
264 args->where.name = "parlor";
265 args->symlink.symlink_data = "interior";
266 }
267
268 static void
write_arginit(void * argp)269 write_arginit(void *argp)
270 {
271 WRITE3args *args = argp;
272
273 bzero(args, sizeof (*args));
274 args->file.data.data_len = rootfh->fhandle3_len;
275 args->file.data.data_val = rootfh->fhandle3_val;
276 }
277
278 typedef void (*call3_arginit_t)(void *);
279
280 typedef struct {
281 call3_arginit_t arginit;
282 rpcproc_t proc;
283 xdrproc_t xdrargs;
284 size_t argsize;
285 xdrproc_t xdrres;
286 size_t ressize;
287 } call3_test_t;
288 call3_test_t call3_tests[] = {
289 {getattr_arginit, NFSPROC3_GETATTR, xdr_GETATTR3args,
290 sizeof (GETATTR3args), xdr_GETATTR3res, sizeof (GETATTR3res)},
291 {setattr_arginit, NFSPROC3_SETATTR, xdr_SETATTR3args,
292 sizeof (SETATTR3args), xdr_SETATTR3res, sizeof (SETATTR3res)},
293 {lookup_arginit, NFSPROC3_LOOKUP, xdr_LOOKUP3args,
294 sizeof (LOOKUP3args), xdr_LOOKUP3res, sizeof (LOOKUP3res)},
295 {access_arginit, NFSPROC3_ACCESS, xdr_ACCESS3args,
296 sizeof (ACCESS3args), xdr_ACCESS3res, sizeof (ACCESS3res)},
297 {commit_arginit, NFSPROC3_COMMIT, xdr_COMMIT3args,
298 sizeof (COMMIT3args), xdr_COMMIT3res, sizeof (COMMIT3res)},
299 {create_arginit, NFSPROC3_CREATE, xdr_CREATE3args,
300 sizeof (CREATE3args), xdr_CREATE3res, sizeof (CREATE3res)},
301 {fsinfo_arginit, NFSPROC3_FSINFO, xdr_FSINFO3args,
302 sizeof (FSINFO3args), xdr_FSINFO3res, sizeof (FSINFO3res)},
303 {fsstat_arginit, NFSPROC3_FSSTAT, xdr_FSSTAT3args,
304 sizeof (FSSTAT3args), xdr_FSSTAT3res, sizeof (FSSTAT3res)},
305 {link_arginit, NFSPROC3_LINK, xdr_LINK3args,
306 sizeof (LINK3args), xdr_LINK3res, sizeof (LINK3res)},
307 {mkdir_arginit, NFSPROC3_MKDIR, xdr_MKDIR3args,
308 sizeof (MKDIR3args), xdr_MKDIR3res, sizeof (MKDIR3res)},
309 {mknod_arginit, NFSPROC3_MKNOD, xdr_MKNOD3args,
310 sizeof (MKNOD3args), xdr_MKNOD3res, sizeof (MKNOD3res)},
311 /*
312 * NULL proc is special. Rather than special case its zero-sized
313 * args/results, we give it a small nonzero size, so as to not
314 * make realloc() do the wrong thing.
315 */
316 {null_arginit, NFSPROC3_NULL, xdr_void, sizeof (int), xdr_void,
317 sizeof (int)},
318 {pathconf_arginit, NFSPROC3_PATHCONF, xdr_PATHCONF3args,
319 sizeof (PATHCONF3args), xdr_PATHCONF3res, sizeof (PATHCONF3res)},
320 {read_arginit, NFSPROC3_READ, xdr_READ3args,
321 sizeof (READ3args), xdr_READ3res, sizeof (READ3res)},
322 {readdir_arginit, NFSPROC3_READDIR, xdr_READDIR3args,
323 sizeof (READDIR3args), xdr_READDIR3res, sizeof (READDIR3res)},
324 {readdirplus_arginit, NFSPROC3_READDIRPLUS, xdr_READDIRPLUS3args,
325 sizeof (READDIRPLUS3args), xdr_READDIRPLUS3res,
326 sizeof (READDIRPLUS3res)},
327 {readlink_arginit, NFSPROC3_READLINK, xdr_READLINK3args,
328 sizeof (READLINK3args), xdr_READLINK3res, sizeof (READLINK3res)},
329 {remove_arginit, NFSPROC3_REMOVE, xdr_REMOVE3args,
330 sizeof (REMOVE3args), xdr_REMOVE3res, sizeof (REMOVE3res)},
331 {rename_arginit, NFSPROC3_RENAME, xdr_RENAME3args,
332 sizeof (RENAME3args), xdr_RENAME3res, sizeof (RENAME3res)},
333 {rmdir_arginit, NFSPROC3_RMDIR, xdr_RMDIR3args,
334 sizeof (RMDIR3args), xdr_RMDIR3res, sizeof (RMDIR3res)},
335 {symlink_arginit, NFSPROC3_SYMLINK, xdr_SYMLINK3args,
336 sizeof (SYMLINK3args), xdr_SYMLINK3res, sizeof (SYMLINK3res)},
337 {write_arginit, NFSPROC3_WRITE, xdr_WRITE3args,
338 sizeof (WRITE3args), xdr_WRITE3res, sizeof (WRITE3res)},
339 {NULL}
340 };
341
342 int
dotest(void)343 dotest(void)
344 {
345 CLIENT *client, *mountclient;
346 AUTH *auth;
347 struct timeval timeout;
348 caddr_t args, res;
349 enum clnt_stat status;
350 rpcproc_t proc;
351 call3_test_t *test;
352 void *argbuf = NULL;
353 void *resbuf = NULL;
354 struct mountres3 mountres3;
355 char *sp;
356 volatile int a = 0;
357
358 while (waiting(&a) == 0)
359 continue;
360
361 timeout.tv_sec = 30;
362 timeout.tv_usec = 0;
363
364 mountclient = clnt_create("localhost", MOUNTPROG, MOUNTVERS3, "tcp");
365 if (mountclient == NULL) {
366 clnt_pcreateerror("clnt_create mount");
367 return (1);
368 }
369 auth = authsys_create_default();
370 mountclient->cl_auth = auth;
371 sp = sharedpath;
372 bzero(&mountres3, sizeof (mountres3));
373 status = clnt_call(mountclient, MOUNTPROC_MNT,
374 xdr_dirpath, (char *)&sp,
375 xdr_mountres3, (char *)&mountres3,
376 timeout);
377 if (status != RPC_SUCCESS) {
378 clnt_perror(mountclient, "mnt");
379 return (1);
380 }
381 if (mountres3.fhs_status != 0) {
382 fprintf(stderr, "MOUNTPROG/MOUNTVERS3 failed %d\n",
383 mountres3.fhs_status);
384 return (1);
385 }
386 rootfh = &mountres3.mountres3_u.mountinfo.fhandle;
387
388 client = clnt_create("localhost", NFS3_PROGRAM, NFS_V3, "tcp");
389 if (client == NULL) {
390 clnt_pcreateerror("clnt_create");
391 return (1);
392 }
393 client->cl_auth = auth;
394
395 for (test = call3_tests; test->arginit; ++test) {
396 argbuf = realloc(argbuf, test->argsize);
397 resbuf = realloc(resbuf, test->ressize);
398 if ((argbuf == NULL) || (resbuf == NULL)) {
399 perror("realloc() failed");
400 return (1);
401 }
402 (test->arginit)(argbuf);
403 bzero(resbuf, test->ressize);
404 status = clnt_call(client, test->proc,
405 test->xdrargs, argbuf,
406 test->xdrres, resbuf,
407 timeout);
408 if (status != RPC_SUCCESS)
409 clnt_perror(client, "call");
410 }
411
412 status = clnt_call(mountclient, MOUNTPROC_UMNT,
413 xdr_dirpath, (char *)&sp,
414 xdr_void, NULL,
415 timeout);
416 if (status != RPC_SUCCESS)
417 clnt_perror(mountclient, "umnt");
418
419 return (0);
420 }
421
422 /*ARGSUSED*/
423 int
main(int argc,char ** argv)424 main(int argc, char **argv)
425 {
426 char shareline[BUFSIZ], unshareline[BUFSIZ];
427 int rc;
428
429 (void) snprintf(sharedpath, sizeof (sharedpath),
430 "/tmp/nfsv3test.%d", getpid());
431 (void) snprintf(shareline, sizeof (shareline),
432 "mkdir %s ; share %s", sharedpath, sharedpath);
433 (void) snprintf(unshareline, sizeof (unshareline),
434 "unshare %s ; rmdir %s", sharedpath, sharedpath);
435
436 (void) system(shareline);
437 rc = dotest();
438 (void) system(unshareline);
439
440 return (rc);
441 }
442