View Javadoc

1   /*
2    * ====================================================================
3    * Licensed to the Apache Software Foundation (ASF) under one
4    * or more contributor license agreements.  See the NOTICE file
5    * distributed with this work for additional information
6    * regarding copyright ownership.  The ASF licenses this file
7    * to you under the Apache License, Version 2.0 (the
8    * "License"); you may not use this file except in compliance
9    * with the License.  You may obtain a copy of the License at
10   *
11   *   http://www.apache.org/licenses/LICENSE-2.0
12   *
13   * Unless required by applicable law or agreed to in writing,
14   * software distributed under the License is distributed on an
15   * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16   * KIND, either express or implied.  See the License for the
17   * specific language governing permissions and limitations
18   * under the License.
19   * ====================================================================
20   *
21   * This software consists of voluntary contributions made by many
22   * individuals on behalf of the Apache Software Foundation.  For more
23   * information on the Apache Software Foundation, please see
24   * <http://www.apache.org/>.
25   *
26   */
27  
28  package org.apache.http.impl.nio.codecs;
29  
30  import org.apache.http.HttpException;
31  import org.apache.http.HttpRequest;
32  import org.apache.http.HttpRequestFactory;
33  import org.apache.http.ParseException;
34  import org.apache.http.RequestLine;
35  import org.apache.http.annotation.NotThreadSafe;
36  import org.apache.http.config.MessageConstraints;
37  import org.apache.http.impl.DefaultHttpRequestFactory;
38  import org.apache.http.message.LineParser;
39  import org.apache.http.message.ParserCursor;
40  import org.apache.http.nio.reactor.SessionInputBuffer;
41  import org.apache.http.params.HttpParams;
42  import org.apache.http.util.Args;
43  import org.apache.http.util.CharArrayBuffer;
44  
45  /**
46   * Default {@link org.apache.http.nio.NHttpMessageParser} implementation
47   * for {@link HttpRequest}s.
48   *
49   * @since 4.1
50   */
51  @SuppressWarnings("deprecation")
52  @NotThreadSafe
53  public class DefaultHttpRequestParser extends AbstractMessageParser<HttpRequest> {
54  
55      private final HttpRequestFactory requestFactory;
56  
57      /**
58       * Creates an instance of this class.
59       *
60       * @param buffer the session input buffer.
61       * @param parser the line parser.
62       * @param params HTTP parameters.
63       *
64       * @deprecated (4.3) use
65       *   {@link DefaultHttpRequestParser#DefaultHttpRequestParser(
66       *   SessionInputBuffer, LineParser, HttpRequestFactory, MessageConstraints)}
67       */
68      @Deprecated
69      public DefaultHttpRequestParser(
70              final SessionInputBuffer buffer,
71              final LineParser parser,
72              final HttpRequestFactory requestFactory,
73              final HttpParams params) {
74          super(buffer, parser, params);
75          Args.notNull(requestFactory, "Request factory");
76          this.requestFactory = requestFactory;
77      }
78  
79      /**
80       * Creates an instance of DefaultHttpRequestParser.
81       *
82       * @param buffer the session input buffer.
83       * @param parser the line parser. If <code>null</code>
84       *   {@link org.apache.http.message.BasicLineParser#INSTANCE} will be used.
85       * @param requestFactory the request factory. If <code>null</code>
86       *   {@link DefaultHttpRequestFactory#INSTANCE} will be used.
87       * @param constraints Message constraints. If <code>null</code>
88       *   {@link MessageConstraints#DEFAULT} will be used.
89       *
90       * @since 4.3
91       */
92      public DefaultHttpRequestParser(
93              final SessionInputBuffer buffer,
94              final LineParser parser,
95              final HttpRequestFactory requestFactory,
96              final MessageConstraints constraints) {
97          super(buffer, parser, constraints);
98          this.requestFactory = requestFactory != null ? requestFactory : DefaultHttpRequestFactory.INSTANCE;
99      }
100 
101     /**
102     * @since 4.3
103     */
104     public DefaultHttpRequestParser(final SessionInputBuffer buffer, final MessageConstraints constraints) {
105         this(buffer, null, null, constraints);
106     }
107 
108     /**
109     * @since 4.3
110     */
111     public DefaultHttpRequestParser(final SessionInputBuffer buffer) {
112         this(buffer, null);
113     }
114 
115     @Override
116     protected HttpRequest createMessage(final CharArrayBuffer buffer)
117             throws HttpException, ParseException {
118         final ParserCursor cursor = new ParserCursor(0, buffer.length());
119         final RequestLine requestLine = lineParser.parseRequestLine(buffer, cursor);
120         return this.requestFactory.newHttpRequest(requestLine);
121     }
122 
123 }