TT#101150 add support for local copy-out of stats

Change-Id: I1752fa8fe94799eedbac7f3fb674a61a0b6de162

daemon/call.c

@@ -560,7 +560,7 @@ void call_timer(void *ptr) {
 		call_timer_iterator(c, &hlp);
 	ITERATE_CALL_LIST_NEXT_END(c);
 
-	stats_counters_ax_calc_avg(&rtpe_stats, run_diff_us);
+	stats_counters_ax_calc_avg(&rtpe_stats, run_diff_us, NULL);
 
 	/* update statistics regarding requests per second */
 	update_requests_per_second_stats(&rtpe_totalstats_interval.offers_ps, atomic64_get(&rtpe_stats.intv.offers));

include/statistics.h

@@ -151,16 +151,22 @@ GQueue *statistics_gather_metrics(void);
 void statistics_free_metrics(GQueue **);
 const char *statistics_ng(bencode_item_t *input, bencode_item_t *output);
 
-INLINE void stats_counters_ax_calc_avg1(atomic64 *ax_var, atomic64 *intv_var, long long run_diff_us) {
+INLINE void stats_counters_ax_calc_avg1(atomic64 *ax_var, atomic64 *intv_var, atomic64 *loc_var,
+		long long run_diff_us)
+{
 	uint64_t tmp = atomic64_get_set(ax_var, 0);
+	if (loc_var)
+		atomic64_set(loc_var, tmp);
 	atomic64_set(intv_var, tmp * 1000000LL / run_diff_us);
 }
 
-INLINE void stats_counters_ax_calc_avg(struct global_stats_ax *stats, long long run_diff_us) {
+INLINE void stats_counters_ax_calc_avg(struct global_stats_ax *stats, long long run_diff_us,
+		struct global_stats_counter *loc)
+{
 	if (run_diff_us <= 0)
 		return;
 
-#define F(x) stats_counters_ax_calc_avg1(&stats->ax.x, &stats->intv.x, run_diff_us);
+#define F(x) stats_counters_ax_calc_avg1(&stats->ax.x, &stats->intv.x, loc ? &loc->x : NULL, run_diff_us);
 #include "counter_stats_fields.inc"
 #undef F
 }