Statistics
| Branch: | Tag: | Revision:

root / lib / hypervisor / FakeHypervisor.py @ 65a6f9b7

History | View | Annotate | Download (6.1 kB)

1 65a6f9b7 Michael Hanselmann
#
2 65a6f9b7 Michael Hanselmann
#
3 65a6f9b7 Michael Hanselmann
4 65a6f9b7 Michael Hanselmann
# Copyright (C) 2006, 2007, 2008 Google Inc.
5 65a6f9b7 Michael Hanselmann
#
6 65a6f9b7 Michael Hanselmann
# This program is free software; you can redistribute it and/or modify
7 65a6f9b7 Michael Hanselmann
# it under the terms of the GNU General Public License as published by
8 65a6f9b7 Michael Hanselmann
# the Free Software Foundation; either version 2 of the License, or
9 65a6f9b7 Michael Hanselmann
# (at your option) any later version.
10 65a6f9b7 Michael Hanselmann
#
11 65a6f9b7 Michael Hanselmann
# This program is distributed in the hope that it will be useful, but
12 65a6f9b7 Michael Hanselmann
# WITHOUT ANY WARRANTY; without even the implied warranty of
13 65a6f9b7 Michael Hanselmann
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
14 65a6f9b7 Michael Hanselmann
# General Public License for more details.
15 65a6f9b7 Michael Hanselmann
#
16 65a6f9b7 Michael Hanselmann
# You should have received a copy of the GNU General Public License
17 65a6f9b7 Michael Hanselmann
# along with this program; if not, write to the Free Software
18 65a6f9b7 Michael Hanselmann
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
19 65a6f9b7 Michael Hanselmann
# 02110-1301, USA.
20 65a6f9b7 Michael Hanselmann
21 65a6f9b7 Michael Hanselmann
22 65a6f9b7 Michael Hanselmann
"""Fake hypervisor
23 65a6f9b7 Michael Hanselmann

24 65a6f9b7 Michael Hanselmann
"""
25 65a6f9b7 Michael Hanselmann
26 65a6f9b7 Michael Hanselmann
import os
27 65a6f9b7 Michael Hanselmann
import os.path
28 65a6f9b7 Michael Hanselmann
29 65a6f9b7 Michael Hanselmann
from ganeti import utils
30 65a6f9b7 Michael Hanselmann
from ganeti import constants
31 65a6f9b7 Michael Hanselmann
from ganeti import errors
32 65a6f9b7 Michael Hanselmann
from ganeti.hypervisor import BaseHypervisor
33 65a6f9b7 Michael Hanselmann
34 65a6f9b7 Michael Hanselmann
35 65a6f9b7 Michael Hanselmann
class FakeHypervisor(BaseHypervisor.BaseHypervisor):
36 65a6f9b7 Michael Hanselmann
  """Fake hypervisor interface.
37 65a6f9b7 Michael Hanselmann

38 65a6f9b7 Michael Hanselmann
  This can be used for testing the ganeti code without having to have
39 65a6f9b7 Michael Hanselmann
  a real virtualisation software installed.
40 65a6f9b7 Michael Hanselmann

41 65a6f9b7 Michael Hanselmann
  """
42 65a6f9b7 Michael Hanselmann
  _ROOT_DIR = constants.RUN_DIR + "/ganeti-fake-hypervisor"
43 65a6f9b7 Michael Hanselmann
44 65a6f9b7 Michael Hanselmann
  def __init__(self):
45 65a6f9b7 Michael Hanselmann
    BaseHypervisor.__init__(self)
46 65a6f9b7 Michael Hanselmann
    if not os.path.exists(self._ROOT_DIR):
47 65a6f9b7 Michael Hanselmann
      os.mkdir(self._ROOT_DIR)
48 65a6f9b7 Michael Hanselmann
49 65a6f9b7 Michael Hanselmann
  def ListInstances(self):
50 65a6f9b7 Michael Hanselmann
    """Get the list of running instances.
51 65a6f9b7 Michael Hanselmann

52 65a6f9b7 Michael Hanselmann
    """
