Lines Matching full:dfi
113 struct ceph_dir_file_info *dfi, in note_last_dentry() argument
120 kfree(dfi->last_name); in note_last_dentry()
121 dfi->last_name = buf; in note_last_dentry()
122 memcpy(dfi->last_name, name, len); in note_last_dentry()
123 dfi->last_name[len] = 0; in note_last_dentry()
124 dfi->next_offset = next_offset; in note_last_dentry()
125 doutc(fsc->client, "'%s'\n", dfi->last_name); in note_last_dentry()
189 struct ceph_dir_file_info *dfi = file->private_data; in __dcache_readdir() local
240 dfi->file_info.flags |= CEPH_F_ATEND; in __dcache_readdir()
292 ret = note_last_dentry(fsc, dfi, last->d_name.name, in __dcache_readdir()
299 if (dfi->readdir_cache_idx >= 0) { in __dcache_readdir()
300 dfi->readdir_cache_idx = -1; in __dcache_readdir()
301 dfi->dir_release_count = 0; in __dcache_readdir()
307 static bool need_send_readdir(struct ceph_dir_file_info *dfi, loff_t pos) in need_send_readdir() argument
309 if (!dfi->last_readdir) in need_send_readdir()
312 return !ceph_frag_contains_value(dfi->frag, fpos_hash(pos)); in need_send_readdir()
314 return dfi->frag != fpos_frag(pos); in need_send_readdir()
319 struct ceph_dir_file_info *dfi = file->private_data; in ceph_readdir() local
332 if (dfi->file_info.flags & CEPH_F_ATEND) in ceph_readdir()
386 if (need_send_readdir(dfi, ctx->pos)) { in ceph_readdir()
392 if (dfi->last_readdir) { in ceph_readdir()
393 ceph_mdsc_put_request(dfi->last_readdir); in ceph_readdir()
394 dfi->last_readdir = NULL; in ceph_readdir()
408 inode, ceph_vinop(inode), frag, dfi->last_name); in ceph_readdir()
425 if (dfi->last_name) { in ceph_readdir()
426 struct qstr d_name = { .name = dfi->last_name, in ceph_readdir()
427 .len = strlen(dfi->last_name) }; in ceph_readdir()
446 req->r_dir_release_cnt = dfi->dir_release_count; in ceph_readdir()
447 req->r_dir_ordered_cnt = dfi->dir_ordered_count; in ceph_readdir()
448 req->r_readdir_cache_idx = dfi->readdir_cache_idx; in ceph_readdir()
449 req->r_readdir_offset = dfi->next_offset; in ceph_readdir()
473 dfi->next_offset = req->r_readdir_offset; in ceph_readdir()
476 dfi->next_offset, in ceph_readdir()
481 dfi->frag = frag; in ceph_readdir()
482 dfi->last_readdir = req; in ceph_readdir()
485 dfi->readdir_cache_idx = req->r_readdir_cache_idx; in ceph_readdir()
486 if (dfi->readdir_cache_idx < 0) { in ceph_readdir()
488 dfi->dir_ordered_count = 0; in ceph_readdir()
490 dfi->next_offset == 2) { in ceph_readdir()
493 dfi->dir_release_count = req->r_dir_release_cnt; in ceph_readdir()
494 dfi->dir_ordered_count = req->r_dir_ordered_cnt; in ceph_readdir()
500 dfi->readdir_cache_idx = -1; in ceph_readdir()
502 dfi->dir_release_count = 0; in ceph_readdir()
511 err = note_last_dentry(fsc, dfi, rde->name, in ceph_readdir()
514 ceph_mdsc_put_request(dfi->last_readdir); in ceph_readdir()
515 dfi->last_readdir = NULL; in ceph_readdir()
519 dfi->next_offset = 2; in ceph_readdir()
524 rinfo = &dfi->last_readdir->r_reply_info; in ceph_readdir()
526 inode, ceph_vinop(inode), dfi->frag, rinfo->dir_nr, ctx->pos, in ceph_readdir()
565 * NOTE: Here no need to put the 'dfi->last_readdir', in ceph_readdir()
578 ceph_mdsc_put_request(dfi->last_readdir); in ceph_readdir()
579 dfi->last_readdir = NULL; in ceph_readdir()
581 if (dfi->next_offset > 2) { in ceph_readdir()
582 frag = dfi->frag; in ceph_readdir()
587 if (!ceph_frag_is_rightmost(dfi->frag)) { in ceph_readdir()
588 frag = ceph_frag_next(dfi->frag); in ceph_readdir()
591 dfi->next_offset, true); in ceph_readdir()
596 ctx->pos = ceph_make_fpos(frag, dfi->next_offset, in ceph_readdir()
598 kfree(dfi->last_name); in ceph_readdir()
599 dfi->last_name = NULL; in ceph_readdir()
605 dfi->file_info.flags |= CEPH_F_ATEND; in ceph_readdir()
613 dfi->dir_release_count) { in ceph_readdir()
615 if (dfi->dir_ordered_count == in ceph_readdir()
621 BUG_ON(dfi->readdir_cache_idx < 0); in ceph_readdir()
622 i_size_write(inode, dfi->readdir_cache_idx * in ceph_readdir()
628 __ceph_dir_set_complete(ci, dfi->dir_release_count, in ceph_readdir()
629 dfi->dir_ordered_count); in ceph_readdir()
637 static void reset_readdir(struct ceph_dir_file_info *dfi) in reset_readdir() argument
639 if (dfi->last_readdir) { in reset_readdir()
640 ceph_mdsc_put_request(dfi->last_readdir); in reset_readdir()
641 dfi->last_readdir = NULL; in reset_readdir()
643 kfree(dfi->last_name); in reset_readdir()
644 dfi->last_name = NULL; in reset_readdir()
645 dfi->dir_release_count = 0; in reset_readdir()
646 dfi->readdir_cache_idx = -1; in reset_readdir()
647 dfi->next_offset = 2; /* compensate for . and .. */ in reset_readdir()
648 dfi->file_info.flags &= ~CEPH_F_ATEND; in reset_readdir()
655 static bool need_reset_readdir(struct ceph_dir_file_info *dfi, loff_t new_pos) in need_reset_readdir() argument
664 } else if (dfi->frag != fpos_frag(new_pos)) { in need_reset_readdir()
667 rinfo = dfi->last_readdir ? &dfi->last_readdir->r_reply_info : NULL; in need_reset_readdir()
677 struct ceph_dir_file_info *dfi = file->private_data; in ceph_dir_llseek() local
698 if (need_reset_readdir(dfi, offset)) { in ceph_dir_llseek()
701 reset_readdir(dfi); in ceph_dir_llseek()
705 dfi->dir_release_count = 0; in ceph_dir_llseek()
706 dfi->readdir_cache_idx = -1; in ceph_dir_llseek()
711 dfi->file_info.flags &= ~CEPH_F_ATEND; in ceph_dir_llseek()
2141 struct ceph_dir_file_info *dfi = file->private_data; in ceph_read_dir() local
2150 if (!dfi->dir_info) { in ceph_read_dir()
2151 dfi->dir_info = kmalloc(bufsize, GFP_KERNEL); in ceph_read_dir()
2152 if (!dfi->dir_info) in ceph_read_dir()
2154 dfi->dir_info_len = in ceph_read_dir()
2155 snprintf(dfi->dir_info, bufsize, in ceph_read_dir()
2175 if (*ppos >= dfi->dir_info_len) in ceph_read_dir()
2177 size = min_t(unsigned, size, dfi->dir_info_len-*ppos); in ceph_read_dir()
2178 left = copy_to_user(buf, dfi->dir_info + *ppos, size); in ceph_read_dir()