1 #include <stdio.h> // perror
2 #include <stdlib.h> // exit
3 #include <unistd.h> // sleep
7 #include "frescan_servers.h"
8 #include "frescan_debug.h"
11 #define LOG_DEVICE LOG_ETHERNET
13 #define NUM_MSG_BYTES 8 // 8 32 64 512 1488
14 #define ENABLE_DEBUG false
15 #define NUM_MEASURES 100
17 #define LOCAL_NODE 0 // 0 1
19 #include <misc/time_measurement_hwtime.h>
20 #include <misc/logger.h>
22 static const trace_point_id_t BEGIN = 0;
23 static const trace_point_id_t END = 1;
28 frescan_send_params_t send_params;
29 frescan_recv_params_t recv_params;
30 char msg[1500]; // big enough for all the messages
31 frescan_init_params_t init_params;
39 DEBUG(ENABLE_DEBUG, ">> Initializing FRESCAN (me:%u)\n", me);
41 init_params.net = NETWORK;
42 init_params.node = LOCAL_NODE;
43 init_params.tx_fp_max_prio = 10;
44 init_params.rx_num_of_channels = 5;
45 init_params.rx_channel_max_prio = NULL;
47 ret = frescan_init(&init_params);
48 if (ret != 0) ERROR ("could not init FRESCAN");
50 DEBUG(ENABLE_DEBUG, ">> Enter in loop for sending packets\n");
52 send_params.net = NETWORK;
53 send_params.channel = 0;
54 send_params.flags = FRESCAN_FP | FRESCAN_ASYNC;
56 send_params.to = (me == 0)? 1 : 0;
58 recv_params.net = NETWORK;
59 recv_params.channel = 0;
60 recv_params.flags = FRESCAN_SYNC;
63 DEBUG(ENABLE_DEBUG, ">> Init logger and timer measurements\n");
65 ret = logger_init(LOG_DEVICE);
68 ret = time_measure_hwtime_init(BEGIN, "frescan_begin");
71 ret = time_measure_hwtime_init(END, "frescan_end");
74 DEBUG(ENABLE_DEBUG, ">> Enter in loop for send-recv packets\n");
76 for (i=0; i<NUM_MEASURES; i++) {
77 time_measure_hwtime_set_timestamp(BEGIN);
79 ret = frescan_send(&send_params,
82 if (ret != 0) ERROR ("could not send message\n");
84 ret = frescan_recv(&recv_params,
90 if (ret != 0) ERROR ("could not receive message");
92 time_measure_hwtime_set_timestamp(END);
94 DEBUG(ENABLE_DEBUG, ">> received %d bytes\n", recv_bytes);
97 ret = time_measure_hwtime_write_membuffer(BEGIN);
100 ret = time_measure_hwtime_write_membuffer(END);
103 while (logger_manual_call() > 0);
106 DEBUG(ENABLE_DEBUG, ">> Enter in loop for recv-send packets\n");
109 ret = frescan_recv(&recv_params,
115 if (ret != 0) ERROR ("could not receive message");
117 ret = frescan_send(&send_params,
120 if (ret != 0) ERROR ("could not send message\n");