summaryrefslogtreecommitdiffstats
path: root/xlators/features/changelog/src/changelog-rpc-common.c
diff options
context:
space:
mode:
authorAnusha Rao <anusha91rao@gmail.com>2015-05-04 12:34:09 +0530
committerVenky Shankar <vshankar@redhat.com>2015-08-11 22:36:44 -0700
commit64e6836ac8fb96f38a859eea0d8525cd9bd2693f (patch)
treeeb00359a9dd7be26f90f9147330a8e2c6fa83232 /xlators/features/changelog/src/changelog-rpc-common.c
parent0dcdc8d9d797ed43d305fb3e3437c2576305ac46 (diff)
features/changelog: Porting log messages to new logging framework
Change-Id: Ic7f842acca52908fd88e0796dc90b82650405b25 BUG: 1194640 Signed-off-by: Anusha Rao <anusha91rao@gmail.com> Reviewed-on: http://review.gluster.org/10532 Tested-by: NetBSD Build System <jenkins@build.gluster.org> Tested-by: Gluster Build System <jenkins@build.gluster.com> Reviewed-by: Venky Shankar <vshankar@redhat.com> Reviewed-by: Kotresh HR <khiremat@redhat.com>
Diffstat (limited to 'xlators/features/changelog/src/changelog-rpc-common.c')
-rw-r--r--xlators/features/changelog/src/changelog-rpc-common.c39
1 files changed, 26 insertions, 13 deletions
diff --git a/xlators/features/changelog/src/changelog-rpc-common.c b/xlators/features/changelog/src/changelog-rpc-common.c
index de3a730534e..7d2ec1de988 100644
--- a/xlators/features/changelog/src/changelog-rpc-common.c
+++ b/xlators/features/changelog/src/changelog-rpc-common.c
@@ -9,7 +9,7 @@
*/
#include "changelog-rpc-common.h"
-
+#include "changelog-messages.h"
/**
*****************************************************
Client Interface
@@ -47,7 +47,8 @@ changelog_rpc_client_init (xlator_t *this, void *cbkdata,
ret = rpc_transport_unix_options_build (&options, sockfile, 0);
if (ret) {
- gf_log (this->name, GF_LOG_ERROR,
+ gf_msg (this->name, GF_LOG_ERROR, 0,
+ CHANGELOG_MSG_RPC_BUILD_ERROR,
"failed to build rpc options");
goto dealloc_dict;
}
@@ -58,13 +59,17 @@ changelog_rpc_client_init (xlator_t *this, void *cbkdata,
ret = rpc_clnt_register_notify (rpc, fn, cbkdata);
if (ret) {
- gf_log (this->name, GF_LOG_ERROR, "failed to register notify");
+ gf_msg (this->name, GF_LOG_ERROR, 0,
+ CHANGELOG_MSG_NOTIFY_REGISTER_FAILED,
+ "failed to register notify");
goto dealloc_rpc_clnt;
}
ret = rpc_clnt_start (rpc);
if (ret) {
- gf_log (this->name, GF_LOG_ERROR, "failed to start rpc");
+ gf_msg (this->name, GF_LOG_ERROR, 0,
+ CHANGELOG_MSG_RPC_START_ERROR,
+ "failed to start rpc");
goto dealloc_rpc_clnt;
}
@@ -158,7 +163,9 @@ changelog_invoke_rpc (xlator_t *this, struct rpc_clnt *rpc,
frame = create_frame (this, this->ctx->pool);
if (!frame) {
- gf_log (this->name, GF_LOG_ERROR, "failed to create frame");
+ gf_msg (this->name, GF_LOG_ERROR, 0,
+ CHANGELOG_MSG_CREATE_FRAME_FAILED,
+ "failed to create frame");
goto error_return;
}
@@ -229,7 +236,9 @@ changelog_rpc_sumbit_reply (rpcsvc_request_t *req,
iob = __changelog_rpc_serialize_reply (req, arg, &iov, xdrproc);
if (!iob)
- gf_log ("", GF_LOG_ERROR, "failed to serialize reply");
+ gf_msg ("", GF_LOG_ERROR, 0,
+ CHANGELOG_MSG_RPC_SUBMIT_REPLY_FAILED,
+ "failed to serialize reply");
else
iobref_add (iobref, iob);
@@ -290,21 +299,24 @@ changelog_rpc_server_init (xlator_t *this, char *sockfile, void *cbkdata,
rpc = rpcsvc_init (this, this->ctx, options, 8);
if (rpc == NULL) {
- gf_log (this->name, GF_LOG_ERROR, "failed to init rpc");
+ gf_msg (this->name, GF_LOG_ERROR, 0,
+ CHANGELOG_MSG_RPC_START_ERROR,
+ "failed to init rpc");
goto dealloc_dict;
}
ret = rpcsvc_register_notify (rpc, fn, cbkdata);
if (ret) {
- gf_log (this->name,
- GF_LOG_ERROR, "failed to register notify function");
+ gf_msg (this->name, GF_LOG_ERROR, 0,
+ CHANGELOG_MSG_NOTIFY_REGISTER_FAILED,
+ "failed to register notify function");
goto dealloc_rpc;
}
ret = rpcsvc_create_listeners (rpc, options, this->name);
if (ret != 1) {
- gf_log (this->name,
- GF_LOG_DEBUG, "failed to create listeners");
+ gf_msg_debug (this->name,
+ 0, "failed to create listeners");
goto dealloc_rpc;
}
@@ -312,8 +324,9 @@ changelog_rpc_server_init (xlator_t *this, char *sockfile, void *cbkdata,
prog = *progs;
ret = rpcsvc_program_register (rpc, prog);
if (ret) {
- gf_log (this->name,
- GF_LOG_ERROR, "cannot register program "
+ gf_msg (this->name, GF_LOG_ERROR, 0,
+ CHANGELOG_MSG_PROGRAM_NAME_REG_FAILED,
+ "cannot register program "
"(name: %s, prognum: %d, pogver: %d)",
prog->progname, prog->prognum, prog->progver);
goto dealloc_rpc;