You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@trafodion.apache.org by su...@apache.org on 2017/09/19 02:54:40 UTC

[3/4] incubator-trafodion git commit: [TRAFODION-2651] Fixed monitor-to-monitor communication by adding reconnect logic to better handle various communication glitches which previously resulted in false node down situations.

[TRAFODION-2651] Fixed monitor-to-monitor communication by adding reconnect
logic to better handle various communication glitches which previously
resulted in false node down situations.


Project: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/commit/5e09a1e3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/tree/5e09a1e3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/diff/5e09a1e3

Branch: refs/heads/master
Commit: 5e09a1e3a41d81394a0beee7eb67f7475a344daf
Parents: cd54195
Author: Zalo Correa <za...@esgyn.com>
Authored: Fri Sep 15 15:39:06 2017 -0700
Committer: Zalo Correa <za...@esgyn.com>
Committed: Fri Sep 15 15:39:06 2017 -0700

----------------------------------------------------------------------
 .../export/include/common/evl_sqlog_eventnum.h  |   28 +-
 core/sqf/monitor/linux/cluster.cxx              | 1851 +++++++++++++++---
 core/sqf/monitor/linux/cluster.h                |   38 +-
 core/sqf/monitor/linux/commaccept.cxx           |  126 +-
 core/sqf/monitor/linux/internal.h               |    3 +
 core/sqf/monitor/linux/msgdef.h                 |    2 +
 core/sqf/monitor/linux/pnode.cxx                |   20 +-
 core/sqf/monitor/linux/pnode.h                  |    3 +
 core/sqf/monitor/linux/reqtmleader.cxx          |   19 +
 core/sqf/monitor/linux/shell.cxx                |   26 +-
 core/sqf/monitor/linux/tmsync.cxx               |   14 +-
 core/sqf/monitor/linux/tmsync.h                 |    2 +-
 core/sqf/monitor/linux/zclient.cxx              |    8 +
 core/sqf/sqenvcom.sh                            |   11 +-
 14 files changed, 1805 insertions(+), 346 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-trafodion/blob/5e09a1e3/core/sqf/export/include/common/evl_sqlog_eventnum.h
----------------------------------------------------------------------
diff --git a/core/sqf/export/include/common/evl_sqlog_eventnum.h b/core/sqf/export/include/common/evl_sqlog_eventnum.h
index dbf8d92..c8b4d59 100644
--- a/core/sqf/export/include/common/evl_sqlog_eventnum.h
+++ b/core/sqf/export/include/common/evl_sqlog_eventnum.h
@@ -143,6 +143,7 @@
 #define MON_CLUSTER_ALLGATHERSOCK_5         101013305
 #define MON_CLUSTER_ALLGATHERSOCK_6         101013306
 #define MON_CLUSTER_ALLGATHERSOCK_7         101013307
+#define MON_CLUSTER_ALLGATHERSOCK_8         101013308
 #define MON_CLUSTER_EPOLLCTL_1              101013401
 #define MON_CLUSTER_INITCLUSTERSOCKS_1      101013501
 #define MON_CLUSTER_INITCLUSTERSOCKS_2      101013502
@@ -158,6 +159,10 @@
 #define MON_CLUSTER_MKSRVSOCK_2             101013702
 #define MON_CLUSTER_MKSRVSOCK_3             101013703
 #define MON_CLUSTER_MKSRVSOCK_4             101013704
+#define MON_CLUSTER_MKSRVSOCK_5             101013705
+#define MON_CLUSTER_MKSRVSOCK_6             101013706
+#define MON_CLUSTER_MKSRVSOCK_7             101013707
+#define MON_CLUSTER_MKSRVSOCK_8             101013708
 #define MON_CLUSTER_MKCLTSOCK_1             101013801
 #define MON_CLUSTER_MKCLTSOCK_2             101013802
 #define MON_CLUSTER_MKCLTSOCK_3             101013803
@@ -167,6 +172,9 @@
 #define MON_CLUSTER_MKCLTSOCK_7             101013807
 #define MON_CLUSTER_MKCLTSOCK_8             101013808
 #define MON_CLUSTER_MKCLTSOCK_9             101013809
+#define MON_CLUSTER_MKCLTSOCK_10            101013810
+#define MON_CLUSTER_MKCLTSOCK_11            101013811
+#define MON_CLUSTER_MKCLTSOCK_12            101013812
 #define MON_CLUSTER_CONNECT_1               101013901
 #define MON_CLUSTER_CONNECT_2               101013902
 #define MON_CLUSTER_CONNECT_3               101013903
@@ -190,8 +198,23 @@
 #define MON_CLUSTER_SETKEEPALIVESOCKOPT_2   101014502
 #define MON_CLUSTER_SETKEEPALIVESOCKOPT_3   101014503
 #define MON_CLUSTER_SETKEEPALIVESOCKOPT_4   101014504
-#define MON_CLUSTER_HARDNODEUP_1            101014601
-#define MON_CLUSTER_NO_LICENSE_VERIFIERS    101015001
+#define MON_CLUSTER_NO_LICENSE_VERIFIERS    101014601
+
+#define MON_CLUSTER_ALLGATHERSOCKRECONN_1   101014701
+
+#define MON_CLUSTER_HARDNODEUP_1            101014801
+
+#define MON_CLUSTER_ACCEPTSOCKPEER_1        101014901
+#define MON_CLUSTER_ACCEPTSOCKPEER_2        101014902
+
+#define MON_CLUSTER_CONNECTSOCKPEER_1       101015001
+#define MON_CLUSTER_CONNECTSOCKPEER_2       101015002
+#define MON_CLUSTER_CONNECTSOCKPEER_3       101015003
+
+#define MON_CLUSTER_EPOLLCTLDELETE_1        101015101
+
+#define MON_PINGSOCKPEER_1                  101015201
+#define MON_PINGSOCKPEER_2                  101015202
 
 /* Module: monitor.cxx = 02 */
 
@@ -800,6 +823,7 @@
 #define MON_COMMACCEPT_16                   101320116
 #define MON_COMMACCEPT_17                   101320117
 #define MON_COMMACCEPT_18                   101320118
+#define MON_COMMACCEPT_19                   101320119
 
 /* Module: reqnodedown.cxx = 33 */
 #define MON_EXT_NODEDOWN_REQ                101330101