Commit a0a70ded authored by QM's avatar QM

fix

parent 16f6e293
...@@ -476,6 +476,7 @@ func (ethRelayer *Relayer4Ethereum) proc() { ...@@ -476,6 +476,7 @@ func (ethRelayer *Relayer4Ethereum) proc() {
ethRelayer.rwLock.RUnlock() ethRelayer.rwLock.RUnlock()
if nil != privateKey4Ethereum && nilAddr != ethRelayer.bridgeRegistryAddr { if nil != privateKey4Ethereum && nilAddr != ethRelayer.bridgeRegistryAddr {
relayerLog.Info("Ethereum relayer starts to run...") relayerLog.Info("Ethereum relayer starts to run...")
timer = time.NewTicker(time.Duration(ethRelayer.fetchHeightPeriodMs) * time.Millisecond)
if ethRelayer.processWithDraw { if ethRelayer.processWithDraw {
//对于是提币代理中继器,则不需要订阅相关的日志事件 //对于是提币代理中继器,则不需要订阅相关的日志事件
goto withdrawProc goto withdrawProc
...@@ -485,7 +486,6 @@ func (ethRelayer *Relayer4Ethereum) proc() { ...@@ -485,7 +486,6 @@ func (ethRelayer *Relayer4Ethereum) proc() {
ethRelayer.subscribeEvent() ethRelayer.subscribeEvent()
ethRelayer.filterLogEvents() ethRelayer.filterLogEvents()
relayerLog.Info("Ethereum relayer starts to process online log event...") relayerLog.Info("Ethereum relayer starts to process online log event...")
timer = time.NewTicker(time.Duration(ethRelayer.fetchHeightPeriodMs) * time.Millisecond)
goto burnLockProc goto burnLockProc
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment