diff options
author | Amar Tumballi <amar@gluster.com> | 2010-07-28 04:23:57 +0000 |
---|---|---|
committer | Anand V. Avati <avati@dev.gluster.com> | 2010-07-28 03:34:58 -0700 |
commit | 550cdfbcf2a5300c926f87403e12f19424bffeac (patch) | |
tree | 21322ead4b1cbb9564e37c96deb7930009e0197d /xlators/protocol/client/src/client-handshake.c | |
parent | 927aedbb556ee07250248181f52642eeb6de9e58 (diff) |
fix all clang errors in xlator/protocol
Signed-off-by: Amar Tumballi <amar@gluster.com>
Signed-off-by: Anand V. Avati <avati@dev.gluster.com>
BUG: 1092 ()
URL: http://bugs.gluster.com/cgi-bin/bugzilla3/show_bug.cgi?id=1092
Diffstat (limited to 'xlators/protocol/client/src/client-handshake.c')
-rw-r--r-- | xlators/protocol/client/src/client-handshake.c | 45 |
1 files changed, 25 insertions, 20 deletions
diff --git a/xlators/protocol/client/src/client-handshake.c b/xlators/protocol/client/src/client-handshake.c index 1cd25424f5f..9a806f7e9dd 100644 --- a/xlators/protocol/client/src/client-handshake.c +++ b/xlators/protocol/client/src/client-handshake.c @@ -126,13 +126,11 @@ client_start_ping (void *data) struct timeval timeout = {0, }; call_frame_t *frame = NULL; int frame_count = 0; - rpc_transport_t *trans = NULL; this = data; conf = this->private; conn = &conf->rpc->conn; - trans = conn->trans; if (conf->opt.ping_timeout == 0) return; @@ -256,15 +254,14 @@ out: int -client3_getspec_cbk (struct rpc_req *req, struct iovec *iov, int count, void *myframe) +client3_getspec_cbk (struct rpc_req *req, struct iovec *iov, int count, + void *myframe) { gf_getspec_rsp rsp = {0,}; call_frame_t *frame = NULL; - clnt_conf_t *conf = NULL; int ret = 0; frame = myframe; - conf = frame->this->private; if (-1 == req->rpc_status) { rsp.op_ret = -1; @@ -385,12 +382,10 @@ client_setvolume_cbk (struct rpc_req *req, struct iovec *iov, int count, void *m char *process_uuid = NULL; char *remote_error = NULL; char *remote_subvol = NULL; - rpc_transport_t *peer_trans = NULL; gf_setvolume_rsp rsp = {0,}; - uint64_t peertrans_int = 0; int ret = 0; - int op_ret = 0; - int op_errno = 0; + int32_t op_ret = 0; + int32_t op_errno = 0; frame = myframe; this = frame->this; @@ -398,14 +393,12 @@ client_setvolume_cbk (struct rpc_req *req, struct iovec *iov, int count, void *m if (-1 == req->rpc_status) { op_ret = -1; - op_errno = EINVAL; goto out; } ret = xdr_to_setvolume_rsp (*iov, &rsp); if (ret < 0) { gf_log ("", GF_LOG_ERROR, "error"); - op_errno = EINVAL; op_ret = -1; goto out; } @@ -460,25 +453,30 @@ client_setvolume_cbk (struct rpc_req *req, struct iovec *iov, int count, void *m } ret = dict_get_str (this->options, "remote-subvolume", &remote_subvol); - if (!remote_subvol) + if (ret || !remote_subvol) goto out; - if (process_uuid && + /* TODO: currently setpeer path is broken */ + /* + if (process_uuid && req->conn && !strcmp (this->ctx->process_uuid, process_uuid)) { + rpc_transport_t *peer_trans = NULL; + uint64_t peertrans_int = 0; + ret = dict_get_uint64 (reply, "transport-ptr", &peertrans_int); - - peer_trans = (void *) (long) (peertrans_int); + if (ret) + goto out; gf_log (this->name, GF_LOG_WARNING, "attaching to the local volume '%s'", remote_subvol); - if (req->conn) { - /* TODO: Some issues with this logic at present */ - //rpc_transport_setpeer (req->conn->trans, peer_trans); - } + peer_trans = (void *) (long) (peertrans_int); + + rpc_transport_setpeer (req->conn->trans, peer_trans); } + */ gf_log (this->name, GF_LOG_NORMAL, "Connected to %s, attached to remote volume '%s'.", @@ -572,11 +570,18 @@ client_setvolume (xlator_t *this, struct rpc_clnt *rpc) } if (this->ctx->cmd_args.volfile_server) { - if (this->ctx->cmd_args.volfile_id) + if (this->ctx->cmd_args.volfile_id) { ret = dict_set_str (options, "volfile-key", this->ctx->cmd_args.volfile_id); + if (ret) + gf_log (this->name, GF_LOG_ERROR, + "failed to set 'volfile-key'"); + } ret = dict_set_uint32 (options, "volfile-checksum", this->graph->volfile_checksum); + if (ret) + gf_log (this->name, GF_LOG_ERROR, + "failed to set 'volfile-checksum'"); } req.dict.dict_len = dict_serialized_length (options); |