Author: kfujino
Date: Wed May 23 02:31:59 2018
New Revision: 1832070
URL: http://svn.apache.org/viewvc?rev=1832070&view=rev
Log:
Simplify the code.
remove unnecessary code.
Modified:
tomcat/tc8.5.x/trunk/java/org/apache/catalina/ha/session/DeltaManager.java
Modified:
tomcat/tc8.5.x/trunk/java/org/apache/catalina/ha/session/DeltaManager.java
URL:
http://svn.apache.org/viewvc/tomcat/tc8.5.x/trunk/java/org/apache/catalina/ha/session/DeltaManager.java?rev=1832070&r1=1832069&r2=1832070&view=diff
==============================================================================
--- tomcat/tc8.5.x/trunk/java/org/apache/catalina/ha/session/DeltaManager.java
(original)
+++ tomcat/tc8.5.x/trunk/java/org/apache/catalina/ha/session/DeltaManager.java
Wed May 23 02:31:59 2018
@@ -766,16 +766,12 @@ public class DeltaManager extends Cluste
iter.hasNext();) {
SessionMessage smsg = iter.next();
if (!stateTimestampDrop) {
- messageReceived(smsg,
- smsg.getAddress() != null ? (Member)
smsg.getAddress() : null);
+ messageReceived(smsg, smsg.getAddress());
} else {
if (smsg.getEventType() !=
SessionMessage.EVT_GET_ALL_SESSIONS &&
smsg.getTimestamp() >=
stateTransferCreateSendTime) {
// FIXME handle EVT_GET_ALL_SESSIONS later
- messageReceived(smsg,
- smsg.getAddress() != null ?
- (Member) smsg.getAddress() :
- null);
+ messageReceived(smsg, smsg.getAddress());
} else {
if (log.isWarnEnabled()) {
log.warn(sm.getString("deltaManager.dropMessage",
@@ -926,7 +922,7 @@ public class DeltaManager extends Cluste
break;
} //switch
- messageReceived(msg, msg.getAddress() != null ? (Member)
msg.getAddress() : null);
+ messageReceived(msg, msg.getAddress());
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
