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
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
|
/*
* CDDL HEADER START
*
* The contents of this file are subject to the terms of the
* Common Development and Distribution License (the "License").
* You may not use this file except in compliance with the License.
*
* You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
* or http://www.opensolaris.org/os/licensing.
* See the License for the specific language governing permissions
* and limitations under the License.
*
* When distributing Covered Code, include this CDDL HEADER in each
* file and include the License file at usr/src/OPENSOLARIS.LICENSE.
* If applicable, add the following below this CDDL HEADER, with the
* fields enclosed by brackets "[]" replaced with your own identifying
* information: Portions Copyright [yyyy] [name of copyright owner]
*
* CDDL HEADER END
*/
/*
* Copyright 2007 Sun Microsystems, Inc. All rights reserved.
* Use is subject to license terms.
*/
#ifndef _RCAPD_H
#define _RCAPD_H
#pragma ident "%Z%%M% %I% %E% SMI"
#ifdef __cplusplus
extern "C" {
#endif
#include <sys/types.h>
#include <procfs.h>
#include "rcapd_conf.h"
#define LC_NAME_LEN 32
#define RCAP_FMRI "svc:/system/rcap:default"
#define CONFIG_PG "config"
#define PRESSURE "pressure"
#define RECONFIG_INT "reconfig_interval"
#define REPORT_INT "report_interval"
#define RSS_SAMPLE_INT "rss_sample_interval"
#define WALK_INT "walk_interval"
#define RCAPD_IGNORED_SET_FLUSH_IVAL 10 /* number of scans between */
/* flushes of the ignored set */
/*
* set the buffer length for /proc-based path names based on the actual
* length of the largest pid
*/
#define RCAPD__STR(a) #a
#define RCAPD_STR(macro) RCAPD__STR(macro)
#define PROC_PATH_MAX (sizeof ("/proc/" RCAPD_STR(PID_MAX) \
"/pagedata"))
/*
* lcollection_insert_update() result flags
*/
#define LCST_CAP_CHANGED (1<<0)
#define LCST_CAP_REMOVED (1<<1)
#define LCST_CAP_ZERO (1<<2)
typedef enum {
RCIDT_PROJECT,
RCIDT_ZONE
} rcid_type_t;
typedef struct {
/*
* The following field could just be a rcid_type_t but it gets
* written out to a file as binary data for communication between
* 64-bit rcapd & 32-bit rcapstat, so we need to force a standard size
* and alignment here.
*/
uint64_t rcid_type;
int64_t rcid_val;
} rcid_t;
typedef enum {
LCU_COMPLETE, /* an enumeration of all possible collections */
LCU_ACTIVE_ONLY /* an enumeration of only once-active collections */
} lcollection_update_type_t;
struct lmapping;
struct lprocess;
struct lcollection;
struct prxmap;
struct psinfo;
/*
* Per-process data.
*/
typedef struct lprocess {
struct lprocess *lpc_prev; /* global process list */
struct lprocess *lpc_next;
pid_t lpc_pid; /* ID of this process */
int lpc_unscannable; /* flag indicating zombie or */
/* other unscannable process */
uint64_t lpc_rss; /* resident set size (kB) */
uint64_t lpc_unrm; /* scannable set size (kB) (est.) */
uint64_t lpc_size; /* process image size (kB) */
int lpc_mark; /* mark-and-sweep flag */
struct lcollection *lpc_collection; /* owning collection */
int lpc_psinfo_fd; /* cached psinfo fd */
int lpc_pgdata_fd; /* cached pagedata fd */
int lpc_xmap_fd; /* cached xmap fd */
struct prxmap *lpc_xmap; /* xmap corresponding to */
/* current pagedata */
int lpc_nxmap; /* number of mappings in xmap */
prpageheader_t *lpc_prpageheader; /* accumulated mask of */
/* process's ref/mod bits */
struct lmapping *lpc_ignore; /* empirically-unpageable mappings */
} lprocess_t;
/*
* Collection statistics.
*/
typedef struct {
uint64_t lcols_scan; /* scan attempts */
uint64_t lcols_pg_att; /* kB attempted to page */
uint64_t lcols_pg_eff; /* kB paged out (est.) */
uint64_t lcols_rss_sample; /* RSS samplings */
uint64_t lcols_unenforced_cap; /* times cap could have been */
/* enforced, but wasn't (due to low */
/* global memory pressure, or global */
/* scanner being activated) */
uint64_t lcols_rss_sum; /* sum of sampled RSS values */
uint64_t lcols_rss_act_sum; /* sum of sampled, excess RSS values */
uint64_t lcols_min_rss; /* minimum RSS (kB), this interval */
uint64_t lcols_max_rss; /* maximum RSS (kB), this interval */
uint64_t lcols_proc_in; /* processes tracked */
uint64_t lcols_proc_out; /* processes freed */
hrtime_t lcols_scan_time; /* time spent scanning (ns) */
hrtime_t lcols_scan_time_complete; /* time spent scanning (ns) */
/* at last completion */
uint64_t lcols_scan_count; /* number of complete scans */
uint64_t lcols_scan_ineffective; /* number of uninterrupted */
/* revolutions of clock hand after */
/* which the excess was not */
/* completely reduced */
} lcollection_stat_t;
/*
* Collection.
*/
typedef struct lcollection {
struct lcollection *lcol_prev; /* global collection list */
struct lcollection *lcol_next;
rcid_t lcol_id; /* numerical ID for this collection */
char lcol_name[LC_NAME_LEN]; /* name of this collection, or */
/* "unknown" */
uint64_t lcol_rss; /* RSS of all processes (kB) */
uint64_t lcol_image_size; /* image size of all processes (kB) */
uint64_t lcol_rss_cap; /* RSS cap (kB) */
lcollection_stat_t lcol_stat; /* statistics */
lcollection_stat_t lcol_stat_old; /* previous interval's statistics */
lprocess_t *lcol_lprocess; /* member processes */
int lcol_mark; /* mark-and-sweep flag */
lprocess_t *lcol_victim; /* victim process to resume scanning */
void *lcol_resaddr; /* address to resume scanning from */
} lcollection_t;
/*
* Collection report.
*/
typedef struct lcollection_report {
rcid_t lcol_id; /* numerical ID for this collection */
char lcol_name[LC_NAME_LEN]; /* name of this collection, or */
/* "unknown" */
uint64_t lcol_rss; /* RSS of all processes (kB) */
uint64_t lcol_image_size; /* image size of all processes (kB) */
uint64_t lcol_rss_cap; /* RSS limit (kB) */
lcollection_stat_t lcol_stat; /* statistics */
} lcollection_report_t;
extern int get_psinfo(pid_t, struct psinfo *, int, int(*)(void *, int), void *,
lprocess_t *);
extern lcollection_t *lcollection_find(rcid_t *);
extern void lcollection_freq_move(lprocess_t *);
extern lcollection_t *lcollection_insert_update(rcid_t *, uint64_t, char *,
int *changes);
extern int lcollection_member(lcollection_t *, lprocess_t *);
extern void lcollection_free(lcollection_t *);
extern void lcollection_update(lcollection_update_type_t);
extern void list_walk_collection(int (*)(lcollection_t *, void *), void *);
extern int lprocess_update_psinfo_fd_cb(void *, int);
extern void lprocess_free(lprocess_t *);
extern void scan(lcollection_t *, int64_t);
extern void scan_abort(void);
extern void check_update_statistics(void);
/*
* Global (in rcapd only) variables.
*/
extern rcfg_t rcfg;
extern uint64_t phys_total;
extern int should_run;
#ifdef __cplusplus
}
#endif
#endif /* _RCAPD_H */
|
