7 #include <sys/select.h>
10 #include <libmnl/libmnl.h>
11 #include <linux/netfilter/nfnetlink.h>
12 #include <linux/netfilter/nfnetlink_conntrack.h>
13 #include <linux/netfilter/nf_conntrack_common.h>
14 #include <linux/netfilter/nf_conntrack_tcp.h>
16 static void put_msg(
char *buf, uint16_t i,
int seq)
20 struct nlattr *nest1, *nest2;
23 nlh->nlmsg_type = (NFNL_SUBSYS_CTNETLINK << 8) | IPCTNL_MSG_CT_NEW;
24 nlh->nlmsg_flags = NLM_F_REQUEST|NLM_F_CREATE|NLM_F_EXCL|NLM_F_ACK;
28 nfh->nfgen_family = AF_INET;
29 nfh->version = NFNETLINK_V0;
68 static int cb_err(
const struct nlmsghdr *nlh,
void *data)
70 struct nlmsgerr *err = (
void *)(nlh + 1);
72 printf(
"message with seq %u has failed: %s\n",
73 nlh->nlmsg_seq, strerror(-err->error));
77 static mnl_cb_t cb_ctl_array[NLMSG_MIN_TYPE] = {
78 [NLMSG_ERROR] = cb_err,
86 char rcv_buf[MNL_SOCKET_BUFFER_SIZE];
90 perror(
"mnl_socket_recvfrom");
101 FD_SET(fd, &readfds);
103 ret = select(fd+1, &readfds, NULL, NULL, &tv);
108 while (ret > 0 && FD_ISSET(fd, &readfds)) {
111 perror(
"mnl_socket_recvfrom");
116 NULL, NULL, cb_ctl_array,
117 MNL_ARRAY_SIZE(cb_ctl_array));
119 perror(
"mnl_cb_run");
123 ret = select(fd+1, &readfds, NULL, NULL, &tv);
129 FD_SET(fd, &readfds);
136 char snd_buf[MNL_SOCKET_BUFFER_SIZE*2];
139 unsigned int seq, portid;
144 perror(
"mnl_socket_open");
148 perror(
"mnl_socket_bind");
159 perror(
"mnl_nlmsg_batch_start");
164 for (i=1024, j=0; i<65535; i++, j++) {
172 send_batch(nl, b, portid);
181 send_batch(nl, b, portid);