![Weston Andros Adamson](/assets/img/avatar_default.png)
Now that pg_test can change the size of the request (by returning a non-zero size smaller than the request), pg_test functions that call other pg_test functions must return the minimum of the result - or 0 if any fail. Also clean up the logic of some pg_test functions so that all checks are for contitions where coalescing is not possible. Signed-off-by: Weston Andros Adamson <dros@primarydata.com> Signed-off-by: Trond Myklebust <trond.myklebust@primarydata.com>
707 lines
19 KiB
C
707 lines
19 KiB
C
/*
|
|
* pNFS Objects layout implementation over open-osd initiator library
|
|
*
|
|
* Copyright (C) 2009 Panasas Inc. [year of first publication]
|
|
* All rights reserved.
|
|
*
|
|
* Benny Halevy <bhalevy@panasas.com>
|
|
* Boaz Harrosh <bharrosh@panasas.com>
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License version 2
|
|
* See the file COPYING included with this distribution for more details.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions
|
|
* are met:
|
|
*
|
|
* 1. Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* 2. Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in the
|
|
* documentation and/or other materials provided with the distribution.
|
|
* 3. Neither the name of the Panasas company nor the names of its
|
|
* contributors may be used to endorse or promote products derived
|
|
* from this software without specific prior written permission.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED
|
|
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
|
|
* MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
|
|
* DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
|
|
* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
|
|
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
|
|
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR
|
|
* BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
|
|
* LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
|
|
* NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
|
|
* SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
|
*/
|
|
|
|
#include <linux/module.h>
|
|
#include <scsi/osd_ore.h>
|
|
|
|
#include "objlayout.h"
|
|
#include "../internal.h"
|
|
|
|
#define NFSDBG_FACILITY NFSDBG_PNFS_LD
|
|
|
|
struct objio_dev_ent {
|
|
struct nfs4_deviceid_node id_node;
|
|
struct ore_dev od;
|
|
};
|
|
|
|
static void
|
|
objio_free_deviceid_node(struct nfs4_deviceid_node *d)
|
|
{
|
|
struct objio_dev_ent *de = container_of(d, struct objio_dev_ent, id_node);
|
|
|
|
dprintk("%s: free od=%p\n", __func__, de->od.od);
|
|
osduld_put_device(de->od.od);
|
|
kfree(de);
|
|
}
|
|
|
|
static struct objio_dev_ent *_dev_list_find(const struct nfs_server *nfss,
|
|
const struct nfs4_deviceid *d_id)
|
|
{
|
|
struct nfs4_deviceid_node *d;
|
|
struct objio_dev_ent *de;
|
|
|
|
d = nfs4_find_get_deviceid(nfss->pnfs_curr_ld, nfss->nfs_client, d_id);
|
|
if (!d)
|
|
return NULL;
|
|
|
|
de = container_of(d, struct objio_dev_ent, id_node);
|
|
return de;
|
|
}
|
|
|
|
static struct objio_dev_ent *
|
|
_dev_list_add(const struct nfs_server *nfss,
|
|
const struct nfs4_deviceid *d_id, struct osd_dev *od,
|
|
gfp_t gfp_flags)
|
|
{
|
|
struct nfs4_deviceid_node *d;
|
|
struct objio_dev_ent *de = kzalloc(sizeof(*de), gfp_flags);
|
|
struct objio_dev_ent *n;
|
|
|
|
if (!de) {
|
|
dprintk("%s: -ENOMEM od=%p\n", __func__, od);
|
|
return NULL;
|
|
}
|
|
|
|
dprintk("%s: Adding od=%p\n", __func__, od);
|
|
nfs4_init_deviceid_node(&de->id_node,
|
|
nfss->pnfs_curr_ld,
|
|
nfss->nfs_client,
|
|
d_id);
|
|
de->od.od = od;
|
|
|
|
d = nfs4_insert_deviceid_node(&de->id_node);
|
|
n = container_of(d, struct objio_dev_ent, id_node);
|
|
if (n != de) {
|
|
dprintk("%s: Race with other n->od=%p\n", __func__, n->od.od);
|
|
objio_free_deviceid_node(&de->id_node);
|
|
de = n;
|
|
}
|
|
|
|
return de;
|
|
}
|
|
|
|
struct objio_segment {
|
|
struct pnfs_layout_segment lseg;
|
|
|
|
struct ore_layout layout;
|
|
struct ore_components oc;
|
|
};
|
|
|
|
static inline struct objio_segment *
|
|
OBJIO_LSEG(struct pnfs_layout_segment *lseg)
|
|
{
|
|
return container_of(lseg, struct objio_segment, lseg);
|
|
}
|
|
|
|
struct objio_state {
|
|
/* Generic layer */
|
|
struct objlayout_io_res oir;
|
|
|
|
bool sync;
|
|
/*FIXME: Support for extra_bytes at ore_get_rw_state() */
|
|
struct ore_io_state *ios;
|
|
};
|
|
|
|
/* Send and wait for a get_device_info of devices in the layout,
|
|
then look them up with the osd_initiator library */
|
|
static int objio_devices_lookup(struct pnfs_layout_hdr *pnfslay,
|
|
struct objio_segment *objio_seg, unsigned c, struct nfs4_deviceid *d_id,
|
|
gfp_t gfp_flags)
|
|
{
|
|
struct pnfs_osd_deviceaddr *deviceaddr;
|
|
struct objio_dev_ent *ode;
|
|
struct osd_dev *od;
|
|
struct osd_dev_info odi;
|
|
bool retry_flag = true;
|
|
int err;
|
|
|
|
ode = _dev_list_find(NFS_SERVER(pnfslay->plh_inode), d_id);
|
|
if (ode) {
|
|
objio_seg->oc.ods[c] = &ode->od; /* must use container_of */
|
|
return 0;
|
|
}
|
|
|
|
err = objlayout_get_deviceinfo(pnfslay, d_id, &deviceaddr, gfp_flags);
|
|
if (unlikely(err)) {
|
|
dprintk("%s: objlayout_get_deviceinfo dev(%llx:%llx) =>%d\n",
|
|
__func__, _DEVID_LO(d_id), _DEVID_HI(d_id), err);
|
|
return err;
|
|
}
|
|
|
|
odi.systemid_len = deviceaddr->oda_systemid.len;
|
|
if (odi.systemid_len > sizeof(odi.systemid)) {
|
|
dprintk("%s: odi.systemid_len > sizeof(systemid=%zd)\n",
|
|
__func__, sizeof(odi.systemid));
|
|
err = -EINVAL;
|
|
goto out;
|
|
} else if (odi.systemid_len)
|
|
memcpy(odi.systemid, deviceaddr->oda_systemid.data,
|
|
odi.systemid_len);
|
|
odi.osdname_len = deviceaddr->oda_osdname.len;
|
|
odi.osdname = (u8 *)deviceaddr->oda_osdname.data;
|
|
|
|
if (!odi.osdname_len && !odi.systemid_len) {
|
|
dprintk("%s: !odi.osdname_len && !odi.systemid_len\n",
|
|
__func__);
|
|
err = -ENODEV;
|
|
goto out;
|
|
}
|
|
|
|
retry_lookup:
|
|
od = osduld_info_lookup(&odi);
|
|
if (unlikely(IS_ERR(od))) {
|
|
err = PTR_ERR(od);
|
|
dprintk("%s: osduld_info_lookup => %d\n", __func__, err);
|
|
if (err == -ENODEV && retry_flag) {
|
|
err = objlayout_autologin(deviceaddr);
|
|
if (likely(!err)) {
|
|
retry_flag = false;
|
|
goto retry_lookup;
|
|
}
|
|
}
|
|
goto out;
|
|
}
|
|
|
|
ode = _dev_list_add(NFS_SERVER(pnfslay->plh_inode), d_id, od,
|
|
gfp_flags);
|
|
objio_seg->oc.ods[c] = &ode->od; /* must use container_of */
|
|
dprintk("Adding new dev_id(%llx:%llx)\n",
|
|
_DEVID_LO(d_id), _DEVID_HI(d_id));
|
|
out:
|
|
objlayout_put_deviceinfo(deviceaddr);
|
|
return err;
|
|
}
|
|
|
|
static void copy_single_comp(struct ore_components *oc, unsigned c,
|
|
struct pnfs_osd_object_cred *src_comp)
|
|
{
|
|
struct ore_comp *ocomp = &oc->comps[c];
|
|
|
|
WARN_ON(src_comp->oc_cap_key.cred_len > 0); /* libosd is NO_SEC only */
|
|
WARN_ON(src_comp->oc_cap.cred_len > sizeof(ocomp->cred));
|
|
|
|
ocomp->obj.partition = src_comp->oc_object_id.oid_partition_id;
|
|
ocomp->obj.id = src_comp->oc_object_id.oid_object_id;
|
|
|
|
memcpy(ocomp->cred, src_comp->oc_cap.cred, sizeof(ocomp->cred));
|
|
}
|
|
|
|
static int __alloc_objio_seg(unsigned numdevs, gfp_t gfp_flags,
|
|
struct objio_segment **pseg)
|
|
{
|
|
/* This is the in memory structure of the objio_segment
|
|
*
|
|
* struct __alloc_objio_segment {
|
|
* struct objio_segment olseg;
|
|
* struct ore_dev *ods[numdevs];
|
|
* struct ore_comp comps[numdevs];
|
|
* } *aolseg;
|
|
* NOTE: The code as above compiles and runs perfectly. It is elegant,
|
|
* type safe and compact. At some Past time Linus has decided he does not
|
|
* like variable length arrays, For the sake of this principal we uglify
|
|
* the code as below.
|
|
*/
|
|
struct objio_segment *lseg;
|
|
size_t lseg_size = sizeof(*lseg) +
|
|
numdevs * sizeof(lseg->oc.ods[0]) +
|
|
numdevs * sizeof(*lseg->oc.comps);
|
|
|
|
lseg = kzalloc(lseg_size, gfp_flags);
|
|
if (unlikely(!lseg)) {
|
|
dprintk("%s: Failed allocation numdevs=%d size=%zd\n", __func__,
|
|
numdevs, lseg_size);
|
|
return -ENOMEM;
|
|
}
|
|
|
|
lseg->oc.numdevs = numdevs;
|
|
lseg->oc.single_comp = EC_MULTPLE_COMPS;
|
|
lseg->oc.ods = (void *)(lseg + 1);
|
|
lseg->oc.comps = (void *)(lseg->oc.ods + numdevs);
|
|
|
|
*pseg = lseg;
|
|
return 0;
|
|
}
|
|
|
|
int objio_alloc_lseg(struct pnfs_layout_segment **outp,
|
|
struct pnfs_layout_hdr *pnfslay,
|
|
struct pnfs_layout_range *range,
|
|
struct xdr_stream *xdr,
|
|
gfp_t gfp_flags)
|
|
{
|
|
struct objio_segment *objio_seg;
|
|
struct pnfs_osd_xdr_decode_layout_iter iter;
|
|
struct pnfs_osd_layout layout;
|
|
struct pnfs_osd_object_cred src_comp;
|
|
unsigned cur_comp;
|
|
int err;
|
|
|
|
err = pnfs_osd_xdr_decode_layout_map(&layout, &iter, xdr);
|
|
if (unlikely(err))
|
|
return err;
|
|
|
|
err = __alloc_objio_seg(layout.olo_num_comps, gfp_flags, &objio_seg);
|
|
if (unlikely(err))
|
|
return err;
|
|
|
|
objio_seg->layout.stripe_unit = layout.olo_map.odm_stripe_unit;
|
|
objio_seg->layout.group_width = layout.olo_map.odm_group_width;
|
|
objio_seg->layout.group_depth = layout.olo_map.odm_group_depth;
|
|
objio_seg->layout.mirrors_p1 = layout.olo_map.odm_mirror_cnt + 1;
|
|
objio_seg->layout.raid_algorithm = layout.olo_map.odm_raid_algorithm;
|
|
|
|
err = ore_verify_layout(layout.olo_map.odm_num_comps,
|
|
&objio_seg->layout);
|
|
if (unlikely(err))
|
|
goto err;
|
|
|
|
objio_seg->oc.first_dev = layout.olo_comps_index;
|
|
cur_comp = 0;
|
|
while (pnfs_osd_xdr_decode_layout_comp(&src_comp, &iter, xdr, &err)) {
|
|
copy_single_comp(&objio_seg->oc, cur_comp, &src_comp);
|
|
err = objio_devices_lookup(pnfslay, objio_seg, cur_comp,
|
|
&src_comp.oc_object_id.oid_device_id,
|
|
gfp_flags);
|
|
if (err)
|
|
goto err;
|
|
++cur_comp;
|
|
}
|
|
/* pnfs_osd_xdr_decode_layout_comp returns false on error */
|
|
if (unlikely(err))
|
|
goto err;
|
|
|
|
*outp = &objio_seg->lseg;
|
|
return 0;
|
|
|
|
err:
|
|
kfree(objio_seg);
|
|
dprintk("%s: Error: return %d\n", __func__, err);
|
|
*outp = NULL;
|
|
return err;
|
|
}
|
|
|
|
void objio_free_lseg(struct pnfs_layout_segment *lseg)
|
|
{
|
|
int i;
|
|
struct objio_segment *objio_seg = OBJIO_LSEG(lseg);
|
|
|
|
for (i = 0; i < objio_seg->oc.numdevs; i++) {
|
|
struct ore_dev *od = objio_seg->oc.ods[i];
|
|
struct objio_dev_ent *ode;
|
|
|
|
if (!od)
|
|
break;
|
|
ode = container_of(od, typeof(*ode), od);
|
|
nfs4_put_deviceid_node(&ode->id_node);
|
|
}
|
|
kfree(objio_seg);
|
|
}
|
|
|
|
static int
|
|
objio_alloc_io_state(struct pnfs_layout_hdr *pnfs_layout_type, bool is_reading,
|
|
struct pnfs_layout_segment *lseg, struct page **pages, unsigned pgbase,
|
|
loff_t offset, size_t count, void *rpcdata, gfp_t gfp_flags,
|
|
struct objio_state **outp)
|
|
{
|
|
struct objio_segment *objio_seg = OBJIO_LSEG(lseg);
|
|
struct ore_io_state *ios;
|
|
int ret;
|
|
struct __alloc_objio_state {
|
|
struct objio_state objios;
|
|
struct pnfs_osd_ioerr ioerrs[objio_seg->oc.numdevs];
|
|
} *aos;
|
|
|
|
aos = kzalloc(sizeof(*aos), gfp_flags);
|
|
if (unlikely(!aos))
|
|
return -ENOMEM;
|
|
|
|
objlayout_init_ioerrs(&aos->objios.oir, objio_seg->oc.numdevs,
|
|
aos->ioerrs, rpcdata, pnfs_layout_type);
|
|
|
|
ret = ore_get_rw_state(&objio_seg->layout, &objio_seg->oc, is_reading,
|
|
offset, count, &ios);
|
|
if (unlikely(ret)) {
|
|
kfree(aos);
|
|
return ret;
|
|
}
|
|
|
|
ios->pages = pages;
|
|
ios->pgbase = pgbase;
|
|
ios->private = aos;
|
|
BUG_ON(ios->nr_pages > (pgbase + count + PAGE_SIZE - 1) >> PAGE_SHIFT);
|
|
|
|
aos->objios.sync = 0;
|
|
aos->objios.ios = ios;
|
|
*outp = &aos->objios;
|
|
return 0;
|
|
}
|
|
|
|
void objio_free_result(struct objlayout_io_res *oir)
|
|
{
|
|
struct objio_state *objios = container_of(oir, struct objio_state, oir);
|
|
|
|
ore_put_io_state(objios->ios);
|
|
kfree(objios);
|
|
}
|
|
|
|
static enum pnfs_osd_errno osd_pri_2_pnfs_err(enum osd_err_priority oep)
|
|
{
|
|
switch (oep) {
|
|
case OSD_ERR_PRI_NO_ERROR:
|
|
return (enum pnfs_osd_errno)0;
|
|
|
|
case OSD_ERR_PRI_CLEAR_PAGES:
|
|
BUG_ON(1);
|
|
return 0;
|
|
|
|
case OSD_ERR_PRI_RESOURCE:
|
|
return PNFS_OSD_ERR_RESOURCE;
|
|
case OSD_ERR_PRI_BAD_CRED:
|
|
return PNFS_OSD_ERR_BAD_CRED;
|
|
case OSD_ERR_PRI_NO_ACCESS:
|
|
return PNFS_OSD_ERR_NO_ACCESS;
|
|
case OSD_ERR_PRI_UNREACHABLE:
|
|
return PNFS_OSD_ERR_UNREACHABLE;
|
|
case OSD_ERR_PRI_NOT_FOUND:
|
|
return PNFS_OSD_ERR_NOT_FOUND;
|
|
case OSD_ERR_PRI_NO_SPACE:
|
|
return PNFS_OSD_ERR_NO_SPACE;
|
|
default:
|
|
WARN_ON(1);
|
|
/* fallthrough */
|
|
case OSD_ERR_PRI_EIO:
|
|
return PNFS_OSD_ERR_EIO;
|
|
}
|
|
}
|
|
|
|
static void __on_dev_error(struct ore_io_state *ios,
|
|
struct ore_dev *od, unsigned dev_index, enum osd_err_priority oep,
|
|
u64 dev_offset, u64 dev_len)
|
|
{
|
|
struct objio_state *objios = ios->private;
|
|
struct pnfs_osd_objid pooid;
|
|
struct objio_dev_ent *ode = container_of(od, typeof(*ode), od);
|
|
/* FIXME: what to do with more-then-one-group layouts. We need to
|
|
* translate from ore_io_state index to oc->comps index
|
|
*/
|
|
unsigned comp = dev_index;
|
|
|
|
pooid.oid_device_id = ode->id_node.deviceid;
|
|
pooid.oid_partition_id = ios->oc->comps[comp].obj.partition;
|
|
pooid.oid_object_id = ios->oc->comps[comp].obj.id;
|
|
|
|
objlayout_io_set_result(&objios->oir, comp,
|
|
&pooid, osd_pri_2_pnfs_err(oep),
|
|
dev_offset, dev_len, !ios->reading);
|
|
}
|
|
|
|
/*
|
|
* read
|
|
*/
|
|
static void _read_done(struct ore_io_state *ios, void *private)
|
|
{
|
|
struct objio_state *objios = private;
|
|
ssize_t status;
|
|
int ret = ore_check_io(ios, &__on_dev_error);
|
|
|
|
/* FIXME: _io_free(ios) can we dealocate the libosd resources; */
|
|
|
|
if (likely(!ret))
|
|
status = ios->length;
|
|
else
|
|
status = ret;
|
|
|
|
objlayout_read_done(&objios->oir, status, objios->sync);
|
|
}
|
|
|
|
int objio_read_pagelist(struct nfs_pgio_data *rdata)
|
|
{
|
|
struct nfs_pgio_header *hdr = rdata->header;
|
|
struct objio_state *objios;
|
|
int ret;
|
|
|
|
ret = objio_alloc_io_state(NFS_I(hdr->inode)->layout, true,
|
|
hdr->lseg, rdata->args.pages, rdata->args.pgbase,
|
|
rdata->args.offset, rdata->args.count, rdata,
|
|
GFP_KERNEL, &objios);
|
|
if (unlikely(ret))
|
|
return ret;
|
|
|
|
objios->ios->done = _read_done;
|
|
dprintk("%s: offset=0x%llx length=0x%x\n", __func__,
|
|
rdata->args.offset, rdata->args.count);
|
|
ret = ore_read(objios->ios);
|
|
if (unlikely(ret))
|
|
objio_free_result(&objios->oir);
|
|
return ret;
|
|
}
|
|
|
|
/*
|
|
* write
|
|
*/
|
|
static void _write_done(struct ore_io_state *ios, void *private)
|
|
{
|
|
struct objio_state *objios = private;
|
|
ssize_t status;
|
|
int ret = ore_check_io(ios, &__on_dev_error);
|
|
|
|
/* FIXME: _io_free(ios) can we dealocate the libosd resources; */
|
|
|
|
if (likely(!ret)) {
|
|
/* FIXME: should be based on the OSD's persistence model
|
|
* See OSD2r05 Section 4.13 Data persistence model */
|
|
objios->oir.committed = NFS_FILE_SYNC;
|
|
status = ios->length;
|
|
} else {
|
|
status = ret;
|
|
}
|
|
|
|
objlayout_write_done(&objios->oir, status, objios->sync);
|
|
}
|
|
|
|
static struct page *__r4w_get_page(void *priv, u64 offset, bool *uptodate)
|
|
{
|
|
struct objio_state *objios = priv;
|
|
struct nfs_pgio_data *wdata = objios->oir.rpcdata;
|
|
struct address_space *mapping = wdata->header->inode->i_mapping;
|
|
pgoff_t index = offset / PAGE_SIZE;
|
|
struct page *page;
|
|
loff_t i_size = i_size_read(wdata->header->inode);
|
|
|
|
if (offset >= i_size) {
|
|
*uptodate = true;
|
|
dprintk("%s: g_zero_page index=0x%lx\n", __func__, index);
|
|
return ZERO_PAGE(0);
|
|
}
|
|
|
|
page = find_get_page(mapping, index);
|
|
if (!page) {
|
|
page = find_or_create_page(mapping, index, GFP_NOFS);
|
|
if (unlikely(!page)) {
|
|
dprintk("%s: grab_cache_page Failed index=0x%lx\n",
|
|
__func__, index);
|
|
return NULL;
|
|
}
|
|
unlock_page(page);
|
|
}
|
|
if (PageDirty(page) || PageWriteback(page))
|
|
*uptodate = true;
|
|
else
|
|
*uptodate = PageUptodate(page);
|
|
dprintk("%s: index=0x%lx uptodate=%d\n", __func__, index, *uptodate);
|
|
return page;
|
|
}
|
|
|
|
static void __r4w_put_page(void *priv, struct page *page)
|
|
{
|
|
dprintk("%s: index=0x%lx\n", __func__,
|
|
(page == ZERO_PAGE(0)) ? -1UL : page->index);
|
|
if (ZERO_PAGE(0) != page)
|
|
page_cache_release(page);
|
|
return;
|
|
}
|
|
|
|
static const struct _ore_r4w_op _r4w_op = {
|
|
.get_page = &__r4w_get_page,
|
|
.put_page = &__r4w_put_page,
|
|
};
|
|
|
|
int objio_write_pagelist(struct nfs_pgio_data *wdata, int how)
|
|
{
|
|
struct nfs_pgio_header *hdr = wdata->header;
|
|
struct objio_state *objios;
|
|
int ret;
|
|
|
|
ret = objio_alloc_io_state(NFS_I(hdr->inode)->layout, false,
|
|
hdr->lseg, wdata->args.pages, wdata->args.pgbase,
|
|
wdata->args.offset, wdata->args.count, wdata, GFP_NOFS,
|
|
&objios);
|
|
if (unlikely(ret))
|
|
return ret;
|
|
|
|
objios->sync = 0 != (how & FLUSH_SYNC);
|
|
objios->ios->r4w = &_r4w_op;
|
|
|
|
if (!objios->sync)
|
|
objios->ios->done = _write_done;
|
|
|
|
dprintk("%s: offset=0x%llx length=0x%x\n", __func__,
|
|
wdata->args.offset, wdata->args.count);
|
|
ret = ore_write(objios->ios);
|
|
if (unlikely(ret)) {
|
|
objio_free_result(&objios->oir);
|
|
return ret;
|
|
}
|
|
|
|
if (objios->sync)
|
|
_write_done(objios->ios, objios);
|
|
|
|
return 0;
|
|
}
|
|
|
|
/*
|
|
* Return 0 if @req cannot be coalesced into @pgio, otherwise return the number
|
|
* of bytes (maximum @req->wb_bytes) that can be coalesced.
|
|
*/
|
|
static size_t objio_pg_test(struct nfs_pageio_descriptor *pgio,
|
|
struct nfs_page *prev, struct nfs_page *req)
|
|
{
|
|
unsigned int size;
|
|
|
|
size = pnfs_generic_pg_test(pgio, prev, req);
|
|
|
|
if (!size || pgio->pg_count + req->wb_bytes >
|
|
(unsigned long)pgio->pg_layout_private)
|
|
return 0;
|
|
|
|
return min(size, req->wb_bytes);
|
|
}
|
|
|
|
static void objio_init_read(struct nfs_pageio_descriptor *pgio, struct nfs_page *req)
|
|
{
|
|
pnfs_generic_pg_init_read(pgio, req);
|
|
if (unlikely(pgio->pg_lseg == NULL))
|
|
return; /* Not pNFS */
|
|
|
|
pgio->pg_layout_private = (void *)
|
|
OBJIO_LSEG(pgio->pg_lseg)->layout.max_io_length;
|
|
}
|
|
|
|
static bool aligned_on_raid_stripe(u64 offset, struct ore_layout *layout,
|
|
unsigned long *stripe_end)
|
|
{
|
|
u32 stripe_off;
|
|
unsigned stripe_size;
|
|
|
|
if (layout->raid_algorithm == PNFS_OSD_RAID_0)
|
|
return true;
|
|
|
|
stripe_size = layout->stripe_unit *
|
|
(layout->group_width - layout->parity);
|
|
|
|
div_u64_rem(offset, stripe_size, &stripe_off);
|
|
if (!stripe_off)
|
|
return true;
|
|
|
|
*stripe_end = stripe_size - stripe_off;
|
|
return false;
|
|
}
|
|
|
|
static void objio_init_write(struct nfs_pageio_descriptor *pgio, struct nfs_page *req)
|
|
{
|
|
unsigned long stripe_end = 0;
|
|
u64 wb_size;
|
|
|
|
if (pgio->pg_dreq == NULL)
|
|
wb_size = i_size_read(pgio->pg_inode) - req_offset(req);
|
|
else
|
|
wb_size = nfs_dreq_bytes_left(pgio->pg_dreq);
|
|
|
|
pnfs_generic_pg_init_write(pgio, req, wb_size);
|
|
if (unlikely(pgio->pg_lseg == NULL))
|
|
return; /* Not pNFS */
|
|
|
|
if (req->wb_offset ||
|
|
!aligned_on_raid_stripe(req->wb_index * PAGE_SIZE,
|
|
&OBJIO_LSEG(pgio->pg_lseg)->layout,
|
|
&stripe_end)) {
|
|
pgio->pg_layout_private = (void *)stripe_end;
|
|
} else {
|
|
pgio->pg_layout_private = (void *)
|
|
OBJIO_LSEG(pgio->pg_lseg)->layout.max_io_length;
|
|
}
|
|
}
|
|
|
|
static const struct nfs_pageio_ops objio_pg_read_ops = {
|
|
.pg_init = objio_init_read,
|
|
.pg_test = objio_pg_test,
|
|
.pg_doio = pnfs_generic_pg_readpages,
|
|
};
|
|
|
|
static const struct nfs_pageio_ops objio_pg_write_ops = {
|
|
.pg_init = objio_init_write,
|
|
.pg_test = objio_pg_test,
|
|
.pg_doio = pnfs_generic_pg_writepages,
|
|
};
|
|
|
|
static struct pnfs_layoutdriver_type objlayout_type = {
|
|
.id = LAYOUT_OSD2_OBJECTS,
|
|
.name = "LAYOUT_OSD2_OBJECTS",
|
|
.flags = PNFS_LAYOUTRET_ON_SETATTR |
|
|
PNFS_LAYOUTRET_ON_ERROR,
|
|
|
|
.owner = THIS_MODULE,
|
|
.alloc_layout_hdr = objlayout_alloc_layout_hdr,
|
|
.free_layout_hdr = objlayout_free_layout_hdr,
|
|
|
|
.alloc_lseg = objlayout_alloc_lseg,
|
|
.free_lseg = objlayout_free_lseg,
|
|
|
|
.read_pagelist = objlayout_read_pagelist,
|
|
.write_pagelist = objlayout_write_pagelist,
|
|
.pg_read_ops = &objio_pg_read_ops,
|
|
.pg_write_ops = &objio_pg_write_ops,
|
|
|
|
.free_deviceid_node = objio_free_deviceid_node,
|
|
|
|
.encode_layoutcommit = objlayout_encode_layoutcommit,
|
|
.encode_layoutreturn = objlayout_encode_layoutreturn,
|
|
};
|
|
|
|
MODULE_DESCRIPTION("pNFS Layout Driver for OSD2 objects");
|
|
MODULE_AUTHOR("Benny Halevy <bhalevy@panasas.com>");
|
|
MODULE_LICENSE("GPL");
|
|
|
|
static int __init
|
|
objlayout_init(void)
|
|
{
|
|
int ret = pnfs_register_layoutdriver(&objlayout_type);
|
|
|
|
if (ret)
|
|
printk(KERN_INFO
|
|
"NFS: %s: Registering OSD pNFS Layout Driver failed: error=%d\n",
|
|
__func__, ret);
|
|
else
|
|
printk(KERN_INFO "NFS: %s: Registered OSD pNFS Layout Driver\n",
|
|
__func__);
|
|
return ret;
|
|
}
|
|
|
|
static void __exit
|
|
objlayout_exit(void)
|
|
{
|
|
pnfs_unregister_layoutdriver(&objlayout_type);
|
|
printk(KERN_INFO "NFS: %s: Unregistered OSD pNFS Layout Driver\n",
|
|
__func__);
|
|
}
|
|
|
|
MODULE_ALIAS("nfs-layouttype4-2");
|
|
|
|
module_init(objlayout_init);
|
|
module_exit(objlayout_exit);
|