4 # Copyright (C) 2006, 2007, 2008 Google Inc.
6 # This program is free software; you can redistribute it and/or modify
7 # it under the terms of the GNU General Public License as published by
8 # the Free Software Foundation; either version 2 of the License, or
9 # (at your option) any later version.
11 # This program is distributed in the hope that it will be useful, but
12 # WITHOUT ANY WARRANTY; without even the implied warranty of
13 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 # General Public License for more details.
16 # You should have received a copy of the GNU General Public License
17 # along with this program; if not, write to the Free Software
18 # Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
30 from ganeti import utils
31 from ganeti import constants
32 from ganeti import errors
33 from ganeti.hypervisor import hv_base
36 class FakeHypervisor(hv_base.BaseHypervisor):
37 """Fake hypervisor interface.
39 This can be used for testing the ganeti code without having to have
40 a real virtualisation software installed.
43 _ROOT_DIR = constants.RUN_DIR + "/ganeti-fake-hypervisor"
46 hv_base.BaseHypervisor.__init__(self)
47 if not os.path.exists(self._ROOT_DIR):
48 os.mkdir(self._ROOT_DIR)
50 def ListInstances(self):
51 """Get the list of running instances.
54 return os.listdir(self._ROOT_DIR)
56 def GetInstanceInfo(self, instance_name):
57 """Get instance properties.
59 @param instance_name: the instance name
61 @return: tuple of (name, id, memory, vcpus, stat, times)
64 file_name = "%s/%s" % (self._ROOT_DIR, instance_name)
65 if not os.path.exists(file_name):
68 fh = open(file_name, "r")
70 inst_id = fh.readline().strip()
71 memory = utils.TryConvert(int, fh.readline().strip())
72 vcpus = utils.TryConvert(fh.readline().strip())
75 return (instance_name, inst_id, memory, vcpus, stat, times)
79 raise errors.HypervisorError("Failed to list instance %s: %s" %
82 def GetAllInstancesInfo(self):
83 """Get properties of all instances.
85 @return: list of tuples (name, id, memory, vcpus, stat, times)
89 for file_name in os.listdir(self._ROOT_DIR):
91 fh = open(self._ROOT_DIR+"/"+file_name, "r")
98 inst_id = fh.readline().strip()
99 memory = utils.TryConvert(int, fh.readline().strip())
100 vcpus = utils.TryConvert(int, fh.readline().strip())
105 data.append((file_name, inst_id, memory, vcpus, stat, times))
107 raise errors.HypervisorError("Failed to list instances: %s" % err)
110 def StartInstance(self, instance, block_devices, extra_args):
111 """Start an instance.
113 For the fake hypervisor, it just creates a file in the base dir,
114 creating an exception if it already exists. We don't actually
115 handle race conditions properly, since these are *FAKE* instances.
118 file_name = self._ROOT_DIR + "/%s" % instance.name
119 if os.path.exists(file_name):
120 raise errors.HypervisorError("Failed to start instance %s: %s" %
121 (instance.name, "already running"))
123 fh = file(file_name, "w")
125 fh.write("0\n%d\n%d\n" %
126 (instance.beparams[constants.BE_MEMORY],
127 instance.beparams[constants.BE_VCPUS]))
131 raise errors.HypervisorError("Failed to start instance %s: %s" %
132 (instance.name, err))
134 def StopInstance(self, instance, force=False):
137 For the fake hypervisor, this just removes the file in the base
138 dir, if it exist, otherwise we raise an exception.
141 file_name = self._ROOT_DIR + "/%s" % instance.name
142 if not os.path.exists(file_name):
143 raise errors.HypervisorError("Failed to stop instance %s: %s" %
144 (instance.name, "not running"))
145 utils.RemoveFile(file_name)
147 def RebootInstance(self, instance):
148 """Reboot an instance.
150 For the fake hypervisor, this does nothing.
155 def GetNodeInfo(self):
156 """Return information about the node.
158 @return: a dict with the following keys (values in MiB):
159 - memory_total: the total memory size on the node
160 - memory_free: the available memory on the node for instances
161 - memory_dom0: the memory used by the node itself, if available
164 # global ram usage from the xm info command
167 # note: in xen 3, memory has changed to total_memory
169 fh = file("/proc/meminfo")
171 data = fh.readlines()
175 raise errors.HypervisorError("Failed to list node info: %s" % err)
180 splitfields = line.split(":", 1)
182 if len(splitfields) > 1:
183 key = splitfields[0].strip()
184 val = splitfields[1].strip()
185 if key == 'MemTotal':
186 result['memory_total'] = int(val.split()[0])/1024
187 elif key in ('MemFree', 'Buffers', 'Cached'):
188 sum_free += int(val.split()[0])/1024
189 elif key == 'Active':
190 result['memory_dom0'] = int(val.split()[0])/1024
191 result['memory_free'] = sum_free
193 # substract running instances
194 all_instances = self.GetAllInstancesInfo()
195 result['memory_free'] -= min(result['memory_free'],
196 sum([row[2] for row in all_instances]))
200 fh = open("/proc/cpuinfo")
202 cpu_total = len(re.findall("(?m)^processor\s*:\s*[0-9]+\s*$",
206 except EnvironmentError, err:
207 raise errors.HypervisorError("Failed to list node info: %s" % err)
208 result['cpu_total'] = cpu_total
209 # FIXME: export correct data here
210 result['cpu_nodes'] = 1
211 result['cpu_sockets'] = 1
216 def GetShellCommandForConsole(cls, instance, hvparams, beparams):
217 """Return a command for connecting to the console of an instance.
220 return "echo Console not available for fake hypervisor"
223 """Verify the hypervisor.
225 For the fake hypervisor, it just checks the existence of the base
229 if not os.path.exists(self._ROOT_DIR):
230 return "The required directory '%s' does not exist." % self._ROOT_DIR