When cancelling a pending request, release any outstanding SharedIOBuffer objects

chrome/common/resource_dispatcher.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.
 
 // See http://dev.chromium.org/developers/design-documents/multi-process-resource-loading
 
 #ifndef CHROME_COMMON_RESOURCE_DISPATCHER_H__
 #define CHROME_COMMON_RESOURCE_DISPATCHER_H__
 
 #include <deque>
@@ skipping 54 matching lines @@
   typedef std::deque<IPC::Message*> MessageQueue;
   struct PendingRequestInfo {
     PendingRequestInfo() { }
     PendingRequestInfo(webkit_glue::ResourceLoaderBridge::Peer* peer,
                        ResourceType::Type resource_type,
                        const GURL& request_url)
         : peer(peer),
           resource_type(resource_type),
           filter_policy(FilterPolicy::DONT_FILTER),
           is_deferred(false),
-          is_cancelled(false),
           url(request_url) {
     }
     ~PendingRequestInfo() { }
     webkit_glue::ResourceLoaderBridge::Peer* peer;
     ResourceType::Type resource_type;
     FilterPolicy::Type filter_policy;
     MessageQueue deferred_message_queue;
     bool is_deferred;
-    bool is_cancelled;
     GURL url;
   };
   typedef base::hash_map<int, PendingRequestInfo> PendingRequestList;
 
   // Message response handlers, called by the message handler for this process.
   void OnUploadProgress(
       const IPC::Message& message,
       int request_id,
       int64 position,
       int64 size);
@@ skipping 20 matching lines @@
   // again in the deferred state.
   void FlushDeferredMessages(int request_id);
 
   // Returns true if the message passed in is a resource related message.
   static bool IsResourceDispatcherMessage(const IPC::Message& message);
 
   // ViewHostMsg_Resource_DataReceived is not POD, it has a shared memory
   // handle in it that we should cleanup it up nicely. This method accepts any
   // message and determine whether the message is
   // ViewHostMsg_Resource_DataReceived and clean up the shared memory handle.
-  void ReleaseResourcesInDataMessage(const IPC::Message& message);
+  static void ReleaseResourcesInDataMessage(const IPC::Message& message);
+
+  // Iterate through a message queue and clean up the messages by calling
+  // ReleaseResourcesInDataMessage and removing them from the queue. Intended
+  // for use on deferred message queues that are no longer needed.
+  static void ReleaseResourcesInMessageQueue(MessageQueue* queue);
 
   IPC::Message::Sender* message_sender_;
 
   // All pending requests issued to the host
   PendingRequestList pending_requests_;
 
   ScopedRunnableMethodFactory<ResourceDispatcher> method_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(ResourceDispatcher);
 };
 
 #endif  // CHROME_COMMON_RESOURCE_DISPATCHER_H__