| Index: net/http/http_stream_parser.h
|
| diff --git a/net/http/http_stream_parser.h b/net/http/http_stream_parser.h
|
| deleted file mode 100644
|
| index a8d0447a086572ad51f23ffb7ad4a1910a8cdcaf..0000000000000000000000000000000000000000
|
| --- a/net/http/http_stream_parser.h
|
| +++ /dev/null
|
| @@ -1,257 +0,0 @@
|
| -// Copyright (c) 2012 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#ifndef NET_HTTP_HTTP_STREAM_PARSER_H_
|
| -#define NET_HTTP_HTTP_STREAM_PARSER_H_
|
| -
|
| -#include <string>
|
| -
|
| -#include "base/basictypes.h"
|
| -#include "base/memory/ref_counted.h"
|
| -#include "base/memory/scoped_ptr.h"
|
| -#include "base/memory/weak_ptr.h"
|
| -#include "base/strings/string_piece.h"
|
| -#include "net/base/completion_callback.h"
|
| -#include "net/base/net_export.h"
|
| -#include "net/base/net_log.h"
|
| -#include "net/base/upload_progress.h"
|
| -
|
| -namespace net {
|
| -
|
| -class ClientSocketHandle;
|
| -class DrainableIOBuffer;
|
| -class GrowableIOBuffer;
|
| -class HttpChunkedDecoder;
|
| -struct HttpRequestInfo;
|
| -class HttpRequestHeaders;
|
| -class HttpResponseInfo;
|
| -class IOBuffer;
|
| -class IOBufferWithSize;
|
| -class SSLCertRequestInfo;
|
| -class SSLInfo;
|
| -class UploadDataStream;
|
| -
|
| -class NET_EXPORT_PRIVATE HttpStreamParser {
|
| - public:
|
| - // Any data in |read_buffer| will be used before reading from the socket
|
| - // and any data left over after parsing the stream will be put into
|
| - // |read_buffer|. The left over data will start at offset 0 and the
|
| - // buffer's offset will be set to the first free byte. |read_buffer| may
|
| - // have its capacity changed.
|
| - HttpStreamParser(ClientSocketHandle* connection,
|
| - const HttpRequestInfo* request,
|
| - GrowableIOBuffer* read_buffer,
|
| - const BoundNetLog& net_log);
|
| - virtual ~HttpStreamParser();
|
| -
|
| - // These functions implement the interface described in HttpStream with
|
| - // some additional functionality
|
| - int SendRequest(const std::string& request_line,
|
| - const HttpRequestHeaders& headers,
|
| - HttpResponseInfo* response,
|
| - const CompletionCallback& callback);
|
| -
|
| - int ReadResponseHeaders(const CompletionCallback& callback);
|
| -
|
| - int ReadResponseBody(IOBuffer* buf, int buf_len,
|
| - const CompletionCallback& callback);
|
| -
|
| - void Close(bool not_reusable);
|
| -
|
| - // Returns the progress of uploading. When data is chunked, size is set to
|
| - // zero, but position will not be.
|
| - UploadProgress GetUploadProgress() const;
|
| -
|
| - bool IsResponseBodyComplete() const;
|
| -
|
| - bool CanFindEndOfResponse() const;
|
| -
|
| - bool IsMoreDataBuffered() const;
|
| -
|
| - bool IsConnectionReused() const;
|
| -
|
| - void SetConnectionReused();
|
| -
|
| - bool IsConnectionReusable() const;
|
| -
|
| - int64 received_bytes() const { return received_bytes_; }
|
| -
|
| - void GetSSLInfo(SSLInfo* ssl_info);
|
| -
|
| - void GetSSLCertRequestInfo(SSLCertRequestInfo* cert_request_info);
|
| -
|
| - // Encodes the given |payload| in the chunked format to |output|.
|
| - // Returns the number of bytes written to |output|. |output_size| should
|
| - // be large enough to store the encoded chunk, which is payload.size() +
|
| - // kChunkHeaderFooterSize. Returns ERR_INVALID_ARGUMENT if |output_size|
|
| - // is not large enough.
|
| - //
|
| - // The output will look like: "HEX\r\n[payload]\r\n"
|
| - // where HEX is a length in hexdecimal (without the "0x" prefix).
|
| - static int EncodeChunk(const base::StringPiece& payload,
|
| - char* output,
|
| - size_t output_size);
|
| -
|
| - // Returns true if request headers and body should be merged (i.e. the
|
| - // sum is small enough and the body is in memory, and not chunked).
|
| - static bool ShouldMergeRequestHeadersAndBody(
|
| - const std::string& request_headers,
|
| - const UploadDataStream* request_body);
|
| -
|
| - // The number of extra bytes required to encode a chunk.
|
| - static const size_t kChunkHeaderFooterSize;
|
| -
|
| - private:
|
| - class SeekableIOBuffer;
|
| -
|
| - // FOO_COMPLETE states implement the second half of potentially asynchronous
|
| - // operations and don't necessarily mean that FOO is complete.
|
| - enum State {
|
| - // STATE_NONE indicates that this is waiting on an external call before
|
| - // continuing.
|
| - STATE_NONE,
|
| - STATE_SEND_HEADERS,
|
| - STATE_SEND_HEADERS_COMPLETE,
|
| - STATE_SEND_BODY,
|
| - STATE_SEND_BODY_COMPLETE,
|
| - STATE_SEND_REQUEST_READ_BODY_COMPLETE,
|
| - STATE_READ_HEADERS,
|
| - STATE_READ_HEADERS_COMPLETE,
|
| - STATE_READ_BODY,
|
| - STATE_READ_BODY_COMPLETE,
|
| - STATE_DONE
|
| - };
|
| -
|
| - // The number of bytes by which the header buffer is grown when it reaches
|
| - // capacity.
|
| - static const int kHeaderBufInitialSize = 4 * 1024; // 4K
|
| -
|
| - // |kMaxHeaderBufSize| is the number of bytes that the response headers can
|
| - // grow to. If the body start is not found within this range of the
|
| - // response, the transaction will fail with ERR_RESPONSE_HEADERS_TOO_BIG.
|
| - // Note: |kMaxHeaderBufSize| should be a multiple of |kHeaderBufInitialSize|.
|
| - static const int kMaxHeaderBufSize = kHeaderBufInitialSize * 64; // 256K
|
| -
|
| - // The maximum sane buffer size.
|
| - static const int kMaxBufSize = 2 * 1024 * 1024; // 2M
|
| -
|
| - // Handle callbacks.
|
| - void OnIOComplete(int result);
|
| -
|
| - // Try to make progress sending/receiving the request/response.
|
| - int DoLoop(int result);
|
| -
|
| - // The implementations of each state of the state machine.
|
| - int DoSendHeaders();
|
| - int DoSendHeadersComplete(int result);
|
| - int DoSendBody();
|
| - int DoSendBodyComplete(int result);
|
| - int DoSendRequestReadBodyComplete(int result);
|
| - int DoReadHeaders();
|
| - int DoReadHeadersComplete(int result);
|
| - int DoReadBody();
|
| - int DoReadBodyComplete(int result);
|
| -
|
| - // This handles most of the logic for DoReadHeadersComplete.
|
| - int HandleReadHeaderResult(int result);
|
| -
|
| - // Examines |read_buf_| to find the start and end of the headers. If they are
|
| - // found, parse them with DoParseResponseHeaders(). Return the offset for
|
| - // the end of the headers, or -1 if the complete headers were not found, or
|
| - // with a net::Error if we encountered an error during parsing.
|
| - int ParseResponseHeaders();
|
| -
|
| - // Parse the headers into response_. Returns OK on success or a net::Error on
|
| - // failure.
|
| - int DoParseResponseHeaders(int end_of_header_offset);
|
| -
|
| - // Examine the parsed headers to try to determine the response body size.
|
| - void CalculateResponseBodySize();
|
| -
|
| - // Next state of the request, when the current one completes.
|
| - State io_state_;
|
| -
|
| - // The request to send.
|
| - const HttpRequestInfo* request_;
|
| -
|
| - // The request header data. May include a merged request body.
|
| - scoped_refptr<DrainableIOBuffer> request_headers_;
|
| -
|
| - // Size of just the request headers. May be less than the length of
|
| - // |request_headers_| if the body was merged with the headers.
|
| - int request_headers_length_;
|
| -
|
| - // Temporary buffer for reading.
|
| - scoped_refptr<GrowableIOBuffer> read_buf_;
|
| -
|
| - // Offset of the first unused byte in |read_buf_|. May be nonzero due to
|
| - // body data in the same packet as header data but is zero when reading
|
| - // headers.
|
| - int read_buf_unused_offset_;
|
| -
|
| - // The amount beyond |read_buf_unused_offset_| where the status line starts;
|
| - // -1 if not found yet.
|
| - int response_header_start_offset_;
|
| -
|
| - // The amount of received data. If connection is reused then intermediate
|
| - // value may be bigger than final.
|
| - int64 received_bytes_;
|
| -
|
| - // The parsed response headers. Owned by the caller of SendRequest. This
|
| - // cannot be safely accessed after reading the final set of headers, as the
|
| - // caller of SendRequest may have been destroyed - this happens in the case an
|
| - // HttpResponseBodyDrainer is used.
|
| - HttpResponseInfo* response_;
|
| -
|
| - // Indicates the content length. If this value is less than zero
|
| - // (and chunked_decoder_ is null), then we must read until the server
|
| - // closes the connection.
|
| - int64 response_body_length_;
|
| -
|
| - // Keep track of the number of response body bytes read so far.
|
| - int64 response_body_read_;
|
| -
|
| - // Helper if the data is chunked.
|
| - scoped_ptr<HttpChunkedDecoder> chunked_decoder_;
|
| -
|
| - // Where the caller wants the body data.
|
| - scoped_refptr<IOBuffer> user_read_buf_;
|
| - int user_read_buf_len_;
|
| -
|
| - // The callback to notify a user that their request or response is
|
| - // complete or there was an error
|
| - CompletionCallback callback_;
|
| -
|
| - // In the client callback, the client can do anything, including
|
| - // destroying this class, so any pending callback must be issued
|
| - // after everything else is done. When it is time to issue the client
|
| - // callback, move it from |callback_| to |scheduled_callback_|.
|
| - CompletionCallback scheduled_callback_;
|
| -
|
| - // The underlying socket.
|
| - ClientSocketHandle* const connection_;
|
| -
|
| - BoundNetLog net_log_;
|
| -
|
| - // Callback to be used when doing IO.
|
| - CompletionCallback io_callback_;
|
| -
|
| - // Buffer used to read the request body from UploadDataStream.
|
| - scoped_refptr<SeekableIOBuffer> request_body_read_buf_;
|
| - // Buffer used to send the request body. This points the same buffer as
|
| - // |request_body_read_buf_| unless the data is chunked.
|
| - scoped_refptr<SeekableIOBuffer> request_body_send_buf_;
|
| - bool sent_last_chunk_;
|
| -
|
| - // Error received when uploading the body, if any.
|
| - int upload_error_;
|
| -
|
| - base::WeakPtrFactory<HttpStreamParser> weak_ptr_factory_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(HttpStreamParser);
|
| -};
|
| -
|
| -} // namespace net
|
| -
|
| -#endif // NET_HTTP_HTTP_STREAM_PARSER_H_
|
|
|