/* * 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 #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 */
