virsh.c 78.2 KB
Newer Older
1
/*
2
 * virsh.c: a shell to exercise the libvirt API
3
 *
4
 * Copyright (C) 2005, 2007-2012 Red Hat, Inc.
5
 *
O
Osier Yang 已提交
6 7 8 9 10 11 12 13 14 15 16
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
17
 * License along with this library.  If not, see
O
Osier Yang 已提交
18
 * <http://www.gnu.org/licenses/>.
19 20
 *
 * Daniel Veillard <veillard@redhat.com>
K
Karel Zak 已提交
21
 * Karel Zak <kzak@redhat.com>
K
Karel Zak 已提交
22
 * Daniel P. Berrange <berrange@redhat.com>
23 24
 */

25
#include <config.h>
E
Eric Blake 已提交
26
#include "virsh.h"
27

28
#include <stdio.h>
K
Karel Zak 已提交
29 30 31
#include <stdlib.h>
#include <string.h>
#include <stdarg.h>
32
#include <unistd.h>
33
#include <errno.h>
K
Karel Zak 已提交
34
#include <getopt.h>
K
Karel Zak 已提交
35
#include <sys/time.h>
J
Jim Meyering 已提交
36
#include "c-ctype.h"
37
#include <fcntl.h>
38
#include <locale.h>
39
#include <time.h>
40
#include <limits.h>
41
#include <assert.h>
42
#include <sys/stat.h>
43
#include <inttypes.h>
E
Eric Blake 已提交
44
#include <strings.h>
K
Karel Zak 已提交
45

46 47 48
#include <libxml/parser.h>
#include <libxml/tree.h>
#include <libxml/xpath.h>
49
#include <libxml/xmlsave.h>
50

51
#ifdef HAVE_READLINE_READLINE_H
52 53
# include <readline/readline.h>
# include <readline/history.h>
54
#endif
K
Karel Zak 已提交
55

56
#include "internal.h"
57
#include "virerror.h"
58
#include "base64.h"
59
#include "virbuffer.h"
60
#include "console.h"
61
#include "virutil.h"
62
#include "viralloc.h"
63
#include "virxml.h"
64
#include "libvirt/libvirt-qemu.h"
65
#include "libvirt/libvirt-lxc.h"
E
Eric Blake 已提交
66
#include "virfile.h"
67
#include "configmake.h"
68
#include "virthread.h"
69
#include "vircommand.h"
70
#include "virkeycode.h"
71
#include "virnetdevbandwidth.h"
72
#include "virbitmap.h"
H
Hu Tao 已提交
73
#include "conf/domain_conf.h"
74
#include "virtypedparam.h"
K
Karel Zak 已提交
75

E
Eric Blake 已提交
76
#include "virsh-domain.h"
77
#include "virsh-domain-monitor.h"
E
Eric Blake 已提交
78
#include "virsh-host.h"
E
Eric Blake 已提交
79
#include "virsh-interface.h"
E
Eric Blake 已提交
80
#include "virsh-network.h"
E
Eric Blake 已提交
81
#include "virsh-nodedev.h"
E
Eric Blake 已提交
82
#include "virsh-nwfilter.h"
E
Eric Blake 已提交
83
#include "virsh-pool.h"
E
Eric Blake 已提交
84
#include "virsh-secret.h"
E
Eric Blake 已提交
85
#include "virsh-snapshot.h"
E
Eric Blake 已提交
86
#include "virsh-volume.h"
E
Eric Blake 已提交
87

K
Karel Zak 已提交
88 89
static char *progname;

90
static const vshCmdGrp cmdGroups[];
K
Karel Zak 已提交
91

E
Eric Blake 已提交
92 93
/* Bypass header poison */
#undef strdup
94

E
Eric Blake 已提交
95
void *
E
Eric Blake 已提交
96 97
_vshMalloc(vshControl *ctl, size_t size, const char *filename, int line)
{
E
Eric Blake 已提交
98
    char *x;
E
Eric Blake 已提交
99

E
Eric Blake 已提交
100
    if (VIR_ALLOC_N(x, size) == 0)
E
Eric Blake 已提交
101 102 103 104 105 106
        return x;
    vshError(ctl, _("%s: %d: failed to allocate %d bytes"),
             filename, line, (int) size);
    exit(EXIT_FAILURE);
}

E
Eric Blake 已提交
107 108 109
void *
_vshCalloc(vshControl *ctl, size_t nmemb, size_t size, const char *filename,
           int line)
E
Eric Blake 已提交
110
{
E
Eric Blake 已提交
111
    char *x;
E
Eric Blake 已提交
112

E
Eric Blake 已提交
113 114
    if (!xalloc_oversized(nmemb, size) &&
        VIR_ALLOC_N(x, nmemb * size) == 0)
E
Eric Blake 已提交
115 116 117 118 119 120
        return x;
    vshError(ctl, _("%s: %d: failed to allocate %d bytes"),
             filename, line, (int) (size*nmemb));
    exit(EXIT_FAILURE);
}

E
Eric Blake 已提交
121
char *
E
Eric Blake 已提交
122 123 124 125 126
_vshStrdup(vshControl *ctl, const char *s, const char *filename, int line)
{
    char *x;

    if (s == NULL)
127
        return NULL;
E
Eric Blake 已提交
128 129 130 131 132 133 134 135 136
    if ((x = strdup(s)))
        return x;
    vshError(ctl, _("%s: %d: failed to allocate %lu bytes"),
             filename, line, (unsigned long)strlen(s));
    exit(EXIT_FAILURE);
}

/* Poison the raw allocating identifiers in favor of our vsh variants.  */
#define strdup use_vshStrdup_instead_of_strdup
137

138
int
139 140 141 142
vshNameSorter(const void *a, const void *b)
{
    const char **sa = (const char**)a;
    const char **sb = (const char**)b;
143

144
    return vshStrcasecmp(*sa, *sb);
145 146
}

E
Eric Blake 已提交
147
double
E
Eric Blake 已提交
148
vshPrettyCapacity(unsigned long long val, const char **unit)
E
Eric Blake 已提交
149
{
150 151 152 153
    if (val < 1024) {
        *unit = "";
        return (double)val;
    } else if (val < (1024.0l * 1024.0l)) {
154
        *unit = "KiB";
155 156
        return (((double)val / 1024.0l));
    } else if (val < (1024.0l * 1024.0l * 1024.0l)) {
157
        *unit = "MiB";
158
        return (double)val / (1024.0l * 1024.0l);
159
    } else if (val < (1024.0l * 1024.0l * 1024.0l * 1024.0l)) {
160
        *unit = "GiB";
161
        return (double)val / (1024.0l * 1024.0l * 1024.0l);
162
    } else {
163
        *unit = "TiB";
164
        return (double)val / (1024.0l * 1024.0l * 1024.0l * 1024.0l);
165 166 167
    }
}

168 169
/*
 * Convert the strings separated by ',' into array. The caller
E
Eric Blake 已提交
170 171 172
 * must free the first array element and the returned array after
 * use (all other array elements belong to the memory allocated
 * for the first array element).
173 174 175 176 177
 *
 * Returns the length of the filled array on success, or -1
 * on error.
 */
int
178
vshStringToArray(const char *str,
179 180
                 char ***array)
{
181
    char *str_copied = vshStrdup(NULL, str);
182
    char *str_tok = NULL;
E
Eric Blake 已提交
183
    char *tmp;
184 185
    unsigned int nstr_tokens = 0;
    char **arr = NULL;
E
Eric Blake 已提交
186
    size_t len = strlen(str_copied);
187

E
Eric Blake 已提交
188 189
    /* tokenize the string from user and save its parts into an array */
    nstr_tokens = 1;
190

E
Eric Blake 已提交
191 192 193 194 195
    /* count the delimiters, recognizing ,, as an escape for a
     * literal comma */
    str_tok = str_copied;
    while ((str_tok = strchr(str_tok, ','))) {
        if (str_tok[1] == ',')
196
            str_tok++;
E
Eric Blake 已提交
197 198 199 200
        else
            nstr_tokens++;
        str_tok++;
    }
201

E
Eric Blake 已提交
202 203 204 205 206
    if (VIR_ALLOC_N(arr, nstr_tokens) < 0) {
        virReportOOMError();
        VIR_FREE(str_copied);
        return -1;
    }
207

E
Eric Blake 已提交
208 209 210 211 212 213 214 215 216 217 218 219 220
    /* tokenize the input string, while treating ,, as a literal comma */
    nstr_tokens = 0;
    tmp = str_tok = str_copied;
    while ((tmp = strchr(tmp, ','))) {
        if (tmp[1] == ',') {
            memmove(&tmp[1], &tmp[2], len - (tmp - str_copied) - 2 + 1);
            len--;
            tmp++;
            continue;
        }
        *tmp++ = '\0';
        arr[nstr_tokens++] = str_tok;
        str_tok = tmp;
221
    }
E
Eric Blake 已提交
222
    arr[nstr_tokens++] = str_tok;
223 224 225 226

    *array = arr;
    return nstr_tokens;
}
227

E
Eric Blake 已提交
228
virErrorPtr last_error;
J
John Levon 已提交
229 230 231 232 233 234 235 236 237 238 239 240 241

/*
 * Quieten libvirt until we're done with the command.
 */
static void
virshErrorHandler(void *unused ATTRIBUTE_UNUSED, virErrorPtr error)
{
    virFreeError(last_error);
    last_error = virSaveLastError();
    if (getenv("VIRSH_DEBUG") != NULL)
        virDefaultErrorFunc(error);
}

242 243 244 245 246 247 248 249 250
/* Store a libvirt error that is from a helper API that doesn't raise errors
 * so it doesn't get overwritten */
void
vshSaveLibvirtError(void)
{
    virFreeError(last_error);
    last_error = virSaveLastError();
}

251 252 253
/*
 * Reset libvirt error on graceful fallback paths
 */
E
Eric Blake 已提交
254
void
255 256 257 258 259 260
vshResetLibvirtError(void)
{
    virFreeError(last_error);
    last_error = NULL;
}

J
John Levon 已提交
261 262 263 264 265 266 267 268
/*
 * Report an error when a command finishes.  This is better than before
 * (when correct operation would report errors), but it has some
 * problems: we lose the smarter formatting of virDefaultErrorFunc(),
 * and it can become harder to debug problems, if errors get reported
 * twice during one command.  This case shouldn't really happen anyway,
 * and it's IMHO a bug that libvirt does that sometimes.
 */
E
Eric Blake 已提交
269
void
E
Eric Blake 已提交
270
vshReportError(vshControl *ctl)
J
John Levon 已提交
271
{
272 273 274 275 276 277 278 279
    if (last_error == NULL) {
        /* Calling directly into libvirt util functions won't trigger the
         * error callback (which sets last_error), so check it ourselves.
         *
         * If the returned error has CODE_OK, this most likely means that
         * no error was ever raised, so just ignore */
        last_error = virSaveLastError();
        if (!last_error || last_error->code == VIR_ERR_OK)
280
            goto out;
281
    }
J
John Levon 已提交
282 283

    if (last_error->code == VIR_ERR_OK) {
284
        vshError(ctl, "%s", _("unknown error"));
J
John Levon 已提交
285 286 287
        goto out;
    }

288
    vshError(ctl, "%s", last_error->message);
J
John Levon 已提交
289 290

out:
291
    vshResetLibvirtError();
J
John Levon 已提交
292 293
}

294 295 296 297 298 299 300 301
/*
 * Detection of disconnections and automatic reconnection support
 */
static int disconnected = 0; /* we may have been disconnected */

/*
 * vshCatchDisconnect:
 *
302 303
 * We get here when the connection was closed.  We can't do much in the
 * handler, just save the fact it was raised.
304
 */
L
Laine Stump 已提交
305
static void
306 307 308 309 310 311
vshCatchDisconnect(virConnectPtr conn ATTRIBUTE_UNUSED,
                   int reason,
                   void *opaque ATTRIBUTE_UNUSED)
{
    if (reason != VIR_CONNECT_CLOSE_REASON_CLIENT)
        disconnected++;
312 313 314 315 316
}

/*
 * vshReconnect:
 *
L
Laine Stump 已提交
317
 * Reconnect after a disconnect from libvirtd
318 319
 *
 */
L
Laine Stump 已提交
320
static void
321 322 323 324 325 326
vshReconnect(vshControl *ctl)
{
    bool connected = false;

    if (ctl->conn != NULL) {
        connected = true;
327
        virConnectClose(ctl->conn);
328
    }
329 330 331 332

    ctl->conn = virConnectOpenAuth(ctl->name,
                                   virConnectAuthPtrDefault,
                                   ctl->readonly ? VIR_CONNECT_RO : 0);
333
    if (!ctl->conn) {
334 335 336 337
        if (disconnected)
            vshError(ctl, "%s", _("Failed to reconnect to the hypervisor"));
        else
            vshError(ctl, "%s", _("failed to connect to the hypervisor"));
338 339 340 341 342 343 344
    } else {
        if (virConnectRegisterCloseCallback(ctl->conn, vshCatchDisconnect,
                                            NULL, NULL) < 0)
            vshError(ctl, "%s", _("Unable to register disconnect callback"));
        if (connected)
            vshError(ctl, "%s", _("Reconnected to the hypervisor"));
    }
345
    disconnected = 0;
346
    ctl->useGetInfo = false;
347
    ctl->useSnapshotOld = false;
348
}
349

350
#ifndef WIN32
351 352 353 354 355 356 357 358 359 360 361 362 363
static void
vshPrintRaw(vshControl *ctl, ...)
{
    va_list ap;
    char *key;

    va_start(ap, ctl);
    while ((key = va_arg(ap, char *)) != NULL) {
        vshPrint(ctl, "%s\r\n", key);
    }
    va_end(ap);
}

364 365 366 367 368 369 370 371 372 373 374 375 376
/**
 * vshAskReedit:
 * @msg: Question to ask user
 *
 * Ask user if he wants to return to previously
 * edited file.
 *
 * Returns 'y' if he wants to
 *         'f' if he forcibly wants to
 *         'n' if he doesn't want to
 *         -1  on error
 *          0  otherwise
 */
E
Eric Blake 已提交
377
int
378 379 380 381 382 383 384 385
vshAskReedit(vshControl *ctl, const char *msg)
{
    int c = -1;
    struct termios ttyattr;

    if (!isatty(STDIN_FILENO))
        return -1;

E
Eric Blake 已提交
386
    vshReportError(ctl);
387 388 389 390 391 392 393 394 395 396 397

    if (vshMakeStdinRaw(&ttyattr, false) < 0)
        return -1;

    while (true) {
        /* TRANSLATORS: For now, we aren't using LC_MESSAGES, and the user
         * choices really are limited to just 'y', 'n', 'f' and '?'  */
        vshPrint(ctl, "\r%s %s", msg, _("Try again? [y,n,f,?]:"));
        c = c_tolower(getchar());

        if (c == '?') {
398 399 400 401 402 403 404
            vshPrintRaw(ctl,
                        "",
                        _("y - yes, start editor again"),
                        _("n - no, throw away my changes"),
                        _("f - force, try to redefine again"),
                        _("? - print this help"),
                        NULL);
405 406 407 408 409 410 411 412 413 414
            continue;
        } else if (c == 'y' || c == 'n' || c == 'f') {
            break;
        }
    }

    tcsetattr(STDIN_FILENO, TCSAFLUSH, &ttyattr);

    vshPrint(ctl, "\r\n");
    return c;
415 416
}
#else /* WIN32 */
417
int
418 419
vshAskReedit(vshControl *ctl, const char *msg ATTRIBUTE_UNUSED)
{
420 421 422 423
    vshDebug(ctl, VSH_ERR_WARNING, "%s", _("This function is not "
                                           "supported on WIN32 platform"));
    return 0;
}
424
#endif /* WIN32 */
425

