diff options
Diffstat (limited to 'xlators/mgmt/glusterd/src')
| -rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-rpc-ops.c | 2 | ||||
| -rw-r--r-- | xlators/mgmt/glusterd/src/glusterd-utils.c | 8 | 
2 files changed, 5 insertions, 5 deletions
diff --git a/xlators/mgmt/glusterd/src/glusterd-rpc-ops.c b/xlators/mgmt/glusterd/src/glusterd-rpc-ops.c index 2b0f87fb00e..8600c7b93c1 100644 --- a/xlators/mgmt/glusterd/src/glusterd-rpc-ops.c +++ b/xlators/mgmt/glusterd/src/glusterd-rpc-ops.c @@ -1632,7 +1632,7 @@ glusterd3_1_brick_op_cbk (struct rpc_req *req, struct iovec *iov,                  gf_log ("", GF_LOG_ERROR, "error");                  rsp.op_ret   = -1;                  rsp.op_errno = EINVAL; -                rsp.op_errstr = "error"; +                rsp.op_errstr = strdup ("Unable to decode response");  		event_type = GD_OP_EVENT_RCVD_RJT;                  goto out;          } diff --git a/xlators/mgmt/glusterd/src/glusterd-utils.c b/xlators/mgmt/glusterd/src/glusterd-utils.c index 3d43899640e..1c1873a6e9f 100644 --- a/xlators/mgmt/glusterd/src/glusterd-utils.c +++ b/xlators/mgmt/glusterd/src/glusterd-utils.c @@ -444,11 +444,10 @@ glusterd_submit_reply (rpcsvc_request_t *req, void *arg,          iob = glusterd_serialize_reply (req, arg, sfunc, &rsp);          if (!iob) {                  gf_log ("", GF_LOG_ERROR, "Failed to serialize reply"); -                goto out; +        } else { +                iobref_add (iobref, iob);          } -        iobref_add (iobref, iob); -          ret = rpcsvc_submit_generic (req, &rsp, 1, payload, payloadcount,                                       iobref); @@ -456,7 +455,6 @@ glusterd_submit_reply (rpcsvc_request_t *req, void *arg,           * we can safely unref the iob in the hope that RPC layer must have           * ref'ed the iob on receiving into the txlist.           */ -        iobuf_unref (iob);          if (ret == -1) {                  gf_log ("", GF_LOG_ERROR, "Reply submission failed");                  goto out; @@ -469,6 +467,8 @@ out:                  iobref_unref (iobref);          } +        if (iob) +                iobuf_unref (iob);          return ret;  }  | 
