mpExperienceSiri: register xp
This commit is contained in:
parent
151497d1d7
commit
134f3897d2
@ -10,6 +10,7 @@ class MpExperience:
|
|||||||
EPLOAD = "epload"
|
EPLOAD = "epload"
|
||||||
NETPERF = "netperf"
|
NETPERF = "netperf"
|
||||||
AB = "ab"
|
AB = "ab"
|
||||||
|
SIRI = "siri"
|
||||||
SENDFILE = "sendfile"
|
SENDFILE = "sendfile"
|
||||||
|
|
||||||
def __init__(self, xpParam, mpTopo, mpConfig):
|
def __init__(self, xpParam, mpTopo, mpConfig):
|
||||||
|
@ -53,13 +53,13 @@ class MpExperienceSiri(MpExperience):
|
|||||||
MpExperienceSiri.SERVER_LOG)
|
MpExperienceSiri.SERVER_LOG)
|
||||||
|
|
||||||
def getSiriServerCmd(self):
|
def getSiriServerCmd(self):
|
||||||
s = "python " + os.path.dirname(os.path.abspath(__file__)) + \
|
s = "python3 " + os.path.dirname(os.path.abspath(__file__)) + \
|
||||||
"/siri_server.py &>" + MpExperienceSiri.SERVER_LOG + "&"
|
"/siri_server.py &>" + MpExperienceSiri.SERVER_LOG + "&"
|
||||||
print(s)
|
print(s)
|
||||||
return s
|
return s
|
||||||
|
|
||||||
def getSiriClientCmd(self):
|
def getSiriClientCmd(self):
|
||||||
s = MpExperienceSiri.JAVA_BIN + " -jar siriClient.jar" + self.mpConfig.getServerIP() + \
|
s = MpExperienceSiri.JAVA_BIN + " -jar siriClient.jar " + self.mpConfig.getServerIP() + \
|
||||||
" 8080 " + self.run_time + " " + self.query_size + " " + self.response_size + \
|
" 8080 " + self.run_time + " " + self.query_size + " " + self.response_size + \
|
||||||
" " + self.delay_query_response + " " + self.min_payload_size + " " + \
|
" " + self.delay_query_response + " " + self.min_payload_size + " " + \
|
||||||
self.max_payload_size + " " + self.interval_time_ms + " " + self.buffer_size + \
|
self.max_payload_size + " " + self.interval_time_ms + " " + self.buffer_size + \
|
||||||
|
@ -14,6 +14,7 @@ from mpExperienceSendFile import MpExperienceSendFile
|
|||||||
from mpExperienceEpload import MpExperienceEpload
|
from mpExperienceEpload import MpExperienceEpload
|
||||||
from mpExperienceNetperf import MpExperienceNetperf
|
from mpExperienceNetperf import MpExperienceNetperf
|
||||||
from mpExperienceAb import MpExperienceAb
|
from mpExperienceAb import MpExperienceAb
|
||||||
|
from mpExperienceSiri import MpExperienceSiri
|
||||||
from mpExperienceNone import MpExperienceNone
|
from mpExperienceNone import MpExperienceNone
|
||||||
from mpExperience import MpExperience
|
from mpExperience import MpExperience
|
||||||
from mpECMPSingleInterfaceTopo import MpECMPSingleInterfaceTopo
|
from mpECMPSingleInterfaceTopo import MpECMPSingleInterfaceTopo
|
||||||
@ -96,6 +97,9 @@ class MpXpRunner:
|
|||||||
elif xp == MpExperience.AB:
|
elif xp == MpExperience.AB:
|
||||||
MpExperienceAb(self.xpParam, self.mpTopo,
|
MpExperienceAb(self.xpParam, self.mpTopo,
|
||||||
self.mpTopoConfig)
|
self.mpTopoConfig)
|
||||||
|
elif xp == MpExperience.SIRI:
|
||||||
|
MpExperienceSiri(self.xpParam, self.mpTopo,
|
||||||
|
self.mpTopoConfig)
|
||||||
elif xp == MpExperience.SENDFILE:
|
elif xp == MpExperience.SENDFILE:
|
||||||
MpExperienceSendFile(self.xpParam, self.mpTopo,
|
MpExperienceSendFile(self.xpParam, self.mpTopo,
|
||||||
self.mpTopoConfig)
|
self.mpTopoConfig)
|
||||||
|
Loading…
Reference in New Issue
Block a user