kernel-aodv_v2.2.2.rar_V2 _aodv_hello.c_kernel-aodv

/***************************************************************************** * * Copyright (C) 2001 Uppsala University and Ericsson AB. * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA * * Authors: Erik Nordstr�m, <erik.nordstrom@it.uu.se> * * *****************************************************************************/ #ifdef NS_PORT #include "aodv-uu.h" #else #include <netinet/in.h> #include "aodv_rreq.h" #include "aodv_rrep.h" #include "routing_table.h" #include "aodv_timeout.h" #include "k_route.h" #include "timer_queue.h" #include "aodv_socket.h" #include "params.h" #include "seek_list.h" #include "defs.h" #include "debug.h" #include "locality.h" #endif /* Comment this to remove packet field output: */ #define DEBUG_OUTPUT #ifndef NS_PORT static LIST(rreq_records); static LIST(rreq_blacklist); static struct rreq_record *rreq_record_insert(struct in_addr orig_addr, u_int32_t rreq_id); static struct rreq_record *rreq_record_find(struct in_addr orig_addr, u_int32_t rreq_id); struct blacklist *rreq_blacklist_find(struct in_addr dest_addr); extern int rreq_gratuitous, expanding_ring_search; extern int internet_gw_mode; #endif RREQ *NS_CLASS rreq_create(u_int8_t flags, struct in_addr dest_addr, u_int32_t dest_seqno, struct in_addr orig_addr) { RREQ *rreq; rreq = (RREQ *) aodv_socket_new_msg(); rreq->type = AODV_RREQ; rreq->res1 = 0; rreq->res2 = 0; rreq->hcnt = 0; rreq->rreq_id = htonl(this_host.rreq_id++); rreq->dest_addr = dest_addr.s_addr; rreq->dest_seqno = htonl(dest_seqno); rreq->orig_addr = orig_addr.s_addr; /* Immediately before a node originates a RREQ flood it must increment its sequence number... */ seqno_incr(this_host.seqno); rreq->orig_seqno = htonl(this_host.seqno); if (flags & RREQ_JOIN) rreq->j = 1; if (flags & RREQ_REPAIR) rreq->r = 1; if (flags & RREQ_GRATUITOUS) rreq->g = 1; if (flags & RREQ_DEST_ONLY) rreq->d = 1; DEBUG(LOG_DEBUG, 0, "Assembled RREQ %s", ip_to_str(dest_addr)); #ifdef DEBUG_OUTPUT log_pkt_fields((AODV_msg *) rreq); #endif return rreq; } AODV_ext *rreq_add_ext(RREQ *rreq, int type, unsigned int offset, int len, char *data) { AODV_ext *ext = NULL; if (offset < RREQ_SIZE) return NULL; ext = (AODV_ext *) ((char *) rreq + offset); ext->type = type; ext->length = len; memcpy(AODV_EXT_DATA(ext), data, len); return ext; } void NS_CLASS rreq_send(struct in_addr dest_addr, u_int32_t dest_seqno, int ttl, u_int8_t flags) { RREQ *rreq; struct in_addr dest; int i; dest.s_addr = AODV_BROADCAST; /* Check if we should force the gratuitous flag... (-g option). */ if (rreq_gratuitous) flags |= RREQ_GRATUITOUS; /* Broadcast on all interfaces */ for (i = 0; i < MAX_NR_INTERFACES; i++) { if (!DEV_NR(i).enabled) continue; rreq = rreq_create(flags, dest_addr, dest_seqno, DEV_NR(i).ipaddr); aodv_socket_send((AODV_msg *) rreq, dest, RREQ_SIZE, ttl, &DEV_NR(i)); } } void NS_CLASS rreq_forward(RREQ * rreq, int size, int ttl) { struct in_addr dest, orig; int i; dest.s_addr = AODV_BROADCAST; orig.s_addr = rreq->orig_addr; /* FORWARD the RREQ if the TTL allows it. */ DEBUG(LOG_INFO, 0, "forwarding RREQ src=%s, rreq_id=%lu", ip_to_str(orig), ntohl(rreq->rreq_id)); /* Queue the received message in the send buffer */ rreq = (RREQ *) aodv_socket_queue_msg((AODV_msg *) rreq, size); rreq->hcnt++; /* Increase hopcount to account for * intermediate route */ /* Send out on all interfaces */ for (i = 0; i < MAX_NR_INTERFACES; i++) { if (!DEV_NR(i).enabled) continue; aodv_socket_send((AODV_msg *) rreq, dest, size, ttl, &DEV_NR(i)); } } void NS_CLASS rreq_process(RREQ * rreq, int rreqlen, struct in_addr ip_src, struct in_addr ip_dst, int ip_ttl, unsigned int ifindex) { AODV_ext *ext; RREP *rrep = NULL; int rrep_size = RREP_SIZE; rt_table_t *rev_rt, *fwd_rt = NULL; u_int32_t rreq_orig_seqno, rreq_dest_seqno; u_int32_t rreq_id, rreq_new_hcnt, life; unsigned int extlen = 0; struct in_addr rreq_dest, rreq_orig; rreq_dest.s_addr = rreq->dest_addr; rreq_orig.s_addr = rreq->orig_addr; rreq_id = ntohl(rreq->rreq_id); rreq_dest_seqno = ntohl(rreq->dest_seqno); rreq_orig_seqno = ntohl(rreq->orig_seqno); rreq_new_hcnt = rreq->hcnt + 1; /* Ignore RREQ's that originated from this node. Either we do this or we buffer our own sent RREQ's as we do with others we receive. */ if (rreq_orig.s_addr == DEV_IFINDEX(ifindex).ipaddr.s_addr) return; DEBUG(LOG_DEBUG, 0, "ip_src=%s rreq_orig=%s rreq_dest=%s", ip_to_str(ip_src), ip_to_str(rreq_orig), ip_to_str(rreq_dest)); if (rreqlen < (int) RREQ_SIZE) { alog(LOG_WARNING, 0, __FUNCTION__, "IP data field too short (%u bytes)" "from %s to %s", rreqlen, ip_to_str(ip_src), ip_to_str(ip_dst)); return; } /* Check if the previous hop of the RREQ is in the blacklist set. If it is, then ignore the RREQ. */ if (rreq_blacklist_find(ip_src)) { DEBUG(LOG_DEBUG, 0, "prev hop of RREQ blacklisted, ignoring!"); return; } /* Ignore already processed RREQs. */ if (rreq_record_find(rreq_orig, rreq_id)) return; /* Now buffer this RREQ so that we don't process a similar RREQ we get within PATH_DISCOVERY_TIME. */ rreq_record_insert(rreq_orig, rreq_id); /* Determine whether there are any RREQ extensions */ ext = (AODV_ext *) ((char *) rreq + RREQ_SIZE); while ((rreqlen - extlen) > RREQ_SIZE) { switch (ext->type) { case RREQ_EXT: DEBUG(LOG_INFO, 0, "RREQ include EXTENSION"); /* Do something here */ break; default: alog(LOG_WARNING, 0, __FUNCTION__, "Unknown extension type %d", ext->type); break; } extlen += AODV_EXT_SIZE(ext); ext = AODV_EXT_NEXT(ext); } #ifdef DEBUG_OUTPUT log_pkt_fields((AODV_msg *) rreq); #endif /* The node always creates or updates a REVERSE ROUTE entry to the source of the RREQ. */ rev_rt = rt_table_find(rreq_orig); /* Calculate the extended minimal life time. */ life = PATH_DISCOVERY_TIME - 2 * rreq_new_hcnt * NODE_TRAVERSAL_TIME; if (rev_rt == NULL) { DEBUG(LOG_DEBUG, 0, "Creating REVERSE route entry, RREQ orig: %s", ip_to_str(rreq_orig)); rev_rt = rt_table_insert(rreq_orig, ip_src, rreq_new_hcnt, rreq_orig_seqno, life, VALID, 0, ifindex); } else { if (rev_rt->dest_seqno == 0 || (int32_t)rreq_orig_seqno > (int32_t)rev_rt->dest_seqno || (rreq_orig_seqno == rev_rt->dest_seqno && (rev_rt->state == INVALID || rreq_new_hcnt < rev_rt->hcnt))) { rev_rt = rt_table_update(rev_rt, ip_src, rreq_new_hcnt, rreq_orig_seqno, life, VALID, rev_rt->flags); } #ifdef DISABLED /* This is a out of draft modification of AODV-UU to prevent nodes from creating routing entries to themselves during the RREP phase. We simple drop the RREQ if there is a missmatch between the reverse path on the node and the one suggested by the RREQ. */ else if (rev_rt->next_hop.s_addr != ip_src.s_addr) { DEBUG(LOG_DEBUG, 0, "Dropping RREQ due to rev