[DevTools] Filter any messages from previous sessions in DevToolsAgentHostImpl

content/browser/devtools/protocol/devtools_protocol_client.cc

 // Copyright 2014 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/devtools/protocol/devtools_protocol_client.h"
 
 #include "base/json/json_writer.h"
 #include "base/strings/stringprintf.h"
 
 namespace content {
@@ skipping 22 matching lines @@
 const DevToolsCommandId DevToolsProtocolClient::kNoId = -1;
 
 DevToolsProtocolClient::DevToolsProtocolClient(
     const RawMessageCallback& raw_message_callback)
     : raw_message_callback_(raw_message_callback) {
 }
 
 DevToolsProtocolClient::~DevToolsProtocolClient() {
 }
 
-void DevToolsProtocolClient::SendRawMessage(const std::string& message) {
-  raw_message_callback_.Run(message);
+void DevToolsProtocolClient::SendRawMessage(int session_id,
+                                            const std::string& message) {
+  raw_message_callback_.Run(session_id, message);
 }
 
-void DevToolsProtocolClient::SendMessage(const base::DictionaryValue& message) {
+void DevToolsProtocolClient::SendMessage(int session_id,
+                                         const base::DictionaryValue& message) {
   std::string json_message;
   base::JSONWriter::Write(message, &json_message);
-  SendRawMessage(json_message);
+  SendRawMessage(session_id, json_message);
 }
 
 void DevToolsProtocolClient::SendNotification(
     const std::string& method,
     scoped_ptr<base::DictionaryValue> params) {
   base::DictionaryValue notification;
   notification.SetString(kMethodParam, method);
   if (params)
     notification.Set(kParamsParam, params.release());
 
-  SendMessage(notification);
+  SendMessage(0, notification);
 }
 
 void DevToolsProtocolClient::SendSuccess(
+    int session_id,
     DevToolsCommandId command_id,
     scoped_ptr<base::DictionaryValue> params) {
+  // TODO: pass

[dgozman, 2015/11/06 22:57:27]

remove

[kozy, 2015/11/07 01:54:44]

Done.

   base::DictionaryValue response;
   response.SetInteger(kIdParam, command_id);
 
   response.Set(kResultParam,
       params ? params.release() : new base::DictionaryValue());
 
-  SendMessage(response);
+  SendMessage(session_id, response);
 }
 
-bool DevToolsProtocolClient::SendError(DevToolsCommandId command_id,
+bool DevToolsProtocolClient::SendError(int session_id,
+                                       DevToolsCommandId command_id,
                                        const Response& response) {
+  // TODO: !

[dgozman, 2015/11/06 22:57:27]

remove

[kozy, 2015/11/07 01:54:43]

Done.

   if (response.status() == kStatusOk ||
       response.status() == kStatusFallThrough) {
     return false;
   }
   base::DictionaryValue dict;
   if (command_id == kNoId)
     dict.Set(kIdParam, base::Value::CreateNullValue());
   else
     dict.SetInteger(kIdParam, command_id);
 
   base::DictionaryValue* error_object = new base::DictionaryValue();
   error_object->SetInteger(kErrorCodeParam, response.status());
   if (!response.message().empty())
     error_object->SetString(kErrorMessageParam, response.message());
 
   dict.Set(kErrorParam, error_object);
-  SendMessage(dict);
+  SendMessage(session_id, dict);
   return true;
 }
 
 typedef DevToolsProtocolClient::Response Response;
 
 Response Response::FallThrough() {
   return Response(kStatusFallThrough);
 }
 
 Response Response::OK() {
@@ skipping 28 matching lines @@
 Response::Response(int status)
     : status_(status) {
 }
 
 Response::Response(int status, const std::string& message)
     : status_(status),
       message_(message) {
 }
 
 }  // namespace content