Statistics
| Branch: | Tag: | Revision:

root / scripts / gnt-instance @ 973d7867

History | View | Annotate | Download (32.5 kB)

1 a8083063 Iustin Pop
#!/usr/bin/python
2 a8083063 Iustin Pop
#
3 a8083063 Iustin Pop
4 a8083063 Iustin Pop
# Copyright (C) 2006, 2007 Google Inc.
5 a8083063 Iustin Pop
#
6 a8083063 Iustin Pop
# This program is free software; you can redistribute it and/or modify
7 a8083063 Iustin Pop
# it under the terms of the GNU General Public License as published by
8 a8083063 Iustin Pop
# the Free Software Foundation; either version 2 of the License, or
9 a8083063 Iustin Pop
# (at your option) any later version.
10 a8083063 Iustin Pop
#
11 a8083063 Iustin Pop
# This program is distributed in the hope that it will be useful, but
12 a8083063 Iustin Pop
# WITHOUT ANY WARRANTY; without even the implied warranty of
13 a8083063 Iustin Pop
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
14 a8083063 Iustin Pop
# General Public License for more details.
15 a8083063 Iustin Pop
#
16 a8083063 Iustin Pop
# You should have received a copy of the GNU General Public License
17 a8083063 Iustin Pop
# along with this program; if not, write to the Free Software
18 a8083063 Iustin Pop
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
19 a8083063 Iustin Pop
# 02110-1301, USA.
20 a8083063 Iustin Pop
21 a8083063 Iustin Pop
22 a8083063 Iustin Pop
import sys
23 a8083063 Iustin Pop
import os
24 312ac745 Iustin Pop
import itertools
25 a8083063 Iustin Pop
from optparse import make_option
26 a8083063 Iustin Pop
from cStringIO import StringIO
27 a8083063 Iustin Pop
28 a8083063 Iustin Pop
from ganeti.cli import *
29 a8083063 Iustin Pop
from ganeti import opcodes
30 a8083063 Iustin Pop
from ganeti import logger
31 a8083063 Iustin Pop
from ganeti import constants
32 a8083063 Iustin Pop
from ganeti import utils
33 312ac745 Iustin Pop
from ganeti import errors
34 312ac745 Iustin Pop
35 312ac745 Iustin Pop
36 312ac745 Iustin Pop
_SHUTDOWN_CLUSTER = "cluster"
37 312ac745 Iustin Pop
_SHUTDOWN_NODES_BOTH = "nodes"
38 312ac745 Iustin Pop
_SHUTDOWN_NODES_PRI = "nodes-pri"
39 312ac745 Iustin Pop
_SHUTDOWN_NODES_SEC = "nodes-sec"
40 312ac745 Iustin Pop
_SHUTDOWN_INSTANCES = "instances"
41 312ac745 Iustin Pop
42 312ac745 Iustin Pop
def _ExpandMultiNames(mode, names):
43 312ac745 Iustin Pop
  """Expand the given names using the passed mode.
44 312ac745 Iustin Pop
45 312ac745 Iustin Pop
  Args:
46 312ac745 Iustin Pop
    - mode, which can be one of _SHUTDOWN_CLUSTER, _SHUTDOWN_NODES_BOTH,
47 312ac745 Iustin Pop
      _SHUTDOWN_NODES_PRI, _SHUTDOWN_NODES_SEC or _SHUTDOWN_INSTANCES
48 312ac745 Iustin Pop
    - names, which is a list of names; for cluster, it must be empty,
49 312ac745 Iustin Pop
      and for node and instance it must be a list of valid item
50 312ac745 Iustin Pop
      names (short names are valid as usual, e.g. node1 instead of
51 312ac745 Iustin Pop
      node1.example.com)
52 312ac745 Iustin Pop
53 312ac745 Iustin Pop
  For _SHUTDOWN_CLUSTER, all instances will be returned. For
54 312ac745 Iustin Pop
  _SHUTDOWN_NODES_PRI/SEC, all instances having those nodes as
55 312ac745 Iustin Pop
  primary/secondary will be shutdown. For _SHUTDOWN_NODES_BOTH, all
56 312ac745 Iustin Pop
  instances having those nodes as either primary or secondary will be
57 312ac745 Iustin Pop
  returned. For _SHUTDOWN_INSTANCES, the given instances will be
58 312ac745 Iustin Pop
  returned.
59 312ac745 Iustin Pop
60 312ac745 Iustin Pop
  """
61 312ac745 Iustin Pop
  if mode == _SHUTDOWN_CLUSTER:
62 312ac745 Iustin Pop
    if names:
63 312ac745 Iustin Pop
      raise errors.OpPrereqError("Cluster filter mode takes no arguments")
64 312ac745 Iustin Pop
    op = opcodes.OpQueryInstances(output_fields=["name"], names=[])
65 312ac745 Iustin Pop
    idata = SubmitOpCode(op)
66 312ac745 Iustin Pop
    inames = [row[0] for row in idata]
67 312ac745 Iustin Pop
68 312ac745 Iustin Pop
  elif mode in (_SHUTDOWN_NODES_BOTH,
69 312ac745 Iustin Pop
                _SHUTDOWN_NODES_PRI,
70 312ac745 Iustin Pop
                _SHUTDOWN_NODES_SEC):
71 312ac745 Iustin Pop
    if not names:
72 312ac745 Iustin Pop
      raise errors.OpPrereqError("No node names passed")
73 312ac745 Iustin Pop
    op = opcodes.OpQueryNodes(output_fields=["name", "pinst_list",
74 312ac745 Iustin Pop
                                             "sinst_list"], names=names)
75 312ac745 Iustin Pop
    ndata = SubmitOpCode(op)
76 312ac745 Iustin Pop
    ipri = [row[1] for row in ndata]
77 312ac745 Iustin Pop
    pri_names = list(itertools.chain(*ipri))
78 312ac745 Iustin Pop
    isec = [row[2] for row in ndata]
79 312ac745 Iustin Pop
    sec_names = list(itertools.chain(*isec))
80 312ac745 Iustin Pop
    if mode == _SHUTDOWN_NODES_BOTH:
81 312ac745 Iustin Pop
      inames = pri_names + sec_names
82 312ac745 Iustin Pop
    elif mode == _SHUTDOWN_NODES_PRI:
83 312ac745 Iustin Pop
      inames = pri_names
84 312ac745 Iustin Pop
    elif mode == _SHUTDOWN_NODES_SEC:
85 312ac745 Iustin Pop
      inames = sec_names
86 312ac745 Iustin Pop
    else:
87 312ac745 Iustin Pop
      raise errors.ProgrammerError("Unhandled shutdown type")
88 312ac745 Iustin Pop
89 312ac745 Iustin Pop
  elif mode == _SHUTDOWN_INSTANCES:
90 312ac745 Iustin Pop
    if not names:
91 312ac745 Iustin Pop
      raise errors.OpPrereqError("No instance names passed")
92 312ac745 Iustin Pop
    op = opcodes.OpQueryInstances(output_fields=["name"], names=names)
93 312ac745 Iustin Pop
    idata = SubmitOpCode(op)
94 312ac745 Iustin Pop
    inames = [row[0] for row in idata]
95 312ac745 Iustin Pop
96 312ac745 Iustin Pop
  else:
97 312ac745 Iustin Pop
    raise errors.OpPrereqError("Unknown mode '%s'" % mode)
98 312ac745 Iustin Pop
99 312ac745 Iustin Pop
  return inames
100 a8083063 Iustin Pop
101 a8083063 Iustin Pop
102 804a1e8e Iustin Pop
def _ConfirmOperation(inames, text):
103 804a1e8e Iustin Pop
  """Ask the user to confirm an operation on a list of instances.
104 804a1e8e Iustin Pop
105 804a1e8e Iustin Pop
  This function is used to request confirmation for doing an operation
106 804a1e8e Iustin Pop
  on a given list of instances.
107 804a1e8e Iustin Pop
108 804a1e8e Iustin Pop
  The inames argument is what the selection algorithm computed, and
109 804a1e8e Iustin Pop
  the text argument is the operation we should tell the user to
110 804a1e8e Iustin Pop
  confirm (e.g. 'shutdown' or 'startup').
111 804a1e8e Iustin Pop
112 804a1e8e Iustin Pop
  Returns: boolean depending on user's confirmation.
113 804a1e8e Iustin Pop
114 804a1e8e Iustin Pop
  """
