X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Famqp1.c;h=87bb50cf8412a1b45efba4b0d59289bbe685ddbe;hb=f9bdd06f48889a85f3d0121dfe93339203c95da3;hp=072598c0c6457df0f40084bb497e2e8151259cb7;hpb=16ce118c7a69efb49a289b07958bc5a22dc0942e;p=collectd.git diff --git a/src/amqp1.c b/src/amqp1.c index 072598c0..87bb50cf 100644 --- a/src/amqp1.c +++ b/src/amqp1.c @@ -372,7 +372,7 @@ static int amqp1_notify(notification_t const *n, } cd_message_t *cdm = malloc(sizeof(*cdm)); - if (cdm == NULL ){ + if (cdm == NULL) { ERROR("amqp1 plugin: notify failed"); return -1; } @@ -471,11 +471,12 @@ static int amqp1_write(const data_set_t *ds, const value_list_t *vl, /* {{{ */ format_json_initialize((char *)cdm->mbuf.start, &bfill, &bfree); format_json_value_list((char *)cdm->mbuf.start, &bfill, &bfree, ds, vl, instance->store_rates); - status= format_json_finalize((char *)cdm->mbuf.start, &bfill, &bfree); + status = format_json_finalize((char *)cdm->mbuf.start, &bfill, &bfree); if (status != 0) { - ERROR("amqp1 plugin: format_json_finalize failed with status %i.", status); + ERROR("amqp1 plugin: format_json_finalize failed with status %i.", + status); cd_message_free(cdm); - return(status); + return status; } cdm->mbuf.size = strlen(cdm->mbuf.start); if (cdm->mbuf.size >= BUFSIZE) {