diff options
Diffstat (limited to 'xlators/features/changelog/src/changelog-barrier.c')
| -rw-r--r-- | xlators/features/changelog/src/changelog-barrier.c | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/xlators/features/changelog/src/changelog-barrier.c b/xlators/features/changelog/src/changelog-barrier.c index 22cfa617e1b..ac1eb0e4397 100644 --- a/xlators/features/changelog/src/changelog-barrier.c +++ b/xlators/features/changelog/src/changelog-barrier.c @@ -9,6 +9,7 @@ */ #include "changelog-helpers.h" +#include "changelog-messages.h" #include "call-stub.h" /* Enqueue a stub*/ @@ -52,13 +53,15 @@ chlog_barrier_dequeue_all (xlator_t *this, struct list_head *queue) { call_stub_t *stub = NULL; - gf_log (this->name, GF_LOG_INFO, + gf_msg (this->name, GF_LOG_INFO, 0, + CHANGELOG_MSG_BARRIER_INFO, "Dequeuing all the changelog barriered fops"); while ((stub = __chlog_barrier_dequeue (this, queue))) call_resume (stub); - gf_log (this->name, GF_LOG_INFO, + gf_msg (this->name, GF_LOG_INFO, 0, + CHANGELOG_MSG_BARRIER_INFO, "Dequeuing changelog barriered fops is finished"); return; } @@ -77,7 +80,8 @@ chlog_barrier_timeout (void *data) INIT_LIST_HEAD (&queue); - gf_log (this->name, GF_LOG_ERROR, + gf_msg (this->name, GF_LOG_ERROR, 0, + CHANGELOG_MSG_BARRIER_ERROR, "Disabling changelog barrier because of the timeout."); LOCK (&priv->lock); @@ -117,7 +121,8 @@ __chlog_barrier_enable (xlator_t *this, changelog_priv_t *priv) priv->timer = gf_timer_call_after (this->ctx, priv->timeout, chlog_barrier_timeout, (void *)this); if (!priv->timer) { - gf_log (this->name, GF_LOG_CRITICAL, + gf_msg (this->name, GF_LOG_CRITICAL, 0, + CHANGELOG_MSG_BARRIER_ERROR, "Couldn't add changelog barrier timeout event."); goto out; } |