[inspector] Support multiple sessions per context group

src/inspector/v8-console-message.cc

 // Copyright 2016 the V8 project 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 "src/inspector/v8-console-message.h"
 
 #include "src/debug/debug-interface.h"
 #include "src/inspector/inspected-context.h"
 #include "src/inspector/protocol/Protocol.h"
 #include "src/inspector/string-util.h"
@@ skipping 441 matching lines @@
     : m_inspector(inspector), m_contextGroupId(contextGroupId) {}
 
 V8ConsoleMessageStorage::~V8ConsoleMessageStorage() { clear(); }
 
 void V8ConsoleMessageStorage::addMessage(
     std::unique_ptr<V8ConsoleMessage> message) {
   int contextGroupId = m_contextGroupId;
   V8InspectorImpl* inspector = m_inspector;
   if (message->type() == ConsoleAPIType::kClear) clear();
 
-  V8InspectorSessionImpl* session =
-      inspector->sessionForContextGroup(contextGroupId);
-  if (session) {
-    if (message->origin() == V8MessageOrigin::kConsole)
-      session->consoleAgent()->messageAdded(message.get());
-    session->runtimeAgent()->messageAdded(message.get());
-  }
+  inspector->forEachSession(
+      contextGroupId, [&message](V8InspectorSessionImpl* session) {
+        if (message->origin() == V8MessageOrigin::kConsole)
+          session->consoleAgent()->messageAdded(message.get());
+        session->runtimeAgent()->messageAdded(message.get());
+      });
   if (!inspector->hasConsoleMessageStorage(contextGroupId)) return;
 
   DCHECK(m_messages.size() <= maxConsoleMessageCount);
   if (m_messages.size() == maxConsoleMessageCount) {
     m_estimatedSize -= m_messages.front()->estimatedSize();
     m_messages.pop_front();
   }
   while (m_estimatedSize + message->estimatedSize() > maxConsoleMessageV8Size &&
          !m_messages.empty()) {
     m_estimatedSize -= m_messages.front()->estimatedSize();
     m_messages.pop_front();
   }
 
   m_messages.push_back(std::move(message));
   m_estimatedSize += m_messages.back()->estimatedSize();
 }
 
 void V8ConsoleMessageStorage::clear() {
   m_messages.clear();
   m_estimatedSize = 0;
-  if (V8InspectorSessionImpl* session =
-          m_inspector->sessionForContextGroup(m_contextGroupId)) {
-    session->releaseObjectGroup("console");
-  }
+  m_inspector->forEachSession(m_contextGroupId,
+                              [](V8InspectorSessionImpl* session) {
+                                session->releaseObjectGroup("console");
+                              });
   m_data.clear();
 }
 
 bool V8ConsoleMessageStorage::shouldReportDeprecationMessage(
     int contextId, const String16& method) {
   std::set<String16>& reportedDeprecationMessages =
       m_data[contextId].m_reportedDeprecationMessages;
   auto it = reportedDeprecationMessages.find(method);
   if (it != reportedDeprecationMessages.end()) return false;
   reportedDeprecationMessages.insert(it, method);
@@ skipping 21 matching lines @@
   m_estimatedSize = 0;
   for (size_t i = 0; i < m_messages.size(); ++i) {
     m_messages[i]->contextDestroyed(contextId);
     m_estimatedSize += m_messages[i]->estimatedSize();
   }
   auto it = m_data.find(contextId);
   if (it != m_data.end()) m_data.erase(contextId);
 }
 
 }  // namespace v8_inspector