View Javadoc

1   // ========================================================================
2   // Copyright (c) 2006-2009 Mort Bay Consulting Pty. Ltd.
3   // ------------------------------------------------------------------------
4   // All rights reserved. This program and the accompanying materials
5   // are made available under the terms of the Eclipse Public License v1.0
6   // and Apache License v2.0 which accompanies this distribution.
7   // The Eclipse Public License is available at 
8   // http://www.eclipse.org/legal/epl-v10.html
9   // The Apache License v2.0 is available at
10  // http://www.opensource.org/licenses/apache2.0.php
11  // You may elect to redistribute this code under either of these licenses. 
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          // IN AJP protocol the socket stay open, so
40          // by default the time out is set to 900 seconds
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      /* (non-Javadoc)
54       * @see org.eclipse.jetty.server.bio.SocketConnector#customize(org.eclipse.io.EndPoint, org.eclipse.jetty.server.Request)
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      // Secured on a packet by packet bases not by connection
71      public boolean isConfidential(Request request)
72      {
73          return ((Ajp13Request) request).isSslSecure();
74      }
75  
76      /* ------------------------------------------------------------ */
77      // Secured on a packet by packet bases not by connection
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 }