1 // Copyright 2017 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #include "content/browser/memory/swap_metrics_driver_impl_mac.h"
6
7 #include <mach/mach.h>
8 #include <mach/mach_vm.h>
9 #include <memory>
10
11 #include "base/mac/mach_logging.h"
12 #include "base/memory/ptr_util.h"
13 #include "base/time/time.h"
14
15 namespace content {
16
17 // static
Create(std::unique_ptr<Delegate> delegate,const base::TimeDelta update_interval)18 std::unique_ptr<SwapMetricsDriver> SwapMetricsDriver::Create(
19 std::unique_ptr<Delegate> delegate,
20 const base::TimeDelta update_interval) {
21 return base::WrapUnique<SwapMetricsDriver>(
22 new SwapMetricsDriverImplMac(std::move(delegate), update_interval));
23 }
24
SwapMetricsDriverImplMac(std::unique_ptr<Delegate> delegate,const base::TimeDelta update_interval)25 SwapMetricsDriverImplMac::SwapMetricsDriverImplMac(
26 std::unique_ptr<Delegate> delegate,
27 const base::TimeDelta update_interval)
28 : SwapMetricsDriverImpl(std::move(delegate), update_interval),
29 host_(mach_host_self()) {}
30
31 SwapMetricsDriverImplMac::~SwapMetricsDriverImplMac() = default;
32
33 SwapMetricsDriver::SwapMetricsUpdateResult
UpdateMetricsInternal(base::TimeDelta interval)34 SwapMetricsDriverImplMac::UpdateMetricsInternal(base::TimeDelta interval) {
35 vm_statistics64_data_t statistics;
36 mach_msg_type_number_t count = HOST_VM_INFO64_COUNT;
37 kern_return_t result =
38 host_statistics64(host_.get(), HOST_VM_INFO64,
39 reinterpret_cast<host_info64_t>(&statistics), &count);
40 if (result != KERN_SUCCESS) {
41 MACH_DLOG(WARNING, result) << "host_statistics64";
42 return SwapMetricsDriver::SwapMetricsUpdateResult::kSwapMetricsUpdateFailed;
43 }
44 DCHECK_EQ(HOST_VM_INFO64_COUNT, count);
45
46 uint64_t swapins = statistics.swapins - last_swapins_;
47 uint64_t swapouts = statistics.swapouts - last_swapouts_;
48 uint64_t decompressions = statistics.decompressions - last_decompressions_;
49 uint64_t compressions = statistics.compressions - last_compressions_;
50 last_swapins_ = statistics.swapins;
51 last_swapouts_ = statistics.swapouts;
52 last_decompressions_ = statistics.decompressions;
53 last_compressions_ = statistics.compressions;
54
55 if (interval.is_zero())
56 return SwapMetricsDriver::SwapMetricsUpdateResult::
57 kSwapMetricsUpdateSuccess;
58
59 delegate_->OnSwapInCount(swapins, interval);
60 delegate_->OnSwapOutCount(swapouts, interval);
61 delegate_->OnDecompressedPageCount(decompressions, interval);
62 delegate_->OnCompressedPageCount(compressions, interval);
63
64 return SwapMetricsDriver::SwapMetricsUpdateResult::kSwapMetricsUpdateSuccess;
65 }
66
67 } // namespace content
68