lustre/ptlrpc/pers.c

   1 /*
   2  * GPL HEADER START
   3  *
   4  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   5  *
   6  * This program is free software; you can redistribute it and/or modify
   7  * it under the terms of the GNU General Public License version 2 only,
   8  * as published by the Free Software Foundation.
   9  *
  10  * This program is distributed in the hope that it will be useful, but
  11  * WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * General Public License version 2 for more details (a copy is included
  14  * in the LICENSE file that accompanied this code).
  15  *
  16  * You should have received a copy of the GNU General Public License
  17  * version 2 along with this program; If not, see
  18  * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
  19  *
  20  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
  21  * CA 95054 USA or visit www.sun.com if you need additional information or
  22  * have any questions.
  23  *
  24  * GPL HEADER END
  25  */
  26 /*
  27  * Copyright (c) 2004, 2010, Oracle and/or its affiliates. All rights reserved.
  28  * Use is subject to license terms.
  29  */
  30 /*
  31  * This file is part of Lustre, http://www.lustre.org/
  32  * Lustre is a trademark of Sun Microsystems, Inc.
  33  */
  34
  35 #define DEBUG_SUBSYSTEM S_RPC
  36 #ifndef __KERNEL__
  37 #include <errno.h>
  38 #include <signal.h>
  39 #include <liblustre.h>
  40 #endif
  41
  42 #include <obd_support.h>
  43 #include <obd_class.h>
  44 #include <lustre_lib.h>
  45 #include <lustre_ha.h>
  46 #include <lustre_import.h>
  47
  48 #include "ptlrpc_internal.h"
  49
  50 #ifdef __KERNEL__
  51
  52 void ptlrpc_fill_bulk_md(lnet_md_t *md, struct ptlrpc_bulk_desc *desc,
  53                          int mdidx)
  54 {
  55         CLASSERT(PTLRPC_MAX_BRW_PAGES < LI_POISON);
  56
  57         LASSERT(mdidx < desc->bd_md_max_brw);
  58         LASSERT(desc->bd_iov_count <= PTLRPC_MAX_BRW_PAGES);
  59         LASSERT(!(md->options & (LNET_MD_IOVEC | LNET_MD_KIOV |
  60                                  LNET_MD_PHYS)));
  61
  62         md->options |= LNET_MD_KIOV;
  63         md->length = max(0, desc->bd_iov_count - mdidx * LNET_MAX_IOV);
  64         md->length = min_t(unsigned int, LNET_MAX_IOV, md->length);
  65         if (desc->bd_enc_iov)
  66                 md->start = &desc->bd_enc_iov[mdidx * LNET_MAX_IOV];
  67         else
  68                 md->start = &desc->bd_iov[mdidx * LNET_MAX_IOV];
  69 }
  70
  71 void ptlrpc_add_bulk_page(struct ptlrpc_bulk_desc *desc, struct page *page,
  72                           int pageoffset, int len)
  73 {
  74         lnet_kiov_t *kiov = &desc->bd_iov[desc->bd_iov_count];
  75
  76         kiov->kiov_page = page;
  77         kiov->kiov_offset = pageoffset;
  78         kiov->kiov_len = len;
  79
  80         desc->bd_iov_count++;
  81 }
  82
  83 #else /* !__KERNEL__ */
  84
  85 void ptlrpc_fill_bulk_md(lnet_md_t *md, struct ptlrpc_bulk_desc *desc,
  86                          int mdidx)
  87 {
  88         LASSERT(mdidx < desc->bd_md_max_brw);
  89         LASSERT(desc->bd_iov_count > mdidx * LNET_MAX_IOV);
  90         LASSERT(!(md->options & (LNET_MD_IOVEC | LNET_MD_KIOV | LNET_MD_PHYS)));
  91
  92         if (desc->bd_iov_count == 1) {
  93                 md->start = desc->bd_iov[0].iov_base;
  94                 md->length = desc->bd_iov[0].iov_len;
  95                 return;
  96         }
  97
  98         md->options |= LNET_MD_IOVEC;
  99         md->start = &desc->bd_iov[mdidx * LNET_MAX_IOV];
 100         md->length = min(LNET_MAX_IOV, desc->bd_iov_count - mdidx *
 101                                        LNET_MAX_IOV);
 102 }
 103
 104 static int can_merge_iovs(lnet_md_iovec_t *existing, lnet_md_iovec_t *candidate)
 105 {
 106         if (existing->iov_base + existing->iov_len == candidate->iov_base)
 107                 return 1;
 108 #if 0
 109         /* Enable this section to provide earlier evidence of fragmented bulk */
 110         CERROR("Can't merge iovs %p for %x, %p for %x\n",
 111                existing->iov_base, existing->iov_len,
 112                candidate->iov_base, candidate->iov_len);
 113 #endif
 114         return 0;
 115 }
 116
 117 void ptlrpc_add_bulk_page(struct ptlrpc_bulk_desc *desc, struct page *page,
 118                           int pageoffset, int len)
 119 {
 120         lnet_md_iovec_t *iov = &desc->bd_iov[desc->bd_iov_count];
 121
 122         iov->iov_base = page->addr + pageoffset;
 123         iov->iov_len = len;
 124
 125         if (desc->bd_iov_count > 0 && can_merge_iovs(iov - 1, iov)) {
 126                 (iov - 1)->iov_len += len;
 127         } else {
 128                 desc->bd_iov_count++;
 129         }
 130 }
 131
 132 #endif /* !__KERNEL__ */