| OLD | NEW |
| 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 // | 4 // |
| 5 // TODO(ukai): code is similar with http_network_transaction.cc. We should | 5 // TODO(ukai): code is similar with http_network_transaction.cc. We should |
| 6 // think about ways to share code, if possible. | 6 // think about ways to share code, if possible. |
| 7 | 7 |
| 8 #include "net/socket_stream/socket_stream.h" | 8 #include "net/socket_stream/socket_stream.h" |
| 9 | 9 |
| 10 #include <string> | 10 #include <string> |
| (...skipping 21 matching lines...) Expand all Loading... |
| 32 static const int kMaxPendingSendAllowed = 32768; // 32 kilobytes. | 32 static const int kMaxPendingSendAllowed = 32768; // 32 kilobytes. |
| 33 static const int kReadBufferSize = 4096; | 33 static const int kReadBufferSize = 4096; |
| 34 | 34 |
| 35 namespace net { | 35 namespace net { |
| 36 | 36 |
| 37 void SocketStream::ResponseHeaders::Realloc(size_t new_size) { | 37 void SocketStream::ResponseHeaders::Realloc(size_t new_size) { |
| 38 headers_.reset(static_cast<char*>(realloc(headers_.release(), new_size))); | 38 headers_.reset(static_cast<char*>(realloc(headers_.release(), new_size))); |
| 39 } | 39 } |
| 40 | 40 |
| 41 SocketStream::SocketStream(const GURL& url, Delegate* delegate) | 41 SocketStream::SocketStream(const GURL& url, Delegate* delegate) |
| 42 : url_(url), | 42 : delegate_(delegate), |
| 43 delegate_(delegate), | 43 url_(url), |
| 44 max_pending_send_allowed_(kMaxPendingSendAllowed), | 44 max_pending_send_allowed_(kMaxPendingSendAllowed), |
| 45 next_state_(STATE_NONE), | 45 next_state_(STATE_NONE), |
| 46 http_auth_handler_factory_(NULL), | 46 http_auth_handler_factory_(NULL), |
| 47 factory_(ClientSocketFactory::GetDefaultFactory()), | 47 factory_(ClientSocketFactory::GetDefaultFactory()), |
| 48 proxy_mode_(kDirectConnection), | 48 proxy_mode_(kDirectConnection), |
| 49 proxy_url_(url), | 49 proxy_url_(url), |
| 50 pac_request_(NULL), | 50 pac_request_(NULL), |
| 51 ALLOW_THIS_IN_INITIALIZER_LIST( | 51 ALLOW_THIS_IN_INITIALIZER_LIST( |
| 52 io_callback_(this, &SocketStream::OnIOCompleted)), | 52 io_callback_(this, &SocketStream::OnIOCompleted)), |
| 53 ALLOW_THIS_IN_INITIALIZER_LIST( | 53 ALLOW_THIS_IN_INITIALIZER_LIST( |
| (...skipping 895 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 949 return context_->proxy_service(); | 949 return context_->proxy_service(); |
| 950 } | 950 } |
| 951 | 951 |
| 952 void SocketStream::GetInfoForTracker( | 952 void SocketStream::GetInfoForTracker( |
| 953 RequestTracker<SocketStream>::RecentRequestInfo* info) const { | 953 RequestTracker<SocketStream>::RecentRequestInfo* info) const { |
| 954 info->original_url = url_; | 954 info->original_url = url_; |
| 955 info->load_log = load_log_; | 955 info->load_log = load_log_; |
| 956 } | 956 } |
| 957 | 957 |
| 958 } // namespace net | 958 } // namespace net |
| OLD | NEW |