tomcat-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From cos...@apache.org
Subject cvs commit: jakarta-tomcat-connectors/jk/java/org/apache/jk/common ChannelSocket.java
Date Fri, 09 Aug 2002 20:52:37 GMT
costin      2002/08/09 13:52:37

  Modified:    jk/java/org/apache/jk/common ChannelSocket.java
  Log:
  Add getters for various fields, added a 'requestCount' attribute,
  make thing prettier for the JMX view.
  
  Revision  Changes    Path
  1.21      +45 -3     jakarta-tomcat-connectors/jk/java/org/apache/jk/common/ChannelSocket.java
  
  Index: ChannelSocket.java
  ===================================================================
  RCS file: /home/cvs/jakarta-tomcat-connectors/jk/java/org/apache/jk/common/ChannelSocket.java,v
  retrieving revision 1.20
  retrieving revision 1.21
  diff -u -r1.20 -r1.21
  --- ChannelSocket.java	8 Aug 2002 18:19:04 -0000	1.20
  +++ ChannelSocket.java	9 Aug 2002 20:52:37 -0000	1.21
  @@ -109,6 +109,8 @@
       int linger=100;
       int socketTimeout;
   
  +    long requestCount=0;
  +    
       /* Turning this to true will reduce the latency with about 20%.
          But it requires changes in tomcat to make sure client-requested
          flush() is honored ( on my test, I got 367->433 RPS and
  @@ -130,6 +132,10 @@
           return tp;
       }
   
  +    public long getRequestCount() {
  +        return requestCount;
  +    }
  +    
       /** Set the port for the ajp13 channel.
        *  To support seemless load balancing and jni, we treat this
        *  as the 'base' port - we'll try up until we find one that is not
  @@ -181,23 +187,47 @@
       public void setServerTimeout(int timeout) {
   	this.serverTimeout = timeout;
       }
  +    public int getServerTimeout() {
  +        return serverTimeout;
  +    }
   
       public void setTcpNoDelay( boolean b ) {
   	tcpNoDelay=b;
       }
   
  +    public boolean getTcpNoDelay() {
  +        return tcpNoDelay;
  +    }
  +    
       public void setSoLinger( int i ) {
   	linger=i;
       }
   
  +    public int getSoLinger() {
  +        return linger;
  +    }
  +    
       public void setSoTimeout( int i ) {
   	socketTimeout=i;
       }
   
  +    public int getSoTimeout() {
  +	return socketTimeout;
  +    }
  +
       public void setMaxPort( int i ) {
           maxPort=i;
       }
   
  +    public int getMaxPort() {
  +        return maxPort;
  +    }
  +
  +    /** At startup we'll look for the first free port in the range.
  +        The difference between this port and the beggining of the range
  +        is the 'id'.
  +        This is usefull for lb cases ( less config ).
  +    */
       public int getInstanceId() {
           return port-startPort;
       }
  @@ -230,6 +260,8 @@
           if( socketTimeout > 0 ) 
               s.setSoTimeout( socketTimeout );
   
  +        requestCount++;
  +
           InputStream is=new BufferedInputStream(s.getInputStream());
           OutputStream os;
           if( BUFFER_WRITE )
  @@ -240,6 +272,18 @@
           ep.setNote( osNote, os );
       }
   
  +    public void resetCounters() {
  +        requestCount=0;
  +    }
  +
  +    /** Called after you change some fields at runtime using jmx.
  +        Experimental for now.
  +    */
  +    public void reinit() throws IOException {
  +        destroy();
  +        init();
  +    }
  +    
       /**
        * @jmx:managed-operation
        */
  @@ -262,7 +306,7 @@
               log.error("Can't find free port " + startPort + " " + maxPort );
               return;
           }
  -        log.info("JK: listening on tcp port " + port );
  +        log.info("JK2: ajp13 listening on tcp port " + port );
           
           // If this is not the base port and we are the 'main' channleSocket and
           // SHM didn't already set the localId - we'll set the instance id
  @@ -558,8 +602,6 @@
   	}
   	return (true);
       }
  -
  -    
   }
   
   class SocketAcceptor implements ThreadPoolRunnable {
  
  
  

--
To unsubscribe, e-mail:   <mailto:tomcat-dev-unsubscribe@jakarta.apache.org>
For additional commands, e-mail: <mailto:tomcat-dev-help@jakarta.apache.org>


Mime
View raw message