diff options
| -rwxr-xr-x | libglusterfsclient/src/libglusterfsclient-internals.h | 1 | ||||
| -rwxr-xr-x | libglusterfsclient/src/libglusterfsclient.c | 13 |
2 files changed, 10 insertions, 4 deletions
diff --git a/libglusterfsclient/src/libglusterfsclient-internals.h b/libglusterfsclient/src/libglusterfsclient-internals.h index d55cfb1f5f6..9b14dcb9153 100755 --- a/libglusterfsclient/src/libglusterfsclient-internals.h +++ b/libglusterfsclient/src/libglusterfsclient-internals.h @@ -131,6 +131,7 @@ typedef struct libglusterfs_client_async_local { struct { fd_t *fd; glusterfs_readv_cbk_t cbk; + char update_offset; }readv_cbk; struct { diff --git a/libglusterfsclient/src/libglusterfsclient.c b/libglusterfsclient/src/libglusterfsclient.c index 107d8dbc590..36189aaa1b9 100755 --- a/libglusterfsclient/src/libglusterfsclient.c +++ b/libglusterfsclient/src/libglusterfsclient.c @@ -3709,11 +3709,15 @@ libglusterfs_readv_async_cbk (call_frame_t *frame, if (op_ret > 0) { libglusterfs_client_fd_ctx_t *fd_ctx = NULL; fd_ctx = libgf_get_fd_ctx (__fd); - pthread_mutex_lock (&fd_ctx->lock); - { - fd_ctx->offset += op_ret; + + /* update offset only if we have used offset stored in fd_ctx */ + if (local->fop.readv_cbk.update_offset) { + pthread_mutex_lock (&fd_ctx->lock); + { + fd_ctx->offset += op_ret; + } + pthread_mutex_unlock (&fd_ctx->lock); } - pthread_mutex_unlock (&fd_ctx->lock); } readv_cbk (op_ret, op_errno, buf, local->cbk_data); @@ -3780,6 +3784,7 @@ glusterfs_read_async (glusterfs_file_t fd, pthread_mutex_lock (&fd_ctx->lock); { offset = fd_ctx->offset; + local->fop.readv_cbk.update_offset = 1; } pthread_mutex_unlock (&fd_ctx->lock); } |