8 #include <sys/socket.h>
9 #include <netinet/in.h>
11 #include <arpa/inet.h>
12 #include <linux/can.h>
19 * [ ] consider can timestamp
24 #define printdbg(...) printf( __VA_ARGS__ )
29 #define BENCH_FLAG_N 1
30 #define BENCH_FLAG_SRC 2
31 #define BENCH_FLAG_DST 4
40 int can_sock_create( int ifindex );
41 int udp_sock_create( struct in_addr ip, unsigned int port );
48 struct cegw_if ceif[2]; /* 0 -> src, 1 -> dst */
52 pthread_barrier_t barrier;
53 struct timespec* tx_time, * rx_time;
55 void* thr_recv( void* arg )
62 if( d.ceif[1].type == IF_CAN )
63 sock = can_sock_create( d.ceif[1].can.ifindex );
65 sock = udp_sock_create( d.ceif[1].eth.ip, d.ceif[1].eth.port );
69 pthread_barrier_wait( &barrier );
72 for( i=0; i<d.n; i++ )
74 recvfrom( sock, &cf, sizeof(cf), 0, NULL, 0 );
75 seq = *((int*)cf.data);
76 clock_gettime( CLOCK_REALTIME, &rx_time[ seq ] );
77 printdbg( "recv: (id=%d)%d\n", cf.can_id, seq );
78 if( d.mode == BENCH_MODE_ONEATTIME )
80 pthread_barrier_wait( &barrier );
88 int timespec_subtract( struct timespec *result, struct timespec *x, struct timespec *yy )
90 struct timespec ylocal = *yy, *y = &ylocal;
91 /* Perform the carry for the later subtraction by updating Y. */
92 if( x->tv_nsec < y->tv_nsec )
94 int nsec = (y->tv_nsec - x->tv_nsec) / 1000000000 + 1;
95 y->tv_nsec -= 1000000000 * nsec;
98 if (x->tv_nsec - y->tv_nsec > 1000000000)
100 int nsec = (x->tv_nsec - y->tv_nsec) / 1000000000;
101 y->tv_nsec += 1000000000 * nsec;
105 /* Compute the time remaining to wait.
106 * `tv_nsec' is certainly positive. */
107 result->tv_sec = x->tv_sec - y->tv_sec;
108 result->tv_nsec = x->tv_nsec - y->tv_nsec;
109 /* Return 1 if result is negative. */
110 return x->tv_sec < y->tv_sec;
113 int udp_sock_create( struct in_addr ip, unsigned int port )
115 struct sockaddr_in addr_udp;
118 addr_udp.sin_family = AF_INET;
119 addr_udp.sin_port = htons( port );
120 addr_udp.sin_addr.s_addr = INADDR_ANY;
122 udp_sock = socket( PF_INET, SOCK_DGRAM, IPPROTO_UDP );
125 fprintf( stderr, "error: udp socket creation failed\n" );
129 if( bind(udp_sock, (struct sockaddr*)&addr_udp, sizeof(addr_udp)) != 0 )
131 fprintf( stderr, "error: udp socket binding failed\n" );
140 * @return can socket fd, or -1 on failure
142 int can_sock_create( int ifindex )
145 struct sockaddr_can addr_can;
147 addr_can.can_family = AF_CAN;
148 addr_can.can_ifindex = ifindex;
150 can_sock = socket( PF_CAN, SOCK_RAW, CAN_RAW );
153 fprintf( stderr, "error: can socket creation failed\n" );
157 if( bind(can_sock, (struct sockaddr*)&addr_can, sizeof(addr_can)) != 0 )
159 fprintf( stderr, "error: can socket binding failed\n" );
166 void dump_arg( int argc, char* argv[] )
171 for( i=0; i<argc; i++ )
173 printf( "%s ", argv[i] );
178 int read_mode( char* in )
180 if( strcmp( in, "asap" ) == 0 )
181 return BENCH_MODE_ASAP;
182 if( strcmp( in, "oneattime") == 0 )
183 return BENCH_MODE_ONEATTIME;
184 if( strcmp( in, "period" ) == 0 )
185 return BENCH_MODE_PERIOD;
187 return BENCH_MODE_UNDEF;
190 int main( int argc, char* argv[] )
203 d.mode = BENCH_MODE_ASAP;
205 struct option longopt[] =
207 { "mode", 0, NULL, 'm' },
213 opt = getopt( argc, argv, "s:d:m:n:" );
219 d.optflag |= BENCH_FLAG_SRC;
220 if( read_if( optarg, &d.ceif[0] ) != 0 )
227 d.optflag |= BENCH_FLAG_DST;
228 if( read_if( optarg, &d.ceif[1] ) )
235 tmp = read_mode( optarg );
236 if( tmp == BENCH_MODE_UNDEF )
238 perr( "benchmarking mode unknown" );
244 d.optflag |= BENCH_FLAG_N;
245 d.n = atoi( optarg );
254 /* '-n' option is mandatory and its value is >0 */
255 if( d.optflag & BENCH_FLAG_N )
259 perr( "'-n' should be at least 1." );
263 perr( "'-n' is mandatory." );
267 /* '-s' and '-d' should be defined and different iftype */
268 if( (d.optflag & BENCH_FLAG_SRC) && (d.optflag & BENCH_FLAG_DST) )
270 if( !(d.ceif[0].type == IF_CAN && d.ceif[1].type == IF_ETH_UDP) &&
271 !(d.ceif[0].type == IF_ETH_UDP && d.ceif[1].type == IF_CAN ) )
273 perr( "'-s' and '-d' should be different interface type." );
278 perr( "'-s' and '-d' should be defined." );
282 tx_time = malloc( d.n*sizeof(struct timespec) );
283 rx_time = malloc( d.n*sizeof(struct timespec) );
285 pthread_barrier_init( &barrier, NULL, 2 );
286 pthread_create( &thr, NULL, thr_recv, NULL );
289 struct sockaddr* addr;
290 struct sockaddr_can addr_can;
291 struct sockaddr_in addr_udp;
294 if( d.ceif[0].type == IF_CAN )
296 sock = socket( PF_CAN, SOCK_RAW, CAN_RAW );
297 addr_can.can_family = AF_CAN;
298 addr_can.can_ifindex = d.ceif[0].can.ifindex;
299 addr = (struct sockaddr*)&addr_can;
300 addr_size = sizeof( addr_can );
304 sock = socket( PF_INET, SOCK_DGRAM, IPPROTO_UDP );
305 addr_udp.sin_family = AF_INET;
306 addr_udp.sin_addr = d.ceif[0].eth.ip;
307 addr_udp.sin_port = htons( d.ceif[0].eth.port );
308 addr = (struct sockaddr*)&addr_udp;
309 addr_size = sizeof( addr_udp );
311 if( sock < 0 ) /* ToDo: ? */
314 pthread_barrier_wait( &barrier );
317 for( i=0; i<d.n; i++ )
321 memcpy( cf.data, &i, sizeof(i) );
323 clock_gettime( CLOCK_REALTIME, &tx_time[cf.data[0]] );
324 ret = sendto( sock, &cf, sizeof(cf), 0, addr, addr_size ); /* ToDo: check ret */
325 printdbg( "sending(%d)\n", ret );
326 if( d.mode == BENCH_MODE_ONEATTIME )
328 pthread_barrier_wait( &barrier );
332 close( sock ); /* ToDo: shutdown? */
333 pthread_join( thr, NULL );
336 dump_arg( argc, argv );
337 for( i=0; i<d.n; i++ )
339 timespec_subtract( &res, &rx_time[i], &tx_time[i] );
341 time = res.tv_sec*1000000000.0f + (float)res.tv_nsec;
342 printf( "%f\t", time );
346 pthread_barrier_destroy( &barrier );