You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by ma...@apache.org on 2017/04/19 09:06:57 UTC
svn commit: r1791884 - in
/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors:
TcpFailureDetector.java TcpPingInterceptor.java ThroughputInterceptor.java
Author: markt
Date: Wed Apr 19 09:06:57 2017
New Revision: 1791884
URL: http://svn.apache.org/viewvc?rev=1791884&view=rev
Log:
Add missing override annotations
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpFailureDetector.java
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpPingInterceptor.java
tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java
Modified: tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpFailureDetector.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpFailureDetector.java?rev=1791884&r1=1791883&r2=1791884&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpFailureDetector.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpFailureDetector.java Wed Apr 19 09:06:57 2017
@@ -218,6 +218,7 @@ public class TcpFailureDetector extends
checkMembers(false);
}
+ @Override
public void checkMembers(boolean checkAll) {
try {
if (membership == null) setupMembership();
@@ -360,42 +361,52 @@ public class TcpFailureDetector extends
return false;
}
+ @Override
public long getReadTestTimeout() {
return readTestTimeout;
}
+ @Override
public boolean getPerformSendTest() {
return performSendTest;
}
+ @Override
public boolean getPerformReadTest() {
return performReadTest;
}
+ @Override
public long getConnectTimeout() {
return connectTimeout;
}
+ @Override
public int getRemoveSuspectsTimeout() {
return removeSuspectsTimeout;
}
+ @Override
public void setPerformReadTest(boolean performReadTest) {
this.performReadTest = performReadTest;
}
+ @Override
public void setPerformSendTest(boolean performSendTest) {
this.performSendTest = performSendTest;
}
+ @Override
public void setReadTestTimeout(long readTestTimeout) {
this.readTestTimeout = readTestTimeout;
}
+ @Override
public void setConnectTimeout(long connectTimeout) {
this.connectTimeout = connectTimeout;
}
+ @Override
public void setRemoveSuspectsTimeout(int removeSuspectsTimeout) {
this.removeSuspectsTimeout = removeSuspectsTimeout;
}
Modified: tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpPingInterceptor.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpPingInterceptor.java?rev=1791884&r1=1791883&r2=1791884&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpPingInterceptor.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/TcpPingInterceptor.java Wed Apr 19 09:06:57 2017
@@ -103,6 +103,7 @@ public class TcpPingInterceptor extends
if (!getUseThread()) sendPing();
}
+ @Override
public long getInterval() {
return interval;
}
@@ -119,6 +120,7 @@ public class TcpPingInterceptor extends
this.staticOnly = staticOnly;
}
+ @Override
public boolean getUseThread() {
return useThread;
}
Modified: tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java?rev=1791884&r1=1791883&r2=1791884&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java Wed Apr 19 09:06:57 2017
@@ -94,6 +94,7 @@ public class ThroughputInterceptor exten
}
+ @Override
public void report(double timeTx) {
if ( log.isInfoEnabled() )
log.info(sm.getString("throughputInterceptor.report",
@@ -102,6 +103,7 @@ public class ThroughputInterceptor exten
df.format(mbRx)));
}
+ @Override
public void setInterval(int interval) {
this.interval = interval;
}
@@ -110,42 +112,52 @@ public class ThroughputInterceptor exten
return interval;
}
+ @Override
public double getLastCnt() {
return lastCnt;
}
+ @Override
public double getMbAppTx() {
return mbAppTx;
}
+ @Override
public double getMbRx() {
return mbRx;
}
+ @Override
public double getMbTx() {
return mbTx;
}
+ @Override
public AtomicLong getMsgRxCnt() {
return msgRxCnt;
}
+ @Override
public AtomicLong getMsgTxCnt() {
return msgTxCnt;
}
+ @Override
public AtomicLong getMsgTxErr() {
return msgTxErr;
}
+ @Override
public long getRxStart() {
return rxStart;
}
+ @Override
public double getTimeTx() {
return timeTx;
}
+ @Override
public long getTxStart() {
return txStart;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org