E
Eric Blake 已提交
426 427
int vshStreamSink(virStreamPtr st ATTRIBUTE_UNUSED,
                  const char *bytes, size_t nbytes, void *opaque)
428 429 430 431 432 433
{
    int *fd = opaque;

    return safewrite(*fd, bytes, nbytes);
}

K
Karel Zak 已提交
434 435 436 437 438 439
/* ---------------
 * Commands
 * ---------------
 */

/*
440
 * "help" command
K
Karel Zak 已提交
441
 */
442
static const vshCmdInfo info_help[] = {
443
    {"help", N_("print help")},
444 445
    {"desc", N_("Prints global help, command specific help, or help for a\n"
                "    group of related commands")},
446

447
    {NULL, NULL}
K
Karel Zak 已提交
448 449
};

450
static const vshCmdOptDef opts_help[] = {
451 452 453 454 455 456
    {.name = "command",
     .type = VSH_OT_DATA,
     .flags = 0,
     .help = N_("Prints global help, command specific help, or help for a group of related commands")
    },
    {.name = NULL}
K
Karel Zak 已提交
457 458
};

E
Eric Blake 已提交
459
static bool
460
cmdHelp(vshControl *ctl, const vshCmd *cmd)
461
 {
462
    const char *name = NULL;
463

464
    if (vshCommandOptString(cmd, "command", &name) <= 0) {
465
        const vshCmdGrp *grp;
466
        const vshCmdDef *def;
467

468 469 470 471 472 473
        vshPrint(ctl, "%s", _("Grouped commands:\n\n"));

        for (grp = cmdGroups; grp->name; grp++) {
            vshPrint(ctl, _(" %s (help keyword '%s'):\n"), grp->name,
                     grp->keyword);

474 475 476
            for (def = grp->commands; def->name; def++) {
                if (def->flags & VSH_CMD_FLAG_ALIAS)
                    continue;
477 478
                vshPrint(ctl, "    %-30s %s\n", def->name,
                         _(vshCmddefGetInfo(def, "help")));
479
            }
480 481 482 483

            vshPrint(ctl, "\n");
        }

E
Eric Blake 已提交
484
        return true;
485
    }
486

E
Eric Blake 已提交
487
    if (vshCmddefSearch(name)) {
488
        return vshCmddefHelp(ctl, name);
E
Eric Blake 已提交
489
    } else if (vshCmdGrpSearch(name)) {
490 491 492
        return vshCmdGrpHelp(ctl, name);
    } else {
        vshError(ctl, _("command or command group '%s' doesn't exist"), name);
E
Eric Blake 已提交
493
        return false;
K
Karel Zak 已提交
494 495 496
    }
}

497 498 499 500 501 502 503 504 505 506 507
/* Tree listing helpers.  */

static int
vshTreePrintInternal(vshControl *ctl,
                     vshTreeLookup lookup,
                     void *opaque,
                     int num_devices,
                     int devid,
                     int lastdev,
                     bool root,
                     virBufferPtr indent)
508
{
509 510 511 512
    int i;
    int nextlastdev = -1;
    int ret = -1;
    const char *dev = (lookup)(devid, false, opaque);
513

514
    if (virBufferError(indent))
515 516
        goto cleanup;

517 518 519 520 521 522 523 524 525 526
    /* Print this device, with indent if not at root */
    vshPrint(ctl, "%s%s%s\n", virBufferCurrentContent(indent),
             root ? "" : "+- ", dev);

    /* Update indent to show '|' or ' ' for child devices */
    if (!root) {
        virBufferAddChar(indent, devid == lastdev ? ' ' : '|');
        virBufferAddChar(indent, ' ');
        if (virBufferError(indent))
            goto cleanup;
527 528
    }

529 530 531
    /* Determine the index of the last child device */
    for (i = 0 ; i < num_devices ; i++) {
        const char *parent = (lookup)(i, true, opaque);
532

533 534 535
        if (parent && STREQ(parent, dev))
            nextlastdev = i;
    }
536

537 538 539
    /* If there is a child device, then print another blank line */
    if (nextlastdev != -1)
        vshPrint(ctl, "%s  |\n", virBufferCurrentContent(indent));
540

541 542
    /* Finally print all children */
    virBufferAddLit(indent, "  ");
543 544
    if (virBufferError(indent))
        goto cleanup;
545 546
    for (i = 0 ; i < num_devices ; i++) {
        const char *parent = (lookup)(i, true, opaque);
547

548 549 550 551 552
        if (parent && STREQ(parent, dev) &&
            vshTreePrintInternal(ctl, lookup, opaque,
                                 num_devices, i, nextlastdev,
                                 false, indent) < 0)
            goto cleanup;
553
    }
554 555
    if (virBufferTrim(indent, "  ", -1) < 0)
        goto cleanup;
556

557 558 559 560
    /* If there was no child device, and we're the last in
     * a list of devices, then print another blank line */
    if (nextlastdev == -1 && devid == lastdev)
        vshPrint(ctl, "%s\n", virBufferCurrentContent(indent));
561

562 563 564 565
    if (!root) {
        if (virBufferTrim(indent, NULL, 2) < 0)
            goto cleanup;
    }
566
    ret = 0;
567 568 569 570
cleanup:
    return ret;
}

E
Eric Blake 已提交
571
int
572 573
vshTreePrint(vshControl *ctl, vshTreeLookup lookup, void *opaque,
             int num_devices, int devid)
574
{
575 576
    int ret;
    virBuffer indent = VIR_BUFFER_INITIALIZER;
577

578 579 580 581 582
    ret = vshTreePrintInternal(ctl, lookup, opaque, num_devices,
                               devid, devid, true, &indent);
    if (ret < 0)
        vshError(ctl, "%s", _("Failed to complete tree listing"));
    virBufferFreeAndReset(&indent);
583
    return ret;
584
}
585

586
/* Common code for the edit / net-edit / pool-edit functions which follow. */
E
Eric Blake 已提交
587
char *
E
Eric Blake 已提交
588
vshEditWriteToTempFile(vshControl *ctl, const char *doc)
589 590 591 592
{
    char *ret;
    const char *tmpdir;
    int fd;
593
    char ebuf[1024];
594

595
    tmpdir = getenv("TMPDIR");
596
    if (!tmpdir) tmpdir = "/tmp";
597 598 599 600
    if (virAsprintf(&ret, "%s/virshXXXXXX.xml", tmpdir) < 0) {
        vshError(ctl, "%s", _("out of memory"));
        return NULL;
    }
601
    fd = mkostemps(ret, 4, O_CLOEXEC);
602
    if (fd == -1) {
603
        vshError(ctl, _("mkostemps: failed to create temporary file: %s"),
604
                 virStrerror(errno, ebuf, sizeof(ebuf)));
605
        VIR_FREE(ret);
606 607 608
        return NULL;
    }

609
    if (safewrite(fd, doc, strlen(doc)) == -1) {
610
        vshError(ctl, _("write: %s: failed to write to temporary file: %s"),
611
                 ret, virStrerror(errno, ebuf, sizeof(ebuf)));
S
Stefan Berger 已提交
612
        VIR_FORCE_CLOSE(fd);
613
        unlink(ret);
614
        VIR_FREE(ret);
615 616
        return NULL;
    }
S
Stefan Berger 已提交
617
    if (VIR_CLOSE(fd) < 0) {
618
        vshError(ctl, _("close: %s: failed to write or close temporary file: %s"),
619
                 ret, virStrerror(errno, ebuf, sizeof(ebuf)));
620
        unlink(ret);
621
        VIR_FREE(ret);
622 623 624 625 626 627 628 629 630 631 632
        return NULL;
    }

    /* Temporary filename: caller frees. */
    return ret;
}

/* Characters permitted in $EDITOR environment variable and temp filename. */
#define ACCEPTED_CHARS \
  "abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789-/_.:@"

E
Eric Blake 已提交
633
int
E
Eric Blake 已提交
634
vshEditFile(vshControl *ctl, const char *filename)
635 636
{
    const char *editor;
E
Eric Blake 已提交
637 638 639 640
    virCommandPtr cmd;
    int ret = -1;
    int outfd = STDOUT_FILENO;
    int errfd = STDERR_FILENO;
641

642
    editor = getenv("VISUAL");
E
Eric Blake 已提交
643
    if (!editor)
644
        editor = getenv("EDITOR");
E
Eric Blake 已提交
645 646
    if (!editor)
        editor = "vi"; /* could be cruel & default to ed(1) here */
647

648 649 650 651 652
    /* Check that filename doesn't contain shell meta-characters, and
     * if it does, refuse to run.  Follow the Unix conventions for
     * EDITOR: the user can intentionally specify command options, so
     * we don't protect any shell metacharacters there.  Lots more
     * than virsh will misbehave if EDITOR has bogus contents (which
E
Eric Blake 已提交
653 654
     * is why sudo scrubs it by default).  Conversely, if the editor
     * is safe, we can run it directly rather than wasting a shell.
655
     */
656 657
    if (strspn(editor, ACCEPTED_CHARS) != strlen(editor)) {
        if (strspn(filename, ACCEPTED_CHARS) != strlen(filename)) {
E
Eric Blake 已提交
658 659 660 661 662 663 664 665 666 667
            vshError(ctl,
                     _("%s: temporary filename contains shell meta or other "
                       "unacceptable characters (is $TMPDIR wrong?)"),
                     filename);
            return -1;
        }
        cmd = virCommandNewArgList("sh", "-c", NULL);
        virCommandAddArgFormat(cmd, "%s %s", editor, filename);
    } else {
        cmd = virCommandNewArgList(editor, filename, NULL);
668 669
    }

E
Eric Blake 已提交
670 671 672 673 674
    virCommandSetInputFD(cmd, STDIN_FILENO);
    virCommandSetOutputFD(cmd, &outfd);
    virCommandSetErrorFD(cmd, &errfd);
    if (virCommandRunAsync(cmd, NULL) < 0 ||
        virCommandWait(cmd, NULL) < 0) {
E
Eric Blake 已提交
675
        vshReportError(ctl);
E
Eric Blake 已提交
676
        goto cleanup;
677
    }
E
Eric Blake 已提交
678
    ret = 0;
679

E
Eric Blake 已提交
680 681 682
cleanup:
    virCommandFree(cmd);
    return ret;
683 684
}

E
Eric Blake 已提交
685
char *
E
Eric Blake 已提交
686
vshEditReadBackFile(vshControl *ctl, const char *filename)
687 688
{
    char *ret;
689
    char ebuf[1024];
690

E
Eric Blake 已提交
691
    if (virFileReadAll(filename, VSH_MAX_XML_FILE, &ret) == -1) {
692
        vshError(ctl,
693
                 _("%s: failed to read temporary file: %s"),
694
                 filename, virStrerror(errno, ebuf, sizeof(ebuf)));
695 696 697 698 699
        return NULL;
    }
    return ret;
}

700

P
Paolo Bonzini 已提交
701 702 703 704
/*
 * "cd" command
 */
static const vshCmdInfo info_cd[] = {
705 706
    {"help", N_("change the current directory")},
    {"desc", N_("Change the current directory.")},
P
Paolo Bonzini 已提交
707 708 709 710
    {NULL, NULL}
};

static const vshCmdOptDef opts_cd[] = {
711 712 713 714 715 716
    {.name = "dir",
     .type = VSH_OT_DATA,
     .flags = 0,
     .help = N_("directory to switch to (default: home or else root)")
    },
    {.name = NULL}
P
Paolo Bonzini 已提交
717 718
};

E
Eric Blake 已提交
719
static bool
720
cmdCd(vshControl *ctl, const vshCmd *cmd)
P
Paolo Bonzini 已提交
721
{
722
    const char *dir = NULL;
723
    char *dir_malloced = NULL;
E
Eric Blake 已提交
724
    bool ret = true;
725
    char ebuf[1024];
P
Paolo Bonzini 已提交
726 727

    if (!ctl->imode) {
728
        vshError(ctl, "%s", _("cd: command valid only in interactive mode"));
E
Eric Blake 已提交
729
        return false;
P
Paolo Bonzini 已提交
730 731
    }

732
    if (vshCommandOptString(cmd, "dir", &dir) <= 0) {
733
        dir = dir_malloced = virGetUserDirectory();
P
Paolo Bonzini 已提交
734 735 736 737
    }
    if (!dir)
        dir = "/";

P
Phil Petty 已提交
738
    if (chdir(dir) == -1) {
739 740
        vshError(ctl, _("cd: %s: %s"),
                 virStrerror(errno, ebuf, sizeof(ebuf)), dir);
E
Eric Blake 已提交
741
        ret = false;
P
Paolo Bonzini 已提交
742 743
    }

744
    VIR_FREE(dir_malloced);
P
Phil Petty 已提交
745
    return ret;
P
Paolo Bonzini 已提交
746 747 748 749 750 751
}

/*
 * "pwd" command
 */
static const vshCmdInfo info_pwd[] = {
752 753
    {"help", N_("print the current directory")},
    {"desc", N_("Print the current directory.")},
P
Paolo Bonzini 已提交
754 755 756
    {NULL, NULL}
};

E
Eric Blake 已提交
757
static bool
P
Paolo Bonzini 已提交
758 759 760
cmdPwd(vshControl *ctl, const vshCmd *cmd ATTRIBUTE_UNUSED)
{
    char *cwd;
761
    bool ret = true;
762
    char ebuf[1024];
P
Paolo Bonzini 已提交
763

764 765
    cwd = getcwd(NULL, 0);
    if (!cwd) {
766
        vshError(ctl, _("pwd: cannot get current directory: %s"),
767
                 virStrerror(errno, ebuf, sizeof(ebuf)));
768 769
        ret = false;
    } else {
770
        vshPrint(ctl, _("%s\n"), cwd);
771 772
        VIR_FREE(cwd);
    }
P
Paolo Bonzini 已提交
773

774
    return ret;
P
Paolo Bonzini 已提交
775 776
}

E
Eric Blake 已提交
777 778 779 780 781 782 783 784 785 786
/*
 * "echo" command
 */
static const vshCmdInfo info_echo[] = {
    {"help", N_("echo arguments")},
    {"desc", N_("Echo back arguments, possibly with quoting.")},
    {NULL, NULL}
};

