Changeset da2f4cb


Ignore:
Timestamp:
Jan 19, 2011 8:16:18 PM (10 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
4c84930
Parents:
653abbcc
Message:
  • Console: Put all socket handlers in same thread pool,

set min/max threads and idle timeout

File:
1 edited

Legend:

Unmodified
Added
Removed
  • apps/routerconsole/java/src/net/i2p/router/web/RouterConsoleRunner.java

    r653abbcc rda2f4cb  
    2525import org.mortbay.http.NCSARequestLog;
    2626import org.mortbay.http.SecurityConstraint;
     27import org.mortbay.http.SocketListener;
    2728import org.mortbay.http.SslListener;
    2829import org.mortbay.http.handler.SecurityHandler;
     
    185186                    String host = tok.nextToken().trim();
    186187                    try {
    187                         if (host.indexOf(":") >= 0) // IPV6 - requires patched Jetty 5
    188                             _server.addListener('[' + host + "]:" + _listenPort);
    189                         else
    190                             _server.addListener(host + ':' + _listenPort);
     188                        //if (host.indexOf(":") >= 0) // IPV6 - requires patched Jetty 5
     189                        //    _server.addListener('[' + host + "]:" + _listenPort);
     190                        //else
     191                        //    _server.addListener(host + ':' + _listenPort);
     192                        Integer lport = Integer.parseInt(_listenPort);
     193                        InetAddrPort iap = new InetAddrPort(host, lport);
     194                        SocketListener lsnr = new SocketListener(iap);
     195                        lsnr.setMinThreads(1);           // default 2
     196                        lsnr.setMaxThreads(24);          // default 256
     197                        lsnr.setMaxIdleTimeMs(90*1000);  // default 10 sec
     198                        lsnr.setName("ConsoleSocket");   // all with same name will use the same thread pool
     199                        _server.addListener(lsnr);
    191200                        boundAddresses++;
     201                    } catch (NumberFormatException nfe) {
     202                        System.err.println("Unable to bind routerconsole to " + host + " port " + _listenPort + ' ' + nfe);
    192203                    } catch (IOException ioe) { // this doesn't seem to work, exceptions don't happen until start() below
    193204                        System.err.println("Unable to bind routerconsole to " + host + " port " + _listenPort + ' ' + ioe);
     
    221232                            // the X.509 cert password (if not present, verifyKeyStore() returned false)
    222233                            ssll.setKeyPassword(ctx.getProperty(PROP_KEY_PASSWORD, "thisWontWork"));
     234                            ssll.setMinThreads(1);           // default 2
     235                            ssll.setMaxThreads(24);          // default 256
     236                            ssll.setMaxIdleTimeMs(90*1000);  // default 10 sec
     237                            ssll.setName("ConsoleSocket");   // all with same name will use the same thread pool
    223238                            _server.addListener(ssll);
    224239                            boundAddresses++;
Note: See TracChangeset for help on using the changeset viewer.