1
2
3
4
5
6
7
8
9
10
11
12
13
14 package org.eclipse.jetty.ajp;
15
16 import java.io.IOException;
17
18 import org.eclipse.jetty.http.HttpSchemes;
19 import org.eclipse.jetty.io.EndPoint;
20 import org.eclipse.jetty.server.HttpConnection;
21 import org.eclipse.jetty.server.Request;
22 import org.eclipse.jetty.server.bio.SocketConnector;
23 import org.eclipse.jetty.util.log.Log;
24
25
26
27
28
29
30 public class Ajp13SocketConnector extends SocketConnector
31 {
32 static String __secretWord = null;
33 static boolean __allowShutdown = false;
34 public Ajp13SocketConnector()
35 {
36 super.setHeaderBufferSize(Ajp13Packet.MAX_DATA_SIZE);
37 super.setRequestBufferSize(Ajp13Packet.MAX_DATA_SIZE);
38 super.setResponseBufferSize(Ajp13Packet.MAX_DATA_SIZE);
39
40
41 super.setMaxIdleTime(900000);
42 }
43
44 protected void doStart() throws Exception
45 {
46 super.doStart();
47 Log.info("AJP13 is not a secure protocol. Please protect port {}",Integer.toString(getLocalPort()));
48 }
49
50
51
52
53
54
55
56 public void customize(EndPoint endpoint, Request request) throws IOException
57 {
58 super.customize(endpoint,request);
59 if (request.isSecure())
60 request.setScheme(HttpSchemes.HTTPS);
61 }
62
63
64 protected HttpConnection newHttpConnection(EndPoint endpoint)
65 {
66 return new Ajp13Connection(this,endpoint,getServer());
67 }
68
69
70
71 public boolean isConfidential(Request request)
72 {
73 return ((Ajp13Request) request).isSslSecure();
74 }
75
76
77
78 public boolean isIntegral(Request request)
79 {
80 return ((Ajp13Request) request).isSslSecure();
81 }
82
83
84 public void setHeaderBufferSize(int headerBufferSize)
85 {
86 Log.debug(Log.IGNORED);
87 }
88
89
90 public void setRequestBufferSize(int requestBufferSize)
91 {
92 Log.debug(Log.IGNORED);
93 }
94
95
96 public void setResponseBufferSize(int responseBufferSize)
97 {
98 Log.debug(Log.IGNORED);
99 }
100
101
102 public void setAllowShutdown(boolean allowShutdown)
103 {
104 Log.warn("AJP13: Shutdown Request is: " + allowShutdown);
105 __allowShutdown = allowShutdown;
106 }
107
108
109 public void setSecretWord(String secretWord)
110 {
111 Log.warn("AJP13: Shutdown Request secret word is : " + secretWord);
112 __secretWord = secretWord;
113 }
114
115 }