static const vshCmdOptDef opts_echo[] = {
787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807
    {.name = "shell",
     .type = VSH_OT_BOOL,
     .flags = 0,
     .help = N_("escape for shell use")
    },
    {.name = "xml",
     .type = VSH_OT_BOOL,
     .flags = 0,
     .help = N_("escape for XML use")
    },
    {.name = "str",
     .type = VSH_OT_ALIAS,
     .flags = 0,
     .help = "string"
    },
    {.name = "string",
     .type = VSH_OT_ARGV,
     .flags = 0,
     .help = N_("arguments to echo")
    },
    {.name = NULL}
E
Eric Blake 已提交
808 809 810 811 812
};

/* Exists mainly for debugging virsh, but also handy for adding back
 * quotes for later evaluation.
 */
E
Eric Blake 已提交
813
static bool
814
cmdEcho(vshControl *ctl, const vshCmd *cmd)
E
Eric Blake 已提交
815 816 817 818
{
    bool shell = false;
    bool xml = false;
    int count = 0;
819
    const vshCmdOpt *opt = NULL;
E
Eric Blake 已提交
820 821 822 823 824 825 826 827
    char *arg;
    virBuffer buf = VIR_BUFFER_INITIALIZER;

    if (vshCommandOptBool(cmd, "shell"))
        shell = true;
    if (vshCommandOptBool(cmd, "xml"))
        xml = true;

828
    while ((opt = vshCommandOptArgv(cmd, opt))) {
829 830
        char *str;
        virBuffer xmlbuf = VIR_BUFFER_INITIALIZER;
E
Eric Blake 已提交
831

832
        arg = opt->data;
833

E
Eric Blake 已提交
834 835
        if (count)
            virBufferAddChar(&buf, ' ');
836

E
Eric Blake 已提交
837
        if (xml) {
838 839 840 841
            virBufferEscapeString(&xmlbuf, "%s", arg);
            if (virBufferError(&buf)) {
                vshPrint(ctl, "%s", _("Failed to allocate XML buffer"));
                return false;
E
Eric Blake 已提交
842
            }
843 844 845
            str = virBufferContentAndReset(&xmlbuf);
        } else {
            str = vshStrdup(ctl, arg);
E
Eric Blake 已提交
846
        }
847 848 849 850 851

        if (shell)
            virBufferEscapeShell(&buf, str);
        else
            virBufferAdd(&buf, str, -1);
E
Eric Blake 已提交
852
        count++;
853
        VIR_FREE(str);
E
Eric Blake 已提交
854 855 856 857
    }

    if (virBufferError(&buf)) {
        vshPrint(ctl, "%s", _("Failed to allocate XML buffer"));
E
Eric Blake 已提交
858
        return false;
E
Eric Blake 已提交
859 860 861 862 863
    }
    arg = virBufferContentAndReset(&buf);
    if (arg)
        vshPrint(ctl, "%s", arg);
    VIR_FREE(arg);
E
Eric Blake 已提交
864
    return true;
E
Eric Blake 已提交
865 866
}

K
Karel Zak 已提交
867 868 869
/*
 * "quit" command
 */
870
static const vshCmdInfo info_quit[] = {
871
    {"help", N_("quit this interactive terminal")},
872
    {"desc", ""},
873
    {NULL, NULL}
K
Karel Zak 已提交
874 875
};

E
Eric Blake 已提交
876
static bool
877
cmdQuit(vshControl *ctl, const vshCmd *cmd ATTRIBUTE_UNUSED)
878
{
E
Eric Blake 已提交
879 880
    ctl->imode = false;
    return true;
K
Karel Zak 已提交
881 882
}

883 884 885 886
/* ---------------
 * Utils for work with command definition
 * ---------------
 */
E
Eric Blake 已提交
887
const char *
888 889 890
vshCmddefGetInfo(const vshCmdDef * cmd, const char *name)
{
    const vshCmdInfo *info;
891

892 893 894 895 896 897
    for (info = cmd->info; info && info->name; info++) {
        if (STREQ(info->name, name))
            return info->data;
    }
    return NULL;
}
898

899 900 901 902 903 904 905
/* Validate that the options associated with cmd can be parsed.  */
static int
vshCmddefOptParse(const vshCmdDef *cmd, uint32_t *opts_need_arg,
                  uint32_t *opts_required)
{
    int i;
    bool optional = false;
906

907 908
    *opts_need_arg = 0;
    *opts_required = 0;
909

910 911
    if (!cmd->opts)
        return 0;
912

913 914
    for (i = 0; cmd->opts[i].name; i++) {
        const vshCmdOptDef *opt = &cmd->opts[i];
915 916 917 918

        if (i > 31)
            return -1; /* too many options */
        if (opt->type == VSH_OT_BOOL) {
E
Eric Blake 已提交
919
            if (opt->flags & VSH_OFLAG_REQ)
920 921 922
                return -1; /* bool options can't be mandatory */
            continue;
        }
E
Eric Blake 已提交
923 924 925 926 927 928 929 930 931 932 933 934
        if (opt->type == VSH_OT_ALIAS) {
            int j;
            if (opt->flags || !opt->help)
                return -1; /* alias options are tracked by the original name */
            for (j = i + 1; cmd->opts[j].name; j++) {
                if (STREQ(opt->help, cmd->opts[j].name))
                    break;
            }
            if (!cmd->opts[j].name)
                return -1; /* alias option must map to a later option name */
            continue;
        }
E
Eric Blake 已提交
935 936
        if (opt->flags & VSH_OFLAG_REQ_OPT) {
            if (opt->flags & VSH_OFLAG_REQ)
L
Lai Jiangshan 已提交
937 938 939 940
                *opts_required |= 1 << i;
            continue;
        }

941
        *opts_need_arg |= 1 << i;
E
Eric Blake 已提交
942
        if (opt->flags & VSH_OFLAG_REQ) {
943 944 945 946 947 948
            if (optional)
                return -1; /* mandatory options must be listed first */
            *opts_required |= 1 << i;
        } else {
            optional = true;
        }
949 950 951

        if (opt->type == VSH_OT_ARGV && cmd->opts[i + 1].name)
            return -1; /* argv option must be listed last */
952 953 954 955
    }
    return 0;
}

956 957 958 959 960 961
static vshCmdOptDef helpopt = {
    .name = "help",
    .type = VSH_OT_BOOL,
    .flags = 0,
    .help = N_("print help for this function")
};
962
static const vshCmdOptDef *
963
vshCmddefGetOption(vshControl *ctl, const vshCmdDef *cmd, const char *name,
964
                   uint32_t *opts_seen, int *opt_index)
965
{
966 967
    int i;

968 969 970 971
    if (STREQ(name, helpopt.name)) {
        return &helpopt;
    }

972 973
    for (i = 0; cmd->opts && cmd->opts[i].name; i++) {
        const vshCmdOptDef *opt = &cmd->opts[i];
974

975
        if (STREQ(opt->name, name)) {
E
Eric Blake 已提交
976 977 978 979
            if (opt->type == VSH_OT_ALIAS) {
                name = opt->help;
                continue;
            }
980
            if ((*opts_seen & (1 << i)) && opt->type != VSH_OT_ARGV) {
981 982 983
                vshError(ctl, _("option --%s already seen"), name);
                return NULL;
            }
984 985
            *opts_seen |= 1 << i;
            *opt_index = i;
K
Karel Zak 已提交
986
            return opt;
987 988 989
        }
    }

990 991 992 993
    if (STRNEQ(cmd->name, "help")) {
        vshError(ctl, _("command '%s' doesn't support option --%s"),
                 cmd->name, name);
    }
K
Karel Zak 已提交
994 995 996
    return NULL;
}

997
static const vshCmdOptDef *
998 999
vshCmddefGetData(const vshCmdDef *cmd, uint32_t *opts_need_arg,
                 uint32_t *opts_seen)
1000
{
1001
    int i;
1002
    const vshCmdOptDef *opt;
K
Karel Zak 已提交
1003

1004 1005 1006 1007
    if (!*opts_need_arg)
        return NULL;

    /* Grab least-significant set bit */
E
Eric Blake 已提交
1008
    i = ffs(*opts_need_arg) - 1;
1009
    opt = &cmd->opts[i];
1010
    if (opt->type != VSH_OT_ARGV)
1011
        *opts_need_arg &= ~(1 << i);
1012
    *opts_seen |= 1 << i;
1013
    return opt;
K
Karel Zak 已提交
1014 1015
}

1016 1017 1018
/*
 * Checks for required options
 */
1019
static int
1020 1021
vshCommandCheckOpts(vshControl *ctl, const vshCmd *cmd, uint32_t opts_required,
                    uint32_t opts_seen)
1022
{
1023
    const vshCmdDef *def = cmd->def;
1024 1025 1026 1027 1028 1029 1030 1031 1032
    int i;

    opts_required &= ~opts_seen;
    if (!opts_required)
        return 0;

    for (i = 0; def->opts[i].name; i++) {
        if (opts_required & (1 << i)) {
            const vshCmdOptDef *opt = &def->opts[i];
1033

1034
            vshError(ctl,
1035
                     opt->type == VSH_OT_DATA || opt->type == VSH_OT_ARGV ?
1036 1037 1038
                     _("command '%s' requires <%s> option") :
                     _("command '%s' requires --%s option"),
                     def->name, opt->name);
1039 1040
        }
    }
1041
    return -1;
1042 1043
}

E
Eric Blake 已提交
1044
const vshCmdDef *
1045 1046
vshCmddefSearch(const char *cmdname)
{
1047
    const vshCmdGrp *g;
1048
    const vshCmdDef *c;
1049

1050 1051
    for (g = cmdGroups; g->name; g++) {
        for (c = g->commands; c->name; c++) {
1052
            if (STREQ(c->name, cmdname))
1053 1054 1055 1056
                return c;
        }
    }

K
Karel Zak 已提交
1057 1058 1059
    return NULL;
}

E
Eric Blake 已提交
1060
const vshCmdGrp *
1061 1062 1063 1064 1065
vshCmdGrpSearch(const char *grpname)
{
    const vshCmdGrp *g;

    for (g = cmdGroups; g->name; g++) {
1066
        if (STREQ(g->name, grpname) || STREQ(g->keyword, grpname))
1067 1068 1069 1070 1071 1072
            return g;
    }

    return NULL;
}

E
Eric Blake 已提交
1073
bool
1074 1075 1076 1077 1078 1079 1080
vshCmdGrpHelp(vshControl *ctl, const char *grpname)
{
    const vshCmdGrp *grp = vshCmdGrpSearch(grpname);
    const vshCmdDef *cmd = NULL;

    if (!grp) {
        vshError(ctl, _("command group '%s' doesn't exist"), grpname);
E
Eric Blake 已提交
1081
        return false;
1082 1083 1084 1085 1086 1087 1088 1089 1090 1091
    } else {
        vshPrint(ctl, _(" %s (help keyword '%s'):\n"), grp->name,
                 grp->keyword);

        for (cmd = grp->commands; cmd->name; cmd++) {
            vshPrint(ctl, "    %-30s %s\n", cmd->name,
                     _(vshCmddefGetInfo(cmd, "help")));
        }
    }

E
Eric Blake 已提交
1092
    return true;
1093 1094
}

E
Eric Blake 已提交
1095
bool
1096
vshCmddefHelp(vshControl *ctl, const char *cmdname)
1097
{
1098
    const vshCmdDef *def = vshCmddefSearch(cmdname);
1099

K
Karel Zak 已提交
1100
    if (!def) {
1101
        vshError(ctl, _("command '%s' doesn't exist"), cmdname);
E
Eric Blake 已提交
1102
        return false;
1103
    } else {
E
Eric Blake 已提交
1104 1105
        /* Don't translate desc if it is "".  */
        const char *desc = vshCmddefGetInfo(def, "desc");
E
Eric Blake 已提交
1106
        const char *help = _(vshCmddefGetInfo(def, "help"));
1107
        char buf[256];
1108 1109
        uint32_t opts_need_arg;
        uint32_t opts_required;
1110
        bool shortopt = false; /* true if 'arg' works instead of '--opt arg' */
1111 1112 1113 1114

        if (vshCmddefOptParse(def, &opts_need_arg, &opts_required)) {
            vshError(ctl, _("internal error: bad options in command: '%s'"),
                     def->name);
E
Eric Blake 已提交
1115
            return false;
1116
        }
K
Karel Zak 已提交
1117

1118
        fputs(_("  NAME\n"), stdout);
1119 1120
        fprintf(stdout, "    %s - %s\n", def->name, help);

1121 1122 1123 1124 1125
        fputs(_("\n  SYNOPSIS\n"), stdout);
        fprintf(stdout, "    %s", def->name);
        if (def->opts) {
            const vshCmdOptDef *opt;
            for (opt = def->opts; opt->name; opt++) {
1126
                const char *fmt = "%s";
1127 1128
                switch (opt->type) {
                case VSH_OT_BOOL:
1129
                    fmt = "[--%s]";
1130 1131
                    break;
                case VSH_OT_INT:
E
Eric Blake 已提交
1132
                    /* xgettext:c-format */
E
Eric Blake 已提交
1133
                    fmt = ((opt->flags & VSH_OFLAG_REQ) ? "<%s>"
1134
                           : _("[--%s <number>]"));
1135 1136
                    if (!(opt->flags & VSH_OFLAG_REQ_OPT))
                        shortopt = true;
1137 1138
                    break;
                case VSH_OT_STRING:
E
Eric Blake 已提交
1139 1140
                    /* xgettext:c-format */
                    fmt = _("[--%s <string>]");
1141 1142
                    if (!(opt->flags & VSH_OFLAG_REQ_OPT))
                        shortopt = true;
1143 1144
                    break;
                case VSH_OT_DATA:
E
Eric Blake 已提交
1145
                    fmt = ((opt->flags & VSH_OFLAG_REQ) ? "<%s>" : "[<%s>]");
1146 1147
                    if (!(opt->flags & VSH_OFLAG_REQ_OPT))
                        shortopt = true;
1148 1149 1150
                    break;
                case VSH_OT_ARGV:
                    /* xgettext:c-format */
1151 1152 1153 1154 1155 1156 1157 1158
                    if (shortopt) {
                        fmt = (opt->flags & VSH_OFLAG_REQ)
                            ? _("{[--%s] <string>}...")
                            : _("[[--%s] <string>]...");
                    } else {
                        fmt = (opt->flags & VSH_OFLAG_REQ) ? _("<%s>...")
                            : _("[<%s>]...");
                    }
1159
                    break;
E
Eric Blake 已提交
1160 1161 1162
                case VSH_OT_ALIAS:
                    /* aliases are intentionally undocumented */
                    continue;
1163
                default:
1164
                    assert(0);
1165
                }
1166
                fputc(' ', stdout);
E
Eric Blake 已提交
1167
                fprintf(stdout, fmt, opt->name);
1168
            }
K
Karel Zak 已提交
1169
        }
1170 1171 1172
        fputc('\n', stdout);

        if (desc[0]) {
1173
            /* Print the description only if it's not empty.  */
1174
            fputs(_("\n  DESCRIPTION\n"), stdout);
E
Eric Blake 已提交
1175
            fprintf(stdout, "    %s\n", _(desc));
K
Karel Zak 已提交
1176
        }
1177

K
Karel Zak 已提交
1178
        if (def->opts) {
1179
            const vshCmdOptDef *opt;
1180
            fputs(_("\n  OPTIONS\n"), stdout);
1181
            for (opt = def->opts; opt->name; opt++) {
1182 1183
                switch (opt->type) {
                case VSH_OT_BOOL:
K
Karel Zak 已提交
1184
                    snprintf(buf, sizeof(buf), "--%s", opt->name);
1185 1186
                    break;
                case VSH_OT_INT:
1187
                    snprintf(buf, sizeof(buf),
E
Eric Blake 已提交
1188
                             (opt->flags & VSH_OFLAG_REQ) ? _("[--%s] <number>")
1189
                             : _("--%s <number>"), opt->name);
1190 1191
                    break;
                case VSH_OT_STRING:
1192
                    /* OT_STRING should never be VSH_OFLAG_REQ */
1193
                    snprintf(buf, sizeof(buf), _("--%s <string>"), opt->name);
1194 1195
                    break;
                case VSH_OT_DATA:
1196 1197
                    snprintf(buf, sizeof(buf), _("[--%s] <string>"),
                             opt->name);
1198 1199
                    break;
                case VSH_OT_ARGV:
1200 1201 1202
                    snprintf(buf, sizeof(buf),
                             shortopt ? _("[--%s] <string>") : _("<%s>"),
                             opt->name);
1203
                    break;
E
Eric Blake 已提交
1204 1205
                case VSH_OT_ALIAS:
                    continue;
1206 1207 1208
                default:
                    assert(0);
                }
1209

E
Eric Blake 已提交
1210
                fprintf(stdout, "    %-15s  %s\n", buf, _(opt->help));
1211
            }
K
Karel Zak 已提交
1212 1213 1214
        }
        fputc('\n', stdout);
    }
E
Eric Blake 已提交
1215
    return true;
K
Karel Zak 已提交
1216 1217 1218 1219 1220 1221
}

