diff options
Diffstat (limited to 'xlators/features/changelog/src')
4 files changed, 4 insertions, 19 deletions
diff --git a/xlators/features/changelog/src/changelog-ev-handle.c b/xlators/features/changelog/src/changelog-ev-handle.c index 77637c7beec..7fa6a89ea98 100644 --- a/xlators/features/changelog/src/changelog-ev-handle.c +++ b/xlators/features/changelog/src/changelog-ev-handle.c @@ -74,7 +74,6 @@ changelog_dispatch_vec (call_frame_t *frame, xlator_t *this, int idx = 0; int count = 0; int ret = 0; - unsigned long range = 0; unsigned long sequence = 0; rbuf_iovec_t *rvec = NULL; struct ev_rpc *erpc = NULL; @@ -83,7 +82,7 @@ changelog_dispatch_vec (call_frame_t *frame, xlator_t *this, /* dispatch NR_IOVEC IO vectors at a time. */ erpc = data; - RLIST_GET_SEQ (erpc->rlist, sequence, range); + sequence = erpc->rlist->seq[0]; rlist_iter_init (&riter, erpc->rlist); @@ -232,7 +231,6 @@ changelog_ev_connector (void *data) void changelog_ev_cleanup_connections (xlator_t *this, changelog_clnt_t *c_clnt) { - int ret = 0; changelog_rpc_clnt_t *crpc = NULL; /* cleanup active connections */ @@ -287,11 +285,9 @@ put_client (changelog_clnt_t *c_clnt, changelog_rpc_clnt_t *crpc) void _dispatcher (rbuf_list_t *rlist, void *arg) { - int ret = 0; xlator_t *this = NULL; changelog_clnt_t *c_clnt = NULL; changelog_rpc_clnt_t *crpc = NULL; - changelog_rpc_clnt_t *tmp = NULL; struct ev_rpc erpc = {0,}; struct list_head *next = NULL; @@ -306,9 +302,9 @@ _dispatcher (rbuf_list_t *rlist, void *arg) if (!crpc) break; erpc.rpc = crpc->rpc; - ret = changelog_invoke_rpc (this, crpc->rpc, - &changelog_ev_program, - CHANGELOG_REV_PROC_EVENT, &erpc); + (void) changelog_invoke_rpc (this, crpc->rpc, + &changelog_ev_program, + CHANGELOG_REV_PROC_EVENT, &erpc); put_client (c_clnt, crpc); } } diff --git a/xlators/features/changelog/src/changelog-helpers.c b/xlators/features/changelog/src/changelog-helpers.c index 0cb68587e57..1e045f7a780 100644 --- a/xlators/features/changelog/src/changelog-helpers.c +++ b/xlators/features/changelog/src/changelog-helpers.c @@ -165,7 +165,6 @@ int changelog_cleanup_event_selection (xlator_t *this, changelog_ev_selector_t *selection) { - int ret = 0; int j = CHANGELOG_EV_SELECTION_RANGE; LOCK (&selection->reflock); @@ -392,7 +391,6 @@ update_path (xlator_t *this, char *cl_path) char low_cl[] = "changelog"; char up_cl[] = "CHANGELOG"; char *found = NULL; - int iter = 0; int ret = -1; found = strstr(cl_path, up_cl); diff --git a/xlators/features/changelog/src/changelog-rpc-common.c b/xlators/features/changelog/src/changelog-rpc-common.c index 4525923d34d..c0744ef6218 100644 --- a/xlators/features/changelog/src/changelog-rpc-common.c +++ b/xlators/features/changelog/src/changelog-rpc-common.c @@ -282,7 +282,6 @@ rpcsvc_t * changelog_rpc_server_init (xlator_t *this, char *sockfile, void *cbkdata, rpcsvc_notify_t fn, struct rpcsvc_program **progs) { - int j = 0; int ret = 0; rpcsvc_t *rpc = NULL; dict_t *options = NULL; diff --git a/xlators/features/changelog/src/changelog.c b/xlators/features/changelog/src/changelog.c index f8f95cf0e81..a2d18ac4d61 100644 --- a/xlators/features/changelog/src/changelog.c +++ b/xlators/features/changelog/src/changelog.c @@ -1877,9 +1877,6 @@ changelog_open_cbk (call_frame_t *frame, void *cookie, xlator_t *this, int op_ret, int op_errno, fd_t *fd, dict_t *xdata) { int ret = 0; - void *opaque = NULL; - char *buf = NULL; - ssize_t buflen = 0; changelog_priv_t *priv = NULL; changelog_event_t ev = {0,}; gf_boolean_t logopen = _gf_false; @@ -2041,8 +2038,6 @@ changelog_assign_barrier_timeout(changelog_priv_t *priv, uint32_t timeout) static void changelog_cleanup_helper_threads (xlator_t *this, changelog_priv_t *priv) { - int ret = 0; - if (priv->cr.rollover_th) { (void) changelog_thread_cleanup (this, priv->cr.rollover_th); priv->cr.rollover_th = 0; @@ -2059,7 +2054,6 @@ static int changelog_spawn_helper_threads (xlator_t *this, changelog_priv_t *priv) { int ret = 0; - int flags = 0; /* Geo-Rep snapshot dependency: * @@ -2752,7 +2746,6 @@ changelog_cleanup_rpc (xlator_t *this, changelog_priv_t *priv) static int changelog_init_rpc (xlator_t *this, changelog_priv_t *priv) { - int ret = 0; rpcsvc_t *rpc = NULL; changelog_ev_selector_t *selection = NULL; @@ -2786,7 +2779,6 @@ int32_t init (xlator_t *this) { int ret = -1; - char *tmp = NULL; changelog_priv_t *priv = NULL; GF_VALIDATE_OR_GOTO ("changelog", this, error_return); |