1 files changed, 21 insertions, 0 deletions
diff --git a/glusterfsd/src/glusterfsd-mgmt.c b/glusterfsd/src/glusterfsd-mgmt.c
index d8582aa7013..f313fa4c630 100644
--- a/glusterfsd/src/glusterfsd-mgmt.c
+++ b/glusterfsd/src/glusterfsd-mgmt.c
@@ -47,6 +47,7 @@
 #include "cli1-xdr.h"
 #include "statedump.h"
 #include "syncop.h"
+#include "xlator.h"
 
 static char is_mgmt_rpc_reconnect;
 
@@ -1928,6 +1929,24 @@ glusterfs_listener_stop (glusterfs_ctx_t *ctx)
 }
 
 int
+glusterfs_mgmt_notify (int32_t op, void *data, ...)
+{
+        int ret = 0;
+        switch (op)
+        {
+                case GF_EN_DEFRAG_STATUS:
+                        ret = glusterfs_rebalance_event_notify ((dict_t*) data);
+                        break;
+
+                default:
+                        gf_log ("", GF_LOG_ERROR, "Invalid op");
+                        break;
+        }
+
+        return ret;
+}
+
+int
 glusterfs_mgmt_init (glusterfs_ctx_t *ctx)
 {
         cmd_args_t              *cmd_args = NULL;
@@ -1972,6 +1991,8 @@ glusterfs_mgmt_init (glusterfs_ctx_t *ctx)
                 goto out;
         }
 
+        ctx->notify = glusterfs_mgmt_notify;
+
         /* This value should be set before doing the 'rpc_clnt_start()' as
            the notify function uses this variable */
         ctx->mgmt = rpc;