forked from I2P_Developers/i2p.i2p
Style fix: leave brackets around for() one-liners
This commit is contained in:
@@ -1667,9 +1667,10 @@ public class I2PTunnel extends EventDispatcherImpl implements Logging {
|
|||||||
*/
|
*/
|
||||||
void routerDisconnected() {
|
void routerDisconnected() {
|
||||||
_log.error(getPrefix() + "Router disconnected - firing notification events");
|
_log.error(getPrefix() + "Router disconnected - firing notification events");
|
||||||
for (ConnectionEventListener lsnr : listeners)
|
for (ConnectionEventListener lsnr : listeners) {
|
||||||
if (lsnr != null) lsnr.routerDisconnected();
|
if (lsnr != null) lsnr.routerDisconnected();
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Callback routine to find out
|
* Callback routine to find out
|
||||||
|
@@ -93,8 +93,9 @@ class MessageHandler implements I2PSessionMuxedListener {
|
|||||||
_log.warn("I2PSession disconnected");
|
_log.warn("I2PSession disconnected");
|
||||||
_manager.disconnectAllHard();
|
_manager.disconnectAllHard();
|
||||||
|
|
||||||
for (I2PSocketManager.DisconnectListener lsnr : _listeners)
|
for (I2PSocketManager.DisconnectListener lsnr : _listeners) {
|
||||||
lsnr.sessionDisconnected();
|
lsnr.sessionDisconnected();
|
||||||
|
}
|
||||||
_listeners.clear();
|
_listeners.clear();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -421,13 +421,15 @@ public class WebMail extends HttpServlet
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
for( MailPart part : mailPart.parts )
|
for( MailPart part : mailPart.parts ) {
|
||||||
showPart( out, part, level + 1, html );
|
showPart( out, part, level + 1, html );
|
||||||
}
|
}
|
||||||
|
}
|
||||||
else if( mailPart.message ) {
|
else if( mailPart.message ) {
|
||||||
for( MailPart part : mailPart.parts )
|
for( MailPart part : mailPart.parts ) {
|
||||||
showPart( out, part, level + 1, html );
|
showPart( out, part, level + 1, html );
|
||||||
}
|
}
|
||||||
|
}
|
||||||
else {
|
else {
|
||||||
boolean showBody = false;
|
boolean showBody = false;
|
||||||
boolean prepareAttachment = false;
|
boolean prepareAttachment = false;
|
||||||
|
@@ -541,11 +541,13 @@ public class TransientSessionKeyManager extends SessionKeyManager {
|
|||||||
if (old != null) {
|
if (old != null) {
|
||||||
// drop both old and tagSet tags
|
// drop both old and tagSet tags
|
||||||
synchronized (_inboundTagSets) {
|
synchronized (_inboundTagSets) {
|
||||||
for (SessionTag tag : old.getTags())
|
for (SessionTag tag : old.getTags()) {
|
||||||
_inboundTagSets.remove(tag);
|
_inboundTagSets.remove(tag);
|
||||||
for (SessionTag tag : sessionTags)
|
}
|
||||||
|
for (SessionTag tag : sessionTags) {
|
||||||
_inboundTagSets.remove(tag);
|
_inboundTagSets.remove(tag);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
if (_log.shouldLog(Log.WARN)) {
|
if (_log.shouldLog(Log.WARN)) {
|
||||||
_log.warn("Multiple tags matching! tagSet: " + tagSet + " and old tagSet: " + old + " tag: " + dupTag + "/" + dupTag);
|
_log.warn("Multiple tags matching! tagSet: " + tagSet + " and old tagSet: " + old + " tag: " + dupTag + "/" + dupTag);
|
||||||
|
@@ -62,9 +62,10 @@ public class StatManager {
|
|||||||
public StatLog getStatLog() { return _statLog; }
|
public StatLog getStatLog() { return _statLog; }
|
||||||
public void setStatLog(StatLog log) {
|
public void setStatLog(StatLog log) {
|
||||||
_statLog = log;
|
_statLog = log;
|
||||||
for (RateStat rs : _rateStats.values())
|
for (RateStat rs : _rateStats.values()) {
|
||||||
rs.setStatLog(log);
|
rs.setStatLog(log);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Create a new statistic to monitor the frequency of some event.
|
* Create a new statistic to monitor the frequency of some event.
|
||||||
|
@@ -124,15 +124,18 @@ class ClientManager {
|
|||||||
_listener.stopListening();
|
_listener.stopListening();
|
||||||
Set<ClientConnectionRunner> runners = new HashSet<ClientConnectionRunner>();
|
Set<ClientConnectionRunner> runners = new HashSet<ClientConnectionRunner>();
|
||||||
synchronized (_runners) {
|
synchronized (_runners) {
|
||||||
for (ClientConnectionRunner runner : _runners.values())
|
for (ClientConnectionRunner runner : _runners.values()) {
|
||||||
runners.add(runner);
|
runners.add(runner);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
synchronized (_pendingRunners) {
|
synchronized (_pendingRunners) {
|
||||||
for (ClientConnectionRunner runner : _pendingRunners)
|
for (ClientConnectionRunner runner : _pendingRunners) {
|
||||||
runners.add(runner);
|
runners.add(runner);
|
||||||
}
|
}
|
||||||
for (ClientConnectionRunner runner : runners)
|
}
|
||||||
|
for (ClientConnectionRunner runner : runners) {
|
||||||
runner.disconnectClient(msg, Log.WARN);
|
runner.disconnectClient(msg, Log.WARN);
|
||||||
|
}
|
||||||
_runnersByHash.clear();
|
_runnersByHash.clear();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@@ -190,27 +190,31 @@ class StoreState {
|
|||||||
buf.append(" Attempted: ");
|
buf.append(" Attempted: ");
|
||||||
synchronized (_attemptedPeers) {
|
synchronized (_attemptedPeers) {
|
||||||
buf.append(_attemptedPeers.size()).append(' ');
|
buf.append(_attemptedPeers.size()).append(' ');
|
||||||
for (Hash peer : _attemptedPeers)
|
for (Hash peer : _attemptedPeers) {
|
||||||
buf.append(peer.toBase64()).append(" ");
|
buf.append(peer.toBase64()).append(" ");
|
||||||
}
|
}
|
||||||
|
}
|
||||||
buf.append(" Pending: ");
|
buf.append(" Pending: ");
|
||||||
synchronized (_pendingPeers) {
|
synchronized (_pendingPeers) {
|
||||||
buf.append(_pendingPeers.size()).append(' ');
|
buf.append(_pendingPeers.size()).append(' ');
|
||||||
for (Hash peer : _pendingPeers)
|
for (Hash peer : _pendingPeers) {
|
||||||
buf.append(peer.toBase64()).append(" ");
|
buf.append(peer.toBase64()).append(" ");
|
||||||
}
|
}
|
||||||
|
}
|
||||||
buf.append(" Failed: ");
|
buf.append(" Failed: ");
|
||||||
synchronized (_failedPeers) {
|
synchronized (_failedPeers) {
|
||||||
buf.append(_failedPeers.size()).append(' ');
|
buf.append(_failedPeers.size()).append(' ');
|
||||||
for (Hash peer : _failedPeers)
|
for (Hash peer : _failedPeers) {
|
||||||
buf.append(peer.toBase64()).append(" ");
|
buf.append(peer.toBase64()).append(" ");
|
||||||
}
|
}
|
||||||
|
}
|
||||||
buf.append(" Successful: ");
|
buf.append(" Successful: ");
|
||||||
synchronized (_successfulPeers) {
|
synchronized (_successfulPeers) {
|
||||||
buf.append(_successfulPeers.size()).append(' ');
|
buf.append(_successfulPeers.size()).append(' ');
|
||||||
for (Hash peer : _successfulPeers)
|
for (Hash peer : _successfulPeers) {
|
||||||
buf.append(peer.toBase64()).append(" ");
|
buf.append(peer.toBase64()).append(" ");
|
||||||
}
|
}
|
||||||
|
}
|
||||||
/****
|
/****
|
||||||
buf.append(" Successful Exploratory: ");
|
buf.append(" Successful Exploratory: ");
|
||||||
synchronized (_successfulExploratoryPeers) {
|
synchronized (_successfulExploratoryPeers) {
|
||||||
|
Reference in New Issue
Block a user