15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2012 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 55821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#ifndef NET_HTTP_HTTP_STREAM_PARSER_H_ 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#define NET_HTTP_HTTP_STREAM_PARSER_H_ 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 85821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include <string> 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/basictypes.h" 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/memory/ref_counted.h" 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/memory/scoped_ptr.h" 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/memory/weak_ptr.h" 14c2e0dbddbe15c98d52c4786dac06cb8952a8ae6dTorne (Richard Coles)#include "base/strings/string_piece.h" 155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/completion_callback.h" 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/net_export.h" 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/net_log.h" 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "net/base/upload_progress.h" 195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace net { 215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class ClientSocketHandle; 235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class DrainableIOBuffer; 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class GrowableIOBuffer; 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class HttpChunkedDecoder; 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)struct HttpRequestInfo; 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class HttpRequestHeaders; 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class HttpResponseInfo; 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class IOBuffer; 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class IOBufferWithSize; 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class SSLCertRequestInfo; 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class SSLInfo; 335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class UploadDataStream; 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)class NET_EXPORT_PRIVATE HttpStreamParser { 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) public: 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Any data in |read_buffer| will be used before reading from the socket 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // and any data left over after parsing the stream will be put into 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |read_buffer|. The left over data will start at offset 0 and the 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // buffer's offset will be set to the first free byte. |read_buffer| may 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // have its capacity changed. 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HttpStreamParser(ClientSocketHandle* connection, 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const HttpRequestInfo* request, 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) GrowableIOBuffer* read_buffer, 455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const BoundNetLog& net_log); 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) virtual ~HttpStreamParser(); 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // These functions implement the interface described in HttpStream with 495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // some additional functionality 505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int SendRequest(const std::string& request_line, 515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const HttpRequestHeaders& headers, 525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HttpResponseInfo* response, 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const CompletionCallback& callback); 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int ReadResponseHeaders(const CompletionCallback& callback); 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int ReadResponseBody(IOBuffer* buf, int buf_len, 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const CompletionCallback& callback); 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void Close(bool not_reusable); 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns the progress of uploading. When data is chunked, size is set to 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // zero, but position will not be. 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) UploadProgress GetUploadProgress() const; 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HttpResponseInfo* GetResponseInfo(); 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool IsResponseBodyComplete() const; 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool CanFindEndOfResponse() const; 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool IsMoreDataBuffered() const; 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool IsConnectionReused() const; 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void SetConnectionReused(); 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool IsConnectionReusable() const; 795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void GetSSLInfo(SSLInfo* ssl_info); 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void GetSSLCertRequestInfo(SSLCertRequestInfo* cert_request_info); 835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Encodes the given |payload| in the chunked format to |output|. 855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns the number of bytes written to |output|. |output_size| should 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // be large enough to store the encoded chunk, which is payload.size() + 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // kChunkHeaderFooterSize. Returns ERR_INVALID_ARGUMENT if |output_size| 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // is not large enough. 895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // 905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The output will look like: "HEX\r\n[payload]\r\n" 915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // where HEX is a length in hexdecimal (without the "0x" prefix). 925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static int EncodeChunk(const base::StringPiece& payload, 935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) char* output, 945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) size_t output_size); 955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Returns true if request headers and body should be merged (i.e. the 975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // sum is small enough and the body is in memory, and not chunked). 985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static bool ShouldMergeRequestHeadersAndBody( 995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const std::string& request_headers, 1005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const UploadDataStream* request_body); 1015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The number of extra bytes required to encode a chunk. 1035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static const size_t kChunkHeaderFooterSize; 1045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) private: 1065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) class SeekableIOBuffer; 1075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // FOO_COMPLETE states implement the second half of potentially asynchronous 1095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // operations and don't necessarily mean that FOO is complete. 1105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) enum State { 1115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) STATE_NONE, 1125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) STATE_SENDING_HEADERS, 1135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // If the request comes with a body, either of the following two 1145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // states will be executed, depending on whether the body is chunked 1155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // or not. 1165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) STATE_SENDING_BODY, 1175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) STATE_SEND_REQUEST_READING_BODY, 1185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) STATE_REQUEST_SENT, 1195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) STATE_READ_HEADERS, 1205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) STATE_READ_HEADERS_COMPLETE, 1215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) STATE_BODY_PENDING, 1225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) STATE_READ_BODY, 1235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) STATE_READ_BODY_COMPLETE, 1245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) STATE_DONE 1255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) }; 1265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The number of bytes by which the header buffer is grown when it reaches 1285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // capacity. 1295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static const int kHeaderBufInitialSize = 4 * 1024; // 4K 1305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |kMaxHeaderBufSize| is the number of bytes that the response headers can 1325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // grow to. If the body start is not found within this range of the 1335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // response, the transaction will fail with ERR_RESPONSE_HEADERS_TOO_BIG. 1345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Note: |kMaxHeaderBufSize| should be a multiple of |kHeaderBufInitialSize|. 1355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static const int kMaxHeaderBufSize = kHeaderBufInitialSize * 64; // 256K 1365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The maximum sane buffer size. 1385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) static const int kMaxBufSize = 2 * 1024 * 1024; // 2M 1395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Handle callbacks. 1415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void OnIOComplete(int result); 1425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Try to make progress sending/receiving the request/response. 1445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int DoLoop(int result); 1455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The implementations of each state of the state machine. 1475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int DoSendHeaders(int result); 1485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int DoSendBody(int result); 1495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int DoSendRequestReadingBody(int result); 1505821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int DoReadHeaders(); 1515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int DoReadHeadersComplete(int result); 1525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int DoReadBody(); 1535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int DoReadBodyComplete(int result); 1545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Examines |read_buf_| to find the start and end of the headers. If they are 1565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // found, parse them with DoParseResponseHeaders(). Return the offset for 1575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // the end of the headers, or -1 if the complete headers were not found, or 1585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // with a net::Error if we encountered an error during parsing. 1595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int ParseResponseHeaders(); 1605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Parse the headers into response_. Returns OK on success or a net::Error on 1625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // failure. 1635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int DoParseResponseHeaders(int end_of_header_offset); 1645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Examine the parsed headers to try to determine the response body size. 1665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) void CalculateResponseBodySize(); 1675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Current state of the request. 1695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) State io_state_; 1705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The request to send. 1725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const HttpRequestInfo* request_; 1735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The request header data. 1755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scoped_refptr<DrainableIOBuffer> request_headers_; 1765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Temporary buffer for reading. 1785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scoped_refptr<GrowableIOBuffer> read_buf_; 1795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Offset of the first unused byte in |read_buf_|. May be nonzero due to 18118bf6eff4fb54bcd655b30cbcda8d102e23e4e2fSelim Gurun // body data in the same packet as header data but is zero when reading 18218bf6eff4fb54bcd655b30cbcda8d102e23e4e2fSelim Gurun // headers. 1835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int read_buf_unused_offset_; 1845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The amount beyond |read_buf_unused_offset_| where the status line starts; 1865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // -1 if not found yet. 1875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int response_header_start_offset_; 1885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1895821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The parsed response headers. Owned by the caller. 1905821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) HttpResponseInfo* response_; 1915821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1925821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Indicates the content length. If this value is less than zero 1935821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // (and chunked_decoder_ is null), then we must read until the server 1945821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // closes the connection. 1955821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int64 response_body_length_; 1965821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 1975821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Keep track of the number of response body bytes read so far. 1985821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int64 response_body_read_; 1995821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2005821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Helper if the data is chunked. 2015821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scoped_ptr<HttpChunkedDecoder> chunked_decoder_; 2025821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2035821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Where the caller wants the body data. 2045821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scoped_refptr<IOBuffer> user_read_buf_; 2055821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) int user_read_buf_len_; 2065821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2075821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The callback to notify a user that their request or response is 2085821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // complete or there was an error 2095821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CompletionCallback callback_; 2105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // In the client callback, the client can do anything, including 2125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // destroying this class, so any pending callback must be issued 2135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // after everything else is done. When it is time to issue the client 2145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // callback, move it from |callback_| to |scheduled_callback_|. 2155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CompletionCallback scheduled_callback_; 2165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // The underlying socket. 2185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) ClientSocketHandle* const connection_; 2195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) BoundNetLog net_log_; 2215821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2225821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Callback to be used when doing IO. 2235821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) CompletionCallback io_callback_; 2245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Buffer used to read the request body from UploadDataStream. 2265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scoped_refptr<SeekableIOBuffer> request_body_read_buf_; 2275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Buffer used to send the request body. This points the same buffer as 2285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // |request_body_read_buf_| unless the data is chunked. 2295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) scoped_refptr<SeekableIOBuffer> request_body_send_buf_; 2305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool sent_last_chunk_; 2315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) base::WeakPtrFactory<HttpStreamParser> weak_ptr_factory_; 2335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DISALLOW_COPY_AND_ASSIGN(HttpStreamParser); 2355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)}; 2365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace net 2385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 2395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#endif // NET_HTTP_HTTP_STREAM_PARSER_H_ 240