pcap-thread.c
2.35 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
#include "pcap-thread.h"
#include "rssi_list.h"
#include <pcap.h>
#include <semaphore.h>
#include <signal.h>
extern volatile sig_atomic_t got_sigint;
extern Element * rssi_list;
extern sem_t synchro;
void *pcap_function(void *arg)
{
char *iface = (char *) arg;
char errbuf[PCAP_ERRBUF_SIZE];
pcap_t * handle = NULL;
struct ieee80211_radiotap_header * rtap_head;
struct ieee80211_header * eh;
struct pcap_pkthdr header;
const u_char * packet;
u_char * mac;
u_char first_flags;
int offset = 0;
//char rssi;
Element * dev_info;
// Open pcap handle to sniff traffic
handle = pcap_open_live(iface, BUFSIZ, 1, 1000, errbuf);
if (handle == NULL) {
printf("Could not open pcap on %s\n", iface);
pthread_exit((void *) -1);
}
while (got_sigint == 0) {
packet = pcap_next(handle, &header);
if (!packet)
continue;
rtap_head = (struct ieee80211_radiotap_header *) packet;
int len = (int) rtap_head->it_len[0] + 256 * (int) rtap_head->it_len[1];
eh = (struct ieee80211_header *) (packet + len);
if ((eh->frame_control & 0x03) == 0x01) {
mac = eh->source_addr;
first_flags = rtap_head->it_present[0];
offset = 8;
offset += ((first_flags & 0x01) == 0x01) ? 8 : 0 ;
offset += ((first_flags & 0x02) == 0x02) ? 1 : 0 ;
offset += ((first_flags & 0x04) == 0x04) ? 1 : 0 ;
offset += ((first_flags & 0x08) == 0x08) ? 4 : 0 ;
offset += ((first_flags & 0x10) == 0x10) ? 2 : 0 ;
//rssi = *((char *) rtap_head + offset) - 0x100; //+offset =22 => on web
const u_char *rssi2 =packet +22;
signed int rssiDb = rssi2[0] -256;
int j=0;
for(j=0;j<len;j++) {
char rssi =*((char *)packet+j)-256;
printf("%d bytes -- RSSI: %d dBm\n",len,rssi);
}
printf("%d bytes -- %02X:%02X:%02X:%02X:%02X:%02X -- RSSI: %d dBm\n",
len, mac[0], mac[1], mac[2], mac[3], mac[4], mac[5], rssiDb);
// We got some message issued by a terminal (FromDS=0,ToDS=1)
printf(" Hop !\n");
sem_wait(&synchro);
if ((dev_info = find_mac(rssi_list, mac)) == NULL)
dev_info = add_element(&rssi_list, mac);
clear_outdated_values(&dev_info->measurements);
//add_value(&dev_info->measurements, (int) rssi);
//printf("post sem_t\n");
sem_post(&synchro);
}
}
pcap_close(handle);
pthread_exit((void *) 0);
}