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-unsubscr...@tomcat.apache.org For additional commands, e-mail: dev-h...@tomcat.apache.org