1 files changed, 32 insertions, 0 deletions
diff --git a/xlators/features/changelog/lib/src/gf-changelog-helpers.c b/xlators/features/changelog/lib/src/gf-changelog-helpers.c
index f071b057d59..6bf709dc664 100644
--- a/xlators/features/changelog/lib/src/gf-changelog-helpers.c
+++ b/xlators/features/changelog/lib/src/gf-changelog-helpers.c
@@ -178,3 +178,35 @@ gf_ftruncate (int fd, off_t length)
 
         return 0;
 }
+
+int
+gf_thread_cleanup (xlator_t *this, pthread_t thread)
+{
+        int ret = 0;
+        void *res = NULL;
+
+        ret = pthread_cancel (thread);
+        if (ret != 0) {
+                gf_log (this->name, GF_LOG_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,
+                        "failed to join thread");
+                goto error_return;
+        }
+
+        if (res != PTHREAD_CANCELED) {
+                gf_log (this->name, GF_LOG_WARNING,
+                        "Thread could not be cleaned up");
+                goto error_return;
+        }
+
+        return 0;
+
+ error_return:
+        return -1;
+}