Compare commits
33 Commits
Author | SHA1 | Date |
---|---|---|
Gerard Wagener | 16d5435b99 | |
Gerard Wagener | acce48baee | |
Gerard Wagener | 38036c3f47 | |
Gerard Wagener | 347d6e4d71 | |
Gerard Wagener | cb4ca4a778 | |
Gerard Wagener | c3f7c26011 | |
Gerard Wagener | 5b2ddf2b27 | |
Gerard Wagener | 8898555fca | |
Gerard Wagener | f24e3eb6df | |
Gerard Wagener | 2e4d1eef26 | |
Gerard Wagener | 459102f9b1 | |
Gerard Wagener | a6e70c500f | |
Gerard Wagener | 4770c2f197 | |
Gerard Wagener | bc3e724a81 | |
Alexandre Dulaunoy | 6871de5f8a | |
Gerard Wagener | 81356312ca | |
Gerard Wagener | 9bd1da24a5 | |
Gerard Wagener | a68dc52870 | |
Gerard Wagener | bd759f159a | |
Gerard Wagener | 985496222a | |
Gerard Wagener | 969e6e6407 | |
Gerard Wagener | 0512a82827 | |
Gerard Wagener | 3f5d27d123 | |
Gerard Wagener | 2226c6c383 | |
Gerard Wagener | 130854cf6e | |
Gerard Wagener | 5a94a11e78 | |
Gerard Wagener | 2703dec6db | |
Gerard Wagener | ff7df8ce2a | |
Gerard Wagener | aff2cb2d94 | |
Gerard Wagener | ffde508ef9 | |
Gerard Wagener | 7988404396 | |
Gerard Wagener | f9204de215 | |
Gerard Wagener | 752228dd7d |
47
README.md
47
README.md
|
@ -1,12 +1,13 @@
|
|||
# Passive Identification of BackScatter
|
||||
# Passive Identification of BackScatter (pibs)
|
||||
|
||||
Read a pcap file and display potential backscatter traffic on standard output
|
||||
|
||||
This is very early stage and subject to change.
|
||||
|
||||
|
||||
# Install dependencies
|
||||
|
||||
As there were some changes in libwiretap, at least the version 2.6.3-1 is needed.
|
||||
As there were some changes in libwiretap, at least the version 2.6.3-1 is required.
|
||||
|
||||
``` shell
|
||||
apt-get install libwiretap-dev
|
||||
apt-get install libhiredis-dev
|
||||
|
@ -16,12 +17,11 @@ apt-get install libglib2.0-dev
|
|||
make
|
||||
```
|
||||
|
||||
# How to use
|
||||
# How to use pibs
|
||||
|
||||
``` shell
|
||||
./pibs -r pcapfile.cap -b
|
||||
`./pibs -r pcapfile.cap -b`
|
||||
|
||||
./pibs -u e344c4fb-442e-45a6-92b9-d8e30aeef448 -z 127.0.0.1 -p 6379 -y 2
|
||||
`./pibs -u e344c4fb-442e-45a6-92b9-d8e30aeef448 -z 127.0.0.1 -p 6379 -y 2`
|
||||
|
||||
Consumes the files from the worker queue and write potential backscatter on
|
||||
standard output. The worker queue should include absolute filenames.
|
||||
|
@ -30,10 +30,39 @@ The redis database 2 is used as specified with the -y option.
|
|||
The string e344c4fb-442e-45a6-92b9-d8e30aeef448 is the uuid that must be inline with the
|
||||
worker.
|
||||
|
||||
pibs -r source.cap.gz -w backscatter.cap
|
||||
`pibs -r source.cap.gz -w backscatter.cap`
|
||||
|
||||
Read the file source.cap.gz, identify potential backscatter and store it in the
|
||||
file backscatter.cap to be further analysed with other tools such as wireshark
|
||||
```
|
||||
|
||||
`pibs -r pcapfile.cap -s`
|
||||
|
||||
Read the file source.cap, identify potential backscatter and display the
|
||||
usage of the used internal hash table. Feature for debugging purpose.
|
||||
|
||||
`pibs -r pcapfile.cap -d`
|
||||
|
||||
Dump the internal data structures for debugging purposes from the processing
|
||||
of the pcapfile.
|
||||
|
||||
`pibs -n`
|
||||
|
||||
Create fresh internal data structure as shared memory for multi processing
|
||||
purposes. The segment id is displayed on standard output.
|
||||
|
||||
`pibs -n -i myinstance.shm`
|
||||
|
||||
Create a shared memory and store the segment identifier in the file
|
||||
myinstance.shm
|
||||
|
||||
`pibs -r pcapfile.cap.gz -a -i instance.shm`
|
||||
|
||||
Read pcapfile.cap.gz identify potential backscatter and store it in the
|
||||
shared memory segment with the identifier stored in the file instance.shm.
|
||||
The previous states are taken into account.
|
||||
|
||||
`pibs -i instance.shm -a -s`
|
||||
|
||||
Display the usage of the internal hash table from the shared memory segment
|
||||
specified in the file instance.shm. This command can be executed in parallel
|
||||
while another pibs instance is filling it.
|
||||
|
|
38
bin/Makefile
38
bin/Makefile
|
@ -1,8 +1,42 @@
|
|||
pibs: pibs.o
|
||||
gcc -Wall -o pibs pibs.o -lwiretap `pkg-config --libs glib-2.0` -lpcap -lhiredis -ggdb
|
||||
all: pibs pibs-stat pibs-BGP-Ranking pibs-isn
|
||||
|
||||
pibs-stat: pibs-stat.o libpibs.o memutils.o synseen.o
|
||||
gcc -Wall -o pibs-stat pibs-stat.o libpibs.o memutils.o synseen.o -lwiretap `pkg-config --libs glib-2.0` -lpcap -lhiredis -ggdb
|
||||
|
||||
|
||||
pibs-stat.o: pibs-stat.c
|
||||
gcc -D HASHDEBUG=0 -Wall -c pibs-stat.c `pkg-config --cflags glib-2.0` -I /usr/include/wireshark/wiretap -I /usr/include/wireshark/wsutil -I /usr/include/wireshark `pkg-config --libs glib-2.0` -I /usr/local/include/hiredis -ggdb
|
||||
|
||||
pibs-isn: pibs-isn.o libpibs.o memutils.o synseen.o
|
||||
gcc -Wall -o pibs-isn pibs-isn.o libpibs.o memutils.o synseen.o -lwiretap `pkg-config --libs glib-2.0` -lpcap -lhiredis -ggdb
|
||||
|
||||
pibs-stat.o: pibs-isn.c
|
||||
gcc -D HASHDEBUG=0 -Wall -c pibs-isn.c `pkg-config --cflags glib-2.0` -I /usr/include/wireshark/wiretap -I /usr/include/wireshark/wsutil -I /usr/include/wireshark `pkg-config --libs glib-2.0` -I /usr/local/include/hiredis -ggdb
|
||||
|
||||
pibs-BGP-Ranking: pibs pibs-BGP-Ranking.o libpibs.o memutils.o synseen.o
|
||||
gcc -Wall -o pibs-BGP-Ranking pibs-BGP-Ranking.o libpibs.o memutils.o synseen.o -lwiretap `pkg-config --libs glib-2.0` -lpcap -lhiredis -ggdb
|
||||
|
||||
pibs-BGP-Ranking.o: pibs-BGP-Ranking.c
|
||||
gcc -D HASHDEBUG=0 -Wall -c pibs-BGP-Ranking.c `pkg-config --cflags glib-2.0` -I /usr/include/wireshark/wiretap -I /usr/include/wireshark/wsutil -I /usr/include/wireshark `pkg-config --libs glib-2.0` -I /usr/local/include/hiredis -ggdb
|
||||
|
||||
pibs: pibs.o memutils.o synseen.o libpibs.o
|
||||
gcc -Wall -o pibs pibs.o memutils.o synseen.o libpibs.o -lwiretap `pkg-config --libs glib-2.0` -lpcap -lhiredis -ggdb
|
||||
|
||||
libpibs.o: libpibs.c
|
||||
gcc -D HASHDEBUG=0 -Wall -c libpibs.c `pkg-config --cflags glib-2.0` -I /usr/include/wireshark/wiretap -I /usr/include/wireshark/wsutil -I /usr/include/wireshark `pkg-config --libs glib-2.0` -I /usr/local/include/hiredis -ggdb
|
||||
|
||||
|
||||
memutils.o: memutils.c
|
||||
gcc -Wall -c memutils.c `pkg-config --cflags glib-2.0` -I /usr/include/wireshark/wiretap -I /usr/include/wireshark/wsutil -I /usr/include/wireshark `pkg-config --libs glib-2.0` -I /usr/local/include/hiredis -ggdb
|
||||
|
||||
synseen.o: synseen.c
|
||||
gcc -D HASHDEBUG=0 -Wall -c synseen.c `pkg-config --cflags glib-2.0` -I /usr/include/wireshark/wiretap -I /usr/include/wireshark/wsutil -I /usr/include/wireshark `pkg-config --libs glib-2.0` -I /usr/local/include/hiredis -ggdb
|
||||
|
||||
pibs.o: pibs.c
|
||||
gcc -D HASHDEBUG=0 -Wall -c pibs.c `pkg-config --cflags glib-2.0` -I /usr/include/wireshark/wiretap -I /usr/include/wireshark/wsutil -I /usr/include/wireshark `pkg-config --libs glib-2.0` -I /usr/local/include/hiredis -ggdb
|
||||
|
||||
clean:
|
||||
-rm pibs
|
||||
-rm pibs-stat
|
||||
-rm pibs-BGP-Ranking
|
||||
-rm *.o
|
||||
|
|
|
@ -0,0 +1,143 @@
|
|||
/*
|
||||
* pibs - Passive Identification of BackScatter
|
||||
*
|
||||
* Copyright (C) 2019 Gerard Wagener
|
||||
* Copyright (C) 2019 CIRCL Computer Incident Response Center Luxembourg
|
||||
* (SMILE gie).
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 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 Affero General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Affero General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
#include "pibs.h"
|
||||
|
||||
void process_frame(pibs_t* pibs, wtap *wth,
|
||||
uint8_t *eth)
|
||||
{
|
||||
struct ip* ipv4;
|
||||
struct tcphdr* tcp;
|
||||
unsigned char* buf;
|
||||
size_t length;
|
||||
|
||||
buf = eth+14;
|
||||
length = wth->rec.rec_header.packet_header.caplen-14;
|
||||
|
||||
if (length < sizeof(struct ip)) {
|
||||
return;
|
||||
}
|
||||
|
||||
|
||||
ipv4 = (struct ip*)buf;
|
||||
// Focus only on TCP packets
|
||||
if (ipv4->ip_p != 6)
|
||||
return;
|
||||
|
||||
tcp = (struct tcphdr*)(buf+sizeof(struct ip));
|
||||
|
||||
synseen_process_frame(pibs, wth, eth, ipv4, tcp);
|
||||
|
||||
//Put other frame processing activities here
|
||||
}
|
||||
|
||||
void process_file(pibs_t* pibs)
|
||||
{
|
||||
wtap *wth;
|
||||
int err;
|
||||
char *errinfo;
|
||||
gint64 data_offset;
|
||||
int ethertype;
|
||||
guint8 *buf;
|
||||
|
||||
fprintf(stderr,"Processing %s\n",pibs->filename);
|
||||
wth = wtap_open_offline ( pibs->filename, WTAP_TYPE_AUTO, (int*)&err,
|
||||
(char**)&errinfo, FALSE);
|
||||
if (wth) {
|
||||
/* Loop over the packets and adjust the headers */
|
||||
while (wtap_read(wth, &err, &errinfo, &data_offset)) {
|
||||
if (wth->rec.rec_type == REC_TYPE_PACKET) {
|
||||
if (wth->rec.tsprec == WTAP_TSPREC_USEC){
|
||||
if (wth->rec.rec_header.packet_header.caplen < 14) {
|
||||
fprintf(stderr,"Packet too small, skip\n");
|
||||
continue;
|
||||
}
|
||||
}
|
||||
buf = wth->rec_data->data;
|
||||
ethertype = buf[12] << 8 | buf[13];
|
||||
// TODO Focus on IPv4 only
|
||||
if (ethertype == 0x0800) {
|
||||
process_frame(pibs, wth, buf);
|
||||
}
|
||||
}
|
||||
}
|
||||
wtap_close(wth);
|
||||
fprintf(stderr,"[INFO] Processing of filename %s done\n",pibs->filename);
|
||||
}else{
|
||||
fprintf(stderr, "[ERROR] Could not open filename %s,cause=%s\n",pibs->filename,
|
||||
wtap_strerror(err));
|
||||
}
|
||||
}
|
||||
|
||||
pibs_t* init(void)
|
||||
{
|
||||
pibs_t *pibs;
|
||||
|
||||
wtap_init(FALSE);
|
||||
pibs=calloc(sizeof(pibs_t),1);
|
||||
//TODO error handling
|
||||
//TODO check if size is correct
|
||||
pibs->filename = calloc(FILENAME_MAX,1);
|
||||
pibs->uuid = calloc(SZUUID,1);
|
||||
pibs->key = calloc(SZKEY,1);
|
||||
pibs->server = calloc(SZSERVER,1);
|
||||
// Initialize the various processors
|
||||
synseen_init(pibs);
|
||||
return pibs;
|
||||
}
|
||||
|
||||
void process_redis_list(pibs_t* pibs)
|
||||
{
|
||||
redisReply *reply;
|
||||
int rtype;
|
||||
snprintf(pibs->key, SZKEY, "analyzer:1:%s",pibs->uuid);
|
||||
pibs->ctx = redisConnect(pibs->server, pibs->port);
|
||||
if (pibs->ctx != NULL) {
|
||||
if (pibs->redisdb >0) {
|
||||
printf("[INFO] Select redis database %d\n", pibs->redisdb);
|
||||
reply = redisCommand(pibs->ctx, "SELECT %d", pibs->redisdb);
|
||||
if (reply) {
|
||||
rtype = reply->type;
|
||||
freeReplyObject(reply);
|
||||
if (rtype != REDIS_REPLY_STATUS) {
|
||||
printf("[ERROR] Cannot switch to database %d. Abort.",
|
||||
pibs->redisdb);
|
||||
return;
|
||||
}
|
||||
}
|
||||
}
|
||||
do {
|
||||
reply = redisCommand(pibs->ctx,"RPOP %s", pibs->key);
|
||||
if (reply) {
|
||||
rtype = reply->type;
|
||||
if (rtype == REDIS_REPLY_STRING ) {
|
||||
printf("#Need to proces file %s\n", reply->str);
|
||||
strncpy(pibs->filename, reply->str, FILENAME_MAX);
|
||||
process_file(pibs);
|
||||
}
|
||||
freeReplyObject(reply);
|
||||
}
|
||||
} while (rtype != REDIS_REPLY_NIL);
|
||||
} else {
|
||||
if (pibs->ctx->errstr) {
|
||||
fprintf(stderr, "Cannot connect to redis. Cause=%s\n",pibs->ctx->errstr);
|
||||
}
|
||||
}
|
||||
}
|
|
@ -0,0 +1,91 @@
|
|||
/*
|
||||
* pibs - Passive Identification of BackScatter
|
||||
*
|
||||
* Copyright (C) 2019 Gerard Wagener
|
||||
* Copyright (C) 2019 CIRCL Computer Incident Response Center Luxembourg
|
||||
* (SMILE gie).
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 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 Affero General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Affero General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
#include "pibs.h"
|
||||
|
||||
//FIXME not generic enough if more segments are needed
|
||||
int load_shmid_file(pibs_t* pibs)
|
||||
{
|
||||
FILE* fp;
|
||||
if (pibs->shmid_file[0]) {
|
||||
fp = fopen(pibs->shmid_file,"r");
|
||||
if (fp) {
|
||||
//FIXME check file
|
||||
fscanf(fp, "%d", &pibs->shmid);
|
||||
return pibs->shmid;
|
||||
}
|
||||
} else {
|
||||
pibs->errno_pibs = ERR_NO_SHMID_FILE;
|
||||
}
|
||||
return -1;
|
||||
}
|
||||
int pibs_shmat(pibs_t* pibs)
|
||||
{
|
||||
/* FIXME init function needs to break up in two functions. One that
|
||||
* initializes internal pibs structures as cli options etc
|
||||
* a second one for describing the data itself, size of bin_table
|
||||
* number of items etc.
|
||||
*/
|
||||
if (pibs->data) {
|
||||
free(pibs->data);
|
||||
pibs->data = NULL;
|
||||
}
|
||||
if (pibs->data) {
|
||||
pibs->errno_pibs = ERR_ATTACH_NOT_EMPTY;
|
||||
printf("TEST Data is not null\n");
|
||||
return -1;
|
||||
}
|
||||
if (!pibs->shmid_file[0]) {
|
||||
pibs->errno_pibs = ERR_NO_SHMID_FILE;
|
||||
return -1;
|
||||
}
|
||||
if (load_shmid_file(pibs) > 0) {
|
||||
pibs->data = shmat(pibs->shmid, NULL, SHM_RND);
|
||||
if ( (int) pibs->data == -1) {
|
||||
pibs->errno_copy = errno;
|
||||
} else {
|
||||
return 1;
|
||||
}
|
||||
}
|
||||
// Something did not work
|
||||
return -1;
|
||||
}
|
||||
|
||||
int pibs_shmget(pibs_t* pibs)
|
||||
{
|
||||
FILE* fp;
|
||||
pibs->shmid = shmget(IPC_PRIVATE, pibs->data_size, IPC_CREAT | 0600);
|
||||
if (pibs->shmid < 0) {
|
||||
pibs->errno_copy = errno;
|
||||
}
|
||||
|
||||
if (pibs->shmid_file[0]){
|
||||
fp = fopen(pibs->shmid_file, "w");
|
||||
if (fp) {
|
||||
fprintf(fp,"%d",pibs->shmid);
|
||||
fclose(fp);
|
||||
}
|
||||
//TODO error handling
|
||||
}
|
||||
//TODO attach to it and bzero it
|
||||
//setup the tables
|
||||
return pibs->shmid;
|
||||
}
|
||||
|
|
@ -0,0 +1,134 @@
|
|||
/*
|
||||
* pibs - Create lists of targets under SYN floods for bgp ranking
|
||||
*
|
||||
* Copyright (C) 2019 Gerard Wagener
|
||||
* Copyright (C) 2019 CIRCL Computer Incident Response Center Luxembourg
|
||||
* (SMILE gie).
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 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 Affero General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Affero General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
#include <stdio.h>
|
||||
#define __USE_XOPEN
|
||||
#include <time.h>
|
||||
#include "pibs.h"
|
||||
#include <gmodule.h>
|
||||
|
||||
void usage(void)
|
||||
{
|
||||
printf("Create lists of targets under SYN floods for BGP Ranking\n");
|
||||
printf("\n");
|
||||
printf("OPTIONS\n");
|
||||
printf(" -h Shows this screen\n");
|
||||
printf(" -r inputfile\n");
|
||||
printf(" Read pcap file from inputfile\n");
|
||||
printf(" -d directory\n");
|
||||
printf(" Root directory where the list should be stored\n");
|
||||
printf("\n");
|
||||
printf("DIRECTORY STRUCTURE\n");
|
||||
printf("<directory>/port/year/month/year-month-day.txt\n");
|
||||
}
|
||||
|
||||
char* create_path(pibs_t* pibs, uint16_t port, uint64_t ts)
|
||||
{
|
||||
struct tm tm;
|
||||
char s[32];
|
||||
char *out;
|
||||
out = calloc(1,FILENAME_MAX);
|
||||
if (out) {
|
||||
snprintf(s,32,"%ld",ts);
|
||||
if (strptime(s,"%s",&tm)){
|
||||
strftime((char*)&s,32,"%Y-%m-%d", &tm);
|
||||
//TODO use date sub-directory in case of too many files
|
||||
snprintf(out, 2*FILENAME_MAX, "%s/%d/%s.txt",pibs->outputfile,port,s);
|
||||
return out;
|
||||
}
|
||||
}
|
||||
//Something went wrong
|
||||
return NULL;
|
||||
}
|
||||
|
||||
//FIXME avoid mem allocation functions for each packet do them globaly per file
|
||||
void frame_to_bgpr(pibs_t* pibs, wtap *wth, uint8_t* eth,
|
||||
struct ip* ipv4, struct tcphdr* tcp)
|
||||
{
|
||||
char *dirname;
|
||||
dirname = create_path(pibs, ntohs(tcp->th_sport), wth->rec.ts.secs);
|
||||
if (dirname) {
|
||||
printf("%s\n", dirname);
|
||||
free(dirname);
|
||||
}
|
||||
}
|
||||
|
||||
gint cmp_ips(gconstpointer a, gconstpointer b)
|
||||
{
|
||||
uint32_t* x;
|
||||
uint32_t* y;
|
||||
x = (uint32_t*)a;
|
||||
y = (uint32_t*)b;
|
||||
return *x<*y;
|
||||
}
|
||||
|
||||
int main(int argc, char* argv[])
|
||||
{
|
||||
pibs_t* pibs;
|
||||
int opt;
|
||||
GTree *ip_tree;
|
||||
pibs = init();
|
||||
uint32_t *y;
|
||||
ip_tree = NULL;
|
||||
|
||||
while ((opt = getopt(argc, argv, "hr:d:")) != -1) {
|
||||
printf("%d\n", opt);
|
||||
switch (opt) {
|
||||
case 'h':
|
||||
usage();
|
||||
break;
|
||||
case 'r':
|
||||
strncpy(pibs->filename, optarg, FILENAME_MAX);
|
||||
pibs->filename[FILENAME_MAX-1] = '\0';
|
||||
break;
|
||||
case 'd':
|
||||
strncpy((char*)&(pibs->outputfile), optarg, FILENAME_MAX);
|
||||
pibs->outputfile[FILENAME_MAX-1] = '\0';
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
//sorted array insert operations -> o(n) not good if we have a lot of inserts
|
||||
//Problem: memalloc per each ip address
|
||||
//Problem: duplicates are added
|
||||
|
||||
// Gtree insert IP value several times
|
||||
|
||||
y = calloc(1,sizeof(uint32_t));
|
||||
*y = 34;
|
||||
// ip_list = g_list_insert_sorted_with_data (ip_list,y,&cmp_ips,NULL);
|
||||
// y = calloc(1,sizeof(uint32_t));
|
||||
// *y = 34;
|
||||
// ip_list = g_list_insert_sorted_with_data (ip_list,y,&cmp_ips,NULL);
|
||||
// y = calloc(1,sizeof(uint32_t));
|
||||
// *y = 99;
|
||||
// ip_list = g_list_insert_sorted_with_data (ip_list,y,&cmp_ips,NULL);
|
||||
|
||||
|
||||
return EXIT_SUCCESS;
|
||||
//Set call back function
|
||||
pibs->synseen_callback = &frame_to_bgpr;
|
||||
|
||||
if (pibs->filename[0]) {
|
||||
process_file(pibs);
|
||||
}
|
||||
|
||||
return EXIT_SUCCESS;
|
||||
}
|
|
@ -0,0 +1,76 @@
|
|||
/*
|
||||
* pibs - Create lists of isn having the same value than ip address
|
||||
*
|
||||
* Copyright (C) 2020 Gerard Wagener
|
||||
* Copyright (C) 2020 CIRCL Computer Incident Response Center Luxembourg
|
||||
* (SMILE gie).
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 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 Affero General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Affero General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
#include <stdio.h>
|
||||
#define __USE_XOPEN
|
||||
#include <time.h>
|
||||
#include "pibs.h"
|
||||
|
||||
void usage(void)
|
||||
{
|
||||
printf("Create lists of targets under SYN floods for BGP Ranking\n");
|
||||
printf("\n");
|
||||
printf("OPTIONS\n");
|
||||
printf(" -h Shows this screen\n");
|
||||
printf(" -r inputfile\n");
|
||||
printf(" Read pcap file from inputfile\n");
|
||||
printf("\n");
|
||||
printf("DIRECTORY STRUCTURE\n");
|
||||
printf("<directory>/port/year/month/year-month-day.txt\n");
|
||||
}
|
||||
|
||||
void process(pibs_t* pibs, wtap *wth, uint8_t* eth,
|
||||
struct ip* ipv4, struct tcphdr* tcp)
|
||||
{
|
||||
if (ipv4->ip_dst.s_addr == tcp->seq) {
|
||||
printf("%x\n",ntohl(tcp->seq));
|
||||
}
|
||||
}
|
||||
|
||||
int main(int argc, char* argv[])
|
||||
{
|
||||
pibs_t* pibs;
|
||||
int opt;
|
||||
pibs = init();
|
||||
|
||||
while ((opt = getopt(argc, argv, "hr:d:")) != -1) {
|
||||
printf("%d\n", opt);
|
||||
switch (opt) {
|
||||
case 'h':
|
||||
usage();
|
||||
break;
|
||||
case 'r':
|
||||
strncpy(pibs->filename, optarg, FILENAME_MAX);
|
||||
pibs->filename[FILENAME_MAX-1] = '\0';
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
//Bypass synseen logic to get all TCP packets
|
||||
pibs->bypass = 1;
|
||||
//Set call back function
|
||||
pibs->synseen_callback = &process;
|
||||
|
||||
if (pibs->filename[0]) {
|
||||
process_file(pibs);
|
||||
}
|
||||
|
||||
return EXIT_SUCCESS;
|
||||
}
|
|
@ -0,0 +1,28 @@
|
|||
/*
|
||||
* pibs - Passive Identification of BackScatter
|
||||
*
|
||||
* Copyright (C) 2019 Gerard Wagener
|
||||
* Copyright (C) 2019 CIRCL Computer Incident Response Center Luxembourg
|
||||
* (SMILE gie).
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 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 Affero General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Affero General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
#include "pibs.h"
|
||||
int main(int argc, char* argv[])
|
||||
{
|
||||
pibs_t* pibs;
|
||||
pibs = init();
|
||||
|
||||
return EXIT_SUCCESS;
|
||||
}
|
464
bin/pibs.c
464
bin/pibs.c
|
@ -18,455 +18,19 @@
|
|||
* You should have received a copy of the GNU Affero General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
#include <getopt.h>
|
||||
#include <assert.h>
|
||||
#include <string.h>
|
||||
#include <pcap/pcap.h>
|
||||
#include <wtap.h>
|
||||
#include <wtap-int.h>
|
||||
#include <unistd.h>
|
||||
#include <signal.h>
|
||||
#include <netinet/ip.h>
|
||||
#include <netinet/in.h>
|
||||
#include <netinet/tcp.h>
|
||||
#include <arpa/inet.h>
|
||||
#include <sys/socket.h>
|
||||
#include <sys/ipc.h>
|
||||
#include <sys/shm.h>
|
||||
#include <errno.h>
|
||||
#include "pibs.h"
|
||||
|
||||
#include <hiredis/hiredis.h>
|
||||
|
||||
//TODO test other values
|
||||
#define NBINS 1024 //Number of bins
|
||||
#define NBINITEMS 255 //Number of items per bin
|
||||
#define SZBIN 4
|
||||
#define SZUUID 40
|
||||
#define SZKEY 1024
|
||||
#define SZSERVER 1024
|
||||
#define NBINSCALE 2 // Scaling factor of the entire datastructure
|
||||
|
||||
#define HDBG(...) if (HASHDEBUG) fprintf(stderr, __VA_ARGS__)
|
||||
|
||||
#define ERR_ATTACH_NOT_EMPTY 11
|
||||
#define ERR_NO_SHMID_FILE 12
|
||||
|
||||
typedef struct pibs_header_s {
|
||||
uint8_t magic [4];
|
||||
uint8_t version;
|
||||
//Put some useful stuff here
|
||||
uint32_t next_item;
|
||||
uint32_t bin_offset;
|
||||
uint64_t data_size;
|
||||
uint32_t max_item;
|
||||
uint8_t padding [3];
|
||||
} pibs_header_t;
|
||||
|
||||
|
||||
/* TODO This can squezed. Timestamp can be expressed on 8 bits i.e. relative
|
||||
* minutes
|
||||
* IP can be represented with 16 bits ipaddr = ip / bin_size
|
||||
* Not sure if space can be saved in usual cases
|
||||
*/
|
||||
typedef struct item_s {
|
||||
uint32_t timestamp;
|
||||
uint32_t next_item;
|
||||
uint32_t ipaddr;
|
||||
} item_t;
|
||||
|
||||
/* Need to hash source IP addresses and record first seen and flags */
|
||||
typedef struct pibs_s {
|
||||
int errno_copy;
|
||||
int errno_pibs;
|
||||
char *filename;
|
||||
char *uuid;
|
||||
char *key;
|
||||
char *server;
|
||||
uint16_t port;
|
||||
redisContext *ctx;
|
||||
int should_dump_table;
|
||||
int show_backscatter;
|
||||
int show_stats;
|
||||
int should_create_shm;
|
||||
int should_attach;
|
||||
int should_writepcap;
|
||||
//TODO use self contained data structure that can be easily serialized
|
||||
//Put data structure in an entire block to easier serialize
|
||||
uint8_t *data;
|
||||
uint32_t next_block;
|
||||
uint32_t next_item;
|
||||
uint32_t bin_offset;
|
||||
uint64_t data_size;
|
||||
uint32_t* bin_table;
|
||||
uint32_t max_item;
|
||||
item_t* items;
|
||||
int shmid;
|
||||
char shmid_file [FILENAME_MAX];
|
||||
char outputfile[FILENAME_MAX];
|
||||
pcap_dumper_t* dumper;
|
||||
pcap_t* outcap;
|
||||
uint32_t redisdb;
|
||||
} pibs_t;
|
||||
|
||||
int load_shmid_file(pibs_t* pibs)
|
||||
void usage(void)
|
||||
{
|
||||
FILE* fp;
|
||||
if (pibs->shmid_file[0]) {
|
||||
fp = fopen(pibs->shmid_file,"r");
|
||||
if (fp) {
|
||||
//FIXME check file
|
||||
fscanf(fp, "%d", &pibs->shmid);
|
||||
return pibs->shmid;
|
||||
printf("Usage: pibs [OPTION] ...\n");
|
||||
printf("Identify backscatter in pacp files\n");
|
||||
printf("\nOPTIONS\n");
|
||||
printf("\n -n Create new shared memory segment data structure\n");
|
||||
printf("\n -i Write shared segment identifier in a file.\n");
|
||||
printf(" This option must be used in conjuntion with -n option\n");
|
||||
printf(" -r read pcap files and identity potential backscatter traffic\n");
|
||||
printf(" -b Show potential backscatter on stdout. The be used in conjuntion with -r\n");
|
||||
}
|
||||
} else {
|
||||
pibs->errno_pibs = ERR_NO_SHMID_FILE;
|
||||
}
|
||||
return -1;
|
||||
}
|
||||
|
||||
//TODO when attaching the next_item must be recovered if results
|
||||
//of previous runs need to be increased
|
||||
int pibs_shmat(pibs_t* pibs)
|
||||
{
|
||||
/* FIXME init function needs to break up in two functions. One that
|
||||
* initializes internal pibs structures as cli options etc
|
||||
* a second one for describing the data itself, size of bin_table
|
||||
* number of items etc.
|
||||
*/
|
||||
if (pibs->data) {
|
||||
free(pibs->data);
|
||||
pibs->data = NULL;
|
||||
}
|
||||
if (pibs->data) {
|
||||
pibs->errno_pibs = ERR_ATTACH_NOT_EMPTY;
|
||||
printf("TEST Data is not null\n");
|
||||
return -1;
|
||||
}
|
||||
if (!pibs->shmid_file[0]) {
|
||||
pibs->errno_pibs = ERR_NO_SHMID_FILE;
|
||||
return -1;
|
||||
}
|
||||
if (load_shmid_file(pibs) > 0) {
|
||||
pibs->data = shmat(pibs->shmid, NULL, SHM_RND);
|
||||
if ( (int) pibs->data == -1) {
|
||||
pibs->errno_copy = errno;
|
||||
} else {
|
||||
return 1;
|
||||
}
|
||||
}
|
||||
// Something did not work
|
||||
return -1;
|
||||
}
|
||||
|
||||
int pibs_shmget(pibs_t* pibs)
|
||||
{
|
||||
FILE* fp;
|
||||
pibs->shmid = shmget(IPC_PRIVATE, pibs->data_size, IPC_CREAT | 0600);
|
||||
if (pibs->shmid < 0) {
|
||||
pibs->errno_copy = errno;
|
||||
}
|
||||
|
||||
if (pibs->shmid_file[0]){
|
||||
fp = fopen(pibs->shmid_file, "w");
|
||||
if (fp) {
|
||||
fprintf(fp,"%d",pibs->shmid);
|
||||
fclose(fp);
|
||||
}
|
||||
//TODO error handling
|
||||
}
|
||||
//TODO attach to it and bzero it
|
||||
//setup the tables
|
||||
return pibs->shmid;
|
||||
}
|
||||
|
||||
/*
|
||||
* Returns -1 if not found
|
||||
* returns last timestamp if found
|
||||
*/
|
||||
int_fast64_t get_last_timestamp(pibs_t* pibs, uint32_t ip)
|
||||
{
|
||||
uint32_t idx;
|
||||
uint32_t i;
|
||||
//TODO explore alternative hashing functions
|
||||
//https://stackoverflow.com/questions/664014/what-integer-hash-function-are-good-that-accepts-an-integer-hash-key/12996028#12996028
|
||||
idx = ip % NBINS;
|
||||
HDBG("[TS] Checking for IP %x at index = %d\n", ip, idx);
|
||||
i = pibs->bin_table[idx];
|
||||
while (i){
|
||||
if (pibs->items[i].ipaddr == ip) {
|
||||
HDBG("[TS] Found item %x at position %d\n", ip , i);
|
||||
return pibs->items[i].timestamp;
|
||||
}
|
||||
i = pibs->items[i].next_item;
|
||||
}
|
||||
HDBG("[TS] IP: %x was not found return -1\n",ip);
|
||||
return -1;
|
||||
}
|
||||
|
||||
void insert_ip(pibs_t* pibs, uint32_t ip, uint32_t ts)
|
||||
{
|
||||
uint32_t idx;
|
||||
uint32_t i;
|
||||
uint32_t parent;
|
||||
|
||||
idx = ip % NBINS;
|
||||
HDBG("[INS] Lookup IP address %x. Hashed value: %d\n", ip, idx);
|
||||
parent = 0;
|
||||
if (pibs->bin_table[idx]){
|
||||
// There is already someone in the bin
|
||||
i = pibs->bin_table[idx];
|
||||
HDBG("[INS] Starting searching at position %d\n", i);
|
||||
do {
|
||||
HDBG("[INS] Iterating items at index %d. Current position: %d.\
|
||||
Next position = %d\n",
|
||||
idx,i,pibs->items[i].next_item);
|
||||
HDBG("[INS] Checking IP at address %p\n",&pibs->items[i]);
|
||||
if (pibs->items[i].ipaddr == ip) {
|
||||
HDBG("[INS] Found item %x at position %d\n", ip , i);
|
||||
HDBG("[INS] New timestamp for ip %x is %d\n",ip,ts);
|
||||
pibs->items[i].timestamp = ts;
|
||||
return;
|
||||
}
|
||||
parent = i;
|
||||
i = pibs->items[i].next_item;
|
||||
} while (i != 0 );
|
||||
HDBG("[INS] The IP %x was not found in the item list, last parent %d\n",
|
||||
ip, parent);
|
||||
}
|
||||
// The IP was not found in an item list or the hashed value wsa not present
|
||||
// in the bin table, so create a new item
|
||||
pibs->next_item++;
|
||||
if (pibs->next_item > pibs->max_item) {
|
||||
printf("FIXME run out of memory. Do something better than abort\n");
|
||||
//Go through old timestamps and keep linked list of stuff that can be
|
||||
//reused or do kind of defragmentation
|
||||
abort();
|
||||
}
|
||||
if (pibs->bin_table[idx] == 0) {
|
||||
pibs->bin_table[idx] = pibs->next_item;
|
||||
}
|
||||
HDBG("[INS] Insert ip %x at position %d, parent = %d\n", ip,
|
||||
pibs->next_item,parent);
|
||||
pibs->items[pibs->next_item].ipaddr = ip;
|
||||
pibs->items[pibs->next_item].timestamp = ts;
|
||||
if (parent) {
|
||||
pibs->items[parent].next_item = pibs->next_item;
|
||||
}
|
||||
}
|
||||
|
||||
void process_frame(pibs_t* pibs, wtap *wth,
|
||||
uint8_t *eth)
|
||||
{
|
||||
struct ip* ipv4;
|
||||
uint32_t ip;
|
||||
struct tcphdr* tcp;
|
||||
int_fast64_t lastseen;
|
||||
unsigned char* buf;
|
||||
size_t length;
|
||||
struct pcap_pkthdr pchdr;
|
||||
|
||||
buf = eth+14;
|
||||
length = wth->rec.rec_header.packet_header.caplen-14;
|
||||
|
||||
if (length < sizeof(struct ip)) {
|
||||
return;
|
||||
}
|
||||
|
||||
|
||||
ipv4 = (struct ip*)buf;
|
||||
// Focus only on TCP packets
|
||||
if (ipv4->ip_p != 6)
|
||||
return;
|
||||
|
||||
tcp = (struct tcphdr*)(buf+sizeof(struct ip));
|
||||
|
||||
memcpy(&ip, &ipv4->ip_src, 4);
|
||||
// Record only source ips where syn flag is set
|
||||
// TODO check other connection establishment alternatives
|
||||
if (tcp->th_flags == 2 ){
|
||||
insert_ip(pibs, ip, wth->rec.ts.secs);
|
||||
return;
|
||||
}
|
||||
|
||||
lastseen = get_last_timestamp(pibs, ip);
|
||||
|
||||
if (lastseen > 0){
|
||||
HDBG("IP %x %s was already seen before at %ld. Time difference %ld.\n"
|
||||
, ip, inet_ntoa(ipv4->ip_src), lastseen, wth->rec.ts.secs-lastseen);
|
||||
return;
|
||||
}
|
||||
// TODO keep these IPs in a hashtable and rank them
|
||||
if (pibs->show_backscatter) {
|
||||
printf("%s,%d,%d\n",
|
||||
inet_ntoa(ipv4->ip_src), tcp->th_flags, ntohs(tcp->th_sport));
|
||||
}
|
||||
//TODO relative time
|
||||
//Purge old ips?
|
||||
if (pibs->should_writepcap) {
|
||||
pchdr.ts.tv_sec = wth->rec.ts.secs;
|
||||
//TODO other part of the timestamp
|
||||
pchdr.ts.tv_usec = wth->rec.ts.nsecs / 1000;
|
||||
pchdr.caplen = wth->rec.rec_header.packet_header.caplen;
|
||||
pchdr.len = wth->rec.rec_header.packet_header.len;
|
||||
pcap_dump((u_char*)pibs->dumper, &pchdr, eth);
|
||||
}
|
||||
}
|
||||
|
||||
void process_file(pibs_t* pibs)
|
||||
{
|
||||
wtap *wth;
|
||||
int err;
|
||||
char *errinfo;
|
||||
gint64 data_offset;
|
||||
int ethertype;
|
||||
guint8 *buf;
|
||||
|
||||
fprintf(stderr,"Processing %s\n",pibs->filename);
|
||||
wth = wtap_open_offline ( pibs->filename, WTAP_TYPE_AUTO, (int*)&err,
|
||||
(char**)&errinfo, FALSE);
|
||||
if (wth) {
|
||||
/* Loop over the packets and adjust the headers */
|
||||
while (wtap_read(wth, &err, &errinfo, &data_offset)) {
|
||||
if (wth->rec.rec_type == REC_TYPE_PACKET) {
|
||||
if (wth->rec.tsprec == WTAP_TSPREC_USEC){
|
||||
if (wth->rec.rec_header.packet_header.caplen < 14) {
|
||||
fprintf(stderr,"Packet too small, skip\n");
|
||||
continue;
|
||||
}
|
||||
}
|
||||
buf = wth->rec_data->data;
|
||||
ethertype = buf[12] << 8 | buf[13];
|
||||
// TODO Focus on IPv4 only
|
||||
if (ethertype == 0x0800) {
|
||||
process_frame(pibs, wth, buf);
|
||||
}
|
||||
}
|
||||
}
|
||||
wtap_close(wth);
|
||||
fprintf(stderr,"[INFO] Processing of filename %s done\n",pibs->filename);
|
||||
}else{
|
||||
fprintf(stderr, "[ERROR] Could not open filename %s,cause=%s\n",pibs->filename,
|
||||
wtap_strerror(err));
|
||||
}
|
||||
}
|
||||
|
||||
pibs_t* init(void)
|
||||
{
|
||||
pibs_t *pibs;
|
||||
|
||||
wtap_init(FALSE);
|
||||
pibs=calloc(sizeof(pibs_t),1);
|
||||
//TODO check if size is correct
|
||||
pibs->data_size = sizeof(pibs_header_t) + NBINSCALE * NBINS * SZBIN * NBINITEMS * sizeof(item_t);
|
||||
pibs->data = calloc(pibs->data_size,1);
|
||||
pibs->filename = calloc(FILENAME_MAX,1);
|
||||
pibs->uuid = calloc(SZUUID,1);
|
||||
pibs->key = calloc(SZKEY,1);
|
||||
pibs->server = calloc(SZSERVER,1);
|
||||
printf("#Internal look up structure size in bytes: %ld\n", pibs->data_size);
|
||||
// Build header
|
||||
pibs->data[0]='P';
|
||||
pibs->data[1] = 'I';
|
||||
pibs->data[2] = 'B';
|
||||
pibs->data[3] = 'S';
|
||||
pibs->data[4] = 1; //version 1
|
||||
pibs->next_block = sizeof(pibs_header_t);
|
||||
pibs->bin_offset = pibs->next_block;
|
||||
printf("#data address is %p\n",pibs->data);
|
||||
pibs->bin_table = (uint32_t*)(pibs->data+pibs->bin_offset);
|
||||
printf("#bin_table address is %p\n", pibs->bin_table);
|
||||
// Create bins
|
||||
pibs->next_block+=SZBIN * NBINS;
|
||||
printf("#next block %d\n", pibs->next_block);
|
||||
pibs->items = (item_t*)(pibs->data+pibs->next_block);
|
||||
pibs->next_item = 0;
|
||||
printf("#items are address %p\n", pibs->items);
|
||||
pibs->max_item = NBINS * NBINITEMS;
|
||||
printf("#max_item: %d\n", pibs->max_item);
|
||||
return pibs;
|
||||
}
|
||||
|
||||
void pibs_dump_raw(pibs_t* pibs)
|
||||
{
|
||||
int i;
|
||||
printf("#RAW table dump\n");
|
||||
printf("#Index next_item\n");
|
||||
printf("#BINs\n");
|
||||
for (i=0; i< NBINS; i++) {
|
||||
printf("%d %d\n", i, pibs->bin_table[i]);
|
||||
}
|
||||
printf("#ITEMS\n");
|
||||
printf("#Index next_item, timestamp, ipaddr\n");
|
||||
for (i=0; i < NBINITEMS * NBINS; i++) {
|
||||
printf("%d %d %d %x\n", i, pibs->items[i].next_item,
|
||||
pibs->items[i].timestamp,
|
||||
pibs->items[i].ipaddr);
|
||||
}
|
||||
}
|
||||
|
||||
void pibs_dump_stats(pibs_t* pibs)
|
||||
{
|
||||
int i;
|
||||
int j;
|
||||
int cnt;
|
||||
uint64_t sum;
|
||||
sum = 0;
|
||||
printf("#Bin table\n");
|
||||
printf("#Bin number, Item offset, number of items\n");
|
||||
for (i=0; i < NBINS; i++) {
|
||||
j= pibs->bin_table[i];
|
||||
cnt = 0;
|
||||
while (j) {
|
||||
cnt++;
|
||||
j=pibs->items[j].next_item;
|
||||
}
|
||||
sum+=cnt;
|
||||
printf("%d %d %d\n", i, pibs->bin_table[i], cnt);
|
||||
}
|
||||
printf("#Number of unique IP addresses: %ld\n", sum);
|
||||
}
|
||||
|
||||
void process_redis_list(pibs_t* pibs)
|
||||
{
|
||||
redisReply *reply;
|
||||
int rtype;
|
||||
snprintf(pibs->key, SZKEY, "analyzer:1:%s",pibs->uuid);
|
||||
pibs->ctx = redisConnect(pibs->server, pibs->port);
|
||||
if (pibs->ctx != NULL) {
|
||||
if (pibs->redisdb >0) {
|
||||
printf("[INFO] Select redis database %d\n", pibs->redisdb);
|
||||
reply = redisCommand(pibs->ctx, "SELECT %d", pibs->redisdb);
|
||||
if (reply) {
|
||||
rtype = reply->type;
|
||||
freeReplyObject(reply);
|
||||
if (rtype != REDIS_REPLY_STATUS) {
|
||||
printf("[ERROR] Cannot switch to database %d. Abort.",
|
||||
pibs->redisdb);
|
||||
return;
|
||||
}
|
||||
}
|
||||
}
|
||||
do {
|
||||
reply = redisCommand(pibs->ctx,"LPOP %s", pibs->key);
|
||||
if (reply) {
|
||||
rtype = reply->type;
|
||||
if (rtype == REDIS_REPLY_STRING ) {
|
||||
printf("#Need to proces file %s\n", reply->str);
|
||||
strncpy(pibs->filename, reply->str, FILENAME_MAX);
|
||||
process_file(pibs);
|
||||
}
|
||||
freeReplyObject(reply);
|
||||
}
|
||||
} while (rtype != REDIS_REPLY_NIL);
|
||||
} else {
|
||||
if (pibs->ctx->errstr) {
|
||||
fprintf(stderr, "Cannot connect to redis. Cause=%s\n",pibs->ctx->errstr);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
int main(int argc, char* argv[])
|
||||
{
|
||||
|
@ -478,7 +42,7 @@ int main(int argc, char* argv[])
|
|||
|
||||
fprintf(stderr, "[INFO] pid = %d\n",(int)getpid());
|
||||
|
||||
while ((opt = getopt(argc, argv, "r:dbsni:au:z:p:w:y:")) != -1) {
|
||||
while ((opt = getopt(argc, argv, "r:dbsni:au:z:p:w:y:h")) != -1) {
|
||||
switch (opt) {
|
||||
case 'r':
|
||||
strncpy(pibs->filename, optarg, FILENAME_MAX);
|
||||
|
@ -517,7 +81,9 @@ int main(int argc, char* argv[])
|
|||
case 'y':
|
||||
pibs->redisdb = atoi(optarg);
|
||||
break;
|
||||
|
||||
case 'h':
|
||||
usage();
|
||||
break;
|
||||
default: /* '?' */
|
||||
|
||||
fprintf(stderr, "[ERROR] Invalid command line was specified\n");
|
||||
|
@ -560,7 +126,7 @@ int main(int argc, char* argv[])
|
|||
}
|
||||
|
||||
if (pibs->show_backscatter)
|
||||
printf("#source IP, TCP flags, source port\n");
|
||||
printf("#timestamp, source IP, TCP flags, source port\n");
|
||||
if (pibs->filename[0]) {
|
||||
process_file(pibs);
|
||||
}
|
||||
|
|
|
@ -0,0 +1,136 @@
|
|||
/*
|
||||
* pibs - Passive Identification of BackScatter
|
||||
*
|
||||
* Copyright (C) 2019 Gerard Wagener
|
||||
* Copyright (C) 2019 CIRCL Computer Incident Response Center Luxembourg
|
||||
* (SMILE gie).
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 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 Affero General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Affero General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
#ifndef _PIBS_H_
|
||||
#define _PIBS_H_
|
||||
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
#include <getopt.h>
|
||||
#include <assert.h>
|
||||
#include <string.h>
|
||||
#include <pcap/pcap.h>
|
||||
#include <wtap.h>
|
||||
#include <wtap-int.h>
|
||||
#include <unistd.h>
|
||||
#include <signal.h>
|
||||
#include <netinet/ip.h>
|
||||
#include <netinet/in.h>
|
||||
#include <netinet/tcp.h>
|
||||
#include <arpa/inet.h>
|
||||
#include <sys/socket.h>
|
||||
#include <sys/ipc.h>
|
||||
#include <sys/shm.h>
|
||||
#include <errno.h>
|
||||
|
||||
#include <hiredis/hiredis.h>
|
||||
|
||||
//TODO test other values
|
||||
#define NBINS 1024 //Number of bins
|
||||
#define NBINITEMS 255 //Number of items per bin
|
||||
#define SZBIN 4
|
||||
#define SZUUID 40
|
||||
#define SZKEY 1024
|
||||
#define SZSERVER 1024
|
||||
#define NBINSCALE 2 // Scaling factor of the entire datastructure
|
||||
|
||||
#define HDBG(...) if (HASHDEBUG) fprintf(stderr, __VA_ARGS__)
|
||||
|
||||
#define ERR_ATTACH_NOT_EMPTY 11
|
||||
#define ERR_NO_SHMID_FILE 12
|
||||
|
||||
typedef struct pibs_header_s {
|
||||
uint8_t magic [4];
|
||||
uint8_t version;
|
||||
//Put some useful stuff here
|
||||
uint32_t next_item;
|
||||
uint32_t bin_offset;
|
||||
uint64_t data_size;
|
||||
uint32_t max_item;
|
||||
uint8_t padding [3];
|
||||
} pibs_header_t;
|
||||
|
||||
|
||||
/* TODO This can squezed. Timestamp can be expressed on 8 bits i.e. relative
|
||||
* minutes
|
||||
* IP can be represented with 16 bits ipaddr = ip / bin_size
|
||||
* Not sure if space can be saved in usual cases
|
||||
*/
|
||||
typedef struct item_s {
|
||||
uint32_t timestamp;
|
||||
uint32_t next_item;
|
||||
uint32_t ipaddr;
|
||||
} item_t;
|
||||
|
||||
/* Need to hash source IP addresses and record first seen and flags */
|
||||
typedef struct pibs_s {
|
||||
int errno_copy;
|
||||
int errno_pibs;
|
||||
char *filename;
|
||||
char *uuid;
|
||||
char *key;
|
||||
char *server;
|
||||
uint16_t port;
|
||||
redisContext *ctx;
|
||||
int should_dump_table;
|
||||
int show_backscatter;
|
||||
int show_stats;
|
||||
int should_create_shm;
|
||||
int should_attach;
|
||||
int should_writepcap;
|
||||
//TODO use self contained data structure that can be easily serialized
|
||||
//Put data structure in an entire block to easier serialize
|
||||
uint8_t *data;
|
||||
uint32_t next_block;
|
||||
uint32_t next_item;
|
||||
uint32_t bin_offset;
|
||||
uint64_t data_size;
|
||||
uint32_t* bin_table;
|
||||
uint32_t max_item;
|
||||
item_t* items;
|
||||
int shmid;
|
||||
char shmid_file [FILENAME_MAX];
|
||||
char outputfile[FILENAME_MAX];
|
||||
pcap_dumper_t* dumper;
|
||||
pcap_t* outcap;
|
||||
uint32_t redisdb;
|
||||
void* synseen_callback;
|
||||
int bypass;
|
||||
} pibs_t;
|
||||
|
||||
int load_shmid_file(pibs_t* pibs);
|
||||
int pibs_shmat(pibs_t* pibs);
|
||||
int pibs_shmget(pibs_t* pibs);
|
||||
int_fast64_t get_last_timestamp(pibs_t* pibs, uint32_t ip);
|
||||
void insert_ip(pibs_t* pibs, uint32_t ip, uint32_t ts);
|
||||
void process_frame(pibs_t* pibs, wtap *wth, uint8_t *eth);
|
||||
void process_file(pibs_t* pibs);
|
||||
void pibs_dump_raw(pibs_t* pibs);
|
||||
void pibs_dump_stats(pibs_t* pibs);
|
||||
void process_redis_list(pibs_t* pibs);
|
||||
void synseen_process_frame(pibs_t *pibs, wtap *wth, uint8_t* eth,
|
||||
struct ip* ipv4, struct tcphdr* tcp);
|
||||
int synseen_init(pibs_t* pibs);
|
||||
pibs_t* init(void);
|
||||
|
||||
typedef void (* synseen_callback_t)(pibs_t* pibs, wtap *wth, uint8_t* eth,
|
||||
struct ip* ipv4, struct tcphdr* tcp);
|
||||
|
||||
#endif
|
|
@ -0,0 +1,212 @@
|
|||
/*
|
||||
* pibs - Passive Identification of BackScatter
|
||||
*
|
||||
* Copyright (C) 2019 Gerard Wagener
|
||||
* Copyright (C) 2019 CIRCL Computer Incident Response Center Luxembourg
|
||||
* (SMILE gie).
|
||||
*
|
||||
* This program is free software: you can redistribute it and/or modify
|
||||
* it under the terms of the GNU Affero General Public License as published by
|
||||
* the Free Software Foundation, either version 3 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 Affero General Public License for more details.
|
||||
*
|
||||
* You should have received a copy of the GNU Affero General Public License
|
||||
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
#include "pibs.h"
|
||||
//TODO when attaching the next_item must be recovered if results
|
||||
//of previous runs need to be increased
|
||||
/*
|
||||
* Returns -1 if not found
|
||||
* returns last timestamp if found
|
||||
*/
|
||||
int_fast64_t get_last_timestamp(pibs_t* pibs, uint32_t ip)
|
||||
{
|
||||
uint32_t idx;
|
||||
uint32_t i;
|
||||
//TODO explore alternative hashing functions
|
||||
//https://stackoverflow.com/questions/664014/what-integer-hash-function-are-good-that-accepts-an-integer-hash-key/12996028#12996028
|
||||
idx = ip % NBINS;
|
||||
HDBG("[TS] Checking for IP %x at index = %d\n", ip, idx);
|
||||
i = pibs->bin_table[idx];
|
||||
while (i){
|
||||
if (pibs->items[i].ipaddr == ip) {
|
||||
HDBG("[TS] Found item %x at position %d\n", ip , i);
|
||||
return pibs->items[i].timestamp;
|
||||
}
|
||||
i = pibs->items[i].next_item;
|
||||
}
|
||||
HDBG("[TS] IP: %x was not found return -1\n",ip);
|
||||
return -1;
|
||||
}
|
||||
|
||||
void insert_ip(pibs_t* pibs, uint32_t ip, uint32_t ts)
|
||||
{
|
||||
uint32_t idx;
|
||||
uint32_t i;
|
||||
uint32_t parent;
|
||||
|
||||
idx = ip % NBINS;
|
||||
HDBG("[INS] Lookup IP address %x. Hashed value: %d\n", ip, idx);
|
||||
parent = 0;
|
||||
if (pibs->bin_table[idx]){
|
||||
// There is already someone in the bin
|
||||
i = pibs->bin_table[idx];
|
||||
HDBG("[INS] Starting searching at position %d\n", i);
|
||||
do {
|
||||
HDBG("[INS] Iterating items at index %d. Current position: %d.\
|
||||
Next position = %d\n",
|
||||
idx,i,pibs->items[i].next_item);
|
||||
HDBG("[INS] Checking IP at address %p\n",&pibs->items[i]);
|
||||
if (pibs->items[i].ipaddr == ip) {
|
||||
HDBG("[INS] Found item %x at position %d\n", ip , i);
|
||||
HDBG("[INS] New timestamp for ip %x is %d\n",ip,ts);
|
||||
pibs->items[i].timestamp = ts;
|
||||
return;
|
||||
}
|
||||
parent = i;
|
||||
i = pibs->items[i].next_item;
|
||||
} while (i != 0 );
|
||||
HDBG("[INS] The IP %x was not found in the item list, last parent %d\n",
|
||||
ip, parent);
|
||||
}
|
||||
// The IP was not found in an item list or the hashed value wsa not present
|
||||
// in the bin table, so create a new item
|
||||
pibs->next_item++;
|
||||
if (pibs->next_item > pibs->max_item) {
|
||||
printf("FIXME run out of memory. Do something better than abort\n");
|
||||
//Go through old timestamps and keep linked list of stuff that can be
|
||||
//reused or do kind of defragmentation
|
||||
abort();
|
||||
}
|
||||
if (pibs->bin_table[idx] == 0) {
|
||||
pibs->bin_table[idx] = pibs->next_item;
|
||||
}
|
||||
HDBG("[INS] Insert ip %x at position %d, parent = %d\n", ip,
|
||||
pibs->next_item,parent);
|
||||
pibs->items[pibs->next_item].ipaddr = ip;
|
||||
pibs->items[pibs->next_item].timestamp = ts;
|
||||
if (parent) {
|
||||
pibs->items[parent].next_item = pibs->next_item;
|
||||
}
|
||||
}
|
||||
|
||||
void pibs_dump_raw(pibs_t* pibs)
|
||||
{
|
||||
int i;
|
||||
printf("#RAW table dump\n");
|
||||
printf("#Index next_item\n");
|
||||
printf("#BINs\n");
|
||||
for (i=0; i< NBINS; i++) {
|
||||
printf("%d %d\n", i, pibs->bin_table[i]);
|
||||
}
|
||||
printf("#ITEMS\n");
|
||||
printf("#Index next_item, timestamp, ipaddr\n");
|
||||
for (i=0; i < NBINITEMS * NBINS; i++) {
|
||||
printf("%d %d %d %x\n", i, pibs->items[i].next_item,
|
||||
pibs->items[i].timestamp,
|
||||
pibs->items[i].ipaddr);
|
||||
}
|
||||
}
|
||||
|
||||
void pibs_dump_stats(pibs_t* pibs)
|
||||
{
|
||||
int i;
|
||||
int j;
|
||||
int cnt;
|
||||
uint64_t sum;
|
||||
sum = 0;
|
||||
printf("#Bin table\n");
|
||||
printf("#Bin number, Item offset, number of items\n");
|
||||
for (i=0; i < NBINS; i++) {
|
||||
j= pibs->bin_table[i];
|
||||
cnt = 0;
|
||||
while (j) {
|
||||
cnt++;
|
||||
j=pibs->items[j].next_item;
|
||||
}
|
||||
sum+=cnt;
|
||||
printf("%d %d %d\n", i, pibs->bin_table[i], cnt);
|
||||
}
|
||||
printf("#Number of unique IP addresses: %ld\n", sum);
|
||||
}
|
||||
|
||||
void synseen_process_frame(pibs_t *pibs, wtap *wth, uint8_t* eth,
|
||||
struct ip* ipv4, struct tcphdr* tcp)
|
||||
{
|
||||
synseen_callback_t synseen_callback;
|
||||
int_fast64_t lastseen;
|
||||
uint32_t ip;
|
||||
struct pcap_pkthdr pchdr;
|
||||
memcpy(&ip, &ipv4->ip_src, 4);
|
||||
if (!pibs->bypass) {
|
||||
// Record only source ips where syn flag is set
|
||||
// TODO check other connection establishment alternatives
|
||||
if (tcp->th_flags == 2 ){
|
||||
insert_ip(pibs, ip, wth->rec.ts.secs);
|
||||
return;
|
||||
}
|
||||
|
||||
lastseen = get_last_timestamp(pibs, ip);
|
||||
|
||||
if (lastseen > 0){
|
||||
HDBG("IP %x %s was already seen before at %ld. Time difference %ld.\n"
|
||||
, ip, inet_ntoa(ipv4->ip_src), lastseen, wth->rec.ts.secs-lastseen);
|
||||
return;
|
||||
}
|
||||
// TODO keep these IPs in a hashtable and rank them
|
||||
if (pibs->show_backscatter) {
|
||||
printf("%ld,%s,%d,%d\n",
|
||||
wth->rec.ts.secs, inet_ntoa(ipv4->ip_src), tcp->th_flags,
|
||||
ntohs(tcp->th_sport));
|
||||
}
|
||||
//TODO relative time
|
||||
//Purge old ips?
|
||||
if (pibs->should_writepcap) {
|
||||
pchdr.ts.tv_sec = wth->rec.ts.secs;
|
||||
//TODO other part of the timestamp
|
||||
pchdr.ts.tv_usec = wth->rec.ts.nsecs / 1000;
|
||||
pchdr.caplen = wth->rec.rec_header.packet_header.caplen;
|
||||
pchdr.len = wth->rec.rec_header.packet_header.len;
|
||||
pcap_dump((u_char*)pibs->dumper, &pchdr, eth);
|
||||
}
|
||||
}
|
||||
if (pibs->synseen_callback) {
|
||||
synseen_callback = pibs->synseen_callback;
|
||||
synseen_callback(pibs, wth, eth, ipv4, tcp);
|
||||
}
|
||||
}
|
||||
|
||||
int synseen_init(pibs_t* pibs)
|
||||
{
|
||||
pibs->data_size = sizeof(pibs_header_t) + NBINSCALE * NBINS * SZBIN * NBINITEMS * sizeof(item_t);
|
||||
pibs->data = calloc(pibs->data_size,1);
|
||||
printf("#Internal look up structure size in bytes: %ld\n", pibs->data_size);
|
||||
// Build header
|
||||
pibs->data[0]='P';
|
||||
pibs->data[1] = 'I';
|
||||
pibs->data[2] = 'B';
|
||||
pibs->data[3] = 'S';
|
||||
pibs->data[4] = 1; //version 1
|
||||
|
||||
pibs->next_block = sizeof(pibs_header_t);
|
||||
pibs->bin_offset = pibs->next_block;
|
||||
printf("#data address is %p\n",pibs->data);
|
||||
pibs->bin_table = (uint32_t*)(pibs->data+pibs->bin_offset);
|
||||
printf("#bin_table address is %p\n", pibs->bin_table);
|
||||
// Create bins
|
||||
pibs->next_block+=SZBIN * NBINS;
|
||||
printf("#next block %d\n", pibs->next_block);
|
||||
pibs->items = (item_t*)(pibs->data+pibs->next_block);
|
||||
pibs->next_item = 0;
|
||||
printf("#items are address %p\n", pibs->items);
|
||||
pibs->max_item = NBINS * NBINITEMS;
|
||||
printf("#max_item: %d\n", pibs->max_item);
|
||||
return 1;
|
||||
}
|
Loading…
Reference in New Issue