Implementation of the GreenWeb language extensions.

ipc/ipc_channel_posix.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_posix.h"
 
 #include <errno.h>
 #include <fcntl.h>
 #include <stddef.h>
 #include <stdint.h>
 #include <sys/socket.h>
 #include <sys/stat.h>
 #include <sys/types.h>
 #include <unistd.h>
 
 #if defined(OS_OPENBSD)
 #include <sys/uio.h>
 #endif
 
 #if !defined(OS_NACL_NONSFI)
 #include <sys/un.h>
 #endif
 
 #include <algorithm>
+#include <iostream>
 #include <map>
 #include <string>
 
 #include "base/command_line.h"
 #include "base/files/file_path.h"
 #include "base/files/file_util.h"
 #include "base/location.h"
 #include "base/logging.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/memory/singleton.h"
 #include "base/posix/eintr_wrapper.h"
 #include "base/posix/global_descriptors.h"
 #include "base/process/process_handle.h"
 #include "base/rand_util.h"
 #include "base/stl_util.h"
 #include "base/strings/string_util.h"
 #include "base/synchronization/lock.h"
+#include "content/renderer/greenweb_latency_tracking.h"
 #include "ipc/attachment_broker.h"
 #include "ipc/ipc_descriptors.h"
 #include "ipc/ipc_listener.h"
 #include "ipc/ipc_logging.h"
 #include "ipc/ipc_message_attachment_set.h"
 #include "ipc/ipc_message_utils.h"
 #include "ipc/ipc_platform_file_attachment_posix.h"
 #include "ipc/ipc_switches.h"
 #include "ipc/unix_domain_socket_util.h"
 
@@ skipping 652 matching lines @@
         delete message;
         return false;
       }
     }
   }
 
 #ifdef IPC_MESSAGE_LOG_ENABLED
   Logging::GetInstance()->OnSendMessage(message, "");
 #endif  // IPC_MESSAGE_LOG_ENABLED
 
-  TRACE_EVENT_WITH_FLOW0(TRACE_DISABLED_BY_DEFAULT("ipc.flow"),
+  // Ideally we want to send a dedicated to communicate the qos_type and
+  //   ebs_enabled info from the main thread to the GPU thread just once.
+  //   As a simple hack, we send them along with each message! The implication
+  //   of this simplification is that we need to make sure that we do not
+  //   overwrite the values in the main thread when we receive an IPC message
+  //   from other processes (see the implementation of
+  //   |ChannelReader::EmitLogBeforeDispatch| in ipc_channel_reader.cc).
+  message->set_qos_type(g_qos_type);
+  message->set_qos_target(g_qos_target);
+  message->set_ebs_enabled(g_ebs_enabled);
+  dbg_ipc_cout("Send" << ": g_ebs_enabled: " << g_ebs_enabled <<
+      ", g_qos_type: " << g_qos_type <<
+      ", g_qos_target" << g_qos_target);
+
+  TRACE_EVENT_WITH_FLOW1(TRACE_DISABLED_BY_DEFAULT("ipc.flow"),
                          "ChannelPosix::Send",
                          message->flags(),
-                         TRACE_EVENT_FLAG_FLOW_OUT);
+                         TRACE_EVENT_FLAG_FLOW_OUT,
+                         "QoS Type",
+                         message->qos_type());
 
   // |output_queue_| takes ownership of |message|.
   OutputElement* element = new OutputElement(message);
   output_queue_.push(element);
 
   if (message->HasBrokerableAttachments()) {
     // |output_queue_| takes ownership of |ids.buffer|.
     Message::SerializedAttachmentIds ids =
         message->SerializedIdsOfBrokerableAttachments();
     output_queue_.push(new OutputElement(ids.buffer, ids.size));
@@ skipping 391 matching lines @@
 }
 
 #if defined(OS_LINUX)
 // static
 void Channel::SetGlobalPid(int pid) {
   ChannelPosix::SetGlobalPid(pid);
 }
 #endif  // OS_LINUX
 
 }  // namespace IPC