gbucchino/tcp_metrics
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update project

Browse Source
This commit is contained in:
Geoffrey Bucchino 2024-07-11 10:53:45 +02:00
parent 63c1d4cc5d
commit 91591626fb
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
exec.sh
View File

@ -2,4 +2,5 @@
clang-11 -g -O2 -target bpf -c tp_tcp.c -o tp_tcp.o && \
gcc ic.c load_bpf.c -o load_bpf -lbpf && \
sudo ./load_bpf 192.168.1.68 f32d493484526abc _HK7-cwCZuOiaBIFi17J3riUeQ8OeR6oOp9o3QZMNpehdJMTkleR4B7-CczXSzwhx656GMZi3m6h15h59burbg== tcp_metrics
#sudo ./load_bpf 192.168.1.68 f32d493484526abc _HK7-cwCZuOiaBIFi17J3riUeQ8OeR6oOp9o3QZMNpehdJMTkleR4B7-CczXSzwhx656GMZi3m6h15h59burbg== tcp_metrics
sudo ./load_bpf 10.231.246.26 392fcb79fc296d8e EwmJtlAXAlJO_e1zjYwxLL2lD3E9jgDRAbba3Wsssn7HcqXKv1OrsmZ66ZlEVwwNMG6gx3_AxqMFnpr6MjuSZQ== tcp_metrics

BIN
influxdb.pcap
View File

Binary file not shown.

4
load_bpf.c
View File

@ -131,7 +131,7 @@ int main(int argc, char *argv[]){
// We have a new packet
if (indexPackets > index){
index = indexPackets;
printf("Index: %d %d\n", index, indexPackets);
err = bpf_map_lookup_elem(map_fd, &keys, &s_reset);
if (err == 0){
struct in_addr *src = (struct in_addr*)&s_reset.saddr;
@ -146,7 +146,7 @@ int main(int argc, char *argv[]){
printf("Sport: %d; dport: %d %d %d %s - %s\n", s_reset.sport, s_reset.dport, s_reset.family, s_reset.proto, tmp, d);
// Get the last value from InfluxDB
lastValue = ic_read(s, d);
//lastValue = ic_read(s, d);
// Send data to InfluxDB
snprintf(buf, BUF_SIZE, "host=%s", s);