The Design and Implementation of the FreeBSD Operating System, Second Edition
Now available: The Design and Implementation of the FreeBSD Operating System (Second Edition)


[ source navigation ] [ diff markup ] [ identifier search ] [ freetext search ] [ file search ] [ list types ] [ track identifier ]

FreeBSD/Linux Kernel Cross Reference
sys/nfsserver/nfs_fha_old.c

Version: -  FREEBSD  -  FREEBSD-13-STABLE  -  FREEBSD-13-0  -  FREEBSD-12-STABLE  -  FREEBSD-12-0  -  FREEBSD-11-STABLE  -  FREEBSD-11-0  -  FREEBSD-10-STABLE  -  FREEBSD-10-0  -  FREEBSD-9-STABLE  -  FREEBSD-9-0  -  FREEBSD-8-STABLE  -  FREEBSD-8-0  -  FREEBSD-7-STABLE  -  FREEBSD-7-0  -  FREEBSD-6-STABLE  -  FREEBSD-6-0  -  FREEBSD-5-STABLE  -  FREEBSD-5-0  -  FREEBSD-4-STABLE  -  FREEBSD-3-STABLE  -  FREEBSD22  -  l41  -  OPENBSD  -  linux-2.6  -  MK84  -  PLAN9  -  xnu-8792 
SearchContext: -  none  -  3  -  10 

    1 /*-
    2  * Copyright (c) 2008 Isilon Inc http://www.isilon.com/
    3  * Copyright (c) 2013 Spectra Logic Corporation
    4  *
    5  * Redistribution and use in source and binary forms, with or without
    6  * modification, are permitted provided that the following conditions
    7  * are met:
    8  * 1. Redistributions of source code must retain the above copyright
    9  *    notice, this list of conditions and the following disclaimer.
   10  * 2. Redistributions in binary form must reproduce the above copyright
   11  *    notice, this list of conditions and the following disclaimer in the
   12  *    documentation and/or other materials provided with the distribution.
   13  *
   14  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
   15  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
   16  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
   17  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
   18  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
   19  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
   20  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
   21  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
   22  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
   23  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
   24  * SUCH DAMAGE.
   25  */
   26 
   27 #include <sys/cdefs.h>
   28 __FBSDID("$FreeBSD: releng/10.4/sys/nfsserver/nfs_fha_old.c 261049 2014-01-22 23:48:15Z mav $");
   29 
   30 #include <sys/param.h>
   31 #include <sys/systm.h>
   32 #include <sys/sysproto.h>
   33 #include <sys/kernel.h>
   34 #include <sys/vnode.h>
   35 #include <sys/malloc.h>
   36 #include <sys/mount.h>
   37 #include <sys/mbuf.h>
   38 #include <sys/sysctl.h>
   39 
   40 #include <rpc/rpc.h>
   41 #include <nfs/xdr_subs.h>
   42 #include <nfs/nfsproto.h>
   43 #include <nfs/nfs_fha.h>
   44 #include <nfsserver/nfs.h>
   45 #include <nfsserver/nfsm_subs.h>
   46 #include <nfsserver/nfs_fha_old.h>
   47 
   48 static void fhaold_init(void *foo);
   49 static void fhaold_uninit(void *foo);
   50 rpcproc_t fhaold_get_procnum(rpcproc_t procnum);
   51 int fhaold_realign(struct mbuf **mb, int malloc_flags);
   52 int fhaold_get_fh(uint64_t *fh, int v3, struct mbuf **md, caddr_t *dpos);
   53 int fhaold_is_read(rpcproc_t procnum);
   54 int fhaold_is_write(rpcproc_t procnum);
   55 int fhaold_get_offset(struct mbuf **md, caddr_t *dpos, int v3,
   56                       struct fha_info *info);
   57 int fhaold_no_offset(rpcproc_t procnum);
   58 void fhaold_set_locktype(rpcproc_t procnum, struct fha_info *info);
   59 static int fheold_stats_sysctl(SYSCTL_HANDLER_ARGS);
   60 
   61 static struct fha_params fhaold_softc;
   62 
   63 SYSCTL_DECL(_vfs_nfsrv);
   64 
   65 extern SVCPOOL *nfsrv_pool;
   66 
   67 SYSINIT(nfs_fhaold, SI_SUB_ROOT_CONF, SI_ORDER_ANY, fhaold_init, NULL);
   68 SYSUNINIT(nfs_fhaold, SI_SUB_ROOT_CONF, SI_ORDER_ANY, fhaold_uninit, NULL);
   69 
   70 static void
   71 fhaold_init(void *foo)
   72 {
   73         struct fha_params *softc;
   74 
   75         softc = &fhaold_softc;
   76 
   77         bzero(softc, sizeof(*softc));
   78 
   79         /*
   80          * Setup the callbacks for this FHA personality.
   81          */
   82         softc->callbacks.get_procnum = fhaold_get_procnum;
   83         softc->callbacks.realign = fhaold_realign;
   84         softc->callbacks.get_fh = fhaold_get_fh;
   85         softc->callbacks.is_read = fhaold_is_read;
   86         softc->callbacks.is_write = fhaold_is_write;
   87         softc->callbacks.get_offset = fhaold_get_offset;
   88         softc->callbacks.no_offset = fhaold_no_offset;
   89         softc->callbacks.set_locktype = fhaold_set_locktype;
   90         softc->callbacks.fhe_stats_sysctl = fheold_stats_sysctl;
   91 
   92         snprintf(softc->server_name, sizeof(softc->server_name),
   93             FHAOLD_SERVER_NAME);
   94 
   95         softc->pool = &nfsrv_pool;
   96 
   97         /*
   98          * Initialize the sysctl context list for the fha module.
   99          */
  100         sysctl_ctx_init(&softc->sysctl_ctx);
  101         softc->sysctl_tree = SYSCTL_ADD_NODE(&softc->sysctl_ctx,
  102             SYSCTL_STATIC_CHILDREN(_vfs_nfsrv), OID_AUTO, "fha", CTLFLAG_RD,
  103             0, "fha node");
  104         if (softc->sysctl_tree == NULL) {
  105                 printf("%s: unable to allocate sysctl tree\n", __func__);
  106                 return;
  107         }
  108         fha_init(softc);
  109 }
  110 
  111 static void
  112 fhaold_uninit(void *foo)
  113 {
  114         struct fha_params *softc;
  115 
  116         softc = &fhaold_softc;
  117 
  118         fha_uninit(softc);
  119 }
  120 
  121 
  122 rpcproc_t
  123 fhaold_get_procnum(rpcproc_t procnum)
  124 {
  125         if (procnum > NFSV2PROC_STATFS)
  126                 return (-1);
  127 
  128         return (nfsrv_nfsv3_procid[procnum]);
  129 }
  130 
  131 int
  132 fhaold_realign(struct mbuf **mb, int malloc_flags)
  133 {
  134         return (nfs_realign(mb, malloc_flags));
  135 }
  136 
  137 int
  138 fhaold_get_fh(uint64_t *fh, int v3, struct mbuf **md, caddr_t *dpos)
  139 {
  140         u_int32_t *tl;
  141         uint8_t *buf;
  142         uint64_t t;
  143         int fhlen, i;
  144 
  145         if (v3) {
  146                 tl = nfsm_dissect_xx_nonblock(NFSX_UNSIGNED, md, dpos);
  147                 if (tl == NULL)
  148                         return EBADRPC;
  149                 fhlen = fxdr_unsigned(int, *tl);
  150                 if (fhlen != 0 && fhlen != NFSX_V3FH)
  151                         return EBADRPC;
  152         } else {
  153                 fhlen = NFSX_V2FH;
  154         }
  155         t = 0;
  156         if (fhlen != 0) {
  157                 buf = nfsm_dissect_xx_nonblock(fhlen, md, dpos);
  158                 if (buf == NULL)
  159                         return EBADRPC;
  160                 for (i = 0; i < fhlen; i++)
  161                         t ^= ((uint64_t)buf[i] << (i & 7) * 8);
  162         }
  163         *fh = t;
  164         return 0;
  165 }
  166 
  167 int
  168 fhaold_is_read(rpcproc_t procnum)
  169 {
  170         if (procnum == NFSPROC_READ)
  171                 return (1);
  172         else
  173                 return (0);
  174 }
  175 
  176 int
  177 fhaold_is_write(rpcproc_t procnum)
  178 {
  179         if (procnum == NFSPROC_WRITE)
  180                 return (1);
  181         else
  182                 return (0);
  183 }
  184 
  185 int
  186 fhaold_get_offset(struct mbuf **md, caddr_t *dpos, int v3,
  187                   struct fha_info *info)
  188 {
  189         uint32_t *tl;
  190 
  191         if (v3) {
  192                 tl = nfsm_dissect_xx_nonblock(2 * NFSX_UNSIGNED, md, dpos);
  193                 if (tl == NULL)
  194                         goto out;
  195                 info->offset = fxdr_hyper(tl);
  196         } else {
  197                 tl = nfsm_dissect_xx_nonblock(NFSX_UNSIGNED, md, dpos);
  198                 if (tl == NULL)
  199                         goto out;
  200                 info->offset = fxdr_unsigned(uint32_t, *tl);
  201         }
  202 
  203         return (0);
  204 out:
  205         return (-1);
  206 }
  207 
  208 int
  209 fhaold_no_offset(rpcproc_t procnum)
  210 {
  211         if (procnum == NFSPROC_FSSTAT ||
  212             procnum == NFSPROC_FSINFO ||
  213             procnum == NFSPROC_PATHCONF ||
  214             procnum == NFSPROC_NOOP ||
  215             procnum == NFSPROC_NULL)
  216                 return (1);
  217         else
  218                 return (0);
  219 }
  220 
  221 void
  222 fhaold_set_locktype(rpcproc_t procnum, struct fha_info *info)
  223 {
  224         switch (procnum) {
  225         case NFSPROC_NULL:
  226         case NFSPROC_GETATTR:
  227         case NFSPROC_LOOKUP:
  228         case NFSPROC_ACCESS:
  229         case NFSPROC_READLINK:
  230         case NFSPROC_READ:
  231         case NFSPROC_READDIR:
  232         case NFSPROC_READDIRPLUS:
  233         case NFSPROC_WRITE:
  234                 info->locktype = LK_SHARED;
  235                 break;
  236         case NFSPROC_SETATTR:
  237         case NFSPROC_CREATE:
  238         case NFSPROC_MKDIR:
  239         case NFSPROC_SYMLINK:
  240         case NFSPROC_MKNOD:
  241         case NFSPROC_REMOVE:
  242         case NFSPROC_RMDIR:
  243         case NFSPROC_RENAME:
  244         case NFSPROC_LINK:
  245         case NFSPROC_FSSTAT:
  246         case NFSPROC_FSINFO:
  247         case NFSPROC_PATHCONF:
  248         case NFSPROC_COMMIT:
  249         case NFSPROC_NOOP:
  250                 info->locktype = LK_EXCLUSIVE;
  251                 break;
  252         }
  253 }
  254 
  255 static int
  256 fheold_stats_sysctl(SYSCTL_HANDLER_ARGS)
  257 {
  258         return (fhe_stats_sysctl(oidp, arg1, arg2, req, &fhaold_softc));
  259 }
  260 
  261 SVCTHREAD *
  262 fhaold_assign(SVCTHREAD *this_thread, struct svc_req *req)
  263 {
  264         return (fha_assign(this_thread, req, &fhaold_softc));
  265 }

Cache object: 5a63573f0e72e0b3a0b6f45c895ee3cd


[ source navigation ] [ diff markup ] [ identifier search ] [ freetext search ] [ file search ] [ list types ] [ track identifier ]


This page is part of the FreeBSD/Linux Linux Kernel Cross-Reference, and was automatically generated using a modified version of the LXR engine.