int option_synch_start = 0;
bool option_background = false;
char *option_histogram = NULL;
-
+int option_msg_to_ignore = 0;
+char *option_save_all_times = NULL;
/* Lists */
typedef struct threads {
ul_list_head_t head;
int timeout; /* number of timeouts */
struct histogram hist;
+ unsigned *times; /* Array of all measured times */
ul_list_node_t node;
} thread_data_t;
if (option_histogram)
histogram_init(&td->hist, 1000*1000/*max [us]*/, 5/*resolution [us]*/);
+
+ if (option_save_all_times) {
+ td->times = malloc(sizeof(*td->times)*option_count);
+ if (!td->times)
+ error(1, errno, "malloc times");
+ }
/* Prepare data structures for the select syscall. */
FD_ZERO (&rdset);
pthread_mutex_unlock(&mut_start);
}
- while (!IS_FINISH_FLAG() && (option_count == 0 || ping_count++ < option_count)) {
+ while (!IS_FINISH_FLAG() && (option_count == 0 || ping_count++ < option_count + option_msg_to_ignore)) {
/* Send a ping message */
pingmsg.flags=0;
pingmsg.id=ping_id;
printf("%d:%ld\n", ping_id, time);
break;
case 3:
- printf("Pong response for id %d received in %ld us\n", ping_id, time);
+ printf("Pong response %d for id %d received in %ld us\n", ping_count, ping_id, time);
break;
}
/* Update statistics */
- td->count++;
- td->mean =
- td->mean * ((double)(td->count - 1) / td->count) +
- (double)time / td->count;
- td->moment2nd =
- td->moment2nd * ((double)(td->count - 1) / td->count) +
- (double)time*time / td->count;
- if (time > td->max) td->max = time;
- if (time < td->min) td->min = time;
- if (option_histogram)
- histogram_add(&td->hist, time);
+ if (ping_count > option_msg_to_ignore) {
+ td->count++;
+ td->mean =
+ td->mean * ((double)(td->count - 1) / td->count) +
+ (double)time / td->count;
+ td->moment2nd =
+ td->moment2nd * ((double)(td->count - 1) / td->count) +
+ (double)time*time / td->count;
+ if (time > td->max) td->max = time;
+ if (time < td->min) td->min = time;
+ if (option_histogram)
+ histogram_add(&td->hist, time);
+ if (option_save_all_times)
+ td->times[ping_count - 1 - option_msg_to_ignore] = time;
+ }
total_count++;
} /* read */
}
fclose(f);
}
+ if (option_save_all_times) {
+ FILE *f;
+ char buf[100];
+ int i;
+ snprintf(buf, sizeof(buf), "%s-%d.dat", option_save_all_times, ping_id);
+ f = fopen(buf, "w");
+ for (i=0; i<option_count; i++)
+ fprintf(f, "%u\n", td->times[i]);
+ fclose(f);
+ }
+
sem_post(&finish_sem);
return (void *)ret;
}
" -b go to background (fork) after initialization, prints child PID\n"
" -c count how many messages each master sends\n"
" -d dev device (e.g. /dev/can1)\n"
+ " -e prefix save all measured times in file <prefix>-<id>.dat\n"
" -g prefix store cumulative histogram in file <prefix>-<id>.dat\n"
" -h print this help\n"
" -i id id of first master message\n"
" -l length length of the messages (0..8)\n"
+ " -n number ignore first <number> messages\n"
" -o open a device only once for all threads (doesn't work)\n" /* due to filters */
" -t timeout timeout in seconds (default 4 s)\n"
" -v be verbose (use more than once to increase verbosity)\n"
int c;
opterr = 0;
- while ((c = getopt (argc, argv, "bc:d:g:hi:l:m:os:t:vw:yrR:")) != -1)
+ while ((c = getopt (argc, argv, "bc:d:e:g:hi:l:m:n:os:t:vw:yrR:")) != -1)
switch (c)
{
case 'b':
case 'd':
option_device = optarg;
break;
+ case 'e':
+ option_save_all_times = optarg;
+ break;
case 'g':
option_histogram = optarg;
break;
case 'm':
option_masters = atoi(optarg);
break;
+ case 'n':
+ option_msg_to_ignore = atoi(optarg);
+ break;
case 'o':
option_open_once = 1;
break;