cvs commit: jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp FastAsyncSocketSender.java

[pero]

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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]