Commit 45fd1b8867b355cecf42dc71ba598af51cc4d977
1 parent
a86d71b5c7
Exists in
master
kesehatan tergantung dari last_incoming
Showing 1 changed file with 4 additions and 4 deletions Side-by-side Diff
matrix-util.js
... | ... | @@ -2,7 +2,7 @@ |
2 | 2 | |
3 | 3 | var moment = require('moment'); |
4 | 4 | var momentFormat = 'YYYY-MM-DD HH:mm:ss'; |
5 | -var maxHealthyWaitMs = 60 * 1000; | |
5 | +var maxHealthyWaitMs = 2 * 60 * 1000; | |
6 | 6 | |
7 | 7 | module.exports = MatrixUtil; |
8 | 8 | |
... | ... | @@ -125,10 +125,10 @@ MatrixUtil.prototype._isPartnerHealthy = function(partner) { |
125 | 125 | |
126 | 126 | if (!matrix.buddies[partner]) { return false; } |
127 | 127 | if (!matrix.buddies[partner]['waiting_for_response']) { return true; } |
128 | - if (!matrix.buddies[partner]['last_outgoing']) { return true; } | |
129 | - if (!matrix.buddies[partner]['last_outgoing']['last_update_ts']) { return true; } | |
128 | + if (!matrix.buddies[partner]['last_incoming']) { return false; } | |
129 | + if (!matrix.buddies[partner]['last_incoming']['last_update_ts']) { return false; } | |
130 | 130 | |
131 | - let delta = Date.now() - Number(matrix.buddies[partner]['last_outgoing']['last_update_ts']); | |
131 | + let delta = Date.now() - Number(matrix.buddies[partner]['last_incoming']['last_update_ts']); | |
132 | 132 | let isHealthy = delta <= maxHealthyWaitMs; |
133 | 133 | |
134 | 134 | logger.verbose('Partner healthy analized', {partner: partner, isHealthy: isHealthy, delta: delta, maxHealthyWaitMs: maxHealthyWaitMs}); |