[Net] Propagate priority changes from URLRequest to HttpTransaction

net/url_request/url_request_test_job.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "net/url_request/url_request_test_job.h"
 
 #include <algorithm>
 #include <list>
 
 #include "base/bind.h"
@@ skipping 71 matching lines @@
                                           NetworkDelegate* network_delegate,
                                           const std::string& scheme) {
   return new URLRequestTestJob(request, network_delegate);
 }
 
 URLRequestTestJob::URLRequestTestJob(URLRequest* request,
                                      NetworkDelegate* network_delegate)
     : URLRequestJob(request, network_delegate),
       auto_advance_(false),
       stage_(WAITING),
+      priority_(request->priority()),
       offset_(0),
       async_buf_(NULL),
       async_buf_size_(0),
       ALLOW_THIS_IN_INITIALIZER_LIST(weak_factory_(this)) {
 }
 
 URLRequestTestJob::URLRequestTestJob(URLRequest* request,
                                      NetworkDelegate* network_delegate,
                                      bool auto_advance)
     : URLRequestJob(request, network_delegate),
       auto_advance_(auto_advance),
       stage_(WAITING),
+      priority_(request->priority()),
       offset_(0),
       async_buf_(NULL),
       async_buf_size_(0),
       ALLOW_THIS_IN_INITIALIZER_LIST(weak_factory_(this)) {
 }
 
 URLRequestTestJob::URLRequestTestJob(URLRequest* request,
                                      NetworkDelegate* network_delegate,
                                      const std::string& response_headers,
                                      const std::string& response_data,
                                      bool auto_advance)
     : URLRequestJob(request, network_delegate),
       auto_advance_(auto_advance),
       stage_(WAITING),
+      priority_(request->priority()),
       response_headers_(new HttpResponseHeaders(response_headers)),
       response_data_(response_data),
       offset_(0),
       async_buf_(NULL),
       async_buf_size_(0),
       ALLOW_THIS_IN_INITIALIZER_LIST(weak_factory_(this)) {
 }
 
 URLRequestTestJob::~URLRequestTestJob() {
   g_pending_jobs.Get().erase(
@@ skipping 91 matching lines @@
 
   std::string value;
   if (!response_headers_->IsRedirect(&value))
     return false;
 
   *location = request_->url().Resolve(value);
   *http_status_code = response_headers_->response_code();
   return true;
 }
 
+void URLRequestTestJob::SetPriority(RequestPriority priority) {
+  priority_ = priority;
+}
 
 void URLRequestTestJob::Kill() {
   stage_ = DONE;
   URLRequestJob::Kill();
   weak_factory_.InvalidateWeakPtrs();
   g_pending_jobs.Get().erase(
       std::remove(
           g_pending_jobs.Get().begin(), g_pending_jobs.Get().end(), this),
       g_pending_jobs.Get().end());
 }
@@ skipping 55 matching lines @@
 
   URLRequestTestJob* next_job(g_pending_jobs.Get().front());
   g_pending_jobs.Get().pop_front();
 
   DCHECK(!next_job->auto_advance());  // auto_advance jobs should be in this q
   next_job->ProcessNextOperation();
   return true;
 }
 
 }  // namespace net