|
|
@ -110,7 +110,6 @@ type Fetcher struct { |
|
|
|
notify chan *announce |
|
|
|
notify chan *announce |
|
|
|
inject chan *inject |
|
|
|
inject chan *inject |
|
|
|
|
|
|
|
|
|
|
|
blockFilter chan chan []*types.Block |
|
|
|
|
|
|
|
headerFilter chan chan *headerFilterTask |
|
|
|
headerFilter chan chan *headerFilterTask |
|
|
|
bodyFilter chan chan *bodyFilterTask |
|
|
|
bodyFilter chan chan *bodyFilterTask |
|
|
|
|
|
|
|
|
|
|
@ -150,7 +149,6 @@ func New(getBlock blockRetrievalFn, verifyHeader headerVerifierFn, broadcastBloc |
|
|
|
return &Fetcher{ |
|
|
|
return &Fetcher{ |
|
|
|
notify: make(chan *announce), |
|
|
|
notify: make(chan *announce), |
|
|
|
inject: make(chan *inject), |
|
|
|
inject: make(chan *inject), |
|
|
|
blockFilter: make(chan chan []*types.Block), |
|
|
|
|
|
|
|
headerFilter: make(chan chan *headerFilterTask), |
|
|
|
headerFilter: make(chan chan *headerFilterTask), |
|
|
|
bodyFilter: make(chan chan *bodyFilterTask), |
|
|
|
bodyFilter: make(chan chan *bodyFilterTask), |
|
|
|
done: make(chan common.Hash), |
|
|
|
done: make(chan common.Hash), |
|
|
|