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 |