From d4c415776b20e4152d4a706276cb06d833a58baa Mon Sep 17 00:00:00 2001 From: Kaleb S KEITHLEY Date: Sat, 19 Dec 2015 20:27:17 -0500 Subject: all: fixes for clang compile warnings cli/src/cli-cmd-parser.c (chenk) cli/src/cli-xml-output.c (spandit) cli/src/cli.c (chenk) libglusterfs/src/common-utils.c (vmallika) libglusterfs/src/gfdb/gfdb_sqlite3.c (jfernand +1) rpc/rpc-transport/socket/src/socket.c (?) xlators/cluster/afr/src/afr-transaction.c (?) xlators/cluster/dht/src/dht-common.h (srangana +2) xlators/cluster/dht/src/dht-selfheal.c (srangana +2) xlators/debug/io-stats/src/io-stats.c (R. Wareing) xlators/features/barrier/src/barrier.c (vshastry) xlators/features/bit-rot/src/bitd/bit-rot-scrub.h (vshankar +1) xlators/features/shard/src/shard.c (kdhananj +1) xlators/mgmt/glusterd/src/glusterd-ganesha.c (skoduri) xlators/mgmt/glusterd/src/glusterd-handler.c (atinmu) xlators/mgmt/glusterd/src/glusterd-op-sm.h (atinmu) xlators/mgmt/glusterd/src/glusterd-snapshot.c (spandit) xlators/mgmt/glusterd/src/glusterd-syncop.c (atinmu) xlators/mgmt/glusterd/src/glusterd-volgen.c (atinmu) xlators/protocol/client/src/client-messages.h (mselvaga +1) xlators/storage/bd/src/bd-helper.c (M. Mohan Kumar) xlators/storage/bd/src/bd.c (M. Mohan Kumar) xlators/storage/posix/src/posix.c (nbalacha +1) Change-Id: I85934fbcaf485932136ef3acd206f6ebecde61dd BUG: 1293133 Signed-off-by: Kaleb S KEITHLEY Reviewed-on: http://review.gluster.org/13031 CentOS-regression: Gluster Build System Smoke: Gluster Build System NetBSD-regression: NetBSD Build System --- rpc/rpc-transport/socket/src/socket.c | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) (limited to 'rpc') diff --git a/rpc/rpc-transport/socket/src/socket.c b/rpc/rpc-transport/socket/src/socket.c index 3ee0c2c75a8..eb3a2d32ba4 100644 --- a/rpc/rpc-transport/socket/src/socket.c +++ b/rpc/rpc-transport/socket/src/socket.c @@ -1806,7 +1806,7 @@ __socket_read_vectored_reply (rpc_transport_t *this) || ((ret == 0) && (remaining_size == 0) && (RPC_LASTFRAG (in->fraghdr)))) { frag->call_body.reply.status_state - = SP_STATE_ACCEPTED_REPLY_INIT; + = SP_STATE_VECTORED_REPLY_STATUS_INIT; in->payload_vector.iov_len = (unsigned long)frag->fragcurrent - (unsigned long)in->payload_vector.iov_base; @@ -1942,7 +1942,7 @@ __socket_read_frag (rpc_transport_t *this) ret = __socket_read_request (this); } else if (in->msg_type == REPLY) { ret = __socket_read_reply (this); - } else if (in->msg_type == GF_UNIVERSAL_ANSWER) { + } else if (in->msg_type == (msg_type_t) GF_UNIVERSAL_ANSWER) { gf_log ("rpc", GF_LOG_ERROR, "older version of protocol/process trying to " "connect from %s. use newer version on that node", @@ -1960,7 +1960,8 @@ __socket_read_frag (rpc_transport_t *this) if ((ret == -1) || ((ret == 0) && (remaining_size == 0) && (RPC_LASTFRAG (in->fraghdr)))) { - frag->state = SP_STATE_NADA; + /* frag->state = SP_STATE_NADA; */ + frag->state = SP_STATE_RPCFRAG_INIT; } break; @@ -2291,7 +2292,7 @@ socket_connect_finish (rpc_transport_t *this) "getsockname on (%d) failed (%s)", priv->sock, strerror (errno)); __socket_disconnect (this); - event = GF_EVENT_POLLERR; + event = RPC_TRANSPORT_DISCONNECT; goto unlock; } -- cgit