diff options
author | obscuren <geffobscura@gmail.com> | 2015-03-21 21:36:20 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2015-03-21 21:36:20 +0800 |
commit | 06697775d1edc3263a7915cee02a94bea488494c (patch) | |
tree | 1d39f205327ee47115a7fe2947ccd5a4ba7a4073 /whisper/peer.go | |
parent | abce6804a085087770be587e039fd4669d5eac26 (diff) | |
parent | 069c87b960c48864dc4f1b9086adf582e1dc88a9 (diff) | |
download | go-tangerine-06697775d1edc3263a7915cee02a94bea488494c.tar go-tangerine-06697775d1edc3263a7915cee02a94bea488494c.tar.gz go-tangerine-06697775d1edc3263a7915cee02a94bea488494c.tar.bz2 go-tangerine-06697775d1edc3263a7915cee02a94bea488494c.tar.lz go-tangerine-06697775d1edc3263a7915cee02a94bea488494c.tar.xz go-tangerine-06697775d1edc3263a7915cee02a94bea488494c.tar.zst go-tangerine-06697775d1edc3263a7915cee02a94bea488494c.zip |
Merge branch 'conversion' of github.com-obscure:ethereum/go-ethereum into conversion
Diffstat (limited to 'whisper/peer.go')
-rw-r--r-- | whisper/peer.go | 21 |
1 files changed, 9 insertions, 12 deletions
diff --git a/whisper/peer.go b/whisper/peer.go index ee5bffd0b..338166c25 100644 --- a/whisper/peer.go +++ b/whisper/peer.go @@ -10,7 +10,7 @@ import ( ) const ( - protocolVersion = 0x02 + protocolVersion uint64 = 0x02 ) type peer struct { @@ -66,21 +66,18 @@ out: } func (self *peer) broadcast(envelopes []*Envelope) error { - envs := make([]interface{}, len(envelopes)) - i := 0 - for _, envelope := range envelopes { - if !self.known.Has(envelope.Hash()) { - envs[i] = envelope - self.known.Add(envelope.Hash()) - i++ + envs := make([]*Envelope, 0, len(envelopes)) + for _, env := range envelopes { + if !self.known.Has(env.Hash()) { + envs = append(envs, env) + self.known.Add(env.Hash()) } } - - if i > 0 { - if err := p2p.Send(self.ws, envelopesMsg, envs[:i]); err != nil { + if len(envs) > 0 { + if err := p2p.Send(self.ws, envelopesMsg, envs); err != nil { return err } - self.peer.DebugDetailln("broadcasted", i, "message(s)") + self.peer.DebugDetailln("broadcasted", len(envs), "message(s)") } return nil } |