diff options
| author | Felföldi Zsolt <zsfelfoldi@gmail.com> | 2018-06-12 19:00:52 +0800 |
|---|---|---|
| committer | Péter Szilágyi <peterke@gmail.com> | 2018-06-12 19:00:52 +0800 |
| commit | 546d42179e7c121b4c3aeeec5ab71a3c112e7a64 (patch) | |
| tree | ec8db9b9127e86f439af6a856ad6c0ab56c060fa /les/handler.go | |
| parent | f991995918899c48cc89c4d4ec4329bb4a7ce108 (diff) | |
| download | go-tangerine-546d42179e7c121b4c3aeeec5ab71a3c112e7a64.tar.gz go-tangerine-546d42179e7c121b4c3aeeec5ab71a3c112e7a64.tar.zst go-tangerine-546d42179e7c121b4c3aeeec5ab71a3c112e7a64.zip | |
les: pass server pool to protocol manager (#16947)
Diffstat (limited to 'les/handler.go')
| -rw-r--r-- | les/handler.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/les/handler.go b/les/handler.go index 1b6916578..38f810d72 100644 --- a/les/handler.go +++ b/les/handler.go @@ -129,7 +129,7 @@ type ProtocolManager struct { // NewProtocolManager returns a new ethereum sub protocol manager. The Ethereum sub protocol manages peers capable // with the ethereum network. -func NewProtocolManager(chainConfig *params.ChainConfig, lightSync bool, protocolVersions []uint, networkId uint64, mux *event.TypeMux, engine consensus.Engine, peers *peerSet, blockchain BlockChain, txpool txPool, chainDb ethdb.Database, odr *LesOdr, txrelay *LesTxRelay, quitSync chan struct{}, wg *sync.WaitGroup) (*ProtocolManager, error) { +func NewProtocolManager(chainConfig *params.ChainConfig, lightSync bool, protocolVersions []uint, networkId uint64, mux *event.TypeMux, engine consensus.Engine, peers *peerSet, blockchain BlockChain, txpool txPool, chainDb ethdb.Database, odr *LesOdr, txrelay *LesTxRelay, serverPool *serverPool, quitSync chan struct{}, wg *sync.WaitGroup) (*ProtocolManager, error) { // Create the protocol manager with the base fields manager := &ProtocolManager{ lightSync: lightSync, @@ -141,6 +141,7 @@ func NewProtocolManager(chainConfig *params.ChainConfig, lightSync bool, protoco networkId: networkId, txpool: txpool, txrelay: txrelay, + serverPool: serverPool, peers: peers, newPeerCh: make(chan *peer), quitSync: quitSync, |