Whamcloud - gitweb
5c78e1250a48c6d4a6b4f498a7438a3fcdd50d34
[fs/lustre-release.git] / 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 {
54         LASSERT (desc->bd_iov_count <= PTLRPC_MAX_BRW_PAGES);
55         LASSERT (!(md->options & (LNET_MD_IOVEC | LNET_MD_KIOV | LNET_MD_PHYS)));
56
57         md->options |= LNET_MD_KIOV;
58         md->length = desc->bd_iov_count;
59         if (desc->bd_enc_iov)
60                 md->start = desc->bd_enc_iov;
61         else
62                 md->start = desc->bd_iov;
63 }
64
65 void ptlrpc_add_bulk_page(struct ptlrpc_bulk_desc *desc, cfs_page_t *page,
66                           int pageoffset, int len)
67 {
68         lnet_kiov_t *kiov = &desc->bd_iov[desc->bd_iov_count];
69
70         kiov->kiov_page = page;
71         kiov->kiov_offset = pageoffset;
72         kiov->kiov_len = len;
73
74         desc->bd_iov_count++;
75 }
76
77 #else /* !__KERNEL__ */
78
79 void ptlrpc_fill_bulk_md(lnet_md_t *md, struct ptlrpc_bulk_desc *desc)
80 {
81         LASSERT (!(md->options & (LNET_MD_IOVEC | LNET_MD_KIOV | LNET_MD_PHYS)));
82         if (desc->bd_iov_count == 1) {
83                 md->start = desc->bd_iov[0].iov_base;
84                 md->length = desc->bd_iov[0].iov_len;
85                 return;
86         }
87
88         md->options |= LNET_MD_IOVEC;
89         md->start = &desc->bd_iov[0];
90         md->length = desc->bd_iov_count;
91 }
92
93 static int can_merge_iovs(lnet_md_iovec_t *existing, lnet_md_iovec_t *candidate)
94 {
95         if (existing->iov_base + existing->iov_len == candidate->iov_base)
96                 return 1;
97 #if 0
98         /* Enable this section to provide earlier evidence of fragmented bulk */
99         CERROR("Can't merge iovs %p for %x, %p for %x\n",
100                existing->iov_base, existing->iov_len,
101                candidate->iov_base, candidate->iov_len);
102 #endif
103         return 0;
104 }
105
106 void ptlrpc_add_bulk_page(struct ptlrpc_bulk_desc *desc, cfs_page_t *page,
107                           int pageoffset, int len)
108 {
109         lnet_md_iovec_t *iov = &desc->bd_iov[desc->bd_iov_count];
110
111         iov->iov_base = page->addr + pageoffset;
112         iov->iov_len = len;
113
114         if (desc->bd_iov_count > 0 && can_merge_iovs(iov - 1, iov)) {
115                 (iov - 1)->iov_len += len;
116         } else {
117                 desc->bd_iov_count++;
118         }
119 }
120
121 #endif /* !__KERNEL__ */