104 static int note_last_dentry(struct ceph_dir_file_info *dfi, const char *name,  in note_last_dentry()  argument
110 	kfree(dfi->last_name);  in note_last_dentry()
111 	dfi->last_name = buf;  in note_last_dentry()
112 	memcpy(dfi->last_name, name, len);  in note_last_dentry()
113 	dfi->last_name[len] = 0;  in note_last_dentry()
114 	dfi->next_offset = next_offset;  in note_last_dentry()
115 	dout("note_last_dentry '%s'\n", dfi->last_name);  in note_last_dentry()
177 	struct ceph_dir_file_info *dfi = file->private_data;  in __dcache_readdir()  local
224 			dfi->file_info.flags |= CEPH_F_ATEND;  in __dcache_readdir()
275 		ret = note_last_dentry(dfi, last->d_name.name, last->d_name.len,  in __dcache_readdir()
281 		if (dfi->readdir_cache_idx >= 0) {  in __dcache_readdir()
282 			dfi->readdir_cache_idx = -1;  in __dcache_readdir()
283 			dfi->dir_release_count = 0;  in __dcache_readdir()
289 static bool need_send_readdir(struct ceph_dir_file_info *dfi, loff_t pos)  in need_send_readdir()  argument
291 	if (!dfi->last_readdir)  in need_send_readdir()
294 		return !ceph_frag_contains_value(dfi->frag, fpos_hash(pos));  in need_send_readdir()
296 		return dfi->frag != fpos_frag(pos);  in need_send_readdir()
301 	struct ceph_dir_file_info *dfi = file->private_data;  in ceph_readdir()  local
312 	if (dfi->file_info.flags & CEPH_F_ATEND)  in ceph_readdir()
353 	if (need_send_readdir(dfi, ctx->pos)) {  in ceph_readdir()
359 		if (dfi->last_readdir) {  in ceph_readdir()
360 			ceph_mdsc_put_request(dfi->last_readdir);  in ceph_readdir()
361 			dfi->last_readdir = NULL;  in ceph_readdir()
375 		     ceph_vinop(inode), frag, dfi->last_name);  in ceph_readdir()
391 		if (dfi->last_name) {  in ceph_readdir()
392 			req->r_path2 = kstrdup(dfi->last_name, GFP_KERNEL);  in ceph_readdir()
402 		req->r_dir_release_cnt = dfi->dir_release_count;  in ceph_readdir()
403 		req->r_dir_ordered_cnt = dfi->dir_ordered_count;  in ceph_readdir()
404 		req->r_readdir_cache_idx = dfi->readdir_cache_idx;  in ceph_readdir()
405 		req->r_readdir_offset = dfi->next_offset;  in ceph_readdir()
429 				dfi->next_offset = req->r_readdir_offset;  in ceph_readdir()
432 							  dfi->next_offset,  in ceph_readdir()
437 		dfi->frag = frag;  in ceph_readdir()
438 		dfi->last_readdir = req;  in ceph_readdir()
441 			dfi->readdir_cache_idx = req->r_readdir_cache_idx;  in ceph_readdir()
442 			if (dfi->readdir_cache_idx < 0) {  in ceph_readdir()
444 				dfi->dir_ordered_count = 0;  in ceph_readdir()
446 				   dfi->next_offset == 2) {  in ceph_readdir()
449 				dfi->dir_release_count = req->r_dir_release_cnt;  in ceph_readdir()
450 				dfi->dir_ordered_count = req->r_dir_ordered_cnt;  in ceph_readdir()
455 			dfi->readdir_cache_idx = -1;  in ceph_readdir()
457 			dfi->dir_release_count = 0;  in ceph_readdir()
466 			err = note_last_dentry(dfi, rde->name, rde->name_len,  in ceph_readdir()
471 			dfi->next_offset = 2;  in ceph_readdir()
476 	rinfo = &dfi->last_readdir->r_reply_info;  in ceph_readdir()
478 	     dfi->frag, rinfo->dir_nr, ctx->pos,  in ceph_readdir()
522 	ceph_mdsc_put_request(dfi->last_readdir);  in ceph_readdir()
523 	dfi->last_readdir = NULL;  in ceph_readdir()
525 	if (dfi->next_offset > 2) {  in ceph_readdir()
526 		frag = dfi->frag;  in ceph_readdir()
531 	if (!ceph_frag_is_rightmost(dfi->frag)) {  in ceph_readdir()
532 		frag = ceph_frag_next(dfi->frag);  in ceph_readdir()
535 							dfi->next_offset, true);  in ceph_readdir()
540 			ctx->pos = ceph_make_fpos(frag, dfi->next_offset,  in ceph_readdir()
542 			kfree(dfi->last_name);  in ceph_readdir()
543 			dfi->last_name = NULL;  in ceph_readdir()
548 	dfi->file_info.flags |= CEPH_F_ATEND;  in ceph_readdir()
556 					dfi->dir_release_count) {  in ceph_readdir()
558 		if (dfi->dir_ordered_count ==  in ceph_readdir()
563 			BUG_ON(dfi->readdir_cache_idx < 0);  in ceph_readdir()
564 			i_size_write(inode, dfi->readdir_cache_idx *  in ceph_readdir()
569 		__ceph_dir_set_complete(ci, dfi->dir_release_count,  in ceph_readdir()
570 					dfi->dir_ordered_count);  in ceph_readdir()
578 static void reset_readdir(struct ceph_dir_file_info *dfi)  in reset_readdir()  argument
580 	if (dfi->last_readdir) {  in reset_readdir()
581 		ceph_mdsc_put_request(dfi->last_readdir);  in reset_readdir()
582 		dfi->last_readdir = NULL;  in reset_readdir()
584 	kfree(dfi->last_name);  in reset_readdir()
585 	dfi->last_name = NULL;  in reset_readdir()
586 	dfi->dir_release_count = 0;  in reset_readdir()
587 	dfi->readdir_cache_idx = -1;  in reset_readdir()
588 	dfi->next_offset = 2;  /* compensate for . and .. */  in reset_readdir()
589 	dfi->file_info.flags &= ~CEPH_F_ATEND;  in reset_readdir()
596 static bool need_reset_readdir(struct ceph_dir_file_info *dfi, loff_t new_pos)  in need_reset_readdir()  argument
605 	} else if (dfi->frag != fpos_frag(new_pos)) {  in need_reset_readdir()
608 	rinfo = dfi->last_readdir ? &dfi->last_readdir->r_reply_info : NULL;  in need_reset_readdir()
618 	struct ceph_dir_file_info *dfi = file->private_data;  in ceph_dir_llseek()  local
636 		if (need_reset_readdir(dfi, offset)) {  in ceph_dir_llseek()
638 			reset_readdir(dfi);  in ceph_dir_llseek()
642 			dfi->dir_release_count = 0;  in ceph_dir_llseek()
643 			dfi->readdir_cache_idx = -1;  in ceph_dir_llseek()
649 			dfi->file_info.flags &= ~CEPH_F_ATEND;  in ceph_dir_llseek()
1378 	struct ceph_dir_file_info *dfi = file->private_data;  in ceph_read_dir()  local
1387 	if (!dfi->dir_info) {  in ceph_read_dir()
1388 		dfi->dir_info = kmalloc(bufsize, GFP_KERNEL);  in ceph_read_dir()
1389 		if (!dfi->dir_info)  in ceph_read_dir()
1391 		dfi->dir_info_len =  in ceph_read_dir()
1392 			snprintf(dfi->dir_info, bufsize,  in ceph_read_dir()
1412 	if (*ppos >= dfi->dir_info_len)  in ceph_read_dir()
1414 	size = min_t(unsigned, size, dfi->dir_info_len-*ppos);  in ceph_read_dir()
1415 	left = copy_to_user(buf, dfi->dir_info + *ppos, size);  in ceph_read_dir()