file_systems/nfs/nfs_add_on.c

44 /* timeout when waiting for an answer to a call */
47 /* number of retries when waiting for an anwser to a call */
220 			struct PendingCall *call;
223 			call=RPCPendingCallsFindAndRemovePendingCall(&ns->pendingCalls, xid,
226 			if (call) {
227 				call->buffer=(uint8 *)malloc(bytes);
228 				memcpy(call->buffer, buffer, bytes);
230 				while (release_sem (call->sem) == B_INTERRUPTED);
232 				dprintf("nfs: postoffice: can't find pending call to remove "
253 	struct PendingCall *call;
326 	call = RPCPendingCallsFindAndRemovePendingCall(&ns->pendingCalls, xid, addr);
331 	if (call==NULL)
339 		 * to the pool without the correct value, compromising the next call using it.
351 	if (call) /* if the call has been found and removed (atomic op), the sem hasn't been released */
419 	struct XDROutPacket call;
422 	XDROutPacketInit(&call);
426 	XDROutPacketAddInt32(&call, prog);
427 	XDROutPacketAddInt32(&call, vers);
428 	XDROutPacketAddInt32(&call, prot);
429 	XDROutPacketAddInt32(&call, 0);
432 		PMAPPROC_GETPORT, &call);
445 			XDROutPacketDestroy(&call);
452 	XDROutPacketDestroy (&call);
459 	struct XDROutPacket call;
464 	XDROutPacketInit(&call);
467 	XDROutPacketAddString(&call,path);
470 		MOUNTPROC_MNT, &call);
474 		XDROutPacketDestroy(&call);
482 		XDROutPacketDestroy(&call);
490 		XDROutPacketDestroy(&call);
497 	XDROutPacketDestroy(&call);
507 	struct XDROutPacket call;
512 	XDROutPacketInit(&call);
515 	XDROutPacketAddFixed(&call, dir->opaque, NFS_FHSIZE);
516 	XDROutPacketAddString(&call, filename);
519 		NFSPROC_LOOKUP, &call);
523 		XDROutPacketDestroy(&call);
531 		XDROutPacketDestroy(&call);
539 		XDROutPacketDestroy(&call);
547 		XDROutPacketDestroy(&call);
555 	XDROutPacketDestroy(&call);
563 	struct XDROutPacket call;
568 	XDROutPacketInit(&call);
571 	XDROutPacketAddFixed(&call, fhandle->opaque, NFS_FHSIZE);
574 		NFSPROC_GETATTR, &call);
577 		XDROutPacketDestroy(&call);
585 		XDROutPacketDestroy(&call);
592 		XDROutPacketDestroy(&call);
599 	XDROutPacketDestroy(&call);
607 	struct XDROutPacket call;
612 	XDROutPacketInit(&call);
615 	XDROutPacketAddFixed(&call, fhandle->opaque, NFS_FHSIZE);
617 	XDROutPacketAddInt32(&call, -1);
618 	XDROutPacketAddInt32(&call, -1);
619 	XDROutPacketAddInt32(&call, -1);
620 	XDROutPacketAddInt32(&call, 0);
621 	XDROutPacketAddInt32(&call, time(NULL));
622 	XDROutPacketAddInt32(&call, 0);
623 	XDROutPacketAddInt32(&call, time(NULL));
624 	XDROutPacketAddInt32(&call, 0);
627 		NFSPROC_SETATTR, &call);
630 		XDROutPacketDestroy(&call);
638 		XDROutPacketDestroy(&call);
645 		XDROutPacketDestroy(&call);
653 	XDROutPacketDestroy(&call);
971 		struct XDROutPacket call;
975 		XDROutPacketInit(&call);
978 		XDROutPacketAddFixed(&call, node->fhandle.opaque, NFS_FHSIZE);
979 		XDROutPacketAddFixed(&call, cookie->opaque, NFS_COOKIESIZE);
980 		XDROutPacketAddInt32(&call, count);
983 			NFSPROC_READDIR, &call);
987 			XDROutPacketDestroy(&call);
995 			XDROutPacketDestroy(&call);
1003 			XDROutPacketDestroy(&call);
1034 					XDROutPacketDestroy (&call);
1044 					XDROutPacketDestroy(&call);
1071 				XDROutPacketDestroy(&call);
1079 		XDROutPacketDestroy (&call);
1377 	struct XDROutPacket call;
1388 	XDROutPacketInit(&call);
1391 	XDROutPacketAddFixed(&call, rootHandle.opaque, NFS_FHSIZE);
1394 		NFSPROC_STATFS, &call);
1397 		XDROutPacketDestroy(&call);
1405 		XDROutPacketDestroy(&call);
1412 		XDROutPacketDestroy(&call);
1435 	XDROutPacketDestroy(&call);
1517 		struct XDROutPacket call;
1524 		XDROutPacketInit(&call);
1527 		XDROutPacketAddFixed(&call, &node->fhandle.opaque, NFS_FHSIZE);
1528 		XDROutPacketAddInt32(&call, pos);
1529 		XDROutPacketAddInt32(&call, count);
1530 		XDROutPacketAddInt32(&call, 0);
1533 			NFSPROC_READ, &call);
1536 			XDROutPacketDestroy(&call);
1544 			XDROutPacketDestroy(&call);
1551 			XDROutPacketDestroy(&call);
1567 		XDROutPacketDestroy(&call);
1598 		struct XDROutPacket call;
1604 		XDROutPacketInit(&call);
1607 		XDROutPacketAddFixed(&call, &node->fhandle.opaque, NFS_FHSIZE);
1608 		XDROutPacketAddInt32(&call, 0);
1609 		XDROutPacketAddInt32(&call, pos + bytesWritten);
1610 		XDROutPacketAddInt32(&call, 0);
1611 		status_t err = XDROutPacketAddDynamic(&call, (const char *)buf + bytesWritten, count);
1616 			NFSPROC_WRITE, &call);
1620 			XDROutPacketDestroy(&call);
1628 			XDROutPacketDestroy(&call);
1636 			XDROutPacketDestroy(&call);
1647 		XDROutPacketDestroy(&call);
1659 	struct XDROutPacket call;
1668 	XDROutPacketInit(&call);
1671 	XDROutPacketAddFixed(&call,node->fhandle.opaque,NFS_FHSIZE);
1673 	XDROutPacketAddInt32(&call, (mask & WSTAT_MODE) ? st->st_mode : UINT32_MAX);
1674 	XDROutPacketAddInt32(&call, (mask & WSTAT_UID) ? st->st_uid : UINT32_MAX);
1675 	XDROutPacketAddInt32(&call, (mask & WSTAT_GID) ? st->st_gid : UINT32_MAX);
1676 	XDROutPacketAddInt32(&call, (mask & WSTAT_SIZE) ? st->st_size : UINT32_MAX);
1677 	XDROutPacketAddInt32(&call, (mask & WSTAT_ATIME) ? st->st_atime : -1);
1678 	XDROutPacketAddInt32(&call, (mask & WSTAT_ATIME) ? 0 : UINT32_MAX);
1679 	XDROutPacketAddInt32(&call, (mask & WSTAT_MTIME) ? st->st_mtime : -1);
1680 	XDROutPacketAddInt32(&call, (mask & WSTAT_MTIME) ? 0 : UINT32_MAX);
1683 		NFSPROC_SETATTR, &call);
1687 		XDROutPacketDestroy(&call);
1695 		XDROutPacketDestroy(&call);
1705 	XDROutPacketDestroy(&call);
1778 		struct XDROutPacket call;
1789 		XDROutPacketInit(&call);
1792 		XDROutPacketAddFixed(&call, dir->fhandle.opaque, NFS_FHSIZE);
1793 		XDROutPacketAddString(&call, name);
1794 		XDROutPacketAddInt32(&call, perms | S_IFREG);
1795 		XDROutPacketAddInt32(&call, -1);
1796 		XDROutPacketAddInt32(&call, -1);
1797 		XDROutPacketAddInt32(&call, 0);
1798 		XDROutPacketAddInt32(&call, time(NULL));
1799 		XDROutPacketAddInt32(&call, 0);
1800 		XDROutPacketAddInt32(&call, time(NULL));
1801 		XDROutPacketAddInt32(&call, 0);
1804 			NFSPROC_CREATE, &call);
1808 			XDROutPacketDestroy(&call);
1816 			XDROutPacketDestroy(&call);
1824 			XDROutPacketDestroy(&call);
1832 			XDROutPacketDestroy(&call);
1841 			XDROutPacketDestroy(&call);
1854 			XDROutPacketDestroy(&call);
1865 			XDROutPacketDestroy(&call);
1870 		XDROutPacketDestroy(&call);
1885 	struct XDROutPacket call;
1897 	XDROutPacketInit(&call);
1902 		XDROutPacketDestroy(&call);
1909 		XDROutPacketDestroy(&call);
1920 		XDROutPacketDestroy(&call);
1926 		XDROutPacketDestroy(&call);
1932 		XDROutPacketDestroy(&call);
1938 		XDROutPacketDestroy(&call);
1942 	XDROutPacketAddFixed(&call, dir->fhandle.opaque, NFS_FHSIZE);
1943 	XDROutPacketAddString(&call, name);
1945 	replyBuf=send_rpc_call (ns,&ns->nfsAddr,NFS_PROGRAM,NFS_VERSION,NFSPROC_REMOVE,&call);
1949 		XDROutPacketDestroy(&call);
1957 		XDROutPacketDestroy(&call);
1965 		XDROutPacketDestroy(&call);
1970 	XDROutPacketDestroy(&call);
2004 	struct XDROutPacket call;
2010 	XDROutPacketInit(&call);
2019 		XDROutPacketDestroy(&call);
2026 		XDROutPacketDestroy(&call);
2030 	XDROutPacketAddFixed(&call, dir->fhandle.opaque, NFS_FHSIZE);
2031 	XDROutPacketAddString(&call, name);
2032 	XDROutPacketAddInt32(&call, perms | S_IFDIR);
2033 	XDROutPacketAddInt32(&call, -1);
2034 	XDROutPacketAddInt32(&call, -1);
2035 	XDROutPacketAddInt32(&call, -1);
2036 	XDROutPacketAddInt32(&call, time(NULL));
2037 	XDROutPacketAddInt32(&call, 0);
2038 	XDROutPacketAddInt32(&call, time(NULL));
2039 	XDROutPacketAddInt32(&call, 0);
2042 		NFSPROC_MKDIR, &call);
2046 		XDROutPacketDestroy(&call);
2054 		XDROutPacketDestroy(&call);
2061 		XDROutPacketDestroy(&call);
2068 		XDROutPacketDestroy(&call);
2077 		XDROutPacketDestroy(&call);
2087 	XDROutPacketDestroy(&call);
2099 	struct XDROutPacket call;
2111 	XDROutPacketInit(&call);
2123 			XDROutPacketDestroy (&call);
2131 		XDROutPacketDestroy(&call);
2135 	XDROutPacketAddFixed(&call, olddir->fhandle.opaque, NFS_FHSIZE);
2136 	XDROutPacketAddString(&call, oldname);
2137 	XDROutPacketAddFixed(&call, newdir->fhandle.opaque, NFS_FHSIZE);
2138 	XDROutPacketAddString(&call, newname);
2141 		NFSPROC_RENAME, &call);
2145 		XDROutPacketDestroy(&call);
2153 		XDROutPacketDestroy(&call);
2161 		XDROutPacketDestroy(&call);
2166 	XDROutPacketDestroy (&call);
2182 	struct XDROutPacket call;
2193 	XDROutPacketInit(&call);
2198 		XDROutPacketDestroy(&call);
2205 		XDROutPacketDestroy(&call);
2216 		XDROutPacketDestroy(&call);
2222 		XDROutPacketDestroy(&call);
2228 		XDROutPacketDestroy(&call);
2234 		XDROutPacketDestroy(&call);
2238 	XDROutPacketAddFixed (&call, dir->fhandle.opaque, NFS_FHSIZE);
2239 	XDROutPacketAddString(&call, name);
2242 		NFSPROC_RMDIR, &call);
2246 		XDROutPacketDestroy(&call);
2254 		XDROutPacketDestroy(&call);
2262 		XDROutPacketDestroy(&call);
2267 	XDROutPacketDestroy(&call);
2275 	struct XDROutPacket call;
2287 	XDROutPacketInit(&call);
2290 	XDROutPacketAddFixed(&call, node->fhandle.opaque, NFS_FHSIZE);
2293 		NFSPROC_READLINK, &call);
2297 		XDROutPacketDestroy(&call);
2305 		XDROutPacketDestroy(&call);
2313 		XDROutPacketDestroy (&call);
2323 	XDROutPacketDestroy(&call);
2335 	struct XDROutPacket call;
2345 	XDROutPacketInit(&call);
2356 		XDROutPacketDestroy(&call);
2360 		XDROutPacketDestroy(&call);
2364 	XDROutPacketAddFixed(&call, dir->fhandle.opaque, NFS_FHSIZE);
2365 	XDROutPacketAddString(&call, name);
2366 	XDROutPacketAddString(&call, path);
2367 	XDROutPacketAddInt32(&call, S_IFLNK);
2368 	XDROutPacketAddInt32(&call, -1);
2369 	XDROutPacketAddInt32(&call, -1);
2370 	XDROutPacketAddInt32(&call, -1);
2371 	XDROutPacketAddInt32(&call, time(NULL));
2372 	XDROutPacketAddInt32(&call, 0);
2373 	XDROutPacketAddInt32(&call, time(NULL));
2374 	XDROutPacketAddInt32(&call, 0);
2377 		NFSPROC_SYMLINK, &call);
2381 		XDROutPacketDestroy(&call);
2389 		XDROutPacketDestroy(&call);
2405 		XDROutPacketDestroy(&call);
2412 		XDROutPacketDestroy(&call);
2423 	XDROutPacketDestroy(&call);