--- a/src/DIF/EFCP/EFCP.cc
+++ b/src/DIF/EFCP/EFCP.cc
@@ -35,9 +35,14 @@
void EFCP::initialize(int step){
// if(step == 3){
- this->efcpTable = (EFCPTable*) getParentModule()->getSubmodule(MOD_EFCPTABLE);
+ efcpTable = (EFCPTable*) getParentModule()->getSubmodule(MOD_EFCPTABLE);
resourceAllocator = ModuleAccess<RA>(MOD_RA).get();
// }
+
+
+ lisEFCPCongestFromRA = new LisEFCPCongestFromRA(efcpTable);
+ getParentModule()->getParentModule()->subscribe(SIG_RA_ExecuteSlowdown, lisEFCPCongestFromRA);
+
}
@@ -174,6 +179,7 @@
dtcpModule->par("noRateSlowDownPolicy").setStringValue(par("noRateSlowDownPolicy").stringValue());
dtcpModule->par("reconcileFCPolicy").setStringValue(par("reconcileFCPolicy").stringValue());
dtcpModule->par("rateReductionPolicy").setStringValue(par("rateReductionPolicy").stringValue());
+ dtcpModule->par("ecnSlowDownPolicy").setStringValue(par("ecnSlowDownPolicy").stringValue());
dtcpModule->finalizeParameters();
dtcpModule->buildInside();
dtcpModule->scheduleStart(simTime());