/* ---------------
 * Utils for work with runtime commands data
 * ---------------
 */
1222 1223 1224
static void
vshCommandOptFree(vshCmdOpt * arg)
{
K
Karel Zak 已提交
1225 1226
    vshCmdOpt *a = arg;

1227
    while (a) {
K
Karel Zak 已提交
1228
        vshCmdOpt *tmp = a;
1229

K
Karel Zak 已提交
1230 1231
        a = a->next;

1232 1233
        VIR_FREE(tmp->data);
        VIR_FREE(tmp);
K
Karel Zak 已提交
1234 1235 1236 1237
    }
}

static void
1238
vshCommandFree(vshCmd *cmd)
1239
{
K
Karel Zak 已提交
1240 1241
    vshCmd *c = cmd;

1242
    while (c) {
K
Karel Zak 已提交
1243
        vshCmd *tmp = c;
1244

K
Karel Zak 已提交
1245 1246 1247 1248
        c = c->next;

        if (tmp->opts)
            vshCommandOptFree(tmp->opts);
1249
        VIR_FREE(tmp);
K
Karel Zak 已提交
1250 1251 1252
    }
}

E
Eric Blake 已提交
1253 1254 1255 1256 1257 1258 1259 1260 1261 1262 1263
/**
 * vshCommandOpt:
 * @cmd: parsed command line to search
 * @name: option name to search for
 * @opt: result of the search
 *
 * Look up an option passed to CMD by NAME.  Returns 1 with *OPT set
 * to the option if found, 0 with *OPT set to NULL if the name is
 * valid and the option is not required, -1 with *OPT set to NULL if
 * the option is required but not present, and -2 if NAME is not valid
 * (-2 indicates a programming error).  No error messages are issued.
K
Karel Zak 已提交
1264
 */
E
Eric Blake 已提交
1265
int
E
Eric Blake 已提交
1266
vshCommandOpt(const vshCmd *cmd, const char *name, vshCmdOpt **opt)
1267
{
E
Eric Blake 已提交
1268 1269
    vshCmdOpt *candidate = cmd->opts;
    const vshCmdOptDef *valid = cmd->def->opts;
1270

E
Eric Blake 已提交
1271 1272 1273 1274 1275 1276 1277
    /* See if option is present on command line.  */
    while (candidate) {
        if (STREQ(candidate->def->name, name)) {
            *opt = candidate;
            return 1;
        }
        candidate = candidate->next;
K
Karel Zak 已提交
1278
    }
E
Eric Blake 已提交
1279 1280 1281 1282 1283 1284 1285

    /* Option not present, see if command requires it.  */
    *opt = NULL;
    while (valid) {
        if (!valid->name)
            break;
        if (STREQ(name, valid->name))
E
Eric Blake 已提交
1286
            return (valid->flags & VSH_OFLAG_REQ) == 0 ? 0 : -1;
E
Eric Blake 已提交
1287 1288 1289 1290
        valid++;
    }
    /* If we got here, the name is unknown.  */
    return -2;
K
Karel Zak 已提交
1291 1292
}

E
Eric Blake 已提交
1293 1294
/**
 * vshCommandOptInt:
1295 1296 1297 1298 1299 1300 1301
 * @cmd command reference
 * @name option name
 * @value result
 *
 * Convert option to int
 * Return value:
 * >0 if option found and valid (@value updated)
E
Eric Blake 已提交
1302
 * 0 if option not found and not required (@value untouched)
1303
 * <0 in all other cases (@value untouched)
K
Karel Zak 已提交
1304
 */
E
Eric Blake 已提交
1305
int
1306
vshCommandOptInt(const vshCmd *cmd, const char *name, int *value)
1307
{
E
Eric Blake 已提交
1308 1309
    vshCmdOpt *arg;
    int ret;
1310

E
Eric Blake 已提交
1311 1312 1313 1314 1315 1316 1317
    ret = vshCommandOpt(cmd, name, &arg);
    if (ret <= 0)
        return ret;
    if (!arg->data) {
        /* only possible on bool, but if name is bool, this is a
         * programming bug */
        return -2;
1318
    }
E
Eric Blake 已提交
1319

E
Eric Blake 已提交
1320 1321 1322
    if (virStrToLong_i(arg->data, NULL, 10, value) < 0)
        return -1;
    return 1;
K
Karel Zak 已提交
1323 1324
}

1325

E
Eric Blake 已提交
1326 1327 1328 1329 1330 1331
/**
 * vshCommandOptUInt:
 * @cmd command reference
 * @name option name
 * @value result
 *
1332 1333 1334
 * Convert option to unsigned int
 * See vshCommandOptInt()
 */
E
Eric Blake 已提交
1335
int
1336 1337
vshCommandOptUInt(const vshCmd *cmd, const char *name, unsigned int *value)
{
E
Eric Blake 已提交
1338 1339
    vshCmdOpt *arg;
    int ret;
1340

E
Eric Blake 已提交
1341 1342 1343 1344 1345 1346 1347
    ret = vshCommandOpt(cmd, name, &arg);
    if (ret <= 0)
        return ret;
    if (!arg->data) {
        /* only possible on bool, but if name is bool, this is a
         * programming bug */
        return -2;
1348
    }
E
Eric Blake 已提交
1349

E
Eric Blake 已提交
1350 1351 1352
    if (virStrToLong_ui(arg->data, NULL, 10, value) < 0)
        return -1;
    return 1;
1353 1354 1355
}


1356
/*
E
Eric Blake 已提交
1357 1358 1359 1360 1361
 * vshCommandOptUL:
 * @cmd command reference
 * @name option name
 * @value result
 *
1362 1363 1364
 * Convert option to unsigned long
 * See vshCommandOptInt()
 */
E
Eric Blake 已提交
1365
int
1366
vshCommandOptUL(const vshCmd *cmd, const char *name, unsigned long *value)
1367
{
E
Eric Blake 已提交
1368 1369
    vshCmdOpt *arg;
    int ret;
1370

E
Eric Blake 已提交
1371 1372 1373 1374 1375 1376 1377
    ret = vshCommandOpt(cmd, name, &arg);
    if (ret <= 0)
        return ret;
    if (!arg->data) {
        /* only possible on bool, but if name is bool, this is a
         * programming bug */
        return -2;
1378
    }
E
Eric Blake 已提交
1379

E
Eric Blake 已提交
1380 1381 1382
    if (virStrToLong_ul(arg->data, NULL, 10, value) < 0)
        return -1;
    return 1;
1383 1384
}

E
Eric Blake 已提交
1385 1386 1387 1388 1389 1390
/**
 * vshCommandOptString:
 * @cmd command reference
 * @name option name
 * @value result
 *
K
Karel Zak 已提交
1391
 * Returns option as STRING
E
Eric Blake 已提交
1392 1393 1394 1395
 * Return value:
 * >0 if option found and valid (@value updated)
 * 0 if option not found and not required (@value untouched)
 * <0 in all other cases (@value untouched)
K
Karel Zak 已提交
1396
 */
E
Eric Blake 已提交
1397
int
1398
vshCommandOptString(const vshCmd *cmd, const char *name, const char **value)
1399
{
E
Eric Blake 已提交
1400 1401 1402 1403 1404 1405 1406 1407 1408 1409
    vshCmdOpt *arg;
    int ret;

    ret = vshCommandOpt(cmd, name, &arg);
    if (ret <= 0)
        return ret;
    if (!arg->data) {
        /* only possible on bool, but if name is bool, this is a
         * programming bug */
        return -2;
1410
    }
1411

E
Eric Blake 已提交
1412
    if (!*arg->data && !(arg->def->flags & VSH_OFLAG_EMPTY_OK)) {
E
Eric Blake 已提交
1413 1414 1415 1416
        return -1;
    }
    *value = arg->data;
    return 1;
K
Karel Zak 已提交
1417 1418
}

E
Eric Blake 已提交
1419 1420 1421 1422 1423 1424
/**
 * vshCommandOptLongLong:
 * @cmd command reference
 * @name option name
 * @value result
 *
1425
 * Returns option as long long
1426
 * See vshCommandOptInt()
1427
 */
E
Eric Blake 已提交
1428
int
1429 1430
vshCommandOptLongLong(const vshCmd *cmd, const char *name,
                      long long *value)
1431
{
E
Eric Blake 已提交
1432 1433
    vshCmdOpt *arg;
    int ret;
1434

E
Eric Blake 已提交
1435 1436 1437 1438 1439 1440 1441
    ret = vshCommandOpt(cmd, name, &arg);
    if (ret <= 0)
        return ret;
    if (!arg->data) {
        /* only possible on bool, but if name is bool, this is a
         * programming bug */
        return -2;
1442
    }
E
Eric Blake 已提交
1443

E
Eric Blake 已提交
1444 1445 1446
    if (virStrToLong_ll(arg->data, NULL, 10, value) < 0)
        return -1;
    return 1;
1447 1448
}

E
Eric Blake 已提交
1449 1450 1451 1452 1453 1454 1455 1456 1457
/**
 * vshCommandOptULongLong:
 * @cmd command reference
 * @name option name
 * @value result
 *
 * Returns option as long long
 * See vshCommandOptInt()
 */
E
Eric Blake 已提交
1458
int
1459 1460 1461
vshCommandOptULongLong(const vshCmd *cmd, const char *name,
                       unsigned long long *value)
{
E
Eric Blake 已提交
1462 1463
    vshCmdOpt *arg;
    int ret;
1464

E
Eric Blake 已提交
1465 1466 1467 1468 1469 1470 1471
    ret = vshCommandOpt(cmd, name, &arg);
    if (ret <= 0)
        return ret;
    if (!arg->data) {
        /* only possible on bool, but if name is bool, this is a
         * programming bug */
        return -2;
1472
    }
E
Eric Blake 已提交
1473

E
Eric Blake 已提交
1474 1475 1476
    if (virStrToLong_ull(arg->data, NULL, 10, value) < 0)
        return -1;
    return 1;
1477 1478 1479
}


E
Eric Blake 已提交
1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490
/**
 * vshCommandOptScaledInt:
 * @cmd command reference
 * @name option name
 * @value result
 * @scale default of 1 or 1024, if no suffix is present
 * @max maximum value permitted
 *
 * Returns option as long long, scaled according to suffix
 * See vshCommandOptInt()
 */
E
Eric Blake 已提交
1491
int
E
Eric Blake 已提交
1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509
vshCommandOptScaledInt(const vshCmd *cmd, const char *name,
                       unsigned long long *value, int scale,
                       unsigned long long max)
{
    const char *str;
    int ret;
    char *end;

    ret = vshCommandOptString(cmd, name, &str);
    if (ret <= 0)
        return ret;
    if (virStrToLong_ull(str, &end, 10, value) < 0 ||
        virScaleInteger(value, end, scale, max) < 0)
        return -1;
    return 1;
}


E
Eric Blake 已提交
1510 1511 1512 1513 1514 1515 1516 1517 1518
/**
 * vshCommandOptBool:
 * @cmd command reference
 * @name option name
 *
 * Returns true/false if the option exists.  Note that this does NOT
 * validate whether the option is actually boolean, or even whether
 * name is legal; so that this can be used to probe whether a data
 * option is present without actually using that data.
K
Karel Zak 已提交
1519
 */
E
Eric Blake 已提交
1520
bool
1521
vshCommandOptBool(const vshCmd *cmd, const char *name)
1522
{
E
Eric Blake 已提交
1523 1524 1525
    vshCmdOpt *dummy;

    return vshCommandOpt(cmd, name, &dummy) == 1;
K
Karel Zak 已提交
1526 1527
}

E
Eric Blake 已提交
1528 1529 1530 1531 1532
/**
 * vshCommandOptArgv:
 * @cmd command reference
 * @opt starting point for the search
 *
1533 1534
 * Returns the next argv argument after OPT (or the first one if OPT
 * is NULL), or NULL if no more are present.
1535
 *
1536
 * Requires that a VSH_OT_ARGV option be last in the
1537 1538
 * list of supported options in CMD->def->opts.
 */
E
Eric Blake 已提交
1539
const vshCmdOpt *
1540
vshCommandOptArgv(const vshCmd *cmd, const vshCmdOpt *opt)
1541
{
1542
    opt = opt ? opt->next : cmd->opts;
1543 1544

    while (opt) {
E
Eric Blake 已提交
1545
        if (opt->def->type == VSH_OT_ARGV) {
1546
            return opt;
1547 1548 1549 1550 1551 1552
        }
        opt = opt->next;
    }
    return NULL;
}

J
Jim Meyering 已提交
1553 1554 1555
/* Determine whether CMD->opts includes an option with name OPTNAME.
   If not, give a diagnostic and return false.
   If so, return true.  */
