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
|
/*
* Copyright (c) 2009 Ken McDonell. All Rights Reserved.
*
* This library is free software; you can redistribute it and/or modify it
* under the terms of the GNU Lesser General Public License as published
* by the Free Software Foundation; either version 2.1 of the License, or
* (at your option) any later version.
*
* This library is distributed in the hope that it will be useful, but
* WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public
* License for more details.
*/
#ifndef _DERIVE_H
#define _DERIVE_H
/*
* Derived Metrics support
*/
typedef struct { /* one value in the expression tree */
int inst;
pmAtomValue value;
int vlen; /* from vlen of pmValueBlock for string and aggregates */
} val_t;
typedef struct { /* dynamic information for an expression node */
pmID pmid;
int numval; /* length of ivlist[] */
int mul_scale; /* scale multiplier */
int div_scale; /* scale divisor */
val_t *ivlist; /* instance-value pairs */
struct timeval stamp; /* timestamp from current fetch */
double time_scale; /* time utilization scaling for rate() */
int last_numval; /* length of last_ivlist[] */
val_t *last_ivlist; /* values from previous fetch for delta() or rate() */
struct timeval last_stamp; /* timestamp from previous fetch for rate() */
} info_t;
typedef struct node { /* expression tree node */
int type;
pmDesc desc;
int save_last;
struct node *left;
struct node *right;
char *value;
info_t *info;
} node_t;
typedef struct { /* one derived metric */
char *name;
pmID pmid;
node_t *expr;
} dm_t;
/*
* Control structure for a set of derived metrics.
* This is used for the static definitions (registered) and the dynamic
* tree of expressions maintained per context.
*/
typedef struct {
__pmMutex mutex;
int nmetric; /* derived metrics */
dm_t *mlist;
int fetch_has_dm; /* ==1 if pmResult rewrite needed */
int numpmid; /* from pmFetch before rewrite */
} ctl_t;
/* lexical types */
#define L_ERROR -2
#define L_EOF -1
#define L_UNDEF 0
#define L_NUMBER 1
#define L_NAME 2
#define L_PLUS 3
#define L_MINUS 4
#define L_STAR 5
#define L_SLASH 6
#define L_LPAREN 7
#define L_RPAREN 8
#define L_AVG 9
#define L_COUNT 10
#define L_DELTA 11
#define L_MAX 12
#define L_MIN 13
#define L_SUM 14
#define L_ANON 15
#define L_RATE 16
extern int __dmtraverse(const char *, char ***) _PCP_HIDDEN;
extern int __dmchildren(const char *, char ***, int **) _PCP_HIDDEN;
extern int __dmgetpmid(const char *, pmID *) _PCP_HIDDEN;
extern int __dmgetname(pmID, char **) _PCP_HIDDEN;
extern void __dmopencontext(__pmContext *) _PCP_HIDDEN;
extern void __dmclosecontext(__pmContext *) _PCP_HIDDEN;
extern int __dmdesc(__pmContext *, pmID, pmDesc *) _PCP_HIDDEN;
extern int __dmprefetch(__pmContext *, int, const pmID *, pmID **) _PCP_HIDDEN;
extern void __dmpostfetch(__pmContext *, pmResult **) _PCP_HIDDEN;
extern void __dmdumpexpr(node_t *, int) _PCP_HIDDEN;
#endif /* _DERIVE_H */
|
