2 Distributed Cloud Emulator (dcemulator)
3 (c) 2015 by Manuel Peuster <manuel.peuster@upb.de>
5 from mininet
.node
import Docker
9 DCDPID_BASE
= 1000 # start of switch dpid's used for data center switches
12 class EmulatorCompute(Docker
):
14 Emulator specific compute node class.
15 Inherits from Dockernet's Docker host class.
16 Represents a single container connected to a (logical)
18 We can add emulator specific helper functions to it.
22 self
, name
, dimage
, **kwargs
):
23 logging
.debug("Create EmulatorCompute instance: %s" % name
)
24 self
.datacenter
= None # pointer to current DC
26 # call original Docker.__init__
27 Docker
.__init
__(self
, name
, dimage
, **kwargs
)
29 def getNetworkStatus(self
):
31 Helper method to receive information about the virtual networks
32 this compute instance is connected to.
34 # format list of tuples (name, Ip, MAC, isUp, status)
35 return [(str(i
), i
.IP(), i
.MAC(), i
.isUp(), i
.status())
36 for i
in self
.intfList()]
40 Helper method to receive information about this compute instance.
43 status
["name"] = self
.name
44 status
["network"] = self
.getNetworkStatus()
45 status
["image"] = self
.dimage
46 status
["cpu_quota"] = self
.cpu_quota
47 status
["cpu_period"] = self
.cpu_period
48 status
["cpu_shares"] = self
.cpu_shares
49 status
["cpuset"] = self
.cpuset
50 status
["mem_limit"] = self
.mem_limit
51 status
["memswap_limit"] = self
.memswap_limit
52 status
["state"] = self
.dcli
.inspect_container(self
.dc
)["State"]
53 status
["id"] = self
.dcli
.inspect_container(self
.dc
)["Id"]
54 status
["datacenter"] = (None if self
.datacenter
is None
55 else self
.datacenter
.name
)
59 class Datacenter(object):
61 Represents a logical data center to which compute resources
62 (Docker containers) can be added at runtime.
64 Will also implement resource bookkeeping in later versions.
67 def __init__(self
, name
):
68 self
.net
= None # DCNetwork to which we belong
70 self
.switch
= None # first prototype assumes one "bigswitch" per DC
71 self
.containers
= {} # keep track of running containers
73 def _get_next_dc_dpid(self
):
80 Each data center is represented by a single switch to which
81 compute resources can be connected at run time.
83 TODO: This will be changed in the future to support multiple networks
86 self
.switch
= self
.net
.mnet
.addSwitch(
87 "%s.s1" % self
.name
, dpid
=hex(self
._get
_next
_dc
_dpid
())[2:])
88 logging
.debug("created data center switch: %s" % str(self
.switch
))
93 def startCompute(self
, name
, image
=None, network
=None):
95 Create a new container as compute resource and connect it to this
98 TODO: This interface will change to support multiple networks to which
99 a single container can be connected.
101 assert name
is not None
102 # set default parameter
106 network
= {} # {"ip": "10.0.0.254/8"}
107 # create the container and connect it to the given network
108 d
= self
.net
.addDocker("%s" % (name
), dimage
=image
)
109 self
.net
.addLink(d
, self
.switch
, params1
=network
)
111 self
.containers
[name
] = d
113 return name
# we might use UUIDs for naming later on
115 def stopCompute(self
, name
):
117 Stop and remove a container from this data center.
119 assert name
in self
.containers
121 link
=None, node1
=self
.containers
[name
], node2
=self
.switch
)
122 self
.net
.removeDocker("%s" % (name
))
123 del self
.containers
[name
]
126 def listCompute(self
):
128 Return a list of all running containers assigned to this
131 return self
.containers
.itervalues()