1556 1557
bool
vshCmdHasOption(vshControl *ctl, const vshCmd *cmd, const char *optname)
J
Jim Meyering 已提交
1558 1559 1560 1561 1562 1563
{
    /* Iterate through cmd->opts, to ensure that there is an entry
       with name OPTNAME and type VSH_OT_DATA. */
    bool found = false;
    const vshCmdOpt *opt;
    for (opt = cmd->opts; opt; opt = opt->next) {
1564
        if (STREQ(opt->def->name, optname) && opt->def->type == VSH_OT_DATA) {
J
Jim Meyering 已提交
1565 1566 1567 1568 1569 1570
            found = true;
            break;
        }
    }

    if (!found)
1571
        vshError(ctl, _("internal error: virsh %s: no %s VSH_OT_DATA option"),
J
Jim Meyering 已提交
1572 1573 1574
                 cmd->def->name, optname);
    return found;
}
1575

1576 1577 1578 1579 1580 1581 1582 1583 1584 1585 1586 1587 1588 1589 1590 1591 1592
static bool
vshConnectionUsability(vshControl *ctl, virConnectPtr conn)
{
    if (!conn ||
        virConnectIsAlive(conn) == 0) {
        vshError(ctl, "%s", _("no valid connection"));
        return false;
    }

    /* The connection is considered dead only if
     * virConnectIsAlive() successfuly says so.
     */
    vshResetLibvirtError();

    return true;
}

K
Karel Zak 已提交
1593 1594 1595
/*
 * Executes command(s) and returns return code from last command
 */
E
Eric Blake 已提交
1596
static bool
1597
vshCommandRun(vshControl *ctl, const vshCmd *cmd)
1598
{
E
Eric Blake 已提交
1599
    bool ret = true;
1600 1601

    while (cmd) {
K
Karel Zak 已提交
1602
        struct timeval before, after;
1603
        bool enable_timing = ctl->timing;
1604

1605 1606
        if ((ctl->conn == NULL || disconnected) &&
            !(cmd->def->flags & VSH_CMD_FLAG_NOCONNECT))
1607 1608
            vshReconnect(ctl);

1609 1610 1611
        if (enable_timing)
            GETTIMEOFDAY(&before);

1612 1613 1614 1615 1616 1617 1618
        if ((cmd->def->flags & VSH_CMD_FLAG_NOCONNECT) ||
            vshConnectionUsability(ctl, ctl->conn)) {
            ret = cmd->def->handler(ctl, cmd);
        } else {
            /* connection is not usable, return error */
            ret = false;
        }
1619

1620 1621 1622
        if (enable_timing)
            GETTIMEOFDAY(&after);

1623 1624 1625 1626 1627 1628 1629 1630 1631 1632
        /* try to automatically catch disconnections */
        if (!ret &&
            ((last_error != NULL) &&
             (((last_error->code == VIR_ERR_SYSTEM_ERROR) &&
               (last_error->domain == VIR_FROM_REMOTE)) ||
              (last_error->code == VIR_ERR_RPC) ||
              (last_error->code == VIR_ERR_NO_CONNECT) ||
              (last_error->code == VIR_ERR_INVALID_CONN))))
            disconnected++;

1633
        if (!ret)
E
Eric Blake 已提交
1634
            vshReportError(ctl);
J
John Levon 已提交
1635

1636
        if (!ret && disconnected != 0)
1637 1638
            vshReconnect(ctl);

1639
        if (STREQ(cmd->def->name, "quit"))        /* hack ... */
K
Karel Zak 已提交
1640 1641
            return ret;

E
Eric Blake 已提交
1642
        if (enable_timing) {
1643
            double diff_ms = (((after.tv_sec - before.tv_sec) * 1000.0) +
E
Eric Blake 已提交
1644 1645 1646 1647
                              ((after.tv_usec - before.tv_usec) / 1000.0));

            vshPrint(ctl, _("\n(Time: %.3f ms)\n\n"), diff_ms);
        } else {
K
Karel Zak 已提交
1648
            vshPrintExtra(ctl, "\n");
E
Eric Blake 已提交
1649
        }
K
Karel Zak 已提交
1650 1651 1652 1653 1654 1655
        cmd = cmd->next;
    }
    return ret;
}

/* ---------------
1656
 * Command parsing
K
Karel Zak 已提交
1657 1658 1659
 * ---------------
 */

1660 1661 1662 1663 1664 1665 1666
typedef enum {
    VSH_TK_ERROR, /* Failed to parse a token */
    VSH_TK_ARG, /* Arbitrary argument, might be option or empty */
    VSH_TK_SUBCMD_END, /* Separation between commands */
    VSH_TK_END /* No more commands */
} vshCommandToken;

E
Eric Blake 已提交
1667 1668 1669 1670
typedef struct _vshCommandParser vshCommandParser;
struct _vshCommandParser {
    vshCommandToken(*getNextArg)(vshControl *, vshCommandParser *,
                                 char **);
L
Lai Jiangshan 已提交
1671
    /* vshCommandStringGetArg() */
1672
    char *pos;
L
Lai Jiangshan 已提交
1673 1674 1675
    /* vshCommandArgvGetArg() */
    char **arg_pos;
    char **arg_end;
E
Eric Blake 已提交
1676
};
1677

E
Eric Blake 已提交
1678
static bool
1679
vshCommandParse(vshControl *ctl, vshCommandParser *parser)
1680
{
K
Karel Zak 已提交
1681 1682 1683
    char *tkdata = NULL;
    vshCmd *clast = NULL;
    vshCmdOpt *first = NULL;
1684

K
Karel Zak 已提交
1685 1686 1687 1688
    if (ctl->cmd) {
        vshCommandFree(ctl->cmd);
        ctl->cmd = NULL;
    }
1689

1690
    while (1) {
K
Karel Zak 已提交
1691
        vshCmdOpt *last = NULL;
1692
        const vshCmdDef *cmd = NULL;
1693
        vshCommandToken tk;
L
Lai Jiangshan 已提交
1694
        bool data_only = false;
1695 1696 1697
        uint32_t opts_need_arg = 0;
        uint32_t opts_required = 0;
        uint32_t opts_seen = 0;
1698

K
Karel Zak 已提交
1699
        first = NULL;
1700

1701
        while (1) {
1702
            const vshCmdOptDef *opt = NULL;
1703

K
Karel Zak 已提交
1704
            tkdata = NULL;
1705
            tk = parser->getNextArg(ctl, parser, &tkdata);
1706 1707

            if (tk == VSH_TK_ERROR)
K
Karel Zak 已提交
1708
                goto syntaxError;
H
Hu Tao 已提交
1709 1710
            if (tk != VSH_TK_ARG) {
                VIR_FREE(tkdata);
1711
                break;
H
Hu Tao 已提交
1712
            }
1713 1714

            if (cmd == NULL) {
K
Karel Zak 已提交
1715 1716
                /* first token must be command name */
                if (!(cmd = vshCmddefSearch(tkdata))) {
1717
                    vshError(ctl, _("unknown command: '%s'"), tkdata);
1718
                    goto syntaxError;   /* ... or ignore this command only? */
K
Karel Zak 已提交
1719
                }
1720 1721 1722 1723 1724 1725 1726
                if (vshCmddefOptParse(cmd, &opts_need_arg,
                                      &opts_required) < 0) {
                    vshError(ctl,
                             _("internal error: bad options in command: '%s'"),
                             tkdata);
                    goto syntaxError;
                }
1727
                VIR_FREE(tkdata);
L
Lai Jiangshan 已提交
1728 1729 1730 1731
            } else if (data_only) {
                goto get_data;
            } else if (tkdata[0] == '-' && tkdata[1] == '-' &&
                       c_isalnum(tkdata[2])) {
1732
                char *optstr = strchr(tkdata + 2, '=');
C
Cole Robinson 已提交
1733
                int opt_index = 0;
1734

1735 1736 1737 1738
                if (optstr) {
                    *optstr = '\0'; /* convert the '=' to '\0' */
                    optstr = vshStrdup(ctl, optstr + 1);
                }
1739
                /* Special case 'help' to ignore all spurious options */
1740
                if (!(opt = vshCmddefGetOption(ctl, cmd, tkdata + 2,
1741
                                               &opts_seen, &opt_index))) {
1742
                    VIR_FREE(optstr);
1743 1744
                    if (STREQ(cmd->name, "help"))
                        continue;
K
Karel Zak 已提交
1745 1746
                    goto syntaxError;
                }
1747
                VIR_FREE(tkdata);
K
Karel Zak 已提交
1748 1749 1750

                if (opt->type != VSH_OT_BOOL) {
                    /* option data */
1751 1752 1753
                    if (optstr)
                        tkdata = optstr;
                    else
1754
                        tk = parser->getNextArg(ctl, parser, &tkdata);
1755
                    if (tk == VSH_TK_ERROR)
K
Karel Zak 已提交
1756
                        goto syntaxError;
1757
                    if (tk != VSH_TK_ARG) {
1758
                        vshError(ctl,
1759
                                 _("expected syntax: --%s <%s>"),
1760 1761
                                 opt->name,
                                 opt->type ==
1762
                                 VSH_OT_INT ? _("number") : _("string"));
K
Karel Zak 已提交
1763 1764
                        goto syntaxError;
                    }
1765 1766
                    if (opt->type != VSH_OT_ARGV)
                        opts_need_arg &= ~(1 << opt_index);
1767 1768 1769 1770 1771 1772 1773 1774
                } else {
                    tkdata = NULL;
                    if (optstr) {
                        vshError(ctl, _("invalid '=' after option --%s"),
                                opt->name);
                        VIR_FREE(optstr);
                        goto syntaxError;
                    }
K
Karel Zak 已提交
1775
                }
L
Lai Jiangshan 已提交
1776 1777 1778 1779
            } else if (tkdata[0] == '-' && tkdata[1] == '-' &&
                       tkdata[2] == '\0') {
                data_only = true;
                continue;
1780
            } else {
L
Lai Jiangshan 已提交
1781
get_data:
1782
                /* Special case 'help' to ignore spurious data */
1783
                if (!(opt = vshCmddefGetData(cmd, &opts_need_arg,
1784 1785
                                             &opts_seen)) &&
                     STRNEQ(cmd->name, "help")) {
1786
                    vshError(ctl, _("unexpected data '%s'"), tkdata);
K
Karel Zak 已提交
1787 1788 1789 1790 1791
                    goto syntaxError;
                }
            }
            if (opt) {
                /* save option */
1792
                vshCmdOpt *arg = vshMalloc(ctl, sizeof(vshCmdOpt));
1793

K
Karel Zak 已提交
1794 1795 1796 1797
                arg->def = opt;
                arg->data = tkdata;
                arg->next = NULL;
                tkdata = NULL;
1798

K
Karel Zak 已提交
1799 1800 1801 1802 1803
                if (!first)
                    first = arg;
                if (last)
                    last->next = arg;
                last = arg;
1804

1805
                vshDebug(ctl, VSH_ERR_INFO, "%s: %s(%s): %s\n",
1806 1807
                         cmd->name,
                         opt->name,
1808 1809
                         opt->type != VSH_OT_BOOL ? _("optdata") : _("bool"),
                         opt->type != VSH_OT_BOOL ? arg->data : _("(none)"));
K
Karel Zak 已提交
1810 1811
            }
        }
1812

D
Daniel Veillard 已提交
1813
        /* command parsed -- allocate new struct for the command */
K
Karel Zak 已提交
1814
        if (cmd) {
1815
            vshCmd *c = vshMalloc(ctl, sizeof(vshCmd));
1816 1817 1818 1819 1820 1821 1822 1823 1824 1825 1826 1827 1828 1829 1830 1831 1832 1833 1834
            vshCmdOpt *tmpopt = first;

            /* if we encountered --help, replace parsed command with
             * 'help <cmdname>' */
            for (tmpopt = first; tmpopt; tmpopt = tmpopt->next) {
                if (STRNEQ(tmpopt->def->name, "help"))
                    continue;

                vshCommandOptFree(first);
                first = vshMalloc(ctl, sizeof(vshCmdOpt));
                first->def = &(opts_help[0]);
                first->data = vshStrdup(ctl, cmd->name);
                first->next = NULL;

                cmd = vshCmddefSearch("help");
                opts_required = 0;
                opts_seen = 0;
                break;
            }
1835

K
Karel Zak 已提交
1836 1837 1838 1839
            c->opts = first;
            c->def = cmd;
            c->next = NULL;

1840
            if (vshCommandCheckOpts(ctl, c, opts_required, opts_seen) < 0) {
1841
                VIR_FREE(c);
1842
                goto syntaxError;
1843
            }
1844

K
Karel Zak 已提交
1845 1846 1847 1848 1849 1850
            if (!ctl->cmd)
                ctl->cmd = c;
            if (clast)
                clast->next = c;
            clast = c;
        }
1851 1852 1853

        if (tk == VSH_TK_END)
            break;
K
Karel Zak 已提交
1854
    }
1855

E
Eric Blake 已提交
1856
    return true;
K
Karel Zak 已提交
1857

1858
 syntaxError:
1859
    if (ctl->cmd) {
K
Karel Zak 已提交
1860
        vshCommandFree(ctl->cmd);
1861 1862
        ctl->cmd = NULL;
    }
K
Karel Zak 已提交
1863 1864
    if (first)
        vshCommandOptFree(first);
1865
    VIR_FREE(tkdata);
E
Eric Blake 已提交
1866
    return false;
K
Karel Zak 已提交
1867 1868
}

1869 1870 1871 1872 1873 1874 1875 1876 1877 1878 1879 1880 1881 1882 1883 1884 1885 1886
/* --------------------
 * Command argv parsing
 * --------------------
 */

static vshCommandToken ATTRIBUTE_NONNULL(2) ATTRIBUTE_NONNULL(3)
vshCommandArgvGetArg(vshControl *ctl, vshCommandParser *parser, char **res)
{
    if (parser->arg_pos == parser->arg_end) {
        *res = NULL;
        return VSH_TK_END;
    }

    *res = vshStrdup(ctl, *parser->arg_pos);
    parser->arg_pos++;
    return VSH_TK_ARG;
}

E
Eric Blake 已提交
1887 1888
static bool
vshCommandArgvParse(vshControl *ctl, int nargs, char **argv)
1889 1890 1891 1892
{
    vshCommandParser parser;

    if (nargs <= 0)
E
Eric Blake 已提交
1893
        return false;
1894 1895 1896 1897 1898 1899 1900 1901 1902 1903 1904 1905 1906 1907 1908 1909 1910 1911 1912 1913 1914 1915 1916 1917 1918 1919 1920 1921 1922 1923 1924 1925 1926 1927 1928 1929 1930 1931 1932 1933 1934 1935 1936 1937 1938 1939 1940 1941 1942 1943 1944 1945 1946 1947 1948 1949 1950 1951 1952 1953 1954 1955 1956 1957 1958 1959 1960 1961 1962 1963 1964 1965

    parser.arg_pos = argv;
    parser.arg_end = argv + nargs;
    parser.getNextArg = vshCommandArgvGetArg;
    return vshCommandParse(ctl, &parser);
}

/* ----------------------
 * Command string parsing
 * ----------------------
 */

