replace `gettimeofday()` calls by `now_realtime_timeval()`
Signed-off-by: Rémi Lefèvre <remi.lefevre@parrot.com>
Rémi Lefèvre committed
Dec 9, 2016 at 09:53 UTC
85e90520db972d7ec4d6e6ddd5cb8f6151e3b911
8 files changed
+19
-19
src/apps_plugin.c
+2
-2
@@ -2159,7 +2159,7 @@ unsigned long long send_resource_usage_to_netdata() {
2159
unsigned long long cpusyst;
2160
2161
if(!last.tv_sec) {
2162
- gettimeofday(&last, NULL);
2162
+ now_realtime_timeval(&last);
2163
getrusage(RUSAGE_SELF, &me_last);
2164
2165
// the first time, give a zero to allow
@@ -2170,7 +2170,7 @@ unsigned long long send_resource_usage_to_netdata() {
2170
cpusyst = 0;
2171
}
2172
else {
2173
- gettimeofday(&now, NULL);
2173
+ now_realtime_timeval(&now);
2174
getrusage(RUSAGE_SELF, &me);
2175
2176
usec = dt_usec(&now, &last);
src/plugin_checks.c
+3
-3
@@ -30,12 +30,12 @@ void *checks_main(void *ptr)
30
rrddim_add(check3, "netdata", NULL, 1, 1, RRDDIM_ABSOLUTE);
31
rrddim_add(check3, "apps.plugin", NULL, 1, 1, RRDDIM_ABSOLUTE);
32
33
- gettimeofday(&last, NULL);
33
+ now_realtime_timeval(&last);
34
while(1) {
35
usleep(susec);
36
37
// find the time to sleep in order to wait exactly update_every seconds
38
- gettimeofday(&now, NULL);
38
+ now_realtime_timeval(&now);
39
loop_usec = dt_usec(&now, &last);
40
usec = loop_usec - susec;
41
debug(D_PROCNETDEV_LOOP, "CHECK: last loop took %llu usec (worked for %llu, sleeped for %llu).", loop_usec, usec, susec);
@@ -71,7 +71,7 @@ void *checks_main(void *ptr)
71
72
if(!apps_cpu) apps_cpu = rrdset_find("apps.cpu");
73
if(check3->counter_done) rrdset_next_usec(check3, loop_usec);
74
- gettimeofday(&loop, NULL);
74
+ now_realtime_timeval(&loop);
75
rrddim_set(check3, "caller", (long long) dt_usec(&loop, &check1->last_collected_time));
76
rrddim_set(check3, "netdata", (long long) dt_usec(&loop, &check2->last_collected_time));
77
if(apps_cpu) rrddim_set(check3, "apps.plugin", (long long) dt_usec(&loop, &apps_cpu->last_collected_time));
src/plugin_idlejitter.c
+2
-2
@@ -33,9 +33,9 @@ void *cpuidlejitter_main(void *ptr)
33
34
while(susec < (rrd_update_every * 1000000ULL)) {
35
36
- gettimeofday(&before, NULL);
36
+ now_realtime_timeval(&before);
37
sleep_usec(sleep_ms * 1000);
38
- gettimeofday(&after, NULL);
38
+ now_realtime_timeval(&after);
39
40
// calculate the time it took for a full loop
41
usec = dt_usec(&after, &before);
src/plugin_nfacct.c
+2
-2
@@ -93,7 +93,7 @@ void *nfacct_main(void *ptr) {
93
unsigned long long usec = 0, susec = 0;
94
RRDSET *st = NULL;
95
96
- gettimeofday(&last, NULL);
96
+ now_realtime_timeval(&last);
97
98
// ------------------------------------------------------------------------
99
@@ -131,7 +131,7 @@ void *nfacct_main(void *ptr) {
131
132
// --------------------------------------------------------------------
133
134
- gettimeofday(&now, NULL);
134
+ now_realtime_timeval(&now);
135
usec = dt_usec(&now, &last) - susec;
136
debug(D_NFACCT_LOOP, "nfacct.plugin: last loop took %llu usec (worked for %llu, sleeped for %llu).", usec + susec, usec, susec);
137
src/plugins_d.c
+1
-1
@@ -341,7 +341,7 @@ void *pluginsd_worker_thread(void *arg)
341
else if(likely(hash == STOPPING_WAKE_ME_UP_PLEASE_HASH && !strcmp(s, "STOPPING_WAKE_ME_UP_PLEASE"))) {
342
error("PLUGINSD: '%s' (pid %d) called STOPPING_WAKE_ME_UP_PLEASE.", cd->fullfilename, cd->pid);
343
344
- gettimeofday(&now, NULL);
344
+ now_realtime_timeval(&now);
345
if(unlikely(!usec && !susec)) {
346
// our first run
347
susec = cd->rrd_update_every * 1000000ULL;
src/rrd.c
+5
-5
@@ -653,7 +653,7 @@ RRDDIM *rrddim_add(RRDSET *st, const char *id, const char *name, long multiplier
653
if(rrd_memory_mode != RRD_MEMORY_MODE_RAM) rd = (RRDDIM *)mymmap(fullfilename, size, ((rrd_memory_mode == RRD_MEMORY_MODE_MAP)?MAP_SHARED:MAP_PRIVATE), 1);
654
if(rd) {
655
struct timeval now;
656
- gettimeofday(&now, NULL);
656
+ now_realtime_timeval(&now);
657
658
if(strcmp(rd->magic, RRDDIMENSION_MAGIC) != 0) {
659
errno = 0;
@@ -977,7 +977,7 @@ collected_number rrddim_set_by_pointer(RRDSET *st, RRDDIM *rd, collected_number
977
{
978
debug(D_RRD_CALLS, "rrddim_set_by_pointer() for chart %s, dimension %s, value " COLLECTED_NUMBER_FORMAT, st->name, rd->name, value);
979
980
- gettimeofday(&rd->last_collected_time, NULL);
980
+ now_realtime_timeval(&rd->last_collected_time);
981
rd->collected_value = value;
982
rd->updated = 1;
983
rd->counter++;
@@ -1010,7 +1010,7 @@ void rrdset_next_usec_unfiltered(RRDSET *st, unsigned long long microseconds)
1010
void rrdset_next_usec(RRDSET *st, unsigned long long microseconds)
1011
{
1012
struct timeval now;
1013
- gettimeofday(&now, NULL);
1013
+ now_realtime_timeval(&now);
1014
1015
if(unlikely(!st->last_collected_time.tv_sec)) {
1016
// the first entry
@@ -1102,7 +1102,7 @@ unsigned long long rrdset_done(RRDSET *st)
1102
if(unlikely(!st->last_collected_time.tv_sec)) {
1103
// it is the first entry
1104
// set the last_collected_time to now
1105
- gettimeofday(&st->last_collected_time, NULL);
1105
+ now_realtime_timeval(&st->last_collected_time);
1106
timeval_align(&st->last_collected_time, st->update_every);
1107
1108
last_collect_ut = st->last_collected_time.tv_sec * 1000000ULL + st->last_collected_time.tv_usec - update_every_ut;
@@ -1145,7 +1145,7 @@ unsigned long long rrdset_done(RRDSET *st)
1145
1146
st->usec_since_last_update = update_every_ut;
1147
1148
- gettimeofday(&st->last_collected_time, NULL);
1148
+ now_realtime_timeval(&st->last_collected_time);
1149
timeval_align(&st->last_collected_time, st->update_every);
1150
1151
unsigned long long ut = st->last_collected_time.tv_sec * 1000000ULL + st->last_collected_time.tv_usec - st->usec_since_last_update;
src/unit_test.c
+1
-1
@@ -1130,7 +1130,7 @@ int unit_test(long delay, long shift)
1130
if(do_absi) rrddim_set(st, "percentage-of-incremental-row", i);
1131
1132
if(!c) {
1133
- gettimeofday(&st->last_collected_time, NULL);
1133
+ now_realtime_timeval(&st->last_collected_time);
1134
st->last_collected_time.tv_usec = shift;
1135
}
1136
src/web_client.c
+3
-3
@@ -125,7 +125,7 @@ void web_client_reset(struct web_client *w) {
125
126
if(likely(w->last_url[0])) {
127
struct timeval tv;
128
- gettimeofday(&tv, NULL);
128
+ now_realtime_timeval(&tv);
129
130
size_t size = (w->mode == WEB_CLIENT_MODE_FILECOPY)?w->response.rlen:w->response.data->len;
131
size_t sent = size;
@@ -1953,7 +1953,7 @@ void web_client_process(struct web_client *w) {
1953
#endif
1954
1955
// start timing us
1956
- gettimeofday(&w->tv_in, NULL);
1956
+ now_realtime_timeval(&w->tv_in);
1957
1958
if(unlikely(!hash_api)) {
1959
hash_api = simple_hash("api");
@@ -2165,7 +2165,7 @@ void web_client_process(struct web_client *w) {
2165
}
2166
}
2167
2168
- gettimeofday(&w->tv_ready, NULL);
2168
+ now_realtime_timeval(&w->tv_ready);
2169
w->response.sent = 0;
2170
w->response.code = code;
2171