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
|
int main(void){
...
...
...
// init
if ((adhandle = pcap_open_live(d->name, // name of the device
65536, // portion of the packet to capture.
1, // promiscuous mode (nonzero means promiscuous)
-1, // read timeout (ms)
errbuf // error buffer
)) == NULL)
{
pcap_freealldevs(alldevs);
return -1;
}
...
...
...
buf_size = generatePacket(buf); // generate the data of the packet
while(1){
rxProcess(adhandle); // See there is a rx packet
do{
rxProcess(adhandle); // See there is a rx packet
QueryPerformanceCounter(&time);
} while(time.QuadPart < timeOut_sendPacket.QuadPart);
timeOut_sendPacket.QuadPart = time.QuadPart + counterTimeDelay.QuadPart;
// => I wait the timeout : it is to control the Tx rate
// Send packet
if (pcap_sendpacket(adhandle, buf, buf_size) != 0){
return 3;
}
buf_size = generatePacket(buf); // generate the data of the packet
printInfos(); // impression de l'état des données reçues (c'est lent)
}
}
void rxProcess(pcap_t *adhandle){
struct pcap_pkthdr *header;
const u_char *pkt_data;
int res;
static unsigned long long dataByteCount = 0;
//console_printf(&console, "rxProcess\r\n");
res = pcap_next_ex(adhandle, &header, &pkt_data);
if(res > 0){
// each packet contain a field with an identifier
// => I can see if packets are discarded
dataByteCount += header->len;
}
} |
Partager