Mercurial Hosting > luan
annotate src/org/eclipse/jetty/server/Connector.java @ 890:5dc615c34848
remove _integralPort
author | Franklin Schmidt <fschmidt@gmail.com> |
---|---|
date | Thu, 06 Oct 2016 23:29:22 -0600 |
parents | 5731a7707466 |
children | b48361bd68e3 |
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; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
25 import java.util.concurrent.ThreadPoolExecutor; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
26 import java.util.concurrent.atomic.AtomicLong; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
27 |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
28 import javax.servlet.ServletRequest; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
29 |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
30 import org.eclipse.jetty.http.HttpBuffers; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
31 import org.eclipse.jetty.http.HttpBuffersImpl; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
32 import org.eclipse.jetty.http.HttpFields; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
33 import org.eclipse.jetty.http.HttpHeaders; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
34 import org.eclipse.jetty.http.HttpSchemes; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
35 import org.eclipse.jetty.io.Buffers; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
36 import org.eclipse.jetty.io.Buffers.Type; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
37 import org.eclipse.jetty.io.Connection; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
38 import org.eclipse.jetty.io.EndPoint; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
39 import org.eclipse.jetty.io.EofException; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
40 import org.eclipse.jetty.util.component.AggregateLifeCycle; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
41 import org.eclipse.jetty.util.component.Dumpable; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
42 import org.slf4j.Logger; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
43 import org.slf4j.LoggerFactory; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
44 |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
45 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
46 * Abstract Connector implementation. This abstract implementation of the Connector interface provides: |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
47 * <ul> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
48 * <li>AbstractLifeCycle implementation</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
49 * <li>Implementations for connector getters and setters</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
50 * <li>Buffer management</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
51 * <li>Socket configuration</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
52 * <li>Base acceptor thread</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
53 * <li>Optional reverse proxy headers checking</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
54 * </ul> |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
55 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
56 public abstract class Connector extends AggregateLifeCycle implements HttpBuffers, Dumpable |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
57 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
58 private static final Logger LOG = LoggerFactory.getLogger(Connector.class); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
59 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
60 private String _name; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
61 |
887
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
62 public final Server server; |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
63 private String _host; |
887
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
64 public final int port; |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
65 private String _integralScheme = HttpSchemes.HTTPS; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
66 private String _confidentialScheme = HttpSchemes.HTTPS; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
67 private int _confidentialPort = 0; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
68 private int _acceptors = 1; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
69 private int _acceptorPriorityOffset = 0; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
70 private boolean _useDNS; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
71 private String _hostHeader; |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
72 |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
73 private String _forwardedHostHeader = HttpHeaders.X_FORWARDED_HOST; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
74 private String _forwardedServerHeader = HttpHeaders.X_FORWARDED_SERVER; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
75 private String _forwardedForHeader = HttpHeaders.X_FORWARDED_FOR; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
76 private String _forwardedProtoHeader = HttpHeaders.X_FORWARDED_PROTO; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
77 private String _forwardedCipherSuiteHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
78 private String _forwardedSslSessionIdHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
79 private boolean _reuseAddress = true; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
80 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
81 protected int _maxIdleTime = 200000; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
82 protected int _lowResourceMaxIdleTime = -1; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
83 protected int _soLingerTime = -1; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
84 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
85 private transient Thread[] _acceptorThreads; |
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 protected final HttpBuffersImpl _buffers = new HttpBuffersImpl(); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
88 |
887
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
89 public Connector(Server server,int port) { |
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
90 this.server = server; |
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
91 this.port = port; |
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
92 server.connectors.add(this); |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
93 addBean(_buffers); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
94 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
95 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
96 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
97 /** |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
98 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
99 public void setHost(String host) |
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 _host = host; |
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 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
104 /* ------------------------------------------------------------ */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
105 /* |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
106 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
107 public String getHost() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
108 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
109 return _host; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
110 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
111 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
112 /* ------------------------------------------------------------ */ |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
113 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
114 * @return Returns the maxIdleTime. |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
115 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
116 public int getMaxIdleTime() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
117 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
118 return _maxIdleTime; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
119 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
120 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
121 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
122 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
123 * 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
|
124 * 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
|
125 * <ul> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
126 * <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
|
127 * <li>When reading the headers and content of a request</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
128 * <li>When writing the headers and content of a response</li> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
129 * </ul> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
130 * 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
|
131 * 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
|
132 * 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
|
133 * 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
|
134 * <p> |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
135 * 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
|
136 * 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
|
137 * |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
138 * @param maxIdleTime |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
139 * The maxIdleTime to set. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
140 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
141 public void setMaxIdleTime(int maxIdleTime) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
142 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
143 _maxIdleTime = maxIdleTime; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
144 } |
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 * @return Returns the maxIdleTime when resources are low. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
149 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
150 public int getLowResourcesMaxIdleTime() |
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 return _lowResourceMaxIdleTime; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
153 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
154 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
155 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
156 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
157 * @param maxIdleTime |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
158 * The maxIdleTime to set when resources are low. |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
159 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
160 public void setLowResourcesMaxIdleTime(int maxIdleTime) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
161 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
162 _lowResourceMaxIdleTime = maxIdleTime; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
163 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
164 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
165 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
166 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
167 * @return Returns the maxIdleTime when resources are low. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
168 * @deprecated |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
169 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
170 @Deprecated |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
171 public final int getLowResourceMaxIdleTime() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
172 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
173 return getLowResourcesMaxIdleTime(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
174 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
175 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
176 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
177 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
178 * @param maxIdleTime |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
179 * The maxIdleTime to set when resources are low. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
180 * @deprecated |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
181 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
182 @Deprecated |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
183 public final void setLowResourceMaxIdleTime(int maxIdleTime) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
184 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
185 setLowResourcesMaxIdleTime(maxIdleTime); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
186 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
187 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
188 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
189 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
190 * @return Returns the soLingerTime. |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
191 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
192 public int getSoLingerTime() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
193 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
194 return _soLingerTime; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
195 } |
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 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
199 * @return Returns the number of acceptor threads. |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
200 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
201 public int getAcceptors() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
202 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
203 return _acceptors; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
204 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
205 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
206 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
207 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
208 * @param acceptors |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
209 * The number of acceptor threads to set. |
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 setAcceptors(int acceptors) |
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 if (acceptors > 2 * Runtime.getRuntime().availableProcessors()) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
214 LOG.warn("Acceptors should be <=2*availableProcessors: " + this); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
215 _acceptors = acceptors; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
216 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
217 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
218 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
219 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
220 * @param soLingerTime |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
221 * The soLingerTime to set or -1 to disable. |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
222 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
223 public void setSoLingerTime(int soLingerTime) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
224 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
225 _soLingerTime = soLingerTime; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
226 } |
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 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
229 @Override |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
230 protected void doStart() throws Exception |
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 // open listener port |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
233 open(); |
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 super.doStart(); |
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 // Start selector thread |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
238 synchronized (this) |
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 _acceptorThreads = new Thread[getAcceptors()]; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
241 |
887
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
242 ThreadPoolExecutor _threadPool = server.threadPool; |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
243 for (int i = 0; i < _acceptorThreads.length; i++) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
244 _threadPool.execute(new Acceptor(i)); |
887
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
245 if (server.isLowOnThreads()) |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
246 LOG.warn("insufficient threads configured for {}",this); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
247 } |
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 LOG.info("Started {}",this); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
250 } |
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 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
253 @Override |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
254 protected void doStop() throws Exception |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
255 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
256 try |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
257 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
258 close(); |
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 catch (IOException e) |
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 LOG.warn("",e); |
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 super.doStop(); |
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 Thread[] acceptors; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
268 synchronized (this) |
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 acceptors = _acceptorThreads; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
271 _acceptorThreads = null; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
272 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
273 if (acceptors != null) |
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 for (Thread thread : acceptors) |
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 if (thread != null) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
278 thread.interrupt(); |
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 } |
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 |
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 public void join() throws InterruptedException |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
285 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
286 Thread[] threads; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
287 synchronized(this) |
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 threads=_acceptorThreads; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
290 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
291 if (threads != null) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
292 for (Thread thread : threads) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
293 if (thread != null) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
294 thread.join(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
295 } |
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 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
298 protected void configure(Socket socket) throws IOException |
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 try |
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 socket.setTcpNoDelay(true); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
303 if (_soLingerTime >= 0) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
304 socket.setSoLinger(true,_soLingerTime / 1000); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
305 else |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
306 socket.setSoLinger(false,0); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
307 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
308 catch (Exception e) |
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 LOG.trace("",e); |
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 } |
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 public void customize(EndPoint endpoint, Request request) throws IOException |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
315 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
316 } |
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 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
319 protected String getLeftMostFieldValue(HttpFields fields, String header) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
320 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
321 if (header == null) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
322 return null; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
323 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
324 String headerValue = fields.getStringField(header); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
325 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
326 if (headerValue == null) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
327 return null; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
328 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
329 int commaIndex = headerValue.indexOf(','); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
330 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
331 if (commaIndex == -1) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
332 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
333 // Single value |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
334 return headerValue; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
335 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
336 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
337 // The left-most value is the farthest downstream client |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
338 return headerValue.substring(0,commaIndex); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
339 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
340 |
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 public void persist(EndPoint endpoint) throws IOException |
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 } |
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 /* ------------------------------------------------------------ */ |
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 * @see org.eclipse.jetty.server.Connector#getConfidentialPort() |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
349 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
350 public int getConfidentialPort() |
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 return _confidentialPort; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
353 } |
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 /* ------------------------------------------------------------ */ |
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 /* |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
358 * @see org.eclipse.jetty.server.Connector#getConfidentialScheme() |
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 public String getConfidentialScheme() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
361 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
362 return _confidentialScheme; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
363 } |
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 * @see org.eclipse.jetty.server.Connector#isConfidential(org.eclipse.jetty.server .Request) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
368 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
369 public boolean isIntegral(Request request) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
370 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
371 return false; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
372 } |
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 /* |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
376 * @see org.eclipse.jetty.server.Connector#getIntegralScheme() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
377 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
378 public String getIntegralScheme() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
379 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
380 return _integralScheme; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
381 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
382 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
383 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
384 /* |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
385 * @see org.eclipse.jetty.server.Connector#isConfidential(org.eclipse.jetty.server.Request) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
386 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
387 public boolean isConfidential(Request request) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
388 { |
889 | 389 return false; |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
390 } |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
391 |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
392 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
393 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
394 * @param confidentialPort |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
395 * The confidentialPort to set. |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
396 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
397 public void setConfidentialPort(int confidentialPort) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
398 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
399 _confidentialPort = confidentialPort; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
400 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
401 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
402 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
403 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
404 * @param confidentialScheme |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
405 * The confidentialScheme to set. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
406 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
407 public void setConfidentialScheme(String confidentialScheme) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
408 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
409 _confidentialScheme = confidentialScheme; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
410 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
411 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
412 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
413 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
414 * @param integralScheme |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
415 * The integralScheme to set. |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
416 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
417 public void setIntegralScheme(String integralScheme) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
418 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
419 _integralScheme = integralScheme; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
420 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
421 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
422 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
423 protected abstract void accept(int acceptorID) throws IOException, InterruptedException; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
424 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
425 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
426 public void stopAccept(int acceptorID) throws Exception |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
427 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
428 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
429 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
430 /* ------------------------------------------------------------ */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
431 public boolean getResolveNames() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
432 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
433 return _useDNS; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
434 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
435 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
436 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
437 public void setResolveNames(boolean resolve) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
438 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
439 _useDNS = resolve; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
440 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
441 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
442 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
443 public String getHostHeader() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
444 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
445 return _hostHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
446 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
447 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
448 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
449 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
450 * Set a forced valued for the host header to control what is returned by {@link ServletRequest#getServerName()} and {@link ServletRequest#getServerPort()}. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
451 * This value is only used if {@link #isForwarded()} is true. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
452 * |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
453 * @param hostHeader |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
454 * The value of the host header to force. |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
455 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
456 public void setHostHeader(String hostHeader) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
457 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
458 _hostHeader = hostHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
459 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
460 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
461 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
462 /* |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
463 * |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
464 * @see #setForwarded(boolean) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
465 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
466 public String getForwardedHostHeader() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
467 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
468 return _forwardedHostHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
469 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
470 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
471 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
472 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
473 * @param forwardedHostHeader |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
474 * The header name for forwarded hosts (default x-forwarded-host) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
475 * @see #setForwarded(boolean) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
476 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
477 public void setForwardedHostHeader(String forwardedHostHeader) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
478 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
479 _forwardedHostHeader = forwardedHostHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
480 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
481 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
482 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
483 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
484 * @return the header name for forwarded server. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
485 * @see #setForwarded(boolean) |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
486 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
487 public String getForwardedServerHeader() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
488 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
489 return _forwardedServerHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
490 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
491 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
492 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
493 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
494 * @param forwardedServerHeader |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
495 * The header name for forwarded server (default x-forwarded-server) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
496 * @see #setForwarded(boolean) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
497 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
498 public void setForwardedServerHeader(String forwardedServerHeader) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
499 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
500 _forwardedServerHeader = forwardedServerHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
501 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
502 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
503 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
504 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
505 * @see #setForwarded(boolean) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
506 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
507 public String getForwardedForHeader() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
508 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
509 return _forwardedForHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
510 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
511 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
512 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
513 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
514 * @param forwardedRemoteAddressHeader |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
515 * The header name for forwarded for (default x-forwarded-for) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
516 * @see #setForwarded(boolean) |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
517 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
518 public void setForwardedForHeader(String forwardedRemoteAddressHeader) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
519 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
520 _forwardedForHeader = forwardedRemoteAddressHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
521 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
522 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
523 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
524 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
525 * Get the forwardedProtoHeader. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
526 * |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
527 * @return the forwardedProtoHeader (default X-Forwarded-For) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
528 * @see #setForwarded(boolean) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
529 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
530 public String getForwardedProtoHeader() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
531 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
532 return _forwardedProtoHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
533 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
534 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
535 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
536 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
537 * Set the forwardedProtoHeader. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
538 * |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
539 * @param forwardedProtoHeader |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
540 * the forwardedProtoHeader to set (default X-Forwarded-For) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
541 * @see #setForwarded(boolean) |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
542 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
543 public void setForwardedProtoHeader(String forwardedProtoHeader) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
544 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
545 _forwardedProtoHeader = forwardedProtoHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
546 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
547 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
548 /* ------------------------------------------------------------ */ |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
549 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
550 * @return The header name holding a forwarded cipher suite (default null) |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
551 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
552 public String getForwardedCipherSuiteHeader() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
553 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
554 return _forwardedCipherSuiteHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
555 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
556 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
557 /* ------------------------------------------------------------ */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
558 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
559 * @param forwardedCipherSuite |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
560 * The header name holding a forwarded cipher suite (default null) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
561 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
562 public void setForwardedCipherSuiteHeader(String forwardedCipherSuite) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
563 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
564 _forwardedCipherSuiteHeader = forwardedCipherSuite; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
565 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
566 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
567 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
568 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
569 * @return The header name holding a forwarded SSL Session ID (default null) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
570 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
571 public String getForwardedSslSessionIdHeader() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
572 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
573 return _forwardedSslSessionIdHeader; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
574 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
575 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
576 /* ------------------------------------------------------------ */ |
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
577 /** |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
578 * @param forwardedSslSessionId |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
579 * The header name holding a forwarded SSL Session ID (default null) |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
580 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
581 public void setForwardedSslSessionIdHeader(String forwardedSslSessionId) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
582 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
583 _forwardedSslSessionIdHeader = forwardedSslSessionId; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
584 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
585 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
586 public int getRequestBufferSize() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
587 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
588 return _buffers.getRequestBufferSize(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
589 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
590 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
591 public void setRequestBufferSize(int requestBufferSize) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
592 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
593 _buffers.setRequestBufferSize(requestBufferSize); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
594 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
595 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
596 public int getRequestHeaderSize() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
597 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
598 return _buffers.getRequestHeaderSize(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
599 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
600 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
601 public void setRequestHeaderSize(int requestHeaderSize) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
602 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
603 _buffers.setRequestHeaderSize(requestHeaderSize); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
604 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
605 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
606 public int getResponseBufferSize() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
607 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
608 return _buffers.getResponseBufferSize(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
609 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
610 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
611 public void setResponseBufferSize(int responseBufferSize) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
612 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
613 _buffers.setResponseBufferSize(responseBufferSize); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
614 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
615 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
616 public int getResponseHeaderSize() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
617 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
618 return _buffers.getResponseHeaderSize(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
619 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
620 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
621 public void setResponseHeaderSize(int responseHeaderSize) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
622 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
623 _buffers.setResponseHeaderSize(responseHeaderSize); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
624 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
625 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
626 public Type getRequestBufferType() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
627 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
628 return _buffers.getRequestBufferType(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
629 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
630 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
631 public Type getRequestHeaderType() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
632 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
633 return _buffers.getRequestHeaderType(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
634 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
635 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
636 public Type getResponseBufferType() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
637 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
638 return _buffers.getResponseBufferType(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
639 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
640 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
641 public Type getResponseHeaderType() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
642 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
643 return _buffers.getResponseHeaderType(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
644 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
645 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
646 public void setRequestBuffers(Buffers requestBuffers) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
647 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
648 _buffers.setRequestBuffers(requestBuffers); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
649 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
650 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
651 public void setResponseBuffers(Buffers responseBuffers) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
652 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
653 _buffers.setResponseBuffers(responseBuffers); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
654 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
655 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
656 public Buffers getRequestBuffers() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
657 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
658 return _buffers.getRequestBuffers(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
659 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
660 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
661 public Buffers getResponseBuffers() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
662 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
663 return _buffers.getResponseBuffers(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
664 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
665 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
666 public int getMaxBuffers() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
667 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
668 return _buffers.getMaxBuffers(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
669 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
670 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
671 /* ------------------------------------------------------------ */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
672 @Override |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
673 public String toString() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
674 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
675 return String.format("%s@%s:%d", |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
676 getClass().getSimpleName(), |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
677 getHost()==null?"0.0.0.0":getHost(), |
887
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
678 getLocalPort()<=0 ? port : getLocalPort()); |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
679 } |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
680 |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
681 /* ------------------------------------------------------------ */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
682 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
683 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
684 private class Acceptor implements Runnable |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
685 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
686 int _acceptor = 0; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
687 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
688 Acceptor(int id) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
689 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
690 _acceptor = id; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
691 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
692 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
693 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
694 public void run() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
695 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
696 Thread current = Thread.currentThread(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
697 String name; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
698 synchronized (Connector.this) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
699 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
700 if (_acceptorThreads == null) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
701 return; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
702 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
703 _acceptorThreads[_acceptor] = current; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
704 name = _acceptorThreads[_acceptor].getName(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
705 current.setName(name + " Acceptor" + _acceptor + " " + Connector.this); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
706 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
707 int old_priority = current.getPriority(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
708 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
709 try |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
710 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
711 current.setPriority(old_priority - _acceptorPriorityOffset); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
712 while (isRunning() && getConnection() != null) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
713 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
714 try |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
715 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
716 accept(_acceptor); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
717 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
718 catch (EofException e) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
719 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
720 LOG.trace("",e); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
721 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
722 catch (IOException e) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
723 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
724 LOG.trace("",e); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
725 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
726 catch (InterruptedException x) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
727 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
728 // Connector has been stopped |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
729 LOG.trace("",x); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
730 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
731 catch (Throwable e) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
732 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
733 LOG.warn("",e); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
734 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
735 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
736 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
737 finally |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
738 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
739 current.setPriority(old_priority); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
740 current.setName(name); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
741 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
742 synchronized (Connector.this) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
743 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
744 if (_acceptorThreads != null) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
745 _acceptorThreads[_acceptor] = null; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
746 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
747 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
748 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
749 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
750 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
751 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
752 public String getName() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
753 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
754 if (_name == null) |
887
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
755 _name = (getHost() == null?"0.0.0.0":getHost()) + ":" + (getLocalPort() <= 0?port:getLocalPort()); |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
756 return _name; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
757 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
758 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
759 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
760 public void setName(String name) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
761 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
762 _name = name; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
763 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
764 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
765 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
766 protected void connectionOpened(Connection connection) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
767 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
768 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
769 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
770 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
771 protected void connectionUpgraded(Connection oldConnection, Connection newConnection) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
772 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
773 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
774 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
775 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
776 protected void connectionClosed(Connection connection) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
777 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
778 connection.onClose(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
779 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
780 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
781 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
782 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
783 * @return the acceptorPriority |
818
ad292e148964
remove util/statistic
Franklin Schmidt <fschmidt@gmail.com>
parents:
802
diff
changeset
|
784 */ |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
785 public int getAcceptorPriorityOffset() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
786 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
787 return _acceptorPriorityOffset; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
788 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
789 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
790 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
791 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
792 * Set the priority offset of the acceptor threads. The priority is adjusted by this amount (default 0) to either favour the acceptance of new threads and |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
793 * newly active connections or to favour the handling of already dispatched connections. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
794 * |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
795 * @param offset |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
796 * the amount to alter the priority of the acceptor threads. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
797 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
798 public void setAcceptorPriorityOffset(int offset) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
799 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
800 _acceptorPriorityOffset = offset; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
801 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
802 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
803 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
804 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
805 * @return True if the the server socket will be opened in SO_REUSEADDR mode. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
806 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
807 public boolean getReuseAddress() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
808 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
809 return _reuseAddress; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
810 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
811 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
812 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
813 /** |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
814 * @param reuseAddress |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
815 * True if the the server socket will be opened in SO_REUSEADDR mode. |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
816 */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
817 public void setReuseAddress(boolean reuseAddress) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
818 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
819 _reuseAddress = reuseAddress; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
820 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
821 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
822 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
823 public final boolean isLowResources() |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
824 { |
887
df84a1741687
make Connector reference to server explicit
Franklin Schmidt <fschmidt@gmail.com>
parents:
885
diff
changeset
|
825 return server.isLowOnThreads(); |
885
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
826 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
827 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
828 /* ------------------------------------------------------------ */ |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
829 private void updateNotEqual(AtomicLong valueHolder, long compare, long value) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
830 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
831 long oldValue = valueHolder.get(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
832 while (compare != oldValue) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
833 { |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
834 if (valueHolder.compareAndSet(oldValue,value)) |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
835 break; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
836 oldValue = valueHolder.get(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
837 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
838 } |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
839 |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
840 // from old interface |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
841 public abstract void open() throws IOException; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
842 public abstract void close() throws IOException; |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
843 public abstract int getLocalPort(); |
150092cebf3e
remove AbstractConnector
Franklin Schmidt <fschmidt@gmail.com>
parents:
865
diff
changeset
|
844 public abstract Object getConnection(); |
802
3428c60d7cfc
replace jetty jars with source
Franklin Schmidt <fschmidt@gmail.com>
parents:
diff
changeset
|
845 } |