[Chromoting] Deprecate AggregatedProcessResourceUsage.*

remoting/host/desktop_session_agent_unittest.cc

 // Copyright 2017 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 "remoting/host/desktop_session_agent.h"
 
 #include <memory>
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/location.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/weak_ptr.h"
 #include "base/message_loop/message_loop.h"
 #include "base/run_loop.h"
 #include "base/single_thread_task_runner.h"
+#include "base/threading/thread_task_runner_handle.h"
 #include "ipc/ipc_channel_proxy.h"
 #include "ipc/ipc_listener.h"
 #include "remoting/base/auto_thread_task_runner.h"
 #include "remoting/host/chromoting_messages.h"
 #include "remoting/host/desktop_environment_options.h"
 #include "remoting/host/fake_desktop_environment.h"
 #include "remoting/host/screen_resolution.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 namespace remoting {
@@ skipping 162 matching lines @@
         delegate->reset();
         proxy->reset();
       },
       base::Unretained(this),
       base::Unretained(&delegate),
       base::Unretained(&proxy)),
       base::TimeDelta::FromMilliseconds(1));
   run_loop_.Run();
 }
 
+TEST_F(DesktopSessionAgentTest, SendAggregatedProcessResourceUsage) {
+  std::unique_ptr<IPC::Channel> receiver;
+  std::unique_ptr<IPC::Channel> sender;
+  ProcessStatsListener listener(base::Bind([](
+          DesktopSessionAgentTest* test,
+          std::unique_ptr<IPC::Channel>* receiver,
+          std::unique_ptr<IPC::Channel>* sender) {
+        test->Shutdown();
+        base::ThreadTaskRunnerHandle::Get()->DeleteSoon(
+            FROM_HERE, receiver->release());
+        base::ThreadTaskRunnerHandle::Get()->DeleteSoon(
+            FROM_HERE, sender->release());
+      },
+      base::Unretained(this),
+      base::Unretained(&receiver),
+      base::Unretained(&sender)));
+  mojo::MessagePipe pipe;
+  receiver = IPC::Channel::CreateServer(
+      pipe.handle1.release(),
+      &listener,
+      task_runner_);
+  ASSERT_TRUE(receiver->Connect());
+  sender = IPC::Channel::CreateClient(
+      pipe.handle0.release(),
+      &listener,
+      task_runner_);
+  ASSERT_TRUE(sender->Connect());
+  protocol::AggregatedProcessResourceUsage aggregated;
+  for (int i = 0; i < 2; i++) {
+    *aggregated.add_usages() = protocol::ProcessResourceUsage();
+  }
+  ASSERT_TRUE(sender->Send(
+      new ChromotingAnyToNetworkMsg_ReportProcessStats(aggregated)));
+  run_loop_.Run();
+}
+
+TEST_F(DesktopSessionAgentTest, SendEmptyAggregatedProcessResourceUsage) {
+  std::unique_ptr<IPC::Channel> receiver;
+  std::unique_ptr<IPC::Channel> sender;
+  ProcessStatsListener listener(base::Bind([](
+          DesktopSessionAgentTest* test,
+          std::unique_ptr<IPC::Channel>* receiver,
+          std::unique_ptr<IPC::Channel>* sender) {
+        test->Shutdown();
+        base::ThreadTaskRunnerHandle::Get()->DeleteSoon(
+            FROM_HERE, receiver->release());
+        base::ThreadTaskRunnerHandle::Get()->DeleteSoon(
+            FROM_HERE, sender->release());
+      },
+      base::Unretained(this),
+      base::Unretained(&receiver),
+      base::Unretained(&sender)));
+  mojo::MessagePipe pipe;
+  receiver = IPC::Channel::CreateServer(
+      pipe.handle1.release(),
+      &listener,
+      task_runner_);
+  ASSERT_TRUE(receiver->Connect());
+  sender = IPC::Channel::CreateClient(
+      pipe.handle0.release(),
+      &listener,
+      task_runner_);
+  ASSERT_TRUE(sender->Connect());
+  ASSERT_TRUE(sender->Send(new ChromotingAnyToNetworkMsg_ReportProcessStats(
+      protocol::AggregatedProcessResourceUsage())));
+  run_loop_.Run();
+}
+
 }  // namespace remoting