53 65a6f9b7 Michael Hanselmann
    return os.listdir(self._ROOT_DIR)
54 65a6f9b7 Michael Hanselmann
55 65a6f9b7 Michael Hanselmann
  def GetInstanceInfo(self, instance_name):
56 65a6f9b7 Michael Hanselmann
    """Get instance properties.
57 65a6f9b7 Michael Hanselmann

58 65a6f9b7 Michael Hanselmann
    Args:
59 65a6f9b7 Michael Hanselmann
      instance_name: the instance name
60 65a6f9b7 Michael Hanselmann

61 65a6f9b7 Michael Hanselmann
    Returns:
62 65a6f9b7 Michael Hanselmann
      (name, id, memory, vcpus, stat, times)
63 65a6f9b7 Michael Hanselmann
    """
64 65a6f9b7 Michael Hanselmann
    file_name = "%s/%s" % (self._ROOT_DIR, instance_name)
65 65a6f9b7 Michael Hanselmann
    if not os.path.exists(file_name):
66 65a6f9b7 Michael Hanselmann
      return None
67 65a6f9b7 Michael Hanselmann
    try:
68 65a6f9b7 Michael Hanselmann
      fh = file(file_name, "r")
69 65a6f9b7 Michael Hanselmann
      try:
70 65a6f9b7 Michael Hanselmann
        inst_id = fh.readline().strip()
71 65a6f9b7 Michael Hanselmann
        memory = fh.readline().strip()
72 65a6f9b7 Michael Hanselmann
        vcpus = fh.readline().strip()
73 65a6f9b7 Michael Hanselmann
        stat = "---b-"
74 65a6f9b7 Michael Hanselmann
        times = "0"
75 65a6f9b7 Michael Hanselmann
        return (instance_name, inst_id, memory, vcpus, stat, times)
76 65a6f9b7 Michael Hanselmann
      finally:
77 65a6f9b7 Michael Hanselmann
        fh.close()
78 65a6f9b7 Michael Hanselmann
    except IOError, err:
79 65a6f9b7 Michael Hanselmann
      raise errors.HypervisorError("Failed to list instance %s: %s" %
80 65a6f9b7 Michael Hanselmann
                                   (instance_name, err))
81 65a6f9b7 Michael Hanselmann
82 65a6f9b7 Michael Hanselmann
  def GetAllInstancesInfo(self):
83 65a6f9b7 Michael Hanselmann
    """Get properties of all instances.
84 65a6f9b7 Michael Hanselmann

85 65a6f9b7 Michael Hanselmann
    Returns:
86 65a6f9b7 Michael Hanselmann
      [(name, id, memory, vcpus, stat, times),...]
87 65a6f9b7 Michael Hanselmann
    """
88 65a6f9b7 Michael Hanselmann
    data = []
89 65a6f9b7 Michael Hanselmann
    for file_name in os.listdir(self._ROOT_DIR):
90 65a6f9b7 Michael Hanselmann
      try:
91 65a6f9b7 Michael Hanselmann
        fh = file(self._ROOT_DIR+"/"+file_name, "r")
92 65a6f9b7 Michael Hanselmann
        inst_id = "-1"
93 65a6f9b7 Michael Hanselmann
        memory = "0"
94 65a6f9b7 Michael Hanselmann
        stat = "-----"
95 65a6f9b7 Michael Hanselmann
        times = "-1"
96 65a6f9b7 Michael Hanselmann
        try:
97 65a6f9b7 Michael Hanselmann
          inst_id = fh.readline().strip()
98 65a6f9b7 Michael Hanselmann
          memory = fh.readline().strip()
99 65a6f9b7 Michael Hanselmann
          vcpus = fh.readline().strip()
100 65a6f9b7 Michael Hanselmann
          stat = "---b-"
101 65a6f9b7 Michael Hanselmann
          times = "0"
102 65a6f9b7 Michael Hanselmann
        finally:
103 65a6f9b7 Michael Hanselmann
          fh.close()
104 65a6f9b7 Michael Hanselmann
        data.append((file_name, inst_id, memory, vcpus, stat, times))
105 65a6f9b7 Michael Hanselmann
      except IOError, err:
