111 static int note_last_dentry(struct ceph_dir_file_info *dfi, const char *name,  in note_last_dentry()  argument
117 	kfree(dfi->last_name);  in note_last_dentry()
118 	dfi->last_name = buf;  in note_last_dentry()
119 	memcpy(dfi->last_name, name, len);  in note_last_dentry()
120 	dfi->last_name[len] = 0;  in note_last_dentry()
121 	dfi->next_offset = next_offset;  in note_last_dentry()
122 	dout("note_last_dentry '%s'\n", dfi->last_name);  in note_last_dentry()
184 	struct ceph_dir_file_info *dfi = file->private_data;  in __dcache_readdir()  local
231 			dfi->file_info.flags |= CEPH_F_ATEND;  in __dcache_readdir()
281 		ret = note_last_dentry(dfi, last->d_name.name, last->d_name.len,  in __dcache_readdir()
287 		if (dfi->readdir_cache_idx >= 0) {  in __dcache_readdir()
288 			dfi->readdir_cache_idx = -1;  in __dcache_readdir()
289 			dfi->dir_release_count = 0;  in __dcache_readdir()
295 static bool need_send_readdir(struct ceph_dir_file_info *dfi, loff_t pos)  in need_send_readdir()  argument
297 	if (!dfi->last_readdir)  in need_send_readdir()
300 		return !ceph_frag_contains_value(dfi->frag, fpos_hash(pos));  in need_send_readdir()
302 		return dfi->frag != fpos_frag(pos);  in need_send_readdir()
307 	struct ceph_dir_file_info *dfi = file->private_data;  in ceph_readdir()  local
318 	if (dfi->file_info.flags & CEPH_F_ATEND)  in ceph_readdir()
366 	if (need_send_readdir(dfi, ctx->pos)) {  in ceph_readdir()
372 		if (dfi->last_readdir) {  in ceph_readdir()
373 			ceph_mdsc_put_request(dfi->last_readdir);  in ceph_readdir()
374 			dfi->last_readdir = NULL;  in ceph_readdir()
388 		     ceph_vinop(inode), frag, dfi->last_name);  in ceph_readdir()
404 		if (dfi->last_name) {  in ceph_readdir()
405 			req->r_path2 = kstrdup(dfi->last_name, GFP_KERNEL);  in ceph_readdir()
415 		req->r_dir_release_cnt = dfi->dir_release_count;  in ceph_readdir()
416 		req->r_dir_ordered_cnt = dfi->dir_ordered_count;  in ceph_readdir()
417 		req->r_readdir_cache_idx = dfi->readdir_cache_idx;  in ceph_readdir()
418 		req->r_readdir_offset = dfi->next_offset;  in ceph_readdir()
442 				dfi->next_offset = req->r_readdir_offset;  in ceph_readdir()
445 							  dfi->next_offset,  in ceph_readdir()
450 		dfi->frag = frag;  in ceph_readdir()
451 		dfi->last_readdir = req;  in ceph_readdir()
454 			dfi->readdir_cache_idx = req->r_readdir_cache_idx;  in ceph_readdir()
455 			if (dfi->readdir_cache_idx < 0) {  in ceph_readdir()
457 				dfi->dir_ordered_count = 0;  in ceph_readdir()
459 				   dfi->next_offset == 2) {  in ceph_readdir()
462 				dfi->dir_release_count = req->r_dir_release_cnt;  in ceph_readdir()
463 				dfi->dir_ordered_count = req->r_dir_ordered_cnt;  in ceph_readdir()
468 			dfi->readdir_cache_idx = -1;  in ceph_readdir()
470 			dfi->dir_release_count = 0;  in ceph_readdir()
479 			err = note_last_dentry(dfi, rde->name, rde->name_len,  in ceph_readdir()
482 				ceph_mdsc_put_request(dfi->last_readdir);  in ceph_readdir()
483 				dfi->last_readdir = NULL;  in ceph_readdir()
487 			dfi->next_offset = 2;  in ceph_readdir()
492 	rinfo = &dfi->last_readdir->r_reply_info;  in ceph_readdir()
494 	     dfi->frag, rinfo->dir_nr, ctx->pos,  in ceph_readdir()
527 			 * NOTE: Here no need to put the 'dfi->last_readdir',  in ceph_readdir()
538 	ceph_mdsc_put_request(dfi->last_readdir);  in ceph_readdir()
539 	dfi->last_readdir = NULL;  in ceph_readdir()
541 	if (dfi->next_offset > 2) {  in ceph_readdir()
542 		frag = dfi->frag;  in ceph_readdir()
547 	if (!ceph_frag_is_rightmost(dfi->frag)) {  in ceph_readdir()
548 		frag = ceph_frag_next(dfi->frag);  in ceph_readdir()
551 							dfi->next_offset, true);  in ceph_readdir()
556 			ctx->pos = ceph_make_fpos(frag, dfi->next_offset,  in ceph_readdir()
558 			kfree(dfi->last_name);  in ceph_readdir()
559 			dfi->last_name = NULL;  in ceph_readdir()
564 	dfi->file_info.flags |= CEPH_F_ATEND;  in ceph_readdir()
572 					dfi->dir_release_count) {  in ceph_readdir()
574 		if (dfi->dir_ordered_count ==  in ceph_readdir()
579 			BUG_ON(dfi->readdir_cache_idx < 0);  in ceph_readdir()
580 			i_size_write(inode, dfi->readdir_cache_idx *  in ceph_readdir()
585 		__ceph_dir_set_complete(ci, dfi->dir_release_count,  in ceph_readdir()
586 					dfi->dir_ordered_count);  in ceph_readdir()
594 static void reset_readdir(struct ceph_dir_file_info *dfi)  in reset_readdir()  argument
596 	if (dfi->last_readdir) {  in reset_readdir()
597 		ceph_mdsc_put_request(dfi->last_readdir);  in reset_readdir()
598 		dfi->last_readdir = NULL;  in reset_readdir()
600 	kfree(dfi->last_name);  in reset_readdir()
601 	dfi->last_name = NULL;  in reset_readdir()
602 	dfi->dir_release_count = 0;  in reset_readdir()
603 	dfi->readdir_cache_idx = -1;  in reset_readdir()
604 	dfi->next_offset = 2;  /* compensate for . and .. */  in reset_readdir()
605 	dfi->file_info.flags &= ~CEPH_F_ATEND;  in reset_readdir()
612 static bool need_reset_readdir(struct ceph_dir_file_info *dfi, loff_t new_pos)  in need_reset_readdir()  argument
621 	} else if (dfi->frag != fpos_frag(new_pos)) {  in need_reset_readdir()
624 	rinfo = dfi->last_readdir ? &dfi->last_readdir->r_reply_info : NULL;  in need_reset_readdir()
634 	struct ceph_dir_file_info *dfi = file->private_data;  in ceph_dir_llseek()  local
654 		if (need_reset_readdir(dfi, offset)) {  in ceph_dir_llseek()
656 			reset_readdir(dfi);  in ceph_dir_llseek()
660 			dfi->dir_release_count = 0;  in ceph_dir_llseek()
661 			dfi->readdir_cache_idx = -1;  in ceph_dir_llseek()
667 			dfi->file_info.flags &= ~CEPH_F_ATEND;  in ceph_dir_llseek()
1941 	struct ceph_dir_file_info *dfi = file->private_data;  in ceph_read_dir()  local
1950 	if (!dfi->dir_info) {  in ceph_read_dir()
1951 		dfi->dir_info = kmalloc(bufsize, GFP_KERNEL);  in ceph_read_dir()
1952 		if (!dfi->dir_info)  in ceph_read_dir()
1954 		dfi->dir_info_len =  in ceph_read_dir()
1955 			snprintf(dfi->dir_info, bufsize,  in ceph_read_dir()
1975 	if (*ppos >= dfi->dir_info_len)  in ceph_read_dir()
1977 	size = min_t(unsigned, size, dfi->dir_info_len-*ppos);  in ceph_read_dir()
1978 	left = copy_to_user(buf, dfi->dir_info + *ppos, size);  in ceph_read_dir()