|
INET Framework for OMNeT++/OMNEST
|
00001 // 00002 // Copyright (C) 2006 Andras Babos and Andras Varga 00003 // 00004 // This program is free software; you can redistribute it and/or 00005 // modify it under the terms of the GNU Lesser General Public License 00006 // as published by the Free Software Foundation; either version 2 00007 // of the License, or (at your option) any later version. 00008 // 00009 // This program is distributed in the hope that it will be useful, 00010 // but WITHOUT ANY WARRANTY; without even the implied warranty of 00011 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 00012 // GNU Lesser General Public License for more details. 00013 // 00014 // You should have received a copy of the GNU Lesser General Public License 00015 // along with this program; if not, see <http://www.gnu.org/licenses/>. 00016 // 00017 00018 #include "OSPFNeighborStateTwoWay.h" 00019 #include "OSPFNeighborStateDown.h" 00020 #include "OSPFNeighborStateInit.h" 00021 #include "OSPFNeighborStateExchangeStart.h" 00022 #include "MessageHandler.h" 00023 #include "OSPFInterface.h" 00024 #include "OSPFArea.h" 00025 #include "OSPFRouter.h" 00026 00027 void OSPF::NeighborStateTwoWay::ProcessEvent(OSPF::Neighbor* neighbor, OSPF::Neighbor::NeighborEventType event) 00028 { 00029 if ((event == OSPF::Neighbor::KillNeighbor) || (event == OSPF::Neighbor::LinkDown)) { 00030 MessageHandler* messageHandler = neighbor->GetInterface()->GetArea()->GetRouter()->GetMessageHandler(); 00031 neighbor->Reset(); 00032 messageHandler->ClearTimer(neighbor->GetInactivityTimer()); 00033 ChangeState(neighbor, new OSPF::NeighborStateDown, this); 00034 } 00035 if (event == OSPF::Neighbor::InactivityTimer) { 00036 neighbor->Reset(); 00037 if (neighbor->GetInterface()->GetType() == OSPF::Interface::NBMA) { 00038 MessageHandler* messageHandler = neighbor->GetInterface()->GetArea()->GetRouter()->GetMessageHandler(); 00039 messageHandler->StartTimer(neighbor->GetPollTimer(), neighbor->GetInterface()->GetPollInterval()); 00040 } 00041 ChangeState(neighbor, new OSPF::NeighborStateDown, this); 00042 } 00043 if (event == OSPF::Neighbor::OneWayReceived) { 00044 neighbor->Reset(); 00045 ChangeState(neighbor, new OSPF::NeighborStateInit, this); 00046 } 00047 if (event == OSPF::Neighbor::HelloReceived) { 00048 MessageHandler* messageHandler = neighbor->GetInterface()->GetArea()->GetRouter()->GetMessageHandler(); 00049 messageHandler->ClearTimer(neighbor->GetInactivityTimer()); 00050 messageHandler->StartTimer(neighbor->GetInactivityTimer(), neighbor->GetRouterDeadInterval()); 00051 } 00052 if (event == OSPF::Neighbor::IsAdjacencyOK) { 00053 if (neighbor->NeedAdjacency()) { 00054 MessageHandler* messageHandler = neighbor->GetInterface()->GetArea()->GetRouter()->GetMessageHandler(); 00055 if (!(neighbor->IsFirstAdjacencyInited())) { 00056 neighbor->InitFirstAdjacency(); 00057 } else { 00058 neighbor->IncrementDDSequenceNumber(); 00059 } 00060 neighbor->SendDatabaseDescriptionPacket(true); 00061 messageHandler->StartTimer(neighbor->GetDDRetransmissionTimer(), neighbor->GetInterface()->GetRetransmissionInterval()); 00062 ChangeState(neighbor, new OSPF::NeighborStateExchangeStart, this); 00063 } 00064 } 00065 }