|
@ -176,10 +176,7 @@ func (sw *Switch) OnStart() error { |
|
|
return err |
|
|
return err |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|
// Start peers
|
|
|
|
|
|
for _, peer := range sw.peers.List() { |
|
|
|
|
|
sw.startInitPeer(peer) |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
// Start listeners
|
|
|
// Start listeners
|
|
|
for _, listener := range sw.listeners { |
|
|
for _, listener := range sw.listeners { |
|
|
go sw.listenerRoutine(listener) |
|
|
go sw.listenerRoutine(listener) |
|
|