diff options
Diffstat (limited to 'xlators/protocol/server')
-rw-r--r-- | xlators/protocol/server/src/server-handshake.c | 4 | ||||
-rw-r--r-- | xlators/protocol/server/src/server-helpers.c | 18 | ||||
-rw-r--r-- | xlators/protocol/server/src/server.c | 3 | ||||
-rw-r--r-- | xlators/protocol/server/src/server3_1-fops.c | 8 |
4 files changed, 17 insertions, 16 deletions
diff --git a/xlators/protocol/server/src/server-handshake.c b/xlators/protocol/server/src/server-handshake.c index bc4d4afa253..94586d20c53 100644 --- a/xlators/protocol/server/src/server-handshake.c +++ b/xlators/protocol/server/src/server-handshake.c @@ -614,7 +614,7 @@ server_setvolume (rpcsvc_request_t *req) fail: rsp.dict.dict_len = dict_serialized_length (reply); if (rsp.dict.dict_len < 0) { - gf_log (this->name, GF_LOG_DEBUG, + gf_log ("server-handshake", GF_LOG_DEBUG, "failed to get serialized length of reply dict"); op_ret = -1; op_errno = EINVAL; @@ -627,7 +627,7 @@ fail: if (rsp.dict.dict_val) { ret = dict_serialize (reply, rsp.dict.dict_val); if (ret < 0) { - gf_log (this->name, GF_LOG_DEBUG, + gf_log ("server-handshake", GF_LOG_DEBUG, "failed to serialize reply dict"); op_ret = -1; op_errno = -ret; diff --git a/xlators/protocol/server/src/server-helpers.c b/xlators/protocol/server/src/server-helpers.c index 11c489e8867..216204a8ba0 100644 --- a/xlators/protocol/server/src/server-helpers.c +++ b/xlators/protocol/server/src/server-helpers.c @@ -541,15 +541,17 @@ server_connection_destroy (xlator_t *this, server_connection_t *conn) INIT_LIST_HEAD (&file_lockers); INIT_LIST_HEAD (&dir_lockers); - LOCK (<able->lock); - { - list_splice_init (<able->file_lockers, - &file_lockers); + if (ltable) { + LOCK (<able->lock); + { + list_splice_init (<able->file_lockers, + &file_lockers); - list_splice_init (<able->dir_lockers, &dir_lockers); + list_splice_init (<able->dir_lockers, &dir_lockers); + } + UNLOCK (<able->lock); + GF_FREE (ltable); } - UNLOCK (<able->lock); - GF_FREE (ltable); flock.l_type = F_UNLCK; flock.l_start = 0; @@ -1030,7 +1032,7 @@ server_print_params (char *str, int size, server_state_t *state) "wbflags=%d,", state->wbflags); if (state->size) filled += snprintf (str + filled, size - filled, - "size=%Zu,", state->size); + "size=%zu,", state->size); if (state->offset) filled += snprintf (str + filled, size - filled, "offset=%"PRId64",", state->offset); diff --git a/xlators/protocol/server/src/server.c b/xlators/protocol/server/src/server.c index 104274edd02..a7501babbcc 100644 --- a/xlators/protocol/server/src/server.c +++ b/xlators/protocol/server/src/server.c @@ -593,10 +593,9 @@ init (xlator_t *this) ret = 0; out: - if (ret) + if (ret && this) this->fini (this); - return ret; } diff --git a/xlators/protocol/server/src/server3_1-fops.c b/xlators/protocol/server/src/server3_1-fops.c index 686c0350d0b..c04861ddf10 100644 --- a/xlators/protocol/server/src/server3_1-fops.c +++ b/xlators/protocol/server/src/server3_1-fops.c @@ -4737,7 +4737,7 @@ server_lookup (rpcsvc_request_t *req) if (buf == NULL) { gf_log (conn->bound_xl->name, GF_LOG_ERROR, "out of memory"); - goto err; + goto out; } ret = dict_unserialize (buf, args.dict.dict_len, @@ -4748,7 +4748,7 @@ server_lookup (rpcsvc_request_t *req) "unserialize req-buffer to dictionary", frame->root->unique, state->resolve.path, state->resolve.ino); - goto err; + goto out; } state->dict = xattr_req; @@ -4761,7 +4761,7 @@ server_lookup (rpcsvc_request_t *req) resolve_and_resume (frame, server_lookup_resume); return 0; -err: +out: if (xattr_req) dict_unref (xattr_req); @@ -4771,7 +4771,7 @@ err: server_lookup_cbk (frame, NULL, frame->this, -1, EINVAL, NULL, NULL, NULL, NULL); - +err: return 0; } |