io-threads: Wire in support for rmdir fop
Signed-off-by: Anand V. Avati <avati@amp.gluster.com>
This commit is contained in:
parent
21363da293
commit
6afeb9dd1b
@ -442,6 +442,45 @@ iot_mkdir (call_frame_t *frame,
|
||||
return 0;
|
||||
}
|
||||
|
||||
int32_t
|
||||
iot_rmdir_cbk (call_frame_t *frame,
|
||||
void * cookie,
|
||||
xlator_t *this,
|
||||
int32_t op_ret,
|
||||
int32_t op_errno)
|
||||
{
|
||||
STACK_UNWIND (frame, op_ret, op_errno);
|
||||
return 0;
|
||||
}
|
||||
|
||||
int32_t
|
||||
iot_rmdir_wrapper (call_frame_t *frame,
|
||||
xlator_t *this,
|
||||
loc_t *loc)
|
||||
{
|
||||
STACK_WIND (frame, iot_rmdir_cbk, FIRST_CHILD (this),
|
||||
FIRST_CHILD (this)->fops->rmdir, loc);
|
||||
return 0;
|
||||
}
|
||||
|
||||
int32_t
|
||||
iot_rmdir (call_frame_t *frame,
|
||||
xlator_t *this,
|
||||
loc_t *loc)
|
||||
{
|
||||
call_stub_t *stub = NULL;
|
||||
|
||||
stub = fop_rmdir_stub (frame, iot_rmdir_wrapper, loc);
|
||||
if (!stub) {
|
||||
gf_log (this->name, GF_LOG_ERROR, "cannot get rmdir stub");
|
||||
STACK_UNWIND (frame, -1, ENOMEM);
|
||||
return 0;
|
||||
}
|
||||
|
||||
iot_schedule ((iot_conf_t *)this->private, loc->inode, stub);
|
||||
return 0;
|
||||
}
|
||||
|
||||
int32_t
|
||||
iot_open_cbk (call_frame_t *frame,
|
||||
void *cookie,
|
||||
@ -1359,6 +1398,7 @@ struct xlator_fops fops = {
|
||||
.readlink = iot_readlink,
|
||||
.mknod = iot_mknod,
|
||||
.mkdir = iot_mkdir,
|
||||
.rmdir = iot_rmdir,
|
||||
};
|
||||
|
||||
struct xlator_mops mops = {
|
||||
|
Loading…
Reference in New Issue
Block a user