1

#include "logwatch.h"

     2

#include "../log.h"

     3

     4

#include <stdlib.h>

     5

     6

void logwatch_source_on_line (char *line, void *arg)

     7

{

     8

    struct logwatch_source *source = arg;

     9

    10

    log_info("%s", line);

    11

}

    12

    13

void logwatch_source_on_error (struct error_info *err, void *arg)

    14

{

    15

    struct logwatch_source *source = arg;

    16

    17

    log_error("%s", error_msg(err));

    18

}

    19

    20

static const struct line_proto_callbacks lp_callbacks = {

    21

    .on_line    = logwatch_source_on_line,

    22

    .on_error   = logwatch_source_on_error,

    23

};

    24

    25

/**

    26

 * Initialize with the given sock

    27

 */

    28

err_t logwatch_source_init (struct logwatch_source *source, struct logwatch *ctx, struct sock_stream *stream, struct error_info *err)

    29

{

    30

    source->ctx = ctx;

    31

    32

    // create the lp to wrap the sock

    33

    if (line_proto_create(&source->lp, stream, LOGWATCH_SOURCE_LINE_MAX, &lp_callbacks, source, err))

    34

        goto error;

    35

    36

    // add to logwatch_sources

    37

    TAILQ_INSERT_TAIL(&ctx->sources, source, logwatch_sources);

    38

    39

    // ok

    40

    return SUCCESS;

    41

    42

error:    

    43

    return ERROR_CODE(err);

    44

}

    45

    46

struct logwatch_source* logwatch_open_fifo (struct logwatch *ctx, const char *path, struct error_info *err)

    47

{

    48

    struct logwatch_source *source;

    49

    struct sock_stream *stream = NULL;

    50

    51

    // alloc

    52

    if ((source = calloc(1, sizeof(*source))) == NULL)

    53

        JUMP_SET_ERROR(err, ERR_CALLOC);

    54

    55

    // open

    56

    if (fifo_open_read(&stream, path, err))

    57

        goto error;

    58

    59

    // init

    60

    if (logwatch_source_init(source, ctx, stream, err))

    61

        goto error;

    62

    63

    // ok

    64

    return source;

    65

    66

error:    

    67

    // cleanup

    68

    if (stream)

    69

        sock_stream_release(stream);

    70

    71

    if (source)

    72

        free(source);

    73

    74

    return NULL;

    75

}

    76

    77

void logwatch_source_destroy (struct logwatch_source *source)

    78

{

    79

    // release the line_proto

    80

    if (source->lp)

    81

        line_proto_release(source->lp);

    82

    83

    // remove from the list

    84

    TAILQ_REMOVE(&source->ctx->sources, source, logwatch_sources);

    85

    86

    free(source);

    87

}