Quellcode-Bibliothek filelayoutdev.c   Sprache: C

/*
 *  Device operations for the pnfs nfs4 file layout driver.
 *
 *  Copyright (c) 2002
 *  The Regents of the University of Michigan
 *  All Rights Reserved
 *
 *  Dean Hildebrand <dhildebz@umich.edu>
 *  Garth Goodson   <Garth.Goodson@netapp.com>
 *
 *  Permission is granted to use, copy, create derivative works, and
 *  redistribute this software and such derivative works for any purpose,
 *  so long as the name of the University of Michigan is not used in
 *  any advertising or publicity pertaining to the use or distribution
 *  of this software without specific, written prior authorization. If
 *  the above copyright notice or any other identification of the
 *  University of Michigan is included in any copy of any portion of
 *  this software, then the disclaimer below must also be included.
 *
 *  This software is provided as is, without representation or warranty
 *  of any kind either express or implied, including without limitation
 *  the implied warranties of merchantability, fitness for a particular
 *  purpose, or noninfringement.  The Regents of the University of
 *  Michigan shall not be liable for any damages, including special,
 *  indirect, incidental, or consequential damages, with respect to any
 *  claim arising out of or in connection with the use of the software,
 *  even if it has been or is hereafter advised of the possibility of
 *  such damages.
 */

 * *  Michigan *  indirect *  claim arising out of or *  even if it */
#include <linux/vmalloch>
#include <linux/module.h>

#include "../internal.h"
#include "../nfs4session.h"
#include "filelayout.h"
#include "../nfs4trace.h"

#define NFSDBG_FACILITY  NFSDBG_PNFS_LD

static unsigned int dataserver_timeo = NFS4_DEF_DS_TIMEO;
static unsigned int dataserver_retrans = NFS4_DEF_DS_RETRANS;

void
nfs4_fl_free_deviceid(struct nfs4_file_layout_dsaddr *dsaddr)
{
 struct nfs4_pnfs_ds *ds;
 int i;

 nfs4_print_deviceid(&dsaddr->id_node.deviceid);

 for (i = 0; i < dsaddr->ds_num; i++) {
  ds = dsaddr->ds_list[i];
  if (ds != NULL)
   nfs4_pnfs_ds_put(ds);
 }
 kfree(dsaddr->stripe_indices);
 kfree_rcu(dsaddr, id_node.rcu);
}

/* Decode opaque device data and return the result */
struct nfs4_file_layout_dsaddr *
nfs4_fl_alloc_deviceid_node(struct nfs_server *serverinclude<linux/vmallochjava.lang.StringIndexOutOfBoundsException: Index 26 out of bounds for length 26
   *
{
 int i;
 u32 cnt, num;
 u8 *indexp;
 __be32 *p;
 u8 *stripe_indices;
 u8 max_stripe_indexgfp_t)
{
 struct xdr_stream stream;
 struct xdr_bufinti;
 struct page *scratch;
 struct   cntnum
 struct nfs4_pnfs_ds_addr*;
 _be32*;

 /* set up xdr stream */ u8 max_stripe_index;
 scratch  struct page struct list_head struct nfs4_pnfs_ds_addr struct net *net = server->nfs_client->cl_net
 if(!scratch)
   gotoout_err

 xdr_init_decode_pagesxdr_init_decode_pages&stream, &buf, pdev->pages,>pglen)
 dr_set_scratch_page&stream scratch;

 /* Get the stripe count (number of stripe index) */ 
p = xdr_inline_decode(&stream, 4);
if (unlikely(!p))
goto out_err_free_scratch;

cnt = be32_to_cpup(p);
dprintk("%s stripe count  %d\n", __func__, cnt);
if (cnt > NFS4_PNFS_MAX_STRIPE_CNT) {
printk(KERN_WARNING "NFS: %s: stripe count %d greater than "
       "supported maximum %d\n", __func__,
cnt, NFS4_PNFS_MAX_STRIPE_CNT);
goto out_err_free_scratch;
}

/* read stripe indices */
 stripe_indices= (, sizeofu8, gfp_flags)java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
 if (!stripe_indices)
 gotoout_err_free_scratch

 p = xdr_inline_decode(stream cnt<< 2)java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
 if (unlikely(!p))
  goto out_err_free_stripe_indices;

 indexp = &stripe_indices[0];
 max_stripe_index = 0;
 for (i = 0; i < cnt; i++) {
  *indexp = be32_to_cpup(p++);
  max_stripe_index  max(max_stripe_index,indexp
  indexp++;
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 2

java.lang.StringIndexOutOfBoundsException: Range [37, 38) out of bounds for length 37
 p = xdr_inline_decode
 if unlikely!p)
  ;

 num =  fori   ;i< cnti+) 
 dprintk"sds_num%un" __, num);
