hgomez      2004/02/23 05:07:58

  Modified:    jk/java/org/apache/jk/server JkMain.java
               jk/java/org/apache/jk/common ChannelSocket.java
  Log:
  set minSpareThreads / maxSpareThreads
  
  Revision  Changes    Path
  1.44      +2 -0      
jakarta-tomcat-connectors/jk/java/org/apache/jk/server/JkMain.java
  
  Index: JkMain.java
  ===================================================================
  RCS file: 
/home/cvs/jakarta-tomcat-connectors/jk/java/org/apache/jk/server/JkMain.java,v
  retrieving revision 1.43
  retrieving revision 1.44
  diff -u -r1.43 -r1.44
  --- JkMain.java       27 Jan 2004 06:43:18 -0000      1.43
  +++ JkMain.java       23 Feb 2004 13:07:58 -0000      1.44
  @@ -502,6 +502,8 @@
       static {
           replacements.put("port","channelSocket.port");
           replacements.put("maxThreads", "channelSocket.maxThreads");   
  +             replacements.put("minSpareThreads", "channelSocket.minSpareThreads");  
 
  +             replacements.put("maxSpareThreads", "channelSocket.maxSpareThreads");  
 
           replacements.put("backlog", "channelSocket.backlog");   
           replacements.put("tcpNoDelay", "channelSocket.tcpNoDelay");
           replacements.put("soTimeout", "channelSocket.soTimeout");
  
  
  
  1.42      +19 -0     
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.41
  retrieving revision 1.42
  diff -u -r1.41 -r1.42
  --- ChannelSocket.java        27 Jan 2004 08:08:29 -0000      1.41
  +++ ChannelSocket.java        23 Feb 2004 13:07:58 -0000      1.42
  @@ -267,10 +267,29 @@
           tp.setMaxThreads(i);
       }
       
  +     public void setMinSpareThreads( int i ) {
  +             if( log.isDebugEnabled()) log.debug("Setting minSpareThreads " + i);
  +                     tp.setMinSpareThreads(i);
  +     }
  +
  +     public void setMaxSpareThreads( int i ) {
  +             if( log.isDebugEnabled()) log.debug("Setting maxSpareThreads " + i);
  +                     tp.setMaxSpareThreads(i);
  +     }
  +
  +
       public int getMaxThreads() {
           return tp.getMaxThreads();   
       }
       
  +     public int getMinSpareThreads() {
  +             return tp.getMinSpareThreads();   
  +     }
  +
  +     public int getMaxSpareThreads() {
  +             return tp.getMaxSpareThreads();   
  +     }
  +
       public void setBacklog(int i) {
       }
       
  
  
  

---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]

Reply via email to