andy/glusterfs
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

performance/stat-prefetch: implement sp_rmdir.

Browse Source 
Signed-off-by: Anand V. Avati <avati@dev.gluster.com>

BUG: 221 (stat prefetch implementation)
URL: http://bugs.gluster.com/cgi-bin/bugzilla3/show_bug.cgi?id=221
This commit is contained in:
Raghavendra G 2009-08-23 22:31:53 +00:00 committed by Anand V. Avati
parent 29c282b160
commit 1a2db6ed79
2 changed files with 57 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
doc/stat-prefetch-design.txt
View File

@ -66,6 +66,8 @@ fops to be implemented:
fds opened on parent inode.
2. Remove the entire cache from all fds opened on inode corresponding to
directory being removed.
3. Delete the entry correspondig to basename of parent from cache stored in
grand-parent.
* readv
Delete the entry corresponding to basename from cache stored in context of fds

55
xlators/performance/stat-prefetch/src/stat-prefetch.c
View File

@ -1216,6 +1216,60 @@ unwind:
}
void
sp_remove_caches_from_all_fds_opened (xlator_t *this, inode_t *inode)
{
fd_t *fd = NULL;
sp_cache_t *cache = NULL;
LOCK (&inode->lock);
{
list_for_each_entry (fd, &inode->fd_list, inode_list) {
cache = sp_get_cache_fd (this, fd);
if (cache) {
sp_cache_remove_entry (cache, NULL, 1);
}
}
}
UNLOCK (&inode->lock);
}
int32_t
sp_rmdir (call_frame_t *frame, xlator_t *this, loc_t *loc)
{
sp_cache_t *cache = NULL;
int32_t ret = -1;
GF_VALIDATE_OR_GOTO (this->name, loc, unwind);
GF_VALIDATE_OR_GOTO (this->name, loc->name, unwind);
GF_VALIDATE_OR_GOTO (this->name, loc->path, unwind);
GF_VALIDATE_OR_GOTO (this->name, loc->inode, unwind);
GF_VALIDATE_OR_GOTO (this->name, loc->parent, unwind);
sp_remove_caches_from_all_fds_opened (this, loc->inode);
cache = sp_get_cache_inode (this, loc->parent, frame->root->pid);
if (cache) {
sp_cache_remove_entry (cache, (char *)loc->name, 0);
}
ret = sp_cache_remove_parent_entry (frame, this, (char *)loc->path);
if (ret == -1) {
gf_log (this->name, GF_LOG_ERROR, "out of memory");
goto unwind;
}
STACK_WIND (frame, sp_err_cbk, FIRST_CHILD(this),
FIRST_CHILD(this)->fops->rmdir, loc);
return 0;
unwind:
STACK_UNWIND (frame, -1, errno);
return 0;
}
int32_t
sp_forget (xlator_t *this, inode_t *inode)
{
@ -1276,6 +1330,7 @@ struct xlator_fops fops = {
.utimens = sp_utimens,
.readlink = sp_readlink,
.unlink = sp_unlink,
.rmdir = sp_rmdir,
};
struct xlator_mops mops = {