static vshCommandToken ATTRIBUTE_NONNULL(2) ATTRIBUTE_NONNULL(3)
vshCommandStringGetArg(vshControl *ctl, vshCommandParser *parser, char **res)
{
    bool single_quote = false;
    bool double_quote = false;
    int sz = 0;
    char *p = parser->pos;
    char *q = vshStrdup(ctl, p);

    *res = q;

    while (*p && (*p == ' ' || *p == '\t'))
        p++;

    if (*p == '\0')
        return VSH_TK_END;
    if (*p == ';') {
        parser->pos = ++p;             /* = \0 or begin of next command */
        return VSH_TK_SUBCMD_END;
    }

    while (*p) {
        /* end of token is blank space or ';' */
        if (!double_quote && !single_quote &&
            (*p == ' ' || *p == '\t' || *p == ';'))
            break;

        if (!double_quote && *p == '\'') { /* single quote */
            single_quote = !single_quote;
            p++;
            continue;
        } else if (!single_quote && *p == '\\') { /* escape */
            /*
             * The same as the bash, a \ in "" is an escaper,
             * but a \ in '' is not an escaper.
             */
            p++;
            if (*p == '\0') {
                vshError(ctl, "%s", _("dangling \\"));
                return VSH_TK_ERROR;
            }
        } else if (!single_quote && *p == '"') { /* double quote */
            double_quote = !double_quote;
            p++;
            continue;
        }

        *q++ = *p++;
        sz++;
    }
    if (double_quote) {
        vshError(ctl, "%s", _("missing \""));
        return VSH_TK_ERROR;
    }

    *q = '\0';
    parser->pos = p;
    return VSH_TK_ARG;
}

E
Eric Blake 已提交
1966 1967
static bool
vshCommandStringParse(vshControl *ctl, char *cmdstr)
1968 1969 1970 1971
{
    vshCommandParser parser;

    if (cmdstr == NULL || *cmdstr == '\0')
E
Eric Blake 已提交
1972
        return false;
1973 1974 1975 1976 1977 1978

    parser.pos = cmdstr;
    parser.getNextArg = vshCommandStringGetArg;
    return vshCommandParse(ctl, &parser);
}

K
Karel Zak 已提交
1979
/* ---------------
1980
 * Misc utils
K
Karel Zak 已提交
1981 1982
 * ---------------
 */
E
Eric Blake 已提交
1983
int
1984 1985 1986 1987 1988 1989 1990 1991 1992 1993 1994 1995 1996 1997 1998 1999 2000 2001 2002 2003 2004 2005 2006 2007 2008 2009 2010
vshDomainState(vshControl *ctl, virDomainPtr dom, int *reason)
{
    virDomainInfo info;

    if (reason)
        *reason = -1;

    if (!ctl->useGetInfo) {
        int state;
        if (virDomainGetState(dom, &state, reason, 0) < 0) {
            virErrorPtr err = virGetLastError();
            if (err && err->code == VIR_ERR_NO_SUPPORT)
                ctl->useGetInfo = true;
            else
                return -1;
        } else {
            return state;
        }
    }

    /* fall back to virDomainGetInfo if virDomainGetState is not supported */
    if (virDomainGetInfo(dom, &info) < 0)
        return -1;
    else
        return info.state;
}

2011 2012
/* Return a non-NULL string representation of a typed parameter; exit
 * if we are out of memory.  */
E
Eric Blake 已提交
2013
char *
2014 2015 2016 2017 2018
vshGetTypedParamValue(vshControl *ctl, virTypedParameterPtr item)
{
    int ret = 0;
    char *str = NULL;

2019
    switch (item->type) {
2020 2021 2022 2023 2024 2025 2026 2027 2028 2029 2030 2031 2032 2033 2034 2035 2036 2037 2038 2039 2040 2041 2042 2043
    case VIR_TYPED_PARAM_INT:
        ret = virAsprintf(&str, "%d", item->value.i);
        break;

    case VIR_TYPED_PARAM_UINT:
        ret = virAsprintf(&str, "%u", item->value.ui);
        break;

    case VIR_TYPED_PARAM_LLONG:
        ret = virAsprintf(&str, "%lld", item->value.l);
        break;

    case VIR_TYPED_PARAM_ULLONG:
        ret = virAsprintf(&str, "%llu", item->value.ul);
        break;

    case VIR_TYPED_PARAM_DOUBLE:
        ret = virAsprintf(&str, "%f", item->value.d);
        break;

    case VIR_TYPED_PARAM_BOOLEAN:
        ret = virAsprintf(&str, "%s", item->value.b ? _("yes") : _("no"));
        break;

2044 2045 2046 2047
    case VIR_TYPED_PARAM_STRING:
        str = vshStrdup(ctl, item->value.s);
        break;

2048
    default:
2049
        vshError(ctl, _("unimplemented parameter type %d"), item->type);
2050 2051
    }

2052
    if (ret < 0) {
2053
        vshError(ctl, "%s", _("Out of memory"));
2054 2055
        exit(EXIT_FAILURE);
    }
2056 2057 2058
    return str;
}

E
Eric Blake 已提交
2059
void
2060
vshDebug(vshControl *ctl, int level, const char *format, ...)
2061
{
K
Karel Zak 已提交
2062
    va_list ap;
2063
    char *str;
K
Karel Zak 已提交
2064

2065 2066 2067 2068 2069 2070 2071
    /* Aligning log levels to that of libvirt.
     * Traces with levels >=  user-specified-level
     * gets logged into file
     */
    if (level < ctl->debug)
        return;

2072
    va_start(ap, format);
2073
    vshOutputLogFile(ctl, level, format, ap);
2074 2075
    va_end(ap);

K
Karel Zak 已提交
2076
    va_start(ap, format);
2077 2078 2079 2080 2081
    if (virVasprintf(&str, format, ap) < 0) {
        /* Skip debug messages on low memory */
        va_end(ap);
        return;
    }
K
Karel Zak 已提交
2082
    va_end(ap);
2083 2084
    fputs(str, stdout);
    VIR_FREE(str);
K
Karel Zak 已提交
2085 2086
}

E
Eric Blake 已提交
2087
void
2088
vshPrintExtra(vshControl *ctl, const char *format, ...)
2089
{
K
Karel Zak 已提交
2090
    va_list ap;
2091
    char *str;
2092

2093
    if (ctl && ctl->quiet)
K
Karel Zak 已提交
2094
        return;
2095

K
Karel Zak 已提交
2096
    va_start(ap, format);
2097 2098 2099 2100 2101
    if (virVasprintf(&str, format, ap) < 0) {
        vshError(ctl, "%s", _("Out of memory"));
        va_end(ap);
        return;
    }
K
Karel Zak 已提交
2102
    va_end(ap);
2103
    fputs(str, stdout);
2104
    VIR_FREE(str);
K
Karel Zak 已提交
2105 2106
}

K
Karel Zak 已提交
2107

E
Eric Blake 已提交
2108
void
2109
vshError(vshControl *ctl, const char *format, ...)
2110
{
K
Karel Zak 已提交
2111
    va_list ap;
2112
    char *str;
2113

2114 2115 2116 2117 2118
    if (ctl != NULL) {
        va_start(ap, format);
        vshOutputLogFile(ctl, VSH_ERR_ERROR, format, ap);
        va_end(ap);
    }
2119

2120 2121 2122 2123
    /* Most output is to stdout, but if someone ran virsh 2>&1, then
     * printing to stderr will not interleave correctly with stdout
     * unless we flush between every transition between streams.  */
    fflush(stdout);
2124
    fputs(_("error: "), stderr);
2125

K
Karel Zak 已提交
2126
    va_start(ap, format);
2127 2128 2129
    /* We can't recursively call vshError on an OOM situation, so ignore
       failure here. */
    ignore_value(virVasprintf(&str, format, ap));
K
Karel Zak 已提交
2130 2131
    va_end(ap);

2132
    fprintf(stderr, "%s\n", NULLSTR(str));
2133
    fflush(stderr);
2134
    VIR_FREE(str);
K
Karel Zak 已提交
2135 2136
}

2137

J
Jiri Denemark 已提交
2138 2139 2140 2141 2142
static void
vshEventLoop(void *opaque)
{
    vshControl *ctl = opaque;

2143 2144 2145 2146 2147 2148 2149 2150 2151 2152
    while (1) {
        bool quit;
        virMutexLock(&ctl->lock);
        quit = ctl->quit;
        virMutexUnlock(&ctl->lock);

        if (quit)
            break;

        if (virEventRunDefaultImpl() < 0)
E
Eric Blake 已提交
2153
            vshReportError(ctl);
J
Jiri Denemark 已提交
2154 2155 2156 2157
    }
}


K
Karel Zak 已提交
2158
/*
2159
 * Initialize connection.
K
Karel Zak 已提交
2160
 */
E
Eric Blake 已提交
2161
static bool
2162
vshInit(vshControl *ctl)
2163
{
2164 2165
    char *debugEnv;

K
Karel Zak 已提交
2166
    if (ctl->conn)
E
Eric Blake 已提交
2167
        return false;
K
Karel Zak 已提交
2168

J
Jiri Denemark 已提交
2169
    if (ctl->debug == VSH_DEBUG_DEFAULT) {
2170 2171 2172
        /* log level not set from commandline, check env variable */
        debugEnv = getenv("VIRSH_DEBUG");
        if (debugEnv) {
J
Jiri Denemark 已提交
2173 2174 2175
            int debug;
            if (virStrToLong_i(debugEnv, NULL, 10, &debug) < 0 ||
                debug < VSH_ERR_DEBUG || debug > VSH_ERR_ERROR) {
2176 2177
                vshError(ctl, "%s",
                         _("VIRSH_DEBUG not set with a valid numeric value"));
J
Jiri Denemark 已提交
2178 2179
            } else {
                ctl->debug = debug;
2180 2181 2182 2183 2184 2185 2186 2187 2188 2189 2190 2191
            }
        }
    }

    if (ctl->logfile == NULL) {
        /* log file not set from cmdline */
        debugEnv = getenv("VIRSH_LOG_FILE");
        if (debugEnv && *debugEnv) {
            ctl->logfile = vshStrdup(ctl, debugEnv);
        }
    }

2192 2193
    vshOpenLogFile(ctl);

2194 2195
    /* set up the library error handler */
    virSetErrorFunc(NULL, virshErrorHandler);
2196

2197
    if (virEventRegisterDefaultImpl() < 0)
E
Eric Blake 已提交
2198
        return false;
2199

J
Jiri Denemark 已提交
2200 2201 2202 2203
    if (virThreadCreate(&ctl->eventLoop, true, vshEventLoop, ctl) < 0)
        return false;
    ctl->eventLoopStarted = true;

2204
    if (ctl->name) {
2205
        vshReconnect(ctl);
2206 2207 2208 2209 2210 2211 2212
        /* Connecting to a named connection must succeed, but we delay
         * connecting to the default connection until we need it
         * (since the first command might be 'connect' which allows a
         * non-default connection, or might be 'help' which needs no
         * connection).
         */
        if (!ctl->conn) {
E
Eric Blake 已提交
2213
            vshReportError(ctl);
2214 2215
            return false;
        }
2216
    }
K
Karel Zak 已提交
2217

E
Eric Blake 已提交
2218
    return true;
K
Karel Zak 已提交
2219 2220
}

2221 2222
#define LOGFILE_FLAGS (O_WRONLY | O_APPEND | O_CREAT | O_SYNC)

2223 2224 2225 2226 2227
/**
 * vshOpenLogFile:
 *
 * Open log file.
 */
E
Eric Blake 已提交
2228
void
2229 2230 2231 2232 2233 2234 2235 2236 2237 2238 2239 2240 2241
vshOpenLogFile(vshControl *ctl)
{
    struct stat st;

    if (ctl->logfile == NULL)
        return;

    /* check log file */
    if (stat(ctl->logfile, &st) == -1) {
        switch (errno) {
            case ENOENT:
                break;
            default:
2242
                vshError(ctl, "%s",
J
Jim Meyering 已提交
2243
                         _("failed to get the log file information"));
2244
                exit(EXIT_FAILURE);
2245 2246 2247
        }
    } else {
        if (!S_ISREG(st.st_mode)) {
2248 2249
            vshError(ctl, "%s", _("the log path is not a file"));
            exit(EXIT_FAILURE);
2250 2251 2252 2253
        }
    }

    /* log file open */
2254
    if ((ctl->log_fd = open(ctl->logfile, LOGFILE_FLAGS, FILE_MODE)) < 0) {
2255
        vshError(ctl, "%s",
J
Jim Meyering 已提交
2256
                 _("failed to open the log file. check the log file path"));
2257
        exit(EXIT_FAILURE);
2258 2259 2260 2261 2262 2263 2264 2265
    }
}

/**
 * vshOutputLogFile:
 *
 * Outputting an error to log file.
 */
E
Eric Blake 已提交
2266
void
2267 2268
vshOutputLogFile(vshControl *ctl, int log_level, const char *msg_format,
                 va_list ap)
2269
{
2270
    virBuffer buf = VIR_BUFFER_INITIALIZER;
J
John Ferlan 已提交
2271
    char *str = NULL;
2272
    size_t len;
2273
    const char *lvl = "";
2274
    time_t stTime;
2275
    struct tm stTm;
2276 2277 2278 2279 2280 2281 2282 2283 2284

    if (ctl->log_fd == -1)
        return;

    /**
     * create log format
     *
     * [YYYY.MM.DD HH:MM:SS SIGNATURE PID] LOG_LEVEL message
    */
2285 2286
    time(&stTime);
    localtime_r(&stTime, &stTm);
2287
    virBufferAsprintf(&buf, "[%d.%02d.%02d %02d:%02d:%02d %s %d] ",
2288 2289 2290 2291 2292 2293
                      (1900 + stTm.tm_year),
                      (1 + stTm.tm_mon),
                      stTm.tm_mday,
                      stTm.tm_hour,
                      stTm.tm_min,
                      stTm.tm_sec,
2294 2295
                      SIGN_NAME,
                      (int) getpid());
2296 2297 2298 2299 2300 2301 2302 2303 2304 2305 2306 2307 2308 2309 2310 2311 2312 2313 2314 2315
    switch (log_level) {
        case VSH_ERR_DEBUG:
            lvl = LVL_DEBUG;
            break;
        case VSH_ERR_INFO:
            lvl = LVL_INFO;
            break;
        case VSH_ERR_NOTICE:
            lvl = LVL_INFO;
            break;
        case VSH_ERR_WARNING:
            lvl = LVL_WARNING;
            break;
        case VSH_ERR_ERROR:
            lvl = LVL_ERROR;
            break;
        default:
            lvl = LVL_DEBUG;
            break;
    }
2316 2317 2318
    virBufferAsprintf(&buf, "%s ", lvl);
    virBufferVasprintf(&buf, msg_format, ap);
    virBufferAddChar(&buf, '\n');
2319

2320 2321
    if (virBufferError(&buf))
        goto error;
2322

2323 2324 2325 2326 2327
    str = virBufferContentAndReset(&buf);
    len = strlen(str);
    if (len > 1 && str[len - 2] == '\n') {
        str[len - 1] = '\0';
        len--;
2328
    }
2329

2330 2331 2332 2333 2334 2335 2336 2337 2338 2339 2340
    /* write log */
    if (safewrite(ctl->log_fd, str, len) < 0)
        goto error;

    return;

error:
    vshCloseLogFile(ctl);
    vshError(ctl, "%s", _("failed to write the log file"));
    virBufferFreeAndReset(&buf);
    VIR_FREE(str);
2341 2342 2343 2344 2345 2346 2347
}

