[b323f7]: src / DIF / FA / FA.h History

Parent: [180d2e] (diff)

Child: [569601] (diff)

Download this file

FA.h    106 lines (84 with data), 2.9 kB 

  1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
//

// 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/.

// 



/**

 * @brief Class representing Flow allocator component

 * @authors Vladimir Vesely (ivesely@fit.vutbr.cz)

 * @date Last refactorized and documented on 2015-03-10

 */



#ifndef FA_H_

#define FA_H_



//Standard libraries

#include <omnetpp.h>

#include <string>

//RINASim libraries

#include "FABase.h"

#include "FAListeners.h"

#include "FAI.h"

#include "Flow.h"

#include "FAITable.h"

#include "RINASignals.h"

#include "ModuleAccess.h"

#include "EFCP.h"

#include "ExternConsts.h"

#include "DA.h"

#include "NewFlowRequestBase.h"



//Constants



extern const int RANDOM_NUMBER_GENERATOR;

extern const int MAX_PORTID;

extern const int MAX_CEPID;

extern const char* MOD_NEFFLOWREQPOLICY;



class FA : public FABase

{

  public:

    FA();

    virtual ~FA();



    virtual bool receiveAllocateRequest(Flow* flow);

    virtual void receiveNM1FlowCreated(Flow* flow);

    virtual bool receiveDeallocateRequest(Flow* flow);

    virtual bool receiveCreateFlowRequestFromRibd(Flow* flow);



    virtual void deinstantiateFai(Flow* flow);



    virtual bool setOriginalAddresses(Flow* flow);

    virtual bool setNeighborAddresses(Flow* flow);



    bool invokeNewFlowRequestPolicy(Flow* flow);



    //Signals

    simsignal_t sigFACreReqFwd;

    simsignal_t sigFACreResNega;

    simsignal_t sigFACreResPosiFwd;



    //Listeners

    LisFAAllocReq*      lisAllocReq;

    LisFACreFloPosi*    lisCreFloPosi;

    LisFADeallocReq*    lisDeallocReq;

    LisFACreReq*        lisCreReq;



  protected:

    //SimpleModule overloads

    virtual void initialize();

    virtual void handleMessage(cMessage *msg);

    void initPointers();



  private:

    EFCP* Efcp;

    DA* DifAllocator;

    NewFlowRequestBase* NFloReqPolicy;



    bool isMalformedFlow(Flow* flow);

    FAI* createFAI(Flow* flow);



    void initSignalsAndListeners();



    void signalizeCreateFlowRequestForward(Flow* flow);

    void signalizeCreateFlowResponseNegative(Flow* flow);



    const Address getAddressFromDa(const APN& apn, bool useNeighbor);



    bool changeDstAddresses(Flow* flow, bool useNeighbor);

    bool changeSrcAddress(Flow* flow, bool useNeighbor);



};



#endif /* FLOWALLOCATOR_H_ */