107 static int note_last_dentry(struct ceph_dir_file_info *dfi, const char *name,  in note_last_dentry()  argument
113 	kfree(dfi->last_name);  in note_last_dentry()
114 	dfi->last_name = buf;  in note_last_dentry()
115 	memcpy(dfi->last_name, name, len);  in note_last_dentry()
116 	dfi->last_name[len] = 0;  in note_last_dentry()
117 	dfi->next_offset = next_offset;  in note_last_dentry()
118 	dout("note_last_dentry '%s'\n", dfi->last_name);  in note_last_dentry()
180 	struct ceph_dir_file_info *dfi = file->private_data;  in __dcache_readdir()  local
227 			dfi->file_info.flags |= CEPH_F_ATEND;  in __dcache_readdir()
279 		ret = note_last_dentry(dfi, last->d_name.name, last->d_name.len,  in __dcache_readdir()
285 		if (dfi->readdir_cache_idx >= 0) {  in __dcache_readdir()
286 			dfi->readdir_cache_idx = -1;  in __dcache_readdir()
287 			dfi->dir_release_count = 0;  in __dcache_readdir()
293 static bool need_send_readdir(struct ceph_dir_file_info *dfi, loff_t pos)  in need_send_readdir()  argument
295 	if (!dfi->last_readdir)  in need_send_readdir()
298 		return !ceph_frag_contains_value(dfi->frag, fpos_hash(pos));  in need_send_readdir()
300 		return dfi->frag != fpos_frag(pos);  in need_send_readdir()
305 	struct ceph_dir_file_info *dfi = file->private_data;  in ceph_readdir()  local
316 	if (dfi->file_info.flags & CEPH_F_ATEND)  in ceph_readdir()
357 	if (need_send_readdir(dfi, ctx->pos)) {  in ceph_readdir()
363 		if (dfi->last_readdir) {  in ceph_readdir()
364 			ceph_mdsc_put_request(dfi->last_readdir);  in ceph_readdir()
365 			dfi->last_readdir = NULL;  in ceph_readdir()
379 		     ceph_vinop(inode), frag, dfi->last_name);  in ceph_readdir()
395 		if (dfi->last_name) {  in ceph_readdir()
396 			req->r_path2 = kstrdup(dfi->last_name, GFP_KERNEL);  in ceph_readdir()
406 		req->r_dir_release_cnt = dfi->dir_release_count;  in ceph_readdir()
407 		req->r_dir_ordered_cnt = dfi->dir_ordered_count;  in ceph_readdir()
408 		req->r_readdir_cache_idx = dfi->readdir_cache_idx;  in ceph_readdir()
409 		req->r_readdir_offset = dfi->next_offset;  in ceph_readdir()
433 				dfi->next_offset = req->r_readdir_offset;  in ceph_readdir()
436 							  dfi->next_offset,  in ceph_readdir()
441 		dfi->frag = frag;  in ceph_readdir()
442 		dfi->last_readdir = req;  in ceph_readdir()
445 			dfi->readdir_cache_idx = req->r_readdir_cache_idx;  in ceph_readdir()
446 			if (dfi->readdir_cache_idx < 0) {  in ceph_readdir()
448 				dfi->dir_ordered_count = 0;  in ceph_readdir()
450 				   dfi->next_offset == 2) {  in ceph_readdir()
453 				dfi->dir_release_count = req->r_dir_release_cnt;  in ceph_readdir()
454 				dfi->dir_ordered_count = req->r_dir_ordered_cnt;  in ceph_readdir()
459 			dfi->readdir_cache_idx = -1;  in ceph_readdir()
461 			dfi->dir_release_count = 0;  in ceph_readdir()
470 			err = note_last_dentry(dfi, rde->name, rde->name_len,  in ceph_readdir()
475 			dfi->next_offset = 2;  in ceph_readdir()
480 	rinfo = &dfi->last_readdir->r_reply_info;  in ceph_readdir()
482 	     dfi->frag, rinfo->dir_nr, ctx->pos,  in ceph_readdir()
526 	ceph_mdsc_put_request(dfi->last_readdir);  in ceph_readdir()
527 	dfi->last_readdir = NULL;  in ceph_readdir()
529 	if (dfi->next_offset > 2) {  in ceph_readdir()
530 		frag = dfi->frag;  in ceph_readdir()
535 	if (!ceph_frag_is_rightmost(dfi->frag)) {  in ceph_readdir()
536 		frag = ceph_frag_next(dfi->frag);  in ceph_readdir()
539 							dfi->next_offset, true);  in ceph_readdir()
544 			ctx->pos = ceph_make_fpos(frag, dfi->next_offset,  in ceph_readdir()
546 			kfree(dfi->last_name);  in ceph_readdir()
547 			dfi->last_name = NULL;  in ceph_readdir()
552 	dfi->file_info.flags |= CEPH_F_ATEND;  in ceph_readdir()
560 					dfi->dir_release_count) {  in ceph_readdir()
562 		if (dfi->dir_ordered_count ==  in ceph_readdir()
567 			BUG_ON(dfi->readdir_cache_idx < 0);  in ceph_readdir()
568 			i_size_write(inode, dfi->readdir_cache_idx *  in ceph_readdir()
573 		__ceph_dir_set_complete(ci, dfi->dir_release_count,  in ceph_readdir()
574 					dfi->dir_ordered_count);  in ceph_readdir()
582 static void reset_readdir(struct ceph_dir_file_info *dfi)  in reset_readdir()  argument
584 	if (dfi->last_readdir) {  in reset_readdir()
585 		ceph_mdsc_put_request(dfi->last_readdir);  in reset_readdir()
586 		dfi->last_readdir = NULL;  in reset_readdir()
588 	kfree(dfi->last_name);  in reset_readdir()
589 	dfi->last_name = NULL;  in reset_readdir()
590 	dfi->dir_release_count = 0;  in reset_readdir()
591 	dfi->readdir_cache_idx = -1;  in reset_readdir()
592 	dfi->next_offset = 2;  /* compensate for . and .. */  in reset_readdir()
593 	dfi->file_info.flags &= ~CEPH_F_ATEND;  in reset_readdir()
600 static bool need_reset_readdir(struct ceph_dir_file_info *dfi, loff_t new_pos)  in need_reset_readdir()  argument
609 	} else if (dfi->frag != fpos_frag(new_pos)) {  in need_reset_readdir()
612 	rinfo = dfi->last_readdir ? &dfi->last_readdir->r_reply_info : NULL;  in need_reset_readdir()
622 	struct ceph_dir_file_info *dfi = file->private_data;  in ceph_dir_llseek()  local
640 		if (need_reset_readdir(dfi, offset)) {  in ceph_dir_llseek()
642 			reset_readdir(dfi);  in ceph_dir_llseek()
646 			dfi->dir_release_count = 0;  in ceph_dir_llseek()
647 			dfi->readdir_cache_idx = -1;  in ceph_dir_llseek()
653 			dfi->file_info.flags &= ~CEPH_F_ATEND;  in ceph_dir_llseek()
1736 	struct ceph_dir_file_info *dfi = file->private_data;  in ceph_read_dir()  local
1745 	if (!dfi->dir_info) {  in ceph_read_dir()
1746 		dfi->dir_info = kmalloc(bufsize, GFP_KERNEL);  in ceph_read_dir()
1747 		if (!dfi->dir_info)  in ceph_read_dir()
1749 		dfi->dir_info_len =  in ceph_read_dir()
1750 			snprintf(dfi->dir_info, bufsize,  in ceph_read_dir()
1770 	if (*ppos >= dfi->dir_info_len)  in ceph_read_dir()
1772 	size = min_t(unsigned, size, dfi->dir_info_len-*ppos);  in ceph_read_dir()
1773 	left = copy_to_user(buf, dfi->dir_info + *ppos, size);  in ceph_read_dir()