[DevTools] Inline IPCDevToolsAgentHost into subclasses.

content/browser/devtools/devtools_agent_host_impl.cc

 // Copyright (c) 2012 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/devtools_agent_host_impl.h"
 
 #include <map>
 #include <vector>
 
 #include "base/basictypes.h"
@@ skipping 64 matching lines @@
   return ServiceWorkerDevToolsManager::GetInstance()
       ->GetDevToolsAgentHostForWorker(worker_process_id, worker_route_id);
 }
 
 DevToolsAgentHostImpl::DevToolsAgentHostImpl()
     : protocol_handler_(new DevToolsProtocolHandler(
           base::Bind(&DevToolsAgentHostImpl::SendMessageToClient,
                      base::Unretained(this)))),
       id_(base::GenerateGUID()),
       client_(NULL),
-      handle_all_commands_(false) {
+      handle_all_commands_(false),
+      message_buffer_size_(0) {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
   g_instances.Get()[id_] = this;
 }
 
 DevToolsAgentHostImpl::~DevToolsAgentHostImpl() {
   DCHECK_CURRENTLY_ON(BrowserThread::UI);
   g_instances.Get().erase(g_instances.Get().find(id_));
 }
 
 // static
@@ skipping 67 matching lines @@
   client_ = NULL;
   client->AgentHostClosed(this, false);
 }
 
 void DevToolsAgentHostImpl::SendMessageToClient(const std::string& message) {
   if (!client_)
     return;
   client_->DispatchProtocolMessage(this, message);
 }
 
+void DevToolsAgentHostImpl::ProcessChunkedMessageFromAgent(
+    const DevToolsMessageChunk& chunk) {
+  if (chunk.is_last && !chunk.post_state.empty())
+    state_cookie_ = chunk.post_state;
+
+  if (chunk.is_first && chunk.is_last) {
+    CHECK(message_buffer_size_ == 0);
+    SendMessageToClient(chunk.data);
+    return;
+  }
+
+  if (chunk.is_first) {
+    message_buffer_ = std::string();
+    message_buffer_.reserve(chunk.message_size);
+    message_buffer_size_ = chunk.message_size;
+  }
+
+  CHECK(message_buffer_.size() + chunk.data.size() <=
+      message_buffer_size_);
+  message_buffer_.append(chunk.data);
+
+  if (chunk.is_last) {
+    CHECK(message_buffer_.size() == message_buffer_size_);
+    SendMessageToClient(message_buffer_);
+    message_buffer_ = std::string();
+    message_buffer_size_ = 0;
+  }
+}
+
 // static
 void DevToolsAgentHost::DetachAllClients() {
   if (g_instances == NULL)
     return;
 
   // Make a copy, since detaching may lead to agent destruction, which
   // removes it from the instances.
   Instances copy = g_instances.Get();
   for (Instances::iterator it(copy.begin()); it != copy.end(); ++it) {
     DevToolsAgentHostImpl* agent_host = it->second;
@@ skipping 65 matching lines @@
     }
   }
 
   if (!handle_all_commands_)
     return protocol_handler_->HandleOptionalCommand(command.Pass());
   protocol_handler_->HandleCommand(command.Pass());
   return true;
 }
 
 }  // namespace content