tests/tests_frescan/test_frescan_fp_send_receive_measures.c

   1 //----------------------------------------------------------------------
   2 //  Copyright (C) 2006 - 2009 by the FRESCOR consortium:
   3 //
   4 //    Universidad de Cantabria,              SPAIN
   5 //    University of York,                    UK
   6 //    Scuola Superiore Sant'Anna,            ITALY
   7 //    Kaiserslautern University,             GERMANY
   8 //    Univ. Politecnica  Valencia,           SPAIN
   9 //    Czech Technical University in Prague,  CZECH REPUBLIC
  10 //    ENEA                                   SWEDEN
  11 //    Thales Communication S.A.              FRANCE
  12 //    Visual Tools S.A.                      SPAIN
  13 //    Rapita Systems Ltd                     UK
  14 //    Evidence                               ITALY
  15 //
  16 //    See http://www.frescor.org
  17 //
  18 //        The FRESCOR project (FP6/2005/IST/5-034026) is funded
  19 //        in part by the European Union Sixth Framework Programme
  20 //        The European Union is not liable of any use that may be
  21 //        made of this code.
  22 //
  23 //
  24 //  based on previous work (FSF) done in the FIRST project
  25 //
  26 //   Copyright (C) 2005  Mälardalen University, SWEDEN
  27 //                       Scuola Superiore S.Anna, ITALY
  28 //                       Universidad de Cantabria, SPAIN
  29 //                       University of York, UK
  30 //
  31 // This file is part of FNA (Frescor Network Adaptation)
  32 //
  33 // FNA is free software; you can redistribute it and/or modify it
  34 // under terms of the GNU General Public License as published by the
  35 // Free Software Foundation; either version 2, or (at your option) any
  36 // later version.  FNA is distributed in the hope that it will be
  37 // useful, but WITHOUT ANY WARRANTY; without even the implied warranty
  38 // of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  39 // General Public License for more details. You should have received a
  40 // copy of the GNU General Public License along with FNA; see file
  41 // COPYING. If not, write to the Free Software Foundation, 675 Mass Ave,
  42 // Cambridge, MA 02139, USA.
  43 //
  44 // As a special exception, including FNA header files in a file,
  45 // instantiating FNA generics or templates, or linking other files
  46 // with FNA objects to produce an executable application, does not
  47 // by itself cause the resulting executable application to be covered
  48 // by the GNU General Public License. This exception does not
  49 // however invalidate any other reasons why the executable file might be
  50 // covered by the GNU Public License.
  51 // -----------------------------------------------------------------------
  52 #include <stdio.h>  // perror
  53 #include <stdlib.h> // exit
  54 #include <unistd.h>   // sleep
  55 #include <assert.h>
  56
  57 #include "frescan.h"
  58 #include "frescan_servers.h"
  59 #include "frescan_debug.h"
  60
  61 #define NETWORK 0
  62 #define LOG_DEVICE LOG_ETHERNET
  63
  64 #define NUM_MSG_BYTES  8  // 8 32 64 512 1488
  65 #define ENABLE_DEBUG   false
  66 #define NUM_MEASURES   100
  67
  68 #define LOCAL_NODE 0 // 0 1
  69
  70 #include <misc/time_measurement_hwtime.h>
  71 #include <misc/logger.h>
  72
  73 static const trace_point_id_t BEGIN = 0;
  74 static const trace_point_id_t END = 1;
  75
  76 int main ()
  77 {
  78         int i, ret;
  79         frescan_send_params_t send_params;
  80         frescan_recv_params_t recv_params;
  81         char msg[1500]; // big enough for all the messages
  82         frescan_init_params_t init_params;
  83         frescan_node_t me;
  84         size_t recv_bytes;
  85         frescan_node_t from;
  86         frescan_prio_t prio;
  87
  88         me = LOCAL_NODE;
  89
  90         DEBUG(ENABLE_DEBUG, ">> Initializing FRESCAN (me:%u)\n", me);
  91
  92         init_params.net = NETWORK;
  93         init_params.node = LOCAL_NODE;
  94         init_params.tx_fp_max_prio = 10;
  95         init_params.rx_num_of_channels = 5;
  96         init_params.rx_channel_max_prio = NULL;
  97
  98         ret = frescan_init(&init_params);
  99         if (ret != 0) FRESCAN_ERROR ("could not init FRESCAN");
 100
 101         DEBUG(ENABLE_DEBUG, ">> Enter in loop for sending packets\n");
 102
 103         send_params.net      = NETWORK;
 104         send_params.channel  = 0;
 105         send_params.flags    = FRESCAN_FP | FRESCAN_ASYNC;
 106         send_params.prio     = 9;
 107         send_params.to       = (me == 0)? 1 : 0;
 108
 109         recv_params.net      = NETWORK;
 110         recv_params.channel  = 0;
 111         recv_params.flags    = FRESCAN_SYNC;
 112
 113         if (me == 0) {
 114                 DEBUG(ENABLE_DEBUG, ">> Init logger and timer measurements\n");
 115
 116                 ret = logger_init(LOG_DEVICE);
 117                 assert(ret == 0);
 118
 119                 ret = time_measure_hwtime_init(BEGIN, "frescan_begin");
 120                 assert(ret == 0);
 121
 122                 ret = time_measure_hwtime_init(END, "frescan_end");
 123                 assert(ret == 0);
 124
 125                 DEBUG(ENABLE_DEBUG, ">> Enter in loop for send-recv packets\n");
 126
 127                 for (i=0; i<NUM_MEASURES; i++) {
 128                         time_measure_hwtime_set_timestamp(BEGIN);
 129
 130                         ret = frescan_send(&send_params,
 131                                            (uint8_t *)msg,
 132                                            NUM_MSG_BYTES);
 133                         if (ret != 0) FRESCAN_ERROR ("could not send message\n");
 134
 135                         ret = frescan_recv(&recv_params,
 136                                            (uint8_t *)msg,
 137                                            sizeof(msg),
 138                                            &recv_bytes,
 139                                            &from,
 140                                            &prio);
 141                         if (ret != 0) FRESCAN_ERROR ("could not receive message");
 142
 143                         time_measure_hwtime_set_timestamp(END);
 144
 145                         DEBUG(ENABLE_DEBUG, ">> received %d bytes\n", recv_bytes);
 146                 }
 147
 148                 ret = time_measure_hwtime_write_membuffer(BEGIN);
 149                 assert(ret == 0);
 150
 151                 ret = time_measure_hwtime_write_membuffer(END);
 152                 assert(ret == 0);
 153
 154                 while (logger_manual_call() > 0);
 155
 156         } else {
 157                 DEBUG(ENABLE_DEBUG, ">> Enter in loop for recv-send packets\n");
 158
 159                 while(1) {
 160                         ret = frescan_recv(&recv_params,
 161                                            (uint8_t *)msg,
 162                                            sizeof(msg),
 163                                            &recv_bytes,
 164                                            &from,
 165                                            &prio);
 166                         if (ret != 0) FRESCAN_ERROR ("could not receive message");
 167
 168                         ret = frescan_send(&send_params,
 169                                            (uint8_t *)msg,
 170                                            recv_bytes);
 171                         if (ret != 0) FRESCAN_ERROR ("could not send message\n");
 172                 }
 173         }
 174
 175         return 0;
 176 }