X-Git-Url: https://git.whamcloud.com/?p=fs%2Flustre-release.git;a=blobdiff_plain;f=lustre%2Fliblustre%2Fllite_cl.c;h=5c7ce91a470a2926495b9bb7ec7eae36c8fd9e98;hp=98ae334b01039e7a6a2a33b3f519f32feefb32a9;hb=93fe562c5dd3829939e3bc0533918f66b19776a4;hpb=490fd542a9bc8e8dafd22a8f4ca7b186f87ab21c diff --git a/lustre/liblustre/llite_cl.c b/lustre/liblustre/llite_cl.c index 98ae334..5c7ce91 100644 --- a/lustre/liblustre/llite_cl.c +++ b/lustre/liblustre/llite_cl.c @@ -1,6 +1,4 @@ -/* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*- - * vim:expandtab:shiftwidth=8:tabstop=8: - * +/* * Copyright (c) 2007 Cluster File Systems, Inc. * Author: Nikita Danilov * @@ -18,6 +16,8 @@ * You should have received a copy of the GNU General Public License * along with Lustre; if not, write to the Free Software * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + * + * Copyright (c) 2011, 2013, Intel Corporation. */ #define DEBUG_SUBSYSTEM S_LLITE @@ -36,16 +36,6 @@ # include #endif -#include -#ifdef HAVE_XTIO_H -#include -#endif -#include -#include -#include -#ifdef HAVE_FILE_H -#include -#endif #include #include @@ -67,9 +57,8 @@ static int slp_type_init (struct lu_device_type *t); static void slp_type_fini (struct lu_device_type *t); -static struct cl_page * slp_page_init(const struct lu_env *env, - struct cl_object *obj, - struct cl_page *page, cfs_page_t *vmpage); +static int slp_page_init(const struct lu_env *env, struct cl_object *obj, + struct cl_page *page, struct page *vmpage); static int slp_attr_get (const struct lu_env *env, struct cl_object *obj, struct cl_attr *attr); @@ -234,32 +223,26 @@ void slp_global_fini(void) * */ -static struct cl_page *slp_page_init(const struct lu_env *env, - struct cl_object *obj, - struct cl_page *page, cfs_page_t *vmpage) +static int slp_page_init(const struct lu_env *env, struct cl_object *obj, + struct cl_page *page, struct page *vmpage) { - struct ccc_page *cpg; - int result; + struct ccc_page *cpg = cl_object_page_slice(obj, page); CLOBINVRNT(env, obj, ccc_object_invariant(obj)); - OBD_ALLOC_PTR(cpg); - if (cpg != NULL) { - cpg->cpg_page = vmpage; + cpg->cpg_page = vmpage; - if (page->cp_type == CPT_CACHEABLE) { - LBUG(); - } else { - struct ccc_object *clobj = cl2ccc(obj); + if (page->cp_type == CPT_CACHEABLE) { + LBUG(); + } else { + struct ccc_object *clobj = cl2ccc(obj); - cl_page_slice_add(page, &cpg->cpg_cl, obj, - &slp_transient_page_ops); - clobj->cob_transient_pages++; - } - result = 0; - } else - result = -ENOMEM; - return ERR_PTR(result); + cl_page_slice_add(page, &cpg->cpg_cl, obj, + &slp_transient_page_ops); + clobj->cob_transient_pages++; + } + + return 0; } static int slp_io_init(const struct lu_env *env, struct cl_object *obj, @@ -311,7 +294,7 @@ static int slp_attr_get(const struct lu_env *env, struct cl_object *obj, static void slp_page_fini_common(struct ccc_page *cp) { - cfs_page_t *vmpage = cp->cpg_page; + struct page *vmpage = cp->cpg_page; LASSERT(vmpage != NULL); llu_free_user_page(vmpage); @@ -451,14 +434,14 @@ static int slp_io_rw_lock(const struct lu_env *env, } -static int slp_io_trunc_iter_init(const struct lu_env *env, - const struct cl_io_slice *ios) +static int slp_io_setattr_iter_init(const struct lu_env *env, + const struct cl_io_slice *ios) { return 0; } -static int slp_io_trunc_start(const struct lu_env *env, - const struct cl_io_slice *ios) +static int slp_io_setattr_start(const struct lu_env *env, + const struct cl_io_slice *ios) { return 0; } @@ -487,6 +470,7 @@ static void llu_free_user_page(struct page *page) OBD_FREE_PTR(page); } + static int llu_queue_pio(const struct lu_env *env, struct cl_io *io, struct llu_io_group *group, char *buf, size_t count, loff_t pos) @@ -497,7 +481,6 @@ static int llu_queue_pio(const struct lu_env *env, struct cl_io *io, struct obd_export *exp = llu_i2obdexp(inode); struct page *page; int rc = 0, ret_bytes = 0; - int local_lock; struct cl_page *clp; struct cl_2queue *queue; ENTRY; @@ -505,8 +488,6 @@ static int llu_queue_pio(const struct lu_env *env, struct cl_io *io, if (!exp) RETURN(-EINVAL); - local_lock = group->lig_params->lrp_lock_mode != LCK_NL; - queue = &io->ci_queue; cl_2queue_init(queue); @@ -516,8 +497,8 @@ static int llu_queue_pio(const struct lu_env *env, struct cl_io *io, unsigned long index, offset, bytes; offset = (pos & ~CFS_PAGE_MASK); - index = pos >> CFS_PAGE_SHIFT; - bytes = CFS_PAGE_SIZE - offset; + index = pos >> PAGE_CACHE_SHIFT; + bytes = PAGE_CACHE_SIZE - offset; if (bytes > count) bytes = count; @@ -572,7 +553,7 @@ static int llu_queue_pio(const struct lu_env *env, struct cl_io *io, if (rc == 0) { enum cl_req_type iot; iot = io->ci_type == CIT_READ ? CRT_READ : CRT_WRITE; - rc = cl_io_submit_sync(env, io, iot, queue, CRP_NORMAL, 0); + rc = cl_io_submit_sync(env, io, iot, queue, 0); } group->lig_rc = rc; @@ -601,7 +582,8 @@ struct llu_io_group * get_io_group(struct inode *inode, int maxpages, static int max_io_pages(ssize_t len, int iovlen) { - return (((len + CFS_PAGE_SIZE -1) / CFS_PAGE_SIZE) + 2 + iovlen - 1); + return ((len + PAGE_CACHE_SIZE - 1) / PAGE_CACHE_SIZE) + + 2 + iovlen - 1; } void put_io_group(struct llu_io_group *group) @@ -609,15 +591,23 @@ void put_io_group(struct llu_io_group *group) OBD_FREE_PTR(group); } +/** + * True, if \a io is a normal io, False for sendfile() / splice_{read|write} + */ +int cl_is_normalio(const struct lu_env *env, const struct cl_io *io) +{ + return 1; +} + static int slp_io_start(const struct lu_env *env, const struct cl_io_slice *ios) { struct ccc_io *cio = cl2ccc_io(env, ios); struct cl_io *io = ios->cis_io; struct cl_object *obj = io->ci_obj; struct inode *inode = ccc_object_inode(obj); - int err, ret; - loff_t pos; - size_t cnt; + int err, ret; + loff_t pos; + long cnt; struct llu_io_group *iogroup; struct lustre_rw_params p = {0}; int iovidx; @@ -647,13 +637,13 @@ static int slp_io_start(const struct lu_env *env, const struct cl_io_slice *ios) if (IS_ERR(iogroup)) RETURN(PTR_ERR(iogroup)); - err = ccc_prep_size(env, obj, io, pos, cnt, 0, &exceed); + err = ccc_prep_size(env, obj, io, pos, cnt, &exceed); if (err != 0 || (write == 0 && exceed != 0)) GOTO(out, err); CDEBUG(D_INODE, - "%s ino %lu, "LPSZ" bytes, offset %lld, i_size %llu\n", - write?"Write":"Read", (unsigned long)st->st_ino, + "%s ino %lu, %lu bytes, offset "LPU64", i_size "LPU64"\n", + write ? "Write" : "Read", (unsigned long)st->st_ino, cnt, (__u64)pos, (__u64)st->st_size); if (write && io->u.ci_wr.wr_append) @@ -662,7 +652,7 @@ static int slp_io_start(const struct lu_env *env, const struct cl_io_slice *ios) for (iovidx = 0; iovidx < cio->cui_nrsegs; iovidx++) { char *buf = (char *) cio->cui_iov[iovidx].iov_base; - size_t count = cio->cui_iov[iovidx].iov_len; + long count = cio->cui_iov[iovidx].iov_len; if (!count) continue; @@ -730,10 +720,10 @@ static const struct cl_io_operations ccc_io_ops = { .cio_end = ccc_io_end, .cio_advance = ccc_io_advance }, - [CIT_TRUNC] = { + [CIT_SETATTR] = { .cio_fini = ccc_io_fini, - .cio_iter_init = slp_io_trunc_iter_init, - .cio_start = slp_io_trunc_start + .cio_iter_init = slp_io_setattr_iter_init, + .cio_start = slp_io_setattr_start }, [CIT_MISC] = { .cio_fini = ccc_io_fini