summaryrefslogtreecommitdiffstats
path: root/xlators/features/changelog/src/changelog-ev-handle.c
diff options
context:
space:
mode:
Diffstat (limited to 'xlators/features/changelog/src/changelog-ev-handle.c')
-rw-r--r--xlators/features/changelog/src/changelog-ev-handle.c12
1 files changed, 8 insertions, 4 deletions
diff --git a/xlators/features/changelog/src/changelog-ev-handle.c b/xlators/features/changelog/src/changelog-ev-handle.c
index ca7443cfd22..5167b56ed88 100644
--- a/xlators/features/changelog/src/changelog-ev-handle.c
+++ b/xlators/features/changelog/src/changelog-ev-handle.c
@@ -199,8 +199,10 @@ changelog_ev_connector (void *data)
crpc->sock,
changelog_rpc_notify);
if (!crpc->rpc) {
- gf_log (this->name, GF_LOG_ERROR, "failed to "
- "connect back.. <%s>", crpc->sock);
+ gf_msg (this->name, GF_LOG_ERROR, 0,
+ CHANGELOG_MSG_RPC_CONNECT_ERROR,
+ "failed to connect back.. <%s>",
+ crpc->sock);
crpc->cleanup (crpc);
goto mutex_unlock;
}
@@ -338,7 +340,8 @@ changelog_ev_dispatch (void *data)
&opaque, sequencer, c_clnt);
if (ret != RBUF_CONSUMABLE) {
if (ret != RBUF_EMPTY)
- gf_log (this->name, GF_LOG_WARNING,
+ gf_msg (this->name, GF_LOG_WARNING, 0,
+ CHANGELOG_MSG_BUFFER_STARVATION_ERROR,
"Failed to get buffer for RPC dispatch "
"[rbuf retval: %d]", ret);
continue;
@@ -347,7 +350,8 @@ changelog_ev_dispatch (void *data)
ret = rbuf_wait_for_completion (c_clnt->rbuf,
opaque, _dispatcher, c_clnt);
if (ret)
- gf_log (this->name, GF_LOG_WARNING,
+ gf_msg (this->name, GF_LOG_WARNING, 0,
+ CHANGELOG_MSG_PUT_BUFFER_FAILED,
"failed to put buffer after consumption");
}