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;  }  | 
