summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorRaghavendra G <raghavendra@gluster.com>2011-07-15 05:12:52 +0000
committerAnand Avati <avati@gluster.com>2011-07-29 01:26:32 -0700
commita31fe944e714f75dcd0f6d58d0776c1139548383 (patch)
tree0fec0956aa76fba3f4c319e02801f5d3d43f49f7
parent412a951dc6b575e89e497a8588426257018e284e (diff)
performance/quick-read: propagate errors during open back to actual fops.
- If open fails and there are any other fops waiting on that open, those fops should also unwind with appropriate errors. Before this patch, irrespective of success/failure of open, fops waiting on it were stack_wound and since fd was invalid, they would fail with EBADFD errors. Due to this actual error would've got masked by EBADFD. Change-Id: I65f88a681ea573a964fae132073696d32701882f BUG: 2346 Reviewed-on: http://review.gluster.com/49 Tested-by: Gluster Build System <jenkins@build.gluster.com> Reviewed-by: Anand Avati <avati@gluster.com>
Diffstat
-rw-r--r--xlators/performance/quick-read/src/quick-read-mem-types.h34
-rw-r--r--xlators/performance/quick-read/src/quick-read.c1181
-rw-r--r--xlators/performance/quick-read/src/quick-read.h12
3 files changed, 867 insertions, 360 deletions
diff --git a/xlators/performance/quick-read/src/quick-read-mem-types.h b/xlators/performance/quick-read/src/quick-read-mem-types.h
index 32591125fe0..972fdb0d8c1 100644
--- a/xlators/performance/quick-read/src/quick-read-mem-types.h
+++ b/xlators/performance/quick-read/src/quick-read-mem-types.h
@@ -1,23 +1,22 @@
/*
- Copyright (c) 2008-2010 Gluster, Inc. <http://www.gluster.com>
- This file is part of GlusterFS.
-
- GlusterFS is free software; you can redistribute it and/or modify
- it under the terms of the GNU Affero General Public License as published
- by the Free Software Foundation; either version 3 of the License,
- or (at your option) any later version.
-
- GlusterFS is distributed in the hope that it will be useful, but
- WITHOUT ANY WARRANTY; without even the implied warranty of
- MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
- Affero General Public License for more details.
-
- You should have received a copy of the GNU Affero General Public License
- along with this program. If not, see
- <http://www.gnu.org/licenses/>.
+ Copyright (c) 2008-2010 Gluster, Inc. <http://www.gluster.com>
+ This file is part of GlusterFS.
+
+ GlusterFS is free software; you can redistribute it and/or modify
+ it under the terms of the GNU Affero General Public License as published
+ by the Free Software Foundation; either version 3 of the License,
+ or (at your option) any later version.
+
+ GlusterFS is distributed in the hope that it will be useful, but
+ WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ Affero General Public License for more details.
+
+ You should have received a copy of the GNU Affero General Public License
+ along with this program. If not, see
+ <http://www.gnu.org/licenses/>.
*/
-
#ifndef __QR_MEM_TYPES_H__
#define __QR_MEM_TYPES_H__
@@ -34,4 +33,3 @@ enum gf_qr_mem_types_ {
gf_qr_mt_end
};
#endif
-
diff --git a/xlators/performance/quick-read/src/quick-read.c b/xlators/performance/quick-read/src/quick-read.c
index 6bcfb4466ee..b97888f13cf 100644
--- a/xlators/performance/quick-read/src/quick-read.c
+++ b/xlators/performance/quick-read/src/quick-read.c
@@ -81,7 +81,7 @@ out:
static int32_t
qr_loc_fill (loc_t *loc, inode_t *inode, char *path)
{
- int32_t ret = -1;
+ int32_t ret = -1;
char *parent = NULL;
if ((loc == NULL) || (inode == NULL) || (path == NULL)
@@ -126,10 +126,10 @@ out:
void
-qr_resume_pending_ops (qr_fd_ctx_t *qr_fd_ctx)
+qr_resume_pending_ops (qr_fd_ctx_t *qr_fd_ctx, int32_t op_ret, int32_t op_errno)
{
- struct list_head waiting_ops;
- call_stub_t *stub = NULL, *tmp = NULL;
+ call_stub_t *stub = NULL, *tmp = NULL;
+ struct list_head waiting_ops = {0, };
if (qr_fd_ctx == NULL) {
goto out;
@@ -148,6 +148,14 @@ qr_resume_pending_ops (qr_fd_ctx_t *qr_fd_ctx)
if (!list_empty (&waiting_ops)) {
list_for_each_entry_safe (stub, tmp, &waiting_ops, list) {
list_del_init (&stub->list);
+ if (op_ret < 0) {
+ qr_local_t *local = NULL;
+
+ local = stub->frame->local;
+ local->op_ret = op_ret;
+ local->op_errno = op_errno;
+ }
+
call_resume (stub);
}
}
@@ -176,25 +184,25 @@ out:
static inline uint32_t
is_match (const char *path, const char *pattern)
{
- int32_t ret = 0;
+ int32_t ret = 0;
- ret = fnmatch (pattern, path, FNM_NOESCAPE);
+ ret = fnmatch (pattern, path, FNM_NOESCAPE);
- return (ret == 0);
+ return (ret == 0);
}
uint32_t
qr_get_priority (qr_conf_t *conf, const char *path)
{
- uint32_t priority = 0;
- struct qr_priority *curr = NULL;
+ uint32_t priority = 0;
+ struct qr_priority *curr = NULL;
list_for_each_entry (curr, &conf->priority_list, list) {
if (is_match (path, curr->pattern))
priority = curr->priority;
}
- return priority;
+ return priority;
}
@@ -202,7 +210,7 @@ qr_get_priority (qr_conf_t *conf, const char *path)
qr_inode_t *
__qr_inode_alloc (xlator_t *this, char *path, inode_t *inode)
{
- qr_inode_t *qr_inode = NULL;
+ qr_inode_t *qr_inode = NULL;
qr_private_t *priv = NULL;
int priority = 0;
@@ -250,13 +258,13 @@ out:
void
__qr_cache_prune (xlator_t *this)
{
- qr_private_t *priv = NULL;
- qr_conf_t *conf = NULL;
- qr_inode_table_t *table = NULL;
- qr_inode_t *curr = NULL, *next = NULL;
- int32_t index = 0;
- uint64_t size_to_prune = 0;
- uint64_t size_pruned = 0;
+ qr_private_t *priv = NULL;
+ qr_conf_t *conf = NULL;
+ qr_inode_table_t *table = NULL;
+ qr_inode_t *curr = NULL, *next = NULL;
+ int32_t index = 0;
+ uint64_t size_to_prune = 0;
+ uint64_t size_pruned = 0;
priv = this->private;
table = &priv->table;
@@ -276,7 +284,7 @@ __qr_cache_prune (xlator_t *this)
done:
table->cache_used -= size_pruned;
- return;
+ return;
}
/* To be called with table->lock held */
@@ -377,7 +385,6 @@ qr_lookup_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
unlock:
UNLOCK (&table->lock);
-
out:
/*
* FIXME: content size in dict can be greater than the size application
@@ -393,16 +400,16 @@ out:
int32_t
qr_lookup (call_frame_t *frame, xlator_t *this, loc_t *loc, dict_t *xattr_req)
{
- qr_conf_t *conf = NULL;
- dict_t *new_req_dict = NULL;
- int32_t op_ret = -1, op_errno = -1;
- data_t *content = NULL;
+ qr_conf_t *conf = NULL;
+ dict_t *new_req_dict = NULL;
+ int32_t op_ret = -1, op_errno = -1;
+ data_t *content = NULL;
uint64_t requested_size = 0, size = 0, value = 0;
- char cached = 0;
- qr_inode_t *qr_inode = NULL;
- qr_private_t *priv = NULL;
- qr_inode_table_t *table = NULL;
- qr_local_t *local = NULL;
+ char cached = 0;
+ qr_inode_t *qr_inode = NULL;
+ qr_private_t *priv = NULL;
+ qr_inode_table_t *table = NULL;
+ qr_local_t *local = NULL;
priv = this->private;
conf = &priv->conf;
@@ -469,7 +476,7 @@ qr_lookup (call_frame_t *frame, xlator_t *this, loc_t *loc, dict_t *xattr_req)
}
}
- STACK_WIND (frame, qr_lookup_cbk, FIRST_CHILD(this),
+ STACK_WIND (frame, qr_lookup_cbk, FIRST_CHILD(this),
FIRST_CHILD(this)->fops->lookup, loc, xattr_req);
if (new_req_dict) {
@@ -494,16 +501,16 @@ int32_t
qr_open_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret,
int32_t op_errno, fd_t *fd)
{
- uint64_t value = 0;
- int32_t ret = -1;
- struct list_head waiting_ops;
- qr_local_t *local = NULL;
+ uint64_t value = 0;
+ int32_t ret = -1;
+ qr_local_t *local = NULL;
qr_inode_t *qr_inode = NULL;
qr_fd_ctx_t *qr_fd_ctx = NULL;
- call_stub_t *stub = NULL, *tmp = NULL;
- char is_open = 0;
- qr_private_t *priv = NULL;
- qr_inode_table_t *table = NULL;
+ call_stub_t *stub = NULL, *tmp = NULL;
+ char is_open = 0;
+ qr_private_t *priv = NULL;
+ qr_inode_table_t *table = NULL;
+ struct list_head waiting_ops;
priv = this->private;
table = &priv->table;
@@ -561,6 +568,14 @@ qr_open_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret,
list_for_each_entry_safe (stub, tmp, &waiting_ops,
list) {
list_del_init (&stub->list);
+ if (op_ret < 0) {
+ qr_local_t *local = NULL;
+
+ local = stub->frame->local;
+ local->op_ret = op_ret;
+ local->op_errno = op_errno;
+ }
+
call_resume (stub);
}
}
@@ -578,15 +593,15 @@ int32_t
qr_open (call_frame_t *frame, xlator_t *this, loc_t *loc, int32_t flags,
fd_t *fd, int32_t wbflags)
{
- qr_inode_t *qr_inode = NULL;
- int32_t ret = -1;
- uint64_t filep = 0;
+ qr_inode_t *qr_inode = NULL;
+ int32_t ret = -1;
+ uint64_t filep = 0;
char content_cached = 0;
- qr_fd_ctx_t *qr_fd_ctx = NULL, *tmp_fd_ctx = NULL;
- int32_t op_ret = -1, op_errno = -1;
- qr_local_t *local = NULL;
- qr_private_t *priv = NULL;
- qr_inode_table_t *table = NULL;
+ qr_fd_ctx_t *qr_fd_ctx = NULL, *tmp_fd_ctx = NULL;
+ int32_t op_ret = -1, op_errno = -1;
+ qr_local_t *local = NULL;
+ qr_private_t *priv = NULL;
+ qr_inode_table_t *table = NULL;
priv = this->private;
table = &priv->table;
@@ -615,8 +630,7 @@ qr_open (call_frame_t *frame, xlator_t *this, loc_t *loc, int32_t flags,
}
tmp_fd_ctx = NULL;
- local = GF_CALLOC (1, sizeof (*local),
- gf_qr_mt_qr_local_t);
+ local = GF_CALLOC (1, sizeof (*local), gf_qr_mt_qr_local_t);
if (local == NULL) {
op_ret = -1;
op_errno = ENOMEM;
@@ -697,7 +711,7 @@ qr_time_elapsed (struct timeval *now, struct timeval *then)
static inline char
qr_need_validation (qr_conf_t *conf, qr_inode_t *qr_inode)
{
- struct timeval now = {0, };
+ struct timeval now = {0, };
char need_validation = 0;
gettimeofday (&now, NULL);
@@ -713,7 +727,7 @@ static int32_t
qr_validate_cache_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
int32_t op_ret, int32_t op_errno, struct iatt *buf)
{
- qr_inode_t *qr_inode = NULL;
+ qr_inode_t *qr_inode = NULL;
qr_local_t *local = NULL;
uint64_t value = 0;
int32_t ret = 0;
@@ -774,7 +788,7 @@ unwind:
int32_t
qr_validate_cache_helper (call_frame_t *frame, xlator_t *this, fd_t *fd)
{
- qr_local_t *local = NULL;
+ qr_local_t *local = NULL;
int32_t op_ret = -1, op_errno = -1;
local = frame->local;
@@ -802,20 +816,23 @@ int
qr_validate_cache (call_frame_t *frame, xlator_t *this, fd_t *fd,
call_stub_t *stub)
{
- int ret = -1;
- int flags = 0;
- uint64_t value = 0;
- loc_t loc = {0, };
- char *path = NULL;
- qr_local_t *local = NULL;
- qr_fd_ctx_t *qr_fd_ctx = NULL;
+ int ret = -1;
+ int flags = 0;
+ uint64_t value = 0;
+ loc_t loc = {0, };
+ char *path = NULL;
+ qr_local_t *local = NULL;
+ qr_fd_ctx_t *qr_fd_ctx = NULL;
call_stub_t *validate_stub = NULL;
- char need_open = 0, can_wind = 0;
+ char need_open = 0, can_wind = 0;
- local = GF_CALLOC (1, sizeof (*local),
- gf_qr_mt_qr_local_t);
- if (local == NULL) {
- goto out;
+ if (frame->local == NULL) {
+ local = GF_CALLOC (1, sizeof (*local), gf_qr_mt_qr_local_t);
+ if (local == NULL) {
+ goto out;
+ }
+ } else {
+ local = frame->local;
}
local->fd = fd;
@@ -868,7 +885,7 @@ qr_validate_cache (call_frame_t *frame, xlator_t *this, fd_t *fd,
if (need_open) {
ret = qr_loc_fill (&loc, fd->inode, path);
if (ret == -1) {
- qr_resume_pending_ops (qr_fd_ctx);
+ qr_resume_pending_ops (qr_fd_ctx, -1, errno);
goto out;
}
@@ -878,8 +895,7 @@ qr_validate_cache (call_frame_t *frame, xlator_t *this, fd_t *fd,
qr_loc_wipe (&loc);
} else if (can_wind) {
- STACK_WIND (frame, qr_validate_cache_cbk,
- FIRST_CHILD (this),
+ STACK_WIND (frame, qr_validate_cache_cbk, FIRST_CHILD (this),
FIRST_CHILD (this)->fops->fstat, fd);
}
@@ -894,9 +910,9 @@ qr_readv_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret,
int32_t op_errno, struct iovec *vector, int32_t count,
struct iatt *stbuf, struct iobref *iobref)
{
- QR_STACK_UNWIND (readv, frame, op_ret, op_errno, vector, count,
+ QR_STACK_UNWIND (readv, frame, op_ret, op_errno, vector, count,
stbuf, iobref);
- return 0;
+ return 0;
}
@@ -904,9 +920,39 @@ int32_t
qr_readv_helper (call_frame_t *frame, xlator_t *this, fd_t *fd, size_t size,
off_t offset)
{
+ qr_local_t *local = NULL;
+ int32_t op_errno = EINVAL, ret = 0;
+ uint64_t value = 0;
+ qr_fd_ctx_t *fdctx = NULL;
+
+ GF_ASSERT (frame);
+
+ local = frame->local;
+ GF_VALIDATE_OR_GOTO (frame->this->name, local, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, this, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, fd, unwind);
+
+ if (local->op_ret < 0) {
+ op_errno = local->op_errno;
+
+ ret = fd_ctx_get (fd, this, &value);
+ if (ret == 0) {
+ fdctx = (qr_fd_ctx_t *)(long) value;
+ }
+
+ gf_log (this->name, GF_LOG_WARNING,
+ "open failed on path (%s) (%s), unwinding read call",
+ fdctx ? fdctx->path : NULL, strerror (errno));
+ goto unwind;
+ }
+
STACK_WIND (frame, qr_readv_cbk, FIRST_CHILD (this),
FIRST_CHILD (this)->fops->readv, fd, size, offset);
return 0;
+
+unwind:
+ QR_STACK_UNWIND (readv, frame, -1, op_errno, NULL, 0, NULL, NULL);
+ return 0;
}
@@ -914,29 +960,29 @@ int32_t
qr_readv (call_frame_t *frame, xlator_t *this, fd_t *fd, size_t size,
off_t offset)
{
- qr_inode_t *qr_inode = NULL;
- int32_t ret = -1, op_ret = -1, op_errno = -1;
- uint64_t value = 0;
- int count = -1, flags = 0, i = 0;
+ qr_inode_t *qr_inode = NULL;
+ int32_t ret = -1, op_ret = -1, op_errno = -1;
+ uint64_t value = 0;
+ int count = -1, flags = 0, i = 0;
char content_cached = 0, need_validation = 0;
- char need_open = 0, can_wind = 0, need_unwind = 0;
- struct iobuf *iobuf = NULL;
- struct iobref *iobref = NULL;
- struct iatt stbuf = {0, };
- data_t *content = NULL;
- qr_fd_ctx_t *qr_fd_ctx = NULL;
- call_stub_t *stub = NULL;
- loc_t loc = {0, };
- qr_conf_t *conf = NULL;
- struct iovec *vector = NULL;
- char *path = NULL;
- off_t start = 0, end = 0;
- size_t len = 0;
- struct iobuf_pool *iobuf_pool = NULL;
- qr_local_t *local = NULL;
+ char need_open = 0, can_wind = 0, need_unwind = 0;
+ struct iobuf *iobuf = NULL;
+ struct iobref *iobref = NULL;
+ struct iatt stbuf = {0, };
+ data_t *content = NULL;
+ qr_fd_ctx_t *qr_fd_ctx = NULL;
+ call_stub_t *stub = NULL;
+ loc_t loc = {0, };
+ qr_conf_t *conf = NULL;
+ struct iovec *vector = NULL;
+ char *path = NULL;
+ off_t start = 0, end = 0;
+ size_t len = 0;
+ struct iobuf_pool *iobuf_pool = NULL;
+ qr_local_t *local = NULL;
char just_validated = 0;
- qr_private_t *priv = NULL;
- qr_inode_table_t *table = NULL;
+ qr_private_t *priv = NULL;
+ qr_inode_table_t *table = NULL;
op_ret = 0;
@@ -979,7 +1025,6 @@ qr_readv (call_frame_t *frame, xlator_t *this, fd_t *fd, size_t size,
content = dict_get (qr_inode->xattr,
GF_CONTENT_KEY);
-
stbuf = qr_inode->stbuf;
content_cached = 1;
list_move_tail (&qr_inode->lru,
@@ -991,7 +1036,8 @@ qr_readv (call_frame_t *frame, xlator_t *this, fd_t *fd, size_t size,
} else {
if ((offset + size)
> content->len) {
- op_ret = content->len - offset;
+ op_ret = content->len
+ - offset;
end = content->len;
} else {
op_ret = size;
@@ -999,7 +1045,8 @@ qr_readv (call_frame_t *frame, xlator_t *this, fd_t *fd, size_t size,
}
}
- count = (op_ret / iobuf_pool->page_size);
+ count = (op_ret
+ / iobuf_pool->page_size);
if ((op_ret % iobuf_pool->page_size)
!= 0) {
count++;
@@ -1037,7 +1084,11 @@ qr_readv (call_frame_t *frame, xlator_t *this, fd_t *fd, size_t size,
goto unlock;
}
- start = offset + (iobuf_pool->page_size * i);
+ start = offset
+ +
+ (iobuf_pool->page_size
+ * i);
+
if (start > end) {
len = 0;
} else {
@@ -1047,7 +1098,8 @@ qr_readv (call_frame_t *frame, xlator_t *this, fd_t *fd, size_t size,
: iobuf_pool->page_size;
memcpy (iobuf->ptr,
- content->data + start,
+ content->data
+ + start,
len);
}
@@ -1067,7 +1119,7 @@ unlock:
out:
if (content_cached || need_unwind) {
QR_STACK_UNWIND (readv, frame, op_ret, op_errno, vector,
- count, &stbuf, iobref);
+ count, &stbuf, iobref);
} else if (need_validation) {
stub = fop_readv_stub (frame, qr_readv, fd, size, offset);
@@ -1100,6 +1152,19 @@ out:
if (qr_fd_ctx->opened) {
can_wind = 1;
} else {
+ if (frame->local == NULL) {
+ frame->local = GF_CALLOC (1,
+ sizeof (qr_local_t),
+ gf_qr_mt_qr_local_t);
+ if (frame->local == NULL) {
+ op_ret = -1;
+ op_errno = ENOMEM;
+ need_unwind = 1;
+ qr_fd_ctx->open_in_transit = 0;
+ }
+ goto fdctx_unlock;
+ }
+
stub = fop_readv_stub (frame,
qr_readv_helper,
fd, size,
@@ -1130,7 +1195,7 @@ out:
if (need_open) {
op_ret = qr_loc_fill (&loc, fd->inode, path);
if (op_ret == -1) {
- qr_resume_pending_ops (qr_fd_ctx);
+ qr_resume_pending_ops (qr_fd_ctx, -1, errno);
goto ret;
}
@@ -1140,8 +1205,7 @@ out:
qr_loc_wipe (&loc);
} else if (can_wind) {
- STACK_WIND (frame, qr_readv_cbk,
- FIRST_CHILD (this),
+ STACK_WIND (frame, qr_readv_cbk, FIRST_CHILD (this),
FIRST_CHILD (this)->fops->readv, fd, size,
offset);
}
@@ -1166,8 +1230,8 @@ qr_writev_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
int32_t op_ret, int32_t op_errno, struct iatt *prebuf,
struct iatt *postbuf)
{
- QR_STACK_UNWIND (writev, frame, op_ret, op_errno, prebuf, postbuf);
- return 0;
+ QR_STACK_UNWIND (writev, frame, op_ret, op_errno, prebuf, postbuf);
+ return 0;
}
@@ -1176,10 +1240,41 @@ qr_writev_helper (call_frame_t *frame, xlator_t *this, fd_t *fd,
struct iovec *vector, int32_t count, off_t off,
struct iobref *iobref)
{
+ qr_local_t *local = NULL;
+ qr_fd_ctx_t *fdctx = NULL;
+ uint64_t value = 0;
+ int32_t ret = 0;
+ int32_t op_errno = EINVAL;
+
+ GF_ASSERT (frame);
+
+ local = frame->local;
+ GF_VALIDATE_OR_GOTO (frame->this->name, local, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, this, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, fd, unwind);
+
+ if (local->op_ret < 0) {
+ op_errno = local->op_errno;
+
+ ret = fd_ctx_get (fd, this, &value);
+ if (ret == 0) {
+ fdctx = (qr_fd_ctx_t *)(long) value;
+ }
+
+ gf_log (this->name, GF_LOG_WARNING,
+ "open failed on path (%s) (%s), unwinding write call",
+ fdctx ? fdctx->path : NULL, strerror (errno));
+ goto unwind;
+ }
+
STACK_WIND (frame, qr_writev_cbk, FIRST_CHILD (this),
FIRST_CHILD (this)->fops->writev, fd, vector, count, off,
iobref);
return 0;
+
+unwind:
+ QR_STACK_UNWIND (writev, frame, -1, op_errno, NULL, NULL);
+ return 0;
}
@@ -1187,17 +1282,17 @@ int32_t
qr_writev (call_frame_t *frame, xlator_t *this, fd_t *fd, struct iovec *vector,
int32_t count, off_t off, struct iobref *iobref)
{
- uint64_t value = 0;
- int flags = 0;
- call_stub_t *stub = NULL;
- char *path = NULL;
- loc_t loc = {0, };
- qr_inode_t *qr_inode = NULL;
+ uint64_t value = 0;
+ int flags = 0;
+ call_stub_t *stub = NULL;
+ char *path = NULL;
+ loc_t loc = {0, };
+ qr_inode_t *qr_inode = NULL;
qr_fd_ctx_t *qr_fd_ctx = NULL;
- int32_t op_ret = -1, op_errno = -1, ret = -1;
- char can_wind = 0, need_unwind = 0, need_open = 0;
- qr_private_t *priv = NULL;
- qr_inode_table_t *table = NULL;
+ int32_t op_ret = -1, op_errno = -1, ret = -1;
+ char can_wind = 0, need_unwind = 0, need_open = 0;
+ qr_private_t *priv = NULL;
+ qr_inode_table_t *table = NULL;
priv = this->private;
table = &priv->table;
@@ -1236,6 +1331,17 @@ qr_writev (call_frame_t *frame, xlator_t *this, fd_t *fd, struct iovec *vector,
if (qr_fd_ctx->opened) {
can_wind = 1;
} else {
+ frame->local = GF_CALLOC (1,
+ sizeof (qr_local_t),
+ gf_qr_mt_qr_local_t);
+ if (frame->local == NULL) {
+ op_ret = -1;
+ op_errno = ENOMEM;
+ need_unwind = 1;
+ qr_fd_ctx->open_in_transit = 0;
+ goto unlock;
+ }
+
stub = fop_writev_stub (frame, qr_writev_helper,
fd, vector, count, off,
iobref);
@@ -1258,8 +1364,7 @@ qr_writev (call_frame_t *frame, xlator_t *this, fd_t *fd, struct iovec *vector,
}
if (need_unwind) {
- QR_STACK_UNWIND (writev, frame, op_ret, op_errno, NULL,
- NULL);
+ QR_STACK_UNWIND (writev, frame, op_ret, op_errno, NULL, NULL);
} else if (can_wind) {
STACK_WIND (frame, qr_writev_cbk, FIRST_CHILD (this),
FIRST_CHILD (this)->fops->writev, fd, vector, count,
@@ -1267,7 +1372,7 @@ qr_writev (call_frame_t *frame, xlator_t *this, fd_t *fd, struct iovec *vector,
} else if (need_open) {
op_ret = qr_loc_fill (&loc, fd->inode, path);
if (op_ret == -1) {
- qr_resume_pending_ops (qr_fd_ctx);
+ qr_resume_pending_ops (qr_fd_ctx, -1, errno);
goto ret;
}
@@ -1285,19 +1390,50 @@ ret:
int32_t
qr_fstat_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret,
- int32_t op_errno, struct iatt *buf)
+ int32_t op_errno, struct iatt *buf)
{
- QR_STACK_UNWIND (fstat, frame, op_ret, op_errno, buf);
- return 0;
+ QR_STACK_UNWIND (fstat, frame, op_ret, op_errno, buf);
+ return 0;
}
int32_t
qr_fstat_helper (call_frame_t *frame, xlator_t *this, fd_t *fd)
{
+ qr_local_t *local = NULL;
+ qr_fd_ctx_t *fdctx = NULL;
+ uint64_t value = 0;
+ int32_t ret = 0;
+ int32_t op_errno = EINVAL;
+
+ GF_ASSERT (frame);
+
+ local = frame->local;
+ GF_VALIDATE_OR_GOTO (frame->this->name, local, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, this, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, fd, unwind);
+
+ if (local->op_ret < 0) {
+ op_errno = local->op_errno;
+
+ ret = fd_ctx_get (fd, this, &value);
+ if (ret == 0) {
+ fdctx = (qr_fd_ctx_t *)(long) value;
+ }
+
+ gf_log (this->name, GF_LOG_WARNING,
+ "open failed on path (%s) (%s), unwinding fstat call",
+ fdctx ? fdctx->path : NULL, strerror (op_errno));
+ goto unwind;
+ }
+
STACK_WIND (frame, qr_fstat_cbk, FIRST_CHILD (this),
FIRST_CHILD (this)->fops->fstat, fd);
return 0;
+
+unwind:
+ QR_STACK_UNWIND (fstat, frame, -1, op_errno, NULL);
+ return 0;
}
@@ -1306,12 +1442,12 @@ qr_fstat (call_frame_t *frame, xlator_t *this, fd_t *fd)
{
qr_fd_ctx_t *qr_fd_ctx = NULL;
char need_open = 0, can_wind = 0, need_unwind = 0;
- uint64_t value = 0;
- int32_t ret = -1, op_ret = -1, op_errno = -1;
- call_stub_t *stub = NULL;
- loc_t loc = {0, };
- char *path = NULL;
- int flags = 0;
+ uint64_t value = 0;
+ int32_t ret = -1, op_ret = -1, op_errno = -1;
+ call_stub_t *stub = NULL;
+ loc_t loc = {0, };
+ char *path = NULL;
+ int flags = 0;
ret = fd_ctx_get (fd, this, &value);
if (ret == 0) {
@@ -1333,6 +1469,17 @@ qr_fstat (call_frame_t *frame, xlator_t *this, fd_t *fd)
if (qr_fd_ctx->opened) {
can_wind = 1;
} else {
+ frame->local = GF_CALLOC (1,
+ sizeof (qr_local_t),
+ gf_qr_mt_qr_local_t);
+ if (frame->local == NULL) {
+ op_ret = -1;
+ op_errno = ENOMEM;
+ need_unwind = 1;
+ qr_fd_ctx->open_in_transit = 0;
+ goto unlock;
+ }
+
stub = fop_fstat_stub (frame, qr_fstat_helper,
fd);
if (stub == NULL) {
@@ -1361,7 +1508,7 @@ qr_fstat (call_frame_t *frame, xlator_t *this, fd_t *fd)
} else if (need_open) {
op_ret = qr_loc_fill (&loc, fd->inode, path);
if (op_ret == -1) {
- qr_resume_pending_ops (qr_fd_ctx);
+ qr_resume_pending_ops (qr_fd_ctx, -1, errno);
goto ret;
}
@@ -1377,15 +1524,13 @@ ret:
}
-
-
int32_t
qr_fsetattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
int32_t op_ret, int32_t op_errno,
struct iatt *preop, struct iatt *postop)
{
- QR_STACK_UNWIND (fsetattr, frame, op_ret, op_errno, preop, postop);
- return 0;
+ QR_STACK_UNWIND (fsetattr, frame, op_ret, op_errno, preop, postop);
+ return 0;
}
@@ -1393,9 +1538,41 @@ int32_t
qr_fsetattr_helper (call_frame_t *frame, xlator_t *this, fd_t *fd,
struct iatt *stbuf, int32_t valid)
{
- STACK_WIND(frame, qr_fsetattr_cbk, FIRST_CHILD(this),
- FIRST_CHILD(this)->fops->fsetattr, fd, stbuf,
- valid);
+ qr_local_t *local = NULL;
+ qr_fd_ctx_t *fdctx = NULL;
+ uint64_t value = 0;
+ int32_t ret = 0;
+ int32_t op_errno = EINVAL;
+
+ GF_ASSERT (frame);
+
+ local = frame->local;
+ GF_VALIDATE_OR_GOTO (frame->this->name, local, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, this, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, fd, unwind);
+
+ if (local->op_ret < 0) {
+ op_errno = local->op_errno;
+
+ ret = fd_ctx_get (fd, this, &value);
+ if (ret == 0) {
+ fdctx = (qr_fd_ctx_t *)(long) value;
+ }
+
+ gf_log (this->name, GF_LOG_WARNING,
+ "open failed on path (%s) (%s), unwinding fsetattr "
+ "call",
+ fdctx ? fdctx->path : NULL, strerror (op_errno));
+ goto unwind;
+ }
+
+ STACK_WIND (frame, qr_fsetattr_cbk, FIRST_CHILD(this),
+ FIRST_CHILD(this)->fops->fsetattr, fd, stbuf,
+ valid);
+ return 0;
+
+unwind:
+ QR_STACK_UNWIND (fsetattr, frame, -1, op_errno, NULL, NULL);
return 0;
}
@@ -1404,13 +1581,13 @@ int32_t
qr_fsetattr (call_frame_t *frame, xlator_t *this, fd_t *fd,
struct iatt *stbuf, int32_t valid)
{
- uint64_t value = 0;
- int flags = 0;
- call_stub_t *stub = NULL;
- char *path = NULL;
- loc_t loc = {0, };
+ uint64_t value = 0;
+ int flags = 0;
+ call_stub_t *stub = NULL;
+ char *path = NULL;
+ loc_t loc = {0, };
qr_fd_ctx_t *qr_fd_ctx = NULL;
- int32_t ret = -1, op_ret = -1, op_errno = -1;
+ int32_t ret = -1, op_ret = -1, op_errno = -1;
char need_open = 0, can_wind = 0, need_unwind = 0;
ret = fd_ctx_get (fd, this, &value);
@@ -1432,6 +1609,17 @@ qr_fsetattr (call_frame_t *frame, xlator_t *this, fd_t *fd,
if (qr_fd_ctx->opened) {
can_wind = 1;
} else {
+ frame->local = GF_CALLOC (1,
+ sizeof (qr_local_t),
+ gf_qr_mt_qr_local_t);
+ if (frame->local == NULL) {
+ op_ret = -1;
+ op_errno = ENOMEM;
+ need_unwind = 1;
+ qr_fd_ctx->open_in_transit = 0;
+ goto unlock;
+ }
+
stub = fop_fsetattr_stub (frame,
qr_fsetattr_helper,
fd, stbuf, valid);
@@ -1454,8 +1642,7 @@ qr_fsetattr (call_frame_t *frame, xlator_t *this, fd_t *fd,
}
if (need_unwind) {
- QR_STACK_UNWIND (fsetattr, frame, op_ret, op_errno, NULL,
- NULL);
+ QR_STACK_UNWIND (fsetattr, frame, op_ret, op_errno, NULL, NULL);
} else if (can_wind) {
STACK_WIND (frame, qr_fsetattr_cbk, FIRST_CHILD (this),
FIRST_CHILD (this)->fops->fsetattr, fd, stbuf,
@@ -1463,7 +1650,7 @@ qr_fsetattr (call_frame_t *frame, xlator_t *this, fd_t *fd,
} else if (need_open) {
op_ret = qr_loc_fill (&loc, fd->inode, path);
if (op_ret == -1) {
- qr_resume_pending_ops (qr_fd_ctx);
+ qr_resume_pending_ops (qr_fd_ctx, -1, errno);
goto ret;
}
@@ -1483,8 +1670,8 @@ int32_t
qr_fsetxattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
int32_t op_ret, int32_t op_errno)
{
- QR_STACK_UNWIND (fsetxattr, frame, op_ret, op_errno);
- return 0;
+ QR_STACK_UNWIND (fsetxattr, frame, op_ret, op_errno);
+ return 0;
}
@@ -1492,9 +1679,41 @@ int32_t
qr_fsetxattr_helper (call_frame_t *frame, xlator_t *this, fd_t *fd,
dict_t *dict, int32_t flags)
{
+ qr_local_t *local = NULL;
+ qr_fd_ctx_t *fdctx = NULL;
+ uint64_t value = 0;
+ int32_t ret = 0;
+ int32_t op_errno = EINVAL;
+
+ GF_ASSERT (frame);
+
+ local = frame->local;
+ GF_VALIDATE_OR_GOTO (frame->this->name, local, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, this, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, fd, unwind);
+
+ if (local->op_ret < 0) {
+ op_errno = local->op_errno;
+
+ ret = fd_ctx_get (fd, this, &value);
+ if (ret == 0) {
+ fdctx = (qr_fd_ctx_t *)(long) value;
+ }
+
+ gf_log (this->name, GF_LOG_WARNING,
+ "open failed on path (%s) (%s), unwinding fsetxattr "
+ "call",
+ fdctx ? fdctx->path : NULL, strerror (op_errno));
+ goto unwind;
+ }
+
STACK_WIND (frame, qr_fsetxattr_cbk, FIRST_CHILD (this),
FIRST_CHILD (this)->fops->fsetxattr, fd, dict, flags);
return 0;
+
+unwind:
+ QR_STACK_UNWIND (fsetxattr, frame, -1, op_errno);
+ return 0;
}
@@ -1502,14 +1721,14 @@ int32_t
qr_fsetxattr (call_frame_t *frame, xlator_t *this, fd_t *fd, dict_t *dict,
int32_t flags)
{
- uint64_t value = 0;
- call_stub_t *stub = NULL;
- char *path = NULL;
- loc_t loc = {0, };
+ uint64_t value = 0;
+ call_stub_t *stub = NULL;
+ char *path = NULL;
+ loc_t loc = {0, };
int open_flags = 0;
- qr_fd_ctx_t *qr_fd_ctx = NULL;
- int32_t ret = -1, op_ret = -1, op_errno = -1;
- char need_open = 0, can_wind = 0, need_unwind = 0;
+ qr_fd_ctx_t *qr_fd_ctx = NULL;
+ int32_t ret = -1, op_ret = -1, op_errno = -1;
+ char need_open = 0, can_wind = 0, need_unwind = 0;
ret = fd_ctx_get (fd, this, &value);
if (ret == 0) {
@@ -1531,6 +1750,17 @@ qr_fsetxattr (call_frame_t *frame, xlator_t *this, fd_t *fd, dict_t *dict,
if (qr_fd_ctx->opened) {
can_wind = 1;
} else {
+ frame->local = GF_CALLOC (1,
+ sizeof (qr_local_t),
+ gf_qr_mt_qr_local_t);
+ if (frame->local == NULL) {
+ op_ret = -1;
+ op_errno = ENOMEM;
+ need_unwind = 1;
+ qr_fd_ctx->open_in_transit = 0;
+ goto unlock;
+ }
+
stub = fop_fsetxattr_stub (frame,
qr_fsetxattr_helper,
fd, dict, flags);
@@ -1561,7 +1791,7 @@ qr_fsetxattr (call_frame_t *frame, xlator_t *this, fd_t *fd, dict_t *dict,
} else if (need_open) {
op_ret = qr_loc_fill (&loc, fd->inode, path);
if (op_ret == -1) {
- qr_resume_pending_ops (qr_fd_ctx);
+ qr_resume_pending_ops (qr_fd_ctx, -1, errno);
goto ret;
}
@@ -1579,10 +1809,10 @@ ret:
int32_t
qr_fgetxattr_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
- int32_t op_ret, int32_t op_errno, dict_t *dict)
+ int32_t op_ret, int32_t op_errno, dict_t *dict)
{
- QR_STACK_UNWIND (fgetxattr, frame, op_ret, op_errno, dict);
- return 0;
+ QR_STACK_UNWIND (fgetxattr, frame, op_ret, op_errno, dict);
+ return 0;
}
@@ -1590,22 +1820,54 @@ int32_t
qr_fgetxattr_helper (call_frame_t *frame, xlator_t *this, fd_t *fd,
const char *name)
{
+ qr_local_t *local = NULL;
+ qr_fd_ctx_t *fdctx = NULL;
+ uint64_t value = 0;
+ int32_t ret = 0;
+ int32_t op_errno = EINVAL;
+
+ GF_ASSERT (frame);
+
+ local = frame->local;
+ GF_VALIDATE_OR_GOTO (frame->this->name, local, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, this, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, fd, unwind);
+
+ if (local->op_ret < 0) {
+ op_errno = local->op_errno;
+
+ ret = fd_ctx_get (fd, this, &value);
+ if (ret == 0) {
+ fdctx = (qr_fd_ctx_t *)(long) value;
+ }
+
+ gf_log (this->name, GF_LOG_WARNING,
+ "open failed on path (%s) (%s), unwinding fgetxattr "
+ "call",
+ fdctx ? fdctx->path : NULL, strerror (op_errno));
+ goto unwind;
+ }
+
STACK_WIND (frame, qr_fgetxattr_cbk, FIRST_CHILD (this),
FIRST_CHILD (this)->fops->fgetxattr, fd, name);
return 0;
+
+unwind:
+ QR_STACK_UNWIND (fgetxattr, frame, -1, op_errno, NULL);
+ return 0;
}
int32_t
qr_fgetxattr (call_frame_t *frame, xlator_t *this, fd_t *fd, const char *name)
{
- int flags = 0;
- uint64_t value = 0;
- call_stub_t *stub = NULL;
- char *path = NULL;
- loc_t loc = {0, };
+ int flags = 0;
+ uint64_t value = 0;
+ call_stub_t *stub = NULL;
+ char *path = NULL;
+ loc_t loc = {0, };
qr_fd_ctx_t *qr_fd_ctx = NULL;
- int32_t ret = -1, op_ret = -1, op_errno = -1;
+ int32_t ret = -1, op_ret = -1, op_errno = -1;
char need_open = 0, can_wind = 0, need_unwind = 0;
/*
@@ -1633,6 +1895,17 @@ qr_fgetxattr (call_frame_t *frame, xlator_t *this, fd_t *fd, const char *name)
if (qr_fd_ctx->opened) {
can_wind = 1;
} else {
+ frame->local = GF_CALLOC (1,
+ sizeof (qr_local_t),
+ gf_qr_mt_qr_local_t);
+ if (frame->local == NULL) {
+ op_ret = -1;
+ op_errno = ENOMEM;
+ need_unwind = 1;
+ qr_fd_ctx->open_in_transit = 0;
+ goto unlock;
+ }
+
stub = fop_fgetxattr_stub (frame,
qr_fgetxattr_helper,
fd, name);
@@ -1662,7 +1935,7 @@ qr_fgetxattr (call_frame_t *frame, xlator_t *this, fd_t *fd, const char *name)
} else if (need_open) {
op_ret = qr_loc_fill (&loc, fd->inode, path);
if (op_ret == -1) {
- qr_resume_pending_ops (qr_fd_ctx);
+ qr_resume_pending_ops (qr_fd_ctx, -1, errno);
goto ret;
}
@@ -1682,28 +1955,59 @@ int32_t
qr_flush_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret,
int32_t op_errno)
{
- QR_STACK_UNWIND (flush, frame, op_ret, op_errno);
- return 0;
+ QR_STACK_UNWIND (flush, frame, op_ret, op_errno);
+ return 0;
}
int32_t
qr_flush_helper (call_frame_t *frame, xlator_t *this, fd_t *fd)
{
+ qr_local_t *local = NULL;
+ qr_fd_ctx_t *fdctx = NULL;
+ uint64_t value = 0;
+ int32_t ret = 0;
+ int32_t op_errno = EINVAL;
+
+ GF_ASSERT (frame);
+
+ local = frame->local;
+ GF_VALIDATE_OR_GOTO (frame->this->name, local, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, this, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, fd, unwind);
+
+ if (local->op_ret < 0) {
+ op_errno = local->op_errno;
+
+ ret = fd_ctx_get (fd, this, &value);
+ if (ret == 0) {
+ fdctx = (qr_fd_ctx_t *)(long) value;
+ }
+
+ gf_log (this->name, GF_LOG_WARNING,
+ "open failed on path (%s) (%s), unwinding flush call",
+ fdctx ? fdctx->path : NULL, strerror (op_errno));
+ goto unwind;
+ }
+
STACK_WIND (frame, qr_flush_cbk, FIRST_CHILD (this),
FIRST_CHILD (this)->fops->flush, fd);
return 0;
+
+unwind:
+ QR_STACK_UNWIND (flush, frame, -1, op_errno);
+ return 0;
}
int32_t
qr_flush (call_frame_t *frame, xlator_t *this, fd_t *fd)
{
- uint64_t value = 0;
- call_stub_t *stub = NULL;
+ uint64_t value = 0;
+ call_stub_t *stub = NULL;
qr_fd_ctx_t *qr_fd_ctx = NULL;
- int32_t ret = -1, op_ret = -1, op_errno = -1;
- char can_wind = 0, need_unwind = 0;
+ int32_t ret = -1, op_ret = -1, op_errno = -1;
+ char can_wind = 0, need_unwind = 0;
ret = fd_ctx_get (fd, this, &value);
if (ret == 0) {
@@ -1716,6 +2020,17 @@ qr_flush (call_frame_t *frame, xlator_t *this, fd_t *fd)
if (qr_fd_ctx->opened) {
can_wind = 1;
} else if (qr_fd_ctx->open_in_transit) {
+ frame->local = GF_CALLOC (1,
+ sizeof (qr_local_t),
+ gf_qr_mt_qr_local_t);
+ if (frame->local == NULL) {
+ op_ret = -1;
+ op_errno = ENOMEM;
+ need_unwind = 1;
+ qr_fd_ctx->open_in_transit = 0;
+ goto unlock;
+ }
+
stub = fop_flush_stub (frame, qr_flush_helper,
fd);
if (stub == NULL) {
@@ -1754,8 +2069,8 @@ int32_t
qr_fentrylk_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
int32_t op_ret, int32_t op_errno)
{
- QR_STACK_UNWIND (fentrylk, frame, op_ret, op_errno);
- return 0;
+ QR_STACK_UNWIND (fentrylk, frame, op_ret, op_errno);
+ return 0;
}
int32_t
@@ -1763,10 +2078,42 @@ qr_fentrylk_helper (call_frame_t *frame, xlator_t *this, const char *volume,
fd_t *fd, const char *basename, entrylk_cmd cmd,
entrylk_type type)
{
+ qr_local_t *local = NULL;
+ qr_fd_ctx_t *fdctx = NULL;
+ uint64_t value = 0;
+ int32_t ret = 0;
+ int32_t op_errno = EINVAL;
+
+ GF_ASSERT (frame);
+
+ local = frame->local;
+ GF_VALIDATE_OR_GOTO (frame->this->name, local, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, this, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, fd, unwind);
+
+ if (local->op_ret < 0) {
+ op_errno = local->op_errno;
+
+ ret = fd_ctx_get (fd, this, &value);
+ if (ret == 0) {
+ fdctx = (qr_fd_ctx_t *)(long) value;
+ }
+
+ gf_log (this->name, GF_LOG_WARNING,
+ "open failed on path (%s) (%s), unwinding fentrylk "
+ "call",
+ fdctx ? fdctx->path : NULL, strerror (op_errno));
+ goto unwind;
+ }
+
STACK_WIND(frame, qr_fentrylk_cbk, FIRST_CHILD(this),
FIRST_CHILD(this)->fops->fentrylk, volume, fd, basename,
cmd, type);
return 0;
+
+unwind:
+ QR_STACK_UNWIND (fentrylk, frame, -1, op_errno);
+ return 0;
}
@@ -1774,13 +2121,13 @@ int32_t
qr_fentrylk (call_frame_t *frame, xlator_t *this, const char *volume, fd_t *fd,
const char *basename, entrylk_cmd cmd, entrylk_type type)
{
- int flags = 0;
- uint64_t value = 0;
- call_stub_t *stub = NULL;
- char *path = NULL;
- loc_t loc = {0, };
+ int flags = 0;
+ uint64_t value = 0;
+ call_stub_t *stub = NULL;
+ char *path = NULL;
+ loc_t loc = {0, };
qr_fd_ctx_t *qr_fd_ctx = NULL;
- int32_t ret = -1, op_ret = -1, op_errno = -1;
+ int32_t ret = -1, op_ret = -1, op_errno = -1;
char need_open = 0, can_wind = 0, need_unwind = 0;
ret = fd_ctx_get (fd, this, &value);
@@ -1803,6 +2150,17 @@ qr_fentrylk (call_frame_t *frame, xlator_t *this, const char *volume, fd_t *fd,
if (qr_fd_ctx->opened) {
can_wind = 1;
} else {
+ frame->local = GF_CALLOC (1,
+ sizeof (qr_local_t),
+ gf_qr_mt_qr_local_t);
+ if (frame->local == NULL) {
+ op_ret = -1;
+ op_errno = ENOMEM;
+ need_unwind = 1;
+ qr_fd_ctx->open_in_transit = 0;
+ goto unlock;
+ }
+
stub = fop_fentrylk_stub (frame,
qr_fentrylk_helper,
volume, fd, basename,
@@ -1834,7 +2192,7 @@ qr_fentrylk (call_frame_t *frame, xlator_t *this, const char *volume, fd_t *fd,
} else if (need_open) {
op_ret = qr_loc_fill (&loc, fd->inode, path);
if (op_ret == -1) {
- qr_resume_pending_ops (qr_fd_ctx);
+ qr_resume_pending_ops (qr_fd_ctx, -1, errno);
goto ret;
}
@@ -1855,8 +2213,8 @@ qr_finodelk_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
int32_t op_ret, int32_t op_errno)
{
- QR_STACK_UNWIND (finodelk, frame, op_ret, op_errno);
- return 0;
+ QR_STACK_UNWIND (finodelk, frame, op_ret, op_errno);
+ return 0;
}
@@ -1864,9 +2222,41 @@ int32_t
qr_finodelk_helper (call_frame_t *frame, xlator_t *this, const char *volume,
fd_t *fd, int32_t cmd, struct gf_flock *lock)
{
+ qr_local_t *local = NULL;
+ qr_fd_ctx_t *fdctx = NULL;
+ uint64_t value = 0;
+ int32_t ret = 0;
+ int32_t op_errno = EINVAL;
+
+ GF_ASSERT (frame);
+
+ local = frame->local;
+ GF_VALIDATE_OR_GOTO (frame->this->name, local, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, this, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, fd, unwind);
+
+ if (local->op_ret < 0) {
+ op_errno = local->op_errno;
+
+ ret = fd_ctx_get (fd, this, &value);
+ if (ret == 0) {
+ fdctx = (qr_fd_ctx_t *)(long) value;
+ }
+
+ gf_log (this->name, GF_LOG_WARNING,
+ "open failed on path (%s) (%s), unwinding finodelk "
+ "call",
+ fdctx ? fdctx->path : NULL, strerror (op_errno));
+ goto unwind;
+ }
+
STACK_WIND (frame, qr_finodelk_cbk, FIRST_CHILD(this),
FIRST_CHILD(this)->fops->finodelk, volume, fd, cmd, lock);
return 0;
+
+unwind:
+ QR_STACK_UNWIND (finodelk, frame, -1, op_errno);
+ return 0;
}
@@ -1874,13 +2264,13 @@ int32_t
qr_finodelk (call_frame_t *frame, xlator_t *this, const char *volume, fd_t *fd,
int32_t cmd, struct gf_flock *lock)
{
- int flags = 0;
- uint64_t value = 0;
- call_stub_t *stub = NULL;
- char *path = NULL;
- loc_t loc = {0, };
+ int flags = 0;
+ uint64_t value = 0;
+ call_stub_t *stub = NULL;
+ char *path = NULL;
+ loc_t loc = {0, };
qr_fd_ctx_t *qr_fd_ctx = NULL;
- int32_t ret = -1, op_ret = -1, op_errno = -1;
+ int32_t ret = -1, op_ret = -1, op_errno = -1;
char need_open = 0, can_wind = 0, need_unwind = 0;
ret = fd_ctx_get (fd, this, &value);
@@ -1903,6 +2293,17 @@ qr_finodelk (call_frame_t *frame, xlator_t *this, const char *volume, fd_t *fd,
if (qr_fd_ctx->opened) {
can_wind = 1;
} else {
+ frame->local = GF_CALLOC (1,
+ sizeof (qr_local_t),
+ gf_qr_mt_qr_local_t);
+ if (frame->local == NULL) {
+ op_ret = -1;
+ op_errno = ENOMEM;
+ need_unwind = 1;
+ qr_fd_ctx->open_in_transit = 0;
+ goto unlock;
+ }
+
stub = fop_finodelk_stub (frame,
qr_finodelk_helper,
volume, fd, cmd,
@@ -1934,7 +2335,7 @@ qr_finodelk (call_frame_t *frame, xlator_t *this, const char *volume, fd_t *fd,
} else if (need_open) {
op_ret = qr_loc_fill (&loc, fd->inode, path);
if (op_ret == -1) {
- qr_resume_pending_ops (qr_fd_ctx);
+ qr_resume_pending_ops (qr_fd_ctx, -1, errno);
goto ret;
}
@@ -1954,30 +2355,62 @@ int32_t
qr_fsync_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret,
int32_t op_errno, struct iatt *prebuf, struct iatt *postbuf)
{
- QR_STACK_UNWIND (fsync, frame, op_ret, op_errno, prebuf, postbuf);
- return 0;
+ QR_STACK_UNWIND (fsync, frame, op_ret, op_errno, prebuf, postbuf);
+ return 0;
}
int32_t
qr_fsync_helper (call_frame_t *frame, xlator_t *this, fd_t *fd, int32_t flags)
{
+ qr_local_t *local = NULL;
+ qr_fd_ctx_t *fdctx = NULL;
+ uint64_t value = 0;
+ int32_t ret = 0;
+ int32_t op_errno = EINVAL;
+
+ GF_ASSERT (frame);
+
+ local = frame->local;
+ GF_VALIDATE_OR_GOTO (frame->this->name, local, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, this, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, fd, unwind);
+
+ if (local->op_ret < 0) {
+ op_errno = local->op_errno;
+
+ ret = fd_ctx_get (fd, this, &value);
+ if (ret == 0) {
+ fdctx = (qr_fd_ctx_t *)(long) value;
+ }
+
+ gf_log (this->name, GF_LOG_WARNING,
+ "open failed on path (%s) (%s), unwinding fsync call",
+ fdctx ? fdctx->path : NULL, strerror (op_errno));
+ goto unwind;
+ }
+
STACK_WIND (frame, qr_fsync_cbk, FIRST_CHILD (this),
FIRST_CHILD(this)->fops->fsync, fd, flags);
return 0;
+
+unwind:
+ QR_STACK_UNWIND (fsync, frame, -1, op_errno, NULL, NULL);
+ return 0;
}
+
int32_t
qr_fsync (call_frame_t *frame, xlator_t *this, fd_t *fd, int32_t flags)
{
- uint64_t value = 0;
- call_stub_t *stub = NULL;
- char *path = NULL;
- loc_t loc = {0, };
+ uint64_t value = 0;
+ call_stub_t *stub = NULL;
+ char *path = NULL;
+ loc_t loc = {0, };
int open_flags = 0;
- qr_fd_ctx_t *qr_fd_ctx = NULL;
- int32_t ret = -1, op_ret = -1, op_errno = -1;
- char need_open = 0, can_wind = 0, need_unwind = 0;
+ qr_fd_ctx_t *qr_fd_ctx = NULL;
+ int32_t ret = -1, op_ret = -1, op_errno = -1;
+ char need_open = 0, can_wind = 0, need_unwind = 0;
ret = fd_ctx_get (fd, this, &value);
if (ret == 0) {
@@ -1999,6 +2432,17 @@ qr_fsync (call_frame_t *frame, xlator_t *this, fd_t *fd, int32_t flags)
if (qr_fd_ctx->opened) {
can_wind = 1;
} else {
+ frame->local = GF_CALLOC (1,
+ sizeof (qr_local_t),
+ gf_qr_mt_qr_local_t);
+ if (frame->local == NULL) {
+ op_ret = -1;
+ op_errno = ENOMEM;
+ need_unwind = 1;
+ qr_fd_ctx->open_in_transit = 0;
+ goto unlock;
+ }
+
stub = fop_fsync_stub (frame, qr_fsync_helper,
fd, flags);
if (stub == NULL) {
@@ -2020,15 +2464,14 @@ qr_fsync (call_frame_t *frame, xlator_t *this, fd_t *fd, int32_t flags)
}
if (need_unwind) {
- QR_STACK_UNWIND (fsync, frame, op_ret, op_errno, NULL,
- NULL);
+ QR_STACK_UNWIND (fsync, frame, op_ret, op_errno, NULL, NULL);
} else if (can_wind) {
STACK_WIND (frame, qr_fsync_cbk, FIRST_CHILD (this),
FIRST_CHILD (this)->fops->fsync, fd, flags);
} else if (need_open) {
op_ret = qr_loc_fill (&loc, fd->inode, path);
if (op_ret == -1) {
- qr_resume_pending_ops (qr_fd_ctx);
+ qr_resume_pending_ops (qr_fd_ctx, -1, errno);
goto ret;
}
@@ -2049,12 +2492,12 @@ qr_ftruncate_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
int32_t op_ret, int32_t op_errno, struct iatt *prebuf,
struct iatt *postbuf)
{
- int32_t ret = 0;
- uint64_t value = 0;
- qr_inode_t *qr_inode = NULL;
- qr_local_t *local = NULL;
- qr_private_t *priv = NULL;
- qr_inode_table_t *table = NULL;
+ int32_t ret = 0;
+ uint64_t value = 0;
+ qr_inode_t *qr_inode = NULL;
+ qr_local_t *local = NULL;
+ qr_private_t *priv = NULL;
+ qr_inode_table_t *table = NULL;
if (op_ret == -1) {
goto out;
@@ -2100,23 +2543,55 @@ int32_t
qr_ftruncate_helper (call_frame_t *frame, xlator_t *this, fd_t *fd,
off_t offset)
{
+ qr_local_t *local = NULL;
+ qr_fd_ctx_t *fdctx = NULL;
+ uint64_t value = 0;
+ int32_t ret = 0;
+ int32_t op_errno = EINVAL;
+
+ GF_ASSERT (frame);
+
+ local = frame->local;
+ GF_VALIDATE_OR_GOTO (frame->this->name, local, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, this, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, fd, unwind);
+
+ if (local->op_ret < 0) {
+ op_errno = local->op_errno;
+
+ ret = fd_ctx_get (fd, this, &value);
+ if (ret == 0) {
+ fdctx = (qr_fd_ctx_t *)(long) value;
+ }
+
+ gf_log (this->name, GF_LOG_WARNING,
+ "open failed on path (%s) (%s), unwinding ftruncate "
+ "call",
+ fdctx ? fdctx->path : NULL, strerror (op_errno));
+ goto unwind;
+ }
+
STACK_WIND (frame, qr_ftruncate_cbk, FIRST_CHILD(this),
FIRST_CHILD(this)->fops->ftruncate, fd, offset);
return 0;
+
+unwind:
+ QR_STACK_UNWIND (ftruncate, frame, -1, op_errno, NULL, NULL);
+ return 0;
}
int32_t
qr_ftruncate (call_frame_t *frame, xlator_t *this, fd_t *fd, off_t offset)
{
- int flags = 0;
- uint64_t value = 0;
- call_stub_t *stub = NULL;
- char *path = NULL;
- loc_t loc = {0, };
- qr_local_t *local = NULL;
+ int flags = 0;
+ uint64_t value = 0;
+ call_stub_t *stub = NULL;
+ char *path = NULL;
+ loc_t loc = {0, };
+ qr_local_t *local = NULL;
qr_fd_ctx_t *qr_fd_ctx = NULL;
- int32_t ret = -1, op_ret = -1, op_errno = -1;
+ int32_t ret = -1, op_ret = -1, op_errno = -1;
char need_open = 0, can_wind = 0, need_unwind = 0;
ret = fd_ctx_get (fd, this, &value);
@@ -2124,8 +2599,7 @@ qr_ftruncate (call_frame_t *frame, xlator_t *this, fd_t *fd, off_t offset)
qr_fd_ctx = (qr_fd_ctx_t *)(long)value;
}
- local = GF_CALLOC (1, sizeof (*local),
- gf_qr_mt_qr_local_t);
+ local = GF_CALLOC (1, sizeof (*local), gf_qr_mt_qr_local_t);
if (local == NULL) {
op_ret = -1;
op_errno = ENOMEM;
@@ -2175,14 +2649,14 @@ qr_ftruncate (call_frame_t *frame, xlator_t *this, fd_t *fd, off_t offset)
out:
if (need_unwind) {
QR_STACK_UNWIND (ftruncate, frame, op_ret, op_errno, NULL,
- NULL);
+ NULL);
} else if (can_wind) {
STACK_WIND (frame, qr_ftruncate_cbk, FIRST_CHILD(this),
FIRST_CHILD(this)->fops->ftruncate, fd, offset);
} else if (need_open) {
op_ret = qr_loc_fill (&loc, fd->inode, path);
if (op_ret == -1) {
- qr_resume_pending_ops (qr_fd_ctx);
+ qr_resume_pending_ops (qr_fd_ctx, -1, errno);
goto ret;
}
@@ -2199,11 +2673,11 @@ ret:
int32_t
-qr_lk_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret,
+qr_lk_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int32_t op_ret,
int32_t op_errno, struct gf_flock *lock)
{
- QR_STACK_UNWIND (lk, frame, op_ret, op_errno, lock);
- return 0;
+ QR_STACK_UNWIND (lk, frame, op_ret, op_errno, lock);
+ return 0;
}
@@ -2211,10 +2685,41 @@ int32_t
qr_lk_helper (call_frame_t *frame, xlator_t *this, fd_t *fd, int32_t cmd,
struct gf_flock *lock)
{
- STACK_WIND (frame, qr_lk_cbk, FIRST_CHILD(this),
+ qr_local_t *local = NULL;
+ qr_fd_ctx_t *fdctx = NULL;
+ uint64_t value = 0;
+ int32_t ret = 0;
+ int32_t op_errno = EINVAL;
+
+ GF_ASSERT (frame);
+
+ local = frame->local;
+ GF_VALIDATE_OR_GOTO (frame->this->name, local, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, this, unwind);
+ GF_VALIDATE_OR_GOTO (frame->this->name, fd, unwind);
+
+ if (local->op_ret < 0) {
+ op_errno = local->op_errno;
+
+ ret = fd_ctx_get (fd, this, &value);
+ if (ret == 0) {
+ fdctx = (qr_fd_ctx_t *)(long) value;
+ }
+
+ gf_log (this->name, GF_LOG_WARNING,
+ "open failed on path (%s) (%s), unwinding lk call",
+ fdctx ? fdctx->path : NULL, strerror (op_errno));
+ goto unwind;
+ }
+
+ STACK_WIND (frame, qr_lk_cbk, FIRST_CHILD(this),
FIRST_CHILD(this)->fops->lk, fd, cmd, lock);
return 0;
+
+unwind:
+ QR_STACK_UNWIND (lk, frame, -1, op_errno, NULL);
+ return 0;
}
@@ -2222,13 +2727,13 @@ int32_t
qr_lk (call_frame_t *frame, xlator_t *this, fd_t *fd, int32_t cmd,
struct gf_flock *lock)
{
- int flags = 0;
- uint64_t value = 0;
- call_stub_t *stub = NULL;
- char *path = NULL;
- loc_t loc = {0, };
+ int flags = 0;
+ uint64_t value = 0;
+ call_stub_t *stub = NULL;
+ char *path = NULL;
+ loc_t loc = {0, };
qr_fd_ctx_t *qr_fd_ctx = NULL;
- int32_t ret = -1, op_ret = -1, op_errno = -1;
+ int32_t ret = -1, op_ret = -1, op_errno = -1;
char need_open = 0, can_wind = 0, need_unwind = 0;
ret = fd_ctx_get (fd, this, &value);
@@ -2251,6 +2756,17 @@ qr_lk (call_frame_t *frame, xlator_t *this, fd_t *fd, int32_t cmd,
if (qr_fd_ctx->opened) {
can_wind = 1;
} else {
+ frame->local = GF_CALLOC (1,
+ sizeof (qr_local_t),
+ gf_qr_mt_qr_local_t);
+ if (frame->local == NULL) {
+ op_ret = -1;
+ op_errno = ENOMEM;
+ need_unwind = 1;
+ qr_fd_ctx->open_in_transit = 0;
+ goto unlock;
+ }
+
stub = fop_lk_stub (frame, qr_lk_helper, fd,
cmd, lock);
if (stub == NULL) {
@@ -2279,7 +2795,7 @@ qr_lk (call_frame_t *frame, xlator_t *this, fd_t *fd, int32_t cmd,
} else if (need_open) {
op_ret = qr_loc_fill (&loc, fd->inode, path);
if (op_ret == -1) {
- qr_resume_pending_ops (qr_fd_ctx);
+ qr_resume_pending_ops (qr_fd_ctx, -1, errno);
goto ret;
}
@@ -2299,8 +2815,8 @@ int32_t
qr_release (xlator_t *this, fd_t *fd)
{
qr_fd_ctx_t *qr_fd_ctx = NULL;
- int32_t ret = 0;
- uint64_t value = 0;
+ int32_t ret = 0;
+ uint64_t value = 0;
ret = fd_ctx_del (fd, this, &value);
if (ret == 0) {
@@ -2317,10 +2833,10 @@ qr_release (xlator_t *this, fd_t *fd)
int32_t
qr_forget (xlator_t *this, inode_t *inode)
{
- qr_inode_t *qr_inode = NULL;
- uint64_t value = 0;
- int32_t ret = -1;
- qr_private_t *priv = NULL;
+ qr_inode_t *qr_inode = NULL;
+ uint64_t value = 0;
+ int32_t ret = -1;
+ qr_private_t *priv = NULL;
priv = this->private;
@@ -2337,21 +2853,23 @@ qr_forget (xlator_t *this, inode_t *inode)
return 0;
}
+
int
qr_priv_dump (xlator_t *this)
{
- qr_conf_t *conf = NULL;
- char key[GF_DUMP_MAX_BUF_LEN];
- char key_prefix[GF_DUMP_MAX_BUF_LEN];
- qr_private_t *priv = NULL;
- qr_inode_table_t *table = NULL;
- uint32_t file_count = 0;
- uint32_t i = 0;
- qr_inode_t *curr = NULL;
- uint64_t total_size = 0;
-
- if (!this)
+ qr_conf_t *conf = NULL;
+ qr_private_t *priv = NULL;
+ qr_inode_table_t *table = NULL;
+ uint32_t file_count = 0;
+ uint32_t i = 0;
+ qr_inode_t *curr = NULL;
+ uint64_t total_size = 0;
+ char key[GF_DUMP_MAX_BUF_LEN];
+ char key_prefix[GF_DUMP_MAX_BUF_LEN];
+
+ if (!this) {
return -1;
+ }
priv = this->private;
conf = &priv->conf;
@@ -2377,8 +2895,7 @@ qr_priv_dump (xlator_t *this)
gf_proc_dump_write (key, "%d", conf->cache_timeout);
if (!table) {
- gf_log (this->name, GF_LOG_WARNING,
- "table is NULL");
+ gf_log (this->name, GF_LOG_WARNING, "table is NULL");
goto out;
} else {
for (i = 0; i < conf->max_pri; i++) {
@@ -2410,7 +2927,7 @@ mem_acct_init (xlator_t *this)
if (ret != 0) {
gf_log (this->name, GF_LOG_ERROR, "Memory accounting init"
- "failed");
+ "failed");
return ret;
}
@@ -2421,15 +2938,14 @@ mem_acct_init (xlator_t *this)
int
validate_options (xlator_t *this, dict_t *options, char **op_errstr)
{
- char *str = NULL;
- int32_t ret = -1;
- int32_t cache_timeout;
- uint64_t cache_size;
+ char *str = NULL;
+ int32_t ret = -1;
+ int32_t cache_timeout = 0;
+ uint64_t cache_size = 0;
- if (!this)
+ if (!this) {
goto out;
-
-
+ }
ret = dict_get_str (this->options, "cache-timeout", &str);
if (ret == 0) {
@@ -2446,7 +2962,7 @@ validate_options (xlator_t *this, dict_t *options, char **op_errstr)
gf_log (this->name, GF_LOG_ERROR,
"invalid cache-timeout value %s", str);
*op_errstr = "Range 1 <= value <= 60";
- ret = -1;
+ ret = -1;
goto out;
}
}
@@ -2477,36 +2993,34 @@ validate_options (xlator_t *this, dict_t *options, char **op_errstr)
}
-
ret =0;
out:
- return ret;
-
+ return ret;
}
int
reconfigure (xlator_t *this, dict_t *options)
{
+ char *str = NULL;
+ int32_t ret = -1;
+ qr_private_t *priv = NULL;
+ qr_conf_t *conf = NULL;
+ int32_t cache_timeout = 0;
+ uint64_t cache_size = 0;
-
-
- char *str = NULL;
- int32_t ret = -1;
- qr_private_t *priv = NULL;
- qr_conf_t *conf = NULL;
- int32_t cache_timeout;
- uint64_t cache_size;
-
- if (!this)
+ if (!this) {
goto out;
+ }
priv = this->private;
- if (!priv)
+ if (!priv) {
goto out;
+ }
conf = &priv->conf;
- if (!conf)
+ if (!conf) {
goto out;
+ }
cache_timeout = conf->cache_timeout;
ret = dict_get_str (options, "cache-timeout", &str);
@@ -2520,9 +3034,9 @@ reconfigure (xlator_t *this, dict_t *options)
goto out;
}
conf->cache_timeout = cache_timeout;
- }
- else
+ } else {
conf->cache_timeout = 1;
+ }
cache_size = conf->cache_size;
ret = dict_get_str (options, "cache-size", &str);
@@ -2535,33 +3049,33 @@ reconfigure (xlator_t *this, dict_t *options)
ret = -1;
goto out;
}
+
gf_log (this->name, GF_LOG_DEBUG,
"Reconfiguring cache-siz to %"PRIu64, cache_size);
conf->cache_size = cache_size;
- }
- else
+ } else {
conf->cache_size = QR_DEFAULT_CACHE_SIZE;
+ }
ret = 0;
out:
return ret;
-
}
int32_t
qr_get_priority_list (const char *opt_str, struct list_head *first)
{
- int32_t max_pri = 1;
- char *tmp_str = NULL;
- char *tmp_str1 = NULL;
- char *tmp_str2 = NULL;
- char *dup_str = NULL;
- char *priority_str = NULL;
- char *pattern = NULL;
- char *priority = NULL;
- char *string = NULL;
- struct qr_priority *curr = NULL, *tmp = NULL;
+ int32_t max_pri = 1;
+ char *tmp_str = NULL;
+ char *tmp_str1 = NULL;
+ char *tmp_str2 = NULL;
+ char *dup_str = NULL;
+ char *priority_str = NULL;
+ char *pattern = NULL;
+ char *priority = NULL;
+ char *string = NULL;
+ struct qr_priority *curr = NULL, *tmp = NULL;
string = gf_strdup (opt_str);
if (string == NULL) {
@@ -2569,64 +3083,64 @@ qr_get_priority_list (const char *opt_str, struct list_head *first)
goto out;
}
- /* Get the pattern for cache priority.
- * "option priority *.jpg:1,abc*:2" etc
- */
- /* TODO: inode_lru in table is statically hard-coded to 5,
- * should be changed to run-time configuration
- */
- priority_str = strtok_r (string, ",", &tmp_str);
- while (priority_str) {
- curr = GF_CALLOC (1, sizeof (*curr), gf_qr_mt_qr_priority_t);
+ /* Get the pattern for cache priority.
+ * "option priority *.jpg:1,abc*:2" etc
+ */
+ /* TODO: inode_lru in table is statically hard-coded to 5,
+ * should be changed to run-time configuration
+ */
+ priority_str = strtok_r (string, ",", &tmp_str);
+ while (priority_str) {
+ curr = GF_CALLOC (1, sizeof (*curr), gf_qr_mt_qr_priority_t);
if (curr == NULL) {
max_pri = -1;
goto out;
}
- list_add_tail (&curr->list, first);
+ list_add_tail (&curr->list, first);
- dup_str = gf_strdup (priority_str);
+ dup_str = gf_strdup (priority_str);
if (dup_str == NULL) {
max_pri = -1;
goto out;
}
- pattern = strtok_r (dup_str, ":", &tmp_str1);
- if (!pattern) {
+ pattern = strtok_r (dup_str, ":", &tmp_str1);
+ if (!pattern) {
max_pri = -1;
goto out;
}
- priority = strtok_r (NULL, ":", &tmp_str1);
- if (!priority) {
+ priority = strtok_r (NULL, ":", &tmp_str1);
+ if (!priority) {
max_pri = -1;
goto out;
}
- gf_log ("quick-read", GF_LOG_TRACE,
- "quick-read priority : pattern %s : priority %s",
- pattern,
- priority);
+ gf_log ("quick-read", GF_LOG_TRACE,
+ "quick-read priority : pattern %s : priority %s",
+ pattern,
+ priority);
- curr->pattern = gf_strdup (pattern);
+ curr->pattern = gf_strdup (pattern);
if (curr->pattern == NULL) {
max_pri = -1;
goto out;
}
- curr->priority = strtol (priority, &tmp_str2, 0);
- if (tmp_str2 && (*tmp_str2)) {
+ curr->priority = strtol (priority, &tmp_str2, 0);
+ if (tmp_str2 && (*tmp_str2)) {
max_pri = -1;
goto out;
} else {
- max_pri = max (max_pri, curr->priority);
+ max_pri = max (max_pri, curr->priority);
}
GF_FREE (dup_str);
dup_str = NULL;
- priority_str = strtok_r (NULL, ",", &tmp_str);
- }
+ priority_str = strtok_r (NULL, ",", &tmp_str);
+ }
out:
if (string != NULL) {
GF_FREE (string);
@@ -2644,14 +3158,14 @@ out:
}
}
- return max_pri;
+ return max_pri;
}
int32_t
init (xlator_t *this)
{
- char *str = NULL;
+ char *str = NULL;
int32_t ret = -1, i = 0;
qr_private_t *priv = NULL;
qr_conf_t *conf = NULL;
@@ -2660,17 +3174,16 @@ init (xlator_t *this)
if (!this->children || this->children->next) {
gf_log (this->name, GF_LOG_ERROR,
"FATAL: volume (%s) not configured with exactly one "
- "child", this->name);
+ "child", this->name);
return -1;
}
- if (!this->parents) {
- gf_log (this->name, GF_LOG_WARNING,
- "dangling volume. check volfile ");
- }
+ if (!this->parents) {
+ gf_log (this->name, GF_LOG_WARNING,
+ "dangling volume. check volfile ");
+ }
- priv = GF_CALLOC (1, sizeof (*priv),
- gf_qr_mt_qr_private_t);
+ priv = GF_CALLOC (1, sizeof (*priv), gf_qr_mt_qr_private_t);
if (priv == NULL) {
gf_log (this->name, GF_LOG_ERROR,
"out of memory");
@@ -2734,25 +3247,24 @@ init (xlator_t *this)
}
}
- INIT_LIST_HEAD (&conf->priority_list);
- conf->max_pri = 1;
- if (dict_get (this->options, "priority")) {
- char *option_list = data_to_str (dict_get (this->options,
- "priority"));
- gf_log (this->name, GF_LOG_TRACE,
- "option path %s", option_list);
- /* parse the list of pattern:priority */
- conf->max_pri = qr_get_priority_list (option_list,
- &conf->priority_list);
+ INIT_LIST_HEAD (&conf->priority_list);
+ conf->max_pri = 1;
+ if (dict_get (this->options, "priority")) {
+ char *option_list = data_to_str (dict_get (this->options,
+ "priority"));
+ gf_log (this->name, GF_LOG_TRACE,
+ "option path %s", option_list);
+ /* parse the list of pattern:priority */
+ conf->max_pri = qr_get_priority_list (option_list,
+ &conf->priority_list);
- if (conf->max_pri == -1) {
+ if (conf->max_pri == -1) {
goto out;
}
conf->max_pri ++;
- }
+ }
- priv->table.lru = GF_CALLOC (conf->max_pri,
- sizeof (*priv->table.lru),
+ priv->table.lru = GF_CALLOC (conf->max_pri, sizeof (*priv->table.lru),
gf_common_mt_list_head);
if (priv->table.lru == NULL) {
ret = -1;
@@ -2782,9 +3294,8 @@ fini (xlator_t *this)
return;
}
-
struct xlator_fops fops = {
- .lookup = qr_lookup,
+ .lookup = qr_lookup,
.open = qr_open,
.readv = qr_readv,
.writev = qr_writev,
@@ -2800,8 +3311,6 @@ struct xlator_fops fops = {
.fsetattr = qr_fsetattr,
};
-
-
struct xlator_cbks cbks = {
.forget = qr_forget,
.release = qr_release,
@@ -2812,9 +3321,9 @@ struct xlator_dumpops dumpops = {
};
struct volume_options options[] = {
- { .key = {"priority"},
- .type = GF_OPTION_TYPE_ANY
- },
+ { .key = {"priority"},
+ .type = GF_OPTION_TYPE_ANY
+ },
{ .key = {"cache-size"},
.type = GF_OPTION_TYPE_SIZET,
.min = 0,
diff --git a/xlators/performance/quick-read/src/quick-read.h b/xlators/performance/quick-read/src/quick-read.h
index 0b2a5ae30e5..3b5c900943b 100644
--- a/xlators/performance/quick-read/src/quick-read.h
+++ b/xlators/performance/quick-read/src/quick-read.h
@@ -108,11 +108,11 @@ typedef struct qr_private qr_private_t;
void qr_local_free (qr_local_t *local);
-#define QR_STACK_UNWIND(op, frame, params ...) do { \
- qr_local_t *__local = frame->local; \
- frame->local = NULL; \
- STACK_UNWIND_STRICT (op, frame, params); \
- qr_local_free (__local); \
-} while (0)
+#define QR_STACK_UNWIND(op, frame, params ...) do { \
+ qr_local_t *__local = frame->local; \
+ frame->local = NULL; \
+ STACK_UNWIND_STRICT (op, frame, params); \
+ qr_local_free (__local); \
+ } while (0)
#endif /* #ifndef __QUICK_READ_H */
generated by cgit (git 2.34.1) at 2024-11-13 01:11:46 +0000