From 9d822c6f5ead1480d71f3e4d8b31fa2a9391020b Mon Sep 17 00:00:00 2001 From: Artjoms Rimdjonoks Date: Tue, 4 Jan 2022 23:50:10 +0200 Subject: .......... [DEV-2051] removed functions names from the function comments --- src/zabbix_server/preprocessor/item_preproc.c | 86 --------------------- src/zabbix_server/preprocessor/preproc_cache.c | 8 -- src/zabbix_server/preprocessor/preproc_manager.c | 66 ---------------- src/zabbix_server/preprocessor/preproc_worker.c | 20 ----- src/zabbix_server/preprocessor/preprocessing.c | 96 ------------------------ 5 files changed, 276 deletions(-) (limited to 'src/zabbix_server/preprocessor') 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 @@ -35,8 +35,6 @@ extern zbx_es_t es_engine; /****************************************************************************** - * * - * Function: item_preproc_numeric_type_hint * * * * Purpose: returns numeric type hint based on item value type * * * @@ -59,8 +57,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 * * * @@ -84,8 +80,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 * * * @@ -130,8 +124,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 * @@ -179,8 +171,6 @@ static int item_preproc_multiplier_variant(unsigned char value_type, zbx_variant } /****************************************************************************** - * * - * Function: item_preproc_validate_notsupport * * * * Purpose: executes during notsupported item preprocessing * * * @@ -194,8 +184,6 @@ static int item_preproc_validate_notsupport(char **errmsg) } /****************************************************************************** - * * - * Function: item_preproc_multiplier * * * * Purpose: execute custom multiplier preprocessing operation * * * @@ -231,8 +219,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 * * * @@ -271,8 +257,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 * * * @@ -311,8 +295,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 * * * @@ -370,8 +352,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 * * * @@ -406,8 +386,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 * * * @@ -442,8 +420,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 * @@ -495,8 +471,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 * * * @@ -528,8 +502,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 * * * @@ -559,8 +531,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 * * * @@ -590,8 +560,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 * * * @@ -621,8 +589,6 @@ static int item_preproc_lrtrim(zbx_variant_t *value, const char *params, char ** } /****************************************************************************** - * * - * Function: item_preproc_2dec * * * * Purpose: execute decimal value conversion operation * * * @@ -686,8 +652,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 * * * @@ -714,8 +678,6 @@ static int item_preproc_bool2dec(zbx_variant_t *value, char **errmsg) } /****************************************************************************** - * * - * Function: item_preproc_oct2dec * * * * Purpose: execute octal to decimal value conversion operation * * * @@ -742,8 +704,6 @@ static int item_preproc_oct2dec(zbx_variant_t *value, char **errmsg) } /****************************************************************************** - * * - * Function: item_preproc_hex2dec * * * * Purpose: execute hexadecimal to decimal value conversion operation * * * @@ -770,8 +730,6 @@ static int item_preproc_hex2dec(zbx_variant_t *value, char **errmsg) } /****************************************************************************** - * * - * Function: item_preproc_regsub_op * * * * Purpose: execute regular expression substitution operation * * * @@ -826,8 +784,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 * * * @@ -861,8 +817,6 @@ static int item_preproc_regsub(zbx_variant_t *value, const char *params, char ** } /****************************************************************************** - * * - * Function: item_preproc_jsonpath_op * * * * Purpose: execute jsonpath query * * * @@ -901,8 +855,6 @@ static int item_preproc_jsonpath_op(zbx_variant_t *value, const char *params, ch } /****************************************************************************** - * * - * Function: item_preproc_jsonpath * * * * Purpose: execute jsonpath query * * * @@ -929,8 +881,6 @@ static int item_preproc_jsonpath(zbx_variant_t *value, const char *params, char } /****************************************************************************** - * * - * Function: item_preproc_xpath * * * * Purpose: execute xpath query * * * @@ -959,8 +909,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 * @@ -1037,8 +985,6 @@ out: } /****************************************************************************** - * * - * Function: item_preproc_validate_regex * * * * Purpose: validates value to match regular expression * * Parameters: value_type - [IN] the item type * @@ -1094,8 +1040,6 @@ out: } /****************************************************************************** - * * - * Function: item_preproc_validate_not_regex * * * * Purpose: validates value to not match regular expression * * Parameters: value_type - [IN] the item type * @@ -1153,8 +1097,6 @@ out: } /****************************************************************************** - * * - * Function: item_preproc_get_error_from_json * * * * Purpose: checks for presence of error field in json data * * * @@ -1209,8 +1151,6 @@ out: } /****************************************************************************** - * * - * Function: item_preproc_get_error_from_xml * * * * Purpose: checks for presence of error field in XML data * * * @@ -1315,8 +1255,6 @@ out: } /****************************************************************************** - * * - * Function: item_preproc_get_error_from_regex * * * * Purpose: checks for presence of error pattern matching regular expression * * * @@ -1379,8 +1317,6 @@ out: } /****************************************************************************** - * * - * Function: item_preproc_throttle_value * * * * Purpose: throttles value by suppressing identical values * * * @@ -1413,8 +1349,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 * * * @@ -1458,8 +1392,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 * * * @@ -1522,8 +1454,6 @@ fail: } /****************************************************************************** - * * - * Function: item_preproc_prometheus_pattern * * * * Purpose: parse Prometheus format metrics * * * @@ -1603,8 +1533,6 @@ out: } /****************************************************************************** - * * - * Function: item_preproc_prometheus_to_json * * * * Purpose: convert Prometheus format metrics to JSON format * * * @@ -1637,8 +1565,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 * * * @@ -1713,8 +1639,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 * * * @@ -1971,8 +1895,6 @@ out: } /****************************************************************************** - * * - * Function: item_preproc_xml_to_json * * * * Purpose: convert XML format value to JSON format * * * @@ -2000,8 +1922,6 @@ static int item_preproc_xml_to_json(zbx_variant_t *value, char **errmsg) } /****************************************************************************** - * * - * Function: item_preproc_str_replace * * * * Purpose: replace substrings in string * * * @@ -2052,8 +1972,6 @@ static int item_preproc_str_replace(zbx_variant_t *value, const char *params, ch } /****************************************************************************** - * * - * Function: zbx_item_preproc * * * * Purpose: execute preprocessing operation * * * @@ -2173,8 +2091,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 * * * @@ -2211,8 +2127,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 * * * 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 @@ -25,8 +25,6 @@ ZBX_VECTOR_IMPL(ppcache, zbx_preproc_cache_ref_t); /****************************************************************************** - * * - * Function: zbx_preproc_cache_get * * * * Purpose: get cache by preprocessing step type * * * @@ -51,8 +49,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 * * * @@ -75,8 +71,6 @@ void zbx_preproc_cache_put(zbx_preproc_cache_t *cache, unsigned char type, void } /****************************************************************************** - * * - * Function: zbx_preproc_cache_init * * * * Purpose: initialize preprocessing cache * * * @@ -87,8 +81,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 @@ -183,8 +183,6 @@ static void request_free_steps(zbx_preprocessing_request_t *request) } /****************************************************************************** - * * - * Function: preprocessor_sync_configuration * * * * Purpose: synchronize preprocessing manager with configuration cache data * * * @@ -257,8 +255,6 @@ static void preprocessing_ar_to_variant(AGENT_RESULT *ar, zbx_variant_t *value) } /****************************************************************************** - * * - * Function: preprocessor_create_task * * * * Purpose: create preprocessing task for request * * * @@ -292,8 +288,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 * * * @@ -337,8 +331,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 * * * @@ -405,8 +397,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 * * * @@ -431,8 +421,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 * * * @@ -524,8 +512,6 @@ out: } /****************************************************************************** - * * - * Function: preprocessor_get_worker_by_client * * * * Purpose: get worker data by IPC client * * * @@ -560,8 +546,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 * * * @@ -584,8 +568,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 * * * @@ -617,8 +599,6 @@ static void preprocessor_assign_tasks(zbx_preprocessing_manager_t *manager) } /****************************************************************************** - * * - * Function: preproc_item_value_clear * * * * Purpose: frees resources allocated by preprocessor item value * * * @@ -638,8 +618,6 @@ static void preproc_item_value_clear(zbx_preproc_item_value_t *value) } /****************************************************************************** - * * - * Function: preprocessor_free_request * * * * Purpose: free preprocessing request * * * @@ -673,8 +651,6 @@ static void preprocessor_free_request(zbx_preprocessing_request_base_t *base) } /****************************************************************************** - * * - * Function: preprocessor_free_direct_request * * * * Purpose: free preprocessing direct request * * * @@ -689,8 +665,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 * * * @@ -741,8 +715,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 * @@ -818,8 +790,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 * * * @@ -857,8 +827,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 * * * @@ -877,8 +845,6 @@ static void preprocessor_enqueue_dependent_value(zbx_preprocessing_manager_t *ma } /****************************************************************************** - * * - * Function: preprocessor_enqueue * * * * Purpose: enqueue preprocessing request * * * @@ -1007,8 +973,6 @@ out: } /****************************************************************************** - * * - * Function: preprocessor_enqueue_dependent * * * * Purpose: enqueue dependent items (if any) * * * @@ -1071,8 +1035,6 @@ static void preprocessor_enqueue_dependent(zbx_preprocessing_manager_t *manager, } /****************************************************************************** - * * - * Function: preprocessor_add_request * * * * Purpose: handle new preprocessing request * * * @@ -1102,8 +1064,6 @@ static void preprocessor_add_request(zbx_preprocessing_manager_t *manager, zbx_i } /****************************************************************************** - * * - * Function: preprocessor_add_test_request * * * * Purpose: handle new preprocessing test request * * * @@ -1131,8 +1091,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 * * * @@ -1247,8 +1205,6 @@ out: } /****************************************************************************** - * * - * Function: preprocessor_add_result * * * * Purpose: handle preprocessing result * * * @@ -1326,8 +1282,6 @@ static void preprocessor_add_result(zbx_preprocessing_manager_t *manager, zbx_ip } /****************************************************************************** - * * - * Function: preprocessor_update_history * * * * Purpose: handle preprocessing result * * * @@ -1402,8 +1356,6 @@ static void preprocessor_finalize_dep_results(zbx_preprocessing_manager_t *manag } /****************************************************************************** - * * - * Function: preprocessor_add_dep_result * * * * Purpose: handle dependent item batch preprocessing result * * * @@ -1434,8 +1386,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 * * * @@ -1466,8 +1416,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 * * * @@ -1499,8 +1447,6 @@ static void preprocessor_next_dep_request(zbx_preprocessing_manager_t *manager, } /****************************************************************************** - * * - * Function: preprocessor_flush_test_result * * * * Purpose: handle preprocessing result * * * @@ -1647,8 +1593,6 @@ static void preprocessor_get_items_totals(zbx_preprocessing_manager_t *manager, } /****************************************************************************** - * * - * Function: preprocessor_get_diag_stats * * * * Purpose: return diagnostic statistics * * * @@ -1674,8 +1618,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 * * * @@ -1747,8 +1689,6 @@ static void preprocessor_get_items_view(zbx_preprocessing_manager_t *manager, zb } /****************************************************************************** - * * - * Function: preprocessor_get_top_items * * * * Purpose: return diagnostic top view * * * @@ -1855,8 +1795,6 @@ static int preproc_item_link_compare(const void *d1, const void *d2) } /****************************************************************************** - * * - * Function: preprocessor_init_manager * * * * Purpose: initializes preprocessing manager * * * @@ -1884,8 +1822,6 @@ static void preprocessor_init_manager(zbx_preprocessing_manager_t *manager) } /****************************************************************************** - * * - * Function: preprocessor_register_worker * * * * Purpose: registers preprocessing worker * * * @@ -1927,8 +1863,6 @@ static void preprocessor_register_worker(zbx_preprocessing_manager_t *manager, z } /****************************************************************************** - * * - * Function: preprocessor_destroy_manager * * * * Purpose: destroy preprocessing manager * * * 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 @@ -50,8 +50,6 @@ zbx_preproc_dep_request_t; zbx_es_t es_engine; /****************************************************************************** - * * - * Function: worker_format_value * * * * Purpose: formats value in text format * * * @@ -92,8 +90,6 @@ static void worker_format_value(const zbx_variant_t *value, char **value_str) } /****************************************************************************** - * * - * Function: worker_format_result * * * * Purpose: formats one preprocessing step result * * * @@ -123,8 +119,6 @@ static void worker_format_result(int step, const zbx_preproc_result_t *result, c } /****************************************************************************** - * * - * Function: worker_format_error * * * * Purpose: formats preprocessing error message * * * @@ -202,8 +196,6 @@ static void worker_format_error(const zbx_variant_t *value, zbx_preproc_result_t } /****************************************************************************** - * * - * Function: worker_item_preproc_execute * * * * Purpose: execute preprocessing steps * * * @@ -295,8 +287,6 @@ static int worker_item_preproc_execute(zbx_preproc_cache_t *cache, unsigned char } /****************************************************************************** - * * - * Function: worker_preprocess_value * * * * Purpose: handle item value preprocessing task * * * @@ -378,8 +368,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 * * * @@ -444,8 +432,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) @@ -456,8 +442,6 @@ static void worker_dep_request_clear(zbx_preproc_dep_request_t *request) } /****************************************************************************** - * * - * Function: worker_preprocess_dep_items * * * * Purpose: preprocess dependent items * * * @@ -561,8 +545,6 @@ out: } /****************************************************************************** - * * - * Function: worker_process_dep_request * * * * Purpose: handle item value preprocessing request * * * @@ -581,8 +563,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 * * * 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 @@ -105,8 +105,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 * * * @@ -136,8 +134,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 * * * @@ -199,8 +195,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 * * * @@ -242,8 +236,6 @@ static int preprocessor_pack_variant(zbx_packed_field_t *fields, const zbx_varia } /****************************************************************************** - * * - * Function: preprocessor_pack_history * * * * Purpose: packs preprocessing history for serialization * * * @@ -276,8 +268,6 @@ static int preprocessor_pack_history(zbx_packed_field_t *fields, const zbx_vecto } /****************************************************************************** - * * - * Function: preprocessor_pack_step * * * * Purpose: packs preprocessing step for serialization * * * @@ -302,8 +292,6 @@ static int preprocessor_pack_step(zbx_packed_field_t *fields, const zbx_preproc_ } /****************************************************************************** - * * - * Function: preprocessor_pack_steps * * * * Purpose: packs preprocessing steps for serialization * * * @@ -329,8 +317,6 @@ static int preprocessor_pack_steps(zbx_packed_field_t *fields, const zbx_preproc } /****************************************************************************** - * * - * Function: preprocesser_unpack_variant * * * * Purpose: unpacks serialized variant value * * * @@ -370,8 +356,6 @@ static int preprocesser_unpack_variant(const unsigned char *data, zbx_variant_t } /****************************************************************************** - * * - * Function: preprocesser_unpack_history * * * * Purpose: unpacks serialized preprocessing history * * * @@ -411,8 +395,6 @@ static int preprocesser_unpack_history(const unsigned char *data, zbx_vector_ptr } /****************************************************************************** - * * - * Function: preprocessor_unpack_step * * * * Purpose: unpacks serialized preprocessing step * * * @@ -436,8 +418,6 @@ static int preprocessor_unpack_step(const unsigned char *data, zbx_preproc_op_t } /****************************************************************************** - * * - * Function: preprocessor_unpack_steps * * * * Purpose: unpacks serialized preprocessing steps * * * @@ -467,8 +447,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 * @@ -527,8 +505,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 * * * @@ -566,8 +542,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 * @@ -660,8 +634,6 @@ out: } /****************************************************************************** - * * - * Function: zbx_preprocessor_pack_result * * * * Purpose: pack preprocessing result data into a single buffer that can be * * used in IPC * @@ -703,8 +675,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 * * * @@ -834,8 +804,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 * @@ -887,8 +855,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 * @@ -932,8 +898,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* * * @@ -954,8 +918,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 * * * @@ -996,8 +958,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 * * * @@ -1068,8 +1028,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 * * * @@ -1111,8 +1069,6 @@ void zbx_preprocessor_unpack_task(zbx_uint64_t *itemid, unsigned char *value_typ } /****************************************************************************** - * * - * Function: free_steps * * * * Purpose: free preprocessing steps * * * @@ -1130,8 +1086,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 * * * @@ -1154,8 +1108,6 @@ void zbx_preprocessor_free_deps(zbx_preproc_dep_t *deps, int deps_num) } /****************************************************************************** - * * - * Function: preprocessor_unpack_dep * * * * Purpose: unpack dependent item preprocessing request * * * @@ -1179,8 +1131,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 * * * @@ -1213,8 +1163,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 * * * @@ -1241,8 +1189,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 * * * @@ -1265,8 +1211,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 * * * @@ -1342,8 +1286,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 * * * @@ -1374,8 +1316,6 @@ static zbx_uint32_t preprocessor_unpack_dep_result(const unsigned char *data, zb } /****************************************************************************** - * * - * Function: zbx_preprocessor_unpack_dep_result * * * * Purpose: unpack preprocessing results * * * @@ -1402,8 +1342,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 * * * @@ -1428,8 +1366,6 @@ void zbx_preprocessor_unpack_dep_result_cont(int *results_num, zbx_preproc_dep_r *results_num += batch_num; } /****************************************************************************** - * * - * Function: zbx_preprocessor_unpack_test_result * * * * Purpose: unpack preprocessing test data from IPC data buffer * * * @@ -1466,8 +1402,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 * * * @@ -1498,8 +1432,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 * * * @@ -1513,8 +1445,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 * * * @@ -1546,8 +1476,6 @@ void zbx_preprocessor_unpack_top_result(zbx_vector_ptr_t *items, const unsigned } /****************************************************************************** - * * - * Function: preprocessor_send * * * * Purpose: sends command to preprocessor manager * * * @@ -1586,8 +1514,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 * * * @@ -1651,8 +1577,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 * * * @@ -1670,8 +1594,6 @@ void zbx_preprocessor_flush(void) } /****************************************************************************** - * * - * Function: zbx_preprocessor_get_queue_size * * * * Purpose: get queue size (enqueued value count) of preprocessing manager * * * @@ -1692,8 +1614,6 @@ zbx_uint64_t zbx_preprocessor_get_queue_size(void) } /****************************************************************************** - * * - * Function: zbx_preproc_op_free * * * * Purpose: frees preprocessing step * * * @@ -1706,8 +1626,6 @@ void zbx_preproc_op_free(zbx_preproc_op_t *op) } /****************************************************************************** - * * - * Function: zbx_preproc_result_free * * * * Purpose: frees preprocessing step test result * * * @@ -1720,8 +1638,6 @@ void zbx_preproc_result_free(zbx_preproc_result_t *result) } /****************************************************************************** - * * - * Function: preprocessor_pack_test_request * * * * Purpose: packs preprocessing step request for serialization * * * @@ -1766,8 +1682,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 * * * @@ -1797,8 +1711,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 * * * @@ -1831,8 +1743,6 @@ out: } /****************************************************************************** - * * - * Function: zbx_preprocessor_get_diag_stats * * * * Purpose: get preprocessing manager diagnostic statistics * * * @@ -1855,8 +1765,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 * * * @@ -1884,8 +1792,6 @@ out: } /****************************************************************************** - * * - * Function: zbx_preprocessor_get_top_items * * * * Purpose: get the top N items by the number of queued values * * * @@ -1896,8 +1802,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 * * * -- cgit v1.2.3