115 804a1e8e Iustin Pop
  count = len(inames)
116 804a1e8e Iustin Pop
  msg = ("The %s will operate on %d instances.\n"
117 804a1e8e Iustin Pop
         "Do you want to continue?" % (text, count))
118 804a1e8e Iustin Pop
  affected = ("\nAffected instances:\n" +
119 804a1e8e Iustin Pop
              "\n".join(["  %s" % name for name in inames]))
120 804a1e8e Iustin Pop
121 804a1e8e Iustin Pop
  choices = [('y', True, 'Yes, execute the %s' % text),
122 804a1e8e Iustin Pop
             ('n', False, 'No, abort the %s' % text)]
123 804a1e8e Iustin Pop
124 804a1e8e Iustin Pop
  if count > 20:
125 804a1e8e Iustin Pop
    choices.insert(1, ('v', 'v', 'View the list of affected instances'))
126 804a1e8e Iustin Pop
    ask = msg
127 804a1e8e Iustin Pop
  else:
128 804a1e8e Iustin Pop
    ask = msg + affected
129 804a1e8e Iustin Pop
130 804a1e8e Iustin Pop
  choice = AskUser(ask, choices)
131 804a1e8e Iustin Pop
  if choice == 'v':
132 804a1e8e Iustin Pop
    choices.pop(1)
133 804a1e8e Iustin Pop
    choice = AskUser(choices, msg + affected)
134 804a1e8e Iustin Pop
  return choice
135 804a1e8e Iustin Pop
136 804a1e8e Iustin Pop
137 973d7867 Iustin Pop
def _TransformPath(user_input):
138 973d7867 Iustin Pop
  """Transform a user path into a canonical value.
139 973d7867 Iustin Pop
140 973d7867 Iustin Pop
  This function transforms the a path passed as textual information
141 973d7867 Iustin Pop
  into the constants that the LU code expects.
142 973d7867 Iustin Pop
143 973d7867 Iustin Pop
  """
144 973d7867 Iustin Pop
  if user_input:
145 973d7867 Iustin Pop
    if user_input.lower() == "default":
146 973d7867 Iustin Pop
      result_path = constants.VALUE_DEFAULT
147 973d7867 Iustin Pop
    elif user_input.lower() == "none":
148 973d7867 Iustin Pop
      result_path = constants.VALUE_NONE
149 973d7867 Iustin Pop
    else:
150 973d7867 Iustin Pop
      if not os.path.isabs(user_input):
151 973d7867 Iustin Pop
        raise errors.OpPrereqError("Path '%s' is not an absolute filename" %
152 973d7867 Iustin Pop
                                   user_input)
153 973d7867 Iustin Pop
      result_path = user_input
154 973d7867 Iustin Pop
  else:
155 973d7867 Iustin Pop
    result_path = constants.VALUE_DEFAULT
156 973d7867 Iustin Pop
157 973d7867 Iustin Pop
  return result_path
158 973d7867 Iustin Pop
159 973d7867 Iustin Pop
160 a8083063 Iustin Pop
def ListInstances(opts, args):
161 f5abe9bd Oleksiy Mishchenko
  """List instances and their properties.
162 a8083063 Iustin Pop
163 a8083063 Iustin Pop
  """
164 a8083063 Iustin Pop
  if opts.output is None:
165 a8083063 Iustin Pop
    selected_fields = ["name", "os", "pnode", "admin_state",
166 a8083063 Iustin Pop
                       "oper_state", "oper_ram"]
167 a8083063 Iustin Pop
  else:
168 a8083063 Iustin Pop
    selected_fields = opts.output.split(",")
169 a8083063 Iustin Pop
170 069dcc86 Iustin Pop
  op = opcodes.OpQueryInstances(output_fields=selected_fields, names=[])
171 a8083063 Iustin Pop
  output = SubmitOpCode(op)
172 a8083063 Iustin Pop
173 a8083063 Iustin Pop
  if not opts.no_headers:
174 137161c9 Michael Hanselmann
    headers = {"name": "Instance", "os": "OS", "pnode": "Primary_node",
175 137161c9 Michael Hanselmann
               "snodes": "Secondary_Nodes", "admin_state": "Autostart",
176 137161c9 Michael Hanselmann
               "oper_state": "Status", "admin_ram": "Configured_memory",
177 137161c9 Michael Hanselmann
               "oper_ram": "Memory", "disk_template": "Disk_template",
178 137161c9 Michael Hanselmann
               "ip": "IP Address", "mac": "MAC Address",
179 644eeef9 Iustin Pop
               "bridge": "Bridge",
180 644eeef9 Iustin Pop
               "sda_size": "Disk/0", "sdb_size": "Disk/1"}
181 137161c9 Michael Hanselmann
  else:
182 137161c9 Michael Hanselmann
    headers = None
183 137161c9 Michael Hanselmann
184 137161c9 Michael Hanselmann
  if opts.human_readable:
185 644eeef9 Iustin Pop
    unitfields = ["admin_ram", "oper_ram", "sda_size", "sdb_size"]
186 137161c9 Michael Hanselmann
  else:
187 137161c9 Michael Hanselmann
    unitfields = None
188 137161c9 Michael Hanselmann
189 644eeef9 Iustin Pop
  numfields = ["admin_ram", "oper_ram", "sda_size", "sdb_size"]
190 137161c9 Michael Hanselmann
191 8a23d2d3 Iustin Pop
  # change raw values to nicer strings
192 8a23d2d3 Iustin Pop
  for row in output:
193 8a23d2d3 Iustin Pop
    for idx, field in enumerate(selected_fields):
194 8a23d2d3 Iustin Pop
      val = row[idx]
195 8a23d2d3 Iustin Pop
      if field == "snodes":
196 8a23d2d3 Iustin Pop
        val = ",".join(val) or "-"
197 8a23d2d3 Iustin Pop
      elif field == "admin_state":
198 8a23d2d3 Iustin Pop
        if val:
199 8a23d2d3 Iustin Pop
          val = "yes"
200 8a23d2d3 Iustin Pop
        else:
201 8a23d2d3 Iustin Pop
          val = "no"
202 8a23d2d3 Iustin Pop
      elif field == "oper_state":
203 8a23d2d3 Iustin Pop
        if val is None:
204 8a23d2d3 Iustin Pop
          val = "(node down)"
205 8a23d2d3 Iustin Pop
        elif val: # True
206 8a23d2d3 Iustin Pop
          val = "running"
207 8a23d2d3 Iustin Pop
        else:
208 8a23d2d3 Iustin Pop
          val = "stopped"
209 8a23d2d3 Iustin Pop
      elif field == "oper_ram":
210 8a23d2d3 Iustin Pop
        if val is None:
211 8a23d2d3 Iustin Pop
          val = "(node down)"
212 8a23d2d3 Iustin Pop
      elif field == "sda_size" or field == "sdb_size":
213 8a23d2d3 Iustin Pop
        if val is None:
214 8a23d2d3 Iustin Pop
          val = "N/A"
215 8a23d2d3 Iustin Pop
      row[idx] = str(val)
216 8a23d2d3 Iustin Pop
217 16be8703 Iustin Pop
  data = GenerateTable(separator=opts.separator, headers=headers,
218 16be8703 Iustin Pop
                       fields=selected_fields, unitfields=unitfields,
219 16be8703 Iustin Pop
                       numfields=numfields, data=output)
220 16be8703 Iustin Pop
221 16be8703 Iustin Pop
  for line in data:
222 16be8703 Iustin Pop
    logger.ToStdout(line)
223 a8083063 Iustin Pop
224 a8083063 Iustin Pop
  return 0
225 a8083063 Iustin Pop
226 a8083063 Iustin Pop
227 a8083063 Iustin Pop
def AddInstance(opts, args):
228 a8083063 Iustin Pop
  """Add an instance to the cluster.
229 a8083063 Iustin Pop
230 a8083063 Iustin Pop
  Args:
231 a8083063 Iustin Pop
    opts - class with options as members
232 a8083063 Iustin Pop
    args - list with a single element, the instance name
233 a8083063 Iustin Pop
  Opts used:
234 a8083063 Iustin Pop
    mem - amount of memory to allocate to instance (MiB)
235 a8083063 Iustin Pop
    size - amount of disk space to allocate to instance (MiB)
236 a8083063 Iustin Pop
    os - which OS to run on instance
237 a8083063 Iustin Pop
    node - node to run new instance on
238 a8083063 Iustin Pop
239 a8083063 Iustin Pop
  """
