aboutsummaryrefslogtreecommitdiffstats
path: root/whisper/peer.go
diff options
context:
space:
mode:
authorPéter Szilágyi <peterke@gmail.com>2015-04-22 22:40:39 +0800
committerPéter Szilágyi <peterke@gmail.com>2015-04-28 15:49:05 +0800
commit406e74e2afdce374fd227873f4eb96a0ba99bd23 (patch)
treeaf605ae0512e7dab0802f0f8ebebe2e02f2798c1 /whisper/peer.go
parent70ded4cbf06d19993d829d843a27002cf181c619 (diff)
downloaddexon-406e74e2afdce374fd227873f4eb96a0ba99bd23.tar.gz
dexon-406e74e2afdce374fd227873f4eb96a0ba99bd23.tar.zst
dexon-406e74e2afdce374fd227873f4eb96a0ba99bd23.zip
whisper: fix a small data race duirng peer connection
Diffstat (limited to 'whisper/peer.go')
-rw-r--r--whisper/peer.go8
1 files changed, 2 insertions, 6 deletions
diff --git a/whisper/peer.go b/whisper/peer.go
index 28abf4260..77e09bece 100644
--- a/whisper/peer.go
+++ b/whisper/peer.go
@@ -23,18 +23,14 @@ type peer struct {
// newPeer creates and initializes a new whisper peer connection, returning either
// the newly constructed link or a failure reason.
-func newPeer(host *Whisper, remote *p2p.Peer, rw p2p.MsgReadWriter) (*peer, error) {
- p := &peer{
+func newPeer(host *Whisper, remote *p2p.Peer, rw p2p.MsgReadWriter) *peer {
+ return &peer{
host: host,
peer: remote,
ws: rw,
known: set.New(),
quit: make(chan struct{}),
}
- if err := p.handshake(); err != nil {
- return nil, err
- }
- return p, nil
}
// start initiates the peer updater, periodically broadcasting the whisper packets