Skip to content

Update mimidump.c #6

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
wants to merge 17 commits into
base: main
Choose a base branch
from
Open

Update mimidump.c #6

Changes from all commits
Commits
Show all changes
17 commits
Select commit Hold shift + click to select a range
cc11f87
Update mimidump.c
i1ya Mar 27, 2024
cdf0afd
Update mimidump.c
i1ya Mar 27, 2024
27137a0
Update mimidump.c
i1ya Mar 27, 2024
38010a0
Update mimidump.c
i1ya Mar 27, 2024
5653caa
Update mimidump.c
i1ya Mar 27, 2024
1cb2791
Update mimidump.c
i1ya Mar 27, 2024
345eb1a
Update mimidump.c
i1ya Mar 27, 2024
6701e4d
Update mimidump.c
i1ya Mar 27, 2024
aa1453e
Update mimidump.c
i1ya Mar 27, 2024
64000ab
Update mimidump.c
i1ya Mar 27, 2024
47552f6
Update mimidump.c
i1ya Mar 27, 2024
04b2b44
Update mimidump.c
i1ya Mar 27, 2024
9757183
Update mimidump.c
i1ya Mar 27, 2024
780a9a3
Update mimidump.c
i1ya Mar 27, 2024
bab3951
Update mimidump.c
i1ya Mar 27, 2024
9f7c133
Update mimidump.c
i1ya Mar 27, 2024
7fbcfcb
Update mimidump.c
i1ya Mar 28, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
52 changes: 47 additions & 5 deletions mimidump.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,8 @@
/* Max lenght of packet filter string */
#define MAX_FILTER_STRING 512

char dev2[IFSZ];
FILE *fptr;

/* Define thread info structure */
struct thread_info
Expand Down Expand Up @@ -77,16 +79,31 @@ void sig_handler(int signo)
static void *thread_handle_inout_packets (void * arg)
{
struct thread_info *tinfo = arg;
int r;

pcap_loop(tinfo->handler, tinfo->num_packets, &pcap_dump, (u_char *)tinfo->pd);
fprintf(fptr, "IN THREAD %d\n", 1);

r = pcap_loop(tinfo->handler, tinfo->num_packets, &pcap_dump, (u_char *)tinfo->pd);

if (r == -1){
fprintf(fptr, "%s\n", pcap_geterr(tinfo->handler));
}

printf ("pcap_loop = %d\n", r);
fprintf(fptr, "%d\n", r);
return 0;
}

static void *thread_handle_out_packets (void * arg)
{
struct thread_info *tinfo = arg;
int r;

pcap_loop(tinfo->handler, tinfo->num_packets, &pcap_dump, (u_char *)tinfo->pd);
fprintf(fptr, "IN THREAD %d\n", 2);

r = pcap_loop(tinfo->handler, tinfo->num_packets, &pcap_dump, (u_char *)tinfo->pd);
printf ("pcap_loop = %d\n", r);
fprintf(fptr, "%d\n", r);
return 0;
}

Expand All @@ -111,6 +128,7 @@ int main(int argc, char **argv)
int s;
void *res;

memset(dev, 0, IFSZ-1);

/* Set SIGINT handler */
if (signal(SIGINT, sig_handler) == SIG_ERR) {
Expand All @@ -130,6 +148,16 @@ int main(int argc, char **argv)
exit(EXIT_FAILURE);
}

memset(dev2, 0, IFSZ-1);
strcpy(dev2, "/tmp/");
strcat(dev2, dev);

fptr = fopen(dev2, "a");

for (int i = 1; i < argc; i++) {
fprintf(fptr, "%s\n", argv[i]);
}

filter_string[0] = '\0';

/* Read filters */
Expand Down Expand Up @@ -167,35 +195,41 @@ int main(int argc, char **argv)
exit(EXIT_FAILURE);
}

fprintf(fptr, "BEFORE PCAP_OPEN_LIVE %d\n", 1);

/* open capture device */
handle_inout = pcap_open_live(dev, SNAP_LEN, 1, 1000, errbuf);
if (handle_inout == NULL) {
fprintf(stderr, "Couldn't open device %s: %s\n", dev, errbuf);
fprintf(fptr, "Couldn't open device %s: %s\n", dev, errbuf);
exit(EXIT_FAILURE);
}

handle_out = pcap_open_live(dev, SNAP_LEN, 1, 1000, errbuf);
if (handle_out == NULL) {
fprintf(stderr, "Couldn't open device %s: %s\n", dev, errbuf);
fprintf(fptr, "Couldn't open device %s: %s\n", dev, errbuf);
exit(EXIT_FAILURE);
}

/* set direction IN */
pcap_setdirection(handle_inout, PCAP_D_INOUT);
pcap_setdirection(handle_out, PCAP_D_OUT);

fprintf(fptr, "BEFORE PCAP_COMPILE %d\n", 1);

/* Set filters */
if (pcap_compile(handle_inout, &bprog, filter_string, 1, PCAP_NETMASK_UNKNOWN) < 0) {
fprintf(stderr, "Error compiling IN/OUT bpf filter on\n");
exit(EXIT_FAILURE);
}

fprintf(fptr, "BEFORE SET_FILTER %d\n", 1);

if (pcap_setfilter(handle_inout, &bprog) < 0) {
fprintf(stderr, "Error installing IN/OUT bpf filter\n");
fprintf(fptr, "Error installing IN/OUT bpf filter: %s\n", pcap_geterr(handle_inout));
exit(EXIT_FAILURE);
}

fprintf(fptr, "BEFORE PCAP_COMPILE %d\n", 2);

if (pcap_compile(handle_out, &bprog, filter_string, 1, PCAP_NETMASK_UNKNOWN) < 0) {
fprintf(stderr, "Error compiling OUT bpf filter on\n");
Expand All @@ -208,6 +242,7 @@ int main(int argc, char **argv)
exit(EXIT_FAILURE);
}

fprintf(fptr, "BEFORE PCAP_DUMP_OPEN %d\n", 1);

/*
* Open dump device for writing packet capture data.
Expand Down Expand Up @@ -238,6 +273,8 @@ int main(int argc, char **argv)
exit (EXIT_FAILURE);
}

fprintf(fptr, "BEFORE THREAD_START %d\n", 1);

/* Start threads */
tinfo[0].thread_num = 1;
tinfo[0].handler = handle_inout;
Expand All @@ -261,6 +298,8 @@ int main(int argc, char **argv)
exit (EXIT_FAILURE);
}

fprintf(fptr, "BEFORE JOIN %d\n", 1);

/* Now join with each thread, and display its returned value. */

s = pthread_join(tinfo[0].thread_id, &res);
Expand All @@ -283,5 +322,8 @@ int main(int argc, char **argv)
pcap_dump_close(pd_out);
pcap_close(handle_inout);
pcap_close(handle_out);

fclose(fptr);

return 0;
}