240 a8083063 Iustin Pop
  instance = args[0]
241 a8083063 Iustin Pop
242 60d49723 Michael Hanselmann
  (pnode, snode) = SplitNodeOption(opts.node)
243 60d49723 Michael Hanselmann
244 a8083063 Iustin Pop
  op = opcodes.OpCreateInstance(instance_name=instance, mem_size=opts.mem,
245 a8083063 Iustin Pop
                                disk_size=opts.size, swap_size=opts.swap,
246 a8083063 Iustin Pop
                                disk_template=opts.disk_template,
247 a8083063 Iustin Pop
                                mode=constants.INSTANCE_CREATE,
248 60d49723 Michael Hanselmann
                                os_type=opts.os, pnode=pnode,
249 60d49723 Michael Hanselmann
                                snode=snode, vcpus=opts.vcpus,
250 bdd55f71 Iustin Pop
                                ip=opts.ip, bridge=opts.bridge,
251 bdd55f71 Iustin Pop
                                start=opts.start, ip_check=opts.ip_check,
252 1862d460 Alexander Schreiber
                                wait_for_sync=opts.wait_for_sync, mac=opts.mac)
253 a8083063 Iustin Pop
  SubmitOpCode(op)
254 a8083063 Iustin Pop
  return 0
255 a8083063 Iustin Pop
256 a8083063 Iustin Pop
257 fe7b0351 Michael Hanselmann
def ReinstallInstance(opts, args):
258 fe7b0351 Michael Hanselmann
  """Reinstall an instance.
259 fe7b0351 Michael Hanselmann
260 fe7b0351 Michael Hanselmann
  Args:
261 fe7b0351 Michael Hanselmann
    opts - class with options as members
262 fe7b0351 Michael Hanselmann
    args - list containing a single element, the instance name
263 fe7b0351 Michael Hanselmann
264 fe7b0351 Michael Hanselmann
  """
265 fe7b0351 Michael Hanselmann
  instance_name = args[0]
266 fe7b0351 Michael Hanselmann
267 fe7b0351 Michael Hanselmann
  if not opts.force:
268 f4bc1f2c Michael Hanselmann
    usertext = ("This will reinstall the instance %s and remove"
269 f4bc1f2c Michael Hanselmann
                " all data. Continue?") % instance_name
270 47988778 Iustin Pop
    if not AskUser(usertext):
271 fe7b0351 Michael Hanselmann
      return 1
272 fe7b0351 Michael Hanselmann
273 d0834de3 Michael Hanselmann
  op = opcodes.OpReinstallInstance(instance_name=instance_name,
274 d0834de3 Michael Hanselmann
                                   os_type=opts.os)
275 fe7b0351 Michael Hanselmann
  SubmitOpCode(op)
276 fe7b0351 Michael Hanselmann
277 fe7b0351 Michael Hanselmann
  return 0
278 fe7b0351 Michael Hanselmann
279 fe7b0351 Michael Hanselmann
280 a8083063 Iustin Pop
def RemoveInstance(opts, args):
281 a8083063 Iustin Pop
  """Remove an instance.
282 a8083063 Iustin Pop
283 a8083063 Iustin Pop
  Args:
284 a8083063 Iustin Pop
    opts - class with options as members
285 a8083063 Iustin Pop
    args - list containing a single element, the instance name
286 a8083063 Iustin Pop
287 a8083063 Iustin Pop
  """
288 a8083063 Iustin Pop
  instance_name = args[0]
289 a8083063 Iustin Pop
  force = opts.force
290 a8083063 Iustin Pop
291 a8083063 Iustin Pop
  if not force:
292 a8083063 Iustin Pop
    usertext = ("This will remove the volumes of the instance %s"
293 a8083063 Iustin Pop
                " (including mirrors), thus removing all the data"
294 a8083063 Iustin Pop
                " of the instance. Continue?") % instance_name
295 47988778 Iustin Pop
    if not AskUser(usertext):
296 a8083063 Iustin Pop
      return 1
297 a8083063 Iustin Pop
298 1d67656e Iustin Pop
  op = opcodes.OpRemoveInstance(instance_name=instance_name,
299 1d67656e Iustin Pop
                                ignore_failures=opts.ignore_failures)
300 a8083063 Iustin Pop
  SubmitOpCode(op)
301 a8083063 Iustin Pop
  return 0
302 a8083063 Iustin Pop
303 a8083063 Iustin Pop
304 decd5f45 Iustin Pop
def RenameInstance(opts, args):
305 4ab0b9e3 Guido Trotter
  """Rename an instance.
306 decd5f45 Iustin Pop
307 decd5f45 Iustin Pop
  Args:
308 decd5f45 Iustin Pop
    opts - class with options as members
309 decd5f45 Iustin Pop
    args - list containing two elements, the instance name and the new name
310 decd5f45 Iustin Pop
311 decd5f45 Iustin Pop
  """
312 decd5f45 Iustin Pop
  op = opcodes.OpRenameInstance(instance_name=args[0],
313 decd5f45 Iustin Pop
                                new_name=args[1],
314 decd5f45 Iustin Pop
                                ignore_ip=opts.ignore_ip)
315 decd5f45 Iustin Pop
  SubmitOpCode(op)
316 decd5f45 Iustin Pop
317 decd5f45 Iustin Pop
  return 0
318 decd5f45 Iustin Pop
319 decd5f45 Iustin Pop
320 a8083063 Iustin Pop
def ActivateDisks(opts, args):
321 a8083063 Iustin Pop
  """Activate an instance's disks.
322 a8083063 Iustin Pop
323 a8083063 Iustin Pop
  This serves two purposes:
324 a8083063 Iustin Pop
    - it allows one (as long as the instance is not running) to mount
325 a8083063 Iustin Pop
    the disks and modify them from the node
326 a8083063 Iustin Pop
    - it repairs inactive secondary drbds
327 a8083063 Iustin Pop
328 a8083063 Iustin Pop
  """
329 a8083063 Iustin Pop
  instance_name = args[0]
330 a8083063 Iustin Pop
  op = opcodes.OpActivateInstanceDisks(instance_name=instance_name)
331 a8083063 Iustin Pop
  disks_info = SubmitOpCode(op)
332 a8083063 Iustin Pop
  for host, iname, nname in disks_info:
333 a8083063 Iustin Pop
    print "%s:%s:%s" % (host, iname, nname)
334 a8083063 Iustin Pop
  return 0
335 a8083063 Iustin Pop
336 a8083063 Iustin Pop
337 a8083063 Iustin Pop
def DeactivateDisks(opts, args):
338 a8083063 Iustin Pop
  """Command-line interface for _ShutdownInstanceBlockDevices.
339 a8083063 Iustin Pop
340 a8083063 Iustin Pop
  This function takes the instance name, looks for its primary node
341 a8083063 Iustin Pop
  and the tries to shutdown its block devices on that node.
342 a8083063 Iustin Pop
343 a8083063 Iustin Pop
  """
344 a8083063 Iustin Pop
  instance_name = args[0]
345 a8083063 Iustin Pop
  op = opcodes.OpDeactivateInstanceDisks(instance_name=instance_name)
346 a8083063 Iustin Pop
  SubmitOpCode(op)
347 a8083063 Iustin Pop
  return 0
348 a8083063 Iustin Pop
349 a8083063 Iustin Pop
350 a8083063 Iustin Pop
def StartupInstance(opts, args):
351 decd5f45 Iustin Pop
  """Startup an instance.
352 a8083063 Iustin Pop
353 a8083063 Iustin Pop
  Args:
354 a8083063 Iustin Pop
    opts - class with options as members
355 a8083063 Iustin Pop
    args - list containing a single element, the instance name
356 a8083063 Iustin Pop
357 a8083063 Iustin Pop
  """
358 312ac745 Iustin Pop
  if opts.multi_mode is None:
359 312ac745 Iustin Pop
    opts.multi_mode = _SHUTDOWN_INSTANCES
360 312ac745 Iustin Pop
  inames = _ExpandMultiNames(opts.multi_mode, args)
361 bcee9cb4 Iustin Pop
  if not inames:
362 bcee9cb4 Iustin Pop
    raise errors.OpPrereqError("Selection filter does not match any instances")
