diff options
| -rw-r--r-- | common/elapi/elapi_internal.c | 204 | ||||
| -rw-r--r-- | common/elapi/elapi_log.c | 14 | ||||
| -rw-r--r-- | common/elapi/elapi_priv.h | 84 | ||||
| -rw-r--r-- | common/elapi/elapi_test/elapi_ut.c | 4 |
4 files changed, 152 insertions, 154 deletions
diff --git a/common/elapi/elapi_internal.c b/common/elapi/elapi_internal.c index cfc2bbee..3007fc2e 100644 --- a/common/elapi/elapi_internal.c +++ b/common/elapi/elapi_internal.c @@ -40,27 +40,27 @@ #define ELAPI_DEFAULT_ERROR_FILE "elapiconf.err" /* Handler for logging through the targets */ -int elapi_internal_target_handler(const char *target, - int target_len, - int type, - void *data, - int length, - void *passed_data, - int *stop) +int elapi_tgt_cb(const char *target, + int target_len, + int type, + void *data, + int length, + void *passed_data, + int *stop) { - struct elapi_target_pass_in_data *target_data; - struct elapi_target_context *context; + struct elapi_tgt_data *target_data; + struct elapi_tgt_ctx *context; - TRACE_FLOW_STRING("elapi_internal_target_handler", "Entry."); + TRACE_FLOW_STRING("elapi_tgt_cb", "Entry."); /* Skip header */ if (type == COL_TYPE_COLLECTION) { - TRACE_FLOW_STRING("elapi_internal_target_handler - skip header", "Exit."); + TRACE_FLOW_STRING("elapi_tgt_cb - skip header", "Exit."); return EOK; } - target_data = (struct elapi_target_pass_in_data *)(passed_data); - context = *((struct elapi_target_context **)(data)); + target_data = (struct elapi_tgt_data *)(passed_data); + context = *((struct elapi_tgt_ctx **)(data)); /* Check if we need to log this event into this target */ TRACE_INFO_NUMBER("EVENT IS LOGGED INTO:", target_data->target_mask); @@ -78,89 +78,89 @@ int elapi_internal_target_handler(const char *target, printf("\n\n\nPROCESSING EVENT:\n"); col_debug_collection(target_data->event, COL_TRAVERSE_DEFAULT); - TRACE_FLOW_STRING("elapi_internal_target_handler", "Exit."); + TRACE_FLOW_STRING("elapi_tgt_cb", "Exit."); return EOK; } /* Internal target cleanup function */ -int elapi_internal_target_cleanup_handler(const char *target, - int target_len, - int type, - void *data, - int length, - void *passed_data, - int *stop) +int elapi_tgt_free_cb(const char *target, + int target_len, + int type, + void *data, + int length, + void *passed_data, + int *stop) { - TRACE_FLOW_STRING("elapi_internal_target_cleanup_handler", "Entry."); + TRACE_FLOW_STRING("elapi_tgt_free_cb", "Entry."); /* Skip header */ if (type == COL_TYPE_COLLECTION) { - TRACE_FLOW_STRING("elapi_internal_target_cleanup_handler - skip header", "Exit."); + TRACE_FLOW_STRING("elapi_tgt_free_cb - skip header", "Exit."); return EOK; } - elapi_internal_destroy_target(*((struct elapi_target_context **)(data))); + elapi_tgt_destroy(*((struct elapi_tgt_ctx **)(data))); - TRACE_FLOW_STRING("elapi_internal_target_cleanup_handler", "Exit."); + TRACE_FLOW_STRING("elapi_tgt_free_cb", "Exit."); return EOK; } -int elapi_internal_sink_handler(const char *sink, - int sink_len, - int type, - void *data, - int length, - void *passed_data, - int *stop) +int elapi_sink_cb(const char *sink, + int sink_len, + int type, + void *data, + int length, + void *passed_data, + int *stop) { - TRACE_FLOW_STRING("elapi_internal_sink_handler", "Entry."); + TRACE_FLOW_STRING("elapi_sink_cb", "Entry."); /* FIXME THIS IS A PLACEHOLDER FUNCTION FOR NOW */ /* Skip header */ if (type == COL_TYPE_COLLECTION) { - TRACE_FLOW_STRING("elapi_internal_sink_handler - skip header", "Exit."); + TRACE_FLOW_STRING("elapi_sink_cb - skip header", "Exit."); return EOK; } printf("Sink: %s\n", sink); - TRACE_FLOW_STRING("elapi_internal_sink_handler", "Exit."); + TRACE_FLOW_STRING("elapi_sink_cb", "Exit."); return EOK; } /* Internal sink cleanup function */ -int elapi_internal_sink_cleanup_handler(const char *sink, - int sink_len, - int type, - void *data, - int length, - void *passed_data, - int *stop) +int elapi_sink_free_cb(const char *sink, + int sink_len, + int type, + void *data, + int length, + void *passed_data, + int *stop) { - TRACE_FLOW_STRING("elapi_internal_sink_cleanup_handler", "Entry."); + TRACE_FLOW_STRING("elapi_sink_free_cb", "Entry."); /* FIXME THIS IS A PLACEHOLDER FUNCTION FOR NOW */ printf("Cleaning Sink: %s\n", sink); - TRACE_FLOW_STRING("elapi_internal_sink_cleanup_handler", "Exit."); + TRACE_FLOW_STRING("elapi_sink_free_cb", "Exit."); return EOK; } /* Function to add a sink to the collection */ /* FIXME - other arguments might be added later */ -int elapi_internal_add_sink(struct collection_item **sink_ref, - char *sink, - struct elapi_dispatcher *handle) +int elapi_sink_add(struct collection_item **sink_ref, + char *sink, + struct elapi_dispatcher *handle) { int error = EOK; - struct elapi_sink_context sink_context; + struct elapi_sink_ctx sink_context; struct collection_item *provider_cfg_item = NULL; - TRACE_FLOW_STRING("elapi_internal_add_sink", "Entry"); + TRACE_FLOW_STRING("elapi_sink_add", "Entry"); TRACE_INFO_STRING("Evaluating sink:", sink); TRACE_INFO_NUMBER("Sink reference before call:", *sink_ref); @@ -214,7 +214,7 @@ int elapi_internal_add_sink(struct collection_item **sink_ref, NULL, sink, (void *)(&sink_context), - sizeof(struct elapi_sink_context), + sizeof(struct elapi_sink_ctx), sink_ref); if (error != 0) { TRACE_ERROR_NUMBER("Failed to add sink data as property", error); @@ -222,14 +222,14 @@ int elapi_internal_add_sink(struct collection_item **sink_ref, } } - TRACE_FLOW_NUMBER("elapi_internal_add_sink returning", error); + TRACE_FLOW_NUMBER("elapi_sink_add returning", error); return error; } /* Destroy target object */ -void elapi_internal_destroy_target(struct elapi_target_context *context) +void elapi_tgt_destroy(struct elapi_tgt_ctx *context) { - TRACE_FLOW_STRING("elapi_internal_destroy_target", "Entry."); + TRACE_FLOW_STRING("elapi_tgt_destroy", "Entry."); TRACE_INFO_NUMBER("Target address in cleanup:", context); @@ -242,24 +242,24 @@ void elapi_internal_destroy_target(struct elapi_target_context *context) free(context); } - TRACE_FLOW_STRING("elapi_internal_destroy_target", "Exit."); + TRACE_FLOW_STRING("elapi_tgt_destroy", "Exit."); } /* Allocate target context and load sinks to it */ -int elapi_internal_create_target(struct elapi_target_context **context, - char *target, - struct elapi_dispatcher *handle) +int elapi_tgt_create(struct elapi_tgt_ctx **context, + char *target, + struct elapi_dispatcher *handle) { int error = EOK; struct collection_item *sink_cfg_item = NULL; struct collection_item *value_cfg_item = NULL; - struct elapi_target_context *target_context; + struct elapi_tgt_ctx *target_context; char **sinks; char **current_sink; struct collection_item *sink_ref; - TRACE_FLOW_STRING("elapi_internal_create_target", "Entry."); + TRACE_FLOW_STRING("elapi_tgt_create", "Entry."); /* Get list of sinks for this target from config */ error = get_config_item(target, @@ -279,7 +279,7 @@ int elapi_internal_create_target(struct elapi_target_context **context, } /* Allocate context */ - target_context = (struct elapi_target_context *)malloc(sizeof(struct elapi_target_context)); + target_context = (struct elapi_tgt_ctx *)malloc(sizeof(struct elapi_tgt_ctx)); if (target_context == NULL) { TRACE_ERROR_NUMBER("Memory allocation failed. Error", target_context); return ENOMEM; @@ -299,7 +299,7 @@ int elapi_internal_create_target(struct elapi_target_context **context, &value_cfg_item); if (error) { TRACE_ERROR_NUMBER("Attempt to read configuration returned error", error); - elapi_internal_destroy_target(target_context); + elapi_tgt_destroy(target_context); return error; } @@ -319,7 +319,7 @@ int elapi_internal_create_target(struct elapi_target_context **context, */ if (error) { TRACE_ERROR_NUMBER("Failed to convert value form INI file", error); - elapi_internal_destroy_target(target_context); + elapi_tgt_destroy(target_context); return error; } } @@ -333,7 +333,7 @@ int elapi_internal_create_target(struct elapi_target_context **context, COL_CLASS_ELAPI_SINK_REF); if (error != 0) { TRACE_ERROR_NUMBER("Failed to create sink collection. Error", error); - elapi_internal_destroy_target(target_context); + elapi_tgt_destroy(target_context); return error; } @@ -348,16 +348,16 @@ int elapi_internal_create_target(struct elapi_target_context **context, /* Load sink if it is not loaded yet */ sink_ref = NULL; - error = elapi_internal_add_sink(&sink_ref, - *current_sink, - handle); + error = elapi_sink_add(&sink_ref, + *current_sink, + handle); if (error) { /* NOTE - we might decide to lax some of the checks * like this later and be satisfied with at least one * sink in the list. Subject for discussion... */ TRACE_ERROR_NUMBER("Failed to add sink", error); - elapi_internal_destroy_target(target_context); + elapi_tgt_destroy(target_context); free_string_config_array(sinks); return error; } @@ -368,7 +368,7 @@ int elapi_internal_create_target(struct elapi_target_context **context, sizeof(struct collection_item *)); if (error != 0) { TRACE_ERROR_NUMBER("Failed to add sink reference", error); - elapi_internal_destroy_target(target_context); + elapi_tgt_destroy(target_context); free_string_config_array(sinks); return error; } @@ -380,20 +380,20 @@ int elapi_internal_create_target(struct elapi_target_context **context, *context = target_context; - TRACE_FLOW_STRING("elapi_internal_create_target", "Exit."); + TRACE_FLOW_STRING("elapi_tgt_create", "Exit."); return EOK; } /* Function to create a list of targets */ -int elapi_internal_construct_target_list(struct elapi_dispatcher *handle) +int elapi_tgt_mklist(struct elapi_dispatcher *handle) { int error = EOK; char **current_target; - struct elapi_target_context *context; + struct elapi_tgt_ctx *context; - TRACE_FLOW_STRING("elapi_internal_construct_target_list", "Entry"); + TRACE_FLOW_STRING("elapi_tgt_mklist", "Entry"); /* Allocate collection to store target */ error = col_create_collection(&(handle->target_list), @@ -429,9 +429,9 @@ int elapi_internal_construct_target_list(struct elapi_dispatcher *handle) /* Allocate target context and load sinks to it */ context = NULL; - error = elapi_internal_create_target(&context, - *current_target, - handle); + error = elapi_tgt_create(&context, + *current_target, + handle); if (error) { TRACE_ERROR_NUMBER("Failed to create target", error); return error; @@ -442,11 +442,11 @@ int elapi_internal_construct_target_list(struct elapi_dispatcher *handle) /* Add created target to the list of targets */ error = col_add_binary_property(handle->target_list, NULL, *current_target, (void *)(&context), - sizeof(struct elapi_target_context *)); + sizeof(struct elapi_tgt_ctx *)); if (error != 0) { TRACE_ERROR_NUMBER("Failed to add sink data as property", error); /* Need to clean allocated context here if we failed to add it */ - elapi_internal_destroy_target(context); + elapi_tgt_destroy(context); return error; } @@ -460,14 +460,14 @@ int elapi_internal_construct_target_list(struct elapi_dispatcher *handle) return ENOENT; } - TRACE_FLOW_STRING("elapi_internal_construct_target_list", "Returning success"); + TRACE_FLOW_STRING("elapi_tgt_mklist", "Returning success"); return EOK; } /* If we failed to read configuration record this in the local file */ -void elapi_internal_dump_errors_to_file(struct collection_item *error_list) +void elapi_dump_ini_err(struct collection_item *error_list) { FILE *efile; char timestr[MAX_TIMESTR]; @@ -475,7 +475,7 @@ void elapi_internal_dump_errors_to_file(struct collection_item *error_list) struct tm *time_as_struct; struct tm time_data; - TRACE_FLOW_STRING("elapi_internal_dump_errors_to_file", "Entry point"); + TRACE_FLOW_STRING("elapi_dump_ini_err", "Entry point"); efile = fopen(ELAPI_DEFAULT_ERROR_FILE, "a"); if (efile == NULL) { @@ -500,21 +500,21 @@ void elapi_internal_dump_errors_to_file(struct collection_item *error_list) print_file_parsing_errors(efile, error_list); fclose(efile); - TRACE_FLOW_STRING("elapi_internal_dump_errors_to_file", "Exit"); + TRACE_FLOW_STRING("elapi_dump_ini_err", "Exit"); } /* Handler for printing target internals */ -static int elapi_internal_sink_ref_debug_handler(const char *sink, - int sink_len, - int type, - void *data, - int length, - void *passed_data, - int *stop) +static int elapi_sink_ref_dbg_cb(const char *sink, + int sink_len, + int type, + void *data, + int length, + void *passed_data, + int *stop) { struct collection_item *sink_item; - struct elapi_sink_context *sink_context; + struct elapi_sink_ctx *sink_context; /* Skip header */ if (type == COL_TYPE_COLLECTION) { @@ -525,7 +525,7 @@ static int elapi_internal_sink_ref_debug_handler(const char *sink, printf("\nReferenced sink name is: %s\n", col_get_item_property(sink_item, NULL)); - sink_context = (struct elapi_sink_context *)(col_get_item_data(sink_item)); + sink_context = (struct elapi_sink_ctx *)(col_get_item_data(sink_item)); printf("Mode: %s\n", sink_context->async_mode ? "true" : "false"); if (sink_context->in_queue) col_print_collection(sink_context->in_queue); @@ -540,29 +540,29 @@ static int elapi_internal_sink_ref_debug_handler(const char *sink, /* Handler for printing target internals */ -static int elapi_internal_target_debug_handler(const char *target, - int target_len, - int type, - void *data, - int length, - void *passed_data, - int *stop) +static int elapi_tgt_dbg_cb(const char *target, + int target_len, + int type, + void *data, + int length, + void *passed_data, + int *stop) { - struct elapi_target_context *context; + struct elapi_tgt_ctx *context; /* Skip header */ if (type == COL_TYPE_COLLECTION) { return EOK; } - context = *((struct elapi_target_context **)(data)); + context = *((struct elapi_tgt_ctx **)(data)); printf("\nTarget value for target \"%s\" is %d\n", target, context->target_value); printf("\nReferenced sinks:\n\n"); (void)col_traverse_collection(context->sink_ref_list, COL_TRAVERSE_ONELEVEL, - elapi_internal_sink_ref_debug_handler, + elapi_sink_ref_dbg_cb, NULL); return EOK; @@ -570,7 +570,7 @@ static int elapi_internal_target_debug_handler(const char *target, /* Internal function to print dispatcher internals - useful for testing */ -void elapi_internal_print_dispatcher(struct elapi_dispatcher *handle) +void elapi_print_dispatcher(struct elapi_dispatcher *handle) { char **current_target; @@ -601,7 +601,7 @@ void elapi_internal_print_dispatcher(struct elapi_dispatcher *handle) if (handle->target_list) { (void)col_traverse_collection(handle->target_list, COL_TRAVERSE_ONELEVEL, - elapi_internal_target_debug_handler, + elapi_tgt_dbg_cb, NULL); } /* FIXME: Async data... */ diff --git a/common/elapi/elapi_log.c b/common/elapi/elapi_log.c index c155fb1a..4787fd3c 100644 --- a/common/elapi/elapi_log.c +++ b/common/elapi/elapi_log.c @@ -242,7 +242,7 @@ int elapi_create_dispatcher_adv(struct elapi_dispatcher **dispatcher, TRACE_ERROR_NUMBER("Attempt to read configuration returned error", error); elapi_destroy_dispatcher(handle); if (error_set) { - elapi_internal_dump_errors_to_file(error_set); + elapi_dump_ini_err(error_set); free_ini_config_errors(error_set); } return error; @@ -274,7 +274,7 @@ int elapi_create_dispatcher_adv(struct elapi_dispatcher **dispatcher, handle->targets = get_string_config_array(item, NULL, NULL, NULL); /* Create the list of targets */ - error = elapi_internal_construct_target_list(handle); + error = elapi_tgt_mklist(handle); if (error != EOK) { TRACE_ERROR_NUMBER("Failed to create target list. Error", error); elapi_destroy_dispatcher(handle); @@ -334,7 +334,7 @@ void elapi_destroy_dispatcher(struct elapi_dispatcher *dispatcher) TRACE_INFO_STRING("Closing target list.", ""); (void)col_traverse_collection(dispatcher->target_list, COL_TRAVERSE_ONELEVEL, - elapi_internal_target_cleanup_handler, + elapi_tgt_free_cb, NULL); TRACE_INFO_STRING("Deleting target list.", ""); @@ -345,7 +345,7 @@ void elapi_destroy_dispatcher(struct elapi_dispatcher *dispatcher) TRACE_INFO_STRING("Closing sink list.", ""); (void)col_traverse_collection(dispatcher->sink_list, COL_TRAVERSE_ONELEVEL, - elapi_internal_sink_cleanup_handler, + elapi_sink_free_cb, NULL); TRACE_INFO_STRING("Deleting target list.", ""); col_destroy_collection(dispatcher->sink_list); @@ -370,7 +370,7 @@ int elapi_dsp_log(uint32_t target, struct collection_item *event) { int error = EOK; - struct elapi_target_pass_in_data target_data; + struct elapi_tgt_data target_data; TRACE_FLOW_STRING("elapi_dsp_log", "Entry"); @@ -387,10 +387,10 @@ int elapi_dsp_log(uint32_t target, TRACE_INFO_NUMBER("Target mask is:", target_data.target_mask); - /* Logging an event is just iterating through the targets and calling the sink_handler */ + /* Logging an event is just iterating through the targets and calling a callback */ error = col_traverse_collection(dispatcher->target_list, COL_TRAVERSE_ONELEVEL, - elapi_internal_target_handler, + elapi_tgt_cb, (void *)(&target_data)); TRACE_FLOW_NUMBER("elapi_dsp_log Exit. Returning", error); diff --git a/common/elapi/elapi_priv.h b/common/elapi/elapi_priv.h index 0fa01b40..eb1d11f8 100644 --- a/common/elapi/elapi_priv.h +++ b/common/elapi/elapi_priv.h @@ -72,7 +72,7 @@ struct elapi_dispatcher { }; /* Structure to pass data from logging function to targets */ -struct elapi_target_pass_in_data { +struct elapi_tgt_data { struct collection_item *event; struct elapi_dispatcher *handle; uint32_t target_mask; @@ -81,7 +81,7 @@ struct elapi_target_pass_in_data { /* This is a structure that holds the information * about the target. */ -struct elapi_target_context { +struct elapi_tgt_ctx { /* Value associted with the * target in the config file. */ @@ -97,7 +97,7 @@ struct elapi_target_context { }; /* The structure that describes the sink in the dispatcher */ -struct elapi_sink_context { +struct elapi_sink_ctx { /* Inpit queue of a sink */ struct collection_item *in_queue; /* Pending list */ @@ -129,66 +129,64 @@ int elapi_create_event_template_with_vargs(struct collection_item **template, va_list args); /* Sink handler function */ -int elapi_internal_sink_handler(const char *sink, - int sink_len, - int type, - void *data, - int length, - void *passed_data, - int *stop); +int elapi_sink_cb(const char *sink, + int sink_len, + int type, + void *data, + int length, + void *passed_data, + int *stop); /* Internal sink cleanup function */ -int elapi_internal_sink_cleanup_handler(const char *sink, - int sink_len, - int type, - void *data, - int length, - void *passed_data, - int *stop); +int elapi_sink_free_cb(const char *sink, + int sink_len, + int type, + void *data, + int length, + void *passed_data, + int *stop); -/* Create list of the sinks */ -int elapi_internal_construct_sink_list(struct elapi_dispatcher *handle); /* Function to add a sink based on configuration */ -int elapi_internal_add_sink(struct collection_item **sink_ref, - char *sink, - struct elapi_dispatcher *handle); +int elapi_sink_add(struct collection_item **sink_ref, + char *sink, + struct elapi_dispatcher *handle); /* Create target object */ -int elapi_internal_create_target(struct elapi_target_context **context, - char *target, - struct elapi_dispatcher *handle); +int elapi_tgt_create(struct elapi_tgt_ctx **context, + char *target, + struct elapi_dispatcher *handle); /* Destroy target object */ -void elapi_internal_destroy_target(struct elapi_target_context *context); +void elapi_tgt_destroy(struct elapi_tgt_ctx *context); /* Internal target cleanup function */ -int elapi_internal_target_cleanup_handler(const char *sink, - int sink_len, - int type, - void *data, - int length, - void *passed_data, - int *stop); +int elapi_tgt_free_cb(const char *sink, + int sink_len, + int type, + void *data, + int length, + void *passed_data, + int *stop); /* Handler for logging through the targets */ -int elapi_internal_target_handler(const char *target, - int target_len, - int type, - void *data, - int length, - void *passed_data, - int *stop); +int elapi_tgt_cb(const char *target, + int target_len, + int type, + void *data, + int length, + void *passed_data, + int *stop); /* Create list of targets for a dispatcher */ -int elapi_internal_construct_target_list(struct elapi_dispatcher *handle); +int elapi_tgt_mklist(struct elapi_dispatcher *handle); /* Send ELAPI config errors into a file */ -void elapi_internal_dump_errors_to_file(struct collection_item *error_list); +void elapi_dump_ini_err(struct collection_item *error_list); /* Print dispatcher internals for testing and debugin purposes */ -void elapi_internal_print_dispatcher(struct elapi_dispatcher *handle); +void elapi_print_dispatcher(struct elapi_dispatcher *handle); #endif diff --git a/common/elapi/elapi_test/elapi_ut.c b/common/elapi/elapi_test/elapi_ut.c index ed434221..2cb94bf7 100644 --- a/common/elapi/elapi_test/elapi_ut.c +++ b/common/elapi/elapi_test/elapi_ut.c @@ -115,7 +115,7 @@ int simple_event_test(void) } /* Internal function to print dispatcher guts */ - elapi_internal_print_dispatcher(elapi_get_dispatcher()); + elapi_print_dispatcher(elapi_get_dispatcher()); printf("Simple test success!\n"); @@ -316,7 +316,7 @@ int complex_event_test(void) elapi_destroy_event_template(template); - elapi_internal_print_dispatcher(dispatcher); + elapi_print_dispatcher(dispatcher); elapi_destroy_dispatcher(dispatcher); |