aboutsummaryrefslogtreecommitdiffstats
path: root/les/handler.go
diff options
context:
space:
mode:
authorFelföldi Zsolt <zsfelfoldi@gmail.com>2018-06-12 19:00:52 +0800
committerPéter Szilágyi <peterke@gmail.com>2018-06-12 19:00:52 +0800
commit546d42179e7c121b4c3aeeec5ab71a3c112e7a64 (patch)
treeec8db9b9127e86f439af6a856ad6c0ab56c060fa /les/handler.go
parentf991995918899c48cc89c4d4ec4329bb4a7ce108 (diff)
downloaddexon-546d42179e7c121b4c3aeeec5ab71a3c112e7a64.tar.gz
dexon-546d42179e7c121b4c3aeeec5ab71a3c112e7a64.tar.zst
dexon-546d42179e7c121b4c3aeeec5ab71a3c112e7a64.zip
les: pass server pool to protocol manager (#16947)
Diffstat (limited to 'les/handler.go')
-rw-r--r--les/handler.go3
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,