363 804a1e8e Iustin Pop
  multi_on = opts.multi_mode != _SHUTDOWN_INSTANCES or len(inames) > 1
364 804a1e8e Iustin Pop
  if not (opts.force_multi or not multi_on
365 804a1e8e Iustin Pop
          or _ConfirmOperation(inames, "startup")):
366 804a1e8e Iustin Pop
    return 1
367 312ac745 Iustin Pop
  for name in inames:
368 312ac745 Iustin Pop
    op = opcodes.OpStartupInstance(instance_name=name,
369 312ac745 Iustin Pop
                                   force=opts.force,
370 312ac745 Iustin Pop
                                   extra_args=opts.extra_args)
371 312ac745 Iustin Pop
    if multi_on:
372 312ac745 Iustin Pop
      logger.ToStdout("Starting up %s" % name)
373 312ac745 Iustin Pop
    SubmitOpCode(op)
374 a8083063 Iustin Pop
  return 0
375 a8083063 Iustin Pop
376 579d4337 Alexander Schreiber
def RebootInstance(opts, args):
377 579d4337 Alexander Schreiber
  """Reboot an instance
378 579d4337 Alexander Schreiber
379 579d4337 Alexander Schreiber
  Args:
380 579d4337 Alexander Schreiber
    opts - class with options as members
381 579d4337 Alexander Schreiber
    args - list containing a single element, the instance name
382 579d4337 Alexander Schreiber
383 579d4337 Alexander Schreiber
  """
384 579d4337 Alexander Schreiber
  if opts.multi_mode is None:
385 579d4337 Alexander Schreiber
    opts.multi_mode = _SHUTDOWN_INSTANCES
386 579d4337 Alexander Schreiber
  inames = _ExpandMultiNames(opts.multi_mode, args)
387 bcee9cb4 Iustin Pop
  if not inames:
388 bcee9cb4 Iustin Pop
    raise errors.OpPrereqError("Selection filter does not match any instances")
389 579d4337 Alexander Schreiber
  multi_on = opts.multi_mode != _SHUTDOWN_INSTANCES or len(inames) > 1
390 579d4337 Alexander Schreiber
  if not (opts.force_multi or not multi_on
391 579d4337 Alexander Schreiber
          or _ConfirmOperation(inames, "reboot")):
392 579d4337 Alexander Schreiber
    return 1
393 579d4337 Alexander Schreiber
  for name in inames:
394 579d4337 Alexander Schreiber
    op = opcodes.OpRebootInstance(instance_name=name,
395 579d4337 Alexander Schreiber
                                  reboot_type=opts.reboot_type,
396 579d4337 Alexander Schreiber
                                  ignore_secondaries=opts.ignore_secondaries)
397 579d4337 Alexander Schreiber
398 579d4337 Alexander Schreiber
    SubmitOpCode(op)
399 579d4337 Alexander Schreiber
  return 0
400 a8083063 Iustin Pop
401 a8083063 Iustin Pop
def ShutdownInstance(opts, args):
402 a8083063 Iustin Pop
  """Shutdown an instance.
403 a8083063 Iustin Pop
404 a8083063 Iustin Pop
  Args:
405 a8083063 Iustin Pop
    opts - class with options as members
406 a8083063 Iustin Pop
    args - list containing a single element, the instance name
407 a8083063 Iustin Pop
408 a8083063 Iustin Pop
  """
409 312ac745 Iustin Pop
  if opts.multi_mode is None:
410 312ac745 Iustin Pop
    opts.multi_mode = _SHUTDOWN_INSTANCES
411 312ac745 Iustin Pop
  inames = _ExpandMultiNames(opts.multi_mode, args)
412 bcee9cb4 Iustin Pop
  if not inames:
413 bcee9cb4 Iustin Pop
    raise errors.OpPrereqError("Selection filter does not match any instances")
414 804a1e8e Iustin Pop
  multi_on = opts.multi_mode != _SHUTDOWN_INSTANCES or len(inames) > 1
415 804a1e8e Iustin Pop
  if not (opts.force_multi or not multi_on
416 804a1e8e Iustin Pop
          or _ConfirmOperation(inames, "shutdown")):
417 804a1e8e Iustin Pop
    return 1
418 312ac745 Iustin Pop
  for name in inames:
419 312ac745 Iustin Pop
    op = opcodes.OpShutdownInstance(instance_name=name)
420 312ac745 Iustin Pop
    if multi_on:
421 312ac745 Iustin Pop
      logger.ToStdout("Shutting down %s" % name)
422 312ac745 Iustin Pop
    SubmitOpCode(op)
423 a8083063 Iustin Pop
  return 0
424 a8083063 Iustin Pop
425 a8083063 Iustin Pop
426 a8083063 Iustin Pop
def AddMDDRBDComponent(opts, args):
427 a8083063 Iustin Pop
  """Add a new component to a remote_raid1 disk.
428 a8083063 Iustin Pop
429 a8083063 Iustin Pop
  Args:
430 a8083063 Iustin Pop
    opts - class with options as members
431 a8083063 Iustin Pop
    args - list with a single element, the instance name
432 a8083063 Iustin Pop
433 a8083063 Iustin Pop
  """
434 a8083063 Iustin Pop
  op = opcodes.OpAddMDDRBDComponent(instance_name=args[0],
435 a8083063 Iustin Pop
                                    disk_name=opts.disk,
436 a8083063 Iustin Pop
                                    remote_node=opts.node)
437 a8083063 Iustin Pop
  SubmitOpCode(op)
438 a8083063 Iustin Pop
  return 0
439 a8083063 Iustin Pop
440 a8083063 Iustin Pop
441 a8083063 Iustin Pop
def RemoveMDDRBDComponent(opts, args):
442 bdb8c997 Guido Trotter
  """Remove a component from a remote_raid1 disk.
443 a8083063 Iustin Pop
444 a8083063 Iustin Pop
  Args:
445 a8083063 Iustin Pop
    opts - class with options as members
446 a8083063 Iustin Pop
    args - list with a single element, the instance name
447 a8083063 Iustin Pop
448 a8083063 Iustin Pop
  """
449 a8083063 Iustin Pop
  op = opcodes.OpRemoveMDDRBDComponent(instance_name=args[0],
450 a8083063 Iustin Pop
                                       disk_name=opts.disk,
451 a8083063 Iustin Pop
                                       disk_id=opts.port)
452 a8083063 Iustin Pop
  SubmitOpCode(op)
453 a8083063 Iustin Pop
  return 0
454 a8083063 Iustin Pop
455 a8083063 Iustin Pop
456 a8083063 Iustin Pop
def ReplaceDisks(opts, args):
457 a8083063 Iustin Pop
  """Replace the disks of an instance
458 a8083063 Iustin Pop
459 a8083063 Iustin Pop
  Args:
460 a8083063 Iustin Pop
    opts - class with options as members
461 a8083063 Iustin Pop
    args - list with a single element, the instance name
462 a8083063 Iustin Pop
463 a8083063 Iustin Pop
  """
464 a8083063 Iustin Pop
  instance_name = args[0]
465 a9e0c397 Iustin Pop
  new_2ndary = opts.new_secondary
466 a9e0c397 Iustin Pop
  if opts.disks is None:
467 a9e0c397 Iustin Pop
    disks = ["sda", "sdb"]
468 a9e0c397 Iustin Pop
  else:
469 a9e0c397 Iustin Pop
    disks = opts.disks.split(",")
470 a9e0c397 Iustin Pop
  if opts.on_primary == opts.on_secondary: # no -p or -s passed, or both passed
471 a9e0c397 Iustin Pop
    mode = constants.REPLACE_DISK_ALL
472 a9e0c397 Iustin Pop
  elif opts.on_primary: # only on primary:
473 a9e0c397 Iustin Pop
    mode = constants.REPLACE_DISK_PRI
474 a9e0c397 Iustin Pop
    if new_2ndary is not None:
475 a9e0c397 Iustin Pop
      raise errors.OpPrereqError("Can't change secondary node on primary disk"
476 a9e0c397 Iustin Pop
                                 " replacement")
477 a9e0c397 Iustin Pop
  elif opts.on_secondary is not None: # only on secondary
478 a9e0c397 Iustin Pop
    mode = constants.REPLACE_DISK_SEC
479 a9e0c397 Iustin Pop
480 a9e0c397 Iustin Pop
  op = opcodes.OpReplaceDisks(instance_name=args[0], disks=disks,
481 a9e0c397 Iustin Pop
                              remote_node=new_2ndary, mode=mode)
