mirror of https://github.com/zlatinb/muwire
introduce a multiplicative factor to the probability of forwarding a query
parent
b0b129f679
commit
43e48dd144
|
@ -17,6 +17,8 @@ import net.i2p.data.Destination
|
||||||
@Log
|
@Log
|
||||||
class UltrapeerConnectionManager extends ConnectionManager {
|
class UltrapeerConnectionManager extends ConnectionManager {
|
||||||
|
|
||||||
|
private static final int QUERY_FACTOR = 2
|
||||||
|
|
||||||
final int maxPeers, maxLeafs
|
final int maxPeers, maxLeafs
|
||||||
final TrustService trustService
|
final TrustService trustService
|
||||||
final ResponderCache responderCache
|
final ResponderCache responderCache
|
||||||
|
@ -52,7 +54,7 @@ class UltrapeerConnectionManager extends ConnectionManager {
|
||||||
final int connCount = peerConnections.size()
|
final int connCount = peerConnections.size()
|
||||||
if (connCount == 0)
|
if (connCount == 0)
|
||||||
return
|
return
|
||||||
final int treshold = (int)(Math.sqrt(connCount)) + 1
|
final int treshold = QUERY_FACTOR * ((int)(Math.sqrt(connCount)) + 1)
|
||||||
peerConnections.values().each {
|
peerConnections.values().each {
|
||||||
// 1. do not send query back to originator
|
// 1. do not send query back to originator
|
||||||
// 2. if firstHop forward to everyone
|
// 2. if firstHop forward to everyone
|
||||||
|
|
Loading…
Reference in New Issue