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.Connection;
20 import org.eclipse.jetty.io.EndPoint;
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.setRequestHeaderSize(Ajp13Packet.MAX_PACKET_SIZE);
37 super.setResponseHeaderSize(Ajp13Packet.MAX_PACKET_SIZE);
38 super.setRequestBufferSize(Ajp13Packet.MAX_PACKET_SIZE);
39 super.setResponseBufferSize(Ajp13Packet.MAX_PACKET_SIZE);
40
41
42 super.setMaxIdleTime(0);
43 }
44
45 @Override
46 protected void doStart() throws Exception
47 {
48 super.doStart();
49 Log.info("AJP13 is not a secure protocol. Please protect port {}",Integer.toString(getLocalPort()));
50 }
51
52
53
54
55
56
57
58 @Override
59 public void customize(EndPoint endpoint, Request request) throws IOException
60 {
61 super.customize(endpoint,request);
62 if (request.isSecure())
63 request.setScheme(HttpSchemes.HTTPS);
64 }
65
66
67 @Override
68 protected Connection newConnection(EndPoint endpoint)
69 {
70 return new Ajp13Connection(this,endpoint,getServer());
71 }
72
73
74
75 @Override
76 public boolean isConfidential(Request request)
77 {
78 return ((Ajp13Request) request).isSslSecure();
79 }
80
81
82
83 @Override
84 public boolean isIntegral(Request request)
85 {
86 return ((Ajp13Request) request).isSslSecure();
87 }
88
89
90 @Deprecated
91 public void setHeaderBufferSize(int headerBufferSize)
92 {
93 Log.debug(Log.IGNORED);
94 }
95
96
97 @Override
98 public void setRequestBufferSize(int requestBufferSize)
99 {
100 Log.debug(Log.IGNORED);
101 }
102
103
104 @Override
105 public void setResponseBufferSize(int responseBufferSize)
106 {
107 Log.debug(Log.IGNORED);
108 }
109
110
111 public void setAllowShutdown(boolean allowShutdown)
112 {
113 Log.warn("AJP13: Shutdown Request is: " + allowShutdown);
114 __allowShutdown = allowShutdown;
115 }
116
117
118 public void setSecretWord(String secretWord)
119 {
120 Log.warn("AJP13: Shutdown Request secret word is : " + secretWord);
121 __secretWord = secretWord;
122 }
123
124 }