482 a8083063 Iustin Pop
  SubmitOpCode(op)
483 a8083063 Iustin Pop
  return 0
484 a8083063 Iustin Pop
485 a8083063 Iustin Pop
486 a8083063 Iustin Pop
def FailoverInstance(opts, args):
487 a8083063 Iustin Pop
  """Failover an instance.
488 a8083063 Iustin Pop
489 a8083063 Iustin Pop
  The failover is done by shutting it down on its present node and
490 a8083063 Iustin Pop
  starting it on the secondary.
491 a8083063 Iustin Pop
492 a8083063 Iustin Pop
  Args:
493 a8083063 Iustin Pop
    opts - class with options as members
494 a8083063 Iustin Pop
    args - list with a single element, the instance name
495 a8083063 Iustin Pop
  Opts used:
496 a8083063 Iustin Pop
    force - whether to failover without asking questions.
497 a8083063 Iustin Pop
498 a8083063 Iustin Pop
  """
499 80de0e3f Iustin Pop
  instance_name = args[0]
500 80de0e3f Iustin Pop
  force = opts.force
501 a8083063 Iustin Pop
502 80de0e3f Iustin Pop
  if not force:
503 80de0e3f Iustin Pop
    usertext = ("Failover will happen to image %s."
504 80de0e3f Iustin Pop
                " This requires a shutdown of the instance. Continue?" %
505 80de0e3f Iustin Pop
                (instance_name,))
506 80de0e3f Iustin Pop
    if not AskUser(usertext):
507 80de0e3f Iustin Pop
      return 1
508 a8083063 Iustin Pop
509 80de0e3f Iustin Pop
  op = opcodes.OpFailoverInstance(instance_name=instance_name,
510 80de0e3f Iustin Pop
                                  ignore_consistency=opts.ignore_consistency)
511 80de0e3f Iustin Pop
  SubmitOpCode(op)
512 80de0e3f Iustin Pop
  return 0
513 a8083063 Iustin Pop
514 a8083063 Iustin Pop
515 a8083063 Iustin Pop
def ConnectToInstanceConsole(opts, args):
516 a8083063 Iustin Pop
  """Connect to the console of an instance.
517 a8083063 Iustin Pop
518 a8083063 Iustin Pop
  Args:
519 a8083063 Iustin Pop
    opts - class with options as members
520 a8083063 Iustin Pop
    args - list with a single element, the instance name
521 a8083063 Iustin Pop
522 a8083063 Iustin Pop
  """
523 a8083063 Iustin Pop
  instance_name = args[0]
524 a8083063 Iustin Pop
525 a8083063 Iustin Pop
  op = opcodes.OpConnectConsole(instance_name=instance_name)
526 82122173 Iustin Pop
  cmd, argv = SubmitOpCode(op)
527 a8083063 Iustin Pop
  # drop lock and exec so other commands can run while we have console
528 a8083063 Iustin Pop
  utils.Unlock("cmd")
529 a8083063 Iustin Pop
  try:
530 82122173 Iustin Pop
    os.execvp(cmd, argv)
531 a8083063 Iustin Pop
  finally:
532 82122173 Iustin Pop
    sys.stderr.write("Can't run console command %s with arguments:\n'%s'" %
533 82122173 Iustin Pop
                     (cmd, " ".join(argv)))
534 a8083063 Iustin Pop
    os._exit(1)
535 a8083063 Iustin Pop
536 a8083063 Iustin Pop
537 a8083063 Iustin Pop
def _FormatBlockDevInfo(buf, dev, indent_level):
538 a8083063 Iustin Pop
  """Show block device information.
539 a8083063 Iustin Pop
540 a8083063 Iustin Pop
  This is only used by ShowInstanceConfig(), but it's too big to be
541 a8083063 Iustin Pop
  left for an inline definition.
542 a8083063 Iustin Pop
543 a8083063 Iustin Pop
  """
544 a8083063 Iustin Pop
  def helper(buf, dtype, status):
545 a8083063 Iustin Pop
    """Format one line for phsyical device status."""
546 a8083063 Iustin Pop
    if not status:
547 a8083063 Iustin Pop
      buf.write("not active\n")
548 a8083063 Iustin Pop
    else:
549 0834c866 Iustin Pop
      (path, major, minor, syncp, estt, degr, ldisk) = status
550 a8083063 Iustin Pop
      buf.write("%s (%d:%d)" % (path, major, minor))
551 a1f445d3 Iustin Pop
      if dtype in (constants.LD_MD_R1, constants.LD_DRBD7, constants.LD_DRBD8):
552 a8083063 Iustin Pop
        if syncp is not None:
553 a8083063 Iustin Pop
          sync_text = "*RECOVERING* %5.2f%%," % syncp
554 a8083063 Iustin Pop
          if estt:
555 a8083063 Iustin Pop
            sync_text += " ETA %ds" % estt
556 a8083063 Iustin Pop
          else:
557 a8083063 Iustin Pop
            sync_text += " ETA unknown"
558 a8083063 Iustin Pop
        else:
559 a8083063 Iustin Pop
          sync_text = "in sync"
560 a8083063 Iustin Pop
        if degr:
561 a8083063 Iustin Pop
          degr_text = "*DEGRADED*"
562 a8083063 Iustin Pop
        else:
563 a8083063 Iustin Pop
          degr_text = "ok"
564 0834c866 Iustin Pop
        if ldisk:
565 0834c866 Iustin Pop
          ldisk_text = " *MISSING DISK*"
566 0834c866 Iustin Pop
        else:
567 0834c866 Iustin Pop
          ldisk_text = ""
568 0834c866 Iustin Pop
        buf.write(" %s, status %s%s" % (sync_text, degr_text, ldisk_text))
569 9db6dbce Iustin Pop
      elif dtype == constants.LD_LV:
570 0834c866 Iustin Pop
        if ldisk:
571 0834c866 Iustin Pop
          ldisk_text = " *FAILED* (failed drive?)"
572 9db6dbce Iustin Pop
        else:
573 0834c866 Iustin Pop
          ldisk_text = ""
574 0834c866 Iustin Pop
        buf.write(ldisk_text)
575 a8083063 Iustin Pop
      buf.write("\n")
576 a8083063 Iustin Pop
577 a8083063 Iustin Pop
  if dev["iv_name"] is not None:
578 a8083063 Iustin Pop
    data = "  - %s, " % dev["iv_name"]
579 a8083063 Iustin Pop
  else:
580 a8083063 Iustin Pop
    data = "  - "
581 a8083063 Iustin Pop
  data += "type: %s" % dev["dev_type"]
582 a8083063 Iustin Pop
  if dev["logical_id"] is not None:
583 a8083063 Iustin Pop
    data += ", logical_id: %s" % (dev["logical_id"],)
584 a8083063 Iustin Pop
  elif dev["physical_id"] is not None:
585 a8083063 Iustin Pop
    data += ", physical_id: %s" % (dev["physical_id"],)
586 a8083063 Iustin Pop
  buf.write("%*s%s\n" % (2*indent_level, "", data))
587 a8083063 Iustin Pop
  buf.write("%*s    primary:   " % (2*indent_level, ""))
588 a8083063 Iustin Pop
  helper(buf, dev["dev_type"], dev["pstatus"])
589 a8083063 Iustin Pop
590 a8083063 Iustin Pop
  if dev["sstatus"]:
591 a8083063 Iustin Pop
    buf.write("%*s    secondary: " % (2*indent_level, ""))
592 a8083063 Iustin Pop
    helper(buf, dev["dev_type"], dev["sstatus"])
593 a8083063 Iustin Pop
594 a8083063 Iustin Pop
  if dev["children"]:
595 a8083063 Iustin Pop
    for child in dev["children"]:
596 a8083063 Iustin Pop
      _FormatBlockDevInfo(buf, child, indent_level+1)
597 a8083063 Iustin Pop
598 a8083063 Iustin Pop
599 a8083063 Iustin Pop
def ShowInstanceConfig(opts, args):
600 a8083063 Iustin Pop
  """Compute instance run-time status.
601 a8083063 Iustin Pop
602 a8083063 Iustin Pop
  """
603 a8083063 Iustin Pop
  retcode = 0
604 a8083063 Iustin Pop
  op = opcodes.OpQueryInstanceData(instances=args)
