MarkFailedNode mark node failed, after request timeout
()
| 178 | |
| 179 | //MarkFailedNode mark node failed, after request timeout |
| 180 | func (this *SyncFlightInfo) MarkFailedNode() { |
| 181 | this.lock.Lock() |
| 182 | defer this.lock.Unlock() |
| 183 | this.failedNodes[this.nodeId] += 1 |
| 184 | this.totalFailed++ |
| 185 | } |
| 186 | |
| 187 | //GetFailedTimes return failed times of a node |
| 188 | func (this *SyncFlightInfo) GetFailedTimes(nodeId uint64) int { |