diff options
author | obscuren <geffobscura@gmail.com> | 2014-12-08 21:25:52 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2014-12-08 21:25:52 +0800 |
commit | 76842b0df8b5605682362bd57fbd6eb315bcaf1f (patch) | |
tree | 8671edce47cfc7212de29eaa200c96bd2c6e47ec /whisper/whisper.go | |
parent | e3a8412df3fe75fe498a3fce64fd2fd691a18183 (diff) | |
download | dexon-76842b0df8b5605682362bd57fbd6eb315bcaf1f.tar dexon-76842b0df8b5605682362bd57fbd6eb315bcaf1f.tar.gz dexon-76842b0df8b5605682362bd57fbd6eb315bcaf1f.tar.bz2 dexon-76842b0df8b5605682362bd57fbd6eb315bcaf1f.tar.lz dexon-76842b0df8b5605682362bd57fbd6eb315bcaf1f.tar.xz dexon-76842b0df8b5605682362bd57fbd6eb315bcaf1f.tar.zst dexon-76842b0df8b5605682362bd57fbd6eb315bcaf1f.zip |
Additional checks and debug output
Diffstat (limited to 'whisper/whisper.go')
-rw-r--r-- | whisper/whisper.go | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/whisper/whisper.go b/whisper/whisper.go index 255bd2152..78e4d4848 100644 --- a/whisper/whisper.go +++ b/whisper/whisper.go @@ -2,6 +2,7 @@ package whisper import ( "bytes" + "fmt" "sync" "time" @@ -34,6 +35,8 @@ const ( envelopesMsg = 0x01 ) +const defaultTtl = 50 * time.Second + type Whisper struct { pub, sec []byte protocol p2p.Protocol @@ -55,6 +58,8 @@ func New(pub, sec []byte) *Whisper { } go whisper.update() + whisper.Send(defaultTtl, nil, NewMessage([]byte("Hello world. This is whisper-go"))) + // p2p whisper sub protocol handler whisper.protocol = p2p.Protocol{ Name: "shh", @@ -102,6 +107,7 @@ func (self *Whisper) msgHandler(peer *p2p.Peer, ws p2p.MsgReadWriter) error { } self.add(envelope) + wpeer.addKnown(envelope) } } @@ -110,6 +116,7 @@ func (self *Whisper) add(envelope *Envelope) { self.mmu.Lock() defer self.mmu.Unlock() + fmt.Println("add", envelope) self.messages[envelope.Hash()] = envelope if self.expiry[envelope.Expiry] == nil { self.expiry[envelope.Expiry] = set.NewNonTS() |