605 a8083063 Iustin Pop
  result = SubmitOpCode(op)
606 a8083063 Iustin Pop
607 a8083063 Iustin Pop
  if not result:
608 a8083063 Iustin Pop
    logger.ToStdout("No instances.")
609 a8083063 Iustin Pop
    return 1
610 a8083063 Iustin Pop
611 a8083063 Iustin Pop
  buf = StringIO()
612 a8083063 Iustin Pop
  retcode = 0
613 a8083063 Iustin Pop
  for instance_name in result:
614 a8083063 Iustin Pop
    instance = result[instance_name]
615 a8083063 Iustin Pop
    buf.write("Instance name: %s\n" % instance["name"])
616 a8083063 Iustin Pop
    buf.write("State: configured to be %s, actual state is %s\n" %
617 a8083063 Iustin Pop
              (instance["config_state"], instance["run_state"]))
618 a8083063 Iustin Pop
    buf.write("  Nodes:\n")
619 a8083063 Iustin Pop
    buf.write("    - primary: %s\n" % instance["pnode"])
620 a8083063 Iustin Pop
    buf.write("    - secondaries: %s\n" % ", ".join(instance["snodes"]))
621 a8083063 Iustin Pop
    buf.write("  Operating system: %s\n" % instance["os"])
622 58acb49d Alexander Schreiber
    buf.write("  Allocated network port: %s\n" % instance["network_port"])
623 a8083063 Iustin Pop
    buf.write("  Hardware:\n")
624 f55ff7ec Iustin Pop
    buf.write("    - VCPUs: %d\n" % instance["vcpus"])
625 a8083063 Iustin Pop
    buf.write("    - memory: %dMiB\n" % instance["memory"])
626 a8083063 Iustin Pop
    buf.write("    - NICs: %s\n" %
627 a8083063 Iustin Pop
        ", ".join(["{MAC: %s, IP: %s, bridge: %s}" %
628 a8083063 Iustin Pop
                   (mac, ip, bridge)
629 a8083063 Iustin Pop
                     for mac, ip, bridge in instance["nics"]]))
630 a8083063 Iustin Pop
    buf.write("  Block devices:\n")
631 a8083063 Iustin Pop
632 a8083063 Iustin Pop
    for device in instance["disks"]:
633 a8083063 Iustin Pop
      _FormatBlockDevInfo(buf, device, 1)
634 a8083063 Iustin Pop
635 a8083063 Iustin Pop
  logger.ToStdout(buf.getvalue().rstrip('\n'))
636 a8083063 Iustin Pop
  return retcode
637 a8083063 Iustin Pop
638 a8083063 Iustin Pop
639 a8083063 Iustin Pop
def SetInstanceParms(opts, args):
640 a8083063 Iustin Pop
  """Modifies an instance.
641 a8083063 Iustin Pop
642 a8083063 Iustin Pop
  All parameters take effect only at the next restart of the instance.
643 a8083063 Iustin Pop
644 a8083063 Iustin Pop
  Args:
645 a8083063 Iustin Pop
    opts - class with options as members
646 a8083063 Iustin Pop
    args - list with a single element, the instance name
647 a8083063 Iustin Pop
  Opts used:
648 a8083063 Iustin Pop
    memory - the new memory size
649 a8083063 Iustin Pop
    vcpus - the new number of cpus
650 1862d460 Alexander Schreiber
    mac - the new MAC address of the instance
651 a8083063 Iustin Pop
652 a8083063 Iustin Pop
  """
653 973d7867 Iustin Pop
  if not (opts.mem or opts.vcpus or opts.ip or opts.bridge or opts.mac or
654 973d7867 Iustin Pop
          opts.kernel_path or opts.initrd_path):
655 a8083063 Iustin Pop
    logger.ToStdout("Please give at least one of the parameters.")
656 a8083063 Iustin Pop
    return 1
657 a8083063 Iustin Pop
658 973d7867 Iustin Pop
  kernel_path = _TransformPath(opts.kernel_path)
659 973d7867 Iustin Pop
  initrd_path = _TransformPath(opts.initrd_path)
660 973d7867 Iustin Pop
661 a8083063 Iustin Pop
  op = opcodes.OpSetInstanceParms(instance_name=args[0], mem=opts.mem,
662 a8083063 Iustin Pop
                                  vcpus=opts.vcpus, ip=opts.ip,
663 973d7867 Iustin Pop
                                  bridge=opts.bridge, mac=opts.mac,
664 973d7867 Iustin Pop
                                  kernel_path=opts.kernel_path,
665 973d7867 Iustin Pop
                                  initrd_path=opts.initrd_path)
666 a8083063 Iustin Pop
  result = SubmitOpCode(op)
667 a8083063 Iustin Pop
668 a8083063 Iustin Pop
  if result:
669 a8083063 Iustin Pop
    logger.ToStdout("Modified instance %s" % args[0])
670 a8083063 Iustin Pop
    for param, data in result:
671 a8083063 Iustin Pop
      logger.ToStdout(" - %-5s -> %s" % (param, data))
672 a8083063 Iustin Pop
    logger.ToStdout("Please don't forget that these parameters take effect"
673 a8083063 Iustin Pop
                    " only at the next start of the instance.")
674 a8083063 Iustin Pop
  return 0
675 a8083063 Iustin Pop
676 a8083063 Iustin Pop
677 a8083063 Iustin Pop
# options used in more than one cmd
678 a8083063 Iustin Pop
node_opt = make_option("-n", "--node", dest="node", help="Target node",
679 a8083063 Iustin Pop
                       metavar="<node>")
680 a8083063 Iustin Pop
681 d0834de3 Michael Hanselmann
os_opt = cli_option("-o", "--os-type", dest="os", help="What OS to run",
682 739ecd56 Michael Hanselmann
                    metavar="<os>")
683 d0834de3 Michael Hanselmann
684 312ac745 Iustin Pop
# multi-instance selection options
685 804a1e8e Iustin Pop
m_force_multi = make_option("--force-multiple", dest="force_multi",
686 804a1e8e Iustin Pop
                            help="Do not ask for confirmation when more than"
687 804a1e8e Iustin Pop
                            " one instance is affected",
688 804a1e8e Iustin Pop
                            action="store_true", default=False)
689 804a1e8e Iustin Pop
690 312ac745 Iustin Pop
m_pri_node_opt = make_option("--primary", dest="multi_mode",
691 312ac745 Iustin Pop
                             help="Filter by nodes (primary only)",
692 312ac745 Iustin Pop
                             const=_SHUTDOWN_NODES_PRI, action="store_const")
693 312ac745 Iustin Pop
694 312ac745 Iustin Pop
m_sec_node_opt = make_option("--secondary", dest="multi_mode",
695 312ac745 Iustin Pop
                             help="Filter by nodes (secondary only)",
696 312ac745 Iustin Pop
                             const=_SHUTDOWN_NODES_SEC, action="store_const")
697 312ac745 Iustin Pop
698 312ac745 Iustin Pop
m_node_opt = make_option("--node", dest="multi_mode",
699 312ac745 Iustin Pop
                         help="Filter by nodes (primary and secondary)",
700 312ac745 Iustin Pop
                         const=_SHUTDOWN_NODES_BOTH, action="store_const")
701 312ac745 Iustin Pop
702 312ac745 Iustin Pop
m_clust_opt = make_option("--all", dest="multi_mode",
703 312ac745 Iustin Pop
                          help="Select all instances in the cluster",
704 312ac745 Iustin Pop
                          const=_SHUTDOWN_CLUSTER, action="store_const")
705 312ac745 Iustin Pop
706 312ac745 Iustin Pop
m_inst_opt = make_option("--instance", dest="multi_mode",
707 312ac745 Iustin Pop
                         help="Filter by instance name [default]",
708 312ac745 Iustin Pop
                         const=_SHUTDOWN_INSTANCES, action="store_const")
