mount_clnt.c
上传用户:jlfgdled
上传日期:2013-04-10
资源大小:33168k
文件大小:4k
源码类别:

Linux/Unix编程

开发平台:

Unix_Linux

  1. /*
  2.  * linux/fs/nfs/mount_clnt.c
  3.  *
  4.  * MOUNT client to support NFSroot.
  5.  *
  6.  * Copyright (C) 1997, Olaf Kirch <okir@monad.swb.de>
  7.  */
  8. #include <linux/types.h>
  9. #include <linux/socket.h>
  10. #include <linux/kernel.h>
  11. #include <linux/errno.h>
  12. #include <linux/uio.h>
  13. #include <linux/net.h>
  14. #include <linux/in.h>
  15. #include <linux/sunrpc/clnt.h>
  16. #include <linux/sunrpc/xprt.h>
  17. #include <linux/sunrpc/sched.h>
  18. #include <linux/nfs_fs.h>
  19. #ifdef RPC_DEBUG
  20. # define NFSDBG_FACILITY NFSDBG_ROOT
  21. #endif
  22. /*
  23. #define MOUNT_PROGRAM 100005
  24. #define MOUNT_VERSION 1
  25. #define MOUNT_MNT 1
  26. #define MOUNT_UMNT 3
  27.  */
  28. static struct rpc_clnt * mnt_create(char *, struct sockaddr_in *,
  29. int, int);
  30. struct rpc_program      mnt_program;
  31. struct mnt_fhstatus {
  32. unsigned int status;
  33. struct nfs_fh * fh;
  34. };
  35. /*
  36.  * Obtain an NFS file handle for the given host and path
  37.  */
  38. int
  39. nfsroot_mount(struct sockaddr_in *addr, char *path, struct nfs_fh *fh,
  40. int version, int protocol)
  41. {
  42. struct rpc_clnt *mnt_clnt;
  43. struct mnt_fhstatus result = { 0, fh };
  44. char hostname[32];
  45. int status;
  46. int call;
  47. dprintk("NFS:      nfs_mount(%08x:%s)n",
  48. (unsigned)ntohl(addr->sin_addr.s_addr), path);
  49. sprintf(hostname, "%u.%u.%u.%u", NIPQUAD(addr->sin_addr.s_addr));
  50. if (!(mnt_clnt = mnt_create(hostname, addr, version, protocol)))
  51. return -EACCES;
  52. call = (version == NFS_MNT3_VERSION)?  MOUNTPROC3_MNT : MNTPROC_MNT;
  53. status = rpc_call(mnt_clnt, call, path, &result, 0);
  54. return status < 0? status : (result.status? -EACCES : 0);
  55. }
  56. static struct rpc_clnt *
  57. mnt_create(char *hostname, struct sockaddr_in *srvaddr, int version,
  58. int protocol)
  59. {
  60. struct rpc_xprt *xprt;
  61. struct rpc_clnt *clnt;
  62. if (!(xprt = xprt_create_proto(protocol, srvaddr, NULL)))
  63. return NULL;
  64. clnt = rpc_create_client(xprt, hostname,
  65. &mnt_program, version,
  66. RPC_AUTH_NULL);
  67. if (!clnt) {
  68. xprt_destroy(xprt);
  69. } else {
  70. clnt->cl_softrtry = 1;
  71. clnt->cl_chatty   = 1;
  72. clnt->cl_oneshot  = 1;
  73. clnt->cl_intr = 1;
  74. }
  75. return clnt;
  76. }
  77. /*
  78.  * XDR encode/decode functions for MOUNT
  79.  */
  80. static int
  81. xdr_error(struct rpc_rqst *req, u32 *p, void *dummy)
  82. {
  83. return -EIO;
  84. }
  85. static int
  86. xdr_encode_dirpath(struct rpc_rqst *req, u32 *p, const char *path)
  87. {
  88. p = xdr_encode_string(p, path);
  89. req->rq_slen = xdr_adjust_iovec(req->rq_svec, p);
  90. return 0;
  91. }
  92. static int
  93. xdr_decode_fhstatus(struct rpc_rqst *req, u32 *p, struct mnt_fhstatus *res)
  94. {
  95. struct nfs_fh *fh = res->fh;
  96. memset((void *)fh, 0, sizeof(*fh));
  97. if ((res->status = ntohl(*p++)) == 0) {
  98. fh->size = NFS2_FHSIZE;
  99. memcpy(fh->data, p, NFS2_FHSIZE);
  100. }
  101. return 0;
  102. }
  103. static int
  104. xdr_decode_fhstatus3(struct rpc_rqst *req, u32 *p, struct mnt_fhstatus *res)
  105. {
  106. struct nfs_fh *fh = res->fh;
  107. memset((void *)fh, 0, sizeof(*fh));
  108. if ((res->status = ntohl(*p++)) == 0) {
  109. int size = ntohl(*p++);
  110. if (size <= NFS3_FHSIZE) {
  111. fh->size = size;
  112. memcpy(fh->data, p, size);
  113. } else
  114. res->status = -EBADHANDLE;
  115. }
  116. return 0;
  117. }
  118. #define MNT_dirpath_sz (1 + 256)
  119. #define MNT_fhstatus_sz (1 + 8)
  120. static struct rpc_procinfo mnt_procedures[2] = {
  121. { "mnt_null",
  122. (kxdrproc_t) xdr_error,
  123. (kxdrproc_t) xdr_error, 0, 0 },
  124. { "mnt_mount",
  125. (kxdrproc_t) xdr_encode_dirpath,
  126. (kxdrproc_t) xdr_decode_fhstatus,
  127. MNT_dirpath_sz << 2, 0 },
  128. };
  129. static struct rpc_procinfo mnt3_procedures[2] = {
  130. { "mnt3_null",
  131. (kxdrproc_t) xdr_error,
  132. (kxdrproc_t) xdr_error, 0, 0 },
  133. { "mnt3_mount",
  134. (kxdrproc_t) xdr_encode_dirpath,
  135. (kxdrproc_t) xdr_decode_fhstatus3,
  136. MNT_dirpath_sz << 2, 0 },
  137. };
  138. static struct rpc_version mnt_version1 = {
  139. 1, 2, mnt_procedures
  140. };
  141. static struct rpc_version       mnt_version3 = {
  142. 3, 2, mnt3_procedures
  143. };
  144. static struct rpc_version * mnt_version[] = {
  145. NULL,
  146. &mnt_version1,
  147. NULL,
  148. &mnt_version3,
  149. };
  150. static struct rpc_stat mnt_stats;
  151. struct rpc_program mnt_program = {
  152. "mount",
  153. NFS_MNT_PROGRAM,
  154. sizeof(mnt_version)/sizeof(mnt_version[0]),
  155. mnt_version,
  156. &mnt_stats,
  157. };