Measure IPC latency for audio...

chrome/renderer/audio_message_filter.cc

 // Copyright (c) 2009 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 "base/histogram.h"
 #include "base/message_loop.h"
+#include "chrome/common/ipc_logging.h"
 #include "chrome/common/render_messages.h"
 #include "chrome/renderer/audio_message_filter.h"
 
+namespace {
+
+void RecordReceiveLatency(base::TimeDelta latency) {
+  static ThreadSafeHistogram histogram("Audio.IPC_Renderer_ReceiveLatency",
+                                       1, 500, 100);
+  histogram.AddTime(latency);
+}
+
+void RecordProcessTime(base::TimeDelta latency) {
+  static ThreadSafeHistogram histogram("Audio.IPC_Renderer_ProcessTime",
+                                       1, 100, 100);
+  histogram.AddTime(latency);
+}
+
+}  // namespace
+
 AudioMessageFilter::AudioMessageFilter(int32 route_id)
     : channel_(NULL),
       route_id_(route_id),
       message_loop_(NULL) {
 }
 
 AudioMessageFilter::~AudioMessageFilter() {
 }
 
 // Called on the IPC thread.
@@ skipping 29 matching lines @@
 }
 
 void AudioMessageFilter::OnFilterRemoved() {
   channel_ = NULL;
 }
 
 void AudioMessageFilter::OnChannelClosing() {
   channel_ = NULL;
 }
 
-void AudioMessageFilter::OnRequestPacket(int stream_id) {
+void AudioMessageFilter::OnRequestPacket(const IPC::Message& msg,
+                                         int stream_id) {
   Delegate* delegate = delegates_.Lookup(stream_id);
   if (!delegate) {
     DLOG(WARNING) << "Got audio packet request for a non-existent or removed"
         " audio renderer.";
     return;
   }
+
+#ifdef IPC_MESSAGE_LOG_ENABLED
+  IPC::Logging* logger = IPC::Logging::current();
+  if (logger->Enabled()) {
+    RecordReceiveLatency(base::Time::FromInternalValue(msg.received_time()) -
+                         base::Time::FromInternalValue(msg.sent_time()));
+  }
+#endif
+
   delegate->OnRequestPacket();
+
+#ifdef IPC_MESSAGE_LOG_ENABLED
+  if (logger->Enabled()) {
+    RecordProcessTime(base::Time::Now() -
+                      base::Time::FromInternalValue(msg.received_time()));
+  }
+#endif
 }
 
 void AudioMessageFilter::OnStreamCreated(int stream_id,
                                          base::SharedMemoryHandle handle,
                                          int length) {
   Delegate* delegate = delegates_.Lookup(stream_id);
   if (!delegate) {
     DLOG(WARNING) << "Got audio stream event for a non-existent or removed"
         " audio renderer.";
     return;
@@ skipping 24 matching lines @@
   delegate->OnVolume(left, right);
 }
 
 int32 AudioMessageFilter::AddDelegate(Delegate* delegate) {
   return delegates_.Add(delegate);
 }
 
 void AudioMessageFilter::RemoveDelegate(int32 id) {
   delegates_.Remove(id);
 }