src/transport/gnunet_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_wlan_sender.c
  23  * @brief program to send via WLAN as much as possible
  24  * @author David Brodski
  25  */
  26
  27 #include <unistd.h>
  28 #include <stdio.h>
  29 #include <stdlib.h>
  30 #include <netinet/in.h>
  31 #include <string.h>
  32 #include <time.h>
  33 #include "gnunet/gnunet_protocols.h"
  34 #include "plugin_transport_wlan.h"
  35
  36 #define WLAN_MTU 1500
  37
  38 /**
  39  * LLC fields for better compatibility
  40  */
  41 #define WLAN_LLC_DSAP_FIELD 0x1f
  42 #define WLAN_LLC_SSAP_FIELD 0x1f
  43
  44 #define IEEE80211_ADDR_LEN      6       /* size of 802.11 address */
  45
  46 #define IEEE80211_FC0_VERSION_MASK              0x03
  47 #define IEEE80211_FC0_VERSION_SHIFT             0
  48 #define IEEE80211_FC0_VERSION_0                 0x00
  49 #define IEEE80211_FC0_TYPE_MASK                 0x0c
  50 #define IEEE80211_FC0_TYPE_SHIFT                2
  51 #define IEEE80211_FC0_TYPE_MGT                  0x00
  52 #define IEEE80211_FC0_TYPE_CTL                  0x04
  53 #define IEEE80211_FC0_TYPE_DATA                 0x08
  54
  55
  56 /*
  57  * generic definitions for IEEE 802.11 frames
  58  */
  59 struct ieee80211_frame
  60 {
  61   u_int8_t i_fc[2];
  62   u_int8_t i_dur[2];
  63   u_int8_t i_addr1[IEEE80211_ADDR_LEN];
  64   u_int8_t i_addr2[IEEE80211_ADDR_LEN];
  65   u_int8_t i_addr3[IEEE80211_ADDR_LEN];
  66   u_int8_t i_seq[2];
  67   u_int8_t llc[4];
  68 #if DEBUG_wlan_ip_udp_packets_on_air > 1
  69   struct iph ip;
  70   struct udphdr udp;
  71 #endif
  72 } GNUNET_PACKED;
  73
  74 /**
  75  * function to fill the radiotap header
  76  * @param header pointer to the radiotap header
  77  * @return GNUNET_YES at success
  78  */
  79 static int
  80 getRadiotapHeader ( struct Radiotap_Send *header)
  81 {
  82
  83
  84     header->rate = 255;
  85     header->tx_power = 0;
  86     header->antenna = 0;
  87
  88   return GNUNET_YES;
  89 }
  90
  91 /**
  92  * function to generate the wlan hardware header for one packet
  93  * @param Header address to write the header to
  94  * @param to_mac_addr pointer to the address of the recipient
  95  * @param mac pointer to the mac address to send from (normally overwritten over by helper)
  96  * @param size size of the whole packet, needed to calculate the time to send the packet
  97  * @return GNUNET_YES if there was no error
  98  */
  99 static int
 100 getWlanHeader (struct ieee80211_frame *Header,
 101                const char *to_mac_addr, const char *mac,
 102                unsigned int size)
 103 {
 104   uint16_t *tmp16;
 105   const int rate = 11000000;
 106
 107   Header->i_fc[0] = IEEE80211_FC0_TYPE_DATA;
 108   Header->i_fc[1] = 0x00;
 109   memcpy (&Header->i_addr3, &mac_bssid, sizeof (mac_bssid));
 110   memcpy (&Header->i_addr2, mac,
 111                   sizeof (mac_bssid));
 112   memcpy (&Header->i_addr1, to_mac_addr, sizeof (mac_bssid));
 113
 114   tmp16 = (uint16_t *) Header->i_dur;
 115   *tmp16 = (uint16_t) htole16 ((size * 1000000) / rate + 290);
 116   Header->llc[0] = WLAN_LLC_DSAP_FIELD;
 117   Header->llc[1] = WLAN_LLC_SSAP_FIELD;
 118
 119   return GNUNET_YES;
 120 }
 121
 122 int main(int argc, char *argv[]){
 123         struct GNUNET_MessageHeader *msg;
 124         struct ieee80211_frame *wlan_header;
 125         struct Radiotap_Send *radiotap;
 126
 127         unsigned int temp[6];
 128         char inmac[6];
 129         char outmac[6];
 130         int pos;
 131         long long count;
 132         double bytes_per_s;
 133         time_t start;
 134         time_t akt;
 135         int i;
 136
 137         if (4 != argc) {
 138                 fprintf(
 139                                 stderr,
 140                                 "This program must be started with the interface and the targets and source mac as argument.\nThis program was compiled at ----- %s ----\n",
 141                                 __TIMESTAMP__);
 142                 fprintf(stderr, "Usage: interface-name mac-target mac-source\n" "e.g. mon0 11-22-33-44-55-66 12-34-56-78-90-ab\n");
 143                 return 1;
 144         }
 145
 146
 147         pid_t pid;
 148         int     commpipe[2];            /* This holds the fd for the input & output of the pipe */
 149
 150         /* Setup communication pipeline first */
 151         if(pipe(commpipe)){
 152                 fprintf(stderr,"Pipe error!\n");
 153                 exit(1);
 154         }
 155
 156         /* Attempt to fork and check for errors */
 157         if( (pid=fork()) == -1){
 158                 fprintf(stderr,"Fork error. Exiting.\n");  /* something went wrong */
 159                 exit(1);
 160         }
 161
 162         if(pid){
 163                 /* A positive (non-negative) PID indicates the parent process */
 164                 close(commpipe[0]);             /* Close unused side of pipe (in side) */
 165                 setvbuf(stdout,(char*)NULL,_IONBF,0);   /* Set non-buffered output on stdout */
 166
 167                 sscanf(argv[3], "%x-%x-%x-%x-%x-%x", &temp[0],&temp[1],&temp[2],&temp[3],&temp[4],&temp[5]);
 168                 for (i = 0; i < 6; i++){
 169                         inmac[i] = temp[i];
 170                 }
 171                 sscanf(argv[2], "%x-%x-%x-%x-%x-%x", &temp[0],&temp[1],&temp[2],&temp[3],&temp[4],&temp[5]);
 172                 for (i = 0; i < 6; i++){
 173                         outmac[i] = temp[i];
 174                 }
 175
 176                 msg = malloc(WLAN_MTU);
 177                 msg->type = htons (GNUNET_MESSAGE_TYPE_WLAN_HELPER_DATA);
 178                 msg->size = htons (WLAN_MTU);
 179                 radiotap = (struct Radiotap_Send *) &msg[1];
 180                 wlan_header = (struct ieee80211_frame *) &radiotap[1];
 181                 pos = 0;
 182
 183                 getRadiotapHeader(radiotap);
 184                 getWlanHeader(wlan_header, outmac, inmac, WLAN_MTU - sizeof(struct GNUNET_MessageHeader));
 185
 186                 start = time(NULL);
 187                 while (1){
 188                         pos += write(commpipe[1], msg, WLAN_MTU - pos);
 189                         if (pos % WLAN_MTU == 0){
 190                                 pos = 0;
 191                                 count ++;
 192
 193                                 if  (count % 1000 == 0){
 194                                         akt = time(NULL);
 195                                         bytes_per_s = count * WLAN_MTU / (akt - start);
 196                                         bytes_per_s /= 1024;
 197                                         printf("send %f kbytes/s\n", bytes_per_s);
 198                                 }
 199                         }
 200
 201                 }
 202         }
 203         else{
 204                 /* A zero PID indicates that this is the child process */
 205                 dup2(commpipe[0],0);    /* Replace stdin with the in side of the pipe */
 206                 close(commpipe[1]);             /* Close unused side of pipe (out side) */
 207                 /* Replace the child fork with a new process */
 208                 if(execl("gnunet-transport-wlan-helper","gnunet-transport-wlan-helper", argv[1], NULL) == -1){
 209                         fprintf(stderr,"Could not start gnunet-transport-wlan-helper!");
 210                         exit(1);
 211                 }
 212         }
 213         return 0;
 214 }