|
NETWORK ATTACKS FRAMEWORK
1.0.0
A NETwork Attacks framework. Making network attacks impact evaluation easier!
|
|
NETWORK ATTACKS FRAMEWORK
1.0.0
A NETwork Attacks framework. Making network attacks impact evaluation easier!
|
Go to the source code of this file.
Defines | |
| #define | ROUTE_TIMEOUT_SLACK 100 |
| #define | JITTER_INTERVAL 100 |
Functions | |
| void | hello_start () |
| void | hello_stop () |
| void | hello_send (void *arg) |
| void | hello_process (RREP *hello, int rreplen, unsigned int ifindex) |
| void | hello_process_non_hello (AODV_msg *aodv_msg, const struct in_addr &source, unsigned int ifindex) |
| NS_INLINE void | hello_update_timeout (rt_table_t *rt, struct timeval *now, long time) |
| #define JITTER_INTERVAL 100 |
Definition at line 35 of file NA_aodv_hello.h.
| #define ROUTE_TIMEOUT_SLACK 100 |
Definition at line 34 of file NA_aodv_hello.h.
| void hello_process | ( | RREP * | hello, |
| int | rreplen, | ||
| unsigned int | ifindex | ||
| ) |
Definition at line 233 of file NA_aodv_hello.cc.
{
u_int32_t hello_seqno, timeout, hello_interval = HELLO_INTERVAL;
u_int8_t state, flags = 0;
struct in_addr ext_neighbor, hello_dest;
rt_table_t *rt;
AODV_ext *ext = NULL;
struct timeval now;
uint32_t cost;
uint8_t fixhop;
cost = costMobile;
if (hello->prevFix)
{
fixhop=1;
cost = costStatic;
}
if (this->isStaticNode())
fixhop++;
gettimeofday(&now, NULL);
hello_dest.s_addr = hello->dest_addr;
hello_seqno = ntohl(hello->dest_seqno);
rt = rt_table_find(hello_dest);
if (rt)
flags = rt->flags;
if (unidir_hack)
flags |= RT_UNIDIR;
#ifndef OMNETPP
/* Check for hello interval extension: */
ext = (AODV_ext *) ((char *) hello + RREP_SIZE);
while (rreplen > (int) RREP_SIZE)
{
#else
ext = hello->getFirstExtension();
for (int i=0; i<hello->getNumExtension (); i++)
{
#endif
switch (ext->type)
{
case RREP_HELLO_INTERVAL_EXT:
if (ext->length == 4)
{
memcpy(&hello_interval, AODV_EXT_DATA(ext), 4);
hello_interval = ntohl(hello_interval);
#ifdef DEBUG_HELLO
DEBUG(LOG_INFO, 0, "Hello extension interval=%lu!",
hello_interval);
#endif
#ifdef OMNETPP
EV << "Hello extension interval = "<< hello_interval;
#endif
}
else
alog(LOG_WARNING, 0,
__FUNCTION__, "Bad hello interval extension!");
break;
case RREP_HELLO_NEIGHBOR_SET_EXT:
#ifdef DEBUG_HELLO
DEBUG(LOG_INFO, 0, "RREP_HELLO_NEIGHBOR_SET_EXT");
#endif
#ifdef OMNETPP
EV << "RREP_HELLO_NEIGHBOR_SET_EXT";
#endif
for (i = 0; i < ext->length; i = i + 4)
{
ext_neighbor.s_addr =
ManetAddress(IPv4Address(*(in_addr_t *) ((char *) AODV_EXT_DATA(ext) + i)));
if (ext_neighbor.s_addr == DEV_IFINDEX(ifindex).ipaddr.s_addr)
flags &= ~RT_UNIDIR;
}
break;
default:
alog(LOG_WARNING, 0, __FUNCTION__,
"Bad extension!! type=%d, length=%d", ext->type, ext->length);
ext = NULL;
break;
}
if (ext == NULL)
break;
rreplen -= AODV_EXT_SIZE(ext);
ext = AODV_EXT_NEXT(ext);
}
#ifdef DEBUG_HELLO
DEBUG(LOG_DEBUG, 0, "rcvd HELLO from %s, seqno %lu",
ip_to_str(hello_dest), hello_seqno);
#endif
#ifdef OMNETPP
EV << "rcvd HELLO from " << ip_to_str(hello_dest) << " seqno = hello_seqno";
#endif
/* This neighbor should only be valid after receiving 3
consecutive hello messages... */
if (receive_n_hellos)
state = INVALID;
else
state = VALID;
timeout = ALLOWED_HELLO_LOSS * hello_interval + ROUTE_TIMEOUT_SLACK;
if (!rt)
{
/* No active or expired route in the routing table. So we add a
new entry... */
rt = rt_table_insert(hello_dest, hello_dest, 1,
hello_seqno, timeout, state, flags, ifindex,cost,fixhop);
if (flags & RT_UNIDIR)
{
DEBUG(LOG_INFO, 0, "%s new NEIGHBOR, link UNI-DIR",
ip_to_str(rt->dest_addr));
}
else
{
DEBUG(LOG_INFO, 0, "%s new NEIGHBOR!", ip_to_str(rt->dest_addr));
}
rt->hello_cnt = 1;
}
else
{
if ((flags & RT_UNIDIR) && rt->state == VALID && rt->hcnt > 1)
{
goto hello_update;
}
if (receive_n_hellos && rt->hello_cnt < (receive_n_hellos - 1))
{
if (timeval_diff(&now, &rt->last_hello_time) <
(long) (hello_interval + hello_interval / 2))
rt->hello_cnt++;
else
rt->hello_cnt = 1;
memcpy(&rt->last_hello_time, &now, sizeof(struct timeval));
return;
}
rt_table_update(rt, hello_dest, 1, hello_seqno, timeout, VALID, flags, ifindex, cost, fixhop);
}
hello_update:
hello_update_timeout(rt, &now, ALLOWED_HELLO_LOSS * hello_interval);
return;
}
| void hello_process_non_hello | ( | AODV_msg * | aodv_msg, |
| const struct in_addr & | source, | ||
| unsigned int | ifindex | ||
| ) |
| void hello_send | ( | void * | arg | ) |
Definition at line 96 of file NA_aodv_hello.cc.
{
RREP *rrep;
AODV_ext *ext = NULL;
u_int8_t flags = 0;
struct in_addr dest;
long time_diff, jitter;
struct timeval now;
int msg_size = RREP_SIZE;
int i;
char buffer[300];
char *buffer_ptr;
buffer_ptr = buffer;
gettimeofday(&now, NULL);
if (optimized_hellos &&
timeval_diff(&now, &this_host.fwd_time) > ACTIVE_ROUTE_TIMEOUT)
{
hello_stop();
return;
}
#ifdef OMNETPP
double delay = -1;
if (par("EqualDelay"))
delay = par("broadcastDelay");
#endif
time_diff = timeval_diff(&now, &this_host.bcast_time);
jitter = hello_jitter();
/* This check will ensure we don't send unnecessary hello msgs, in case
we have sent other bcast msgs within HELLO_INTERVAL */
if (time_diff >= HELLO_INTERVAL)
{
for (i = 0; i < MAX_NR_INTERFACES; i++)
{
if (!DEV_NR(i).enabled)
continue;
#ifdef DEBUG_HELLO
DEBUG(LOG_DEBUG, 0, "sending Hello to 255.255.255.255");
#endif
#ifdef OMNETPP
EV << "sending Hello to 255.255.255.255";
#endif
rrep = rrep_create(flags, 0, 0, DEV_NR(i).ipaddr,
this_host.seqno,
DEV_NR(i).ipaddr,
ALLOWED_HELLO_LOSS * HELLO_INTERVAL);
/* Assemble a RREP extension which contain our neighbor set... */
if (unidir_hack)
{
int i;
#ifndef OMNETPP
if (ext)
ext = AODV_EXT_NEXT(ext);
else
/* Check for hello interval extension: */
ext = (AODV_ext *) ((char *) rrep + RREP_SIZE);
ext->type = RREP_HELLO_NEIGHBOR_SET_EXT;
ext->length = 0;
#endif
for (i = 0; i < RT_TABLESIZE; i++)
{
list_t *pos;
list_foreach(pos, &rt_tbl.tbl[i])
{
rt_table_t *rt = (rt_table_t *) pos;
/* If an entry has an active hello timer, we assume
that we are receiving hello messages from that
node... */
if (rt->hello_timer.used)
{
#ifdef DEBUG_HELLO
DEBUG(LOG_INFO, 0,
"Adding %s to hello neighbor set ext",
ip_to_str(rt->dest_addr));
#endif
#ifndef OMNETPP
memcpy(AODV_EXT_NEXT(ext), &rt->dest_addr,
sizeof(struct in_addr));
ext->length += sizeof(struct in_addr);
#else
memcpy(buffer_ptr, &rt->dest_addr,
sizeof(struct in_addr));
buffer_ptr+=sizeof(struct in_addr);
#endif
}
}
}
#ifdef OMNETPP
if (ext->length)
{
msg_size = RREP_SIZE + AODV_EXT_SIZE(ext);
}
rrep->setName("AodvHello");
rrep->setByteLength(msg_size);
#else
if (buffer_ptr-buffer>0)
{
rrep->addExtension(RREP_HELLO_NEIGHBOR_SET_EXT,(int)(buffer_ptr-buffer),buffer);
msg_size = RREP_SIZE + (int)(buffer_ptr-buffer);
}
#endif
}
dest.s_addr = ManetAddress(IPv4Address(AODV_BROADCAST));
#ifdef OMNETPP
rrep->ttl=1;
aodv_socket_send((AODV_msg *) rrep, dest, msg_size, 1, &DEV_NR(i),delay);
#else
aodv_socket_send((AODV_msg *) rrep, dest, msg_size, 1, &DEV_NR(i));
#endif
}
timer_set_timeout(&hello_timer, HELLO_INTERVAL + jitter);
}
else
{
if (HELLO_INTERVAL - time_diff + jitter < 0)
timer_set_timeout(&hello_timer,
HELLO_INTERVAL - time_diff - jitter);
else
timer_set_timeout(&hello_timer,
HELLO_INTERVAL - time_diff + jitter);
}
}
| void hello_start | ( | ) |
Definition at line 73 of file NA_aodv_hello.cc.
{
if (hello_timer.used)
return;
gettimeofday(&this_host.fwd_time, NULL);
DEBUG(LOG_DEBUG, 0, "Starting to send HELLOs!");
timer_init(&hello_timer, &NS_CLASS hello_send, NULL);
hello_send(NULL);
}
| void hello_stop | ( | ) |
Definition at line 86 of file NA_aodv_hello.cc.
{
DEBUG(LOG_DEBUG, 0,
"No active forwarding routes - stopped sending HELLOs!");
#ifdef OMNETPP
EV << "No active forwarding routes - stopped sending HELLOs!";
#endif
timer_remove(&hello_timer);
}
| NS_INLINE void hello_update_timeout | ( | rt_table_t * | rt, |
| struct timeval * | now, | ||
| long | time | ||
| ) |
Definition at line 396 of file NA_aodv_hello.cc.
{
timer_set_timeout(&rt->hello_timer, time + HELLO_DELAY);
1.7.6.1