mflood-seqtable.cc

NS2中没有集成MFLOOD模块

#include "mflood/mflood-seqtable.h"

 

// The Routing Table

MFlood_RTEntry::MFlood_RTEntry() {

 src_ = 0;

 for(int i=0;i<REM_SEQ_COUNT;i++)

      rt_seqnos[i] = 0xffffffff;

 max_seqno = 0;

 min_seqno = 0;

 seq_it = 0;

};

 

// The Routing Table

MFlood_RTEntry::MFlood_RTEntry(nsaddr_t src,u_int32_t seq) {

 src_ = src;

 for(int i=0;i<REM_SEQ_COUNT;i++)

  rt_seqnos[i] = 0xffffffff;

 rt_seqnos[0] = seq;

 max_seqno = seq;

 min_seqno = 0;

 seq_it = 1;

};

 

bool MFlood_RTEntry::isNewSeq(u_int32_t seq)

{

 if(seq > max_seqno)

  return true;

 //採用min_seqno來拋棄掉太久以前的包

 if(seq < min_seqno)

  return false;

 for(int i=0;i<REM_SEQ_COUNT;i++)

  if(seq == rt_seqnos[i])

   return false;

 return true;

}

 

void MFlood_RTEntry::addSeq(u_int32_t seq)

{

 u_int16_t min_it = 0;

 if(seq < min_seqno)

  return;

 if(seq > max_seqno)

  max_seqno = seq;

/*

 for(int i=0;i<REM_SEQ_COUNT;i++)

  if(seq == rt_seqnos)

   return;

*/

 rt_seqnos[seq_it++] = seq;

 seq_it %= REM_SEQ_COUNT;

 min_seqno = 0xffffffff;

 //計算出min_seqno

 for(int i=0;i<REM_SEQ_COUNT;i++)

  if(min_seqno > rt_seqnos[i])

   min_seqno = rt_seqnos[i];

}

 

// The Routing Table

MFlood_RTEntry* MFlood_RTable::rt_lookup(nsaddr_t id) {

 MFlood_RTEntry *rt = rthead.lh_first;

 for(; rt; rt = rt->rt_link.le_next) {

  if(rt->src_ == id)

   break;

 }

 return rt;

}

 

void MFlood_RTable::rt_delete(nsaddr_t id) {

 MFlood_RTEntry *rt = rt_lookup(id);

 if(rt) {

  LIST_REMOVE(rt, rt_link);

  delete rt;

 }

}

 

void MFlood_RTable::rt_print() {

 MFlood_RTEntry *rt = rthead.lh_first;

 printf("\n Seq table:\n");

 for(; rt; rt = rt->rt_link.le_next) {

      printf("index: %d , seq: %d \n",rt->src_,rt->max_seqno);

 }

 return;

}