void *ping (__attribute__((unused)) void *arg)
{
- for (int i = 0; i < nb_measurements; i++) {
+ for (int i = -1; i < nb_measurements; i++) {
int duration = MINDUR * ((MAXDUR / MINDUR) * rand () / RAND_MAX);
usleep (duration);
ts_t ts1, ts2;
sys_timestamp (&ts1);
sys_timestamp (&ts2);
- deltas[i] = diff_timestamp (&ts2, &ts1);
+ if (i != -1) deltas[i] = diff_timestamp (&ts2, &ts1);
}
pthread_exit (NULL);
void *ping (__attribute__((unused)) void *arg)
{
- for (int i = 0; i < nb_measurements; i++) {
+ for (int i = -1; i < nb_measurements; i++) {
int duration = MINDUR * ((MAXDUR / MINDUR) * rand () / RAND_MAX);
sys_timestamp (&ts1);
usleep (duration);
sys_timestamp (&ts2);
- deltas[i] = diff_timestamp (&ts2, &ts1) - duration;
+ if (i != -1) deltas[i] = diff_timestamp (&ts2, &ts1) - duration;
}
pthread_exit (NULL);
usleep (TIMER);
- for (int i = 0; i < nb_measurements; i++) {
+ for (int i = -1; i < nb_measurements; i++) {
char *msg = get_msg (MSGLEN);
pthread_barrier_wait (barrier);
printf ("Receiving pong...\n");
- for (int i = 0; i < nb_measurements; i++) {
+ for (int i = -1; i < nb_measurements; i++) {
pthread_mutex_lock (&mutex);
usleep (TIMER);
}
sys_timestamp (&ts2);
- deltas[i] = diff_timestamp (&ts2, &ts1);
+ if (i != -1) deltas[i] = diff_timestamp (&ts2, &ts1);
}
mq_close (mq_in);
usleep (TIMER);
- for (int i = 0; i < nb_measurements; i++) {
+ for (int i = -1; i < nb_measurements; i++) {
char *msg = get_msg (MSGLEN);
pthread_barrier_wait (barrier);
printf ("Receiving pong...\n");
- for (int i = 0; i < nb_measurements; i++) {
+ for (int i = -1; i < nb_measurements; i++) {
pthread_mutex_lock (&mutex);
usleep (TIMER);
}
sys_timestamp (&ts2);
- deltas[i] = diff_timestamp (&ts2, &ts1);
+ if (i != -1) deltas[i] = diff_timestamp (&ts2, &ts1);
}
close (fdin);
void *ping (__attribute__((unused)) void *arg)
{
- for (int i = 0; i < nb_measurements; i++) {
+ for (int i = -1; i < nb_measurements; i++) {
ts_t ts1;
sys_timestamp (&ts1);
ts_t ts2;
sys_timestamp (&ts2);
- deltas[i] = diff_timestamp (&ts2, &ts1);
+ if (i != -1) deltas[i] = diff_timestamp (&ts2, &ts1);
}
pthread_exit (NULL);
void *ping (__attribute__((unused)) void *arg)
{
- for (int i = 0; i < nb_measurements; i++) {
+ for (int i = -1; i < nb_measurements; i++) {
sys_timestamp (&ts1);
pthread_join(posix_t, NULL);
- deltas[i] = diff_timestamp (&ts2, &ts1);
+ if (i != -1) deltas[i] = diff_timestamp (&ts2, &ts1);
}
pthread_exit (NULL);
usleep (TIMER);
- for (int i = 0; i < nb_measurements; i++) {
+ for (int i = -1; i < nb_measurements; i++) {
char *msg = get_msg (MSGLEN);
pthread_barrier_wait (barrier);
printf ("Receiving pong...\n");
- for (int i = 0; i < nb_measurements; i++) {
+ for (int i = -1; i < nb_measurements; i++) {
pthread_mutex_lock (&mutex);
usleep (TIMER);
pthread_exit (NULL);
}
sys_timestamp (&ts2);
- deltas[i] = diff_timestamp (&ts2, &ts1);
+ if (i != -1) deltas[i] = diff_timestamp (&ts2, &ts1);
}
close (sock);