1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
|
package Mojo::IOLoop::ReadWriteProcess::CGroup::v1::Memory;
use Mojo::Base -base;
use constant {
# show various statistics
STAT_INTERFACE => 'memory.stat',
# show current usage for memory
CURRENT_INTERFACE => 'memory.usage_in_bytes',
# show current usage for memory+Swap
CURRENT_AND_SWAP_INTERFACE => 'memory.memsw.usage_in_bytes',
# set/show limit of memory usage
LIMIT_INTERFACE => 'memory.limit_in_bytes',
# show current usage for memory
LIMIT_AND_SWAP_INTERFACE => 'memory.memsw.limit_in_bytes',
# show the number of memory usage hits limits
FAILCNT_INTERFACE => 'memory.failcnt',
# show max memory usage recorded
MAX_RECORDED_INTERFACE => 'memory.max_usage_in_bytes',
# show max memory+Swap usage recorded
MAX_RECORDED_AND_SWAP_INTERFACE => 'memory.memsw.max_usage_in_bytes',
# set/show soft limit of memory usage
SOFT_LIMIT_INTERFACE => 'memory.soft_limit_in_bytes',
# set/show hierarchical account enabled
USE_HIERARCHY_INTERFACE => 'memory.use_hierarchy',
# trigger forced move charge to parent
FORCE_EMPTY_INTERFACE => 'memory.force_empty',
# set memory pressure notifications
PRESSURE_LEVEL_INTERFACE => 'memory.pressure_level',
# set/show swappiness parameter of vmscan (See sysctl's vm.swappiness)
SWAPPINESS_INTERFACE => 'memory.swappiness',
# set/show controls of moving charges
MOVE_CHARGE_AT_IMMIGRATE_INTERFACE => 'memory.move_charge_at_immigrate',
# set/show oom controls.
OOM_CONTROL_INTERFACE => 'memory.oom_control',
# show the number of memory usage per numa node
NUMA_STAT_INTERFACE => 'memory.numa_stat',
# set/show hard limit for kernel memory
KMEM_LIMIT_INTERFACE => 'memory.kmem.limit_in_bytes',
# show current kernel memory allocation
KMEM_USAGE_INTERFACE => 'memory.kmem.usage_in_bytes',
# show the number of kernel memory usage hits limits
KMEM_FAILCNT_INTERFACE => 'memory.kmem.failcnt',
# show max kernel memory usage recorded
KMEM_MAX_RECORDED_INTERFACE => 'memory.kmem.max_usage_in_bytes',
# set/show hard limit for tcp buf memory
KMEM_TCP_LIMIT_INTERFACE => 'memory.kmem.tcp.limit_in_bytes',
# show current tcp buf memory allocation
KMEM_TCP_USAGE_INTERFACE => 'memory.kmem.tcp.usage_in_bytes',
# show the number of tcp buf memory usage hits limits
KMEM_TCP_FAILCNT_INTERFACE => 'memory.kmem.tcp.failcnt',
# show max tcp buf memory usage recorded
KMEM_TCP_MAX_USAGE_INTERFACE => 'memory.kmem.tcp.max_usage_in_bytes',
};
has cgroup => sub { Mojo::IOLoop::ReadWriteProcess::CGroup::v1->new };
sub current { shift->cgroup->_list(CURRENT_INTERFACE) }
sub stat { shift->cgroup->_list(STAT_INTERFACE) }
sub swap_current { shift->cgroup->_list(CURRENT_AND_SWAP_INTERFACE) }
sub limit { shift->cgroup->_setget(LIMIT_INTERFACE, @_) }
sub failcnt { shift->cgroup->_list(FAILCNT_INTERFACE) }
sub observed_max_usage { shift->cgroup->_list(MAX_RECORDED_INTERFACE) }
sub observed_swap_max_usage {
shift->cgroup->_list(MAX_RECORDED_AND_SWAP_INTERFACE);
}
sub use_hierarchy { shift->cgroup->_setget(USE_HIERARCHY_INTERFACE, @_) }
sub soft_limit { shift->cgroup->_setget(SOFT_LIMIT_INTERFACE, @_) }
sub force_empty { shift->cgroup->_setget(FORCE_EMPTY_INTERFACE, @_) }
sub pressure_level { shift->cgroup->_setget(PRESSURE_LEVEL_INTERFACE, @_) }
sub swappiness { shift->cgroup->_setget(SWAPPINESS_INTERFACE, @_) }
sub move_charge {
shift->cgroup->_setget(MOVE_CHARGE_AT_IMMIGRATE_INTERFACE, @_);
}
sub oom_control { shift->cgroup->_setget(OOM_CONTROL_INTERFACE, @_) }
sub numa_stat { shift->cgroup->_list(NUMA_STAT_INTERFACE) }
sub kmem_limit { shift->cgroup->_setget(KMEM_LIMIT_INTERFACE, @_) }
sub kmem_usage { shift->cgroup->_list(KMEM_USAGE_INTERFACE) }
sub kmem_failcnt { shift->cgroup->_list(KMEM_FAILCNT_INTERFACE) }
sub kmem_max_usage { shift->cgroup->_list(KMEM_MAX_RECORDED_INTERFACE) }
sub kmem_tcp_limit { shift->cgroup->_setget(KMEM_TCP_LIMIT_INTERFACE, @_) }
sub kmem_tcp_usage { shift->cgroup->_list(KMEM_TCP_USAGE_INTERFACE) }
sub kmem_tcp_failcnt { shift->cgroup->_list(KMEM_TCP_FAILCNT_INTERFACE) }
sub kmem_tcp_max_usage { shift->cgroup->_list(KMEM_TCP_MAX_USAGE_INTERFACE) }
1;
=encoding utf-8
=head1 NAME
Mojo::IOLoop::ReadWriteProcess::CGroup::v1::Memory - CGroups v1 Memory Controller
=head1 SYNOPSIS
use Mojo::IOLoop::ReadWriteProcess::CGroup::v1;
my $cgroup = Mojo::IOLoop::ReadWriteProcess::CGroup::v1->new( name => "test" );
$cgroup->memory->current;
=head1 DESCRIPTION
This module uses features that are only available on Linux,
and requires cgroups and capability for unshare syscalls to achieve pid isolation.
=head1 METHODS
L<Mojo::IOLoop::ReadWriteProcess::CGroup::v1::Memory> inherits all methods from L<Mojo::Base> and implements
the following new ones.
=head1 LICENSE
Copyright (C) Ettore Di Giacinto.
This library is free software; you can redistribute it and/or modify
it under the same terms as Perl itself.
=head1 AUTHOR
Ettore Di Giacinto E<lt>edigiacinto@suse.comE<gt>
=cut
|
