X-Git-Url: https://git.octo.it/?a=blobdiff_plain;f=src%2Famqp1.c;h=87bb50cf8412a1b45efba4b0d59289bbe685ddbe;hb=24b87484c7fd2e0998682db6f77e54d8cdc459d4;hp=635af0f7cfe4d921e73a9bc56ef63dfe2ff6cfcd;hpb=a9191cc20f0a5af022ae1d9482af2eaf0098a46a;p=collectd.git diff --git a/src/amqp1.c b/src/amqp1.c index 635af0f7..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,15 +471,16 @@ 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) { - ERROR("amqp1 plugin: format graphite failed"); + ERROR("amqp1 plugin: format json failed"); cd_message_free(cdm); return -1; }