Bitmessage/MiNode
3
0
Fork 1
Code Pull Requests 9 Actions Activity

WIP: Update request time in vectors_requested to not re-request too often #16

Draft
lee.miller wants to merge 1 commits from lee.miller/MiNode:network into v0.3
pull from: lee.miller/MiNode:network
merge into: Bitmessage:v0.3
Conversation 0 Commits 1 Files Changed 1 +2 -2
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 1a2bcb7e33 - Show all commits

4
minode/connection.py
View File

@ -431,13 +431,13 @@ class ConnectionBase(threading.Thread):
self.send_queue.put(message.GetData(pack)) self.send_queue.put(message.GetData(pack))
self.vectors_requested.update({ self.vectors_requested.update({
vector: time.time() for vector in pack vector: time.time() for vector in pack
if vector not in self.vectors_requested}) })
self.vectors_to_get.difference_update(pack) self.vectors_to_get.difference_update(pack)
else: else:
self.send_queue.put(message.GetData(self.vectors_to_get)) self.send_queue.put(message.GetData(self.vectors_to_get))
self.vectors_requested.update({ self.vectors_requested.update({
vector: time.time() for vector in self.vectors_to_get vector: time.time() for vector in self.vectors_to_get
if vector not in self.vectors_requested}) })
self.vectors_to_get.clear() self.vectors_to_get.clear()
if self.vectors_requested: if self.vectors_requested:
self.vectors_requested = { self.vectors_requested = {