src/transport/gnunet-transport-wlan-sender.c

   1 /*
   2  This file is part of GNUnet
   3  (C) 2011 Christian Grothoff (and other contributing authors)
   4
   5  GNUnet is free software; you can redistribute it and/or modify
   6  it under the terms of the GNU General Public License as published
   7  by the Free Software Foundation; either version 3, or (at your
   8  option) any later version.
   9
  10  GNUnet is distributed in the hope that it will be useful, but
  11  WITHOUT ANY WARRANTY; without even the implied warranty of
  12  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  General Public License for more details.
  14
  15  You should have received a copy of the GNU General Public License
  16  along with GNUnet; see the file COPYING.  If not, write to the
  17  Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  18  Boston, MA 02111-1307, USA.
  19  */
  20
  21 /**
  22  * @file transport/gnunet-transport-wlan-sender.c
  23  * @brief program to send via WLAN as much as possible (to test physical/theoretical throughput)
  24  * @author David Brodski
  25  */
  26 #include "platform.h"
  27 #include "gnunet_protocols.h"
  28 #include "plugin_transport_wlan.h"
  29
  30 #define WLAN_MTU 1500
  31
  32 /**
  33  * LLC fields for better compatibility
  34  */
  35 #define WLAN_LLC_DSAP_FIELD 0x1f
  36 #define WLAN_LLC_SSAP_FIELD 0x1f
  37
  38 #define IEEE80211_ADDR_LEN      6       /* size of 802.11 address */
  39
  40 #define IEEE80211_FC0_VERSION_MASK              0x03
  41 #define IEEE80211_FC0_VERSION_SHIFT             0
  42 #define IEEE80211_FC0_VERSION_0                 0x00
  43 #define IEEE80211_FC0_TYPE_MASK                 0x0c
  44 #define IEEE80211_FC0_TYPE_SHIFT                2
  45 #define IEEE80211_FC0_TYPE_MGT                  0x00
  46 #define IEEE80211_FC0_TYPE_CTL                  0x04
  47 #define IEEE80211_FC0_TYPE_DATA                 0x08
  48
  49 GNUNET_NETWORK_STRUCT_BEGIN
  50
  51 /*
  52  * generic definitions for IEEE 802.11 frames
  53  */
  54 struct ieee80211_frame
  55 {
  56   u_int8_t i_fc[2];
  57   u_int8_t i_dur[2];
  58   u_int8_t i_addr1[IEEE80211_ADDR_LEN];
  59   u_int8_t i_addr2[IEEE80211_ADDR_LEN];
  60   u_int8_t i_addr3[IEEE80211_ADDR_LEN];
  61   u_int8_t i_seq[2];
  62   u_int8_t llc[4];
  63 } GNUNET_PACKED;
  64 GNUNET_NETWORK_STRUCT_END
  65
  66 /**
  67  * function to fill the radiotap header
  68  * @param header pointer to the radiotap header
  69  * @return GNUNET_YES at success
  70  */
  71 static int
  72 getRadiotapHeader (struct Radiotap_Send *header)
  73 {
  74   header->rate = 255;
  75   header->tx_power = 0;
  76   header->antenna = 0;
  77
  78   return GNUNET_YES;
  79 }
  80
  81 /**
  82  * function to generate the wlan hardware header for one packet
  83  * @param Header address to write the header to
  84  * @param to_mac_addr pointer to the address of the recipient
  85  * @param mac pointer to the mac address to send from (normally overwritten over by helper)
  86  * @param size size of the whole packet, needed to calculate the time to send the packet
  87  * @return GNUNET_YES if there was no error
  88  */
  89 static int
  90 getWlanHeader (struct ieee80211_frame *Header, const char *to_mac_addr,
  91                const char *mac, unsigned int size)
  92 {
  93   uint16_t *tmp16;
  94   const int rate = 11000000;
  95
  96   Header->i_fc[0] = IEEE80211_FC0_TYPE_DATA;
  97   Header->i_fc[1] = 0x00;
  98   memcpy (&Header->i_addr3, &mac_bssid_gnunet, sizeof (mac_bssid_gnunet));
  99   memcpy (&Header->i_addr2, mac, sizeof (mac_bssid_gnunet));
 100   memcpy (&Header->i_addr1, to_mac_addr, sizeof (mac_bssid_gnunet));
 101
 102   tmp16 = (uint16_t *) Header->i_dur;
 103   *tmp16 = (uint16_t) GNUNET_htole16 ((size * 1000000) / rate + 290);
 104   Header->llc[0] = WLAN_LLC_DSAP_FIELD;
 105   Header->llc[1] = WLAN_LLC_SSAP_FIELD;
 106
 107   return GNUNET_YES;
 108 }
 109
 110
 111 int
 112 main (int argc, char *argv[])
 113 {
 114   char msg_buf[WLAN_MTU];
 115   struct GNUNET_MessageHeader *msg;
 116   struct ieee80211_frame *wlan_header;
 117   struct Radiotap_Send *radiotap;
 118
 119   unsigned int temp[6];
 120   char inmac[6];
 121   char outmac[6];
 122   int pos;
 123   long long count;
 124   double bytes_per_s;
 125   time_t start;
 126   time_t akt;
 127   int i;
 128
 129   if (4 != argc)
 130   {
 131     fprintf (stderr,
 132              "This program must be started with the interface and the targets and source mac as argument.\n");
 133     fprintf (stderr,
 134              "Usage: interface-name mac-target mac-source\n"
 135              "e.g. mon0 11-22-33-44-55-66 12-34-56-78-90-ab\n");
 136     return 1;
 137   }
 138   if (6 !=
 139       sscanf (argv[3], "%x-%x-%x-%x-%x-%x", &temp[0], &temp[1], &temp[2],
 140               &temp[3], &temp[4], &temp[5]))
 141   {
 142     fprintf (stderr,
 143              "Usage: interface-name mac-target mac-source\n"
 144              "e.g. mon0 11-22-33-44-55-66 12-34-56-78-90-ab\n");
 145     return 1;
 146   }
 147   if (6 !=
 148       sscanf (argv[2], "%x-%x-%x-%x-%x-%x", &temp[0], &temp[1], &temp[2],
 149               &temp[3], &temp[4], &temp[5]))
 150   {
 151     fprintf (stderr,
 152              "Usage: interface-name mac-target mac-source\n"
 153              "e.g. mon0 11-22-33-44-55-66 12-34-56-78-90-ab\n");
 154     return 1;
 155   }
 156   for (i = 0; i < 6; i++)
 157     inmac[i] = temp[i];
 158   for (i = 0; i < 6; i++)
 159     outmac[i] = temp[i];
 160
 161   pid_t pid;
 162   int commpipe[2];              /* This holds the fd for the input & output of the pipe */
 163
 164   /* Setup communication pipeline first */
 165   if (pipe (commpipe))
 166   {
 167     fprintf (stderr,
 168              "Failed to create pipe: %s\n",
 169              STRERROR (errno));
 170     exit (1);
 171   }
 172
 173   /* Attempt to fork and check for errors */
 174   if ((pid = fork ()) == -1)
 175   {
 176     fprintf (stderr, "Failed to fork: %s\n",
 177              STRERROR (errno));
 178     exit (1);
 179   }
 180
 181   if (pid)
 182   {
 183     /* A positive (non-negative) PID indicates the parent process */
 184     close (commpipe[0]);        /* Close unused side of pipe (in side) */
 185     setvbuf (stdout, (char *) NULL, _IONBF, 0); /* Set non-buffered output on stdout */
 186
 187
 188     msg = (struct GNUNET_MessageHeader *) msg_buf;
 189     msg->type = htons (GNUNET_MESSAGE_TYPE_WLAN_HELPER_DATA);
 190     msg->size = htons (WLAN_MTU);
 191     radiotap = (struct Radiotap_Send *) &msg[1];
 192     wlan_header = (struct ieee80211_frame *) &radiotap[1];
 193     pos = 0;
 194
 195     getRadiotapHeader (radiotap);
 196     getWlanHeader (wlan_header, outmac, inmac,
 197                    WLAN_MTU - sizeof (struct GNUNET_MessageHeader));
 198
 199     start = time (NULL);
 200     count = 0;
 201     while (1)
 202     {
 203       pos += write (commpipe[1], msg, WLAN_MTU - pos);
 204       if (pos % WLAN_MTU == 0)
 205       {
 206         pos = 0;
 207         count++;
 208
 209         if (count % 1000 == 0)
 210         {
 211           akt = time (NULL);
 212           bytes_per_s = count * WLAN_MTU / (akt - start);
 213           bytes_per_s /= 1024;
 214           printf ("send %f kbytes/s\n", bytes_per_s);
 215         }
 216       }
 217
 218     }
 219   }
 220   else
 221   {
 222     /* A zero PID indicates that this is the child process */
 223     (void) close (0);
 224     if (-1 == dup2 (commpipe[0], 0))    /* Replace stdin with the in side of the pipe */
 225       fprintf (stderr, "dup2 failed: %s\n", strerror (errno));
 226     (void) close (commpipe[1]); /* Close unused side of pipe (out side) */
 227     /* Replace the child fork with a new process */
 228     if (execl
 229         ("gnunet-helper-transport-wlan", "gnunet-helper-transport-wlan",
 230          argv[1], NULL) == -1)
 231     {
 232       fprintf (stderr, "Could not start gnunet-helper-transport-wlan!");
 233       _exit (1);
 234     }
 235   }
 236   return 0;
 237 }