diff options
Diffstat (limited to 'libglusterfs/src/event-history.c')
-rw-r--r-- | libglusterfs/src/event-history.c | 81 |
1 files changed, 40 insertions, 41 deletions
diff --git a/libglusterfs/src/event-history.c b/libglusterfs/src/event-history.c index 95484a4322b..4845330f62b 100644 --- a/libglusterfs/src/event-history.c +++ b/libglusterfs/src/event-history.c @@ -12,72 +12,71 @@ #include "libglusterfs-messages.h" eh_t * -eh_new (size_t buffer_size, gf_boolean_t use_buffer_once, - void (*destroy_buffer_data) (void *data)) +eh_new(size_t buffer_size, gf_boolean_t use_buffer_once, + void (*destroy_buffer_data)(void *data)) { - eh_t *history = NULL; - buffer_t *buffer = NULL; + eh_t *history = NULL; + buffer_t *buffer = NULL; - history = GF_CALLOC (1, sizeof (eh_t), gf_common_mt_eh_t); - if (!history) { - goto out; - } + history = GF_CALLOC(1, sizeof(eh_t), gf_common_mt_eh_t); + if (!history) { + goto out; + } - buffer = cb_buffer_new (buffer_size, use_buffer_once, - destroy_buffer_data); - if (!buffer) { - GF_FREE (history); - history = NULL; - goto out; - } + buffer = cb_buffer_new(buffer_size, use_buffer_once, destroy_buffer_data); + if (!buffer) { + GF_FREE(history); + history = NULL; + goto out; + } - history->buffer = buffer; + history->buffer = buffer; - pthread_mutex_init (&history->lock, NULL); + pthread_mutex_init(&history->lock, NULL); out: - return history; + return history; } void -eh_dump (eh_t *history, void *data, - int (dump_fn) (circular_buffer_t *buffer, void *data)) +eh_dump(eh_t *history, void *data, + int(dump_fn)(circular_buffer_t *buffer, void *data)) { - if (!history) { - gf_msg_debug ("event-history", 0, "history is NULL"); - goto out; - } + if (!history) { + gf_msg_debug("event-history", 0, "history is NULL"); + goto out; + } - cb_buffer_dump (history->buffer, data, dump_fn); + cb_buffer_dump(history->buffer, data, dump_fn); out: - return; + return; } int -eh_save_history (eh_t *history, void *data) +eh_save_history(eh_t *history, void *data) { - int ret = -1; + int ret = -1; - ret = cb_add_entry_buffer (history->buffer, data); + ret = cb_add_entry_buffer(history->buffer, data); - return ret; + return ret; } int -eh_destroy (eh_t *history) +eh_destroy(eh_t *history) { - if (!history) { - gf_msg ("event-history", GF_LOG_INFO, 0, LG_MSG_INVALID_ARG, - "history for the xlator is NULL"); - return -1; - } + if (!history) { + gf_msg("event-history", GF_LOG_INFO, 0, LG_MSG_INVALID_ARG, + "history for the xlator is NULL"); + return -1; + } - cb_buffer_destroy (history->buffer); - history->buffer = NULL; + cb_buffer_destroy(history->buffer); + history->buffer = NULL; - pthread_mutex_destroy (&history->lock); + pthread_mutex_destroy(&history->lock); - GF_FREE (history); + GF_FREE(history); - return 0; + return 0; } |