forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-22 12:46:44 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

optimize section reactivation

Browse source
This commit is contained in:
zelig 2015-01-05 04:03:57 +00:00
parent 1278173372
commit 89763b33a7
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
eth/block_pool.go
View file

@ -527,9 +527,11 @@ func (self *BlockPool) activateChain(section *section, peer *peerInfo) {
i := 0 i := 0
LOOP: LOOP:
for section != nil { for section != nil {
// register this section with the peer // register this section with the peer and quit if registered
poolLogger.Debugf("[%s] register section with peer %s", sectionName(section), peer.id) poolLogger.Debugf("[%s] register section with peer %s", sectionName(section), peer.id)
peer.addSection(section.top.hash, section) if peer.addSection(section.top.hash, section) == section {
return
}
poolLogger.Debugf("[%s] activate section process", sectionName(section)) poolLogger.Debugf("[%s] activate section process", sectionName(section))
select { select {
case section.controlC <- peer: case section.controlC <- peer:
@ -947,11 +949,14 @@ func (self *BlockPool) getPeer(peerId string) (*peerInfo, bool) {
return info, false return info, false
} }
func (self *peerInfo) addSection(hash []byte, section *section) { func (self *peerInfo) addSection(hash []byte, section *section) (found *section) {
self.lock.Lock() self.lock.Lock()
defer self.lock.Unlock() defer self.lock.Unlock()
key := string(hash)
found = self.sections[key]
poolLogger.Debugf("section process %s added to %s", sectionName(section), self.id) poolLogger.Debugf("section process %s added to %s", sectionName(section), self.id)
self.sections[string(hash)] = section self.sections[key] = section
return
} }
func (self *BlockPool) switchPeer(oldPeer, newPeer *peerInfo) { func (self *BlockPool) switchPeer(oldPeer, newPeer *peerInfo) {