106 65a6f9b7 Michael Hanselmann
        raise errors.HypervisorError("Failed to list instances: %s" % err)
107 65a6f9b7 Michael Hanselmann
    return data
108 65a6f9b7 Michael Hanselmann
109 65a6f9b7 Michael Hanselmann
  def StartInstance(self, instance, force, extra_args):
110 65a6f9b7 Michael Hanselmann
    """Start an instance.
111 65a6f9b7 Michael Hanselmann

112 65a6f9b7 Michael Hanselmann
    For the fake hypervisor, it just creates a file in the base dir,
113 65a6f9b7 Michael Hanselmann
    creating an exception if it already exists. We don't actually
114 65a6f9b7 Michael Hanselmann
    handle race conditions properly, since these are *FAKE* instances.
115 65a6f9b7 Michael Hanselmann

116 65a6f9b7 Michael Hanselmann
    """
117 65a6f9b7 Michael Hanselmann
    file_name = self._ROOT_DIR + "/%s" % instance.name
118 65a6f9b7 Michael Hanselmann
    if os.path.exists(file_name):
119 65a6f9b7 Michael Hanselmann
      raise errors.HypervisorError("Failed to start instance %s: %s" %
120 65a6f9b7 Michael Hanselmann
                                   (instance.name, "already running"))
121 65a6f9b7 Michael Hanselmann
    try:
122 65a6f9b7 Michael Hanselmann
      fh = file(file_name, "w")
123 65a6f9b7 Michael Hanselmann
      try:
124 65a6f9b7 Michael Hanselmann
        fh.write("0\n%d\n%d\n" % (instance.memory, instance.vcpus))
125 65a6f9b7 Michael Hanselmann
      finally:
126 65a6f9b7 Michael Hanselmann
        fh.close()
127 65a6f9b7 Michael Hanselmann
    except IOError, err:
128 65a6f9b7 Michael Hanselmann
      raise errors.HypervisorError("Failed to start instance %s: %s" %
129 65a6f9b7 Michael Hanselmann
                                   (instance.name, err))
130 65a6f9b7 Michael Hanselmann
131 65a6f9b7 Michael Hanselmann
  def StopInstance(self, instance, force=False):
132 65a6f9b7 Michael Hanselmann
    """Stop an instance.
133 65a6f9b7 Michael Hanselmann

134 65a6f9b7 Michael Hanselmann
    For the fake hypervisor, this just removes the file in the base
135 65a6f9b7 Michael Hanselmann
    dir, if it exist, otherwise we raise an exception.
136 65a6f9b7 Michael Hanselmann

137 65a6f9b7 Michael Hanselmann
    """
138 65a6f9b7 Michael Hanselmann
    file_name = self._ROOT_DIR + "/%s" % instance.name
139 65a6f9b7 Michael Hanselmann
    if not os.path.exists(file_name):
140 65a6f9b7 Michael Hanselmann
      raise errors.HypervisorError("Failed to stop instance %s: %s" %
141 65a6f9b7 Michael Hanselmann
                                   (instance.name, "not running"))
142 65a6f9b7 Michael Hanselmann
    utils.RemoveFile(file_name)
143 65a6f9b7 Michael Hanselmann
144 65a6f9b7 Michael Hanselmann
  def RebootInstance(self, instance):
145 65a6f9b7 Michael Hanselmann
    """Reboot an instance.
146 65a6f9b7 Michael Hanselmann

147 65a6f9b7 Michael Hanselmann
    For the fake hypervisor, this does nothing.
148 65a6f9b7 Michael Hanselmann

149 65a6f9b7 Michael Hanselmann
    """
150 65a6f9b7 Michael Hanselmann
    return
151 65a6f9b7 Michael Hanselmann
152 65a6f9b7 Michael Hanselmann
  def GetNodeInfo(self):
