forked from I2P_Developers/i2p.i2p
Compare commits
1 Commits
i2p.i2p.2.
...
i2p.i2p.2.
Author | SHA1 | Date | |
---|---|---|---|
fdb09dbe41 |
@ -1083,13 +1083,13 @@
|
|||||||
</or>
|
</or>
|
||||||
</condition>
|
</condition>
|
||||||
</fail>
|
</fail>
|
||||||
<fail message="Non-zero build number: ${i2p.build.number}" >
|
<!--<fail message="Non-zero build number: ${i2p.build.number}" >
|
||||||
<condition>
|
<condition>
|
||||||
<not>
|
<not>
|
||||||
<equals arg1="${i2p.build.number}" arg2="0"/>
|
<equals arg1="${i2p.build.number}" arg2="0"/>
|
||||||
</not>
|
</not>
|
||||||
</condition>
|
</condition>
|
||||||
</fail>
|
</fail>-->
|
||||||
<fail message="Non-empty extra build: ${build.extra}" >
|
<fail message="Non-empty extra build: ${build.extra}" >
|
||||||
<condition>
|
<condition>
|
||||||
<not>
|
<not>
|
||||||
|
@ -47,7 +47,7 @@ class InboundMessageDistributor implements GarlicMessageReceiver.CloveReceiver {
|
|||||||
// all createRateStat in TunnelDispatcher
|
// all createRateStat in TunnelDispatcher
|
||||||
|
|
||||||
if (_client != null) {
|
if (_client != null) {
|
||||||
TunnelPoolSettings clienttps = _context.tunnelManager().getInboundSettings(_client);
|
TunnelPoolSettings clienttps = getTunnelPoolSettings(_client);
|
||||||
if (_log.shouldLog(Log.DEBUG))
|
if (_log.shouldLog(Log.DEBUG))
|
||||||
_log.debug("Initializing client (nickname: "
|
_log.debug("Initializing client (nickname: "
|
||||||
+ clienttps.getDestinationNickname()
|
+ clienttps.getDestinationNickname()
|
||||||
@ -63,6 +63,21 @@ class InboundMessageDistributor implements GarlicMessageReceiver.CloveReceiver {
|
|||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public TunnelPoolSettings getTunnelPoolSettings(Hash _client) {
|
||||||
|
TunnelPoolSettings clienttps = _context.tunnelManager().getInboundSettings(_client);
|
||||||
|
int i = 0;
|
||||||
|
while (clienttps == null) {
|
||||||
|
i++;
|
||||||
|
try {
|
||||||
|
Thread.sleep(100);
|
||||||
|
} catch (InterruptedException ie) {}
|
||||||
|
if (_log.shouldLog(Log.DEBUG))
|
||||||
|
_log.debug("Waiting for tunnel settings for " + _client.toBase32() + " (" + i*100 + " milliseconds)");
|
||||||
|
clienttps = _context.tunnelManager().getInboundSettings(_client);
|
||||||
|
}
|
||||||
|
return clienttps;
|
||||||
|
}
|
||||||
|
|
||||||
public void distribute(I2NPMessage msg, Hash target) {
|
public void distribute(I2NPMessage msg, Hash target) {
|
||||||
distribute(msg, target, null);
|
distribute(msg, target, null);
|
||||||
|
Reference in New Issue
Block a user