//
// Copyright ďż˝ 2014 PRISTINE Consortium (http://ict-pristine.eu)
//
// 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/.
//
/**
* @file FAI.h
* @author Vladimir Vesely (ivesely@fit.vutbr.cz)
* @date Apr 30, 2014
* @brief
* @detail
*/
#ifndef FAI_H_
#define FAI_H_
//Standard libraries
#include <omnetpp.h>
//RINASim libraries
#include "FABase.h"
#include "Flow.h"
#include "FAIListeners.h"
#include "RINASignals.h"
#include "EFCP.h"
#include "ModuleAccess.h"
class FAI : public cSimpleModule {
public:
FAI();
virtual ~FAI();
std::string info() const;
bool receiveAllocateRequest();
bool processDegenerateDataTransfer();
bool receiveAllocateResponsePositive();
void receiveAllocateResponseNegative();
bool receiveCreateRequest();
bool receiveCreateResponsePositive();
bool receiveCreateResponseNegative();
void receiveDeallocateRequest();
void receiveDeleteRequest();
void receiveDeleteResponse();
void postInitialize(FABase* fa, Flow* fl, EFCP* efcp);
const FABase* getFa() const {
return FaModule;
}
Flow* getFlow() {
return FlowObject;
}
protected:
int portId;
int cepId;
FABase* FaModule;
Flow* FlowObject;
//Signals
simsignal_t sigFAIAllocReq;
simsignal_t sigFAIAllocResPosi;
simsignal_t sigFAIAllocResNega;
simsignal_t sigFAICreReq;
simsignal_t sigFAIDelReq;
simsignal_t sigFAIDelRes;
simsignal_t sigFAICreResNega;
simsignal_t sigFAICreResPosi;
//Listeners
LisFAIAllocReq* lisAllocReq;
LisFAIAllocResNega* lisAllocResNega;
LisFAIAllocResPosi* lisAllocResPosi;
LisFAICreReq* lisCreReq;
LisFAICreResNega* lisCreResNega;
LisFAICreResPosi* lisCreResPosi;
LisFAIDelReq* lisDelReq;
LisFAIDelRes* lisDelRes;
virtual void initialize();
virtual void handleMessage(cMessage *msg);
private:
EFCP* efcp;
cGate* southI;
cGate* southO;
cGate* northI;
cGate* northO;
void initSignalsAndListeners();
bool createEFCP();
bool createBindings();
bool deleteBindings();
bool invokeAllocateRetryPolicy();
void signalizeCreateFlowRequest();
void signalizeCreateFlowResponsePositive();
void signalizeCreateFlowResponseNegative();
void signalizeDeleteFlowRequest();
void signalizeDeleteFlowResponse();
void signalizeAllocationRequestFromFAI();
void signalizeAllocateResponseNegative();
void signalizeAllocateResponsePositive();
};
//Free function
std::ostream& operator<< (std::ostream& os, const FAI& fai);
#endif /* FAI_H_ */