membership.memberAlive( (MemberImpl) member);
notify = true;
} else {
- addSuspects.put(member, new Long(System.currentTimeMillis()));
+ addSuspects.put(member, Long.valueOf(System.currentTimeMillis()));
}
}
}
notify = true;
} else {
//add the member as suspect
- removeSuspects.put(member, new Long(System.currentTimeMillis()));
+ removeSuspects.put(member, Long.valueOf(System.currentTimeMillis()));
}
}
if ( notify ) {
if (log.isDebugEnabled()) log.debug("Member has shutdown:" + m);
membership.removeMember(m);
t = new Runnable() {
+ @Override
public void run() {
String name = Thread.currentThread().getName();
try {
} else if (membership.memberAlive(m)) {
if (log.isDebugEnabled()) log.debug("Mcast add member " + m);
t = new Runnable() {
+ @Override
public void run() {
String name = Thread.currentThread().getName();
try {
}
}
Runnable t = new Runnable() {
+ @Override
public void run() {
String name = Thread.currentThread().getName();
try {
log.debug("Mcast exipre member " + expired[i]);
try {
Runnable t = new Runnable() {
+ @Override
public void run() {
String name = Thread.currentThread().getName();
try {
// NO-OP
}
- /**
- *
- * @throws IOException
- * TODO Implement this org.apache.catalina.tribes.ChannelReceiver method
- */
@Override
public void start() throws IOException {
super.start();
return result;
}
- /**
- *
- * TODO Implement this org.apache.catalina.tribes.ChannelReceiver method
- */
@Override
public void stop() {
setListen(false);
<Bug code="SWL" />
</Match>
<Match>
+ <Class name="org.apache.catalina.tribes.group.interceptors.TcpFailureDetector"/>
+ <Method name="memberAlive"/>
+ <Bug code="DE"/>
+ </Match>
+ <Match>
+ <Class name="org.apache.catalina.tribes.membership.McastServiceImpl"/>
+ <Method name="stop"/>
+ <Bug code="DE"/>
+ </Match>
+ <Match>
+ <Class name="org.apache.catalina.tribes.membership.McastServiceImpl$ReceiverThread"/>
+ <Method name="run"/>
+ <Bug code="DE"/>
+ </Match>
+ <Match>
+ <Class name="org.apache.catalina.tribes.membership.McastServiceImpl$RecoveryThread"/>
+ <Method name="run"/>
+ <Bug code="NS"/>
+ </Match>
+ <Match>
<!-- Class name needs to start with a lower case letter in this case -->
<Class name="org.apache.naming.java.javaURLContextFactory" />
<Bug code="Nm" />