From 334c01f5c99b23a20b300e4be4e48cbb2f5d96a9 Mon Sep 17 00:00:00 2001
From: =?utf8?q?Tom=C3=A1=C5=A1=20Brada?= <tomasbrod@azet.sk>
Date: Thu, 17 Dec 2015 19:49:56 +0100
Subject: [PATCH] DHT: Try to always send 4 Selects

---
 dht.pas | 12 +++++++++++-
 1 file changed, 11 insertions(+), 1 deletion(-)

diff --git a/dht.pas b/dht.pas
index 44d7e56..fcfd124 100644
--- a/dht.pas
+++ b/dht.pas
@@ -228,12 +228,14 @@ procedure RecvRequest(msg:tSMsg);
  var caps:byte;
  var r:tMemoryStream;
  var bkt:^tBucket;
- var i:byte;
+ var i,li:byte;
+ var SendCnt:byte;
  begin
  s.skip(1);
  hID:=s.ReadPtr(20);
  rID:=s.ReadPtr(20);
  caps:=s.ReadByte;
+ SendCnt:=0;
  //writeln('DHT: ',string(msg.source^),' Request for ',string(rID^));
  UpdateNode(hID^,msg.source^);
  {Select peers only from The bucket,
@@ -253,6 +255,14 @@ procedure RecvRequest(msg:tSMsg);
    if bkt^.peer[i].ReqDelta>1 then continue;
    //writeln('-> Select to ',string(bkt^.peer[i].addr));
    SendMessage(r.base^,r.length,bkt^.peer[i].addr);
+   li:=i;
+   Inc(SendCnt);
+  end;
+  while SendCnt<4 do begin
+   GetNextNode(bkt,li,rID^,3);
+   if not assigned(bkt) then break;
+   SendMessage(r.base^,r.length,bkt^.peer[li].addr);
+   Inc(SendCnt);
   end;
   r.Seek(0);
   r.Trunc;
-- 
2.11.4.GIT