diff options
Diffstat (limited to 'common/src/tfe_future.cpp')
| -rw-r--r-- | common/src/tfe_future.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/common/src/tfe_future.cpp b/common/src/tfe_future.cpp index 3e3fc9f..922eadc 100644 --- a/common/src/tfe_future.cpp +++ b/common/src/tfe_future.cpp @@ -18,6 +18,7 @@ struct future_promise_instance int fsid_f_num; long long f_num; int no_stats; + int statsd_cycle; MESA_htable_handle name_table; char statsd_server_ip[256]; int statsd_server_port; @@ -72,6 +73,7 @@ void future_promise_library_init(const char* profile) MESA_load_profile_string_def(profile, "STAT", "statsd_server", g_FP_instance.statsd_server_ip, sizeof(g_FP_instance.statsd_server_ip), ""); MESA_load_profile_int_def(profile, "STAT", "statsd_port", &(g_FP_instance.statsd_server_port), 0); + MESA_load_profile_int_def(profile, "STAT", "statsd_cycle", &(g_FP_instance.statsd_cycle), 2); MESA_load_profile_string_def(profile, "STAT", "histogram_bins", g_FP_instance.histogram_bins, sizeof(g_FP_instance.histogram_bins), FP_HISTOGRAM_BINS); MESA_load_profile_int_def(profile, "STAT", "print_diff", @@ -112,8 +114,7 @@ void future_promise_library_init(const char* profile) FS_set_para(fs, PRINT_MODE, &value, sizeof(value)); value=1; FS_set_para(fs, CREATE_THREAD, &value, sizeof(value)); - value=2; - FS_set_para(fs, STAT_CYCLE, &value, sizeof(value)); + FS_set_para(fs, STAT_CYCLE, &g_FP_instance.statsd_cycle, sizeof(g_FP_instance.statsd_cycle)); if(strlen(g_FP_instance.statsd_server_ip)>0 && g_FP_instance.statsd_server_port!=0) { FS_set_para(fs, STATS_SERVER_IP, g_FP_instance.statsd_server_ip, strlen(g_FP_instance.statsd_server_ip)+1); |