in tools/minicluster/minicluster.py [0:0]
def _create_peloton_ports(self):
config = self.config
self.resmgr_ports = []
for i in range(0, config["peloton_resmgr_instance_count"]):
# to not cause port conflicts among apps, increase port by 10
# for each instance
portset = [
port + i * 10 for port in config["peloton_resmgr_ports"]]
self.resmgr_ports.append(portset)
self.hostmgr_ports = []
for i in range(0, config["peloton_hostmgr_instance_count"]):
portset = [
port + i * 10 for port in config["peloton_hostmgr_ports"]]
self.hostmgr_ports.append(portset)
self.jobmgr_ports = []
for i in range(0, config["peloton_jobmgr_instance_count"]):
portset = [
port + i * 10 for port in config["peloton_jobmgr_ports"]]
self.jobmgr_ports.append(portset)
self.aurorabridge_ports = []
for i in range(0, config["peloton_aurorabridge_instance_count"]):
portset = [
port + i * 10 for port in config["peloton_aurorabridge_ports"]]
self.aurorabridge_ports.append(portset)
self.apiserver_ports = []
for i in range(0, config["peloton_apiserver_instance_count"]):
portset = [
port + i * 10 for port in config["peloton_apiserver_ports"]]
self.apiserver_ports.append(portset)
self.archiver_ports = []
for i in range(0, config["peloton_archiver_instance_count"]):
portset = [
port + i * 10 for port in config["peloton_archiver_ports"]]
self.archiver_ports.append(portset)
self.placement_ports = []
for i in range(0, len(config["peloton_placement_instances"])):
portset = [
port + i * 10 for port in config["peloton_placement_ports"]]
self.placement_ports.append(portset)
self.mockcqos_ports = []
for i in range(0, config["peloton_mock_cqos_instance_count"]):
portset = [
port + i * 10 for port in config["peloton_mock_cqos_ports"]]
self.mockcqos_ports.append(portset)