709 312ac745 Iustin Pop
710 312ac745 Iustin Pop
711 a8083063 Iustin Pop
# this is defined separately due to readability only
712 a8083063 Iustin Pop
add_opts = [
713 a8083063 Iustin Pop
  DEBUG_OPT,
714 60d49723 Michael Hanselmann
  make_option("-n", "--node", dest="node",
715 60d49723 Michael Hanselmann
              help="Target node and optional secondary node",
716 60d49723 Michael Hanselmann
              metavar="<pnode>[:<snode>]"),
717 b9ac33e9 Iustin Pop
  cli_option("-s", "--os-size", dest="size", help="Disk size, in MiB unless"
718 b9ac33e9 Iustin Pop
             " a suffix is used",
719 a8083063 Iustin Pop
             default=20 * 1024, type="unit", metavar="<size>"),
720 b9ac33e9 Iustin Pop
  cli_option("--swap-size", dest="swap", help="Swap size, in MiB unless a"
721 b9ac33e9 Iustin Pop
             " suffix is used",
722 a8083063 Iustin Pop
             default=4 * 1024, type="unit", metavar="<size>"),
723 d0834de3 Michael Hanselmann
  os_opt,
724 b9ac33e9 Iustin Pop
  cli_option("-m", "--memory", dest="mem", help="Memory size (in MiB)",
725 a8083063 Iustin Pop
              default=128, type="unit", metavar="<mem>"),
726 a8083063 Iustin Pop
  make_option("-p", "--cpu", dest="vcpus", help="Number of virtual CPUs",
727 a8083063 Iustin Pop
              default=1, type="int", metavar="<PROC>"),
728 a8083063 Iustin Pop
  make_option("-t", "--disk-template", dest="disk_template",
729 a1f445d3 Iustin Pop
              help="Custom disk setup (diskless, plain, local_raid1,"
730 a1f445d3 Iustin Pop
              " remote_raid1 or drbd)", default=None, metavar="TEMPL"),
731 a8083063 Iustin Pop
  make_option("-i", "--ip", dest="ip",
732 a8083063 Iustin Pop
              help="IP address ('none' [default], 'auto', or specify address)",
733 a8083063 Iustin Pop
              default='none', type="string", metavar="<ADDRESS>"),
734 1862d460 Alexander Schreiber
  make_option("--mac", dest="mac",
735 1862d460 Alexander Schreiber
              help="MAC address ('auto' [default], or specify address)",
736 1862d460 Alexander Schreiber
              default='auto', type="string", metavar="<MACADDRESS>"),
737 a8083063 Iustin Pop
  make_option("--no-wait-for-sync", dest="wait_for_sync", default=True,
738 a8083063 Iustin Pop
              action="store_false", help="Don't wait for sync (DANGEROUS!)"),
739 a8083063 Iustin Pop
  make_option("-b", "--bridge", dest="bridge",
740 a8083063 Iustin Pop
              help="Bridge to connect this instance to",
741 bdd55f71 Iustin Pop
              default=None, metavar="<bridge>"),
742 bdd55f71 Iustin Pop
  make_option("--no-start", dest="start", default=True,
743 bdd55f71 Iustin Pop
              action="store_false", help="Don't start the instance after"
744 bdd55f71 Iustin Pop
              " creation"),
745 bdd55f71 Iustin Pop
  make_option("--no-ip-check", dest="ip_check", default=True,
746 bdd55f71 Iustin Pop
              action="store_false", help="Don't check that the instance's IP"
747 bdd55f71 Iustin Pop
              " is alive (only valid with --no-start)"),
748 a8083063 Iustin Pop
  ]
