Fix Exporiting compilaton error (#14306)
thiagoftsm committed
Jan 20, 2023 at 18:25 UTC
c036541019018e363f0aa7bd705534baeb015b09
3 files changed
+15
-15
exporting/aws_kinesis/aws_kinesis.c
+1
-1
@@ -52,7 +52,7 @@ int init_aws_kinesis_instance(struct instance *instance)
52
instance->prepare_header = NULL;
53
instance->check_response = NULL;
54
55
- instance->buffer = (void *)buffer_create(0);
55
+ instance->buffer = (void *)buffer_create(0, &netdata_buffers_statistics.buffers_exporters);
56
if (!instance->buffer) {
57
error("EXPORTING: cannot create buffer for AWS Kinesis exporting connector instance %s", instance->config.name);
58
return 1;
exporting/pubsub/pubsub.c
+1
-1
@@ -30,7 +30,7 @@ int init_pubsub_instance(struct instance *instance)
30
instance->prepare_header = NULL;
31
instance->check_response = NULL;
32
33
- instance->buffer = (void *)buffer_create(0);
33
+ instance->buffer = (void *)buffer_create(0, &netdata_buffers_statistics.buffers_exporters);
34
if (!instance->buffer) {
35
error("EXPORTING: cannot create buffer for Pub/Sub exporting connector instance %s", instance->config.name);
36
return 1;
exporting/tests/test_exporting_engine.c
+13
-13
@@ -612,7 +612,7 @@ static void test_exporting_discard_response(void **state)
612
{
613
struct engine *engine = *state;
614
615
- BUFFER *response = buffer_create(0);
615
+ BUFFER *response = buffer_create(0, NULL);
616
buffer_sprintf(response, "Test response");
617
618
assert_int_equal(exporting_discard_response(response, engine->instance_root), 0);
@@ -651,8 +651,8 @@ static void test_simple_connector_send_buffer(void **state)
651
int sock = 1;
652
int failures = 3;
653
size_t buffered_metrics = 1;
654
- BUFFER *header = buffer_create(0);
655
- BUFFER *buffer = buffer_create(0);
654
+ BUFFER *header = buffer_create(0, NULL);
655
+ BUFFER *buffer = buffer_create(0, NULL);
656
buffer_strcat(header, "test header\n");
657
buffer_strcat(buffer, "test buffer\n");
658
@@ -695,10 +695,10 @@ static void test_simple_connector_worker(void **state)
695
instance->connector_specific_data = simple_connector_data;
696
simple_connector_data->last_buffer = callocz(1, sizeof(struct simple_connector_buffer));
697
simple_connector_data->first_buffer = simple_connector_data->last_buffer;
698
- simple_connector_data->header = buffer_create(0);
699
- simple_connector_data->buffer = buffer_create(0);
700
- simple_connector_data->last_buffer->header = buffer_create(0);
701
- simple_connector_data->last_buffer->buffer = buffer_create(0);
698
+ simple_connector_data->header = buffer_create(0, NULL);
699
+ simple_connector_data->buffer = buffer_create(0, NULL);
700
+ simple_connector_data->last_buffer->header = buffer_create(0, NULL);
701
+ simple_connector_data->last_buffer->buffer = buffer_create(0, NULL);
702
strcpy(simple_connector_data->connected_to, "localhost");
703
704
buffer_sprintf(simple_connector_data->last_buffer->header, "test header");
@@ -822,7 +822,7 @@ static void test_flush_host_labels(void **state)
822
struct engine *engine = *state;
823
struct instance *instance = engine->instance_root;
824
825
- instance->labels_buffer = buffer_create(12);
825
+ instance->labels_buffer = buffer_create(12, NULL);
826
buffer_strcat(instance->labels_buffer, "check string");
827
assert_int_equal(buffer_strlen(instance->labels_buffer), 12);
828
@@ -1133,7 +1133,7 @@ static void rrd_stats_api_v1_charts_allmetrics_prometheus(void **state)
1133
{
1134
(void)state;
1135
1136
- BUFFER *buffer = buffer_create(0);
1136
+ BUFFER *buffer = buffer_create(0, NULL);
1137
1138
RRDSET *st;
1139
rrdset_foreach_read(st, localhost);
@@ -1241,8 +1241,8 @@ static void test_prometheus_remote_write_prepare_header(void **state)
1241
struct simple_connector_data *simple_connector_data = callocz(1, sizeof(struct simple_connector_data));
1242
instance->connector_specific_data = simple_connector_data;
1243
simple_connector_data->last_buffer = callocz(1, sizeof(struct simple_connector_buffer));
1244
- simple_connector_data->last_buffer->header = buffer_create(0);
1245
- simple_connector_data->last_buffer->buffer = buffer_create(0);
1244
+ simple_connector_data->last_buffer->header = buffer_create(0, NULL);
1245
+ simple_connector_data->last_buffer->buffer = buffer_create(0, NULL);
1246
strcpy(simple_connector_data->connected_to, "localhost");
1247
1248
buffer_sprintf(simple_connector_data->last_buffer->buffer, "test buffer");
@@ -1269,7 +1269,7 @@ static void test_prometheus_remote_write_prepare_header(void **state)
1269
static void test_process_prometheus_remote_write_response(void **state)
1270
{
1271
(void)state;
1272
- BUFFER *buffer = buffer_create(0);
1272
+ BUFFER *buffer = buffer_create(0, NULL);
1273
1274
buffer_sprintf(buffer, "HTTP/1.1 200 OK\r\n");
1275
assert_int_equal(process_prometheus_remote_write_response(buffer, NULL), 0);
@@ -1834,7 +1834,7 @@ static void test_format_batch_mongodb(void **state)
1834
connector_specific_data->first_buffer->next = current_buffer;
1835
connector_specific_data->last_buffer = current_buffer;
1836
1837
- BUFFER *buffer = buffer_create(0);
1837
+ BUFFER *buffer = buffer_create(0, NULL);
1838
buffer_sprintf(buffer, "{ \"metric\": \"test_metric\" }\n");
1839
instance->buffer = buffer;
1840
stats->buffered_metrics = 1;