//
// This program is free software: you can redistribute it and/or modify
// it under the terms of the GNU Lesser General Public License as published by
// the Free Software Foundation, either version 3 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 Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public License
// along with this program. If not, see http://www.gnu.org/licenses/.
//
#include "FAITable.h"
Define_Module(FAITable);
void FAITable::initialize()
{
WATCH_LIST(FaiTable);
}
std::string FAITable::info() const {
std::ostringstream os;
os << "id=" << this->getId() << endl;
/*
for(TFTConstIter it = FaiTable.begin(); it != FaiTable.end(); ++it )
{
FAITableEntry tft = *it;
os << tft << endl;
}
*/
return os.str();
}
FAITableEntry* FAITable::findEntryByDstAddressAndFwd(const APN& apname) {
for(TFTIter it = FaiTable.begin(); it != FaiTable.end(); ++it) {
FAITableEntry tft = *it;
if (tft.getCFlow()->getDstAddr().getApname() == apname
&& tft.getAllocateStatus() == FAITableEntry::FORWARDED)
return &(*it);
}
return NULL;
}
FAITableEntry* FAITable::findEntryBySrcAddressAndFwd(const APN& apname) {
//EV << "Look APN> " << ipcAddr << endl;
for(TFTIter it = FaiTable.begin(); it != FaiTable.end(); ++it) {
FAITableEntry tft = *it;
//EV << "XXXX " << tft.getCFlow()->getSrcAddr().getIpcAddress() << endl
// << "YYYY " << (tft.getAllocateStatus() == FAITableEntry::FORWARDED) << endl;
if (tft.getCFlow()->getSrcAddr().getIpcAddress() == apname
&& tft.getAllocateStatus() == FAITableEntry::FORWARDED)
return &(*it);
}
return NULL;
}
FAITableEntry* FAITable::findEntryByApns(const APN& srcApn, const APN& dstApn) {
for(TFTIter it = FaiTable.begin(); it != FaiTable.end(); ++it) {
FAITableEntry tft = *it;
if (tft.getCFlow()->getSrcApni().getApn() == srcApn
&& tft.getCFlow()->getDstApni().getApn() == dstApn
&& tft.getAllocateStatus() == FAITableEntry::FORWARDED)
return &(*it);
}
return NULL;
}
FAITableEntry* FAITable::findEntryByDstNeighborAndFwd(const APN& apname) {
for(TFTIter it = FaiTable.begin(); it != FaiTable.end(); ++it) {
FAITableEntry tft = *it;
if (tft.getCFlow()->getDstNeighbor().getApname() == apname
&& tft.getAllocateStatus() == FAITableEntry::FORWARDED)
return &(*it);
}
return NULL;
}
void FAITable::handleMessage(cMessage *msg)
{
}
void FAITable::insertNew(Flow* flow) {
this->insert(FAITableEntry(flow));
}
void FAITable::insert(const FAITableEntry& entry) {
Enter_Method("insertFlow()");
FaiTable.push_back(entry);
}
void FAITable::removeByFlow(Flow* flow) {
Enter_Method("removeFlow()");
FAITableEntry* entry = findEntryByFlow(flow);
if (entry)
FaiTable.remove(*entry);
}
FAITableEntry* FAITable::findEntryByFlow(const Flow* flow) {
for(TFTIter it = FaiTable.begin(); it != FaiTable.end(); ++it) {
FAITableEntry tft = *it;
if (*(tft.getCFlow()) == *flow)
return &(*it);
}
return NULL;
}
FAITableEntry* FAITable::findEntryByFai(FAIBase* fai) {
for(TFTIter it = FaiTable.begin(); it != FaiTable.end(); ++it) {
FAITableEntry tft = *it;
if (tft.getFai() == fai)
return &(*it);
}
return NULL;
}
void FAITable::changeAllocStatus(Flow* flow, FAITableEntry::AllocateStatus status) {
FAITableEntry* fte = findEntryByFlow(flow);
if (fte) {
fte->setAllocateStatus(status);
}
else
EV << "findByFlow() returned NULL" << endl;
}
void FAITable::changeAllocStatus(FAIBase* fai, FAITableEntry::AllocateStatus status) {
FAITableEntry* fte = findEntryByFai(fai);
if (fte)
fte->setAllocateStatus(status);
else
EV << "findByFai() returned NULL" << endl;
}
void FAITable::setFaiToFlow(FAIBase* fai, Flow* flow) {
FAITableEntry* fte = findEntryByFlow(flow);
fte->setFai(fai);
}