/**
 * vshCloseLogFile:
 *
 * Close log file.
 */
E
Eric Blake 已提交
2348
void
2349 2350
vshCloseLogFile(vshControl *ctl)
{
2351 2352
    char ebuf[1024];

2353
    /* log file close */
2354 2355
    if (VIR_CLOSE(ctl->log_fd) < 0) {
        vshError(ctl, _("%s: failed to write log file: %s"),
2356 2357
                 ctl->logfile ? ctl->logfile : "?",
                 virStrerror(errno, ebuf, sizeof(ebuf)));
2358 2359 2360
    }

    if (ctl->logfile) {
2361
        VIR_FREE(ctl->logfile);
2362 2363 2364 2365
        ctl->logfile = NULL;
    }
}

2366
#ifdef USE_READLINE
2367

K
Karel Zak 已提交
2368 2369 2370 2371 2372
/* -----------------
 * Readline stuff
 * -----------------
 */

2373
/*
K
Karel Zak 已提交
2374 2375
 * Generator function for command completion.  STATE lets us
 * know whether to start from scratch; without any state
2376
 * (i.e. STATE == 0), then we start at the top of the list.
K
Karel Zak 已提交
2377 2378
 */
static char *
2379 2380
vshReadlineCommandGenerator(const char *text, int state)
{
2381
    static int grp_list_index, cmd_list_index, len;
K
Karel Zak 已提交
2382
    const char *name;
2383 2384
    const vshCmdGrp *grp;
    const vshCmdDef *cmds;
K
Karel Zak 已提交
2385 2386

    if (!state) {
2387 2388
        grp_list_index = 0;
        cmd_list_index = 0;
2389
        len = strlen(text);
K
Karel Zak 已提交
2390 2391
    }

2392 2393
    grp = cmdGroups;

K
Karel Zak 已提交
2394
    /* Return the next name which partially matches from the
2395
     * command list.
K
Karel Zak 已提交
2396
     */
2397 2398 2399 2400 2401 2402 2403 2404 2405 2406 2407 2408 2409 2410
    while (grp[grp_list_index].name) {
        cmds = grp[grp_list_index].commands;

        if (cmds[cmd_list_index].name) {
            while ((name = cmds[cmd_list_index].name)) {
                cmd_list_index++;

                if (STREQLEN(name, text, len))
                    return vshStrdup(NULL, name);
            }
        } else {
            cmd_list_index = 0;
            grp_list_index++;
        }
K
Karel Zak 已提交
2411 2412 2413 2414 2415 2416 2417
    }

    /* If no names matched, then return NULL. */
    return NULL;
}

static char *
2418 2419
vshReadlineOptionsGenerator(const char *text, int state)
{
K
Karel Zak 已提交
2420
    static int list_index, len;
2421
    static const vshCmdDef *cmd = NULL;
K
Karel Zak 已提交
2422
    const char *name;
K
Karel Zak 已提交
2423 2424 2425 2426 2427 2428 2429 2430 2431

    if (!state) {
        /* determine command name */
        char *p;
        char *cmdname;

        if (!(p = strchr(rl_line_buffer, ' ')))
            return NULL;

2432
        cmdname = vshCalloc(NULL, (p - rl_line_buffer) + 1, 1);
2433
        memcpy(cmdname, rl_line_buffer, p - rl_line_buffer);
K
Karel Zak 已提交
2434 2435 2436

        cmd = vshCmddefSearch(cmdname);
        list_index = 0;
2437
        len = strlen(text);
2438
        VIR_FREE(cmdname);
K
Karel Zak 已提交
2439 2440 2441 2442
    }

    if (!cmd)
        return NULL;
2443

2444 2445 2446
    if (!cmd->opts)
        return NULL;

K
Karel Zak 已提交
2447
    while ((name = cmd->opts[list_index].name)) {
2448
        const vshCmdOptDef *opt = &cmd->opts[list_index];
K
Karel Zak 已提交
2449
        char *res;
2450

K
Karel Zak 已提交
2451
        list_index++;
2452

2453
        if (opt->type == VSH_OT_DATA || opt->type == VSH_OT_ARGV)
K
Karel Zak 已提交
2454 2455
            /* ignore non --option */
            continue;
2456

K
Karel Zak 已提交
2457
        if (len > 2) {
2458
            if (STRNEQLEN(name, text + 2, len - 2))
K
Karel Zak 已提交
2459 2460
                continue;
        }
2461
        res = vshMalloc(NULL, strlen(name) + 3);
2462
        snprintf(res, strlen(name) + 3,  "--%s", name);
K
Karel Zak 已提交
2463 2464 2465 2466 2467 2468 2469 2470
        return res;
    }

    /* If no names matched, then return NULL. */
    return NULL;
}

static char **
2471 2472 2473
vshReadlineCompletion(const char *text, int start,
                      int end ATTRIBUTE_UNUSED)
{
K
Karel Zak 已提交
2474 2475
    char **matches = (char **) NULL;

2476
    if (start == 0)
K
Karel Zak 已提交
2477
        /* command name generator */
2478
        matches = rl_completion_matches(text, vshReadlineCommandGenerator);
K
Karel Zak 已提交
2479 2480
    else
        /* commands options */
2481
        matches = rl_completion_matches(text, vshReadlineOptionsGenerator);
K
Karel Zak 已提交
2482 2483 2484 2485
    return matches;
}


2486 2487
static int
vshReadlineInit(vshControl *ctl)
2488
{
2489 2490
    char *userdir = NULL;

K
Karel Zak 已提交
2491 2492 2493 2494 2495
    /* Allow conditional parsing of the ~/.inputrc file. */
    rl_readline_name = "virsh";

    /* Tell the completer that we want a crack first. */
    rl_attempted_completion_function = vshReadlineCompletion;
2496 2497 2498

    /* Limit the total size of the history buffer */
    stifle_history(500);
2499

2500
    /* Prepare to read/write history from/to the $XDG_CACHE_HOME/virsh/history file */
2501
    userdir = virGetUserCacheDirectory();
2502

2503 2504
    if (userdir == NULL) {
        vshError(ctl, "%s", _("Could not determine home directory"));
2505
        return -1;
2506
    }
2507

2508
    if (virAsprintf(&ctl->historydir, "%s/virsh", userdir) < 0) {
2509
        vshError(ctl, "%s", _("Out of memory"));
2510
        VIR_FREE(userdir);
2511 2512 2513 2514 2515
        return -1;
    }

    if (virAsprintf(&ctl->historyfile, "%s/history", ctl->historydir) < 0) {
        vshError(ctl, "%s", _("Out of memory"));
2516
        VIR_FREE(userdir);
2517 2518 2519
        return -1;
    }

2520
    VIR_FREE(userdir);
2521 2522 2523 2524 2525 2526 2527

    read_history(ctl->historyfile);

    return 0;
}

static void
2528
vshReadlineDeinit(vshControl *ctl)
2529 2530
{
    if (ctl->historyfile != NULL) {
2531 2532
        if (virFileMakePathWithMode(ctl->historydir, 0755) < 0 &&
            errno != EEXIST) {
2533 2534
            char ebuf[1024];
            vshError(ctl, _("Failed to create '%s': %s"),
2535
                     ctl->historydir, virStrerror(errno, ebuf, sizeof(ebuf)));
E
Eric Blake 已提交
2536
        } else {
2537
            write_history(ctl->historyfile);
E
Eric Blake 已提交
2538
        }
2539 2540
    }

2541 2542
    VIR_FREE(ctl->historydir);
    VIR_FREE(ctl->historyfile);
K
Karel Zak 已提交
2543 2544
}

2545
static char *
2546
vshReadline(vshControl *ctl ATTRIBUTE_UNUSED, const char *prompt)
2547
{
2548
    return readline(prompt);
2549 2550
}

2551
#else /* !USE_READLINE */
2552

2553
static int
2554
vshReadlineInit(vshControl *ctl ATTRIBUTE_UNUSED)
2555 2556 2557 2558 2559
{
    /* empty */
    return 0;
}

2560
static void
2561
vshReadlineDeinit(vshControl *ctl ATTRIBUTE_UNUSED)
2562 2563 2564 2565 2566
{
    /* empty */
}

static char *
2567
vshReadline(vshControl *ctl, const char *prompt)
2568 2569 2570 2571 2572
{
    char line[1024];
    char *r;
    int len;

2573 2574
    fputs(prompt, stdout);
    r = fgets(line, sizeof(line), stdin);
2575 2576 2577
    if (r == NULL) return NULL; /* EOF */

    /* Chomp trailing \n */
2578
    len = strlen(r);
2579 2580 2581
    if (len > 0 && r[len-1] == '\n')
        r[len-1] = '\0';

2582
    return vshStrdup(ctl, r);
2583 2584
}

2585
#endif /* !USE_READLINE */
2586

2587 2588 2589 2590 2591 2592
static void
vshDeinitTimer(int timer ATTRIBUTE_UNUSED, void *opaque ATTRIBUTE_UNUSED)
{
    /* nothing to be done here */
}

K
Karel Zak 已提交
2593
/*
J
Jim Meyering 已提交
2594
 * Deinitialize virsh
K
Karel Zak 已提交
2595
 */
E
Eric Blake 已提交
2596
static bool
2597
vshDeinit(vshControl *ctl)
2598
{
2599
    vshReadlineDeinit(ctl);
2600
    vshCloseLogFile(ctl);
2601
    VIR_FREE(ctl->name);
K
Karel Zak 已提交
2602
    if (ctl->conn) {
2603 2604 2605
        int ret;
        if ((ret = virConnectClose(ctl->conn)) != 0) {
            vshError(ctl, _("Failed to disconnect from the hypervisor, %d leaked reference(s)"), ret);
K
Karel Zak 已提交
2606 2607
        }
    }
D
Daniel P. Berrange 已提交
2608 2609
    virResetLastError();

J
Jiri Denemark 已提交
2610
    if (ctl->eventLoopStarted) {
2611 2612 2613 2614
        int timer;

        virMutexLock(&ctl->lock);
        ctl->quit = true;
J
Jiri Denemark 已提交
2615
        /* HACK: Add a dummy timeout to break event loop */
2616 2617 2618 2619 2620
        timer = virEventAddTimeout(0, vshDeinitTimer, NULL, NULL);
        virMutexUnlock(&ctl->lock);

        virThreadJoin(&ctl->eventLoop);

J
Jiri Denemark 已提交
2621 2622 2623 2624 2625 2626
        if (timer != -1)
            virEventRemoveTimeout(timer);

        ctl->eventLoopStarted = false;
    }

2627 2628
    virMutexDestroy(&ctl->lock);

E
Eric Blake 已提交
2629
    return true;
K
Karel Zak 已提交
2630
}
2631

K
Karel Zak 已提交
2632 2633 2634
/*
 * Print usage
 */
E
Eric Blake 已提交
2635
static void
2636
vshUsage(void)
2637
{
2638
    const vshCmdGrp *grp;
2639
    const vshCmdDef *cmd;
2640

L
Lai Jiangshan 已提交
2641 2642
    fprintf(stdout, _("\n%s [options]... [<command_string>]"
                      "\n%s [options]... <command> [args...]\n\n"
2643
                      "  options:\n"
2644
                      "    -c | --connect=URI      hypervisor connection URI\n"
2645
                      "    -r | --readonly         connect readonly\n"
2646
                      "    -d | --debug=NUM        debug level [0-4]\n"
2647 2648 2649
                      "    -h | --help             this help\n"
                      "    -q | --quiet            quiet mode\n"
                      "    -t | --timing           print timing information\n"
2650 2651 2652 2653 2654
                      "    -l | --log=FILE         output logging to file\n"
                      "    -v                      short version\n"
                      "    -V                      long version\n"
                      "         --version[=TYPE]   version, TYPE is short or long (default short)\n"
                      "    -e | --escape <char>    set escape sequence for console\n\n"
2655
                      "  commands (non interactive mode):\n\n"), progname, progname);
2656

2657
    for (grp = cmdGroups; grp->name; grp++) {
E
Eric Blake 已提交
2658 2659 2660 2661 2662
        fprintf(stdout, _(" %s (help keyword '%s')\n"),
                grp->name, grp->keyword);
        for (cmd = grp->commands; cmd->name; cmd++) {
            if (cmd->flags & VSH_CMD_FLAG_ALIAS)
                continue;
2663
            fprintf(stdout,
E
Eric Blake 已提交
2664 2665 2666
                    "    %-30s %s\n", cmd->name,
                    _(vshCmddefGetInfo(cmd, "help")));
        }
2667 2668 2669 2670 2671
        fprintf(stdout, "\n");
    }

    fprintf(stdout, "%s",
            _("\n  (specify help <group> for details about the commands in the group)\n"));
2672 2673 2674
    fprintf(stdout, "%s",
            _("\n  (specify help <command> for details about the command)\n\n"));
    return;
K
Karel Zak 已提交
2675 2676
}

2677 2678 2679 2680 2681 2682 2683 2684 2685 2686
/*
 * Show version and options compiled in
 */
