metrics: Add dbus interface for GetRandomPerfOutput

chromeos/dbus/debug_daemon_client.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 "chromeos/dbus/debug_daemon_client.h"
 
 #include <fcntl.h>
 #include <unistd.h>
 #include <string>
 #include <vector>
@@ skipping 143 matching lines @@
     writer.AppendUint32(duration);
 
     debugdaemon_proxy_->CallMethod(
         &method_call,
         dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
         base::Bind(&DebugDaemonClientImpl::OnGetPerfData,
                    weak_ptr_factory_.GetWeakPtr(),
                    callback));
   }
 
+  void GetPerfOutput(uint32_t duration,
+                     const GetPerfOutputCallback& callback) override {
+    dbus::MethodCall method_call(debugd::kDebugdInterface,
+                                 debugd::kGetRandomPerfOutput);
+    dbus::MessageWriter writer(&method_call);
+    writer.AppendUint32(duration);
+
+    debugdaemon_proxy_->CallMethod(
+        &method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
+        base::Bind(&DebugDaemonClientImpl::OnGetPerfOutput,
+                   weak_ptr_factory_.GetWeakPtr(), callback));
+  }
+
   void GetScrubbedLogs(const GetLogsCallback& callback) override {
     dbus::MethodCall method_call(debugd::kDebugdInterface,
                                  debugd::kGetFeedbackLogs);
     debugdaemon_proxy_->CallMethod(
         &method_call,
         dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
         base::Bind(&DebugDaemonClientImpl::OnGetAllLogs,
                    weak_ptr_factory_.GetWeakPtr(),
                    callback));
   }
@@ skipping 280 matching lines @@
     size_t buf_size = 0;
     if (!reader.PopArrayOfBytes(&buffer, &buf_size))
       return;
 
     // TODO(asharif): Figure out a way to avoid this copy.
     data.insert(data.end(), buffer, buffer + buf_size);
 
     callback.Run(data);
   }
 
+  void OnGetPerfOutput(const GetPerfOutputCallback& callback,
+                       dbus::Response* response) {
+    if (!response)
+      return;
+
+    dbus::MessageReader reader(response);
+
+    int status = 0;
+    if (!reader.PopInt32(&status))
+      return;
+
+    const uint8* buffer = nullptr;
+    size_t buf_size = 0;
+
+    if (!reader.PopArrayOfBytes(&buffer, &buf_size))
+      return;
+    std::vector<uint8> perf_data;
+    if (buf_size > 0)
+      perf_data.insert(perf_data.end(), buffer, buffer + buf_size);
+
+    if (!reader.PopArrayOfBytes(&buffer, &buf_size))
+      return;
+    std::vector<uint8> perf_stat;
+    if (buf_size > 0)
+      perf_stat.insert(perf_stat.end(), buffer, buffer + buf_size);
+
+    callback.Run(status, perf_data, perf_stat);
+  }
+
   void OnGetAllLogs(const GetLogsCallback& callback,
                     dbus::Response* response) {
     std::map<std::string, std::string> logs;
     bool broken = false; // did we see a broken (k,v) pair?
     dbus::MessageReader sub_reader(NULL);
     if (!response || !dbus::MessageReader(response).PopArray(&sub_reader)) {
       callback.Run(false, logs);
       return;
     }
     while (sub_reader.HasMoreData()) {
@@ skipping 142 matching lines @@
 DebugDaemonClient::EmptyStopSystemTracingCallback() {
   return base::Bind(&EmptyStopSystemTracingCallbackBody);
 }
 
 // static
 DebugDaemonClient* DebugDaemonClient::Create() {
   return new DebugDaemonClientImpl();
 }
 
 }  // namespace chromeos