()
| 44 | } |
| 45 | |
| 46 | func NewNodeStatusExecutor() *NodeStatusExecutor { |
| 47 | return &NodeStatusExecutor{ |
| 48 | ticker: time.NewTicker(30 * time.Second), |
| 49 | apiCallStat: rpc.NewCallStat(10), |
| 50 | |
| 51 | lastUDPInDatagrams: -1, |
| 52 | lastUDPOutDatagrams: -1, |
| 53 | } |
| 54 | } |
| 55 | |
| 56 | func (this *NodeStatusExecutor) Listen() { |
| 57 | this.isFirstTime = true |