749 a8083063 Iustin Pop
750 a8083063 Iustin Pop
commands = {
751 a8083063 Iustin Pop
  'add': (AddInstance, ARGS_ONE, add_opts,
752 a8083063 Iustin Pop
          "[opts...] <name>",
753 a8083063 Iustin Pop
          "Creates and adds a new instance to the cluster"),
754 a8083063 Iustin Pop
  'add-mirror': (AddMDDRBDComponent, ARGS_ONE,
755 a8083063 Iustin Pop
                [DEBUG_OPT, node_opt,
756 a8083063 Iustin Pop
                 make_option("-b", "--disk", dest="disk", metavar="sdX",
757 a8083063 Iustin Pop
                             help=("The name of the instance disk for which to"
758 a8083063 Iustin Pop
                                   " add the mirror"))],
759 a8083063 Iustin Pop
                "-n node -b disk <instance>",
760 a8083063 Iustin Pop
                "Creates a new mirror for the instance"),
761 a8083063 Iustin Pop
  'console': (ConnectToInstanceConsole, ARGS_ONE, [DEBUG_OPT],
762 a8083063 Iustin Pop
              "<instance>",
763 a8083063 Iustin Pop
              "Opens a console on the specified instance"),
764 80de0e3f Iustin Pop
  'failover': (FailoverInstance, ARGS_ONE,
765 fe7b0351 Michael Hanselmann
               [DEBUG_OPT, FORCE_OPT,
766 a8083063 Iustin Pop
                make_option("--ignore-consistency", dest="ignore_consistency",
767 a8083063 Iustin Pop
                            action="store_true", default=False,
768 a8083063 Iustin Pop
                            help="Ignore the consistency of the disks on"
769 a8083063 Iustin Pop
                            " the secondary"),
770 a8083063 Iustin Pop
                ],
771 a8083063 Iustin Pop
               "[-f] <instance>",
772 a8083063 Iustin Pop
               "Stops the instance and starts it on the backup node, using"
773 a8083063 Iustin Pop
               " the remote mirror (only for instances of type remote_raid1)"),
774 a8083063 Iustin Pop
  'info': (ShowInstanceConfig, ARGS_ANY, [DEBUG_OPT], "[<instance>...]",
775 a8083063 Iustin Pop
           "Show information on the specified instance"),
776 a8083063 Iustin Pop
  'list': (ListInstances, ARGS_NONE,
777 dcb93971 Michael Hanselmann
           [DEBUG_OPT, NOHDR_OPT, SEP_OPT, USEUNITS_OPT, FIELDS_OPT],
778 a8083063 Iustin Pop
           "", "Lists the instances and their status"),
779 d0834de3 Michael Hanselmann
  'reinstall': (ReinstallInstance, ARGS_ONE, [DEBUG_OPT, FORCE_OPT, os_opt],
780 fe7b0351 Michael Hanselmann
                "[-f] <instance>", "Reinstall the instance"),
781 1d67656e Iustin Pop
  'remove': (RemoveInstance, ARGS_ONE,
782 1d67656e Iustin Pop
             [DEBUG_OPT, FORCE_OPT,
783 1d67656e Iustin Pop
              make_option("--ignore-failures", dest="ignore_failures",
784 1d67656e Iustin Pop
                          action="store_true", default=False,
785 1d67656e Iustin Pop
                          help=("Remove the instance from the cluster even"
786 1d67656e Iustin Pop
                                " if there are failures during the removal"
787 1d67656e Iustin Pop
                                " process (shutdown, disk removal, etc.)")),
788 1d67656e Iustin Pop
              ],
789 a8083063 Iustin Pop
             "[-f] <instance>", "Shuts down the instance and removes it"),
790 a8083063 Iustin Pop
  'remove-mirror': (RemoveMDDRBDComponent, ARGS_ONE,
791 a8083063 Iustin Pop
                   [DEBUG_OPT, node_opt,
792 a8083063 Iustin Pop
                    make_option("-b", "--disk", dest="disk", metavar="sdX",
793 a8083063 Iustin Pop
                                help=("The name of the instance disk"
794 a8083063 Iustin Pop
                                      " for which to add the mirror")),
795 a8083063 Iustin Pop
                    make_option("-p", "--port", dest="port", metavar="PORT",
796 a8083063 Iustin Pop
                                help=("The port of the drbd device"
797 a8083063 Iustin Pop
                                      " which to remove from the mirror"),
798 a8083063 Iustin Pop
                                type="int"),
799 a8083063 Iustin Pop
                    ],
800 a8083063 Iustin Pop
                   "-b disk -p port <instance>",
801 a8083063 Iustin Pop
                   "Removes a mirror from the instance"),
802 decd5f45 Iustin Pop
  'rename': (RenameInstance, ARGS_FIXED(2),
803 decd5f45 Iustin Pop
             [DEBUG_OPT,
804 decd5f45 Iustin Pop
              make_option("--no-ip-check", dest="ignore_ip",
805 decd5f45 Iustin Pop
                          help="Do not check that the IP of the new name"
806 decd5f45 Iustin Pop
                          " is alive",
807 decd5f45 Iustin Pop
                          default=False, action="store_true"),
808 decd5f45 Iustin Pop
              ],
809 decd5f45 Iustin Pop
             "<instance> <new_name>", "Rename the instance"),
810 a8083063 Iustin Pop
  'replace-disks': (ReplaceDisks, ARGS_ONE,
811 a8083063 Iustin Pop
                    [DEBUG_OPT,
812 a8083063 Iustin Pop
                     make_option("-n", "--new-secondary", dest="new_secondary",
813 a9e0c397 Iustin Pop
                                 help=("New secondary node (for secondary"
814 a9e0c397 Iustin Pop
                                       " node change)"), metavar="NODE"),
815 a9e0c397 Iustin Pop
                     make_option("-p", "--on-primary", dest="on_primary",
816 a9e0c397 Iustin Pop
                                 default=False, action="store_true",
817 a9e0c397 Iustin Pop
                                 help=("Replace the disk(s) on the primary"
818 12c3449a Michael Hanselmann
                                       " node (only for the drbd template)")),
819 a9e0c397 Iustin Pop
                     make_option("-s", "--on-secondary", dest="on_secondary",
820 a9e0c397 Iustin Pop
                                 default=False, action="store_true",
821 a9e0c397 Iustin Pop
                                 help=("Replace the disk(s) on the secondary"
822 12c3449a Michael Hanselmann
                                       " node (only for the drbd template)")),
823 a9e0c397 Iustin Pop
                     make_option("--disks", dest="disks", default=None,
824 a9e0c397 Iustin Pop
                                 help=("Comma-separated list of disks"
825 a9e0c397 Iustin Pop
                                       " to replace (e.g. sda) (optional,"
826 a9e0c397 Iustin Pop
                                       " defaults to all disks")),
827 a9e0c397 Iustin Pop
                     ],
828 a8083063 Iustin Pop
                    "[-n NODE] <instance>",
829 a8083063 Iustin Pop
                    "Replaces all disks for the instance"),
830 a8083063 Iustin Pop
  'modify': (SetInstanceParms, ARGS_ONE,
831 fe7b0351 Michael Hanselmann
             [DEBUG_OPT, FORCE_OPT,
832 a8083063 Iustin Pop
              cli_option("-m", "--memory", dest="mem",
833 a8083063 Iustin Pop
                         help="Memory size",
834 a8083063 Iustin Pop
                         default=None, type="unit", metavar="<mem>"),
835 a8083063 Iustin Pop
              make_option("-p", "--cpu", dest="vcpus",
836 a8083063 Iustin Pop
                          help="Number of virtual CPUs",
837 a8083063 Iustin Pop
                          default=None, type="int", metavar="<PROC>"),
838 a8083063 Iustin Pop
              make_option("-i", "--ip", dest="ip",
839 a8083063 Iustin Pop
                          help="IP address ('none' or numeric IP)",
840 a8083063 Iustin Pop
                          default=None, type="string", metavar="<ADDRESS>"),
841 a8083063 Iustin Pop
              make_option("-b", "--bridge", dest="bridge",
842 a8083063 Iustin Pop
                          help="Bridge to connect this instance to",
843 decd5f45 Iustin Pop
                          default=None, type="string", metavar="<bridge>"),
844 1862d460 Alexander Schreiber
              make_option("--mac", dest="mac",
845 1862d460 Alexander Schreiber
                          help="MAC address", default=None,
846 1862d460 Alexander Schreiber
                          type="string", metavar="<MACADDRESS>"),
847 973d7867 Iustin Pop
              make_option("--kernel", dest="kernel_path",
848 973d7867 Iustin Pop
                          help="Path to the instances' kernel (or"
849 973d7867 Iustin Pop
                          " 'default')", default=None,
850 973d7867 Iustin Pop
                          type="string", metavar="<FILENAME>"),
851 973d7867 Iustin Pop
              make_option("--initrd", dest="initrd_path",
852 973d7867 Iustin Pop
                          help="Path to the instances' initrd (or 'none', or"
853 973d7867 Iustin Pop
                          " 'default')", default=None,
854 973d7867 Iustin Pop
                          type="string", metavar="<FILENAME>"),
855 a8083063 Iustin Pop
              ],
856 a8083063 Iustin Pop
             "<instance>", "Alters the parameters of an instance"),
857 312ac745 Iustin Pop
  'shutdown': (ShutdownInstance, ARGS_ANY,
858 312ac745 Iustin Pop
               [DEBUG_OPT, m_node_opt, m_pri_node_opt, m_sec_node_opt,
859 804a1e8e Iustin Pop
                m_clust_opt, m_inst_opt, m_force_multi],
860 a8083063 Iustin Pop
               "<instance>", "Stops an instance"),
861 312ac745 Iustin Pop
  'startup': (StartupInstance, ARGS_ANY,
862 804a1e8e Iustin Pop
              [DEBUG_OPT, FORCE_OPT, m_force_multi,
863 a8083063 Iustin Pop
               make_option("-e", "--extra", dest="extra_args",
864 a8083063 Iustin Pop
                           help="Extra arguments for the instance's kernel",
865 a8083063 Iustin Pop
                           default=None, type="string", metavar="<PARAMS>"),
866 312ac745 Iustin Pop
               m_node_opt, m_pri_node_opt, m_sec_node_opt,
867 312ac745 Iustin Pop
               m_clust_opt, m_inst_opt,
868 a8083063 Iustin Pop
               ],
869 a8083063 Iustin Pop
            "<instance>", "Starts an instance"),
870 579d4337 Alexander Schreiber
871 579d4337 Alexander Schreiber
  'reboot': (RebootInstance, ARGS_ANY,
872 579d4337 Alexander Schreiber
              [DEBUG_OPT, m_force_multi,
873 579d4337 Alexander Schreiber
               make_option("-e", "--extra", dest="extra_args",
874 579d4337 Alexander Schreiber
                           help="Extra arguments for the instance's kernel",
875 579d4337 Alexander Schreiber
                           default=None, type="string", metavar="<PARAMS>"),
876 579d4337 Alexander Schreiber
               make_option("-t", "--type", dest="reboot_type",
877 579d4337 Alexander Schreiber
                           help="Type of reboot: soft/hard/full",
878 579d4337 Alexander Schreiber
                           default=constants.INSTANCE_REBOOT_SOFT,
879 579d4337 Alexander Schreiber
                           type="string", metavar="<REBOOT>"),
880 579d4337 Alexander Schreiber
               make_option("--ignore-secondaries", dest="ignore_secondaries",
881 579d4337 Alexander Schreiber
                           default=False, action="store_true",
882 579d4337 Alexander Schreiber
                           help="Ignore errors from secondaries"),
883 579d4337 Alexander Schreiber
               m_node_opt, m_pri_node_opt, m_sec_node_opt,
884 579d4337 Alexander Schreiber
               m_clust_opt, m_inst_opt,
885 579d4337 Alexander Schreiber
               ],
886 579d4337 Alexander Schreiber
            "<instance>", "Reboots an instance"),
887 a8083063 Iustin Pop
  'activate-disks': (ActivateDisks, ARGS_ONE, [DEBUG_OPT],
888 a8083063 Iustin Pop
                     "<instance>",
889 a8083063 Iustin Pop
                     "Activate an instance's disks"),
890 a8083063 Iustin Pop
  'deactivate-disks': (DeactivateDisks, ARGS_ONE, [DEBUG_OPT],
891 a8083063 Iustin Pop
                       "<instance>",
892 a8083063 Iustin Pop
                       "Deactivate an instance's disks"),
893 846baef9 Iustin Pop
  'list-tags': (ListTags, ARGS_ONE, [DEBUG_OPT],
894 846baef9 Iustin Pop
                "<node_name>", "List the tags of the given instance"),
895 810c50b7 Iustin Pop
  'add-tags': (AddTags, ARGS_ATLEAST(1), [DEBUG_OPT, TAG_SRC_OPT],
896 846baef9 Iustin Pop
               "<node_name> tag...", "Add tags to the given instance"),
897 810c50b7 Iustin Pop
  'remove-tags': (RemoveTags, ARGS_ATLEAST(1), [DEBUG_OPT, TAG_SRC_OPT],
898 846baef9 Iustin Pop
                  "<node_name> tag...", "Remove tags from given instance"),
899 a8083063 Iustin Pop
  }
900 a8083063 Iustin Pop
901 a8083063 Iustin Pop
if __name__ == '__main__':
902 846baef9 Iustin Pop
  sys.exit(GenericMain(commands,
903 846baef9 Iustin Pop
                       override={"tag_type": constants.TAG_INSTANCE}))