Author: fhanik
Date: Thu May 18 14:31:20 2006
New Revision: 407636
URL: http://svn.apache.org/viewvc?rev=407636&view=rev
Log:
Fixed the interceptors, async start logic
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
URL:
http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java?rev=407636&r1=407635&r2=407636&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/MessageDispatchInterceptor.java
Thu May 18 14:31:20 2006
@@ -61,6 +61,7 @@
}
addAndGetCurrentSize(msg.getMessage().getLength());
} else {
+ System.out.println("Not queueing the message");
super.sendMessage(destination, msg, payload);
}
}
@@ -104,7 +105,7 @@
//start the thread
if (!run ) {
synchronized (this) {
- if ( !run && ((svc & Channel.SND_TX_SEQ)==svc) ) {//only start
with the sender
+ if ( !run && ((svc & Channel.SND_TX_SEQ)==Channel.SND_TX_SEQ)
) {//only start with the sender
msgDispatchThread = new Thread(this);
msgDispatchThread.setName("MessageDispatchThread");
msgDispatchThread.setDaemon(true);
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java
URL:
http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java?rev=407636&r1=407635&r2=407636&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/interceptors/ThroughputInterceptor.java
Thu May 18 14:31:20 2006
@@ -43,7 +43,7 @@
double timeTx = 0;
AtomicLong msgTxCnt = new AtomicLong(1);
AtomicLong msgRxCnt = new AtomicLong(1);
- AtomicLong msgTxErr = new AtomicLong(1);
+ AtomicLong msgTxErr = new AtomicLong(0);
int interval = 10000;
AtomicInteger access = new AtomicInteger(0);
long start = 0;
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
