tests/tests_frescan/test_frescan_servers_send_receive_measures.c

   1 #include <stdio.h>  // perror
   2 #include <stdlib.h> // exit
   3 #include <unistd.h>   // sleep
   4 #include <assert.h>
   5
   6 #include "frescan.h"
   7 #include "frescan_servers.h"
   8 #include "frescan_debug.h"
   9
  10 #define NETWORK 0
  11 #define LOG_DEVICE LOG_ETHERNET
  12
  13 #define NUM_MSG_BYTES  1488  // 8 32 64 512 1488
  14 #define ENABLE_DEBUG   false
  15 #define NUM_MEASURES   100
  16
  17 #define LOCAL_NODE 0 // 0 1
  18
  19 #include <misc/time_measurement_hwtime.h>
  20 #include <misc/logger.h>
  21
  22 static const trace_point_id_t BEGIN = 0;
  23 static const trace_point_id_t END = 1;
  24
  25 int main ()
  26 {
  27         int i, ret;
  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;
  32         frescan_server_params_t server_params;
  33         frescan_node_t me;
  34         size_t recv_bytes;
  35         frescan_node_t from;
  36         frescan_prio_t prio;
  37
  38         me = LOCAL_NODE;
  39
  40         DEBUG(ENABLE_DEBUG, ">> Initializing FRESCAN (me:%u)\n", me);
  41
  42         init_params.net = NETWORK;
  43         init_params.node = LOCAL_NODE;
  44         init_params.tx_fp_max_prio = 10;
  45         init_params.rx_num_of_channels = 5;
  46         init_params.rx_channel_max_prio = NULL;
  47
  48         ret = frescan_init(&init_params);
  49         if (ret != 0) ERROR ("could not init FRESCAN");
  50
  51         DEBUG(ENABLE_DEBUG, ">> Creating a Server\n");
  52
  53         server_params.values.budget = NUM_MSG_BYTES / 8;
  54         server_params.values.period.tv_sec  = 1;
  55         server_params.values.period.tv_nsec = 0;
  56         server_params.prio = 4;
  57
  58         ret = frescan_servers_create(NETWORK,
  59                                      &server_params,
  60                                      &send_params.ss);
  61         if (ret != 0) ERROR ("could not create server");
  62
  63         DEBUG(ENABLE_DEBUG, ">> Enter in loop for sending packets\n");
  64
  65         send_params.net      = NETWORK;
  66         send_params.channel  = 0;
  67         send_params.flags    = FRESCAN_SS | FRESCAN_ASYNC;
  68         send_params.to = (me == 0)? 1 : 0;
  69
  70         recv_params.net      = NETWORK;
  71         recv_params.channel  = 0;
  72         recv_params.flags    = FRESCAN_SYNC;
  73
  74         if (me == 0) {
  75                 DEBUG(ENABLE_DEBUG, ">> Init logger and timer measurements\n");
  76
  77                 ret = logger_init(LOG_DEVICE);
  78                 assert(ret == 0);
  79
  80                 ret = time_measure_hwtime_init(BEGIN, "frescan_begin");
  81                 assert(ret == 0);
  82
  83                 ret = time_measure_hwtime_init(END, "frescan_end");
  84                 assert(ret == 0);
  85
  86                 DEBUG(ENABLE_DEBUG, ">> Enter in loop for send-recv packets\n");
  87
  88                 for (i=0; i<NUM_MEASURES; i++) {
  89                         time_measure_hwtime_set_timestamp(BEGIN);
  90
  91                         ret = frescan_send(&send_params,
  92                                            (uint8_t *)msg,
  93                                            NUM_MSG_BYTES);
  94                         if (ret != 0) ERROR ("could not send message\n");
  95
  96                         ret = frescan_recv(&recv_params,
  97                                            (uint8_t *)msg,
  98                                            sizeof(msg),
  99                                            &recv_bytes,
 100                                            &from,
 101                                            &prio);
 102                         if (ret != 0) ERROR ("could not receive message");
 103
 104                         time_measure_hwtime_set_timestamp(END);
 105
 106                         DEBUG(ENABLE_DEBUG, ">> received %d bytes\n", recv_bytes);
 107                 }
 108
 109                 ret = time_measure_hwtime_write_membuffer(BEGIN);
 110                 assert(ret == 0);
 111
 112                 ret = time_measure_hwtime_write_membuffer(END);
 113                 assert(ret == 0);
 114
 115                 while (logger_manual_call() > 0);
 116
 117         } else {
 118                 DEBUG(ENABLE_DEBUG, ">> Enter in loop for recv-send packets\n");
 119
 120                 while(1) {
 121                         ret = frescan_recv(&recv_params,
 122                                            (uint8_t *)msg,
 123                                            sizeof(msg),
 124                                            &recv_bytes,
 125                                            &from,
 126                                            &prio);
 127                         if (ret != 0) ERROR ("could not receive message");
 128
 129                         ret = frescan_send(&send_params,
 130                                            (uint8_t *)msg,
 131                                            recv_bytes);
 132                         if (ret != 0) ERROR ("could not send message\n");
 133                 }
 134         }
 135
 136         return 0;
 137 }