OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 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 | 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 #include "content/browser/loader/resource_scheduler.h" | 5 #include "content/browser/loader/resource_scheduler.h" |
6 | 6 |
7 #include "base/memory/scoped_vector.h" | 7 #include "base/memory/scoped_vector.h" |
8 #include "base/message_loop/message_loop.h" | 8 #include "base/message_loop/message_loop.h" |
9 #include "base/strings/string_number_conversions.h" | 9 #include "base/strings/string_number_conversions.h" |
10 #include "content/browser/browser_thread_impl.h" | 10 #include "content/browser/browser_thread_impl.h" |
(...skipping 180 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
191 void ChangeRequestPriority(TestRequest* request, | 191 void ChangeRequestPriority(TestRequest* request, |
192 net::RequestPriority new_priority, | 192 net::RequestPriority new_priority, |
193 int intra_priority = 0) { | 193 int intra_priority = 0) { |
194 scoped_refptr<FakeResourceMessageFilter> filter( | 194 scoped_refptr<FakeResourceMessageFilter> filter( |
195 new FakeResourceMessageFilter(kChildId)); | 195 new FakeResourceMessageFilter(kChildId)); |
196 const ResourceRequestInfoImpl* info = ResourceRequestInfoImpl::ForRequest( | 196 const ResourceRequestInfoImpl* info = ResourceRequestInfoImpl::ForRequest( |
197 request->url_request()); | 197 request->url_request()); |
198 const GlobalRequestID& id = info->GetGlobalRequestID(); | 198 const GlobalRequestID& id = info->GetGlobalRequestID(); |
199 ResourceHostMsg_DidChangePriority msg(id.request_id, new_priority, | 199 ResourceHostMsg_DidChangePriority msg(id.request_id, new_priority, |
200 intra_priority); | 200 intra_priority); |
201 bool ok = false; | 201 rdh_.OnMessageReceived(msg, filter.get()); |
202 rdh_.OnMessageReceived(msg, filter.get(), &ok); | |
203 EXPECT_TRUE(ok); | |
204 } | 202 } |
205 | 203 |
206 int next_request_id_; | 204 int next_request_id_; |
207 base::MessageLoopForIO message_loop_; | 205 base::MessageLoopForIO message_loop_; |
208 BrowserThreadImpl ui_thread_; | 206 BrowserThreadImpl ui_thread_; |
209 BrowserThreadImpl io_thread_; | 207 BrowserThreadImpl io_thread_; |
210 ResourceDispatcherHostImpl rdh_; | 208 ResourceDispatcherHostImpl rdh_; |
211 ResourceScheduler scheduler_; | 209 ResourceScheduler scheduler_; |
212 net::HttpServerPropertiesImpl http_server_properties_; | 210 net::HttpServerPropertiesImpl http_server_properties_; |
213 net::TestURLRequestContext context_; | 211 net::TestURLRequestContext context_; |
(...skipping 315 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
529 http_server_properties_.SetSupportsSpdy( | 527 http_server_properties_.SetSupportsSpdy( |
530 net::HostPortPair("spdyhost2", 8080), true); | 528 net::HostPortPair("spdyhost2", 8080), true); |
531 ChangeRequestPriority(low2_spdy.get(), net::LOWEST); | 529 ChangeRequestPriority(low2_spdy.get(), net::LOWEST); |
532 scoped_ptr<TestRequest> low2(NewRequest("http://host/low", net::LOWEST)); | 530 scoped_ptr<TestRequest> low2(NewRequest("http://host/low", net::LOWEST)); |
533 EXPECT_TRUE(low2->started()); | 531 EXPECT_TRUE(low2->started()); |
534 } | 532 } |
535 | 533 |
536 } // unnamed namespace | 534 } // unnamed namespace |
537 | 535 |
538 } // namespace content | 536 } // namespace content |
OLD | NEW |