Commit f6e5bd71beb6a671e40fb4634d1c20511cb53fe0
1 parent
66277927bc
Exists in
master
isPartnerHealthy update matrix
Showing 1 changed file with 21 additions and 1 deletions Side-by-side Diff
matrix-util.js
... | ... | @@ -110,7 +110,7 @@ MatrixUtil.prototype.isPartnerOffline = function(partner) { |
110 | 110 | return true; |
111 | 111 | } |
112 | 112 | |
113 | -MatrixUtil.prototype.isPartnerHealthy = function(partner) { | |
113 | +MatrixUtil.prototype._isPartnerHealthy = function(partner) { | |
114 | 114 | if (!partner) { return; } |
115 | 115 | partner = _cleanPartnerId(partner); |
116 | 116 | |
... | ... | @@ -135,6 +135,26 @@ MatrixUtil.prototype.isPartnerHealthy = function(partner) { |
135 | 135 | return isHealthy; |
136 | 136 | } |
137 | 137 | |
138 | +MatrixUtil.prototype.isPartnerHealthy = function(partner) { | |
139 | + let isHealthy = this._isPartnerHealthy(partner); | |
140 | + | |
141 | + if (!matrix.healthy_partners) { | |
142 | + matrix.healthy_partners = []; | |
143 | + } | |
144 | + | |
145 | + // update matrix | |
146 | + if (isHealthy) { | |
147 | + matrix.healthy_partners.push(partner); | |
148 | + } | |
149 | + else { | |
150 | + let idx = matrix.healthy_partners.indexOf(partner); | |
151 | + if (idx > -1) { | |
152 | + matrix.healthy_partners.splice(idx, 1); | |
153 | + } | |
154 | + } | |
155 | + | |
156 | + return isHealthy; | |
157 | +} | |
138 | 158 | |
139 | 159 | MatrixUtil.prototype._updateLastResponseTime = function(partner) { |
140 | 160 | let matrix = this.matrix; |