blob: 5ef38c969eca1194d7225a56572a3ae792be4cfb [file] [log] [blame]
Willy Tarreau609aad92018-11-22 08:31:09 +01001/*
2 * activity measurement functions.
3 *
4 * Copyright 2000-2018 Willy Tarreau <w@1wt.eu>
5 *
6 * This program is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU General Public License
8 * as published by the Free Software Foundation; either version
9 * 2 of the License, or (at your option) any later version.
10 *
11 */
12
Willy Tarreau4c7e4b72020-05-27 12:58:42 +020013#include <haproxy/api.h>
Willy Tarreau6be78492020-06-05 00:00:29 +020014#include <haproxy/cfgparse.h>
Willy Tarreauf1d32c42020-06-04 21:07:02 +020015#include <haproxy/channel.h>
Willy Tarreau83487a82020-06-04 20:19:54 +020016#include <haproxy/cli.h>
Willy Tarreau5e539c92020-06-04 20:45:39 +020017#include <haproxy/stream_interface.h>
Willy Tarreau48fbcae2020-06-03 18:09:46 +020018#include <haproxy/tools.h>
Willy Tarreaua04ded52020-06-02 10:29:48 +020019#include <haproxy/activity-t.h>
Willy Tarreau66347942020-06-01 12:18:08 +020020#include <haproxy/freq_ctr.h>
Willy Tarreau75c62c22018-11-22 11:02:09 +010021
22
23/* bit field of profiling options. Beware, may be modified at runtime! */
Willy Tarreaud2d33482019-04-25 17:09:07 +020024unsigned int profiling = HA_PROF_TASKS_AUTO;
Willy Tarreaud9add3a2019-04-25 08:57:41 +020025unsigned long task_profiling_mask = 0;
Willy Tarreau609aad92018-11-22 08:31:09 +010026
27/* One struct per thread containing all collected measurements */
28struct activity activity[MAX_THREADS] __attribute__((aligned(64))) = { };
29
30
31/* Updates the current thread's statistics about stolen CPU time. The unit for
32 * <stolen> is half-milliseconds.
33 */
34void report_stolen_time(uint64_t stolen)
35{
36 activity[tid].cpust_total += stolen;
37 update_freq_ctr(&activity[tid].cpust_1s, stolen);
38 update_freq_ctr_period(&activity[tid].cpust_15s, 15000, stolen);
39}
Willy Tarreau75c62c22018-11-22 11:02:09 +010040
41/* config parser for global "profiling.tasks", accepts "on" or "off" */
42static int cfg_parse_prof_tasks(char **args, int section_type, struct proxy *curpx,
43 struct proxy *defpx, const char *file, int line,
44 char **err)
45{
46 if (too_many_args(1, args, err, NULL))
47 return -1;
48
49 if (strcmp(args[1], "on") == 0)
Willy Tarreaud2d33482019-04-25 17:09:07 +020050 profiling = (profiling & ~HA_PROF_TASKS_MASK) | HA_PROF_TASKS_ON;
51 else if (strcmp(args[1], "auto") == 0)
52 profiling = (profiling & ~HA_PROF_TASKS_MASK) | HA_PROF_TASKS_AUTO;
Willy Tarreau75c62c22018-11-22 11:02:09 +010053 else if (strcmp(args[1], "off") == 0)
Willy Tarreaud2d33482019-04-25 17:09:07 +020054 profiling = (profiling & ~HA_PROF_TASKS_MASK) | HA_PROF_TASKS_OFF;
Willy Tarreau75c62c22018-11-22 11:02:09 +010055 else {
Willy Tarreaud2d33482019-04-25 17:09:07 +020056 memprintf(err, "'%s' expects either 'on', 'auto', or 'off' but got '%s'.", args[0], args[1]);
Willy Tarreau75c62c22018-11-22 11:02:09 +010057 return -1;
58 }
59 return 0;
60}
61
62/* parse a "set profiling" command. It always returns 1. */
63static int cli_parse_set_profiling(char **args, char *payload, struct appctx *appctx, void *private)
64{
Willy Tarreau75c62c22018-11-22 11:02:09 +010065 if (!cli_has_level(appctx, ACCESS_LVL_ADMIN))
66 return 1;
67
Willy Tarreau9d008692019-08-09 11:21:01 +020068 if (strcmp(args[2], "tasks") != 0)
69 return cli_err(appctx, "Expects 'tasks'.\n");
Willy Tarreau75c62c22018-11-22 11:02:09 +010070
Willy Tarreaud2d33482019-04-25 17:09:07 +020071 if (strcmp(args[3], "on") == 0) {
72 unsigned int old = profiling;
73 while (!_HA_ATOMIC_CAS(&profiling, &old, (old & ~HA_PROF_TASKS_MASK) | HA_PROF_TASKS_ON))
74 ;
75 }
76 else if (strcmp(args[3], "auto") == 0) {
77 unsigned int old = profiling;
78 while (!_HA_ATOMIC_CAS(&profiling, &old, (old & ~HA_PROF_TASKS_MASK) | HA_PROF_TASKS_AUTO))
79 ;
80 }
81 else if (strcmp(args[3], "off") == 0) {
82 unsigned int old = profiling;
83 while (!_HA_ATOMIC_CAS(&profiling, &old, (old & ~HA_PROF_TASKS_MASK) | HA_PROF_TASKS_OFF))
84 ;
85 }
Willy Tarreau9d008692019-08-09 11:21:01 +020086 else
87 return cli_err(appctx, "Expects 'on', 'auto', or 'off'.\n");
88
Willy Tarreau75c62c22018-11-22 11:02:09 +010089 return 1;
90}
91
92/* This function dumps all profiling settings. It returns 0 if the output
93 * buffer is full and it needs to be called again, otherwise non-zero.
94 */
95static int cli_io_handler_show_profiling(struct appctx *appctx)
96{
97 struct stream_interface *si = appctx->owner;
Willy Tarreaud2d33482019-04-25 17:09:07 +020098 const char *str;
Willy Tarreau75c62c22018-11-22 11:02:09 +010099
100 if (unlikely(si_ic(si)->flags & (CF_WRITE_ERROR|CF_SHUTW)))
101 return 1;
102
103 chunk_reset(&trash);
104
Willy Tarreaud2d33482019-04-25 17:09:07 +0200105 switch (profiling & HA_PROF_TASKS_MASK) {
106 case HA_PROF_TASKS_AUTO: str="auto"; break;
107 case HA_PROF_TASKS_ON: str="on"; break;
108 default: str="off"; break;
109 }
110
111 chunk_printf(&trash,
112 "Per-task CPU profiling : %s # set profiling tasks {on|auto|off}\n",
113 str);
Willy Tarreau75c62c22018-11-22 11:02:09 +0100114
115 if (ci_putchk(si_ic(si), &trash) == -1) {
116 /* failed, try again */
117 si_rx_room_blk(si);
118 return 0;
119 }
120 return 1;
121}
122
123/* config keyword parsers */
124static struct cfg_kw_list cfg_kws = {ILH, {
125 { CFG_GLOBAL, "profiling.tasks", cfg_parse_prof_tasks },
126 { 0, NULL, NULL }
127}};
128
Willy Tarreau0108d902018-11-25 19:14:37 +0100129INITCALL1(STG_REGISTER, cfg_register_keywords, &cfg_kws);
130
Willy Tarreau75c62c22018-11-22 11:02:09 +0100131/* register cli keywords */
132static struct cli_kw_list cli_kws = {{ },{
133 { { "show", "profiling", NULL }, "show profiling : show CPU profiling options", NULL, cli_io_handler_show_profiling, NULL },
134 { { "set", "profiling", NULL }, "set profiling : enable/disable CPU profiling", cli_parse_set_profiling, NULL },
135 {{},}
136}};
137
Willy Tarreau0108d902018-11-25 19:14:37 +0100138INITCALL1(STG_REGISTER, cli_register_kw, &cli_kws);