|
|
@ -262,7 +262,7 @@ func (self *Whisper) add(envelope *Envelope) error { |
|
|
|
// Insert the message into the tracked pool
|
|
|
|
// Insert the message into the tracked pool
|
|
|
|
hash := envelope.Hash() |
|
|
|
hash := envelope.Hash() |
|
|
|
if _, ok := self.messages[hash]; ok { |
|
|
|
if _, ok := self.messages[hash]; ok { |
|
|
|
log.Trace(fmt.Sprintf("whisper envelope already cached: %x\n", envelope)) |
|
|
|
log.Trace(fmt.Sprintf("whisper envelope already cached: %x\n", hash)) |
|
|
|
return nil |
|
|
|
return nil |
|
|
|
} |
|
|
|
} |
|
|
|
self.messages[hash] = envelope |
|
|
|
self.messages[hash] = envelope |
|
|
@ -277,7 +277,7 @@ func (self *Whisper) add(envelope *Envelope) error { |
|
|
|
// Notify the local node of a message arrival
|
|
|
|
// Notify the local node of a message arrival
|
|
|
|
go self.postEvent(envelope) |
|
|
|
go self.postEvent(envelope) |
|
|
|
} |
|
|
|
} |
|
|
|
log.Trace(fmt.Sprintf("cached whisper envelope %x\n", envelope)) |
|
|
|
log.Trace(fmt.Sprintf("cached whisper envelope %x\n", hash)) |
|
|
|
return nil |
|
|
|
return nil |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|