|
|
@ -732,28 +732,13 @@ namespace data |
|
|
|
if (!replyMsg) |
|
|
|
if (!replyMsg) |
|
|
|
{ |
|
|
|
{ |
|
|
|
LogPrint ("Requested ", key, " not found. ", numExcluded, " excluded"); |
|
|
|
LogPrint ("Requested ", key, " not found. ", numExcluded, " excluded"); |
|
|
|
std::vector<IdentHash> routers; |
|
|
|
|
|
|
|
if (numExcluded > 0) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
std::set<IdentHash> excludedRouters; |
|
|
|
std::set<IdentHash> excludedRouters; |
|
|
|
for (int i = 0; i < numExcluded; i++) |
|
|
|
for (int i = 0; i < numExcluded; i++) |
|
|
|
{ |
|
|
|
{ |
|
|
|
excludedRouters.insert (excluded); |
|
|
|
excludedRouters.insert (excluded); |
|
|
|
excluded += 32; |
|
|
|
excluded += 32; |
|
|
|
} |
|
|
|
} |
|
|
|
for (int i = 0; i < 3; i++) |
|
|
|
replyMsg = CreateDatabaseSearchReply (ident, GetClosestFloodfills (ident, 3, excludedRouters)); |
|
|
|
{ |
|
|
|
|
|
|
|
auto floodfill = GetClosestFloodfill (ident, excludedRouters); |
|
|
|
|
|
|
|
if (floodfill) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
routers.push_back (floodfill->GetIdentHash ()); |
|
|
|
|
|
|
|
excludedRouters.insert (floodfill->GetIdentHash ()); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
else |
|
|
|
|
|
|
|
routers = GetClosestFloodfills (ident, 3); |
|
|
|
|
|
|
|
replyMsg = CreateDatabaseSearchReply (ident, routers); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
@ -955,7 +940,8 @@ namespace data |
|
|
|
return r; |
|
|
|
return r; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
std::vector<IdentHash> NetDb::GetClosestFloodfills (const IdentHash& destination, size_t num) const |
|
|
|
std::vector<IdentHash> NetDb::GetClosestFloodfills (const IdentHash& destination, size_t num, |
|
|
|
|
|
|
|
std::set<IdentHash>& excluded) const |
|
|
|
{ |
|
|
|
{ |
|
|
|
struct Sorted |
|
|
|
struct Sorted |
|
|
|
{ |
|
|
|
{ |
|
|
@ -990,9 +976,13 @@ namespace data |
|
|
|
{ |
|
|
|
{ |
|
|
|
if (i < num) |
|
|
|
if (i < num) |
|
|
|
{ |
|
|
|
{ |
|
|
|
res.push_back (it.r->GetIdentHash ()); |
|
|
|
auto& ident = it.r->GetIdentHash (); |
|
|
|
|
|
|
|
if (!excluded.count (ident)) |
|
|
|
|
|
|
|
{ |
|
|
|
|
|
|
|
res.push_back (ident); |
|
|
|
i++; |
|
|
|
i++; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} |
|
|
|
else |
|
|
|
else |
|
|
|
break; |
|
|
|
break; |
|
|
|
} |
|
|
|
} |
|
|
|