summaryrefslogtreecommitdiffstats
path: root/xlators/performance/io-threads
diff options
context:
space:
mode:
authorShehjar Tikoo <shehjart@gluster.com>2009-10-01 06:59:00 +0000
committerAnand V. Avati <avati@dev.gluster.com>2009-10-01 07:23:35 -0700
commit7c1bdb3aad6063f69338d92490cd4d11d4d578f1 (patch)
tree97c49d292fde9ffeced3d0b399a1d40c6a667e1f /xlators/performance/io-threads
parent1e0b3920dc0bcb8d15586adceacacedba75b17ab (diff)
io-threads: NFS-friendly logic changes
Signed-off-by: Anand V. Avati <avati@dev.gluster.com> BUG: 145 (NFSv3 related additions to 2.1 task list) URL: http://bugs.gluster.com/cgi-bin/bugzilla3/show_bug.cgi?id=145
Diffstat (limited to 'xlators/performance/io-threads')
-rw-r--r--xlators/performance/io-threads/src/io-threads.c56
1 files changed, 31 insertions, 25 deletions
diff --git a/xlators/performance/io-threads/src/io-threads.c b/xlators/performance/io-threads/src/io-threads.c
index 3a7504f32..a5cbea739 100644
--- a/xlators/performance/io-threads/src/io-threads.c
+++ b/xlators/performance/io-threads/src/io-threads.c
@@ -319,7 +319,7 @@ iot_lookup_cbk (call_frame_t *frame, void * cookie, xlator_t *this,
inode_t *inode, struct stat *buf, dict_t *xattr,
struct stat *postparent)
{
- STACK_UNWIND (frame, op_ret, op_errno, inode, buf, xattr);
+ STACK_UNWIND (frame, op_ret, op_errno, inode, buf, xattr, postparent);
return 0;
}
@@ -358,7 +358,7 @@ out:
if (stub != NULL) {
call_stub_destroy (stub);
}
- STACK_UNWIND (frame, -1, -ret, NULL, NULL, NULL);
+ STACK_UNWIND (frame, -1, -ret, NULL, NULL, NULL, NULL);
}
return 0;
@@ -518,9 +518,9 @@ out:
int
iot_readlink_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
int32_t op_ret, int32_t op_errno, const char *path,
- struct stat *sbuf)
+ struct stat *stbuf)
{
- STACK_UNWIND (frame, op_ret, op_errno, path);
+ STACK_UNWIND (frame, op_ret, op_errno, path, stbuf);
return 0;
}
@@ -556,7 +556,7 @@ iot_readlink (call_frame_t *frame, xlator_t *this, loc_t *loc, size_t size)
out:
if (ret < 0) {
- STACK_UNWIND (frame, -1, -ret, NULL);
+ STACK_UNWIND (frame, -1, -ret, NULL, NULL);
if (stub != NULL) {
call_stub_destroy (stub);
@@ -573,7 +573,8 @@ iot_mknod_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
struct stat *buf, struct stat *preparent,
struct stat *postparent)
{
- STACK_UNWIND (frame, op_ret, op_errno, inode, buf);
+ STACK_UNWIND (frame, op_ret, op_errno, inode, buf, preparent,
+ postparent);
return 0;
}
@@ -608,7 +609,7 @@ iot_mknod (call_frame_t *frame, xlator_t *this, loc_t *loc, mode_t mode,
out:
if (ret < 0) {
- STACK_UNWIND (frame, -1, -ret, NULL, NULL);
+ STACK_UNWIND (frame, -1, -ret, NULL, NULL, NULL, NULL);
if (stub != NULL) {
call_stub_destroy (stub);
@@ -624,7 +625,8 @@ iot_mkdir_cbk (call_frame_t *frame, void * cookie, xlator_t *this,
struct stat *buf, struct stat *preparent,
struct stat *postparent)
{
- STACK_UNWIND (frame, op_ret, op_errno, inode, buf);
+ STACK_UNWIND (frame, op_ret, op_errno, inode, buf, preparent,
+ postparent);
return 0;
}
@@ -657,7 +659,7 @@ iot_mkdir (call_frame_t *frame, xlator_t *this, loc_t *loc, mode_t mode)
out:
if (ret < 0) {
- STACK_UNWIND (frame, -1, -ret, NULL, NULL);
+ STACK_UNWIND (frame, -1, -ret, NULL, NULL, NULL, NULL);
if (stub != NULL) {
call_stub_destroy (stub);
@@ -672,7 +674,7 @@ iot_rmdir_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
int32_t op_ret, int32_t op_errno, struct stat *preparent,
struct stat *postparent)
{
- STACK_UNWIND (frame, op_ret, op_errno);
+ STACK_UNWIND (frame, op_ret, op_errno, preparent, postparent);
return 0;
}
@@ -704,7 +706,7 @@ iot_rmdir (call_frame_t *frame, xlator_t *this, loc_t *loc)
stub);
out:
if (ret < 0) {
- STACK_UNWIND (frame, -1, -ret);
+ STACK_UNWIND (frame, -1, -ret, NULL, NULL);
if (stub != NULL) {
call_stub_destroy (stub);
@@ -720,7 +722,8 @@ iot_symlink_cbk (call_frame_t *frame, void * cookie, xlator_t *this,
struct stat *buf, struct stat *preparent,
struct stat *postparent)
{
- STACK_UNWIND (frame, op_ret, op_errno, inode, buf);
+ STACK_UNWIND (frame, op_ret, op_errno, inode, buf, preparent,
+ postparent);
return 0;
}
@@ -755,7 +758,7 @@ iot_symlink (call_frame_t *frame, xlator_t *this, const char *linkname,
out:
if (ret < 0) {
- STACK_UNWIND (frame, -1, -ret, NULL, NULL);
+ STACK_UNWIND (frame, -1, -ret, NULL, NULL, NULL, NULL);
if (stub != NULL) {
call_stub_destroy (stub);
@@ -772,7 +775,8 @@ iot_rename_cbk (call_frame_t *frame, void * cookie, xlator_t *this,
struct stat *preoldparent, struct stat *postoldparent,
struct stat *prenewparent, struct stat *postnewparent)
{
- STACK_UNWIND (frame, op_ret, op_errno, buf);
+ STACK_UNWIND (frame, op_ret, op_errno, buf,
+ preoldparent, postoldparent, prenewparent, postnewparent);
return 0;
}
@@ -806,7 +810,7 @@ iot_rename (call_frame_t *frame, xlator_t *this, loc_t *oldloc, loc_t *newloc)
out:
if (ret < 0) {
- STACK_UNWIND (frame, -1, -ret, NULL);
+ STACK_UNWIND (frame, -1, -ret, NULL, NULL, NULL, NULL, NULL);
if (stub != NULL) {
call_stub_destroy (stub);
@@ -874,7 +878,8 @@ iot_create_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
struct stat *stbuf, struct stat *preparent,
struct stat *postparent)
{
- STACK_UNWIND (frame, op_ret, op_errno, fd, inode, stbuf);
+ STACK_UNWIND (frame, op_ret, op_errno, fd, inode, stbuf, preparent,
+ postparent);
return 0;
}
@@ -913,7 +918,7 @@ iot_create (call_frame_t *frame, xlator_t *this, loc_t *loc, int32_t flags,
out:
if (ret < 0) {
- STACK_UNWIND (frame, -1, -ret, NULL, 0);
+ STACK_UNWIND (frame, -1, -ret, NULL, NULL, NULL, NULL, NULL);
if (stub != NULL) {
call_stub_destroy (stub);
@@ -968,7 +973,7 @@ iot_readv (call_frame_t *frame, xlator_t *this, fd_t *fd, size_t size,
out:
if (ret < 0) {
- STACK_UNWIND (frame, -1, -ret, NULL, 0);
+ STACK_UNWIND (frame, -1, -ret, NULL, -1, NULL, NULL);
if (stub != NULL) {
call_stub_destroy (stub);
@@ -1125,7 +1130,7 @@ iot_writev (call_frame_t *frame, xlator_t *this, fd_t *fd,
stub);
out:
if (ret < 0) {
- STACK_UNWIND (frame, -1, -ret, NULL);
+ STACK_UNWIND (frame, -1, -ret, NULL, NULL);
if (stub != NULL) {
call_stub_destroy (stub);
@@ -1348,7 +1353,7 @@ iot_truncate (call_frame_t *frame, xlator_t *this, loc_t *loc, off_t offset)
out:
if (ret < 0) {
- STACK_UNWIND (frame, -1, -ret, NULL);
+ STACK_UNWIND (frame, -1, -ret, NULL, NULL);
if (stub != NULL) {
call_stub_destroy (stub);
@@ -1399,7 +1404,7 @@ iot_ftruncate (call_frame_t *frame, xlator_t *this, fd_t *fd, off_t offset)
stub);
out:
if (ret < 0) {
- STACK_UNWIND (frame, -1, -ret, NULL);
+ STACK_UNWIND (frame, -1, -ret, NULL, NULL);
if (stub != NULL) {
call_stub_destroy (stub);
@@ -1466,7 +1471,7 @@ iot_unlink_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
int32_t op_ret, int32_t op_errno, struct stat *preparent,
struct stat *postparent)
{
- STACK_UNWIND (frame, op_ret, op_errno);
+ STACK_UNWIND (frame, op_ret, op_errno, preparent, postparent);
return 0;
}
@@ -1503,7 +1508,7 @@ iot_unlink (call_frame_t *frame, xlator_t *this, loc_t *loc)
out:
if (ret < 0) {
- STACK_UNWIND (frame, -1, -ret);
+ STACK_UNWIND (frame, -1, -ret, NULL, NULL);
if (stub != NULL) {
call_stub_destroy (stub);
@@ -1519,7 +1524,8 @@ iot_link_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
int32_t op_ret, int32_t op_errno, inode_t *inode,
struct stat *buf, struct stat *preparent, struct stat *postparent)
{
- STACK_UNWIND (frame, op_ret, op_errno, inode, buf);
+ STACK_UNWIND (frame, op_ret, op_errno, inode, buf, preparent,
+ postparent);
return 0;
}
@@ -1552,7 +1558,7 @@ iot_link (call_frame_t *frame, xlator_t *this, loc_t *oldloc, loc_t *newloc)
oldloc->inode, stub);
out:
if (ret < 0) {
- STACK_UNWIND (frame, -1, -ret, NULL, NULL);
+ STACK_UNWIND (frame, -1, -ret, NULL, NULL, NULL, NULL);
if (stub != NULL) {
call_stub_destroy (stub);