Mercurial Hosting > luan
annotate src/org/eclipse/jetty/server/Connector.java @ 950:a778413aefc0
add SaneSelector
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Wed, 12 Oct 2016 14:37:56 -0600 |
parents | f5aefdc4a81a |
children | a021c4c9c244 |
rev | line source |
---|---|
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
1 // |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
2 // ======================================================================== |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
3 // Copyright (c) 1995-2014 Mort Bay Consulting Pty. Ltd. |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
4 // ------------------------------------------------------------------------ |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
5 // All rights reserved. This program and the accompanying materials |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
6 // are made available under the terms of the Eclipse Public License v1.0 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
7 // and Apache License v2.0 which accompanies this distribution. |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
8 // |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
9 // The Eclipse Public License is available at |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
10 // http://www.eclipse.org/legal/epl-v10.html |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
11 // |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
12 // The Apache License v2.0 is available at |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
13 // http://www.opensource.org/licenses/apache2.0.php |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
14 // |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
15 // You may elect to redistribute this code under either of these licenses. |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
16 // ======================================================================== |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
17 // |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
18 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
19 package org.eclipse.jetty.server; |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
20 |
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
21 import java.io.IOException; |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
22 import java.net.InetAddress; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
23 import java.net.Socket; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
24 import java.net.UnknownHostException; |
909 | 25 import java.nio.channels.ServerSocketChannel; |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
26 import java.util.concurrent.ThreadPoolExecutor; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
27 import java.util.concurrent.atomic.AtomicLong; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
28 |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
29 import javax.servlet.ServletRequest; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
30 |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
31 import org.eclipse.jetty.http.HttpBuffers; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
32 import org.eclipse.jetty.http.HttpBuffersImpl; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
33 import org.eclipse.jetty.http.HttpFields; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
34 import org.eclipse.jetty.http.HttpHeaders; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
35 import org.eclipse.jetty.http.HttpSchemes; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
36 import org.eclipse.jetty.io.Buffers; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
37 import org.eclipse.jetty.io.Buffers.Type; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
38 import org.eclipse.jetty.io.Connection; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
39 import org.eclipse.jetty.io.EndPoint; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
40 import org.eclipse.jetty.io.EofException; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
41 import org.eclipse.jetty.util.component.AggregateLifeCycle; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
42 import org.eclipse.jetty.util.component.Dumpable; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
43 import org.slf4j.Logger; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
44 import org.slf4j.LoggerFactory; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
45 |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
46 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
47 * Abstract Connector implementation. This abstract implementation of the Connector interface provides: |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
48 * <ul> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
49 * <li>AbstractLifeCycle implementation</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
50 * <li>Implementations for connector getters and setters</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
51 * <li>Buffer management</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
52 * <li>Socket configuration</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
53 * <li>Base acceptor thread</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
54 * <li>Optional reverse proxy headers checking</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
55 * </ul> |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
56 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
57 public abstract class Connector extends AggregateLifeCycle implements HttpBuffers, Dumpable |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
58 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
59 private static final Logger LOG = LoggerFactory.getLogger(Connector.class); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
60 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
61 private String _name; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
62 |
887
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
63 public final Server server; |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
64 private String _host; |
887
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
65 public final int port; |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
66 private int _acceptors = 1; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
67 |
948
f5aefdc4a81a
simplify SelectChannelConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
914
diff
changeset
|
68 protected final int _maxIdleTime = 200000; |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
69 protected int _soLingerTime = -1; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
70 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
71 protected final HttpBuffersImpl _buffers = new HttpBuffersImpl(); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
72 |
909 | 73 // from child classes |
74 protected transient ServerSocketChannel _acceptChannel; | |
75 | |
887
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
76 public Connector(Server server,int port) { |
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
77 this.server = server; |
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
78 this.port = port; |
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
79 server.connectors.add(this); |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
80 addBean(_buffers); |
907
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
81 _buffers.setRequestBufferType(Type.DIRECT); |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
82 _buffers.setRequestHeaderType(Type.INDIRECT); |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
83 _buffers.setResponseBufferType(Type.DIRECT); |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
84 _buffers.setResponseHeaderType(Type.INDIRECT); |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
85 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
86 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
87 public void setHost(String host) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
88 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
89 _host = host; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
90 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
91 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
92 public String getHost() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
93 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
94 return _host; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
95 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
96 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
97 public int getMaxIdleTime() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
98 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
99 return _maxIdleTime; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
100 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
101 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
102 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
103 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
104 * Set the maximum Idle time for a connection, which roughly translates to the {@link Socket#setSoTimeout(int)} call, although with NIO implementations |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
105 * other mechanisms may be used to implement the timeout. The max idle time is applied: |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
106 * <ul> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
107 * <li>When waiting for a new request to be received on a connection</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
108 * <li>When reading the headers and content of a request</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
109 * <li>When writing the headers and content of a response</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
110 * </ul> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
111 * Jetty interprets this value as the maximum time between some progress being made on the connection. So if a single byte is read or written, then the |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
112 * timeout (if implemented by jetty) is reset. However, in many instances, the reading/writing is delegated to the JVM, and the semantic is more strictly |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
113 * enforced as the maximum time a single read/write operation can take. Note, that as Jetty supports writes of memory mapped file buffers, then a write may |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
114 * take many 10s of seconds for large content written to a slow device. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
115 * <p> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
116 * Previously, Jetty supported separate idle timeouts and IO operation timeouts, however the expense of changing the value of soTimeout was significant, so |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
117 * these timeouts were merged. With the advent of NIO, it may be possible to again differentiate these values (if there is demand). |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
118 * |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
119 * @param maxIdleTime |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
120 * The maxIdleTime to set. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
121 */ |
913 | 122 /* |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
123 public void setMaxIdleTime(int maxIdleTime) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
124 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
125 _maxIdleTime = maxIdleTime; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
126 } |
913 | 127 */ |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
128 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
129 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
130 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
131 * @return Returns the soLingerTime. |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
132 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
133 public int getSoLingerTime() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
134 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
135 return _soLingerTime; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
136 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
137 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
138 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
139 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
140 * @return Returns the number of acceptor threads. |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
141 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
142 public int getAcceptors() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
143 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
144 return _acceptors; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
145 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
146 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
147 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
148 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
149 * @param acceptors |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
150 * The number of acceptor threads to set. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
151 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
152 public void setAcceptors(int acceptors) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
153 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
154 if (acceptors > 2 * Runtime.getRuntime().availableProcessors()) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
155 LOG.warn("Acceptors should be <=2*availableProcessors: " + this); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
156 _acceptors = acceptors; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
157 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
158 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
159 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
160 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
161 * @param soLingerTime |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
162 * The soLingerTime to set or -1 to disable. |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
163 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
164 public void setSoLingerTime(int soLingerTime) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
165 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
166 _soLingerTime = soLingerTime; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
167 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
168 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
169 @Override |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
170 protected void doStart() throws Exception |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
171 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
172 super.doStart(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
173 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
174 // Start selector thread |
905
e7175965e6cf
remove Connector._acceptorThreads
Franklin Schmidt <fschmidt@gmail.com>
parents:
904
diff
changeset
|
175 ThreadPoolExecutor _threadPool = server.threadPool; |
e7175965e6cf
remove Connector._acceptorThreads
Franklin Schmidt <fschmidt@gmail.com>
parents:
904
diff
changeset
|
176 for (int i = 0; i < _acceptors; i++) |
906 | 177 _threadPool.execute(new Acceptor()); |
905
e7175965e6cf
remove Connector._acceptorThreads
Franklin Schmidt <fschmidt@gmail.com>
parents:
904
diff
changeset
|
178 if (server.isLowOnThreads()) |
e7175965e6cf
remove Connector._acceptorThreads
Franklin Schmidt <fschmidt@gmail.com>
parents:
904
diff
changeset
|
179 LOG.warn("insufficient threads configured for {}",this); |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
180 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
181 LOG.info("Started {}",this); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
182 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
183 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
184 @Override |
913 | 185 protected synchronized void doStop() throws Exception |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
186 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
187 try |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
188 { |
913 | 189 if (_acceptChannel != null) |
190 _acceptChannel.close(); | |
191 _acceptChannel=null; | |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
192 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
193 catch (IOException e) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
194 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
195 LOG.warn("",e); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
196 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
197 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
198 super.doStop(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
199 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
200 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
201 |
914
54308d65265a
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
913
diff
changeset
|
202 protected final void configure(Socket socket) throws IOException |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
203 { |
914
54308d65265a
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
913
diff
changeset
|
204 socket.setTcpNoDelay(true); |
54308d65265a
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
913
diff
changeset
|
205 if (_soLingerTime >= 0) |
54308d65265a
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
913
diff
changeset
|
206 socket.setSoLinger(true,_soLingerTime / 1000); |
54308d65265a
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
913
diff
changeset
|
207 else |
54308d65265a
simplify SelectorManager
Franklin Schmidt <fschmidt@gmail.com>
parents:
913
diff
changeset
|
208 socket.setSoLinger(false,0); |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
209 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
210 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
211 public void customize(EndPoint endpoint, Request request) throws IOException |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
212 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
213 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
214 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
215 public void persist(EndPoint endpoint) throws IOException |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
216 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
217 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
218 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
219 public boolean isConfidential(Request request) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
220 { |
889 | 221 return false; |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
222 } |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
223 |
906 | 224 protected abstract void accept() throws IOException, InterruptedException; |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
225 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
226 public void stopAccept(int acceptorID) throws Exception |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
227 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
228 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
229 |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
230 public int getRequestBufferSize() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
231 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
232 return _buffers.getRequestBufferSize(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
233 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
234 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
235 public void setRequestBufferSize(int requestBufferSize) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
236 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
237 _buffers.setRequestBufferSize(requestBufferSize); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
238 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
239 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
240 public int getRequestHeaderSize() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
241 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
242 return _buffers.getRequestHeaderSize(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
243 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
244 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
245 public void setRequestHeaderSize(int requestHeaderSize) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
246 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
247 _buffers.setRequestHeaderSize(requestHeaderSize); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
248 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
249 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
250 public int getResponseBufferSize() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
251 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
252 return _buffers.getResponseBufferSize(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
253 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
254 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
255 public void setResponseBufferSize(int responseBufferSize) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
256 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
257 _buffers.setResponseBufferSize(responseBufferSize); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
258 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
259 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
260 public int getResponseHeaderSize() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
261 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
262 return _buffers.getResponseHeaderSize(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
263 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
264 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
265 public void setResponseHeaderSize(int responseHeaderSize) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
266 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
267 _buffers.setResponseHeaderSize(responseHeaderSize); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
268 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
269 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
270 public Type getRequestBufferType() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
271 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
272 return _buffers.getRequestBufferType(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
273 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
274 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
275 public Type getRequestHeaderType() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
276 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
277 return _buffers.getRequestHeaderType(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
278 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
279 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
280 public Type getResponseBufferType() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
281 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
282 return _buffers.getResponseBufferType(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
283 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
284 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
285 public Type getResponseHeaderType() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
286 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
287 return _buffers.getResponseHeaderType(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
288 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
289 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
290 public void setRequestBuffers(Buffers requestBuffers) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
291 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
292 _buffers.setRequestBuffers(requestBuffers); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
293 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
294 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
295 public void setResponseBuffers(Buffers responseBuffers) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
296 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
297 _buffers.setResponseBuffers(responseBuffers); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
298 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
299 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
300 public Buffers getRequestBuffers() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
301 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
302 return _buffers.getRequestBuffers(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
303 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
304 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
305 public Buffers getResponseBuffers() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
306 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
307 return _buffers.getResponseBuffers(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
308 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
309 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
310 public int getMaxBuffers() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
311 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
312 return _buffers.getMaxBuffers(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
313 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
314 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
315 @Override |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
316 public String toString() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
317 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
318 return String.format("%s@%s:%d", |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
319 getClass().getSimpleName(), |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
320 getHost()==null?"0.0.0.0":getHost(), |
909 | 321 port); |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
322 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
323 |
909 | 324 |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
325 private class Acceptor implements Runnable |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
326 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
327 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
328 public void run() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
329 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
330 Thread current = Thread.currentThread(); |
905
e7175965e6cf
remove Connector._acceptorThreads
Franklin Schmidt <fschmidt@gmail.com>
parents:
904
diff
changeset
|
331 String name = current.getName(); |
906 | 332 current.setName(name + " Acceptor" + " " + Connector.this); |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
333 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
334 try |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
335 { |
909 | 336 while (isRunning() && _acceptChannel != null) |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
337 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
338 try |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
339 { |
906 | 340 accept(); |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
341 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
342 catch (EofException e) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
343 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
344 LOG.trace("",e); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
345 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
346 catch (IOException e) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
347 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
348 LOG.trace("",e); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
349 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
350 catch (InterruptedException x) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
351 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
352 // Connector has been stopped |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
353 LOG.trace("",x); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
354 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
355 catch (Throwable e) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
356 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
357 LOG.warn("",e); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
358 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
359 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
360 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
361 finally |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
362 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
363 current.setName(name); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
364 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
365 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
366 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
367 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
368 public String getName() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
369 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
370 if (_name == null) |
909 | 371 _name = (getHost() == null?"0.0.0.0":getHost()) + ":" + port; |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
372 return _name; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
373 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
374 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
375 public final boolean isLowResources() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
376 { |
887
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
377 return server.isLowOnThreads(); |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
378 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
379 |
907
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
380 |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
381 // from AbstractNIOConnector |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
382 |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
383 /* ------------------------------------------------------------------------------- */ |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
384 public boolean getUseDirectBuffers() |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
385 { |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
386 return getRequestBufferType()==Type.DIRECT; |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
387 } |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
388 |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
389 /* ------------------------------------------------------------------------------- */ |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
390 /** |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
391 * @param direct If True (the default), the connector can use NIO direct buffers. |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
392 * Some JVMs have memory management issues (bugs) with direct buffers. |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
393 */ |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
394 public void setUseDirectBuffers(boolean direct) |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
395 { |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
396 _buffers.setRequestBufferType(direct?Type.DIRECT:Type.INDIRECT); |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
397 _buffers.setResponseBufferType(direct?Type.DIRECT:Type.INDIRECT); |
bc4e299de953
remove AbstractNIOConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
906
diff
changeset
|
398 } |
909 | 399 |
400 | |
401 // from child classes | |
402 | |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
403 } |