OLD | NEW |
| (Empty) |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | |
2 // Use of this source code is governed by a BSD-style license that can be | |
3 // found in the LICENSE file. | |
4 | |
5 #include "net/http/http_pipelined_host_forced.h" | |
6 | |
7 #include "base/values.h" | |
8 #include "net/http/http_pipelined_connection_impl.h" | |
9 #include "net/http/http_pipelined_stream.h" | |
10 #include "net/socket/buffered_write_stream_socket.h" | |
11 #include "net/socket/client_socket_handle.h" | |
12 | |
13 namespace net { | |
14 | |
15 HttpPipelinedHostForced::HttpPipelinedHostForced( | |
16 HttpPipelinedHost::Delegate* delegate, | |
17 const Key& key, | |
18 HttpPipelinedConnection::Factory* factory) | |
19 : delegate_(delegate), | |
20 key_(key), | |
21 factory_(factory) { | |
22 if (!factory) { | |
23 factory_.reset(new HttpPipelinedConnectionImpl::Factory()); | |
24 } | |
25 } | |
26 | |
27 HttpPipelinedHostForced::~HttpPipelinedHostForced() { | |
28 CHECK(!pipeline_.get()); | |
29 } | |
30 | |
31 HttpPipelinedStream* HttpPipelinedHostForced::CreateStreamOnNewPipeline( | |
32 ClientSocketHandle* connection, | |
33 const SSLConfig& used_ssl_config, | |
34 const ProxyInfo& used_proxy_info, | |
35 const BoundNetLog& net_log, | |
36 bool was_npn_negotiated, | |
37 NextProto protocol_negotiated) { | |
38 CHECK(!pipeline_.get()); | |
39 scoped_ptr<BufferedWriteStreamSocket> buffered_socket( | |
40 new BufferedWriteStreamSocket(connection->PassSocket())); | |
41 connection->SetSocket(buffered_socket.PassAs<StreamSocket>()); | |
42 pipeline_.reset(factory_->CreateNewPipeline( | |
43 connection, this, key_.origin(), used_ssl_config, used_proxy_info, | |
44 net_log, was_npn_negotiated, protocol_negotiated)); | |
45 return pipeline_->CreateNewStream(); | |
46 } | |
47 | |
48 HttpPipelinedStream* HttpPipelinedHostForced::CreateStreamOnExistingPipeline() { | |
49 if (!pipeline_.get()) { | |
50 return NULL; | |
51 } | |
52 return pipeline_->CreateNewStream(); | |
53 } | |
54 | |
55 bool HttpPipelinedHostForced::IsExistingPipelineAvailable() const { | |
56 return pipeline_.get() != NULL; | |
57 } | |
58 | |
59 const HttpPipelinedHost::Key& HttpPipelinedHostForced::GetKey() const { | |
60 return key_; | |
61 } | |
62 | |
63 void HttpPipelinedHostForced::OnPipelineEmpty( | |
64 HttpPipelinedConnection* pipeline) { | |
65 CHECK_EQ(pipeline_.get(), pipeline); | |
66 pipeline_.reset(); | |
67 delegate_->OnHostIdle(this); | |
68 // WARNING: We'll probably be deleted here. | |
69 } | |
70 | |
71 void HttpPipelinedHostForced::OnPipelineHasCapacity( | |
72 HttpPipelinedConnection* pipeline) { | |
73 CHECK_EQ(pipeline_.get(), pipeline); | |
74 delegate_->OnHostHasAdditionalCapacity(this); | |
75 if (!pipeline->depth()) { | |
76 OnPipelineEmpty(pipeline); | |
77 // WARNING: We might be deleted here. | |
78 } | |
79 } | |
80 | |
81 void HttpPipelinedHostForced::OnPipelineFeedback( | |
82 HttpPipelinedConnection* pipeline, | |
83 HttpPipelinedConnection::Feedback feedback) { | |
84 // We don't care. We always pipeline. | |
85 } | |
86 | |
87 base::Value* HttpPipelinedHostForced::PipelineInfoToValue() const { | |
88 base::ListValue* list_value = new base::ListValue(); | |
89 if (pipeline_.get()) { | |
90 base::DictionaryValue* pipeline_dict = new base::DictionaryValue; | |
91 pipeline_dict->SetString("host", key_.origin().ToString()); | |
92 pipeline_dict->SetBoolean("forced", true); | |
93 pipeline_dict->SetInteger("depth", pipeline_->depth()); | |
94 pipeline_dict->SetInteger("capacity", 1000); | |
95 pipeline_dict->SetBoolean("usable", pipeline_->usable()); | |
96 pipeline_dict->SetBoolean("active", pipeline_->active()); | |
97 pipeline_dict->SetInteger("source_id", pipeline_->net_log().source().id); | |
98 list_value->Append(pipeline_dict); | |
99 } | |
100 return list_value; | |
101 } | |
102 | |
103 } // namespace net | |
OLD | NEW |