|
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!
|
#include <string.h>#include <assert.h>#include "NA_aodv_uu_omnet.h"#include "UDPPacket.h"#include "IPv4ControlInfo.h"#include "IPv6ControlInfo.h"#include "ICMPMessage_m.h"#include "ICMPAccess.h"#include "NotifierConsts.h"#include "IPv4Datagram.h"#include "IPv4InterfaceData.h"#include "ProtocolMap.h"#include "IPv4Address.h"#include "IPvXAddress.h"#include "ControlManetRouting_m.h"#include "Ieee802Ctrl_m.h"Go to the source code of this file.
Typedefs | |
| typedef std::vector< IPv4Address > | IPAddressVector |
Functions | |
| Define_Module (NA_AODVUU) | |
| void NS_CLASS | initialize (int stage) |
| NS_CLASS | ~NA_AODVUU () |
| void NS_CLASS | handleMessageFromAttackController (cMessage *msg) |
| void NS_CLASS | packetFailed (IPv4Datagram *dgram) |
| void NS_CLASS | packetFailedMac (Ieee80211DataFrame *dgram) |
| void NS_CLASS | handleMessage (cMessage *msg) |
| int NS_CLASS | startAODVUUAgent () |
| IPv4Datagram *NS_CLASS | pkt_encapsulate (IPv4Datagram *p, IPv4Address gateway) |
| IPv4Datagram *NS_CLASS | pkt_decapsulate (IPv4Datagram *p) |
| void NS_CLASS | scheduleNextEvent () |
| const char *NS_CLASS | if_indextoname (int ifindex, char *ifname) |
| void NS_CLASS | recvAODVUUPacket (cMessage *msg) |
| void NS_CLASS | processPacket (IPv4Datagram *p, unsigned int ifindex) |
| struct dev_info NS_CLASS | dev_ifindex (int ifindex) |
| struct dev_info NS_CLASS | dev_nr (int n) |
| int NS_CLASS | ifindex2devindex (unsigned int ifindex) |
| void NS_CLASS | processLinkBreak (const cPolymorphic *details) |
| void NS_CLASS | finish () |
| uint32_t NS_CLASS | getRoute (const ManetAddress &dest, std::vector< ManetAddress > &add) |
| bool NS_CLASS | getNextHop (const ManetAddress &dest, ManetAddress &add, int &iface, double &cost) |
| bool NS_CLASS | isProactive () |
| void NS_CLASS | setRefreshRoute (const ManetAddress &destination, const ManetAddress &nextHop, bool isReverse) |
| bool NS_CLASS | isOurType (cPacket *msg) |
| bool NS_CLASS | getDestAddress (cPacket *msg, ManetAddress &dest) |
| bool NS_CLASS | setRoute (const ManetAddress &dest, const ManetAddress &add, const int &ifaceIndex, const int &hops, const ManetAddress &mask) |
| bool NS_CLASS | setRoute (const ManetAddress &dest, const ManetAddress &add, const char *ifaceName, const int &hops, const ManetAddress &mask) |
Variables | |
| const int | UDP_HEADER_BYTES = 8 |
| typedef std::vector<IPv4Address> IPAddressVector |
Definition at line 56 of file NA_aodv_uu_omnet.cc.
| struct dev_info NS_CLASS dev_ifindex | ( | int | ifindex | ) | [read] |
Definition at line 1065 of file NA_aodv_uu_omnet.cc.
{
int index = ifindex2devindex(ifindex);
return (this_host.devs[index]);
}
Definition at line 1071 of file NA_aodv_uu_omnet.cc.
Definition at line 1106 of file NA_aodv_uu_omnet.cc.
{
simtime_t t = simTime();
if (t==0)
return;
if (iswrite)
return;
iswrite=true;
recordScalar("simulated time", t);
recordScalar("Aodv totalSend ", totalSend);
recordScalar("rreq send", totalRreqSend);
recordScalar("rreq rec", totalRreqRec);
recordScalar("rrep send", totalRrepSend);
recordScalar("rrep rec", totalRrepRec);
recordScalar("rrep ack send", totalRrepAckSend);
recordScalar("rrep ack rec", totalRrepAckRec);
recordScalar("rerr send", totalRerrSend);
recordScalar("rerr rec", totalRerrRec);
}
| bool NS_CLASS getDestAddress | ( | cPacket * | msg, |
| ManetAddress & | dest | ||
| ) |
Definition at line 1239 of file NA_aodv_uu_omnet.cc.
| bool NS_CLASS getNextHop | ( | const ManetAddress & | dest, |
| ManetAddress & | add, | ||
| int & | iface, | ||
| double & | cost | ||
| ) |
Definition at line 1134 of file NA_aodv_uu_omnet.cc.
{
struct in_addr destAddr;
destAddr.s_addr = dest;
ManetAddress apAddr;
rt_table_t * fwd_rt = this->rt_table_find(destAddr);
if (fwd_rt)
{
if (fwd_rt->state != VALID)
return false;
add = fwd_rt->next_hop.s_addr;
InterfaceEntry * ie = getInterfaceEntry (fwd_rt->ifindex);
iface = ie->getInterfaceId();
cost = fwd_rt->hcnt;
return true;
}
else if (getAp(dest,apAddr))
{
destAddr.s_addr = apAddr;
fwd_rt = this->rt_table_find(destAddr);
if (!fwd_rt)
return false;
if (fwd_rt->state != VALID)
return false;
add = fwd_rt->next_hop.s_addr;
InterfaceEntry * ie = getInterfaceEntry (fwd_rt->ifindex);
iface = ie->getInterfaceId();
cost = fwd_rt->hcnt;
return true;
}
return false;
}
Definition at line 1128 of file NA_aodv_uu_omnet.cc.
{
return 0;
}
| void NS_CLASS handleMessage | ( | cMessage * | msg | ) |
Definition at line 528 of file NA_aodv_uu_omnet.cc.
{
AODV_msg *aodvMsg=NULL;
IPv4Datagram * ipDgram=NULL;
UDPPacket * udpPacket=NULL;
cMessage *msg_aux;
struct in_addr src_addr;
struct in_addr dest_addr;
if (is_init==false)
opp_error ("Aodv has not been initialized ");
if (msg==sendMessageEvent)
{
// timer event
scheduleNextEvent();
return;
}
/* Handle packet depending on type */
if (dynamic_cast<ControlManetRouting *>(msg))
{
ControlManetRouting * control = check_and_cast <ControlManetRouting *> (msg);
if (control->getOptionCode()== MANET_ROUTE_NOROUTE)
{
ipDgram = (IPv4Datagram*) control->decapsulate();
cPolymorphic * ctrl = ipDgram->removeControlInfo();
unsigned int ifindex = NS_IFINDEX; /* Always use ns interface */
if (ctrl)
{
if (dynamic_cast<Ieee802Ctrl*> (ctrl))
{
Ieee802Ctrl *ieeectrl = dynamic_cast<Ieee802Ctrl*> (ctrl);
ManetAddress address(ieeectrl->getDest());
int index = getWlanInterfaceIndexByAddress(address);
if (index!=-1)
ifindex = index;
}
delete ctrl;
}
EV << "Aodv rec datagram " << ipDgram->getName() << " with dest=" << ipDgram->getDestAddress().str() << "\n";
processPacket(ipDgram,ifindex); // Data path
}
else if (control->getOptionCode()== MANET_ROUTE_UPDATE)
{
DEBUG(LOG_DEBUG, 0, "forwarding packers, actualize time outs");
src_addr.s_addr = control->getSrcAddress();
dest_addr.s_addr = control->getDestAddress();
rt_table_t * fwd_rt = rt_table_find(dest_addr);
rt_table_t * rev_rt = rt_table_find(src_addr);
rt_table_update_route_timeouts(fwd_rt, rev_rt);
/* When forwarding data, make sure we are sending HELLO messages */
gettimeofday(&this_host.fwd_time, NULL);
}
delete msg;
scheduleNextEvent();
return;
}
else if (dynamic_cast<UDPPacket *>(msg) || dynamic_cast<AODV_msg *>(msg))
{
udpPacket = NULL;
if (!isInMacLayer())
{
udpPacket = check_and_cast<UDPPacket*>(msg);
if (udpPacket->getDestinationPort()!= 654)
{
delete msg;
scheduleNextEvent();
return;
}
msg_aux = udpPacket->decapsulate();
}
else
msg_aux = msg;
if (dynamic_cast<AODV_msg *>(msg_aux))
{
aodvMsg = check_and_cast <AODV_msg *>(msg_aux);
if (!isInMacLayer())
{
IPv4ControlInfo *controlInfo = check_and_cast<IPv4ControlInfo*>(udpPacket->removeControlInfo());
src_addr.s_addr = ManetAddress(controlInfo->getSrcAddr());
aodvMsg->setControlInfo(controlInfo);
}
else
{
Ieee802Ctrl *controlInfo = check_and_cast<Ieee802Ctrl*>(udpPacket->getControlInfo());
src_addr.s_addr = ManetAddress(controlInfo->getSrc());
}
}
else
{
if (udpPacket)
delete udpPacket;
delete msg_aux;
scheduleNextEvent();
return;
}
if (udpPacket)
delete udpPacket;
}
else
{
delete msg;
scheduleNextEvent();
return;
}
/* Detect routing loops */
if (isLocalAddress(src_addr.s_addr))
{
delete aodvMsg;
aodvMsg=NULL;
scheduleNextEvent();
return;
}
recvAODVUUPacket(aodvMsg);
scheduleNextEvent();
}
| void NS_CLASS handleMessageFromAttackController | ( | cMessage * | msg | ) |
Definition at line 343 of file NA_aodv_uu_omnet.cc.
{
// It is necessary to call Enter_Method for doing context switching (4.10 of User Manual)
Enter_Method("NA_AODVUU: handle message from attack controller");
LOG << "NA_AODVUU: Received message: "<< msg->getFullName() << "\n";
// BEGIN NA_SINKHOLE - sancale
// Activate sinkhole
if (not strcmp(msg->getFullName(), "sinkholeActivate")) {
NA_SinkholeMessage *dmsg;
dmsg = check_and_cast<NA_SinkholeMessage *>(msg);
LOG << "--> Activating module NA_AODVUU for Sinkhole...\n";
LOG << " Sinkhole Probability received: "<< dmsg->getSinkholeAttackProbability() << "\n";
LOG << " Sink only when route in table: " << dmsg->getSinkOnlyWhenRouteInTable() << "\n";
//Now sinkhole attack is activated in this module
sinkholeAttackIsActive = true;
sinkholeAttackProbability = dmsg->getSinkholeAttackProbability();
sinkOnlyWhenRouteInTable = dmsg->getSinkOnlyWhenRouteInTable();
seqnoAdded = dmsg->getSeqnoAdded();
numHops = dmsg->getNumHops();
delete(msg);
// Deactivate sinkhole
} else if (not strcmp(msg->getFullName(), "sinkholeDeactivate")) {
NA_SinkholeMessage *dmsg;
dmsg = check_and_cast<NA_SinkholeMessage *>(msg);
LOG << "Deactivating module NA_AODVUU for Sinkhole...\n";
//Now sinkholes attack is deactivated
sinkholeAttackIsActive = false;
seqnoAdded = NULL;
numHops = NULL;
delete(msg);
// END NA_SINKHOLE - sancale
} else {
LOG << "ERROR: Message unknown in NA_AODVUU::handleMessageFromAttackController. Msg: " << msg->getFullName() << "\n";
}
}
| const char* NS_CLASS if_indextoname | ( | int | ifindex, |
| char * | ifname | ||
| ) |
Definition at line 831 of file NA_aodv_uu_omnet.cc.
{
InterfaceEntry * ie;
assert(ifindex >= 0);
ie = getInterfaceEntry(ifindex);
return ie->getName();
}
| int NS_CLASS ifindex2devindex | ( | unsigned int | ifindex | ) |
Definition at line 1076 of file NA_aodv_uu_omnet.cc.
{
int i;
for (i = 0; i < this_host.nif; i++)
if (dev_indices[i] == ifindex)
return i;
return -1;
}
| void NS_CLASS initialize | ( | int | stage | ) |
Definition at line 78 of file NA_aodv_uu_omnet.cc.
{
/*
Enable usage of some of the configuration variables from Tcl.
Note: Do NOT change the values of these variables in the constructor
after binding them! The desired default values should be set in
~ns/tcl/lib/ns-default.tcl instead.
*/
if (stage==4)
{
#ifndef AODV_GLOBAL_STATISTISTIC
iswrite = false;
totalSend=0;
totalRreqSend=0;
totalRreqRec=0;
totalRrepSend=0;
totalRrepRec=0;
totalRrepAckSend=0;
totalRrepAckRec=0;
totalRerrSend=0;
totalRerrRec=0;
#endif
log_to_file = 0;
hello_jittering = 0;
optimized_hellos = 0;
expanding_ring_search = 0;
local_repair = 0;
debug=0;
rreq_gratuitous =0;
// BEGIN NA_SINKHOLE - sancale
// Sinkhole attack initialization
sinkholeAttackIsActive = false;
sinkholeAttackProbability = 0;
sinkOnlyWhenRouteInTable = false;
numSents = 0;
// END NA_SINKHOLE - sancale
//sendMessageEvent = new cMessage();
if ((bool)par("log_to_file"))
log_to_file = 1;
if ((bool) par("hello_jittering"))
hello_jittering = 1;
if ((bool)par("optimized_hellos"))
optimized_hellos = 1;
if ((bool)par("expanding_ring_search"))
expanding_ring_search = 1;
if ((bool) par("local_repair"))
local_repair = 1;
if ((bool)par("rreq_gratuitous"))
rreq_gratuitous = 1;
if ((bool)par("debug"))
debug = 1;
useIndex = par("UseIndex");
unidir_hack = (int) par("unidir_hack");
receive_n_hellos = (int) par("receive_n_hellos");
wait_on_reboot = (int) par ("wait_on_reboot");
rt_log_interval = (int) par("rt_log_interval"); // Note: in milliseconds!
ratelimit = (int) par("ratelimit");
llfeedback = 0;
if (par("llfeedback"))
llfeedback = 1;
internet_gw_mode = (int) par("internet_gw_mode");
gateWayAddress = new IPv4Address(par("internet_gw_address").stringValue());
if (llfeedback)
{
active_route_timeout = ACTIVE_ROUTE_TIMEOUT_LLF;
ttl_start = TTL_START_LLF;
delete_period = DELETE_PERIOD_LLF;
}
else
{
active_route_timeout = (int) par("active_timeout");// ACTIVE_ROUTE_TIMEOUT_HELLO;
ttl_start = TTL_START_HELLO;
delete_period = DELETE_PERIOD_HELLO;
}
/* Initialize common manet routing protocol structures */
registerRoutingModule();
if (llfeedback)
linkLayerFeeback();
/* From main.c */
progname = strdup("AODV-UU");
/* From debug.c */
/* Note: log_nmsgs was never used anywhere */
log_nmsgs = 0;
log_rt_fd = -1;
#ifndef _WIN32
if (debug && !log_file_fd_init)
{
log_file_fd = -1;
openlog("aodv-uu ",0,LOG_USER);
log_init();
log_file_fd_init=true;
}
#else
debug = 0;
#endif
/* Set host parameters */
memset(&this_host, 0, sizeof(struct host_info));
memset(dev_indices, 0, sizeof(unsigned int) * MAX_NR_INTERFACES);
this_host.seqno = 1;
this_host.rreq_id = 0;
this_host.nif = 1;
for (int i = 0; i < MAX_NR_INTERFACES; i++)
DEV_NR(i).enabled=0;
for (int i = 0; i <getNumInterfaces(); i++)
{
DEV_NR(i).ifindex = i;
dev_indices[i] = i;
strcpy(DEV_NR(i).ifname, getInterfaceEntry(i)->getName());
if (!isInMacLayer())
{
DEV_NR(i).netmask.s_addr =
ManetAddress(getInterfaceEntry(i)->ipv4Data()->getIPAddress().getNetworkMask());
DEV_NR(i).ipaddr.s_addr =
ManetAddress(getInterfaceEntry(i)->ipv4Data()->getIPAddress());
}
else
{
DEV_NR(i).netmask.s_addr = ManetAddress(MACAddress::BROADCAST_ADDRESS);
DEV_NR(i).ipaddr.s_addr = ManetAddress(getInterfaceEntry(i)->getMacAddress());
}
}
/* Set network interface parameters */
for (int i=0; i < getNumWlanInterfaces(); i++)
{
DEV_NR(getWlanInterfaceIndex(i)).enabled = 1;
DEV_NR(getWlanInterfaceIndex(i)).sock = -1;
DEV_NR(getWlanInterfaceIndex(i)).broadcast.s_addr = ManetAddress(IPv4Address(AODV_BROADCAST));
}
NS_DEV_NR = getWlanInterfaceIndexByAddress();
NS_IFINDEX = getWlanInterfaceIndexByAddress();
#ifndef AODV_USE_STL
list_t *lista_ptr;
lista_ptr=&rreq_records;
INIT_LIST_HEAD(&rreq_records);
lista_ptr=&rreq_blacklist;
INIT_LIST_HEAD(&rreq_blacklist);
lista_ptr=&seekhead;
INIT_LIST_HEAD(&seekhead);
lista_ptr=&TQ;
INIT_LIST_HEAD(&TQ);
#endif
/* Initialize data structures */
worb_timer.data = NULL;
worb_timer.used = 0;
hello_timer.data = NULL;
hello_timer.used = 0;
rt_log_timer.data = NULL;
rt_log_timer.used = 0;
isRoot = par("isRoot");
costStatic = par("costStatic");
costMobile = par("costMobile");
useHover = par("useHover");
proactive_rreq_timeout= par("proactiveRreqTimeout").longValue();
if (isRoot)
{
timer_init(&proactive_rreq_timer,&NS_CLASS rreq_proactive, NULL);
timer_set_timeout(&proactive_rreq_timer, proactive_rreq_timeout);
}
propagateProactive = par("propagateProactive");
strcpy(nodeName,getParentModule()->getParentModule()->getFullName());
aodv_socket_init();
rt_table_init();
packet_queue_init();
startAODVUUAgent();
is_init=true;
// Initialize the timer
scheduleNextEvent();
ev << "Aodv active"<< "\n";
}
}
Definition at line 1231 of file NA_aodv_uu_omnet.cc.
| bool NS_CLASS isProactive | ( | ) |
Definition at line 1167 of file NA_aodv_uu_omnet.cc.
{
return false;
}
| void NS_CLASS packetFailed | ( | IPv4Datagram * | dgram | ) |
Definition at line 390 of file NA_aodv_uu_omnet.cc.
{
rt_table_t *rt_next_hop, *rt;
struct in_addr dest_addr, src_addr, next_hop;
src_addr.s_addr = ManetAddress(dgram->getSrcAddress());
dest_addr.s_addr = ManetAddress(dgram->getDestAddress());
DEBUG(LOG_DEBUG, 0, "Got failure callback");
/* We don't care about link failures for broadcast or non-data packets */
if (dgram->getDestAddress().getInt() == IP_BROADCAST ||
dgram->getDestAddress().getInt() == AODV_BROADCAST)
{
DEBUG(LOG_DEBUG, 0, "Ignoring callback");
scheduleNextEvent();
return;
}
DEBUG(LOG_DEBUG, 0, "LINK FAILURE for next_hop=%s dest=%s ",ip_to_str(next_hop), ip_to_str(dest_addr));
if (seek_list_find(dest_addr))
{
DEBUG(LOG_DEBUG, 0, "Ongoing route discovery, buffering packet...");
packet_queue_add((IPv4Datagram *)dgram->dup(), dest_addr);
scheduleNextEvent();
return;
}
rt = rt_table_find(dest_addr);
if (!rt || rt->state == INVALID)
{
scheduleNextEvent();
return;
}
next_hop.s_addr = rt->next_hop.s_addr;
rt_next_hop = rt_table_find(next_hop);
if (!rt_next_hop || rt_next_hop->state == INVALID)
{
scheduleNextEvent();
return;
}
/* Do local repair? */
if (local_repair && rt->hcnt <= MAX_REPAIR_TTL)
/* && ch->num_forwards() > rt->hcnt */
{
/* Buffer the current packet */
packet_queue_add((IPv4Datagram *) dgram->dup(), dest_addr);
// In omnet++ it's not possible to access to the mac queue
// /* Buffer pending packets from interface queue */
// interfaceQueue((nsaddr_t) next_hop.s_addr, IFQ_BUFFER);
// /* Mark the route to be repaired */
rt_next_hop->flags |= RT_REPAIR;
neighbor_link_break(rt_next_hop);
rreq_local_repair(rt, src_addr, NULL);
}
else
{
/* No local repair - just force timeout of link and drop packets */
neighbor_link_break(rt_next_hop);
// In omnet++ it's not possible to access to the mac queue
// interfaceQueue((nsaddr_t) next_hop.s_addr, IFQ_DROP);
}
scheduleNextEvent();
}
| void NS_CLASS packetFailedMac | ( | Ieee80211DataFrame * | dgram | ) |
Definition at line 464 of file NA_aodv_uu_omnet.cc.
{
rt_table_t *rt_next_hop, *rt;
struct in_addr dest_addr, src_addr, next_hop;
if (dgram->getReceiverAddress().isBroadcast())
{
scheduleNextEvent();
return;
}
src_addr.s_addr = ManetAddress(dgram->getAddress3());
dest_addr.s_addr = ManetAddress(dgram->getAddress4());
if (seek_list_find(dest_addr))
{
DEBUG(LOG_DEBUG, 0, "Ongoing route discovery, buffering packet...");
packet_queue_add(dgram->dup(), dest_addr);
scheduleNextEvent();
return;
}
rt = rt_table_find(dest_addr);
if (!rt || rt->state == INVALID)
{
scheduleNextEvent();
return;
}
next_hop.s_addr = rt->next_hop.s_addr;
rt_next_hop = rt_table_find(next_hop);
if (!rt_next_hop || rt_next_hop->state == INVALID)
{
scheduleNextEvent();
return;
}
/* Do local repair? */
if (local_repair && rt->hcnt <= MAX_REPAIR_TTL)
/* && ch->num_forwards() > rt->hcnt */
{
/* Buffer the current packet */
packet_queue_add(dgram->dup(), dest_addr);
// In omnet++ it's not possible to access to the mac queue
// /* Buffer pending packets from interface queue */
// interfaceQueue((nsaddr_t) next_hop.s_addr, IFQ_BUFFER);
// /* Mark the route to be repaired */
rt_next_hop->flags |= RT_REPAIR;
neighbor_link_break(rt_next_hop);
rreq_local_repair(rt, src_addr, NULL);
}
else
{
/* No local repair - just force timeout of link and drop packets */
neighbor_link_break(rt_next_hop);
// In omnet++ it's not possible to access to the mac queue
// interfaceQueue((nsaddr_t) next_hop.s_addr, IFQ_DROP);
}
scheduleNextEvent();
}
| IPv4Datagram* NS_CLASS pkt_decapsulate | ( | IPv4Datagram * | p | ) |
Definition at line 756 of file NA_aodv_uu_omnet.cc.
{
if (p->getTransportProtocol() == IP_PROT_IP)
{
IPv4Datagram *datagram = check_and_cast <IPv4Datagram *>(p->decapsulate());
datagram->setTimeToLive(p->getTimeToLive());
delete p;
return datagram;
}
return NULL;
}
| IPv4Datagram* NS_CLASS pkt_encapsulate | ( | IPv4Datagram * | p, |
| IPv4Address | gateway | ||
| ) |
Definition at line 726 of file NA_aodv_uu_omnet.cc.
{
IPv4Datagram *datagram = new IPv4Datagram(p->getName());
datagram->setByteLength(IP_HEADER_BYTES);
datagram->encapsulate(p);
// set source and destination address
datagram->setDestAddress(gateway);
IPv4Address src = p->getSrcAddress();
// when source address was given, use it; otherwise it'll get the address
// of the outgoing interface after routing
// set other fields
datagram->setTypeOfService(p->getTypeOfService());
datagram->setIdentification(p->getIdentification());
datagram->setMoreFragments(false);
datagram->setDontFragment (p->getDontFragment());
datagram->setFragmentOffset(0);
datagram->setTimeToLive(
p->getTimeToLive() > 0 ?
p->getTimeToLive() :
0);
datagram->setTransportProtocol(IP_PROT_IP);
return datagram;
}
| void NS_CLASS processLinkBreak | ( | const cPolymorphic * | details | ) |
Definition at line 1086 of file NA_aodv_uu_omnet.cc.
{
IPv4Datagram *dgram=NULL;
if (llfeedback)
{
if (dynamic_cast<IPv4Datagram *>(const_cast<cPolymorphic*> (details)))
{
dgram = check_and_cast<IPv4Datagram *>(details);
packetFailed(dgram);
return;
}
else if (dynamic_cast<Ieee80211DataFrame *>(const_cast<cPolymorphic*> (details)))
{
Ieee80211DataFrame *frame = dynamic_cast<Ieee80211DataFrame *>(const_cast<cPolymorphic*>(details));
packetFailedMac(frame);
}
}
}
| void NS_CLASS processPacket | ( | IPv4Datagram * | p, |
| unsigned int | ifindex | ||
| ) |
Definition at line 901 of file NA_aodv_uu_omnet.cc.
{
rt_table_t *fwd_rt, *rev_rt;
struct in_addr dest_addr, src_addr;
u_int8_t rreq_flags = 0;
struct ip_data *ipd = NULL;
fwd_rt = NULL; /* For broadcast we provide no next hop */
ipd = NULL; /* No ICMP messaging */
bool isLocal=true;
src_addr.s_addr = ManetAddress(p->getSrcAddress());
dest_addr.s_addr = ManetAddress(p->getDestAddress());
InterfaceEntry * ie;
if (!p->getSrcAddress().isUnspecified())
{
isLocal = isLocalAddress(ManetAddress(p->getSrcAddress()));
}
ie = getInterfaceEntry (ifindex);
if (p->getTransportProtocol()==IP_PROT_TCP)
rreq_flags |= RREQ_GRATUITOUS;
/* If this is a TCP packet and we don't have a route, we should
set the gratuituos flag in the RREQ. */
bool isMcast = ie->ipv4Data()->isMemberOfMulticastGroup(dest_addr.s_addr.getIPv4());
/* If the packet is not interesting we just let it go through... */
if (isMcast || dest_addr.s_addr == ManetAddress(IPv4Address(AODV_BROADCAST)))
{
send(p,"to_ip");
return;
}
/* Find the entry of the neighboring node and the destination (if any). */
rev_rt = rt_table_find(src_addr);
fwd_rt = rt_table_find(dest_addr);
#ifdef CONFIG_GATEWAY
/* Check if we have a route and it is an Internet destination (Should be
* encapsulated and routed through the gateway). */
if (fwd_rt && (fwd_rt->state == VALID) &&
(fwd_rt->flags & RT_INET_DEST))
{
/* The destination should be relayed through the IG */
rt_table_update_timeout(fwd_rt, ACTIVE_ROUTE_TIMEOUT);
p = pkt_encapsulate(p, *gateWayAddress);
if (p == NULL)
{
DEBUG(LOG_ERR, 0, "IP Encapsulation failed!");
return;
}
/* Update pointers to headers */
dest_addr.s_addr = gateWayAddress->getInt();
fwd_rt = rt_table_find(dest_addr);
}
#endif /* CONFIG_GATEWAY */
/* UPDATE TIMERS on active forward and reverse routes... */
rt_table_update_route_timeouts(fwd_rt, rev_rt);
/* OK, the timeouts have been updated. Now see if either: 1. The
packet is for this node -> ACCEPT. 2. The packet is not for this
node -> Send RERR (someone want's this node to forward packets
although there is no route) or Send RREQ. */
if (!fwd_rt || fwd_rt->state == INVALID ||
(fwd_rt->hcnt == 1 && (fwd_rt->flags & RT_UNIDIR)))
{
/* Check if the route is marked for repair or is INVALID. In
* that case, do a route discovery. */
struct in_addr rerr_dest;
// BEGIN NA_SINKHOLE - sancale
// If the sinkhole does not know the route, it does not send RERR
if (sinkholeAttackIsActive) {
if (sinkOnlyWhenRouteInTable == false) {
LOG << "Sinkhole does not send RERR" << endl;
cout << simTime() << ": Sinkhole does not send RERR " << endl;
delete p;
return;
}
}
// END NA_SINKHOLE - sancale
if (isLocal)
goto route_discovery;
if (fwd_rt && (fwd_rt->flags & RT_REPAIR))
goto route_discovery;
RERR *rerr;
DEBUG(LOG_DEBUG, 0,
"No route, src=%s dest=%s prev_hop=%s - DROPPING!",
ip_to_str(src_addr), ip_to_str(dest_addr));
if (fwd_rt)
{
rerr = rerr_create(0, fwd_rt->dest_addr,fwd_rt->dest_seqno);
rt_table_update_timeout(fwd_rt, DELETE_PERIOD);
}
else
rerr = rerr_create(0, dest_addr, 0);
DEBUG(LOG_DEBUG, 0, "Sending RERR to prev hop %s for unknown dest %s",
ip_to_str(src_addr), ip_to_str(dest_addr));
/* Unicast the RERR to the source of the data transmission
* if possible, otherwise we broadcast it. */
if (rev_rt && rev_rt->state == VALID)
rerr_dest = rev_rt->next_hop;
else
rerr_dest.s_addr = ManetAddress(IPv4Address(AODV_BROADCAST));
aodv_socket_send((AODV_msg *) rerr, rerr_dest,RERR_CALC_SIZE(rerr),
1, &DEV_IFINDEX(ifindex));
if (wait_on_reboot)
{
DEBUG(LOG_DEBUG, 0, "Wait on reboot timer reset.");
timer_set_timeout(&worb_timer, DELETE_PERIOD);
}
//drop (p);
sendICMP(p);
/* DEBUG(LOG_DEBUG, 0, "Dropping pkt uid=%d", ch->uid()); */
// icmpAccess.get()->sendErrorMessage(p, ICMP_DESTINATION_UNREACHABLE, 0);
return;
route_discovery:
/* Buffer packets... Packets are queued by the ip_queue.o
module already. We only need to save the handle id, and
return the proper verdict when we know what to do... */
packet_queue_add(p, dest_addr);
if (fwd_rt && (fwd_rt->flags & RT_REPAIR))
rreq_local_repair(fwd_rt, src_addr, ipd);
else
rreq_route_discovery(dest_addr, rreq_flags, ipd);
return;
}
else
{
/* DEBUG(LOG_DEBUG, 0, "Sending pkt uid=%d", ch->uid()); */
send(p,"to_ip");
/* When forwarding data, make sure we are sending HELLO messages */
gettimeofday(&this_host.fwd_time, NULL);
if (!llfeedback && optimized_hellos)
hello_start();
}
}
| void NS_CLASS recvAODVUUPacket | ( | cMessage * | msg | ) |
Definition at line 841 of file NA_aodv_uu_omnet.cc.
{
struct in_addr src, dst;
int ttl;
int interfaceId;
AODV_msg *aodv_msg = check_and_cast<AODV_msg *> (msg);
int len = aodv_msg->getByteLength();
int ifIndex=NS_IFINDEX;
ttl = aodv_msg->ttl-1;
if (!isInMacLayer())
{
IPv4ControlInfo *ctrl = check_and_cast<IPv4ControlInfo *>(msg->getControlInfo());
IPvXAddress srcAddr = ctrl->getSrcAddr();
IPvXAddress destAddr = ctrl->getDestAddr();
src.s_addr = ManetAddress(srcAddr);
dst.s_addr = ManetAddress(destAddr);
interfaceId = ctrl->getInterfaceId();
}
else
{
Ieee802Ctrl *ctrl = check_and_cast<Ieee802Ctrl *>(msg->getControlInfo());
src.s_addr = ManetAddress(ctrl->getSrc());
dst.s_addr = ManetAddress(ctrl->getDest());
}
InterfaceEntry * ie;
for (int i = 0; i < getNumWlanInterfaces(); i++)
{
ie = getWlanInterfaceEntry(i);
if (!isInMacLayer())
{
IPv4InterfaceData *ipv4data = ie->ipv4Data();
if (interfaceId ==ie->getInterfaceId())
ifIndex=getWlanInterfaceIndex(i);
if (ManetAddress(ipv4data->getIPAddress()) == src.s_addr)
{
delete aodv_msg;
return;
}
}
else
{
ManetAddress add(ie->getMacAddress());
if (add== src.s_addr)
{
delete aodv_msg;
return;
}
}
}
aodv_socket_process_packet(aodv_msg, len, src, dst, ttl, ifIndex);
delete aodv_msg;
}
| void NS_CLASS scheduleNextEvent | ( | ) |
Definition at line 777 of file NA_aodv_uu_omnet.cc.
{
simtime_t timer;
simtime_t timeout = timer_age_queue();
if (!aodvTimerMap.empty())
{
timer = aodvTimerMap.begin()->first;
if (sendMessageEvent->isScheduled())
{
if (timer < sendMessageEvent->getArrivalTime())
{
cancelEvent(sendMessageEvent);
scheduleAt(timer, sendMessageEvent);
}
}
else
{
scheduleAt(timer, sendMessageEvent);
}
}
}
| void NS_CLASS setRefreshRoute | ( | const ManetAddress & | destination, |
| const ManetAddress & | nextHop, | ||
| bool | isReverse | ||
| ) |
Definition at line 1172 of file NA_aodv_uu_omnet.cc.
{
struct in_addr dest_addr, next_hop;
dest_addr.s_addr = destination;
next_hop.s_addr = nextHop;
rt_table_t * route = rt_table_find(dest_addr);
if(par ("checkNextHop").boolValue())
{
if (nextHop.isUnspecified())
return;
if (!isReverse)
{
if (route &&(route->next_hop.s_addr==nextHop))
rt_table_update_route_timeouts(route, NULL);
}
if (isReverse && !route)
{
// Gratuitous Return Path
struct in_addr node_addr;
struct in_addr ip_src;
node_addr.s_addr = destination;
ip_src.s_addr = nextHop;
rt_table_insert(node_addr, ip_src,0,0, ACTIVE_ROUTE_TIMEOUT, VALID, 0,NS_DEV_NR,0xFFFFFFF,100);
}
else if (route && (route->next_hop.s_addr==nextHop))
rt_table_update_route_timeouts(NULL, route);
}
else
{
if (!isReverse)
{
if (route)
rt_table_update_route_timeouts(route, NULL);
}
if (isReverse && !route && !nextHop.isUnspecified())
{
// Gratuitous Return Path
struct in_addr node_addr;
struct in_addr ip_src;
node_addr.s_addr = destination;
ip_src.s_addr = nextHop;
rt_table_insert(node_addr, ip_src,0,0, ACTIVE_ROUTE_TIMEOUT, VALID, 0,NS_DEV_NR,0xFFFFFFF,100);
}
else if (route)
rt_table_update_route_timeouts(NULL, route);
}
Enter_Method_Silent();
scheduleNextEvent();
}
| bool NS_CLASS setRoute | ( | const ManetAddress & | dest, |
| const ManetAddress & | add, | ||
| const int & | ifaceIndex, | ||
| const int & | hops, | ||
| const ManetAddress & | mask | ||
| ) |
Definition at line 1249 of file NA_aodv_uu_omnet.cc.
{
Enter_Method_Silent();
struct in_addr destAddr;
struct in_addr nextAddr;
struct in_addr rerr_dest;
destAddr.s_addr = dest;
nextAddr.s_addr = add;
bool status=true;
bool delEntry = add.isUnspecified();
DEBUG(LOG_DEBUG, 0, "setRoute %s next hop %s",ip_to_str(destAddr),ip_to_str(nextAddr));
rt_table_t * fwd_rt = rt_table_find(destAddr);
if (fwd_rt)
{
if (delEntry)
{
RERR* rerr = rerr_create(0, destAddr, 0);
DEBUG(LOG_DEBUG, 0, "setRoute Sending for unknown dest %s", ip_to_str(destAddr));
/* Unicast the RERR to the source of the data transmission
* if possible, otherwise we broadcast it. */
rerr_dest.s_addr = ManetAddress(IPv4Address(AODV_BROADCAST));
aodv_socket_send((AODV_msg *) rerr, rerr_dest,RERR_CALC_SIZE(rerr),
1, &DEV_IFINDEX(NS_IFINDEX));
}
ManetAddress dest = fwd_rt->dest_addr.s_addr;
AodvRtTableMap::iterator it = aodvRtTableMap.find(dest);
if (it != aodvRtTableMap.end())
{
if (it->second != fwd_rt)
opp_error("AODV routing table error");
}
aodvRtTableMap.erase(it);
if (fwd_rt->state == VALID || fwd_rt->state == IMMORTAL)
rt_tbl.num_active--;
timer_remove(&fwd_rt->rt_timer);
timer_remove(&fwd_rt->hello_timer);
timer_remove(&fwd_rt->ack_timer);
rt_tbl.num_entries = aodvRtTableMap.size();
free (fwd_rt);
}
else
DEBUG(LOG_DEBUG, 0, "No route entry to delete");
if (ifaceIndex>=getNumInterfaces())
status = false;
ManetRoutingBase::setRoute(dest,add,ifaceIndex,hops,mask);
if (!delEntry && ifaceIndex<getNumInterfaces())
{
fwd_rt = modifyAODVTables(destAddr,nextAddr,hops,(uint32_t) SIMTIME_DBL(simTime()), 0xFFFF,IMMORTAL,0, ifaceIndex);
status = (fwd_rt!=NULL);
}
return status;
}
| bool NS_CLASS setRoute | ( | const ManetAddress & | dest, |
| const ManetAddress & | add, | ||
| const char * | ifaceName, | ||
| const int & | hops, | ||
| const ManetAddress & | mask | ||
| ) |
Definition at line 1312 of file NA_aodv_uu_omnet.cc.
{
Enter_Method_Silent();
struct in_addr destAddr;
struct in_addr nextAddr;
struct in_addr rerr_dest;
destAddr.s_addr = dest;
nextAddr.s_addr = add;
bool status=true;
int index;
bool delEntry = add.isUnspecified();
DEBUG(LOG_DEBUG, 0, "setRoute %s next hop %s",ip_to_str(destAddr),ip_to_str(nextAddr));
rt_table_t * fwd_rt = rt_table_find(destAddr);
if (fwd_rt)
{
if (delEntry)
{
RERR* rerr = rerr_create(0, destAddr, 0);
DEBUG(LOG_DEBUG, 0, "setRoute Sending for unknown dest %s", ip_to_str(destAddr));
/* Unicast the RERR to the source of the data transmission
* if possible, otherwise we broadcast it. */
rerr_dest.s_addr = ManetAddress(IPv4Address(AODV_BROADCAST));
aodv_socket_send((AODV_msg *) rerr, rerr_dest,RERR_CALC_SIZE(rerr),
1, &DEV_IFINDEX(NS_IFINDEX));
}
ManetAddress dest = fwd_rt->dest_addr.s_addr;
AodvRtTableMap::iterator it = aodvRtTableMap.find(dest);
if (it != aodvRtTableMap.end())
{
if (it->second != fwd_rt)
opp_error("AODV routing table error");
}
aodvRtTableMap.erase(it);
if (fwd_rt->state == VALID || fwd_rt->state == IMMORTAL)
rt_tbl.num_active--;
timer_remove(&fwd_rt->rt_timer);
timer_remove(&fwd_rt->hello_timer);
timer_remove(&fwd_rt->ack_timer);
rt_tbl.num_entries = aodvRtTableMap.size();
free (fwd_rt);
}
else
DEBUG(LOG_DEBUG, 0, "No route entry to delete");
for (index = 0; index <getNumInterfaces(); index++)
{
if (strcmp(ifaceName, getInterfaceEntry(index)->getName())==0) break;
}
if (index>=getNumInterfaces())
status = false;
ManetRoutingBase::setRoute(dest,add,index,hops,mask);
if (!delEntry && index<getNumInterfaces())
{
fwd_rt = modifyAODVTables(destAddr,nextAddr,hops,(uint32_t) SIMTIME_DBL(simTime()), 0xFFFF,IMMORTAL,0, index);
status = (fwd_rt!=NULL);
}
return status;
}
| int NS_CLASS startAODVUUAgent | ( | ) |
Definition at line 677 of file NA_aodv_uu_omnet.cc.
{
/* Set up the wait-on-reboot timer */
if (wait_on_reboot)
{
timer_init(&worb_timer, &NS_CLASS wait_on_reboot_timeout, &wait_on_reboot);
timer_set_timeout(&worb_timer, DELETE_PERIOD);
DEBUG(LOG_NOTICE, 0, "In wait on reboot for %d milliseconds.",DELETE_PERIOD);
}
/* Schedule the first HELLO */
if (!llfeedback && !optimized_hellos)
hello_start();
/* Initialize routing table logging */
if (rt_log_interval)
log_rt_table_init();
/* Initialization complete */
initialized = 1;
DEBUG(LOG_DEBUG, 0, "Routing agent with IP = %s started.",
ip_to_str(DEV_NR(NS_DEV_NR).ipaddr));
DEBUG(LOG_DEBUG, 0, "Settings:");
DEBUG(LOG_DEBUG, 0, "unidir_hack %s", unidir_hack ? "ON" : "OFF");
DEBUG(LOG_DEBUG, 0, "rreq_gratuitous %s", rreq_gratuitous ? "ON" : "OFF");
DEBUG(LOG_DEBUG, 0, "expanding_ring_search %s", expanding_ring_search ? "ON" : "OFF");
DEBUG(LOG_DEBUG, 0, "local_repair %s", local_repair ? "ON" : "OFF");
DEBUG(LOG_DEBUG, 0, "receive_n_hellos %s", receive_n_hellos ? "ON" : "OFF");
DEBUG(LOG_DEBUG, 0, "hello_jittering %s", hello_jittering ? "ON" : "OFF");
DEBUG(LOG_DEBUG, 0, "wait_on_reboot %s", wait_on_reboot ? "ON" : "OFF");
DEBUG(LOG_DEBUG, 0, "optimized_hellos %s", optimized_hellos ? "ON" : "OFF");
DEBUG(LOG_DEBUG, 0, "ratelimit %s", ratelimit ? "ON" : "OFF");
DEBUG(LOG_DEBUG, 0, "llfeedback %s", llfeedback ? "ON" : "OFF");
DEBUG(LOG_DEBUG, 0, "internet_gw_mode %s", internet_gw_mode ? "ON" : "OFF");
DEBUG(LOG_DEBUG, 0, "ACTIVE_ROUTE_TIMEOUT=%d", ACTIVE_ROUTE_TIMEOUT);
DEBUG(LOG_DEBUG, 0, "TTL_START=%d", TTL_START);
DEBUG(LOG_DEBUG, 0, "DELETE_PERIOD=%d", DELETE_PERIOD);
/* Schedule the first timeout */
scheduleNextEvent();
return 0;
}
Definition at line 274 of file NA_aodv_uu_omnet.cc.
{
list_t *tmp = NULL, *pos = NULL;
#ifdef AODV_USE_STL_RT
while (!aodvRtTableMap.empty())
{
free (aodvRtTableMap.begin()->second);
aodvRtTableMap.erase(aodvRtTableMap.begin());
}
#else
for (int i = 0; i < RT_TABLESIZE; i++)
{
list_foreach_safe(pos, tmp, &rt_tbl.tbl[i])
{
rt_table_t *rt = (rt_table_t *) pos;
list_detach(&rt->l);
precursor_list_destroy(rt);
free(rt);
}
}
#endif
#ifndef AODV_USE_STL
while (!list_empty(&rreq_records))
{
pos = list_first(&rreq_records);
list_detach(pos);
if (pos) free(pos);
}
while (!list_empty(&rreq_blacklist))
{
pos = list_first(&rreq_blacklist);
list_detach(pos);
if (pos) free(pos);
}
while (!list_empty(&seekhead))
{
pos = list_first(&seekhead);
list_detach(pos);
if (pos) free(pos);
}
#else
while (!rreq_records.empty())
{
free (rreq_records.back());
rreq_records.pop_back();
}
while (!rreq_blacklist.empty())
{
free (rreq_blacklist.begin()->second);
rreq_blacklist.erase(rreq_blacklist.begin());
}
while (!seekhead.empty())
{
delete (seekhead.begin()->second);
seekhead.erase(seekhead.begin());
}
#endif
packet_queue_destroy();
cancelAndDelete(sendMessageEvent);
log_cleanup();
delete gateWayAddress;
}
| const int UDP_HEADER_BYTES = 8 |
Definition at line 55 of file NA_aodv_uu_omnet.cc.
1.7.6.1