153 65a6f9b7 Michael Hanselmann
    """Return information about the node.
154 65a6f9b7 Michael Hanselmann

155 65a6f9b7 Michael Hanselmann
    The return value is a dict, which has to have the following items:
156 65a6f9b7 Michael Hanselmann
      (all values in MiB)
157 65a6f9b7 Michael Hanselmann
      - memory_total: the total memory size on the node
158 65a6f9b7 Michael Hanselmann
      - memory_free: the available memory on the node for instances
159 65a6f9b7 Michael Hanselmann
      - memory_dom0: the memory used by the node itself, if available
160 65a6f9b7 Michael Hanselmann

161 65a6f9b7 Michael Hanselmann
    """
162 65a6f9b7 Michael Hanselmann
    # global ram usage from the xm info command
163 65a6f9b7 Michael Hanselmann
    # memory                 : 3583
164 65a6f9b7 Michael Hanselmann
    # free_memory            : 747
165 65a6f9b7 Michael Hanselmann
    # note: in xen 3, memory has changed to total_memory
166 65a6f9b7 Michael Hanselmann
    try:
167 65a6f9b7 Michael Hanselmann
      fh = file("/proc/meminfo")
168 65a6f9b7 Michael Hanselmann
      try:
169 65a6f9b7 Michael Hanselmann
        data = fh.readlines()
170 65a6f9b7 Michael Hanselmann
      finally:
171 65a6f9b7 Michael Hanselmann
        fh.close()
172 65a6f9b7 Michael Hanselmann
    except IOError, err:
173 65a6f9b7 Michael Hanselmann
      raise errors.HypervisorError("Failed to list node info: %s" % err)
174 65a6f9b7 Michael Hanselmann
175 65a6f9b7 Michael Hanselmann
    result = {}
176 65a6f9b7 Michael Hanselmann
    sum_free = 0
177 65a6f9b7 Michael Hanselmann
    for line in data:
178 65a6f9b7 Michael Hanselmann
      splitfields = line.split(":", 1)
179 65a6f9b7 Michael Hanselmann
180 65a6f9b7 Michael Hanselmann
      if len(splitfields) > 1:
181 65a6f9b7 Michael Hanselmann
        key = splitfields[0].strip()
182 65a6f9b7 Michael Hanselmann
        val = splitfields[1].strip()
183 65a6f9b7 Michael Hanselmann
        if key == 'MemTotal':
184 65a6f9b7 Michael Hanselmann
          result['memory_total'] = int(val.split()[0])/1024
185 65a6f9b7 Michael Hanselmann
        elif key in ('MemFree', 'Buffers', 'Cached'):
186 65a6f9b7 Michael Hanselmann
          sum_free += int(val.split()[0])/1024
187 65a6f9b7 Michael Hanselmann
        elif key == 'Active':
188 65a6f9b7 Michael Hanselmann
          result['memory_dom0'] = int(val.split()[0])/1024
189 65a6f9b7 Michael Hanselmann
190 65a6f9b7 Michael Hanselmann
    result['memory_free'] = sum_free
191 65a6f9b7 Michael Hanselmann
    return result
192 65a6f9b7 Michael Hanselmann
193 65a6f9b7 Michael Hanselmann
  @staticmethod
194 65a6f9b7 Michael Hanselmann
  def GetShellCommandForConsole(instance):
195 65a6f9b7 Michael Hanselmann
    """Return a command for connecting to the console of an instance.
196 65a6f9b7 Michael Hanselmann

197 65a6f9b7 Michael Hanselmann
    """
198 65a6f9b7 Michael Hanselmann
    return "echo Console not available for fake hypervisor"
199 65a6f9b7 Michael Hanselmann
200 65a6f9b7 Michael Hanselmann
  def Verify(self):
201 65a6f9b7 Michael Hanselmann
    """Verify the hypervisor.
202 65a6f9b7 Michael Hanselmann

203 65a6f9b7 Michael Hanselmann
    For the fake hypervisor, it just checks the existence of the base
204 65a6f9b7 Michael Hanselmann
    dir.
205 65a6f9b7 Michael Hanselmann

206 65a6f9b7 Michael Hanselmann
    """
207 65a6f9b7 Michael Hanselmann
    if not os.path.exists(self._ROOT_DIR):
208 65a6f9b7 Michael Hanselmann
      return "The required directory '%s' does not exist." % self._ROOT_DIR