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