summaryrefslogtreecommitdiffstats
path: root/exporting/process_data.c
diff options
context:
space:
mode:
authorAustin S. Hemmelgarn <austin@netdata.cloud>2020-04-13 10:32:33 -0400
committerAustin S. Hemmelgarn <austin@netdata.cloud>2020-04-13 10:32:33 -0400
commit983a26d1a2c110b35db252b4b79c3f03eb4eeb4b (patch)
tree85d42c30bc81514bd5c18aa564497e439290523b /exporting/process_data.c
parent5a12b4a7e42587058b9b42871a1316545d527a57 (diff)
Revert "Revert changes since v1.21 in pereparation for hotfix release."
Diffstat (limited to 'exporting/process_data.c')
-rw-r--r--exporting/process_data.c17
1 files changed, 15 insertions, 2 deletions
diff --git a/exporting/process_data.c b/exporting/process_data.c
index c902aabdda..f2442e701c 100644
--- a/exporting/process_data.c
+++ b/exporting/process_data.c
@@ -206,7 +206,7 @@ int start_host_formatting(struct engine *engine, RRDHOST *host)
* Start chart formatting for every connector instance's buffer
*
* @param engine an engine data structure.
- * @param a chart.
+ * @param st a chart.
* @return Returns 0 on success, 1 on failure.
*/
int start_chart_formatting(struct engine *engine, RRDSET *st)
@@ -242,7 +242,7 @@ int metric_formatting(struct engine *engine, RRDDIM *rd)
error("EXPORTING: cannot format metric for %s", instance->config.name);
return 1;
}
- instance->stats.chart_buffered_metrics++;
+ instance->stats.buffered_metrics++;
}
}
@@ -390,6 +390,19 @@ int flush_host_labels(struct instance *instance, RRDHOST *host)
}
/**
+ * Update stats for buffered bytes
+ *
+ * @param instance an instance data structure.
+ * @return Always returns 0.
+ */
+int simple_connector_update_buffered_bytes(struct instance *instance)
+{
+ instance->stats.buffered_bytes = (collected_number)buffer_strlen((BUFFER *)(instance->buffer));
+
+ return 0;
+}
+
+/**
* Notify workers
*
* Notify exporting connector instance working threads that data is ready to send.