SetNodeId set a new node id
(nodeId uint64)
| 171 | |
| 172 | //SetNodeId set a new node id |
| 173 | func (this *SyncFlightInfo) SetNodeId(nodeId uint64) { |
| 174 | this.lock.Lock() |
| 175 | defer this.lock.Unlock() |
| 176 | this.nodeId = nodeId |
| 177 | } |
| 178 | |
| 179 | //MarkFailedNode mark node failed, after request timeout |
| 180 | func (this *SyncFlightInfo) MarkFailedNode() { |