SVN Commit by andreas: r4841 - branches/REL-1_4_0_PATCHES/pgadmin3/src/slony

Author: andreas
Date: 2005-12-12 11:37:05 +0000 (Mon, 12 Dec 2005)
New Revision: 4841

Modified:
branches/REL-1_4_0_PATCHES/pgadmin3/src/slony/slNode.cpp
Log:
fix slony node statistics

Modified: branches/REL-1_4_0_PATCHES/pgadmin3/src/slony/slNode.cpp
===================================================================
--- branches/REL-1_4_0_PATCHES/pgadmin3/src/slony/slNode.cpp 2005-12-12 11:36:44 UTC (rev 4840)
+++ branches/REL-1_4_0_PATCHES/pgadmin3/src/slony/slNode.cpp 2005-12-12 11:37:05 UTC (rev 4841)
@@ -171,7 +171,7 @@
wxT(" st_last_event_ts - st_last_received_ts AS eventlag,")
wxT(" ev_seqno, ev_type || ' ' || COALESCE(ev_data1, '') AS hanging\n")
wxT(" FROM ") + GetCluster()->GetSchemaPrefix() + wxT("sl_status\n")
- wxT(" LEFT JOIN ") + GetCluster()->GetSchemaPrefix() + wxT("sl_event ON ev_seqno=\n")
+ wxT(" LEFT JOIN ") + GetCluster()->GetSchemaPrefix() + wxT("sl_event ON ev_origin=st_origin AND ev_seqno=\n")
wxT(" (SELECT MIN(ev_seqno) FROM ") + GetCluster()->GetSchemaPrefix() + wxT("sl_event WHERE ev_seqno > st_last_received)\n")
wxT(" WHERE st_origin = ") + NumToStr(GetCluster()->GetLocalNodeID()) + wxT("\n")
wxT(" AND st_received = ") + NumToStr(GetSlId()));
@@ -331,7 +331,7 @@
wxT(" CASE WHEN st_lag_num_events > 0 THEN st_last_event_ts - st_last_received_ts END AS eventlag,")
wxT(" ev_seqno, ev_type || ' ' || COALESCE(ev_data1, '') AS hanging\n")
wxT(" FROM ") + GetCluster()->GetSchemaPrefix() + wxT("sl_status\n")
- wxT(" LEFT JOIN ") + GetCluster()->GetSchemaPrefix() + wxT("sl_event ON ev_seqno=\n")
+ wxT(" LEFT JOIN ") + GetCluster()->GetSchemaPrefix() + wxT("sl_event ON ev_origin=st_origin AND ev_seqno=\n")
wxT(" (SELECT MIN(ev_seqno) FROM ") + GetCluster()->GetSchemaPrefix() + wxT("sl_event WHERE ev_seqno > st_last_received)\n")
wxT(" WHERE st_origin = ") + NumToStr(GetCluster()->GetLocalNodeID()));