/* ** Zabbix ** Copyright (C) 2001-2022 Zabbix SIA ** ** This program is free software; you can redistribute it and/or modify ** it under the terms of the GNU General Public License as published by ** the Free Software Foundation; either version 2 of the License, or ** (at your option) any later version. ** ** This program 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 General Public License for more details. ** ** You should have received a copy of the GNU General Public License ** along with this program; if not, write to the Free Software ** Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. **/ #include "common.h" #include "valuecache.h" #include "zbxlld.h" #include "dbcache.h" #include "zbxha.h" #include "checks_internal.h" /****************************************************************************** * * * Purpose: processes program type (server) specific internal checks * * * * Parameters: param1 - [IN] the first parameter * * request - [IN] the request * * result - [OUT] the result * * * * Return value: SUCCEED - data successfully retrieved and stored in result * * NOTSUPPORTED - requested item is not supported * * FAIL - not a server specific internal check * * * * Comments: This function is used to process server specific internal checks * * before generic internal checks are processed. * * * ******************************************************************************/ int zbx_get_value_internal_ext(const char *param1, const AGENT_REQUEST *request, AGENT_RESULT *result) { int nparams, ret = NOTSUPPORTED; char *param2, *param3; nparams = get_rparams_num(request); if (0 == strcmp(param1, "triggers")) /* zabbix["triggers"] */ { if (1 != nparams) { SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid number of parameters.")); goto out; } SET_UI64_RESULT(result, DCget_trigger_count()); } else if (0 == strcmp(param1, "history") || /* zabbix["history"] */ 0 == strcmp(param1, "history_log") || /* zabbix["history_log"] */ 0 == strcmp(param1, "history_str") || /* zabbix["history_str"] */ 0 == strcmp(param1, "history_text") || /* zabbix["history_text"] */ 0 == strcmp(param1, "history_uint")) /* zabbix["history_uint"] */ { if (1 != nparams) { SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid number of parameters.")); goto out; } SET_UI64_RESULT(result, DBget_row_count(param1)); } else if (0 == strcmp(param1, "trends") || /* zabbix["trends"] */ 0 == strcmp(param1, "trends_uint")) /* zabbix["trends_uint"] */ { if (1 != nparams) { SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid number of parameters.")); goto out; } SET_UI64_RESULT(result, DBget_row_count(param1)); } else if (0 == strcmp(param1, "proxy")) /* zabbix["proxy",,"lastaccess" OR "delay"] */ { int value, res; char *error = NULL; /* this item is always processed by server */ if (3 != nparams) { SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid number of parameters.")); goto out; } param2 = get_rparam(request, 2); if (0 == strcmp(param2, "lastaccess")) { res = DBget_proxy_lastaccess(get_rparam(request, 1), &value, &error); } else if (0 == strcmp(param2, "delay")) { int lastaccess; if (SUCCEED == (res = DCget_proxy_delay_by_name(get_rparam(request, 1), &value, &error)) && SUCCEED == (res = DBget_proxy_lastaccess(get_rparam(request, 1), &lastaccess, &error))) { value += (int)time(NULL) - lastaccess; } } else { SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid third parameter.")); goto out; } if (SUCCEED != res) { SET_MSG_RESULT(result, error); goto out; } SET_UI64_RESULT(result, value); } else if (0 == strcmp(param1, "vcache")) { zbx_vc_stats_t stats; if (FAIL == zbx_vc_get_statistics(&stats)) { SET_MSG_RESULT(result, zbx_strdup(NULL, "Value cache is disabled.")); goto out; } if (2 > nparams || nparams > 3) { SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid number of parameters.")); goto out; } param2 = get_rparam(request, 1); if (NULL == (param3 = get_rparam(request, 2))) param3 = ""; if (0 == strcmp(param2, "buffer")) { if (0 == strcmp(param3, "free")) SET_UI64_RESULT(result, stats.free_size); else if (0 == strcmp(param3, "pfree")) SET_DBL_RESULT(result, (double)stats.free_size / stats.total_size * 100); else if (0 == strcmp(param3, "total")) SET_UI64_RESULT(result, stats.total_size); else if (0 == strcmp(param3, "used")) SET_UI64_RESULT(result, stats.total_size - stats.free_size); else if (0 == strcmp(param3, "pused")) SET_DBL_RESULT(result, (double)(stats.total_size - stats.free_size) / stats.total_size * 100); else { SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid third parameter.")); goto out; } } else if (0 == strcmp(param2, "cache")) { if (0 == strcmp(param3, "hits")) SET_UI64_RESULT(result, stats.hits); else if (0 == strcmp(param3, "requests")) SET_UI64_RESULT(result, stats.hits + stats.misses); else if (0 == strcmp(param3, "misses")) SET_UI64_RESULT(result, stats.misses); else if (0 == strcmp(param3, "mode")) SET_UI64_RESULT(result, stats.mode); else { SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid third parameter.")); goto out; } } else { SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid second parameter.")); goto out; } } else if (0 == strcmp(param1, "lld_queue")) { zbx_uint64_t value; char *error = NULL; if (1 != nparams) { SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid number of parameters.")); goto out; } if (FAIL == zbx_lld_get_queue_size(&value, &error)) { SET_MSG_RESULT(result, error); goto out; } SET_UI64_RESULT(result, value); } else if (0 == strcmp(param1, "cluster")) { char *nodes = NULL, *error = NULL; if (3 != nparams) { SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid number of parameters.")); goto out; } param2 = get_rparam(request, 1); if (0 != strcmp(param2, "discovery")) { SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid second parameter.")); goto out; } param2 = get_rparam(request, 2); if (0 != strcmp(param2, "nodes")) { SET_MSG_RESULT(result, zbx_strdup(NULL, "Invalid third parameter.")); goto out; } if (SUCCEED != zbx_ha_get_nodes(&nodes, &error)) { SET_MSG_RESULT(result, error); goto out; } SET_TEXT_RESULT(result, nodes); } else { ret = FAIL; goto out; } ret = SUCCEED; out: return ret; }