ServiceWorker: Release a reference when it fails to dispatch ExtendableMessageEvent

content/browser/message_port_service.cc

 // Copyright 2013 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 "content/browser/message_port_service.h"
 
 #include <stddef.h>
 
 #include "content/common/message_port_messages.h"
 #include "content/public/browser/browser_thread.h"
@@ skipping 277 matching lines @@
   }
 
   // Any ports in messages currently in the queue should also be put on hold.
   for (const auto& message : message_ports_[message_port_id].queued_messages)
     for (const TransferredMessagePort& sent_port : message.second)
       HoldMessages(sent_port.id);
 
   message_ports_[message_port_id].hold_messages_for_destination = true;
 }
 
+bool MessagePortService::AreMessagesHeld(int message_port_id) {
+  DCHECK_CURRENTLY_ON(BrowserThread::IO);
+  if (!message_ports_.count(message_port_id))
+    return false;
+  return message_ports_[message_port_id].hold_messages_for_destination;
+}
+
 void MessagePortService::ClosePort(int message_port_id) {
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
   if (!message_ports_.count(message_port_id)) {
     NOTREACHED();
     return;
   }
 
   if (message_ports_[message_port_id].queue_for_inflight_messages) {
     message_ports_[message_port_id].should_be_destroyed = true;
     return;
@@ skipping 27 matching lines @@
     // Do the disentanglement (and be paranoid about the other side existing
     // just in case something unusual happened during entanglement).
     if (message_ports_.count(entangled_id)) {
       message_ports_[entangled_id].entangled_message_port_id = MSG_ROUTING_NONE;
     }
   }
   message_ports_.erase(erase_item);
 }
 
 }  // namespace content