Implementation of the GreenWeb language extensions.

ipc/ipc_channel_reader.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 "ipc/ipc_channel_reader.h"
 
 #include <algorithm>
+#include <iostream>
 
 #include "base/metrics/histogram_macros.h"
+#include "content/renderer/greenweb_latency_tracking.h"
 #include "ipc/ipc_listener.h"
 #include "ipc/ipc_logging.h"
 #include "ipc/ipc_message.h"
 #include "ipc/ipc_message_attachment_set.h"
 #include "ipc/ipc_message_macros.h"
 
 namespace IPC {
 namespace internal {
 
 ChannelReader::ChannelReader(Listener* listener) : listener_(listener) {
@@ skipping 180 matching lines @@
 }
 
 void ChannelReader::EmitLogBeforeDispatch(const Message& message) {
 #ifdef IPC_MESSAGE_LOG_ENABLED
   std::string name;
   Logging::GetInstance()->GetMessageText(message.type(), &name, &message, NULL);
   TRACE_EVENT_WITH_FLOW1("ipc,toplevel", "ChannelReader::DispatchInputData",
                          message.flags(), TRACE_EVENT_FLAG_FLOW_IN, "name",
                          name);
 #else
-  TRACE_EVENT_WITH_FLOW2("ipc,toplevel", "ChannelReader::DispatchInputData",
-                         message.flags(), TRACE_EVENT_FLAG_FLOW_IN, "class",
-                         IPC_MESSAGE_ID_CLASS(message.type()), "line",
-                         IPC_MESSAGE_ID_LINE(message.type()));
+  TRACE_EVENT_WITH_FLOW1("ipc,toplevel", "ChannelReader::DispatchInputData",
+                         message.flags(), TRACE_EVENT_FLAG_FLOW_IN, "QoS Type",
+                         message.qos_type());
 #endif
+  // The info of the main renderer thread can't be overwritten!
+  // This is because in the current implementation we send the ebs_enable and qos_type
+  //   info along with every IPC message. So it's possible that the GPU process sends
+  //   a default ebs_enabled value that overwrites the value that is already correctly
+  //   set in the main renderer thread.
+  if (base::trace_event::TraceLog::GetInstance()->GetProcessName() != "Renderer") {
+    g_qos_type = message.qos_type();
+    g_qos_target = message.qos_target();
+    g_ebs_enabled = message.ebs_enabled();
+  }
+  dbg_ipc_cout("Receive" << ": g_ebs_enabled: " << g_ebs_enabled <<
+      ", g_qos_type: " << g_qos_type <<
+      ", g_qos_target" << g_qos_target);
 }
 
 bool ChannelReader::DispatchAttachmentBrokerMessage(const Message& message) {
 #if USE_ATTACHMENT_BROKER
   if (IsAttachmentBrokerEndpoint() && GetAttachmentBroker()) {
     return GetAttachmentBroker()->OnMessageReceived(message);
   }
 #endif  // USE_ATTACHMENT_BROKER
 
   return false;
@@ skipping 78 matching lines @@
   if (size <= Channel::kMaximumMessageSize) {
     return true;
   }
   input_overflow_buf_.clear();
   LOG(ERROR) << "IPC message is too big: " << size;
   return false;
 }
 
 }  // namespace internal
 }  // namespace IPC