lab/mininet-sample
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

mpExperienceDITG: burst now

Browse Source
This commit is contained in:
Quentin De Coninck 2016-06-02 19:00:08 +02:00
parent bbe6564a7b
commit b4e1b944f8
2 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/mpExperienceDITG.py
View File

@ -41,6 +41,8 @@ class MpExperienceDITG(MpExperience):
""" """
self.kbytes = self.xpParam.getParam(MpParamXp.DITGKBYTES) self.kbytes = self.xpParam.getParam(MpParamXp.DITGKBYTES)
self.mean_poisson_packets_sec = self.xpParam.getParam(MpParamXp.DITGMEANPOISSONPACKETSSEC) self.mean_poisson_packets_sec = self.xpParam.getParam(MpParamXp.DITGMEANPOISSONPACKETSSEC)
self.bursts_on_packets_sec = self.xpParam.getParam(MpParamXp.BURSTSONPACKETSSEC)
self.bursts_off_packets_sec = self.xpParam.getParam(MpParamXp.BURSTSOFFPACKETSSEC)
def prepare(self): def prepare(self):
MpExperience.prepare(self) MpExperience.prepare(self)
@ -50,7 +52,7 @@ class MpExperienceDITG(MpExperience):
def getClientCmd(self): def getClientCmd(self):
s = MpExperienceDITG.ITGSEND_BIN + " -a " + self.mpConfig.getServerIP() + \ s = MpExperienceDITG.ITGSEND_BIN + " -a " + self.mpConfig.getServerIP() + \
" -T TCP -k " + self.kbytes + " -O " + self.mean_poisson_packets_sec + " -l " + MpExperienceDITG.DITG_TEMP_LOG + " && " + \ " -T TCP -k " + self.kbytes + " -l " + MpExperienceDITG.DITG_TEMP_LOG + " -B C " + self.bursts_on_packets_sec + " C " + self.bursts_off_packets_sec + " && " + \
MpExperienceDITG.ITGDEC_BIN + " " + MpExperienceDITG.DITG_TEMP_LOG + " &> " + MpExperienceDITG.DITG_LOG MpExperienceDITG.ITGDEC_BIN + " " + MpExperienceDITG.DITG_TEMP_LOG + " &> " + MpExperienceDITG.DITG_LOG
print(s) print(s)
return s return s

4
src/mpParamXp.py
View File

@ -52,6 +52,8 @@ class MpParamXp(MpParam):
VLCTIME = "vlcTime" VLCTIME = "vlcTime"
DITGKBYTES = "ditgKBytes" DITGKBYTES = "ditgKBytes"
DITGMEANPOISSONPACKETSSEC = "ditgMeanPoissonPacketsSec" DITGMEANPOISSONPACKETSSEC = "ditgMeanPoissonPacketsSec"
BURSTSONPACKETSSEC = "burstsOnPacketsSec"
BURSTSOFFPACKETSSEC = "burstsOffPacketsSec"
PRIOPATH0 = "prioPath0" PRIOPATH0 = "prioPath0"
PRIOPATH1 = "prioPath1" PRIOPATH1 = "prioPath1"
EXPIRATION = "expiration" EXPIRATION = "expiration"
@ -128,6 +130,8 @@ class MpParamXp(MpParam):
defaultValue[VLCTIME] = "0" defaultValue[VLCTIME] = "0"
defaultValue[DITGKBYTES] = "10000" defaultValue[DITGKBYTES] = "10000"
defaultValue[DITGMEANPOISSONPACKETSSEC] = "1500" defaultValue[DITGMEANPOISSONPACKETSSEC] = "1500"
defaultValue[BURSTSONPACKETSSEC] = "2250"
defaultValue[BURSTSOFFPACKETSSEC] = "750"
defaultValue[PRIOPATH0] = "0" defaultValue[PRIOPATH0] = "0"
defaultValue[PRIOPATH1] = "0" defaultValue[PRIOPATH1] = "0"