You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by pe...@apache.org on 2005/04/10 18:54:06 UTC
cvs commit: jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp FastAsyncSocketSender.java
pero 2005/04/10 09:54:06
Modified: modules/cluster/src/share/org/apache/catalina/cluster/tcp
FastAsyncSocketSender.java
Log:
fix correct nr of queued bytes stats.
missing sync
Revision Changes Path
1.4 +4 -4 jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp/FastAsyncSocketSender.java
Index: FastAsyncSocketSender.java
===================================================================
RCS file: /home/cvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp/FastAsyncSocketSender.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- FastAsyncSocketSender.java 10 Apr 2005 16:20:46 -0000 1.3
+++ FastAsyncSocketSender.java 10 Apr 2005 16:54:06 -0000 1.4
@@ -401,15 +401,15 @@
return queuedNrOfBytes ;
}
- protected void setQueuedNrOfBytes(long queuedNrOfBytes) {
+ protected synchronized void setQueuedNrOfBytes(long queuedNrOfBytes) {
this.queuedNrOfBytes = queuedNrOfBytes;
}
- protected void incQueuedNrOfBytes(long size) {
+ protected synchronized void incQueuedNrOfBytes(long size) {
queuedNrOfBytes += size;
}
- protected void decQueuedNrOfBytes(long size) {
+ protected synchronized void decQueuedNrOfBytes(long size) {
queuedNrOfBytes -= size;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: tomcat-dev-unsubscribe@jakarta.apache.org
For additional commands, e-mail: tomcat-dev-help@jakarta.apache.org