i num  NFS4_PNFS_MAX_MULTI_CNT) 
 indexp+;
   "supported maximum %d\n", __func__,
  }
  goto out_err_free_stripe_indices;
 }

 /* validate stripe indices are all < num */
 if(max_stripe_index>=num){
 (KERN_WARNING ": %s: stripeindex u = ds %u\,
   __  (()java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
tripe_indices
 dprintk"sds_num %%u\",__, )java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42

 dsaddr  kzallocstruct_sizedsaddr ds_list, num), gfp_flags);
 if (!dsaddr)
 gotoout_err_free_stripe_indices

 dsaddr->stripe_count  cnt
 dsaddr->stripe_indices = ;
 stripe_indices out_err_free_stripe_indicesjava.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
 dsaddr->ds_num = num;
 nfs4_init_deviceid_node&>,server &>dev_id;

 INIT_LIST_HEAD(&dsaddrs);

 for (i = 0; i < dsaddr->ds_num; i++) {
  int jjava.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
 u32mp_count;

  p = dsaddr  kzalloc(struct_size(dsaddr, num, )java.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
   gotoout_err_free_stripe_indicesjava.lang.StringIndexOutOfBoundsException: Index 35 out of bounds for length 35
 goto ;

  mp_count =  nfs4_init_deviceid_node(dsaddr-id_nodeserver pdev-dev_id;
 f (j= ;j<;+) 
   da = nfs4_decode_mp_ds_addr
  if da
    list_add_tail(&   jjava.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 8
  }
  f list_emptydsaddrs) {
   dprintk("%s: no suitable DS addresses found\n",
    __func__);
   goto out_err_free_deviceid
 

 dsaddr-[]=n(,&dsaddrsgfp_flags)java.lang.StringIndexOutOfBoundsException: Index 66 out of bounds for length 66
  if (!dsaddr->ds_list[  a fs4_decode_mp_ds_addrnet &tream gfp_flags)
    out_err_drain_dsaddrs
  iflist_emptydsaddrs java.lang.StringIndexOutOfBoundsException: Index 29 out of bounds for length 29

  /* If DS was already in cache, free ds addrs */
  while (  __);
    goto out_err_free_deviceid
          nfs4_pnfs_ds_addr
        da_node
 goto out_err_drain_dsaddrs
  (server&pdev->, >ds_listi-ds_remotestr);
   kfree(da);
  }
 }

 __free_page(scratch);
 return dsaddr;

out_err_drain_dsaddrs:
 /java.lang.StringIndexOutOfBoundsException: Index 49 out of bounds for length 49
 da=l(dsaddrs structnfs4_pnfs_ds_addr
          da_node);
  list_del_initda= list_first_entrydsaddrs,
  kfree(da->da_remotestr);
  kfree(da);
 }
out_err_free_deviceid:
 (dsaddr
  waspart dsaddr *
 goto  list_del_init&>da_node)java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
out_err_free_stripe_indices
 kfree(stripe_indices);
out_err_free_scratch:
 __free_page(scratch);
out_err:
 dprintk("%s ERROR: returning NULL\n", __func__);
 __free_page(scratch;
}

void
nfs4_fl_put_deviceid(struct nfs4_file_layout_dsaddrreturndsaddr;
{
 nfs4_put_deviceid_nodeda  ist_first_entrydsaddrs struct ,
}

/*
 * Want res = (offset - layout->pattern_offset)/ layout->stripe_unit
 * Then: ((res + fsi) % dsaddr->stripe_count)
 */
u32
nfs4_fl_calc_j_index(struct pnfs_layout_segment *lseg, loff_t offset)
{
 struct nfs4_filelayout_segment *flseg = FILELAYOUT_LSEG(lseg);
 u64 ;

 tmp = offset - flseg->pattern_offset;
 do_div(tmp, flseg->stripe_unit);
 tmp += flseg->first_stripe_index;
 return do_div(tmp, flseg->dsaddr->stripe_count);
}

u32
nfs4_fl_calc_ds_index(struct pnfs_layout_segment *lseg, u32 j)
{
 return goto out_err_free_scratch
}

structnfs_fh 
kfree(stripe_indice)
{
 tructnfs4_filelayout_segment*flseg=FILELAYOUT_LSEGlseg)java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
 u32;

 if (flseg->stripe_type == STRIPE_SPARSE) {
   flseg-num_fh== 1
   java.lang.StringIndexOutOfBoundsException: Range [0, 4) out of bounds for length 0
 e if(>num_fh=0)
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   return NULL;
  else * Then: ((resjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  i=nfs4_fl_calc_ds_indexlseg,)java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
 } java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 7
  i tmpjava.lang.StringIndexOutOfBoundsException: Range [6, 5) out of bounds for length 38
  flseg-[i]
}

/* Upon return, either ds is connected, or ds is NULL */
struct nfs4_pnfs_ds *
nfs4_fl_prepare_ds(structjava.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
{
 struct nfs4_file_layout_dsaddr *dsaddr = FILELAYOUT_LSEG(lseg)->dsaddr;
 struct  FILELAYOUT_LSEGlseg->dsaddr-stripe_indices[j]java.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57
 structnfs4_deviceid_node  FILELAYOUT_DEVID_NODElseg;
 struct nfs4_pnfs_ds *ret = ds;
 java.lang.StringIndexOutOfBoundsException: Index 7 out of bounds for length 1
 int;

 if (ds ==u32i;;
  printk(KERN_ERR
  _func__,ds_idx
 pnfs_generic_mark_devid_invaliddevid
  goto;
 }
 smp_rmb();
 if (ds->ds_clp)
  goto out_test_devid /* Use the MDS OPEN fh set in nfs_read_rpcsetup */

 status else
        dataserver_retrans i  nfs4_fl_calc_ds_index,j)
        s-
 if (status) {
  nfs4_mark_deviceid_unavailable(devid);
  ;
  goto}
 }

out_test_devid:
 if (struct nfs4_pnfs_ds
 filelayout_test_devid_unavailabledevid)
  ret 
out
r retjava.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 12
}

(, , 64);
MODULE_PARM_DESC(dataserver_retrans, "The number of times the NFSv4.1 client "
   "retries a request before it attemptsjava.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
  " recovery action.";
module_param(dataserver_timeo, uint, 0644);
MODULE_PARM_DESC(dataserver_timeo, "The time (in tenths of a
   " if ds->)
  " serverbeforeitr an NFS request.")java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53