summaryrefslogtreecommitdiffstats
path: root/xlators/features/changelog/lib/src/gf-changelog-helpers.c
diff options
context:
space:
mode:
Diffstat (limited to 'xlators/features/changelog/lib/src/gf-changelog-helpers.c')
-rw-r--r--xlators/features/changelog/lib/src/gf-changelog-helpers.c10
1 files changed, 7 insertions, 3 deletions
diff --git a/xlators/features/changelog/lib/src/gf-changelog-helpers.c b/xlators/features/changelog/lib/src/gf-changelog-helpers.c
index 6bf709dc664..d6245743437 100644
--- a/xlators/features/changelog/lib/src/gf-changelog-helpers.c
+++ b/xlators/features/changelog/lib/src/gf-changelog-helpers.c
@@ -10,6 +10,7 @@
#include "changelog-mem-types.h"
#include "gf-changelog-helpers.h"
+#include "changelog-lib-messages.h"
ssize_t gf_changelog_read_path (int fd, char *buffer, size_t bufsize)
{
@@ -187,20 +188,23 @@ gf_thread_cleanup (xlator_t *this, pthread_t thread)
ret = pthread_cancel (thread);
if (ret != 0) {
- gf_log (this->name, GF_LOG_WARNING,
+ gf_msg (this->name, GF_LOG_WARNING, 0,
+ CHANGELOG_LIB_MSG_THREAD_CLEANUP_WARNING,
"Failed to send cancellation to thread");
goto error_return;
}
ret = pthread_join (thread, &res);
if (ret != 0) {
- gf_log (this->name, GF_LOG_WARNING,
+ gf_msg (this->name, GF_LOG_WARNING, 0,
+ CHANGELOG_LIB_MSG_THREAD_CLEANUP_WARNING,
"failed to join thread");
goto error_return;
}
if (res != PTHREAD_CANCELED) {
- gf_log (this->name, GF_LOG_WARNING,
+ gf_msg (this->name, GF_LOG_WARNING, 0,
+ CHANGELOG_LIB_MSG_THREAD_CLEANUP_WARNING,
"Thread could not be cleaned up");
goto error_return;
}