diff --git a/src/receive.c b/src/receive.c index e573011da..06239e9a9 100644 --- a/src/receive.c +++ b/src/receive.c @@ -11,6 +11,7 @@ #include #include #include +#include #include #include @@ -64,6 +65,13 @@ int main(int argc, char *argv[]) while (1) { msg_recv(&m, &n); + +#if 1 + struct timespec ts; + clock_gettime(CLOCK_REALTIME, &ts); + fprintf(stdout, "%17.6f", ts.tv_sec + ts.tv_nsec / 1e9); +#endif + msg_fprint(stdout, &m); } diff --git a/src/send.c b/src/send.c index 344d96f3f..9bf5aefbf 100644 --- a/src/send.c +++ b/src/send.c @@ -11,6 +11,7 @@ #include #include #include +#include #include #include @@ -74,6 +75,13 @@ int main(int argc, char *argv[]) while (!feof(stdin)) { msg_fscan(stdin, &m); msg_send(&m, &n); + +#if 1 + struct timespec ts; + clock_gettime(CLOCK_REALTIME, &ts); + fprintf(stdout, "%17.6f", ts.tv_sec + ts.tv_nsec / 1e9); +#endif + msg_fprint(stdout, &m); } diff --git a/src/test.c b/src/test.c index 02b3b136d..675cda4e0 100644 --- a/src/test.c +++ b/src/test.c @@ -74,6 +74,12 @@ int main(int argc, char *argv[]) double rtt, rtt_max = LLONG_MIN, rtt_min = LLONG_MAX, avg = 0; int run = 0; + +#if 1 /* Print header */ + fprintf(stdout, "%17s", "timestamp"); +#endif + fprintf(stdout, "%10s%10s%10s%10s\n", "rtt", "min", "max", "avg"); + while (1) { clock_gettime(CLOCK_REALTIME, ts1); msg_send(&m, &n); @@ -89,7 +95,13 @@ int main(int argc, char *argv[]) avg += rtt; run++; - info("rtt %.3f min %.3f max %.3f avg %.3f", 1e3 * rtt, 1e3 * rtt_min, 1e3 * rtt_max, 1e3 * avg / run); +#if 1 + struct timespec ts; + clock_gettime(CLOCK_REALTIME, &ts); + fprintf(stdout, "%17.6f", ts.tv_sec + ts.tv_nsec / 1e9); +#endif + + fprintf(stdout, "%10.3f%10.3f%10.3f%10.3f\n", 1e3 * rtt, 1e3 * rtt_min, 1e3 * rtt_max, 1e3 * avg / run); m.sequence++; }