You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by kf...@apache.org on 2016/11/10 06:19:02 UTC
svn commit: r1769051 - in /tomcat/tc8.0.x/trunk:
java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java
webapps/docs/changelog.xml webapps/docs/config/cluster-interceptor.xml
Author: kfujino
Date: Thu Nov 10 06:19:01 2016
New Revision: 1769051
URL: http://svn.apache.org/viewvc?rev=1769051&view=rev
Log:
Reduce the warning logs for a message received from a different domain in order to avoid excessive log outputs.
Modified:
tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java
tomcat/tc8.0.x/trunk/webapps/docs/changelog.xml
tomcat/tc8.0.x/trunk/webapps/docs/config/cluster-interceptor.xml
Modified: tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java
URL: http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java?rev=1769051&r1=1769050&r2=1769051&view=diff
==============================================================================
--- tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java (original)
+++ tomcat/tc8.0.x/trunk/java/org/apache/catalina/tribes/group/interceptors/DomainFilterInterceptor.java Thu Nov 10 06:19:01 2016
@@ -17,6 +17,7 @@
package org.apache.catalina.tribes.group.interceptors;
import java.util.Arrays;
+import java.util.concurrent.atomic.AtomicInteger;
import org.apache.catalina.tribes.ChannelMessage;
import org.apache.catalina.tribes.Member;
@@ -41,14 +42,19 @@ public class DomainFilterInterceptor ext
protected volatile Membership membership = null;
protected byte[] domain = new byte[0];
+ protected int logInterval = 100;
+ private final AtomicInteger logCounter = new AtomicInteger(logInterval);
@Override
public void messageReceived(ChannelMessage msg) {
if (Arrays.equals(domain, msg.getAddress().getDomain())) {
super.messageReceived(msg);
} else {
- if (log.isWarnEnabled())
- log.warn(sm.getString("domainFilterInterceptor.message.refused", msg.getAddress()));
+ if (logCounter.incrementAndGet() >= logInterval) {
+ logCounter.set(0);
+ if (log.isWarnEnabled())
+ log.warn(sm.getString("domainFilterInterceptor.message.refused", msg.getAddress()));
+ }
}
}//messageReceived
@@ -126,4 +132,12 @@ public class DomainFilterInterceptor ext
setDomain(org.apache.catalina.tribes.util.Arrays.convert(domain));
}
+ public int getLogInterval() {
+ return logInterval;
+ }
+
+ public void setLogInterval(int logInterval) {
+ this.logInterval = logInterval;
+ }
+
}
Modified: tomcat/tc8.0.x/trunk/webapps/docs/changelog.xml
URL: http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/webapps/docs/changelog.xml?rev=1769051&r1=1769050&r2=1769051&view=diff
==============================================================================
--- tomcat/tc8.0.x/trunk/webapps/docs/changelog.xml (original)
+++ tomcat/tc8.0.x/trunk/webapps/docs/changelog.xml Thu Nov 10 06:19:01 2016
@@ -54,6 +54,14 @@
</fix>
</changelog>
</subsection>
+ <subsection name="Tribes">
+ <changelog>
+ <fix>
+ Reduce the warning logs for a message received from a different domain
+ in order to avoid excessive log outputs. (kfujino)
+ </fix>
+ </changelog>
+ </subsection>
</section>
<section name="Tomcat 8.0.39 (violetagg)" rtext="release in progress">
<subsection name="Catalina">
Modified: tomcat/tc8.0.x/trunk/webapps/docs/config/cluster-interceptor.xml
URL: http://svn.apache.org/viewvc/tomcat/tc8.0.x/trunk/webapps/docs/config/cluster-interceptor.xml?rev=1769051&r1=1769050&r2=1769051&view=diff
==============================================================================
--- tomcat/tc8.0.x/trunk/webapps/docs/config/cluster-interceptor.xml (original)
+++ tomcat/tc8.0.x/trunk/webapps/docs/config/cluster-interceptor.xml Thu Nov 10 06:19:01 2016
@@ -103,6 +103,10 @@
using ISO-8859-1 encoding.<br/>
2. byte array in string form, for example {216,123,12,3}<br/>
</attribute>
+ <attribute name="logInterval" required="false">
+ This value indicates the interval for logging for messages from different domains.
+ The default is 100, which means that to log per 100 messages.
+ </attribute>
</attributes>
</subsection>
<subsection name="org.apache.catalina.tribes.group.interceptors.MessageDispatch15Interceptor Attributes">
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org