static void
vshShowVersion(vshControl *ctl ATTRIBUTE_UNUSED)
{
    /* FIXME - list a copyright blurb, as in GNU programs?  */
    vshPrint(ctl, _("Virsh command line tool of libvirt %s\n"), VERSION);
    vshPrint(ctl, _("See web site at %s\n\n"), "http://libvirt.org/");

L
Laine Stump 已提交
2687 2688
    vshPrint(ctl, "%s", _("Compiled with support for:\n"));
    vshPrint(ctl, "%s", _(" Hypervisors:"));
2689
#ifdef WITH_QEMU
2690
    vshPrint(ctl, " QEMU/KVM");
2691
#endif
D
Doug Goldstein 已提交
2692 2693 2694
#ifdef WITH_LXC
    vshPrint(ctl, " LXC");
#endif
2695 2696 2697
#ifdef WITH_UML
    vshPrint(ctl, " UML");
#endif
D
Doug Goldstein 已提交
2698 2699 2700 2701 2702 2703
#ifdef WITH_XEN
    vshPrint(ctl, " Xen");
#endif
#ifdef WITH_LIBXL
    vshPrint(ctl, " LibXL");
#endif
2704 2705 2706
#ifdef WITH_OPENVZ
    vshPrint(ctl, " OpenVZ");
#endif
D
Doug Goldstein 已提交
2707 2708
#ifdef WITH_VMWARE
    vshPrint(ctl, " VMWare");
2709
#endif
D
Doug Goldstein 已提交
2710 2711
#ifdef WITH_PHYP
    vshPrint(ctl, " PHYP");
2712
#endif
D
Doug Goldstein 已提交
2713 2714
#ifdef WITH_VBOX
    vshPrint(ctl, " VirtualBox");
2715 2716 2717 2718
#endif
#ifdef WITH_ESX
    vshPrint(ctl, " ESX");
#endif
D
Doug Goldstein 已提交
2719 2720
#ifdef WITH_HYPERV
    vshPrint(ctl, " Hyper-V");
2721
#endif
D
Doug Goldstein 已提交
2722 2723
#ifdef WITH_XENAPI
    vshPrint(ctl, " XenAPI");
2724 2725 2726 2727 2728 2729
#endif
#ifdef WITH_TEST
    vshPrint(ctl, " Test");
#endif
    vshPrint(ctl, "\n");

L
Laine Stump 已提交
2730
    vshPrint(ctl, "%s", _(" Networking:"));
2731 2732 2733 2734 2735 2736 2737 2738 2739
#ifdef WITH_REMOTE
    vshPrint(ctl, " Remote");
#endif
#ifdef WITH_NETWORK
    vshPrint(ctl, " Network");
#endif
#ifdef WITH_BRIDGE
    vshPrint(ctl, " Bridging");
#endif
2740
#if defined(WITH_INTERFACE)
D
Doug Goldstein 已提交
2741
    vshPrint(ctl, " Interface");
2742 2743
# if defined(WITH_NETCF)
    vshPrint(ctl, " netcf");
2744
# elif defined(WITH_UDEV)
2745
    vshPrint(ctl, " udev");
2746
# endif
2747 2748 2749 2750 2751 2752 2753 2754 2755
#endif
#ifdef WITH_NWFILTER
    vshPrint(ctl, " Nwfilter");
#endif
#ifdef WITH_VIRTUALPORT
    vshPrint(ctl, " VirtualPort");
#endif
    vshPrint(ctl, "\n");

L
Laine Stump 已提交
2756
    vshPrint(ctl, "%s", _(" Storage:"));
2757 2758 2759 2760 2761 2762 2763 2764 2765 2766 2767 2768 2769 2770 2771 2772 2773 2774 2775 2776
#ifdef WITH_STORAGE_DIR
    vshPrint(ctl, " Dir");
#endif
#ifdef WITH_STORAGE_DISK
    vshPrint(ctl, " Disk");
#endif
#ifdef WITH_STORAGE_FS
    vshPrint(ctl, " Filesystem");
#endif
#ifdef WITH_STORAGE_SCSI
    vshPrint(ctl, " SCSI");
#endif
#ifdef WITH_STORAGE_MPATH
    vshPrint(ctl, " Multipath");
#endif
#ifdef WITH_STORAGE_ISCSI
    vshPrint(ctl, " iSCSI");
#endif
#ifdef WITH_STORAGE_LVM
    vshPrint(ctl, " LVM");
2777 2778 2779
#endif
#ifdef WITH_STORAGE_RBD
    vshPrint(ctl, " RBD");
2780 2781 2782
#endif
#ifdef WITH_STORAGE_SHEEPDOG
    vshPrint(ctl, " Sheepdog");
2783 2784 2785
#endif
    vshPrint(ctl, "\n");

2786
    vshPrint(ctl, "%s", _(" Miscellaneous:"));
2787 2788 2789
#ifdef WITH_LIBVIRTD
    vshPrint(ctl, " Daemon");
#endif
2790 2791 2792 2793 2794 2795 2796 2797 2798 2799 2800 2801 2802 2803 2804 2805 2806 2807 2808 2809 2810 2811 2812 2813 2814 2815 2816 2817 2818 2819 2820 2821 2822 2823 2824 2825 2826 2827 2828 2829 2830
#ifdef WITH_NODE_DEVICES
    vshPrint(ctl, " Nodedev");
#endif
#ifdef WITH_SECDRIVER_APPARMOR
    vshPrint(ctl, " AppArmor");
#endif
#ifdef WITH_SECDRIVER_SELINUX
    vshPrint(ctl, " SELinux");
#endif
#ifdef WITH_SECRETS
    vshPrint(ctl, " Secrets");
#endif
#ifdef ENABLE_DEBUG
    vshPrint(ctl, " Debug");
#endif
#ifdef WITH_DTRACE_PROBES
    vshPrint(ctl, " DTrace");
#endif
#ifdef USE_READLINE
    vshPrint(ctl, " Readline");
#endif
#ifdef WITH_DRIVER_MODULES
    vshPrint(ctl, " Modular");
#endif
    vshPrint(ctl, "\n");
}

static bool
vshAllowedEscapeChar(char c)
{
    /* Allowed escape characters:
     * a-z A-Z @ [ \ ] ^ _
     */
    return ('a' <= c && c <= 'z') ||
        ('@' <= c && c <= '_');
}

/*
 * argv[]:  virsh [options] [command]
 *
 */
E
Eric Blake 已提交
2831
static bool
2832 2833
vshParseArgv(vshControl *ctl, int argc, char **argv)
{
2834
    int arg, len, debug;
2835 2836 2837 2838 2839 2840 2841 2842 2843 2844 2845 2846 2847 2848 2849 2850 2851 2852 2853
    struct option opt[] = {
        {"debug", required_argument, NULL, 'd'},
        {"help", no_argument, NULL, 'h'},
        {"quiet", no_argument, NULL, 'q'},
        {"timing", no_argument, NULL, 't'},
        {"version", optional_argument, NULL, 'v'},
        {"connect", required_argument, NULL, 'c'},
        {"readonly", no_argument, NULL, 'r'},
        {"log", required_argument, NULL, 'l'},
        {"escape", required_argument, NULL, 'e'},
        {NULL, 0, NULL, 0}
    };

    /* Standard (non-command) options. The leading + ensures that no
     * argument reordering takes place, so that command options are
     * not confused with top-level virsh options. */
    while ((arg = getopt_long(argc, argv, "+d:hqtc:vVrl:e:", opt, NULL)) != -1) {
        switch (arg) {
        case 'd':
2854
            if (virStrToLong_i(optarg, NULL, 10, &debug) < 0) {
2855 2856 2857
                vshError(ctl, "%s", _("option -d takes a numeric argument"));
                exit(EXIT_FAILURE);
            }
2858 2859 2860 2861 2862
            if (debug < VSH_ERR_DEBUG || debug > VSH_ERR_ERROR)
                vshError(ctl, _("ignoring debug level %d out of range [%d-%d]"),
                         debug, VSH_ERR_DEBUG, VSH_ERR_ERROR);
            else
                ctl->debug = debug;
2863 2864 2865 2866 2867 2868 2869 2870 2871 2872 2873 2874 2875 2876 2877 2878 2879 2880 2881 2882 2883 2884 2885 2886 2887 2888 2889 2890 2891 2892 2893 2894 2895 2896 2897 2898 2899 2900 2901 2902 2903 2904 2905 2906 2907 2908 2909 2910 2911 2912 2913 2914 2915 2916 2917 2918 2919 2920 2921 2922 2923 2924 2925 2926 2927 2928 2929 2930 2931 2932
            break;
        case 'h':
            vshUsage();
            exit(EXIT_SUCCESS);
            break;
        case 'q':
            ctl->quiet = true;
            break;
        case 't':
            ctl->timing = true;
            break;
        case 'c':
            ctl->name = vshStrdup(ctl, optarg);
            break;
        case 'v':
            if (STRNEQ_NULLABLE(optarg, "long")) {
                puts(VERSION);
                exit(EXIT_SUCCESS);
            }
            /* fall through */
        case 'V':
            vshShowVersion(ctl);
            exit(EXIT_SUCCESS);
        case 'r':
            ctl->readonly = true;
            break;
        case 'l':
            ctl->logfile = vshStrdup(ctl, optarg);
            break;
        case 'e':
            len = strlen(optarg);

            if ((len == 2 && *optarg == '^' &&
                 vshAllowedEscapeChar(optarg[1])) ||
                (len == 1 && *optarg != '^')) {
                ctl->escapeChar = optarg;
            } else {
                vshError(ctl, _("Invalid string '%s' for escape sequence"),
                         optarg);
                exit(EXIT_FAILURE);
            }
            break;
        default:
            vshError(ctl, _("unsupported option '-%c'. See --help."), arg);
            exit(EXIT_FAILURE);
        }
    }

    if (argc > optind) {
        /* parse command */
        ctl->imode = false;
        if (argc - optind == 1) {
            vshDebug(ctl, VSH_ERR_INFO, "commands: \"%s\"\n", argv[optind]);
            return vshCommandStringParse(ctl, argv[optind]);
        } else {
            return vshCommandArgvParse(ctl, argc - optind, argv + optind);
        }
    }
    return true;
}

static const vshCmdDef virshCmds[] = {
    {"cd", cmdCd, opts_cd, info_cd, VSH_CMD_FLAG_NOCONNECT},
    {"echo", cmdEcho, opts_echo, info_echo, VSH_CMD_FLAG_NOCONNECT},
    {"exit", cmdQuit, NULL, info_quit, VSH_CMD_FLAG_NOCONNECT},
    {"help", cmdHelp, opts_help, info_help, VSH_CMD_FLAG_NOCONNECT},
    {"pwd", cmdPwd, NULL, info_pwd, VSH_CMD_FLAG_NOCONNECT},
    {"quit", cmdQuit, NULL, info_quit, VSH_CMD_FLAG_NOCONNECT},
    {NULL, NULL, NULL, NULL, 0}
};
2933

2934 2935 2936 2937 2938 2939 2940 2941 2942 2943 2944 2945 2946 2947 2948
static const vshCmdGrp cmdGroups[] = {
    {VSH_CMD_GRP_DOM_MANAGEMENT, "domain", domManagementCmds},
    {VSH_CMD_GRP_DOM_MONITORING, "monitor", domMonitoringCmds},
    {VSH_CMD_GRP_HOST_AND_HV, "host", hostAndHypervisorCmds},
    {VSH_CMD_GRP_IFACE, "interface", ifaceCmds},
    {VSH_CMD_GRP_NWFILTER, "filter", nwfilterCmds},
    {VSH_CMD_GRP_NETWORK, "network", networkCmds},
    {VSH_CMD_GRP_NODEDEV, "nodedev", nodedevCmds},
    {VSH_CMD_GRP_SECRET, "secret", secretCmds},
    {VSH_CMD_GRP_SNAPSHOT, "snapshot", snapshotCmds},
    {VSH_CMD_GRP_STORAGE_POOL, "pool", storagePoolCmds},
    {VSH_CMD_GRP_STORAGE_VOL, "volume", storageVolCmds},
    {VSH_CMD_GRP_VIRSH, "virsh", virshCmds},
    {NULL, NULL, NULL}
};
K
Karel Zak 已提交
2949

2950 2951 2952 2953
int
main(int argc, char **argv)
{
    vshControl _ctl, *ctl = &_ctl;
2954
    char *defaultConn;
E
Eric Blake 已提交
2955
    bool ret = true;
K
Karel Zak 已提交
2956

2957 2958 2959
    memset(ctl, 0, sizeof(vshControl));
    ctl->imode = true;          /* default is interactive mode */
    ctl->log_fd = -1;           /* Initialize log file descriptor */
J
Jiri Denemark 已提交
2960
    ctl->debug = VSH_DEBUG_DEFAULT;
E
Eric Blake 已提交
2961
    ctl->escapeChar = "^]";     /* Same default as telnet */
2962

2963

2964 2965
    if (!setlocale(LC_ALL, "")) {
        perror("setlocale");
2966
        /* failure to setup locale is not fatal */
2967
    }
2968
    if (!bindtextdomain(PACKAGE, LOCALEDIR)) {
2969
        perror("bindtextdomain");
E
Eric Blake 已提交
2970
        return EXIT_FAILURE;
2971
    }
2972
    if (!textdomain(PACKAGE)) {
2973
        perror("textdomain");
E
Eric Blake 已提交
2974
        return EXIT_FAILURE;
2975 2976
    }

2977 2978 2979 2980 2981
    if (virMutexInit(&ctl->lock) < 0) {
        vshError(ctl, "%s", _("Failed to initialize mutex"));
        return EXIT_FAILURE;
    }

2982 2983 2984 2985 2986
    if (virInitialize() < 0) {
        vshError(ctl, "%s", _("Failed to initialize libvirt"));
        return EXIT_FAILURE;
    }

2987
    if (!(progname = strrchr(argv[0], '/')))
K
Karel Zak 已提交
2988 2989 2990
        progname = argv[0];
    else
        progname++;
2991

2992
    if ((defaultConn = getenv("VIRSH_DEFAULT_CONNECT_URI"))) {
E
Eric Blake 已提交
2993
        ctl->name = vshStrdup(ctl, defaultConn);
2994 2995
    }

D
Daniel P. Berrange 已提交
2996 2997
    if (!vshParseArgv(ctl, argc, argv)) {
        vshDeinit(ctl);
K
Karel Zak 已提交
2998
        exit(EXIT_FAILURE);
D
Daniel P. Berrange 已提交
2999
    }
3000

D
Daniel P. Berrange 已提交
3001 3002
    if (!vshInit(ctl)) {
        vshDeinit(ctl);
K
Karel Zak 已提交
3003
        exit(EXIT_FAILURE);
D
Daniel P. Berrange 已提交
3004
    }
3005

K
Karel Zak 已提交
3006
    if (!ctl->imode) {
3007
        ret = vshCommandRun(ctl, ctl->cmd);
3008
    } else {
K
Karel Zak 已提交
3009 3010
        /* interactive mode */
        if (!ctl->quiet) {
K
Karel Zak 已提交
3011
            vshPrint(ctl,
3012
                     _("Welcome to %s, the virtualization interactive terminal.\n\n"),
3013
                     progname);
J
Jim Meyering 已提交
3014
            vshPrint(ctl, "%s",
3015
                     _("Type:  'help' for help with commands\n"
3016
                       "       'quit' to quit\n\n"));
K
Karel Zak 已提交
3017
        }
3018 3019 3020 3021 3022 3023

        if (vshReadlineInit(ctl) < 0) {
            vshDeinit(ctl);
            exit(EXIT_FAILURE);
        }

K
Karel Zak 已提交
3024
        do {
3025
            const char *prompt = ctl->readonly ? VSH_PROMPT_RO : VSH_PROMPT_RW;
3026
            ctl->cmdstr =
3027
                vshReadline(ctl, prompt);
3028 3029
            if (ctl->cmdstr == NULL)
                break;          /* EOF */
K
Karel Zak 已提交
3030
            if (*ctl->cmdstr) {
3031
#if USE_READLINE
K
Karel Zak 已提交
3032
                add_history(ctl->cmdstr);
3033
#endif
3034
                if (vshCommandStringParse(ctl, ctl->cmdstr))
K
Karel Zak 已提交
3035 3036
                    vshCommandRun(ctl, ctl->cmd);
            }
3037
            VIR_FREE(ctl->cmdstr);
3038
        } while (ctl->imode);
K
Karel Zak 已提交
3039

3040 3041
        if (ctl->cmdstr == NULL)
            fputc('\n', stdout);        /* line break after alone prompt */
K
Karel Zak 已提交
3042
    }
3043

K
Karel Zak 已提交
3044 3045
    vshDeinit(ctl);
    exit(ret ? EXIT_SUCCESS : EXIT_FAILURE);
3046
}