Prioritize which HTTP requests get a socket first by adding a priority level ...

net/url_request/url_request.h

 // Copyright (c) 2006-2008 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.
 
 #ifndef NET_URL_REQUEST_URL_REQUEST_H_
 #define NET_URL_REQUEST_URL_REQUEST_H_
 
 #include <string>
 #include <vector>
 
+#include "base/logging.h"
 #include "base/ref_counted.h"
 #include "googleurl/src/gurl.h"
 #include "net/base/load_states.h"
 #include "net/http/http_response_info.h"
 #include "net/url_request/url_request_status.h"
 
 namespace base {
-  class Time;
-}
+class Time;
+}  // namespace base
 
 namespace net {
-
 class IOBuffer;
 class UploadData;
 class X509Certificate;
-
-}
+}  // namespace net
 
 class URLRequestContext;
 class URLRequestJob;
 
 // This stores the values of the Set-Cookie headers received during the request.
 // Each item in the vector corresponds to a Set-Cookie: line received,
 // excluding the "Set-Cookie:" part.
 typedef std::vector<std::string> ResponseCookies;
 
 //-----------------------------------------------------------------------------
@@ skipping 386 matching lines @@
 
   void set_enable_profiling(bool profiling) { enable_profiling_ = profiling; }
 
   // Used to specify the context (cookie store, cache) for this request.
   URLRequestContext* context();
   void set_context(URLRequestContext* context);
 
   // Returns the expected content size if available
   int64 GetExpectedContentSize() const;
 
+  // Returns the priority level for this request.  A larger value indicates
+  // higher priority.  Negative values are not used.
+  int priority() const { return priority_; }
+  void set_priority(int priority) {
+    DCHECK_GE(priority, 0);
+    priority_ = priority;
+  }
+
  protected:
   // Allow the URLRequestJob class to control the is_pending() flag.
   void set_is_pending(bool value) { is_pending_ = value; }
 
   // Allow the URLRequestJob class to set our status too
-  void set_status(const URLRequestStatus &value) { status_ = value; }
+  void set_status(const URLRequestStatus& value) { status_ = value; }
 
   // Allow the URLRequestJob to redirect this request.  Returns net::OK if
   // successful, otherwise an error code is returned.
   int Redirect(const GURL& location, int http_status_code);
 
  private:
   friend class URLRequestJob;
 
   // Detaches the job from this request in preparation for this object going
   // away or the job being replaced. The job will not call us back when it has
@@ skipping 48 matching lines @@
   // infinite redirects.
   int redirect_limit_;
 
   // Contextual information used for this request (can be NULL).
   scoped_refptr<URLRequestContext> context_;
 
   // Cached value for use after we've orphaned the job handling the
   // first transaction in a request involving redirects.
   uint64 final_upload_progress_;
 
+  // The priority level for this request.  Objects like ClientSocketPool use
+  // this to determine which URLRequest to allocate sockets to first.
+  int priority_;
+
   DISALLOW_COPY_AND_ASSIGN(URLRequest);
 };
 
 //-----------------------------------------------------------------------------
 // To help ensure that all requests are cleaned up properly, we keep static
 // counters of live objects.  TODO(darin): Move this leak checking stuff into
 // a common place and generalize it so it can be used everywhere (Bug 566229).
 
 #ifndef NDEBUG
 
 struct URLRequestMetrics {
   int object_count;
   URLRequestMetrics() : object_count(0) {}
   ~URLRequestMetrics();
 };
 
 extern URLRequestMetrics url_request_metrics;
 
 #define URLREQUEST_COUNT_CTOR() url_request_metrics.object_count++
 #define URLREQUEST_COUNT_DTOR() url_request_metrics.object_count--
 
 #else  // disable leak checking in release builds...
 
 #define URLREQUEST_COUNT_CTOR()
 #define URLREQUEST_COUNT_DTOR()
 
 #endif  // #ifndef NDEBUG
 
 #endif  // NET_URL_REQUEST_URL_REQUEST_H_