diff options
| author | Artjoms Rimdjonoks <artjoms.rimdjonoks@zabbix.com> | 2022-01-05 00:50:10 +0300 |
|---|---|---|
| committer | Artjoms Rimdjonoks <artjoms.rimdjonoks@zabbix.com> | 2022-01-05 00:50:10 +0300 |
| commit | 9d822c6f5ead1480d71f3e4d8b31fa2a9391020b (patch) | |
| tree | 6ed3e6693afcd38fc32da689f0168d87cf709d4b /src/zabbix_server/preprocessor | |
| parent | 729a48cff3694ccaa49ef292adb5913894de8c9a (diff) | |
.......... [DEV-2051] removed functions names from the function comments
Diffstat (limited to 'src/zabbix_server/preprocessor')
| -rw-r--r-- | src/zabbix_server/preprocessor/item_preproc.c | 86 | ||||
| -rw-r--r-- | src/zabbix_server/preprocessor/preproc_cache.c | 8 | ||||
| -rw-r--r-- | src/zabbix_server/preprocessor/preproc_manager.c | 66 | ||||
| -rw-r--r-- | src/zabbix_server/preprocessor/preproc_worker.c | 20 | ||||
| -rw-r--r-- | src/zabbix_server/preprocessor/preprocessing.c | 96 |
5 files changed, 0 insertions, 276 deletions
diff --git a/src/zabbix_server/preprocessor/item_preproc.c b/src/zabbix_server/preprocessor/item_preproc.c index 3d2c5222402..7feae968916 100644 --- a/src/zabbix_server/preprocessor/item_preproc.c +++ b/src/zabbix_server/preprocessor/item_preproc.c @@ -36,8 +36,6 @@ extern zbx_es_t es_engine; /****************************************************************************** * * - * Function: item_preproc_numeric_type_hint * - * * * Purpose: returns numeric type hint based on item value type * * * * Parameters: value_type - [IN] the item value type * @@ -60,8 +58,6 @@ static int item_preproc_numeric_type_hint(unsigned char value_type) /****************************************************************************** * * - * Function: item_preproc_convert_value * - * * * Purpose: convert variant value to the requested type * * * * Parameters: value - [IN/OUT] the value to convert * @@ -85,8 +81,6 @@ static int item_preproc_convert_value(zbx_variant_t *value, unsigned char type, /****************************************************************************** * * - * Function: zbx_item_preproc_convert_value_to_numeric * - * * * Purpose: converts variant value to numeric * * * * Parameters: value_num - [OUT] the converted value * @@ -131,8 +125,6 @@ int zbx_item_preproc_convert_value_to_numeric(zbx_variant_t *value_num, const zb /****************************************************************************** * * - * Function: item_preproc_multiplier_variant * - * * * Purpose: execute custom multiplier preprocessing operation on variant * * value type * * * @@ -180,8 +172,6 @@ static int item_preproc_multiplier_variant(unsigned char value_type, zbx_variant /****************************************************************************** * * - * Function: item_preproc_validate_notsupport * - * * * Purpose: executes during notsupported item preprocessing * * * * Return value: FAIL - for further error handling * @@ -195,8 +185,6 @@ static int item_preproc_validate_notsupport(char **errmsg) /****************************************************************************** * * - * Function: item_preproc_multiplier * - * * * Purpose: execute custom multiplier preprocessing operation * * * * Parameters: value_type - [IN] the item type * @@ -232,8 +220,6 @@ static int item_preproc_multiplier(unsigned char value_type, zbx_variant_t *valu /****************************************************************************** * * - * Function: item_preproc_delta_float * - * * * Purpose: execute delta type preprocessing operation * * * * Parameters: value - [IN/OUT] the value to process * @@ -272,8 +258,6 @@ static int item_preproc_delta_float(zbx_variant_t *value, const zbx_timespec_t * /****************************************************************************** * * - * Function: item_preproc_delta_uint64 * - * * * Purpose: execute delta type preprocessing operation * * * * Parameters: value - [IN/OUT] the value to process * @@ -312,8 +296,6 @@ static int item_preproc_delta_uint64(zbx_variant_t *value, const zbx_timespec_t /****************************************************************************** * * - * Function: item_preproc_delta * - * * * Purpose: execute delta type preprocessing operation * * * * Parameters: value_type - [IN] the item value type * @@ -371,8 +353,6 @@ static int item_preproc_delta(unsigned char value_type, zbx_variant_t *value, co /****************************************************************************** * * - * Function: item_preproc_delta_value * - * * * Purpose: execute delta (simple change) preprocessing operation * * * * Parameters: value_type - [IN] the item value type * @@ -407,8 +387,6 @@ static int item_preproc_delta_value(unsigned char value_type, zbx_variant_t *val /****************************************************************************** * * - * Function: item_preproc_delta_speed * - * * * Purpose: execute delta (speed per second) preprocessing operation * * * * Parameters: value_type - [IN] the item value type * @@ -443,8 +421,6 @@ static int item_preproc_delta_speed(unsigned char value_type, zbx_variant_t *val /****************************************************************************** * * - * Function: unescape_param * - * * * Purpose: copy first n chars from in to out, unescape escaped characters * * during copying * * * @@ -496,8 +472,6 @@ static void unescape_param(int op_type, const char *in, int len, char *out) /****************************************************************************** * * - * Function: item_preproc_trim * - * * * Purpose: execute trim type preprocessing operation * * * * Parameters: value - [IN/OUT] the value to process * @@ -529,8 +503,6 @@ static int item_preproc_trim(zbx_variant_t *value, unsigned char op_type, const /****************************************************************************** * * - * Function: item_preproc_rtrim * - * * * Purpose: execute right trim preprocessing operation * * * * Parameters: value - [IN/OUT] the value to process * @@ -560,8 +532,6 @@ static int item_preproc_rtrim(zbx_variant_t *value, const char *params, char **e /****************************************************************************** * * - * Function: item_preproc_ltrim * - * * * Purpose: execute left trim preprocessing operation * * * * Parameters: value - [IN/OUT] the value to process * @@ -591,8 +561,6 @@ static int item_preproc_ltrim(zbx_variant_t *value, const char *params, char **e /****************************************************************************** * * - * Function: item_preproc_lrtrim * - * * * Purpose: execute left and right trim preprocessing operation * * * * Parameters: value - [IN/OUT] the value to process * @@ -622,8 +590,6 @@ static int item_preproc_lrtrim(zbx_variant_t *value, const char *params, char ** /****************************************************************************** * * - * Function: item_preproc_2dec * - * * * Purpose: execute decimal value conversion operation * * * * Parameters: value - [IN/OUT] the value to convert * @@ -687,8 +653,6 @@ static int item_preproc_2dec(zbx_variant_t *value, unsigned char op_type, char * /****************************************************************************** * * - * Function: item_preproc_bool2dec * - * * * Purpose: execute boolean to decimal value conversion operation * * * * Parameters: value - [IN/OUT] the value to convert * @@ -715,8 +679,6 @@ static int item_preproc_bool2dec(zbx_variant_t *value, char **errmsg) /****************************************************************************** * * - * Function: item_preproc_oct2dec * - * * * Purpose: execute octal to decimal value conversion operation * * * * Parameters: value - [IN/OUT] the value to convert * @@ -743,8 +705,6 @@ static int item_preproc_oct2dec(zbx_variant_t *value, char **errmsg) /****************************************************************************** * * - * Function: item_preproc_hex2dec * - * * * Purpose: execute hexadecimal to decimal value conversion operation * * * * Parameters: value - [IN/OUT] the value to convert * @@ -771,8 +731,6 @@ static int item_preproc_hex2dec(zbx_variant_t *value, char **errmsg) /****************************************************************************** * * - * Function: item_preproc_regsub_op * - * * * Purpose: execute regular expression substitution operation * * * * Parameters: value - [IN/OUT] the value to process * @@ -827,8 +785,6 @@ static int item_preproc_regsub_op(zbx_variant_t *value, const char *params, char /****************************************************************************** * * - * Function: item_preproc_regsub * - * * * Purpose: execute regular expression substitution operation * * * * Parameters: value - [IN/OUT] the value to process * @@ -862,8 +818,6 @@ static int item_preproc_regsub(zbx_variant_t *value, const char *params, char ** /****************************************************************************** * * - * Function: item_preproc_jsonpath_op * - * * * Purpose: execute jsonpath query * * * * Parameters: value - [IN/OUT] the value to process * @@ -902,8 +856,6 @@ static int item_preproc_jsonpath_op(zbx_variant_t *value, const char *params, ch /****************************************************************************** * * - * Function: item_preproc_jsonpath * - * * * Purpose: execute jsonpath query * * * * Parameters: value - [IN/OUT] the value to process * @@ -930,8 +882,6 @@ static int item_preproc_jsonpath(zbx_variant_t *value, const char *params, char /****************************************************************************** * * - * Function: item_preproc_xpath * - * * * Purpose: execute xpath query * * * * Parameters: value - [IN/OUT] the value to process * @@ -960,8 +910,6 @@ static int item_preproc_xpath(zbx_variant_t *value, const char *params, char **e /****************************************************************************** * * - * Function: item_preproc_validate_range * - * * * Purpose: validates value to be within the specified range * * Parameters: value_type - [IN] the item type * * value - [IN/OUT] the value to process * @@ -1038,8 +986,6 @@ out: /****************************************************************************** * * - * Function: item_preproc_validate_regex * - * * * Purpose: validates value to match regular expression * * Parameters: value_type - [IN] the item type * * value - [IN/OUT] the value to process * @@ -1095,8 +1041,6 @@ out: /****************************************************************************** * * - * Function: item_preproc_validate_not_regex * - * * * Purpose: validates value to not match regular expression * * Parameters: value_type - [IN] the item type * * value - [IN/OUT] the value to process * @@ -1154,8 +1098,6 @@ out: /****************************************************************************** * * - * Function: item_preproc_get_error_from_json * - * * * Purpose: checks for presence of error field in json data * * * * Parameters: value - [IN/OUT] the value to process * @@ -1210,8 +1152,6 @@ out: /****************************************************************************** * * - * Function: item_preproc_get_error_from_xml * - * * * Purpose: checks for presence of error field in XML data * * * * Parameters: value - [IN/OUT] the value to process * @@ -1316,8 +1256,6 @@ out: /****************************************************************************** * * - * Function: item_preproc_get_error_from_regex * - * * * Purpose: checks for presence of error pattern matching regular expression * * * * Parameters: value - [IN/OUT] the value to process * @@ -1380,8 +1318,6 @@ out: /****************************************************************************** * * - * Function: item_preproc_throttle_value * - * * * Purpose: throttles value by suppressing identical values * * * * Parameters: value - [IN/OUT] the value to process * @@ -1414,8 +1350,6 @@ static int item_preproc_throttle_value(zbx_variant_t *value, const zbx_timespec_ /****************************************************************************** * * - * Function: item_preproc_throttle_timed_value * - * * * Purpose: throttles value by suppressing identical values * * * * Parameters: value - [IN/OUT] the value to process * @@ -1459,8 +1393,6 @@ static int item_preproc_throttle_timed_value(zbx_variant_t *value, const zbx_tim /****************************************************************************** * * - * Function: item_preproc_script * - * * * Purpose: executes script passed with params * * * * Parameters: value - [IN/OUT] the value to process * @@ -1523,8 +1455,6 @@ fail: /****************************************************************************** * * - * Function: item_preproc_prometheus_pattern * - * * * Purpose: parse Prometheus format metrics * * * * Parameters: value - [IN/OUT] the value to process * @@ -1604,8 +1534,6 @@ out: /****************************************************************************** * * - * Function: item_preproc_prometheus_to_json * - * * * Purpose: convert Prometheus format metrics to JSON format * * * * Parameters: value - [IN/OUT] the value to process * @@ -1638,8 +1566,6 @@ static int item_preproc_prometheus_to_json(zbx_variant_t *value, const char *par /****************************************************************************** * * - * Function: item_preproc_csv_to_json_add_field * - * * * Purpose: convert CSV format metrics to JSON format * * * * Parameters: json - [IN/OUT] json object * @@ -1714,8 +1640,6 @@ static int item_preproc_csv_to_json_add_field(struct zbx_json *json, char ***nam /****************************************************************************** * * - * Function: item_preproc_csv_to_json * - * * * Purpose: convert CSV format metrics to JSON format * * * * Parameters: value - [IN/OUT] the value to process * @@ -1972,8 +1896,6 @@ out: /****************************************************************************** * * - * Function: item_preproc_xml_to_json * - * * * Purpose: convert XML format value to JSON format * * * * Parameters: value - [IN/OUT] the value to process * @@ -2001,8 +1923,6 @@ static int item_preproc_xml_to_json(zbx_variant_t *value, char **errmsg) /****************************************************************************** * * - * Function: item_preproc_str_replace * - * * * Purpose: replace substrings in string * * * * Parameters: value - [IN/OUT] the value to process * @@ -2053,8 +1973,6 @@ static int item_preproc_str_replace(zbx_variant_t *value, const char *params, ch /****************************************************************************** * * - * Function: zbx_item_preproc * - * * * Purpose: execute preprocessing operation * * * * Parameters: cache - [IN/OUT] the preprocessing cache * @@ -2174,8 +2092,6 @@ int zbx_item_preproc(zbx_preproc_cache_t *cache, unsigned char value_type, zbx_v /****************************************************************************** * * - * Function: zbx_item_preproc_handle_error * - * * * Purpose: apply 'on fail' preprocessing error handler * * * * Parameters: value - [IN/OUT] the value * @@ -2212,8 +2128,6 @@ int zbx_item_preproc_handle_error(zbx_variant_t *value, const zbx_preproc_op_t * /****************************************************************************** * * - * Function: zbx_item_preproc_test * - * * * Purpose: test preprocessing steps * * * * Parameters: value_type - [IN] the item value type * diff --git a/src/zabbix_server/preprocessor/preproc_cache.c b/src/zabbix_server/preprocessor/preproc_cache.c index 347d5198b6f..674da06cc56 100644 --- a/src/zabbix_server/preprocessor/preproc_cache.c +++ b/src/zabbix_server/preprocessor/preproc_cache.c @@ -26,8 +26,6 @@ ZBX_VECTOR_IMPL(ppcache, zbx_preproc_cache_ref_t); /****************************************************************************** * * - * Function: zbx_preproc_cache_get * - * * * Purpose: get cache by preprocessing step type * * * * Parameters: cache - [IN] the preprocessing cache * @@ -52,8 +50,6 @@ void *zbx_preproc_cache_get(zbx_preproc_cache_t *cache, unsigned char type) /****************************************************************************** * * - * Function: zbx_preproc_cache_put * - * * * Purpose: put preprocessing step cache into preprocessing cache * * * * Parameters: cache - [IN] the preprocessing cache * @@ -76,8 +72,6 @@ void zbx_preproc_cache_put(zbx_preproc_cache_t *cache, unsigned char type, void /****************************************************************************** * * - * Function: zbx_preproc_cache_init * - * * * Purpose: initialize preprocessing cache * * * ******************************************************************************/ @@ -88,8 +82,6 @@ void zbx_preproc_cache_init(zbx_preproc_cache_t *cache) /****************************************************************************** * * - * Function: zbx_preproc_cache_clear * - * * * Purpose: free resources allocated by preprocessing cache * * * ******************************************************************************/ diff --git a/src/zabbix_server/preprocessor/preproc_manager.c b/src/zabbix_server/preprocessor/preproc_manager.c index 250336d23e8..849a6a1fd4b 100644 --- a/src/zabbix_server/preprocessor/preproc_manager.c +++ b/src/zabbix_server/preprocessor/preproc_manager.c @@ -184,8 +184,6 @@ static void request_free_steps(zbx_preprocessing_request_t *request) /****************************************************************************** * * - * Function: preprocessor_sync_configuration * - * * * Purpose: synchronize preprocessing manager with configuration cache data * * * * Parameters: manager - [IN] the manager to be synchronized * @@ -258,8 +256,6 @@ static void preprocessing_ar_to_variant(AGENT_RESULT *ar, zbx_variant_t *value) /****************************************************************************** * * - * Function: preprocessor_create_task * - * * * Purpose: create preprocessing task for request * * * * Parameters: manager - [IN] preprocessing manager * @@ -293,8 +289,6 @@ static zbx_uint32_t preprocessor_create_task(zbx_preprocessing_manager_t *manage /****************************************************************************** * * - * Function: preprocessor_set_request_state_done * - * * * Purpose: set request state to done and handle linked items * * * * Parameters: manager - [IN] preprocessing manager * @@ -338,8 +332,6 @@ static void preprocessor_set_request_state_done(zbx_preprocessing_manager_t *man /****************************************************************************** * * - * Function: preprocessor_create_dep_message * - * * * Purpose: create message(s) for dependent item bulk preprocessing * * * * Parameters: manager - [IN] preprocessing manager * @@ -406,8 +398,6 @@ static int preprocessor_create_dep_message(zbx_preprocessing_manager_t *manager, /****************************************************************************** * * - * Function: preprocessor_dep_request_next_message * - * * * Purpose: returns next dependent item preprocessing message * * * * Parameters: request - [IN] the dependent item preprocessing request * @@ -432,8 +422,6 @@ static int preprocessor_dep_request_next_message(zbx_preprocessing_dep_request_t /****************************************************************************** * * - * Function: preprocessor_get_next_task * - * * * Purpose: gets next task to be sent to worker * * * * Parameters: manager - [IN] preprocessing manager * @@ -525,8 +513,6 @@ out: /****************************************************************************** * * - * Function: preprocessor_get_worker_by_client * - * * * Purpose: get worker data by IPC client * * * * Parameters: manager - [IN] preprocessing manager * @@ -561,8 +547,6 @@ static zbx_preprocessing_worker_t *preprocessor_get_worker_by_client(zbx_preproc /****************************************************************************** * * - * Function: preprocessor_get_free_worker * - * * * Purpose: get worker without active preprocessing task * * * * Parameters: manager - [IN] preprocessing manager * @@ -585,8 +569,6 @@ static zbx_preprocessing_worker_t *preprocessor_get_free_worker(zbx_preprocessin /****************************************************************************** * * - * Function: preprocessor_assign_tasks * - * * * Purpose: assign available queued preprocessing tasks to free workers * * * * Parameters: manager - [IN] preprocessing manager * @@ -618,8 +600,6 @@ static void preprocessor_assign_tasks(zbx_preprocessing_manager_t *manager) /****************************************************************************** * * - * Function: preproc_item_value_clear * - * * * Purpose: frees resources allocated by preprocessor item value * * * * Parameters: value - [IN] value to be freed * @@ -639,8 +619,6 @@ static void preproc_item_value_clear(zbx_preproc_item_value_t *value) /****************************************************************************** * * - * Function: preprocessor_free_request * - * * * Purpose: free preprocessing request * * * * Parameters: base - [IN] request data to be freed * @@ -674,8 +652,6 @@ static void preprocessor_free_request(zbx_preprocessing_request_base_t *base) /****************************************************************************** * * - * Function: preprocessor_free_direct_request * - * * * Purpose: free preprocessing direct request * * * * Parameters: direct_request - [IN] forward data to be freed * @@ -690,8 +666,6 @@ static void preprocessor_free_direct_request(zbx_preprocessing_direct_request_t /****************************************************************************** * * - * Function: preprocessor_flush_value * - * * * Purpose: add new value to the local history cache or send to LLD manager * * * * Parameters: value - [IN] value to be added or sent * @@ -742,8 +716,6 @@ static void preprocessor_flush_dep_results(zbx_preprocessing_manager_t *manager, /****************************************************************************** * * - * Function: preprocessing_flush_queue * - * * * Purpose: add all sequential processed values from beginning of the queue * * to the local history cache * * * @@ -819,8 +791,6 @@ static void preproc_link_nodes(zbx_preprocessing_manager_t *manager, zbx_uint64_ /****************************************************************************** * * - * Function: preprocessor_link_items * - * * * Purpose: create relation between item values within value queue * * * * Parameters: manager - [IN] preprocessing manager * @@ -858,8 +828,6 @@ static void preprocessor_link_items(zbx_preprocessing_manager_t *manager, zbx_li /****************************************************************************** * * - * Function: preprocessor_enqueue_dependent_value * - * * * Purpose: enqueue dependent items (if any) by preproc value * * * * Parameters: manager - [IN] preprocessing manager * @@ -878,8 +846,6 @@ static void preprocessor_enqueue_dependent_value(zbx_preprocessing_manager_t *ma /****************************************************************************** * * - * Function: preprocessor_enqueue * - * * * Purpose: enqueue preprocessing request * * * * Parameters: manage - [IN] preprocessing manager * @@ -1008,8 +974,6 @@ out: /****************************************************************************** * * - * Function: preprocessor_enqueue_dependent * - * * * Purpose: enqueue dependent items (if any) * * * * Parameters: manager - [IN] preprocessing manager * @@ -1072,8 +1036,6 @@ static void preprocessor_enqueue_dependent(zbx_preprocessing_manager_t *manager, /****************************************************************************** * * - * Function: preprocessor_add_request * - * * * Purpose: handle new preprocessing request * * * * Parameters: manager - [IN] preprocessing manager * @@ -1103,8 +1065,6 @@ static void preprocessor_add_request(zbx_preprocessing_manager_t *manager, zbx_i /****************************************************************************** * * - * Function: preprocessor_add_test_request * - * * * Purpose: handle new preprocessing test request * * * * Parameters: manager - [IN] preprocessing manager * @@ -1132,8 +1092,6 @@ static void preprocessor_add_test_request(zbx_preprocessing_manager_t *manager, /****************************************************************************** * * - * Function: preprocessor_set_variant_result * - * * * Purpose: get result data from variant and error message * * * * Parameters: request - [IN/OUT] preprocessing request * @@ -1248,8 +1206,6 @@ out: /****************************************************************************** * * - * Function: preprocessor_add_result * - * * * Purpose: handle preprocessing result * * * * Parameters: manager - [IN] preprocessing manager * @@ -1327,8 +1283,6 @@ static void preprocessor_add_result(zbx_preprocessing_manager_t *manager, zbx_ip /****************************************************************************** * * - * Function: preprocessor_update_history * - * * * Purpose: handle preprocessing result * * * * Parameters: manager - [IN] preprocessing manager * @@ -1403,8 +1357,6 @@ static void preprocessor_finalize_dep_results(zbx_preprocessing_manager_t *manag /****************************************************************************** * * - * Function: preprocessor_add_dep_result * - * * * Purpose: handle dependent item batch preprocessing result * * * * Parameters: manager - [IN] preprocessing manager * @@ -1435,8 +1387,6 @@ static void preprocessor_process_dep_result(zbx_preprocessing_manager_t *manager /****************************************************************************** * * - * Function: preprocessor_add_dep_result * - * * * Purpose: handle next dependent item batch preprocessing result * * * * Parameters: manager - [IN] preprocessing manager * @@ -1467,8 +1417,6 @@ static void preprocessor_process_dep_result_cont(zbx_preprocessing_manager_t *ma /****************************************************************************** * * - * Function: preprocessor_next_dep_request * - * * * Purpose: handle dependent item batch preprocessing result * * * * Parameters: manager - [IN] preprocessing manager * @@ -1500,8 +1448,6 @@ static void preprocessor_next_dep_request(zbx_preprocessing_manager_t *manager, /****************************************************************************** * * - * Function: preprocessor_flush_test_result * - * * * Purpose: handle preprocessing result * * * * Parameters: manager - [IN] preprocessing manager * @@ -1648,8 +1594,6 @@ static void preprocessor_get_items_totals(zbx_preprocessing_manager_t *manager, /****************************************************************************** * * - * Function: preprocessor_get_diag_stats * - * * * Purpose: return diagnostic statistics * * * * Parameters: manager - [IN] preprocessing manager * @@ -1675,8 +1619,6 @@ static void preprocessor_get_diag_stats(zbx_preprocessing_manager_t *manager, zb /****************************************************************************** * * - * Function: preproc_sort_item_by_values_desc * - * * * Purpose: compare item statistics by value * * * ******************************************************************************/ @@ -1748,8 +1690,6 @@ static void preprocessor_get_items_view(zbx_preprocessing_manager_t *manager, zb /****************************************************************************** * * - * Function: preprocessor_get_top_items * - * * * Purpose: return diagnostic top view * * * * Parameters: manager - [IN] preprocessing manager * @@ -1856,8 +1796,6 @@ static int preproc_item_link_compare(const void *d1, const void *d2) /****************************************************************************** * * - * Function: preprocessor_init_manager * - * * * Purpose: initializes preprocessing manager * * * * Parameters: manager - [IN] the manager to initialize * @@ -1885,8 +1823,6 @@ static void preprocessor_init_manager(zbx_preprocessing_manager_t *manager) /****************************************************************************** * * - * Function: preprocessor_register_worker * - * * * Purpose: registers preprocessing worker * * * * Parameters: manager - [IN] the manager * @@ -1928,8 +1864,6 @@ static void preprocessor_register_worker(zbx_preprocessing_manager_t *manager, z /****************************************************************************** * * - * Function: preprocessor_destroy_manager * - * * * Purpose: destroy preprocessing manager * * * * Parameters: manager - [IN] the manager to destroy * diff --git a/src/zabbix_server/preprocessor/preproc_worker.c b/src/zabbix_server/preprocessor/preproc_worker.c index e5450f415b4..a015b6f9b8b 100644 --- a/src/zabbix_server/preprocessor/preproc_worker.c +++ b/src/zabbix_server/preprocessor/preproc_worker.c @@ -51,8 +51,6 @@ zbx_es_t es_engine; /****************************************************************************** * * - * Function: worker_format_value * - * * * Purpose: formats value in text format * * * * Parameters: value - [IN] the value to format * @@ -93,8 +91,6 @@ static void worker_format_value(const zbx_variant_t *value, char **value_str) /****************************************************************************** * * - * Function: worker_format_result * - * * * Purpose: formats one preprocessing step result * * * * Parameters: step - [IN] the preprocessing step number * @@ -124,8 +120,6 @@ static void worker_format_result(int step, const zbx_preproc_result_t *result, c /****************************************************************************** * * - * Function: worker_format_error * - * * * Purpose: formats preprocessing error message * * * * Parameters: value - [IN] the input value * @@ -203,8 +197,6 @@ static void worker_format_error(const zbx_variant_t *value, zbx_preproc_result_t /****************************************************************************** * * - * Function: worker_item_preproc_execute * - * * * Purpose: execute preprocessing steps * * * * Parameters: cache - [IN/OUT] the preprocessing cache * @@ -296,8 +288,6 @@ static int worker_item_preproc_execute(zbx_preproc_cache_t *cache, unsigned char /****************************************************************************** * * - * Function: worker_preprocess_value * - * * * Purpose: handle item value preprocessing task * * * * Parameters: socket - [IN] IPC socket * @@ -379,8 +369,6 @@ static void worker_preprocess_value(zbx_ipc_socket_t *socket, zbx_ipc_message_t /****************************************************************************** * * - * Function: worker_test_value * - * * * Purpose: handle item value test preprocessing task * * * * Parameters: socket - [IN] IPC socket * @@ -445,8 +433,6 @@ static void worker_test_value(zbx_ipc_socket_t *socket, zbx_ipc_message_t *messa /****************************************************************************** * * - * Function: worker_dep_request_clear * - * * ******************************************************************************/ static void worker_dep_request_clear(zbx_preproc_dep_request_t *request) { @@ -457,8 +443,6 @@ static void worker_dep_request_clear(zbx_preproc_dep_request_t *request) /****************************************************************************** * * - * Function: worker_preprocess_dep_items * - * * * Purpose: preprocess dependent items * * * * Parameters: socket - [IN] IPC socket * @@ -562,8 +546,6 @@ out: /****************************************************************************** * * - * Function: worker_process_dep_request * - * * * Purpose: handle item value preprocessing request * * * * Parameters: socket - [IN] IPC socket * @@ -582,8 +564,6 @@ static void worker_process_dep_request(zbx_ipc_socket_t *socket, zbx_ipc_message /****************************************************************************** * * - * Function: worker_process_dep_request_cont * - * * * Purpose: handle following item value preprocessing request * * * * Parameters: socket - [IN] IPC socket * diff --git a/src/zabbix_server/preprocessor/preprocessing.c b/src/zabbix_server/preprocessor/preprocessing.c index b938432272b..02d661e8bb8 100644 --- a/src/zabbix_server/preprocessor/preprocessing.c +++ b/src/zabbix_server/preprocessor/preprocessing.c @@ -106,8 +106,6 @@ static int message_pack_fields(zbx_ipc_message_t *message, const zbx_packed_fiel /****************************************************************************** * * - * Function: message_pack_data * - * * * Purpose: helper for data packing based on defined format * * * * Parameters: message - [OUT] IPC message, can be NULL for buffer size * @@ -137,8 +135,6 @@ static zbx_uint32_t message_pack_data(zbx_ipc_message_t *message, zbx_packed_fie /****************************************************************************** * * - * Function: preprocessor_pack_value * - * * * Purpose: pack item value data into a single buffer that can be used in IPC * * * * Parameters: message - [OUT] IPC message * @@ -200,8 +196,6 @@ static zbx_uint32_t preprocessor_pack_value(zbx_ipc_message_t *message, zbx_prep /****************************************************************************** * * - * Function: preprocessor_pack_variant * - * * * Purpose: packs variant value for serialization * * * * Parameters: fields - [OUT] the packed fields * @@ -243,8 +237,6 @@ static int preprocessor_pack_variant(zbx_packed_field_t *fields, const zbx_varia /****************************************************************************** * * - * Function: preprocessor_pack_history * - * * * Purpose: packs preprocessing history for serialization * * * * Parameters: fields - [OUT] the packed fields * @@ -277,8 +269,6 @@ static int preprocessor_pack_history(zbx_packed_field_t *fields, const zbx_vecto /****************************************************************************** * * - * Function: preprocessor_pack_step * - * * * Purpose: packs preprocessing step for serialization * * * * Parameters: fields - [OUT] the packed fields * @@ -303,8 +293,6 @@ static int preprocessor_pack_step(zbx_packed_field_t *fields, const zbx_preproc_ /****************************************************************************** * * - * Function: preprocessor_pack_steps * - * * * Purpose: packs preprocessing steps for serialization * * * * Parameters: fields - [OUT] the packed fields * @@ -330,8 +318,6 @@ static int preprocessor_pack_steps(zbx_packed_field_t *fields, const zbx_preproc /****************************************************************************** * * - * Function: preprocesser_unpack_variant * - * * * Purpose: unpacks serialized variant value * * * * Parameters: data - [IN] the serialized data * @@ -371,8 +357,6 @@ static int preprocesser_unpack_variant(const unsigned char *data, zbx_variant_t /****************************************************************************** * * - * Function: preprocesser_unpack_history * - * * * Purpose: unpacks serialized preprocessing history * * * * Parameters: data - [IN] the serialized data * @@ -412,8 +396,6 @@ static int preprocesser_unpack_history(const unsigned char *data, zbx_vector_ptr /****************************************************************************** * * - * Function: preprocessor_unpack_step * - * * * Purpose: unpacks serialized preprocessing step * * * * Parameters: data - [IN] the serialized data * @@ -437,8 +419,6 @@ static int preprocessor_unpack_step(const unsigned char *data, zbx_preproc_op_t /****************************************************************************** * * - * Function: preprocessor_unpack_steps * - * * * Purpose: unpacks serialized preprocessing steps * * * * Parameters: data - [IN] the serialized data * @@ -468,8 +448,6 @@ static int preprocessor_unpack_steps(const unsigned char *data, zbx_preproc_op_t /****************************************************************************** * * - * Function: zbx_preprocessor_pack_task * - * * * Purpose: pack preprocessing task data into a single buffer that can be * * used in IPC * * * @@ -528,8 +506,6 @@ zbx_uint32_t zbx_preprocessor_pack_task(unsigned char **data, zbx_uint64_t itemi /****************************************************************************** * * - * Function: preprocessor_append_packed_message * - * * * Purpose: pack fields into serialized message * * * * Parameters: fields - [IN] the fields to pack * @@ -567,8 +543,6 @@ static int preprocessor_append_packed_message(const zbx_packed_field_t *fields, /****************************************************************************** * * - * Function: zbx_preprocessor_pack_dep_request * - * * * Purpose: pack dependent item preprocessing fields into messages for * * sending to worker * * * @@ -661,8 +635,6 @@ out: /****************************************************************************** * * - * Function: zbx_preprocessor_pack_result * - * * * Purpose: pack preprocessing result data into a single buffer that can be * * used in IPC * * * @@ -704,8 +676,6 @@ zbx_uint32_t zbx_preprocessor_pack_result(unsigned char **data, zbx_variant_t *v /****************************************************************************** * * - * Function: zbx_preprocessor_free_dep_results * - * * * Purpose: free dependent item preprocessing response * * * * Parameters: results - [OUT] the preprocessing results * @@ -835,8 +805,6 @@ void zbx_preprocessor_result_append(zbx_preproc_result_buffer_t *buf, zbx_uint64 /****************************************************************************** * * - * Function: zbx_preprocessor_pack_test_result * - * * * Purpose: pack preprocessing result data into a single buffer that can be * * used in IPC * * * @@ -888,8 +856,6 @@ zbx_uint32_t zbx_preprocessor_pack_test_result(unsigned char **data, const zbx_p /****************************************************************************** * * - * Function: zbx_preprocessor_pack_diag_stats * - * * * Purpose: pack diagnostic statistics data into a single buffer that can be * * used in IPC * * Parameters: data - [OUT] memory buffer for packed data * @@ -933,8 +899,6 @@ zbx_uint32_t zbx_preprocessor_pack_diag_stats(unsigned char **data, int total, i /****************************************************************************** * * - * Function: zbx_preprocessor_pack_top_request * - * * * Purpose: pack top request data into a single buffer that can be used in IPC* * * * Parameters: data - [OUT] memory buffer for packed data * @@ -955,8 +919,6 @@ zbx_uint32_t zbx_preprocessor_pack_top_items_request(unsigned char **data, int l /****************************************************************************** * * - * Function: zbx_preprocessor_pack_top_result * - * * * Purpose: pack top result data into a single buffer that can be used in IPC * * * * Parameters: data - [OUT] memory buffer for packed data * @@ -997,8 +959,6 @@ zbx_uint32_t zbx_preprocessor_pack_top_items_result(unsigned char **data, zbx_pr /****************************************************************************** * * - * Function: zbx_preprocessor_unpack_value * - * * * Purpose: unpack item value data from IPC data buffer * * * * Parameters: value - [OUT] unpacked item value * @@ -1069,8 +1029,6 @@ zbx_uint32_t zbx_preprocessor_unpack_value(zbx_preproc_item_value_t *value, unsi /****************************************************************************** * * - * Function: zbx_preprocessor_unpack_task * - * * * Purpose: unpack preprocessing task data from IPC data buffer * * * * Parameters: itemid - [OUT] itemid * @@ -1112,8 +1070,6 @@ void zbx_preprocessor_unpack_task(zbx_uint64_t *itemid, unsigned char *value_typ /****************************************************************************** * * - * Function: free_steps * - * * * Purpose: free preprocessing steps * * * ******************************************************************************/ @@ -1131,8 +1087,6 @@ void zbx_preprocessor_free_steps(zbx_preproc_op_t *steps, int steps_num) /****************************************************************************** * * - * Function: zbx_preprocessor_free_deps * - * * * Purpose: free dependent item preprocessing request * * * * Parameters: deps - [OUT] the dependent items * @@ -1155,8 +1109,6 @@ void zbx_preprocessor_free_deps(zbx_preproc_dep_t *deps, int deps_num) /****************************************************************************** * * - * Function: preprocessor_unpack_dep * - * * * Purpose: unpack dependent item preprocessing request * * * * Parameters: data - [IN] serialized dependent item preprocessing data * @@ -1180,8 +1132,6 @@ static zbx_uint32_t preprocessor_unpack_dep(const unsigned char *data, zbx_prepr /****************************************************************************** * * - * Function: zbx_preprocessor_unpack_dep_task * - * * * Purpose: unpack initial dependent item preprocessing request * * * * Parameters: ts - [OUT] the value timestamp * @@ -1214,8 +1164,6 @@ void zbx_preprocessor_unpack_dep_task(zbx_timespec_t *ts, zbx_variant_t *value, /****************************************************************************** * * - * Function: zbx_preprocessor_unpack_dep_task_cont * - * * * Purpose: unpack following dependent item preprocessing request * * * * Parameters: ts - [OUT] the value timestamp * @@ -1242,8 +1190,6 @@ void zbx_preprocessor_unpack_dep_task_cont(zbx_preproc_dep_t *deps, int *deps_nu /****************************************************************************** * * - * Function: zbx_preprocessor_unpack_result * - * * * Purpose: unpack preprocessing task data from IPC data buffer * * * * Parameters: value - [OUT] result value * @@ -1266,8 +1212,6 @@ void zbx_preprocessor_unpack_result(zbx_variant_t *value, zbx_vector_ptr_t *hist /****************************************************************************** * * - * Function: agent_result_set_value * - * * * Purpose: convert variant value to AGENT_RESULT * * * * Parameters: value - [IN] the value to convert * @@ -1343,8 +1287,6 @@ static void agent_result_set_value(zbx_variant_t *value, zbx_item_value_type_t v /****************************************************************************** * * - * Function: preprocessor_unpack_dep_result * - * * * Purpose: unpack dependent item preprocessing result * * * * Parameters: data - [IN] IPC data buffer * @@ -1375,8 +1317,6 @@ static zbx_uint32_t preprocessor_unpack_dep_result(const unsigned char *data, zb /****************************************************************************** * * - * Function: zbx_preprocessor_unpack_dep_result * - * * * Purpose: unpack preprocessing results * * * * Parameters: total_num - [OUT] the total number of results * @@ -1403,8 +1343,6 @@ void zbx_preprocessor_unpack_dep_result(int *total_num, int *results_num, zbx_pr /****************************************************************************** * * - * Function: zbx_preprocessor_unpack_dep_result_cont * - * * * Purpose: unpack following preprocessing results * * * * Parameters: results_num - [OUT] the number of results in this batch * @@ -1429,8 +1367,6 @@ void zbx_preprocessor_unpack_dep_result_cont(int *results_num, zbx_preproc_dep_r } /****************************************************************************** * * - * Function: zbx_preprocessor_unpack_test_result * - * * * Purpose: unpack preprocessing test data from IPC data buffer * * * * Parameters: results - [OUT] the preprocessing step results * @@ -1467,8 +1403,6 @@ void zbx_preprocessor_unpack_test_result(zbx_vector_ptr_t *results, zbx_vector_p /****************************************************************************** * * - * Function: zbx_preprocessor_unpack_diag_stats * - * * * Purpose: unpack preprocessing test data from IPC data buffer * * * * Parameters: total - [OUT] the number of values * @@ -1499,8 +1433,6 @@ void zbx_preprocessor_unpack_diag_stats(int *total, int *queued, int *processing /****************************************************************************** * * - * Function: zbx_preprocessor_unpack_top_request * - * * * Purpose: unpack preprocessing test data from IPC data buffer * * * * Parameters: data - [OUT] memory buffer for packed data * @@ -1514,8 +1446,6 @@ void zbx_preprocessor_unpack_top_request(int *limit, const unsigned char *data) /****************************************************************************** * * - * Function: zbx_preprocessor_unpack_top_request * - * * * Purpose: unpack preprocessing test data from IPC data buffer * * * * Parameters: items - [OUT] the item diag data * @@ -1547,8 +1477,6 @@ void zbx_preprocessor_unpack_top_result(zbx_vector_ptr_t *items, const unsigned /****************************************************************************** * * - * Function: preprocessor_send * - * * * Purpose: sends command to preprocessor manager * * * * Parameters: code - [IN] message code * @@ -1587,8 +1515,6 @@ static void preprocessor_send(zbx_uint32_t code, unsigned char *data, zbx_uint32 /****************************************************************************** * * - * Function: zbx_preprocess_item_value * - * * * Purpose: perform item value preprocessing and dependent item processing * * * * Parameters: itemid - [IN] the itemid * @@ -1652,8 +1578,6 @@ void zbx_preprocess_item_value(zbx_uint64_t itemid, zbx_uint64_t hostid, unsigne /****************************************************************************** * * - * Function: zbx_preprocessor_flush * - * * * Purpose: send flush command to preprocessing manager * * * ******************************************************************************/ @@ -1671,8 +1595,6 @@ void zbx_preprocessor_flush(void) /****************************************************************************** * * - * Function: zbx_preprocessor_get_queue_size * - * * * Purpose: get queue size (enqueued value count) of preprocessing manager * * * * Return value: enqueued item count * @@ -1693,8 +1615,6 @@ zbx_uint64_t zbx_preprocessor_get_queue_size(void) /****************************************************************************** * * - * Function: zbx_preproc_op_free * - * * * Purpose: frees preprocessing step * * * ******************************************************************************/ @@ -1707,8 +1627,6 @@ void zbx_preproc_op_free(zbx_preproc_op_t *op) /****************************************************************************** * * - * Function: zbx_preproc_result_free * - * * * Purpose: frees preprocessing step test result * * * ******************************************************************************/ @@ -1721,8 +1639,6 @@ void zbx_preproc_result_free(zbx_preproc_result_t *result) /****************************************************************************** * * - * Function: preprocessor_pack_test_request * - * * * Purpose: packs preprocessing step request for serialization * * * * Return value: The size of packed data * @@ -1767,8 +1683,6 @@ static zbx_uint32_t preprocessor_pack_test_request(unsigned char **data, unsigne /****************************************************************************** * * - * Function: zbx_preprocessor_unpack_test_request * - * * * Purpose: unpack preprocessing test request data from IPC data buffer * * * * Parameters: value_type - [OUT] item value type * @@ -1798,8 +1712,6 @@ void zbx_preprocessor_unpack_test_request(unsigned char *value_type, char **valu /****************************************************************************** * * - * Function: zbx_preprocessor_test * - * * * Purpose: tests item preprocessing with the specified input value and steps * * * ******************************************************************************/ @@ -1832,8 +1744,6 @@ out: /****************************************************************************** * * - * Function: zbx_preprocessor_get_diag_stats * - * * * Purpose: get preprocessing manager diagnostic statistics * * * ******************************************************************************/ @@ -1856,8 +1766,6 @@ int zbx_preprocessor_get_diag_stats(int *total, int *queued, int *processing, in /****************************************************************************** * * - * Function: zbx_preprocessor_get_top_items * - * * * Purpose: get the top N items by the number of queued values * * * ******************************************************************************/ @@ -1885,8 +1793,6 @@ out: /****************************************************************************** * * - * Function: zbx_preprocessor_get_top_items * - * * * Purpose: get the top N items by the number of queued values * * * ******************************************************************************/ @@ -1897,8 +1803,6 @@ int zbx_preprocessor_get_top_items(int limit, zbx_vector_ptr_t *items, char **er /****************************************************************************** * * - * Function: zbx_preprocessor_get_top_oldest_preproc_items * - * * * Purpose: get the oldest items with preprocessing still in queue * * * ******************************************************************************/ |