forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-18 01:43:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/pss: WIP outbox

Browse source
This commit is contained in:
lash 2018-03-29 20:55:41 +02:00
parent f6d48fe564
commit 580d116704
1 changed files with 20 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
swarm/pss/pss.go
View file

@ -687,6 +687,12 @@ func (self *Pss) forward(msg *PssMsg) {
to := make([]byte, addressLength) to := make([]byte, addressLength)
copy(to[:len(msg.To)], msg.To) copy(to[:len(msg.To)], msg.To)
// message hash
digest, err := self.storeMsg(msg)
if err != nil {
log.Warn(fmt.Sprintf("could not store message %v to cache: %v", msg, err))
}
// send with kademlia // send with kademlia
// find the closest peer to the recipient and attempt to send // find the closest peer to the recipient and attempt to send
sent := 0 sent := 0
@ -822,3 +828,17 @@ func (self *Pss) isMsgExpired(msg *PssMsg) bool {
} }
return false return false
} }
func (self *Pss) isMsgExpired(msg *PssMsg) bool {
msgexp := time.Unix(int64(msg.Expire), 0)
// if msgexp.Before(time.Now()) {
// log.Trace("pss expired :/ ... dropping")
// return nil
// } else if msgexp.After(time.Now().Add(self.msgTTL)) {
// return errors.New("Invalid TTL")
// }
if msgexp.Before(time.Now()) || msgexp.After(time.Now().Add(self.msgTTL)) {
return true
}
return false
}