This commit is contained in:
wanwiset25 2024-05-17 20:33:46 +04:00
parent 1bdf53662e
commit c72aabbac1
2 changed files with 0 additions and 11 deletions

View file

@ -112,7 +112,6 @@ func New(ctx *node.ServiceContext, config *ethconfig.Config) (*LightEthereum, er
}
leth.relay = NewLesTxRelay(peers, leth.reqDist)
leth.serverPool = newServerPool(chainDb, quitSync, &leth.wg)
leth.retriever = newRetrieveManager(peers, leth.reqDist, leth.serverPool)
leth.odr = NewLesOdr(chainDb, leth.chtIndexer, leth.bloomTrieIndexer, leth.bloomIndexer, leth.retriever)
if leth.blockchain, err = light.NewLightChain(leth.odr, leth.chainConfig, leth.engine); err != nil {

View file

@ -269,16 +269,6 @@ func (c *conn) set(f connFlag, val bool) {
atomic.StoreInt32((*int32)(&c.flags), int32(flags))
}
func (c *conn) set(f connFlag, val bool) {
flags := connFlag(atomic.LoadInt32((*int32)(&c.flags)))
if val {
flags |= f
} else {
flags &= ^f
}
atomic.StoreInt32((*int32)(&c.flags), int32(flags))
}
// Peers returns all connected peers.
func (srv *Server) Peers() []*Peer {
var ps []*Peer