运维工具+监控+zabbix+监控服务器

/* ** Zabbix ** Copyright (C) 2001-2019 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 "log.h" #include "threads.h" #include "dbcache.h" #include "ipc.h" #include "mutexs.h" #include "memalloc.h" #include "strpool.h" #include "zbxserver.h" #include "zbxalgo.h" #include "dbcache.h" #include "zbxregexp.h" #include "cfg.h" #include "../zbxcrypto/tls_tcp_active.h" #include "dbcache.h" #define ZBX_DBCONFIG_IMPL #include "dbconfig.h" #include "dbsync.h" static int sync_in_progress = 0; #define LOCK_CACHE if (0 == sync_in_progress) zbx_mutex_lock(&config_lock) #define UNLOCK_CACHE if (0 == sync_in_progress) zbx_mutex_unlock(&config_lock) #define START_SYNC LOCK_CACHE; sync_in_progress = 1 #define FINISH_SYNC sync_in_progress = 0; UNLOCK_CACHE #define ZBX_LOC_NOWHERE 0 #define ZBX_LOC_QUEUE 1 #define ZBX_LOC_POLLER 2 #define ZBX_SNMP_OID_TYPE_NORMAL 0 #define ZBX_SNMP_OID_TYPE_DYNAMIC 1 #define ZBX_SNMP_OID_TYPE_MACRO 2 /* trigger is functional unless its expression contains disabled or not monitored items */ #define TRIGGER_FUNCTIONAL_TRUE 0 #define TRIGGER_FUNCTIONAL_FALSE 1 /* shorthand macro for calling in_maintenance_without_data_collection() */ #define DCin_maintenance_without_data_collection(dc_host, dc_item) \ in_maintenance_without_data_collection(dc_host->maintenance_status, \ dc_host->maintenance_type, dc_item->type) /* validator function optionally used to validate macro values when expanding user macros */ /****************************************************************************** * * * Function: zbx_value_validator_func_t * * * * Purpose: validate macro value when expanding user macros * * * * Parameters: macro - [IN] the user macro * * value - [IN] the macro value * * error - [OUT] the error message * * * * Return value: SUCCEED - the value is valid * * FAIL - otherwise * * * ******************************************************************************/ typedef int (*zbx_value_validator_func_t)(const char *macro, const char *value, char **error); static ZBX_DC_CONFIG *config = NULL; static ZBX_MUTEX config_lock = ZBX_MUTEX_NULL; static zbx_mem_info_t *config_mem; extern unsigned char program_type; extern int CONFIG_TIMER_FORKS; ZBX_MEM_FUNC_IMPL(__config, config_mem) static void dc_get_hostids_by_functionids(zbx_vector_uint64_t *functionids, zbx_vector_uint64_t *hostids); static char *dc_cache_expanded_expression(const char *expression, const char **expression_ex, char **error); /****************************************************************************** * * * Function: is_item_processed_by_server * * * * Parameters: type - [IN] item type [ITEM_TYPE_* flag] * * key - [IN] item key * * * * Return value: SUCCEED when an item should be processed by server * * FAIL otherwise * * * * Comments: list of the items, always processed by server * * ,------------------+--------------------------------------, * * | type | key | * * +------------------+--------------------------------------+ * * | Zabbix internal | zabbix[host,,items] | * * | Zabbix internal | zabbix[host,,items_unsupported] | * * | Zabbix internal | zabbix[host,,maintenance] | * * | Zabbix internal | zabbix[proxy,<proxyname>,lastaccess] | * * | Zabbix aggregate | * | * * | Calculated | * | * * '------------------+--------------------------------------' * * * ******************************************************************************/ int is_item_processed_by_server(unsigned char type, const char *key) { int ret = FAIL; switch (type) { case ITEM_TYPE_AGGREGATE: case ITEM_TYPE_CALCULATED: ret = SUCCEED; break; case ITEM_TYPE_INTERNAL: if (0 == strncmp(key, "zabbix[", 7)) { AGENT_REQUEST request; char *arg1, *arg2, *arg3; init_request(&request); if (SUCCEED != parse_item_key(key, &request) || 3 != request.nparam) goto clean; arg1 = get_rparam(&request, 0); if (0 == strcmp(arg1, "host")) { arg2 = get_rparam(&request, 1); arg3 = get_rparam(&request, 2); if ((0 != strcmp(arg3, "maintenance") && 0 != strcmp(arg3, "items") && 0 != strcmp(arg3, "items_unsupported")) || '\0' != *arg2) { goto clean; } } else if (0 == strcmp(arg1, "proxy")) { arg3 = get_rparam(&request, 2); if (0 != strcmp(arg3, "lastaccess")) goto clean; } else goto clean; ret = SUCCEED; clean: free_request(&request); } break; } return ret; } static unsigned char poller_by_item(zbx_uint64_t proxy_hostid, unsigned char type, const char *key) { if (0 != proxy_hostid && SUCCEED != is_item_processed_by_server(type, key)) return ZBX_NO_POLLER; switch (type) { case ITEM_TYPE_SIMPLE: if (SUCCEED == cmp_key_id(key, SERVER_ICMPPING_KEY) || SUCCEED == cmp_key_id(key, SERVER_ICMPPINGSEC_KEY) || SUCCEED == cmp_key_id(key, SERVER_ICMPPINGLOSS_KEY)) { if (0 == CONFIG_PINGER_FORKS) break; return ZBX_POLLER_TYPE_PINGER; } /* break; is not missing here */ case ITEM_TYPE_ZABBIX: case ITEM_TYPE_SNMPv1: case ITEM_TYPE_SNMPv2c: case ITEM_TYPE_SNMPv3: case ITEM_TYPE_INTERNAL: case ITEM_TYPE_AGGREGATE: case ITEM_TYPE_EXTERNAL: case ITEM_TYPE_DB_MONITOR: case ITEM_TYPE_SSH: case ITEM_TYPE_TELNET: case ITEM_TYPE_CALCULATED: if (0 == CONFIG_POLLER_FORKS) break; return ZBX_POLLER_TYPE_NORMAL; case ITEM_TYPE_IPMI: if (0 == CONFIG_IPMIPOLLER_FORKS) break; return ZBX_POLLER_TYPE_IPMI; case ITEM_TYPE_JMX: if (0 == CONFIG_JAVAPOLLER_FORKS) break; return ZBX_POLLER_TYPE_JAVA; } return ZBX_NO_POLLER; } /****************************************************************************** *