forked from I2P_Developers/i2p.i2p
;; -> ;
This commit is contained in:
@ -66,7 +66,7 @@ import net.i2p.util.EventDispatcher;
|
|||||||
public I2PTunnelUDPClientBase(String destination, Logging l, EventDispatcher notifyThis,
|
public I2PTunnelUDPClientBase(String destination, Logging l, EventDispatcher notifyThis,
|
||||||
I2PTunnel tunnel) throws IllegalArgumentException {
|
I2PTunnel tunnel) throws IllegalArgumentException {
|
||||||
super("UDPServer", notifyThis, tunnel);
|
super("UDPServer", notifyThis, tunnel);
|
||||||
_clientId = __clientId.incrementAndGet();;
|
_clientId = __clientId.incrementAndGet();
|
||||||
this.l = l;
|
this.l = l;
|
||||||
|
|
||||||
_context = tunnel.getContext();
|
_context = tunnel.getContext();
|
||||||
|
@ -175,7 +175,7 @@ public class BlocklistEntries {
|
|||||||
StringBuilder buf = new StringBuilder();
|
StringBuilder buf = new StringBuilder();
|
||||||
long now = System.currentTimeMillis();
|
long now = System.currentTimeMillis();
|
||||||
String date = RFC3339Date.to3339Date(now);
|
String date = RFC3339Date.to3339Date(now);
|
||||||
buf.append(date).append('\n');;
|
buf.append(date).append('\n');
|
||||||
BufferedReader br = null;
|
BufferedReader br = null;
|
||||||
try {
|
try {
|
||||||
br = new BufferedReader(new InputStreamReader(new FileInputStream(inputFile), "UTF-8"));
|
br = new BufferedReader(new InputStreamReader(new FileInputStream(inputFile), "UTF-8"));
|
||||||
@ -196,7 +196,7 @@ public class BlocklistEntries {
|
|||||||
rlist.add(s.substring(1));
|
rlist.add(s.substring(1));
|
||||||
} else {
|
} else {
|
||||||
elist.add(s);
|
elist.add(s);
|
||||||
buf.append(s).append('\n');;
|
buf.append(s).append('\n');
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (IOException ioe) {
|
} catch (IOException ioe) {
|
||||||
|
@ -169,7 +169,7 @@ public class EventLogHelper extends FormHandler {
|
|||||||
if (events.isEmpty()) {
|
if (events.isEmpty()) {
|
||||||
if (isAll) {
|
if (isAll) {
|
||||||
if (_age == 0)
|
if (_age == 0)
|
||||||
return ("<table id=\"eventlog\"><tr><td class=\"infohelp\">") + _t("No events found") + ("</td></tr></table>");;
|
return ("<table id=\"eventlog\"><tr><td class=\"infohelp\">") + _t("No events found") + ("</td></tr></table>");
|
||||||
return ("<table id=\"eventlog\"><tr><td>") + _t("No events found in previous {0}", DataHelper.formatDuration2(_age)) + ("</td></tr></table>");
|
return ("<table id=\"eventlog\"><tr><td>") + _t("No events found in previous {0}", DataHelper.formatDuration2(_age)) + ("</td></tr></table>");
|
||||||
}
|
}
|
||||||
if (_age == 0)
|
if (_age == 0)
|
||||||
|
@ -39,7 +39,7 @@ class SummaryBarRenderer {
|
|||||||
static final Map<String, String> SECTION_NAMES;
|
static final Map<String, String> SECTION_NAMES;
|
||||||
|
|
||||||
static {
|
static {
|
||||||
Map<String, String> aMap = new HashMap<String, String>();;
|
Map<String, String> aMap = new HashMap<String, String>();
|
||||||
aMap.put("HelpAndFAQ", _x("Help & FAQ"));
|
aMap.put("HelpAndFAQ", _x("Help & FAQ"));
|
||||||
aMap.put("I2PServices", _x("I2P Services"));
|
aMap.put("I2PServices", _x("I2P Services"));
|
||||||
aMap.put("I2PInternals", _x("I2P Internals"));
|
aMap.put("I2PInternals", _x("I2P Internals"));
|
||||||
|
@ -64,7 +64,7 @@ class SAMStreamSession implements SAMMessageSess {
|
|||||||
/** stream id (Long) to StreamSender */
|
/** stream id (Long) to StreamSender */
|
||||||
private final HashMap<Integer,StreamSender> sendersMap = new HashMap<Integer,StreamSender>();
|
private final HashMap<Integer,StreamSender> sendersMap = new HashMap<Integer,StreamSender>();
|
||||||
|
|
||||||
private final AtomicInteger lastNegativeId = new AtomicInteger();;
|
private final AtomicInteger lastNegativeId = new AtomicInteger();
|
||||||
|
|
||||||
// Can we create outgoing connections?
|
// Can we create outgoing connections?
|
||||||
protected final boolean canCreate;
|
protected final boolean canCreate;
|
||||||
|
@ -613,7 +613,7 @@ class ConnectionPacketHandler {
|
|||||||
return;
|
return;
|
||||||
} else {
|
} else {
|
||||||
if (_log.shouldWarn())
|
if (_log.shouldWarn())
|
||||||
_log.warn("Reset received on " + con);;
|
_log.warn("Reset received on " + con);
|
||||||
// ok, valid RST
|
// ok, valid RST
|
||||||
con.resetReceived();
|
con.resetReceived();
|
||||||
con.eventOccurred();
|
con.eventOccurred();
|
||||||
|
@ -592,7 +592,7 @@ public abstract class I2PSessionImpl implements I2PSession, I2CPMessageReader.I2
|
|||||||
_signingPrivateKey = new SigningPrivateKey(dtype);
|
_signingPrivateKey = new SigningPrivateKey(dtype);
|
||||||
_signingPrivateKey.readBytes(destKeyStream);
|
_signingPrivateKey.readBytes(destKeyStream);
|
||||||
if (_signingPrivateKey.isOffline()) {
|
if (_signingPrivateKey.isOffline()) {
|
||||||
_offlineExpiration = DataHelper.readLong(destKeyStream, 4) * 1000;;
|
_offlineExpiration = DataHelper.readLong(destKeyStream, 4) * 1000;
|
||||||
int itype = (int) DataHelper.readLong(destKeyStream, 2);
|
int itype = (int) DataHelper.readLong(destKeyStream, 2);
|
||||||
SigType type = SigType.getByCode(itype);
|
SigType type = SigType.getByCode(itype);
|
||||||
if (type == null)
|
if (type == null)
|
||||||
|
@ -36,7 +36,7 @@ class ACKTimer extends SimpleTimer2.TimedEvent {
|
|||||||
*/
|
*/
|
||||||
public ACKTimer(RouterContext context, Destination from, Destination to) {
|
public ACKTimer(RouterContext context, Destination from, Destination to) {
|
||||||
super(context.simpleTimer2());
|
super(context.simpleTimer2());
|
||||||
_context = context;;
|
_context = context;
|
||||||
_log = context.logManager().getLog(ACKTimer.class);
|
_log = context.logManager().getLog(ACKTimer.class);
|
||||||
_from = from;
|
_from = from;
|
||||||
_to = to;
|
_to = to;
|
||||||
|
Reference in New Issue
Block a user