More changes for distributed monitoring.

git-svn-id: svn://svn.zabbix.com/trunk@3335 97f52cf1-0a1b-0410-bd0e-c28be96e8082

1 files changed, 14 insertions, 2 deletions

diff --git a/src/libs/zbxdbhigh/db.c b/src/libs/zbxdbhigh/db.c
index c4dda150..657834ff 100644
--- a/src/libs/zbxdbhigh/db.c
+++ b/src/libs/zbxdbhigh/db.c
@@ -1341,14 +1341,14 @@ int	DBadd_history(zbx_uint64_t itemid, double value, int clock)
 	DBexecute("insert into history (clock,itemid,value) values (%d," ZBX_FS_UI64 ",%f)",
 		clock,itemid,value);
 
+	DBadd_trend(itemid, value, clock);
+
 	if(CONFIG_MASTER_NODEID>=0)
 	{
 		DBexecute("insert into history_sync (nodeid,clock,itemid,value) values (%d,%d," ZBX_FS_UI64 ",%f)",
 			get_nodeid_by_id(itemid),clock,itemid,value);
 	}
 
-	DBadd_trend(itemid, value, clock);
-
 	return SUCCEED;
 }
 
@@ -1361,6 +1361,12 @@ int	DBadd_history_uint(zbx_uint64_t itemid, zbx_uint64_t value, int clock)
 
 	DBadd_trend(itemid, (double)value, clock);
 
+	if(CONFIG_MASTER_NODEID>=0)
+	{
+		DBexecute("insert into history_uint_sync (nodeid,clock,itemid,value) values (%d,%d," ZBX_FS_UI64 "," ZBX_FS_UI64 ")",
+			get_nodeid_by_id(itemid),clock,itemid,value);
+	}
+
 	return SUCCEED;
 }
 
@@ -1374,6 +1380,12 @@ int	DBadd_history_str(zbx_uint64_t itemid, char *value, int clock)
 	DBexecute("insert into history_str (clock,itemid,value) values (%d," ZBX_FS_UI64 ",'%s')",
 		clock,itemid,value_esc);
 
+	if(CONFIG_MASTER_NODEID>=0)
+	{
+		DBexecute("insert into history_str_sync (nodeid,clock,itemid,value) values (%d,%d," ZBX_FS_UI64 ",'%s')",
+			get_nodeid_by_id(itemid),clock,itemid,value_esc);
+	}
+
 	return SUCCEED;
 }