X-Git-Url: https://git.whamcloud.com/?a=blobdiff_plain;f=lustre%2Fliblustre%2Fdir.c;h=b14e1a23eaf7f131c49524d03b9c2da9a73d2f39;hb=9d72ec94b56590ad5da7003e93dd268d81fc8d14;hp=a13c95029e90e446a42f41e36d28357269513cac;hpb=2841be335687840cf98961e6c6cde6ee9312e4d7;p=fs%2Flustre-release.git diff --git a/lustre/liblustre/dir.c b/lustre/liblustre/dir.c index a13c950..b14e1a2 100644 --- a/lustre/liblustre/dir.c +++ b/lustre/liblustre/dir.c @@ -40,28 +40,26 @@ #define DEBUG_SUBSYSTEM S_LLITE -#include -#include +#include +#include #include -#include -#include -#include #include -#include -#include - -#ifdef HAVE_LINUX_UNISTD_H -#include -#elif defined(HAVE_UNISTD_H) -#include -#endif - - +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include #include "llite_lib.h" #include /* (new) readdir implementation overview can be found in lustre/llite/dir.c */ - static int llu_dir_do_readpage(struct inode *inode, struct page *page) { struct llu_inode_info *lli = llu_i2info(inode); @@ -80,13 +78,16 @@ static int llu_dir_do_readpage(struct inode *inode, struct page *page) rc = md_lock_match(sbi->ll_md_exp, LDLM_FL_BLOCK_GRANTED, &lli->lli_fid, LDLM_IBITS, &policy, LCK_CR, &lockh); if (!rc) { - struct ldlm_enqueue_info einfo = {LDLM_IBITS, LCK_CR, - llu_md_blocking_ast, ldlm_completion_ast, NULL, NULL, - inode}; - - rc = md_enqueue(sbi->ll_md_exp, &einfo, &it, - &op_data, &lockh, NULL, 0, NULL, - LDLM_FL_CANCEL_ON_BLOCK); + struct ldlm_enqueue_info einfo = { + .ei_type = LDLM_IBITS, + .ei_mode = LCK_CR, + .ei_cb_bl = llu_md_blocking_ast, + .ei_cb_cp = ldlm_completion_ast, + .ei_cbdata = inode, + }; + + rc = md_enqueue(sbi->ll_md_exp, &einfo, NULL, &it, &op_data, + &lockh, LDLM_FL_CANCEL_ON_BLOCK); request = (struct ptlrpc_request *)it.d.lustre.it_data; if (request) ptlrpc_req_finished(request); @@ -97,7 +98,7 @@ static int llu_dir_do_readpage(struct inode *inode, struct page *page) } ldlm_lock_dump_handle(D_OTHER, &lockh); - op_data.op_offset = (__u64)hash_x_index(page->index, 0); + op_data.op_hash_offset = hash_x_index(page->index, 0); op_data.op_npages = 1; rc = md_readpage(sbi->ll_md_exp, &op_data, &page, &request); if (!rc) { @@ -116,10 +117,10 @@ static int llu_dir_do_readpage(struct inode *inode, struct page *page) return rc; } -static cfs_page_t *llu_dir_read_page(struct inode *ino, __u64 hash, +static struct page *llu_dir_read_page(struct inode *ino, __u64 hash, int exact, struct ll_dir_chain *chain) { - cfs_page_t *page; + struct page *page; int rc; ENTRY; @@ -137,15 +138,15 @@ static cfs_page_t *llu_dir_read_page(struct inode *ino, __u64 hash, return page; } -void *(*memmover)(void *, const void *, size_t) = memmove; +static void *(*memmover)(void *, const void *, size_t) = memmove; #define NAME_OFFSET(de) ((int) ((de)->d_name - (char *) (de))) #define ROUND_UP64(x) (((x)+sizeof(__u64)-1) & ~(sizeof(__u64)-1)) static int filldir(char *buf, int buflen, const char *name, int namelen, loff_t offset, ino_t ino, unsigned int d_type, int *filled) { - struct dirent64 *dirent = (struct dirent64 *)(buf + *filled); - struct dirent64 holder; + struct intnl_dirent *dirent = (struct intnl_dirent *)(buf + *filled); + struct intnl_dirent holder; int reclen = ROUND_UP64(NAME_OFFSET(dirent) + namelen + 1); /* @@ -189,7 +190,7 @@ ssize_t llu_iop_filldirentries(struct inode *dir, _SYSIO_OFF_T *basep, struct intnl_stat *st = llu_i2stat(dir); loff_t pos = *basep; struct ll_dir_chain chain; - cfs_page_t *page; + struct page *page; int filled = 0; int rc; int done;