From 6bb7aa43117e8744ef5f3a00de50fa711b92f86e Mon Sep 17 00:00:00 2001
From: MassimilianoPinto <massimiliano.pinto@skysql.com>
Date: Tue, 17 Jun 2014 18:16:45 +0200
Subject: [PATCH] first implementation for depth of replication

first implementation for depth of replication for nodes
---
 server/modules/monitor/mysql_mon.c | 35 ++++++++++++++++++++++++++++++
 1 file changed, 35 insertions(+)

diff --git a/server/modules/monitor/mysql_mon.c b/server/modules/monitor/mysql_mon.c
index 34ca6e469..3459eedfa 100644
--- a/server/modules/monitor/mysql_mon.c
+++ b/server/modules/monitor/mysql_mon.c
@@ -34,6 +34,7 @@
  *					Parameters are now printed in diagnostics
  * 03/06/14	Mark Ridoch		Add support for maintenance mode
  * 17/06/14	Massimiliano Pinto	Addition of getServerByNodeId routine
+ *					and first implementation for depth of replication for nodes.
  *
  * @endverbatim
  */
@@ -694,6 +695,40 @@ MONITOR_SERVERS	*ptr;
                         
 			ptr = ptr->next;
 		}
+
+		/* check the replication tree */
+		ptr = handle->databases;
+
+		while (ptr)
+		{
+			depth = 0;
+			current = ptr->server;
+			node_id = current->node_id;
+			if (node_id < 1)
+				continue;
+
+			while(1) {
+				backend = getServerByNodeId(handle->databases, node_id);
+				if (backend) {
+					node_id = backend->master_id;
+				} else
+					node_id = -1;
+
+				if (node_id > 0) {
+					current->depth = depth + 1;
+					depth++;
+				} else {
+					if (depth == 0)
+						current->depth = -1;
+					else
+						current->depth = depth;
+					break;
+				}
+			}
+
+			ptr = ptr->next;
+		}
+
 		thread_millisleep(handle->interval);
 	}
 }