forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-21 20:26:41 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Response propagation and timeout

Browse source
This commit is contained in:
Daniel A. Nagy 2015-02-06 15:49:37 +01:00
parent 5d5899ddef
commit 9f4e7db263
1 changed files with 24 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
bzz/netstore.go
View file

@ -158,7 +158,24 @@ func (self *netStore) addStoreRequest(req *storeRequestMsgData) {
}
func (self *netStore) propagateResponse(chunk *Chunk) {
// send chunk to first requesterCount peer of each Id
for id, requesters := range chunk.req.requesters {
counter = requesterCount
msg := &storeRequestMsgData{
Key: chunk.Key,
Data: chunk.Data,
Size: chunk.Size,
Id: id,
}
for _, req := range requesters {
if req.Timeout.After(time.Now()) {
go req.peer.store(msg)
counter--
if counter <= 0 {
break
}
}
}
}
}
func (self *netStore) addRetrieveRequest(req *retrieveRequestMsgData) {
@ -231,7 +248,12 @@ func (self *netStore) peers(req *retrieveRequestMsgData, chunk *Chunk, timeout t
}
func (self *netStore) searchTimeout(rs *requestStatus, req *retrieveRequestMsgData) (timeout time.Time) {
return
t := time.Now().Add(3 * time.Second)
if req.Timeout.Before(t) {
return req.Timeout
} else {
return t
}
}
// these should go to cademlia