X-Git-Url: https://git.whamcloud.com/?p=fs%2Flustre-release.git;a=blobdiff_plain;f=lustre%2Fliblustre%2Fllite_cl.c;h=5c7ce91a470a2926495b9bb7ec7eae36c8fd9e98;hp=aa5b72ccb2f445b475611af97bdab3c405d6addb;hb=93fe562c5dd3829939e3bc0533918f66b19776a4;hpb=3d3e8e27d6bfbfcf6970f7aa8942caf7a362c3db diff --git a/lustre/liblustre/llite_cl.c b/lustre/liblustre/llite_cl.c index aa5b72cc..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); @@ -321,14 +304,7 @@ static void slp_page_fini_common(struct ccc_page *cp) static void slp_page_completion_common(const struct lu_env *env, struct ccc_page *cp, int ioret) { - struct cl_sync_io *anchor = cp->cpg_sync_io; - - if (anchor) { - cp->cpg_sync_io = NULL; - cl_sync_io_note(anchor, ioret); - } else { - LBUG(); - } + LASSERT(cp->cpg_cl.cpl_page->cp_sync_io != NULL); } static void slp_page_completion_read(const struct lu_env *env, @@ -458,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; } @@ -494,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) @@ -503,19 +480,14 @@ static int llu_queue_pio(const struct lu_env *env, struct cl_io *io, struct intnl_stat *st = llu_i2stat(inode); struct obd_export *exp = llu_i2obdexp(inode); struct page *page; - int rc = 0, npages = 0, ret_bytes = 0; - int local_lock; + int rc = 0, ret_bytes = 0; struct cl_page *clp; - struct ccc_page *clup; struct cl_2queue *queue; - struct cl_sync_io *anchor = &ccc_env_info(env)->cti_sync_io; ENTRY; if (!exp) RETURN(-EINVAL); - local_lock = group->lig_params->lrp_lock_mode != LCK_NL; - queue = &io->ci_queue; cl_2queue_init(queue); @@ -525,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; @@ -561,8 +533,6 @@ static int llu_queue_pio(const struct lu_env *env, struct cl_io *io, break; } - clup = cl2ccc_page(cl_page_at(clp, &slp_device_type)); - clup->cpg_sync_io = anchor; cl_2queue_add(queue, clp); /* drop the reference count for cl_page_find, so that the page @@ -571,7 +541,6 @@ static int llu_queue_pio(const struct lu_env *env, struct cl_io *io, cl_page_clip(env, clp, offset, offset+bytes); - npages++; count -= bytes; pos += bytes; buf += bytes; @@ -581,25 +550,10 @@ static int llu_queue_pio(const struct lu_env *env, struct cl_io *io, page++; } while (count); - cl_sync_io_init(anchor, npages); - /* printk("Inited anchor with %d pages\n", npages); */ - if (rc == 0) { - enum cl_req_type crt; - - crt = io->ci_type == CIT_READ ? CRT_READ : CRT_WRITE; - rc = cl_io_submit_rw(env, io, crt, queue, CRP_NORMAL); - if (rc == 0) { - /* If some pages weren't sent for any reason, count - * then as completed, to avoid infinite wait. */ - cl_page_list_for_each(clp, &queue->c2_qin) { - CL_PAGE_DEBUG(D_ERROR, env, clp, - "not completed\n"); - cl_sync_io_note(anchor, +1); - } - /* wait for the IO to be finished. */ - rc = cl_sync_io_wait(env, io, &queue->c2_qout, anchor); - } + enum cl_req_type iot; + iot = io->ci_type == CIT_READ ? CRT_READ : CRT_WRITE; + rc = cl_io_submit_sync(env, io, iot, queue, 0); } group->lig_rc = rc; @@ -628,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) @@ -636,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; @@ -674,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) @@ -689,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; @@ -757,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