cvs commit: jakarta-tomcat-connectors/http11/src/java/org/apache/coyote/http11 Http11Protocol.java

[yoavs]

yoavs       2004/05/27 09:12:09

  Modified:    http11/src/java/org/apache/coyote/http11 Http11Protocol.java
  Log:
  Added support for threadPriority attribute 
(http://nagoya.apache.org/bugzilla/show_bug.cgi?id=28914).
  
  Revision  Changes    Path
  1.54      +13 -7     
jakarta-tomcat-connectors/http11/src/java/org/apache/coyote/http11/Http11Protocol.java
  
  Index: Http11Protocol.java
  ===================================================================
  RCS file: 
/home/cvs/jakarta-tomcat-connectors/http11/src/java/org/apache/coyote/http11/Http11Protocol.java,v
  retrieving revision 1.53
  retrieving revision 1.54
  diff -u -r1.53 -r1.54
  --- Http11Protocol.java       2 Mar 2004 01:17:39 -0000       1.53
  +++ Http11Protocol.java       27 May 2004 16:12:09 -0000      1.54
  @@ -76,14 +76,11 @@
       public void setAttribute( String name, Object value ) {
           if( log.isTraceEnabled())
               log.trace(sm.getString("http11protocol.setattribute", name, value));
  +
  +        System.out.println(getClass().getName() +
  +     ": setAttribute(" + name + ", " + value + "): here.");
  +
           attributes.put(name, value);
  -/*
  -        if ("maxKeepAliveRequests".equals(name)) {
  -            maxKeepAliveRequests = Integer.parseInt((String) value.toString());
  -        } else if ("port".equals(name)) {
  -            setPort(Integer.parseInt((String) value.toString()));
  -        }
  -*/
       }
   
       public Object getAttribute( String key ) {
  @@ -279,6 +276,15 @@
       public void setMinSpareThreads( int minSpareThreads ) {
           ep.setMinSpareThreads(minSpareThreads);
           setAttribute("minSpareThreads", "" + minSpareThreads);
  +    }
  +
  +    public void setThreadPriority(int threadPriority) {
  +      ep.setThreadPriority(threadPriority);
  +      setAttribute("threadPriority", "" + threadPriority);
  +    }
  +
  +    public int getThreadPriority() {
  +      return ep.getThreadPriority();
       }
   
       // -------------------- Tcp setup --------------------
  
  
  

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