Skip to content
This repository was archived by the owner on May 16, 2019. It is now read-only.

Commit 41f83b6

Browse files
committed
Restrict size of inv and values packets
1 parent 94c6205 commit 41f83b6

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

dht/protocol.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,7 @@ def rpc_inv(self, sender, *serlialized_invs):
128128

129129
def rpc_values(self, sender, *serialized_values):
130130
self.addToRouter(sender)
131-
for val in serialized_values:
131+
for val in serialized_values[:100]:
132132
try:
133133
v = objects.Value()
134134
v.ParseFromString(val)
@@ -215,7 +215,7 @@ def send_values(inv_list):
215215
i.valueKey = k
216216
inv.append(i.SerializeToString())
217217
if len(inv) > 0:
218-
self.callInv(node, inv).addCallback(send_values)
218+
self.callInv(node, inv[:100]).addCallback(send_values)
219219

220220
def handleCallResponse(self, result, node):
221221
"""

0 commit comments

Comments
 (0)