1 files changed, 179 insertions, 0 deletions
diff --git a/net/http/http_network_transaction.h b/net/http/http_network_transaction.h
new file mode 100644
index 0000000..f53a5e7
--- /dev/null
+++ b/net/http/http_network_transaction.h
@@ -0,0 +1,179 @@
+// Copyright 2008, Google Inc.
+// All rights reserved.
+//
+// Redistribution and use in source and binary forms, with or without
+// modification, are permitted provided that the following conditions are
+// met:
+//
+//    * Redistributions of source code must retain the above copyright
+// notice, this list of conditions and the following disclaimer.
+//    * Redistributions in binary form must reproduce the above
+// copyright notice, this list of conditions and the following disclaimer
+// in the documentation and/or other materials provided with the
+// distribution.
+//    * Neither the name of Google Inc. nor the names of its
+// contributors may be used to endorse or promote products derived from
+// this software without specific prior written permission.
+//
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+#ifndef NET_HTTP_HTTP_NETWORK_TRANSACTION_H_
+#define NET_HTTP_HTTP_NETWORK_TRANSACTION_H_
+
+#include "base/ref_counted.h"
+#include "net/base/address_list.h"
+#include "net/http/http_connection.h"
+#include "net/http/http_proxy_service.h"
+#include "net/http/http_response_info.h"
+#include "net/http/http_transaction.h"
+
+namespace net {
+
+class ClientSocketFactory;
+class HostResolver;
+class HttpChunkedDecoder;
+class HttpNetworkSession;
+class UploadDataStream;
+
+class HttpNetworkTransaction : public HttpTransaction {
+ public:
+  HttpNetworkTransaction(HttpNetworkSession* session,
+                         ClientSocketFactory* socket_factory);
+
+  // HttpTransaction methods:
+  virtual void Destroy();
+  virtual int Start(const HttpRequestInfo* request_info,
+                    CompletionCallback* callback);
+  virtual int RestartIgnoringLastError(CompletionCallback* callback);
+  virtual int RestartWithAuth(const std::wstring& username,
+                              const std::wstring& password,
+                              CompletionCallback* callback);
+  virtual int Read(char* buf, int buf_len, CompletionCallback* callback);
+  virtual const HttpResponseInfo* GetResponseInfo() const;
+  virtual LoadState GetLoadState() const;
+  virtual uint64 GetUploadProgress() const;
+
+ private:
+  ~HttpNetworkTransaction();
+  void BuildRequestHeaders();
+  void DoCallback(int result);
+  void OnIOComplete(int result);
+
+  // Runs the state transition loop.
+  int DoLoop(int result);
+
+  // Each of these methods corresponds to a State value.  Those with an input
+  // argument receive the result from the previous state.  If a method returns
+  // ERR_IO_PENDING, then the result from OnIOComplete will be passed to the
+  // next state method as the result arg.
+  int DoResolveProxy();
+  int DoResolveProxyComplete(int result);
+  int DoInitConnection();
+  int DoInitConnectionComplete(int result);
+  int DoResolveHost();
+  int DoResolveHostComplete(int result);
+  int DoConnect();
+  int DoConnectComplete(int result);
+  int DoWriteHeaders();
+  int DoWriteHeadersComplete(int result);
+  int DoWriteBody();
+  int DoWriteBodyComplete(int result);
+  int DoReadHeaders();
+  int DoReadHeadersComplete(int result);
+  int DoReadBody();
+  int DoReadBodyComplete(int result);
+
+  // Called when read_buf_ contains the complete response headers.
+  int DidReadResponseHeaders();
+
+  // Called to possibly recover from the given error.  Sets next_state_ and
+  // returns OK if recovering from the error.  Otherwise, the same error code
+  // is returned.
+  int HandleIOError(int error);
+
+  CompletionCallbackImpl<HttpNetworkTransaction> io_callback_;
+  CompletionCallback* user_callback_;
+
+  scoped_refptr<HttpNetworkSession> session_;
+
+  const HttpRequestInfo* request_;
+  HttpResponseInfo response_;
+
+  HttpProxyService::PacRequest* pac_request_;
+  HttpProxyInfo proxy_info_;
+
+  scoped_ptr<HostResolver> resolver_;
+  AddressList addresses_;
+
+  ClientSocketFactory* socket_factory_;
+  HttpConnection connection_;
+  bool reused_socket_;
+
+  bool using_ssl_;     // True if handling a HTTPS request
+  bool using_proxy_;   // True if using a HTTP proxy
+  bool using_tunnel_;  // True if using a tunnel for HTTPS
+
+  std::string request_headers_;
+  scoped_ptr<UploadDataStream> request_body_stream_;
+  uint64 bytes_sent_;
+
+  // The read buffer may be larger than it is full.  The 'capacity' indicates
+  // the allocation size of the buffer, and the 'len' indicates how much data
+  // is in the buffer already.  The 'body offset' indicates the offset of the
+  // start of the response body within the read buffer.
+  scoped_ptr_malloc<char> header_buf_;
+  int header_buf_capacity_;
+  int header_buf_len_;
+  int header_buf_body_offset_;
+  enum { kHeaderBufInitialSize = 4096 };
+
+  // Indicates the content length remaining to read.  If this value is less
+  // than zero (and chunked_decoder_ is null), then we read until the server
+  // closes the connection.
+  int64 content_length_;
+
+  // Keeps track of the number of response body bytes read so far.
+  int64 content_read_;
+
+  scoped_ptr<HttpChunkedDecoder> chunked_decoder_;
+
+  // User buffer and length passed to the Read method.
+  char* read_buf_;
+  int read_buf_len_;
+
+  // The different states for the 'Start' routine.
+  enum State {
+    STATE_RESOLVE_PROXY,
+    STATE_RESOLVE_PROXY_COMPLETE,
+    STATE_INIT_CONNECTION,
+    STATE_INIT_CONNECTION_COMPLETE,
+    STATE_RESOLVE_HOST,
+    STATE_RESOLVE_HOST_COMPLETE,
+    STATE_CONNECT,
+    STATE_CONNECT_COMPLETE,
+    STATE_WRITE_HEADERS,
+    STATE_WRITE_HEADERS_COMPLETE,
+    STATE_WRITE_BODY,
+    STATE_WRITE_BODY_COMPLETE,
+    STATE_READ_HEADERS,
+    STATE_READ_HEADERS_COMPLETE,
+    STATE_READ_BODY,
+    STATE_READ_BODY_COMPLETE,
+    STATE_NONE
+  };
+  State next_state_;
+};
+
+}  // namespace net
+
+#endif  // NET_HTTP_HTTP_NETWORK_TRANSACTION_H_