network_conf.c 119.7 KB
Newer Older
1 2 3
/*
 * network_conf.c: network XML handling
 *
4
 * Copyright (C) 2006-2013 Red Hat, Inc.
5 6 7 8 9 10 11 12 13 14 15 16 17
 * Copyright (C) 2006-2008 Daniel P. Berrange
 *
 * 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
18
 * License along with this library.  If not, see
O
Osier Yang 已提交
19
 * <http://www.gnu.org/licenses/>.
20 21 22 23 24 25
 *
 * Author: Daniel P. Berrange <berrange@redhat.com>
 */

#include <config.h>

26
#include <unistd.h>
27 28
#include <arpa/inet.h>
#include <sys/types.h>
A
Atsushi SAKAI 已提交
29
#include <sys/stat.h>
30
#include <fcntl.h>
31
#include <string.h>
32 33
#include <dirent.h>

34
#include "virerror.h"
35
#include "datatypes.h"
36
#include "network_conf.h"
37 38
#include "netdev_vport_profile_conf.h"
#include "netdev_bandwidth_conf.h"
39
#include "netdev_vlan_conf.h"
40
#include "viralloc.h"
41
#include "virxml.h"
42
#include "viruuid.h"
43
#include "virutil.h"
44
#include "virbuffer.h"
45
#include "c-ctype.h"
E
Eric Blake 已提交
46
#include "virfile.h"
47

48
#define MAX_BRIDGE_ID 256
49
#define VIR_FROM_THIS VIR_FROM_NETWORK
50 51 52
#define NEXT_FREE_CLASS_ID 3
/* currently, /sbin/tc implementation allows up to 16 bits for minor class size */
#define CLASS_ID_BITMAP_SIZE (1<<16)
53

54 55
VIR_ENUM_IMPL(virNetworkForward,
              VIR_NETWORK_FORWARD_LAST,
56 57 58 59 60 61
              "none", "nat", "route", "bridge", "private", "vepa", "passthrough", "hostdev")

VIR_ENUM_DECL(virNetworkForwardHostdevDevice)
VIR_ENUM_IMPL(virNetworkForwardHostdevDevice,
              VIR_NETWORK_FORWARD_HOSTDEV_DEVICE_LAST,
              "none", "pci", "netdev")
62

63
virNetworkObjPtr virNetworkFindByUUID(const virNetworkObjListPtr nets,
64 65
                                      const unsigned char *uuid)
{
66 67
    unsigned int i;

68 69
    for (i = 0 ; i < nets->count ; i++) {
        virNetworkObjLock(nets->objs[i]);
70 71
        if (!memcmp(nets->objs[i]->def->uuid, uuid, VIR_UUID_BUFLEN))
            return nets->objs[i];
72 73
        virNetworkObjUnlock(nets->objs[i]);
    }
74 75 76 77

    return NULL;
}

78
virNetworkObjPtr virNetworkFindByName(const virNetworkObjListPtr nets,
79 80
                                      const char *name)
{
81 82
    unsigned int i;

83 84
    for (i = 0 ; i < nets->count ; i++) {
        virNetworkObjLock(nets->objs[i]);
85 86
        if (STREQ(nets->objs[i]->def->name, name))
            return nets->objs[i];
87 88
        virNetworkObjUnlock(nets->objs[i]);
    }
89 90 91 92 93

    return NULL;
}


94 95 96 97 98
static void
virPortGroupDefClear(virPortGroupDefPtr def)
{
    VIR_FREE(def->name);
    VIR_FREE(def->virtPortProfile);
99
    virNetDevBandwidthFree(def->bandwidth);
100
    virNetDevVlanClear(&def->vlan);
101
    def->bandwidth = NULL;
102 103 104 105 106
}

static void
virNetworkForwardIfDefClear(virNetworkForwardIfDefPtr def)
{
107 108
    if (def->type == VIR_NETWORK_FORWARD_HOSTDEV_DEVICE_NETDEV)
        VIR_FREE(def->device.dev);
109 110
}

111 112 113 114 115 116
static void
virNetworkForwardPfDefClear(virNetworkForwardPfDefPtr def)
{
    VIR_FREE(def->dev);
}

117 118 119 120 121 122 123
static void
virNetworkDHCPHostDefClear(virNetworkDHCPHostDefPtr def)
{
    VIR_FREE(def->mac);
    VIR_FREE(def->name);
}

124 125
static void
virNetworkIpDefClear(virNetworkIpDefPtr def)
126 127 128 129
{
    VIR_FREE(def->family);
    VIR_FREE(def->ranges);

130 131
    while (def->nhosts--)
        virNetworkDHCPHostDefClear(&def->hosts[def->nhosts]);
132 133 134 135 136 137

    VIR_FREE(def->hosts);
    VIR_FREE(def->tftproot);
    VIR_FREE(def->bootfile);
}

138 139
static void
virNetworkDNSTxtDefClear(virNetworkDNSTxtDefPtr def)
140
{
141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167
    VIR_FREE(def->name);
    VIR_FREE(def->value);
}

static void
virNetworkDNSHostDefClear(virNetworkDNSHostDefPtr def)
{
    while (def->nnames--)
        VIR_FREE(def->names[def->nnames]);
    VIR_FREE(def->names);
}

static void
virNetworkDNSSrvDefClear(virNetworkDNSSrvDefPtr def)
{
    VIR_FREE(def->domain);
    VIR_FREE(def->service);
    VIR_FREE(def->protocol);
    VIR_FREE(def->target);
}

static void
virNetworkDNSDefClear(virNetworkDNSDefPtr def)
{
    if (def->txts) {
        while (def->ntxts--)
            virNetworkDNSTxtDefClear(&def->txts[def->ntxts]);
168
        VIR_FREE(def->txts);
169 170 171 172
    }
    if (def->hosts) {
        while (def->nhosts--)
            virNetworkDNSHostDefClear(&def->hosts[def->nhosts]);
173
        VIR_FREE(def->hosts);
174 175 176 177
    }
    if (def->srvs) {
        while (def->nsrvs--)
            virNetworkDNSSrvDefClear(&def->srvs[def->nsrvs]);
178
        VIR_FREE(def->srvs);
179 180 181
    }
}

182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199
static void
virNetworkForwardDefClear(virNetworkForwardDefPtr def)
{
    int ii;

    for (ii = 0 ; ii < def->npfs && def->pfs ; ii++) {
        virNetworkForwardPfDefClear(&def->pfs[ii]);
    }
    VIR_FREE(def->pfs);

    for (ii = 0 ; ii < def->nifs && def->ifs ; ii++) {
        virNetworkForwardIfDefClear(&def->ifs[ii]);
    }
    VIR_FREE(def->ifs);
}

void
virNetworkDefFree(virNetworkDefPtr def)
200
{
201
    int ii;
202 203 204 205 206 207

    if (!def)
        return;

    VIR_FREE(def->name);
    VIR_FREE(def->bridge);
208
    VIR_FREE(def->domain);
209

210
    virNetworkForwardDefClear(&def->forward);
211

212 213
    for (ii = 0 ; ii < def->nips && def->ips ; ii++) {
        virNetworkIpDefClear(&def->ips[ii]);
214
    }
215
    VIR_FREE(def->ips);
216

217 218 219 220 221
    for (ii = 0; ii < def->nPortGroups && def->portGroups; ii++) {
        virPortGroupDefClear(&def->portGroups[ii]);
    }
    VIR_FREE(def->portGroups);

222
    virNetworkDNSDefClear(&def->dns);
223

224 225
    VIR_FREE(def->virtPortProfile);

226
    virNetDevBandwidthFree(def->bandwidth);
227
    virNetDevVlanClear(&def->vlan);
228 229 230 231 232 233 234 235 236 237
    VIR_FREE(def);
}

void virNetworkObjFree(virNetworkObjPtr net)
{
    if (!net)
        return;

    virNetworkDefFree(net->def);
    virNetworkDefFree(net->newDef);
238
    virBitmapFree(net->class_id);
239

240 241
    virMutexDestroy(&net->lock);

242 243 244
    VIR_FREE(net);
}

245 246 247 248 249 250 251 252 253 254 255
void virNetworkObjListFree(virNetworkObjListPtr nets)
{
    unsigned int i;

    for (i = 0 ; i < nets->count ; i++)
        virNetworkObjFree(nets->objs[i]);

    VIR_FREE(nets->objs);
    nets->count = 0;
}

256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271
/*
 * virNetworkObjAssignDef:
 * @network: the network object to update
 * @def: the new NetworkDef (will be consumed by this function iff successful)
 * @live: is this new def the "live" version, or the "persistent" version
 *
 * Replace the appropriate copy of the given network's NetworkDef
 * with def. Use "live" and current state of the network to determine
 * which to replace.
 *
 * Returns 0 on success, -1 on failure.
 */
int
virNetworkObjAssignDef(virNetworkObjPtr network,
                       const virNetworkDefPtr def,
                       bool live)
272
{
273 274
    if (virNetworkObjIsActive(network)) {
        if (live) {
275 276
            virNetworkDefFree(network->def);
            network->def = def;
277 278
        } else if (network->persistent) {
            /* save current configuration to be restored on network shutdown */
279
            virNetworkDefFree(network->newDef);
280
            network->newDef = def;
281 282 283 284 285
        } else {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("cannot save persistent config of transient "
                             "network '%s'"), network->def->name);
            return -1;
286
        }
287
    } else if (!live) {
288
        virNetworkDefFree(network->newDef);
289
        virNetworkDefFree(network->def);
290
        network->newDef = NULL;
291 292 293 294 295 296 297 298 299
        network->def = def;
    } else {
        virReportError(VIR_ERR_OPERATION_INVALID,
                       _("cannot save live config of inactive "
                         "network '%s'"), network->def->name);
        return -1;
    }
    return 0;
}
300

301 302 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 318 319 320 321 322
/*
 * virNetworkAssignDef:
 * @nets: list of all networks
 * @def: the new NetworkDef (will be consumed by this function iff successful)
 * @live: is this new def the "live" version, or the "persistent" version
 *
 * Either replace the appropriate copy of the NetworkDef with name
 * matching def->name or, if not found, create a new NetworkObj with
 * def. For an existing network, use "live" and current state of the
 * network to determine which to replace.
 *
 * Returns -1 on failure, 0 on success.
 */
virNetworkObjPtr
virNetworkAssignDef(virNetworkObjListPtr nets,
                    const virNetworkDefPtr def,
                    bool live)
{
    virNetworkObjPtr network;

    if ((network = virNetworkFindByName(nets, def->name))) {
        if (virNetworkObjAssignDef(network, def, live) < 0) {
323
            virNetworkObjUnlock(network);
324 325
            return NULL;
        }
326 327 328
        return network;
    }

329 330 331 332 333
    if (VIR_REALLOC_N(nets->objs, nets->count + 1) < 0) {
        virReportOOMError();
        return NULL;
    }

334
    if (VIR_ALLOC(network) < 0) {
335
        virReportOOMError();
336 337
        return NULL;
    }
338
    if (virMutexInit(&network->lock) < 0) {
339 340
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("cannot initialize mutex"));
341 342 343
        VIR_FREE(network);
        return NULL;
    }
344
    virNetworkObjLock(network);
345 346
    network->def = def;

347 348 349 350 351 352 353 354 355 356 357
    if (!(network->class_id = virBitmapNew(CLASS_ID_BITMAP_SIZE))) {
        virReportOOMError();
        goto error;
    }

    /* The first three class IDs are already taken */
    ignore_value(virBitmapSetBit(network->class_id, 0));
    ignore_value(virBitmapSetBit(network->class_id, 1));
    ignore_value(virBitmapSetBit(network->class_id, 2));

    network->def = def;
358 359
    nets->objs[nets->count] = network;
    nets->count++;
360 361

    return network;
362 363 364 365
error:
    virNetworkObjUnlock(network);
    virNetworkObjFree(network);
    return NULL;
366 367 368

}

369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391 392 393 394 395
/*
 * virNetworkObjSetDefTransient:
 * @network: network object pointer
 * @live: if true, run this operation even for an inactive network.
 *   this allows freely updated network->def with runtime defaults
 *   before starting the network, which will be discarded on network
 *   shutdown. Any cleanup paths need to be sure to handle newDef if
 *   the network is never started.
 *
 * Mark the active network config as transient. Ensures live-only update
 * operations do not persist past network destroy.
 *
 * Returns 0 on success, -1 on failure
 */
int
virNetworkObjSetDefTransient(virNetworkObjPtr network, bool live)
{
    if (!virNetworkObjIsActive(network) && !live)
        return 0;

    if (!network->persistent || network->newDef)
        return 0;

    network->newDef = virNetworkDefCopy(network->def, VIR_NETWORK_XML_INACTIVE);
    return network->newDef ? 0 : -1;
}

396 397 398 399 400 401 402
/* virNetworkObjUnsetDefTransient:
 *
 * This *undoes* what virNetworkObjSetDefTransient did.
 */
void
virNetworkObjUnsetDefTransient(virNetworkObjPtr network)
{
403
    if (network->newDef) {
404 405 406 407 408 409
        virNetworkDefFree(network->def);
        network->def = network->newDef;
        network->newDef = NULL;
    }
}

410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525 526
/*
 * virNetworkObjGetPersistentDef:
 * @network: network object pointer
 *
 * Return the persistent network configuration. If network is transient,
 * return the running config.
 *
 * Returns NULL on error, virNetworkDefPtr on success.
 */
virNetworkDefPtr
virNetworkObjGetPersistentDef(virNetworkObjPtr network)
{
    if (network->newDef)
        return network->newDef;
    else
        return network->def;
}

/*
 * virNetworkObjReplacePersistentDef:
 * @network: network object pointer
 * @def: new virNetworkDef to replace current persistent config
 *
 * Replace the "persistent" network configuration with the given new
 * virNetworkDef. This pays attention to whether or not the network
 * is active.
 *
 * Returns -1 on error, 0 on success
 */
int
virNetworkObjReplacePersistentDef(virNetworkObjPtr network,
                                  virNetworkDefPtr def)
{
    if (virNetworkObjIsActive(network)) {
        virNetworkDefFree(network->newDef);
        network->newDef = def;
    } else {
        virNetworkDefFree(network->def);
        network->def = def;
    }
    return 0;
}

/*
 * virNetworkDefCopy:
 * @def: NetworkDef to copy
 * @flags: VIR_NETWORK_XML_INACTIVE if appropriate
 *
 * make a deep copy of the given NetworkDef
 *
 * Returns a new NetworkDef on success, or NULL on failure.
 */
virNetworkDefPtr
virNetworkDefCopy(virNetworkDefPtr def, unsigned int flags)
{
    char *xml = NULL;
    virNetworkDefPtr newDef = NULL;

    if (!def) {
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       "%s", _("NULL NetworkDef"));
        return NULL;
    }

    /* deep copy with a format/parse cycle */
    if (!(xml = virNetworkDefFormat(def, flags)))
        goto cleanup;
    newDef = virNetworkDefParseString(xml);
cleanup:
    VIR_FREE(xml);
    return newDef;
}

/*
 * virNetworkConfigChangeSetup:
 *
 * 1) checks whether network state is consistent with the requested
 *    type of modification.
 *
 * 3) make sure there are separate "def" and "newDef" copies of
 *    networkDef if appropriate.
 *
 * Returns 0 on success, -1 on error.
 */
int
virNetworkConfigChangeSetup(virNetworkObjPtr network, unsigned int flags)
{
    bool isActive;
    int ret = -1;

    isActive = virNetworkObjIsActive(network);

    if (!isActive && (flags & VIR_NETWORK_UPDATE_AFFECT_LIVE)) {
        virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                       _("network is not running"));
        goto cleanup;
    }

    if (flags & VIR_NETWORK_UPDATE_AFFECT_CONFIG) {
        if (!network->persistent) {
            virReportError(VIR_ERR_OPERATION_INVALID, "%s",
                           _("cannot change persistent config of a "
                             "transient network"));
            goto cleanup;
        }
        /* this should already have been done by the driver, but do it
         * anyway just in case.
         */
        if (isActive && (virNetworkObjSetDefTransient(network, false) < 0))
            goto cleanup;
    }

    ret = 0;
cleanup:
    return ret;
}

527
void virNetworkRemoveInactive(virNetworkObjListPtr nets,
528 529
                              const virNetworkObjPtr net)
{
530
    unsigned int i;
531

532
    virNetworkObjUnlock(net);
533
    for (i = 0 ; i < nets->count ; i++) {
534
        virNetworkObjLock(nets->objs[i]);
535
        if (nets->objs[i] == net) {
536
            virNetworkObjUnlock(nets->objs[i]);
537
            virNetworkObjFree(nets->objs[i]);
538

539 540 541
            if (i < (nets->count - 1))
                memmove(nets->objs + i, nets->objs + i + 1,
                        sizeof(*(nets->objs)) * (nets->count - (i + 1)));
542

543 544 545 546 547 548 549
            if (VIR_REALLOC_N(nets->objs, nets->count - 1) < 0) {
                ; /* Failure to reduce memory allocation isn't fatal */
            }
            nets->count--;

            break;
        }
550
        virNetworkObjUnlock(nets->objs[i]);
551
    }
552 553
}

554 555 556 557 558 559 560 561 562 563 564 565 566 567 568 569
/* return ips[index], or NULL if there aren't enough ips */
virNetworkIpDefPtr
virNetworkDefGetIpByIndex(const virNetworkDefPtr def,
                          int family, size_t n)
{
    int ii;

    if (!def->ips || n >= def->nips)
        return NULL;

    if (family == AF_UNSPEC) {
        return &def->ips[n];
    }

    /* find the nth ip of type "family" */
    for (ii = 0; ii < def->nips; ii++) {
570
        if (VIR_SOCKET_ADDR_IS_FAMILY(&def->ips[ii].address, family)
571 572 573 574 575 576 577 578
            && (n-- <= 0)) {
            return &def->ips[ii];
        }
    }
    /* failed to find enough of the right family */
    return NULL;
}

L
Laine Stump 已提交
579 580 581
/* return number of 1 bits in netmask for the network's ipAddress,
 * or -1 on error
 */
582
int virNetworkIpDefPrefix(const virNetworkIpDefPtr def)
L
Laine Stump 已提交
583
{
584 585
    if (def->prefix > 0) {
        return def->prefix;
586 587 588
    } else if (VIR_SOCKET_ADDR_VALID(&def->netmask)) {
        return virSocketAddrGetNumNetmaskBits(&def->netmask);
    } else if (VIR_SOCKET_ADDR_IS_FAMILY(&def->address, AF_INET)) {
L
Laine Stump 已提交
589 590 591 592 593 594
        /* Return the natural prefix for the network's ip address.
         * On Linux we could use the IN_CLASSx() macros, but those
         * aren't guaranteed on all platforms, so we just deal with
         * the bits ourselves.
         */
        unsigned char octet
595
            = ntohl(def->address.data.inet4.sin_addr.s_addr) >> 24;
L
Laine Stump 已提交
596 597 598 599 600 601 602 603 604 605 606
        if ((octet & 0x80) == 0) {
            /* Class A network */
            return 8;
        } else if ((octet & 0xC0) == 0x80) {
            /* Class B network */
            return 16;
        } else if ((octet & 0xE0) == 0xC0) {
            /* Class C network */
            return 24;
        }
        return -1;
607
    } else if (VIR_SOCKET_ADDR_IS_FAMILY(&def->address, AF_INET6)) {
608
        return 64;
L
Laine Stump 已提交
609 610 611 612 613 614 615 616
    }
    return -1;
}

/* Fill in a virSocketAddr with the proper netmask for this
 * definition, based on either the definition's netmask, or its
 * prefix. Return -1 on error (and set the netmask family to AF_UNSPEC)
 */
617 618
int virNetworkIpDefNetmask(const virNetworkIpDefPtr def,
                           virSocketAddrPtr netmask)
L
Laine Stump 已提交
619
{
620
    if (VIR_SOCKET_ADDR_IS_FAMILY(&def->netmask, AF_INET)) {
L
Laine Stump 已提交
621 622 623 624
        *netmask = def->netmask;
        return 0;
    }

625
    return virSocketAddrPrefixToNetmask(virNetworkIpDefPrefix(def), netmask,
626
                                        VIR_SOCKET_ADDR_FAMILY(&def->address));
L
Laine Stump 已提交
627 628
}

629 630

static int
631 632 633
virNetworkDHCPRangeDefParseXML(const char *networkName,
                               xmlNodePtr node,
                               virNetworkDHCPRangeDefPtr range)
634 635 636 637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668 669 670 671 672 673 674
{


    char *start = NULL, *end = NULL;
    int ret = -1;

    if (!(start = virXMLPropString(node, "start"))) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("Missing 'start' attribute in dhcp range for network '%s'"),
                       networkName);
        goto cleanup;
    }
    if (virSocketAddrParse(&range->start, start, AF_UNSPEC) < 0)
        goto cleanup;

    if (!(end = virXMLPropString(node, "end"))) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("Missing 'end' attribute in dhcp range for network '%s'"),
                       networkName);
        goto cleanup;
    }
    if (virSocketAddrParse(&range->end, end, AF_UNSPEC) < 0)
        goto cleanup;

    /* do a sanity check of the range */
    if (virSocketAddrGetRange(&range->start, &range->end) < 0) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("Invalid dhcp range '%s' to '%s' in network '%s'"),
                       start, end, networkName);
        goto cleanup;
    }

    ret = 0;

cleanup:
    VIR_FREE(start);
    VIR_FREE(end);
    return ret;
}

static int
675
virNetworkDHCPHostDefParseXML(const char *networkName,
G
Gene Czarcinski 已提交
676
                              const virNetworkIpDefPtr def,
677 678 679
                              xmlNodePtr node,
                              virNetworkDHCPHostDefPtr host,
                              bool partialOkay)
680 681 682 683 684 685 686 687
{
    char *mac = NULL, *name = NULL, *ip = NULL;
    virMacAddr addr;
    virSocketAddr inaddr;
    int ret = -1;

    mac = virXMLPropString(node, "mac");
    if (mac != NULL) {
G
Gene Czarcinski 已提交
688 689 690 691 692 693 694
        if (VIR_SOCKET_ADDR_IS_FAMILY(&def->address, AF_INET6)) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("Invalid to specify MAC address '%s' "
                             "in network '%s' IPv6 static host definition"),
                           mac, networkName);
            goto cleanup;
        }
695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736
        if (virMacAddrParse(mac, &addr) < 0) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("Cannot parse MAC address '%s' in network '%s'"),
                           mac, networkName);
            goto cleanup;
        }
        if (virMacAddrIsMulticast(&addr)) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("expected unicast mac address, found "
                             "multicast '%s' in network '%s'"),
                           (const char *)mac, networkName);
            goto cleanup;
        }
    }

    name = virXMLPropString(node, "name");
    if (name && (!c_isalpha(name[0]))) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("Cannot use name address '%s' in network '%s'"),
                       name, networkName);
        goto cleanup;
    }

    ip = virXMLPropString(node, "ip");
    if (ip && (virSocketAddrParse(&inaddr, ip, AF_UNSPEC) < 0)) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("Invalid IP address in static host definition "
                         "for network '%s'"),
                       networkName);
        goto cleanup;
    }

    if (partialOkay) {
        /* for search/match, you just need one of the three */
        if (!(mac || name || ip)) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("At least one of name, mac, or ip attribute "
                             "must be specified for static host definition "
                             "in network '%s' "),
                           networkName);
        }
    } else {
G
Gene Czarcinski 已提交
737 738 739 740 741 742 743 744 745 746 747 748
        /* normal usage - you need at least name (IPv6) or one of MAC
         * address or name (IPv4)
         */
        if (VIR_SOCKET_ADDR_IS_FAMILY(&def->address, AF_INET6)) {
            if (!name) {
                virReportError(VIR_ERR_XML_ERROR,
                           _("Static host definition in IPv6 network '%s' "
                             "must have name attribute"),
                           networkName);
                goto cleanup;
            }
        } else if (!(mac || name)) {
749
            virReportError(VIR_ERR_XML_ERROR,
G
Gene Czarcinski 已提交
750
                           _("Static host definition in IPv4 network '%s' "
751 752 753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779
                             "must have mac or name attribute"),
                           networkName);
            goto cleanup;
        }
        if (!ip) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("Missing IP address in static host definition "
                             "for network '%s'"),
                           networkName);
            goto cleanup;
        }
    }

    host->mac = mac;
    mac = NULL;
    host->name = name;
    name = NULL;
    if (ip)
        host->ip = inaddr;
    ret = 0;

cleanup:
    VIR_FREE(mac);
    VIR_FREE(name);
    VIR_FREE(ip);
    return ret;
}

static int
780 781 782
virNetworkDHCPDefParseXML(const char *networkName,
                          xmlNodePtr node,
                          virNetworkIpDefPtr def)
783
{
784 785 786 787 788

    xmlNodePtr cur;

    cur = node->children;
    while (cur != NULL) {
789 790
        if (cur->type == XML_ELEMENT_NODE &&
            xmlStrEqual(cur->name, BAD_CAST "range")) {
791

792
            if (VIR_REALLOC_N(def->ranges, def->nranges + 1) < 0) {
793
                virReportOOMError();
794 795
                return -1;
            }
796 797
            if (virNetworkDHCPRangeDefParseXML(networkName, cur,
                                               &def->ranges[def->nranges]) < 0) {
798 799
                return -1;
            }
800
            def->nranges++;
801

802 803 804 805
        } else if (cur->type == XML_ELEMENT_NODE &&
            xmlStrEqual(cur->name, BAD_CAST "host")) {

            if (VIR_REALLOC_N(def->hosts, def->nhosts + 1) < 0) {
806
                virReportOOMError();
807 808
                return -1;
            }
G
Gene Czarcinski 已提交
809
            if (virNetworkDHCPHostDefParseXML(networkName, def, cur,
810 811
                                              &def->hosts[def->nhosts],
                                              false) < 0) {
812 813
                return -1;
            }
814
            def->nhosts++;
815

G
Gene Czarcinski 已提交
816 817 818
        } else if (VIR_SOCKET_ADDR_IS_FAMILY(&def->address, AF_INET) &&
                   cur->type == XML_ELEMENT_NODE &&
                   xmlStrEqual(cur->name, BAD_CAST "bootp")) {
819 820
            char *file;
            char *server;
821
            virSocketAddr inaddr;
822
            memset(&inaddr, 0, sizeof(inaddr));
823

824
            if (!(file = virXMLPropString(cur, "file"))) {
825 826 827
                cur = cur->next;
                continue;
            }
828
            server = virXMLPropString(cur, "server");
829

830
            if (server &&
831
                virSocketAddrParse(&inaddr, server, AF_UNSPEC) < 0) {
E
Eric Blake 已提交
832 833
                VIR_FREE(file);
                VIR_FREE(server);
834
                return -1;
E
Eric Blake 已提交
835
            }
836

837
            def->bootfile = file;
838
            def->bootserver = inaddr;
E
Eric Blake 已提交
839
            VIR_FREE(server);
840 841 842 843 844 845 846 847
        }

        cur = cur->next;
    }

    return 0;
}

848
static int
849 850 851 852
virNetworkDNSHostDefParseXML(const char *networkName,
                             xmlNodePtr node,
                             virNetworkDNSHostDefPtr def,
                             bool partialOkay)
853 854 855 856
{
    xmlNodePtr cur;
    char *ip;

857 858 859 860
    if (!(ip = virXMLPropString(node, "ip")) && !partialOkay) {
        virReportError(VIR_ERR_XML_DETAIL,
                       _("Missing IP address in network '%s' DNS HOST record"),
                       networkName);
861 862 863 864
        VIR_FREE(ip);
        goto error;
    }

865 866 867 868 869
    if (ip && (virSocketAddrParse(&def->ip, ip, AF_UNSPEC) < 0)) {
        virReportError(VIR_ERR_XML_DETAIL,
                       _("Invalid IP address in network '%s' DNS HOST record"),
                       networkName);
        VIR_FREE(ip);
870 871
        goto error;
    }
872
    VIR_FREE(ip);
873 874 875 876 877 878

    cur = node->children;
    while (cur != NULL) {
        if (cur->type == XML_ELEMENT_NODE &&
            xmlStrEqual(cur->name, BAD_CAST "hostname")) {
              if (cur->children != NULL) {
879
                  if (VIR_REALLOC_N(def->names, def->nnames + 1) < 0) {
880 881 882
                      virReportOOMError();
                      goto error;
                  }
883 884 885 886 887 888
                  def->names[def->nnames++] = (char *)xmlNodeGetContent(cur);
                  if (!def->names[def->nnames - 1]) {
                      virReportError(VIR_ERR_XML_DETAIL,
                                     _("Missing hostname in network '%s' DNS HOST record"),
                                     networkName);
                  }
889 890 891 892
              }
        }
        cur = cur->next;
    }
893 894 895 896 897 898
    if (def->nnames == 0 && !partialOkay) {
        virReportError(VIR_ERR_XML_DETAIL,
                       _("Missing hostname in network '%s' DNS HOST record"),
                       networkName);
        goto error;
    }
899

900 901 902 903 904 905
    if (!VIR_SOCKET_ADDR_VALID(&def->ip) && def->nnames == 0) {
        virReportError(VIR_ERR_XML_DETAIL,
                       _("Missing ip and hostname in network '%s' DNS HOST record"),
                       networkName);
        goto error;
    }
906

907
    return 0;
908 909

error:
910 911
    virNetworkDNSHostDefClear(def);
    return -1;
912 913
}

914
static int
915 916 917 918 919
virNetworkDNSSrvDefParseXML(const char *networkName,
                            xmlNodePtr node,
                            xmlXPathContextPtr ctxt,
                            virNetworkDNSSrvDefPtr def,
                            bool partialOkay)
920
{
921
    if (!(def->service = virXMLPropString(node, "service")) && !partialOkay) {
922
        virReportError(VIR_ERR_XML_DETAIL,
923 924
                       _("Missing required service attribute in DNS SRV record "
                         " of network %s"), networkName);
925 926
        goto error;
    }
927
    if (strlen(def->service) > DNS_RECORD_LENGTH_SRV) {
928
        virReportError(VIR_ERR_XML_DETAIL,
929 930
                       _("Service name '%s' in network %s is too long, limit is %d bytes"),
                       def->service, networkName, DNS_RECORD_LENGTH_SRV);
931 932 933
        goto error;
    }

934
    if (!(def->protocol = virXMLPropString(node, "protocol")) && !partialOkay) {
935
        virReportError(VIR_ERR_XML_DETAIL,
936 937 938
                       _("Missing required protocol attribute "
                         "in dns srv record '%s' of network %s"),
                       def->service, networkName);
939 940 941 942
        goto error;
    }

    /* Check whether protocol value is the supported one */
943
    if (STRNEQ(def->protocol, "tcp") && (STRNEQ(def->protocol, "udp"))) {
944
        virReportError(VIR_ERR_XML_DETAIL,
945 946 947
                       _("Invalid protocol attribute value '%s' "
                         " in DNS SRV record of network %s"),
                       def->protocol, networkName);
948 949 950
        goto error;
    }

951 952 953
    /* Following attributes are optional */
    if ((def->target = virXMLPropString(node, "target")) &&
        (def->domain = virXMLPropString(node, "domain"))) {
954 955
        xmlNodePtr save_ctxt = ctxt->node;

956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971
        ctxt->node = node;
        if (virXPathUInt("string(./@port)", ctxt, &def->port) < 0 ||
            def->port > 65535) {
            virReportError(VIR_ERR_XML_DETAIL,
                           _("Missing or invalid port attribute "
                             "in network %s"), networkName);
            goto error;
        }

        if (virXPathUInt("string(./@priority)", ctxt, &def->priority) < 0 ||
            def->priority > 65535) {
            virReportError(VIR_ERR_XML_DETAIL,
                           _("Missing or invalid priority attribute "
                             "in network %s"), networkName);
            goto error;
        }
972

973 974 975 976 977 978 979
        if (virXPathUInt("string(./@weight)", ctxt, &def->weight) < 0 ||
            def->weight > 65535) {
            virReportError(VIR_ERR_XML_DETAIL,
                           _("Missing or invalid weight attribute "
                             "in network %s"), networkName);
            goto error;
        }
980 981 982 983

        ctxt->node = save_ctxt;
    }

984 985 986 987 988 989 990
    if (!(def->service || def->protocol)) {
        virReportError(VIR_ERR_XML_DETAIL,
                       _("Missing required service attribute or protocol "
                         "in DNS SRV record of network %s"), networkName);
        goto error;
    }
    return 0;
991 992

error:
993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020
    virNetworkDNSSrvDefClear(def);
    return -1;
}

static int
virNetworkDNSTxtDefParseXML(const char *networkName,
                            xmlNodePtr node,
                            virNetworkDNSTxtDefPtr def,
                            bool partialOkay)
{
    if (!(def->name = virXMLPropString(node, "name"))) {
        virReportError(VIR_ERR_XML_DETAIL,
                       _("missing required name attribute in DNS TXT record "
                         "of network %s"), networkName);
        goto error;
    }
    if (strchr(def->name, ' ') != NULL) {
        virReportError(VIR_ERR_XML_DETAIL,
                       _("prohibited space character in DNS TXT record "
                         "name '%s' of network %s"), def->name, networkName);
        goto error;
    }
    if (!(def->value = virXMLPropString(node, "value")) && !partialOkay) {
        virReportError(VIR_ERR_XML_DETAIL,
                       _("missing required value attribute in DNS TXT record "
                         "named '%s' of network %s"), def->name, networkName);
        goto error;
    }
1021

1022 1023 1024 1025 1026 1027 1028
    if (!(def->name || def->value)) {
        virReportError(VIR_ERR_XML_DETAIL,
                       _("Missing required name or value "
                         "in DNS TXT record of network %s"), networkName);
        goto error;
    }
    return 0;
1029

1030 1031 1032
error:
    virNetworkDNSTxtDefClear(def);
    return -1;
1033 1034
}

1035
static int
1036
virNetworkDNSDefParseXML(const char *networkName,
1037
                         xmlNodePtr node,
1038 1039
                         xmlXPathContextPtr ctxt,
                         virNetworkDNSDefPtr def)
1040
{
1041 1042 1043 1044 1045 1046
    xmlNodePtr *hostNodes = NULL;
    xmlNodePtr *srvNodes = NULL;
    xmlNodePtr *txtNodes = NULL;
    int nhosts, nsrvs, ntxts;
    int ii, ret = -1;
    xmlNodePtr save = ctxt->node;
1047

1048 1049 1050 1051 1052 1053 1054 1055
    ctxt->node = node;

    nhosts = virXPathNodeSet("./host", ctxt, &hostNodes);
    if (nhosts < 0) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("invalid <host> element found in <dns> of network %s"),
                       networkName);
        goto cleanup;
1056
    }
1057 1058 1059 1060 1061
    if (nhosts > 0) {
        if (VIR_ALLOC_N(def->hosts, nhosts) < 0) {
            virReportOOMError();
            goto cleanup;
        }
1062

1063 1064 1065 1066
        for (ii = 0; ii < nhosts; ii++) {
            if (virNetworkDNSHostDefParseXML(networkName, hostNodes[ii],
                                             &def->hosts[def->nhosts], false) < 0) {
                goto cleanup;
1067
            }
1068 1069 1070
            def->nhosts++;
        }
    }
1071

1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083
    nsrvs = virXPathNodeSet("./srv", ctxt, &srvNodes);
    if (nsrvs < 0) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("invalid <srv> element found in <dns> of network %s"),
                       networkName);
        goto cleanup;
    }
    if (nsrvs > 0) {
        if (VIR_ALLOC_N(def->srvs, nsrvs) < 0) {
            virReportOOMError();
            goto cleanup;
        }
1084

1085 1086 1087 1088
        for (ii = 0; ii < nsrvs; ii++) {
            if (virNetworkDNSSrvDefParseXML(networkName, srvNodes[ii], ctxt,
                                            &def->srvs[def->nsrvs], false) < 0) {
                goto cleanup;
1089
            }
1090 1091 1092
            def->nsrvs++;
        }
    }
1093

1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104
    ntxts = virXPathNodeSet("./txt", ctxt, &txtNodes);
    if (ntxts < 0) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("invalid <txt> element found in <dns> of network %s"),
                       networkName);
        goto cleanup;
    }
    if (ntxts > 0) {
        if (VIR_ALLOC_N(def->txts, ntxts) < 0) {
            virReportOOMError();
            goto cleanup;
1105 1106
        }

1107 1108 1109 1110 1111 1112 1113
        for (ii = 0; ii < ntxts; ii++) {
            if (virNetworkDNSTxtDefParseXML(networkName, txtNodes[ii],
                                            &def->txts[def->ntxts], false) < 0) {
                goto cleanup;
            }
            def->ntxts++;
        }
1114 1115 1116
    }

    ret = 0;
1117 1118 1119 1120 1121
cleanup:
    VIR_FREE(hostNodes);
    VIR_FREE(srvNodes);
    VIR_FREE(txtNodes);
    ctxt->node = save;
1122 1123 1124
    return ret;
}

1125
static int
1126 1127 1128 1129
virNetworkIPDefParseXML(const char *networkName,
                        xmlNodePtr node,
                        xmlXPathContextPtr ctxt,
                        virNetworkIpDefPtr def)
1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151 1152 1153 1154
{
    /*
     * virNetworkIpDef object is already allocated as part of an array.
     * On failure clear it out, but don't free it.
     */

    xmlNodePtr cur, save;
    char *address = NULL, *netmask = NULL;
    unsigned long prefix;
    int result = -1;

    save = ctxt->node;
    ctxt->node = node;

    /* grab raw data from XML */
    def->family = virXPathString("string(./@family)", ctxt);
    address = virXPathString("string(./@address)", ctxt);
    if (virXPathULong("string(./@prefix)", ctxt, &prefix) < 0)
        def->prefix = 0;
    else
        def->prefix = prefix;

    netmask = virXPathString("string(./@netmask)", ctxt);

    if (address) {
1155
        if (virSocketAddrParse(&def->address, address, AF_UNSPEC) < 0) {
1156 1157 1158
            virReportError(VIR_ERR_XML_ERROR,
                           _("Bad address '%s' in definition of network '%s'"),
                           address, networkName);
1159
            goto cleanup;
1160
        }
1161

1162
    }
1163

1164 1165
    /* validate family vs. address */
    if (def->family == NULL) {
1166 1167
        if (!(VIR_SOCKET_ADDR_IS_FAMILY(&def->address, AF_INET) ||
              VIR_SOCKET_ADDR_IS_FAMILY(&def->address, AF_UNSPEC))) {
1168 1169 1170
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("no family specified for non-IPv4 address '%s' in network '%s'"),
                           address, networkName);
1171
            goto cleanup;
1172 1173
        }
    } else if (STREQ(def->family, "ipv4")) {
1174
        if (!VIR_SOCKET_ADDR_IS_FAMILY(&def->address, AF_INET)) {
1175 1176 1177
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("family 'ipv4' specified for non-IPv4 address '%s' in network '%s'"),
                           address, networkName);
1178
            goto cleanup;
1179 1180
        }
    } else if (STREQ(def->family, "ipv6")) {
1181
        if (!VIR_SOCKET_ADDR_IS_FAMILY(&def->address, AF_INET6)) {
1182 1183 1184
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("family 'ipv6' specified for non-IPv6 address '%s' in network '%s'"),
                           address, networkName);
1185
            goto cleanup;
1186 1187
        }
    } else {
1188 1189 1190
        virReportError(VIR_ERR_XML_ERROR,
                       _("Unrecognized family '%s' in definition of network '%s'"),
                       def->family, networkName);
1191
        goto cleanup;
1192
    }
1193

1194 1195 1196 1197
    /* parse/validate netmask */
    if (netmask) {
        if (address == NULL) {
            /* netmask is meaningless without an address */
1198 1199 1200
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("netmask specified without address in network '%s'"),
                           networkName);
1201
            goto cleanup;
1202 1203
        }

1204
        if (!VIR_SOCKET_ADDR_IS_FAMILY(&def->address, AF_INET)) {
1205 1206 1207
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("netmask not supported for address '%s' in network '%s' (IPv4 only)"),
                           address, networkName);
1208
            goto cleanup;
1209 1210 1211 1212
        }

        if (def->prefix > 0) {
            /* can't have both netmask and prefix at the same time */
1213 1214 1215
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("network '%s' cannot have both prefix='%u' and a netmask"),
                           networkName, def->prefix);
1216
            goto cleanup;
1217 1218
        }

1219
        if (virSocketAddrParse(&def->netmask, netmask, AF_UNSPEC) < 0)
1220
            goto cleanup;
1221

1222
        if (!VIR_SOCKET_ADDR_IS_FAMILY(&def->netmask, AF_INET)) {
1223 1224 1225
            virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                           _("network '%s' has invalid netmask '%s' for address '%s' (both must be IPv4)"),
                           networkName, netmask, address);
1226
            goto cleanup;
1227 1228 1229
        }
    }

G
Gene Czarcinski 已提交
1230 1231 1232 1233 1234 1235 1236 1237 1238
    cur = node->children;
    while (cur != NULL) {
        if (cur->type == XML_ELEMENT_NODE &&
            xmlStrEqual(cur->name, BAD_CAST "dhcp")) {
            if (virNetworkDHCPDefParseXML(networkName, cur, def) < 0)
                goto cleanup;
        } else if (cur->type == XML_ELEMENT_NODE &&
                   xmlStrEqual(cur->name, BAD_CAST "tftp")) {
            char *root;
1239

G
Gene Czarcinski 已提交
1240 1241 1242 1243 1244
            if (!VIR_SOCKET_ADDR_IS_FAMILY(&def->address, AF_INET)) {
                virReportError(VIR_ERR_CONFIG_UNSUPPORTED,
                               _("Unsupported <tftp> element in an IPv6 element in network '%s'"),
                               networkName);
                goto cleanup;
1245
            }
G
Gene Czarcinski 已提交
1246 1247 1248 1249 1250
            if (!(root = virXMLPropString(cur, "root"))) {
                cur = cur->next;
                continue;
            }
            def->tftproot = (char *)root;
1251
        }
G
Gene Czarcinski 已提交
1252
        cur = cur->next;
1253
    }
1254

1255 1256
    result = 0;

1257
cleanup:
1258 1259
    if (result < 0) {
        virNetworkIpDefClear(def);
1260
    }
1261 1262 1263 1264 1265
    VIR_FREE(address);
    VIR_FREE(netmask);

    ctxt->node = save;
    return result;
1266 1267
}

1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279
static int
virNetworkPortGroupParseXML(virPortGroupDefPtr def,
                            xmlNodePtr node,
                            xmlXPathContextPtr ctxt)
{
    /*
     * virPortGroupDef object is already allocated as part of an array.
     * On failure clear it out, but don't free it.
     */

    xmlNodePtr save;
    xmlNodePtr virtPortNode;
1280
    xmlNodePtr vlanNode;
1281
    xmlNodePtr bandwidth_node;
1282 1283 1284 1285 1286 1287 1288 1289 1290
    char *isDefault = NULL;

    int result = -1;

    save = ctxt->node;
    ctxt->node = node;

    /* grab raw data from XML */
    def->name = virXPathString("string(./@name)", ctxt);
1291 1292 1293
    if (!def->name) {
        virReportError(VIR_ERR_XML_ERROR, "%s",
                       _("Missing required name attribute in portgroup"));
1294
        goto cleanup;
1295 1296
    }

1297 1298 1299 1300 1301
    isDefault = virXPathString("string(./@default)", ctxt);
    def->isDefault = isDefault && STRCASEEQ(isDefault, "yes");

    virtPortNode = virXPathNode("./virtualport", ctxt);
    if (virtPortNode &&
1302
        (!(def->virtPortProfile = virNetDevVPortProfileParse(virtPortNode, 0)))) {
1303
        goto cleanup;
1304
    }
1305

1306 1307
    bandwidth_node = virXPathNode("./bandwidth", ctxt);
    if (bandwidth_node &&
1308
        !(def->bandwidth = virNetDevBandwidthParse(bandwidth_node, -1))) {
1309
        goto cleanup;
1310 1311
    }

1312 1313
    vlanNode = virXPathNode("./vlan", ctxt);
    if (vlanNode && virNetDevVlanParse(vlanNode, ctxt, &def->vlan) < 0)
1314
        goto cleanup;
1315

1316
    result = 0;
1317
cleanup:
1318 1319 1320 1321 1322 1323 1324 1325 1326
    if (result < 0) {
        virPortGroupDefClear(def);
    }
    VIR_FREE(isDefault);

    ctxt->node = save;
    return result;
}

1327 1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338 1339 1340 1341 1342 1343 1344 1345 1346 1347 1348 1349 1350 1351 1352 1353 1354 1355 1356 1357 1358 1359 1360 1361 1362 1363 1364 1365 1366 1367 1368 1369 1370 1371 1372 1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397 1398 1399 1400 1401
static int
virNetworkForwardNatDefParseXML(const char *networkName,
                                xmlNodePtr node,
                                xmlXPathContextPtr ctxt,
                                virNetworkForwardDefPtr def)
{
    int ret = -1;
    xmlNodePtr *natAddrNodes = NULL;
    int nNatAddrs;
    char *addrStart = NULL;
    char *addrEnd = NULL;
    xmlNodePtr save = ctxt->node;

    ctxt->node = node;

    if (def->type != VIR_NETWORK_FORWARD_NAT) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("The <nat> element can only be used when <forward> 'mode' is 'nat' in network %s"),
                       networkName);
        goto cleanup;
    }

    /* addresses for SNAT */
    nNatAddrs = virXPathNodeSet("./address", ctxt, &natAddrNodes);
    if (nNatAddrs < 0) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("invalid <address> element found in <forward> of "
                         "network %s"), networkName);
        goto cleanup;
    } else if (nNatAddrs > 1) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("Only one <address> element is allowed in <nat> in "
                         "<forward> in network %s"), networkName);
        goto cleanup;
    } else if (nNatAddrs == 1) {
        addrStart = virXMLPropString(*natAddrNodes, "start");
        if (addrStart == NULL) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("missing 'start' attribute in <address> element in <nat> in "
                             "<forward> in network %s"), networkName);
            goto cleanup;
        }
        addrEnd = virXMLPropString(*natAddrNodes, "end");
        if (addrEnd == NULL) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("missing 'end' attribute in <address> element in <nat> in "
                             "<forward> in network %s"), networkName);
            goto cleanup;
        }
    }

    if (addrStart && virSocketAddrParse(&def->addrStart, addrStart, AF_INET) < 0) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("Bad ipv4 start address '%s' in <nat> in <forward> in "
                         "network '%s'"), addrStart, networkName);
        goto cleanup;
    }

    if (addrEnd && virSocketAddrParse(&def->addrEnd, addrEnd, AF_INET) < 0) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("Bad ipv4 end address '%s' in <nat> in <forward> in "
                         "network '%s'"), addrEnd, networkName);
        goto cleanup;
    }

    ret = 0;

cleanup:
    VIR_FREE(addrStart);
    VIR_FREE(addrEnd);
    VIR_FREE(natAddrNodes);
    ctxt->node = save;
    return ret;
}

1402 1403 1404 1405 1406 1407 1408 1409 1410 1411
static int
virNetworkForwardDefParseXML(const char *networkName,
                             xmlNodePtr node,
                             xmlXPathContextPtr ctxt,
                             virNetworkForwardDefPtr def)
{
    int ii, ret = -1;
    xmlNodePtr *forwardIfNodes = NULL;
    xmlNodePtr *forwardPfNodes = NULL;
    xmlNodePtr *forwardAddrNodes = NULL;
1412 1413
    xmlNodePtr *forwardNatNodes = NULL;
    int nForwardIfs, nForwardAddrs, nForwardPfs, nForwardNats;
1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462
    char *forwardDev = NULL;
    char *forwardManaged = NULL;
    char *type = NULL;
    xmlNodePtr save = ctxt->node;

    ctxt->node = node;

    if (!(type = virXPathString("string(./@mode)", ctxt))) {
        def->type = VIR_NETWORK_FORWARD_NAT;
    } else {
        if ((def->type = virNetworkForwardTypeFromString(type)) < 0) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("unknown forwarding type '%s'"), type);
            goto cleanup;
        }
        VIR_FREE(type);
    }

    forwardManaged = virXPathString("string(./@managed)", ctxt);
    if (forwardManaged != NULL &&
        STRCASEEQ(forwardManaged, "yes")) {
        def->managed = true;
    }

    /* bridge and hostdev modes can use a pool of physical interfaces */
    nForwardIfs = virXPathNodeSet("./interface", ctxt, &forwardIfNodes);
    if (nForwardIfs < 0) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("invalid <interface> element found in <forward> of network %s"),
                       networkName);
        goto cleanup;
    }

    nForwardAddrs = virXPathNodeSet("./address", ctxt, &forwardAddrNodes);
    if (nForwardAddrs < 0) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("invalid <address> element found in <forward> of network %s"),
                       networkName);
        goto cleanup;
    }

    nForwardPfs = virXPathNodeSet("./pf", ctxt, &forwardPfNodes);
    if (nForwardPfs < 0) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("invalid <pf> element found in <forward> of network %s"),
                       networkName);
        goto cleanup;
    }

1463 1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480
    nForwardNats = virXPathNodeSet("./nat", ctxt, &forwardNatNodes);
    if (nForwardNats < 0) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("invalid <nat> element found in <forward> of network %s"),
                       networkName);
        goto cleanup;
    } else if (nForwardNats > 1) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("Only one <nat> element is allowed in <forward> of network %s"),
                       networkName);
        goto cleanup;
    } else if (nForwardNats == 1) {
        if (virNetworkForwardNatDefParseXML(networkName,
                                            *forwardNatNodes,
                                            ctxt, def) < 0)
            goto cleanup;
    }

1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553 1554 1555 1556 1557 1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570 1571 1572 1573 1574 1575 1576 1577 1578 1579 1580 1581 1582 1583 1584 1585 1586 1587 1588 1589 1590 1591 1592 1593 1594 1595 1596 1597 1598 1599 1600 1601 1602 1603 1604 1605 1606 1607 1608 1609 1610 1611 1612 1613 1614 1615 1616 1617 1618 1619 1620 1621
    if (((nForwardIfs > 0) + (nForwardAddrs > 0) + (nForwardPfs > 0)) > 1) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("<address>, <interface>, and <pf> elements in <forward> "
                         "of network %s are mutually exclusive"),
                       networkName);
        goto cleanup;
    }

    forwardDev = virXPathString("string(./@dev)", ctxt);
    if (forwardDev && (nForwardAddrs > 0 || nForwardPfs > 0)) {
        virReportError(VIR_ERR_XML_ERROR, "%s",
                       _("the <forward> 'dev' attribute cannot be used when "
                         "<address> or <pf> sub-elements are present "
                         "in network %s"));
        goto cleanup;
    }

    if (nForwardIfs > 0 || forwardDev) {

        if (VIR_ALLOC_N(def->ifs, MAX(nForwardIfs, 1)) < 0) {
            virReportOOMError();
            goto cleanup;
        }

        if (forwardDev) {
            def->ifs[0].device.dev = forwardDev;
            def->ifs[0].type = VIR_NETWORK_FORWARD_HOSTDEV_DEVICE_NETDEV;
            forwardDev = NULL;
            def->nifs++;
        }

        /* parse each <interface> */
        for (ii = 0; ii < nForwardIfs; ii++) {
            forwardDev = virXMLPropString(forwardIfNodes[ii], "dev");
            if (!forwardDev) {
                virReportError(VIR_ERR_XML_ERROR,
                               _("Missing required dev attribute in "
                                 "<forward> <interface> element of network %s"),
                               networkName);
                goto cleanup;
            }

            if ((ii == 0) && (def->nifs == 1)) {
                /* both <forward dev='x'> and <interface dev='x'/> are
                 * present.  If they don't match, it's an error.
                 */
                if (STRNEQ(forwardDev, def->ifs[0].device.dev)) {
                    virReportError(VIR_ERR_XML_ERROR,
                                   _("<forward dev='%s'> must match first "
                                     "<interface dev='%s'/> in network %s"),
                                   def->ifs[0].device.dev,
                                   forwardDev, networkName);
                    goto cleanup;
                }
                VIR_FREE(forwardDev);
                continue;
            }

            def->ifs[ii].device.dev = forwardDev;
            forwardDev = NULL;
            def->ifs[ii].type = VIR_NETWORK_FORWARD_HOSTDEV_DEVICE_NETDEV;
            def->nifs++;
        }

    } else if (nForwardAddrs > 0) {

        if (VIR_ALLOC_N(def->ifs, nForwardAddrs) < 0) {
            virReportOOMError();
            goto cleanup;
        }

        for (ii = 0; ii < nForwardAddrs; ii++) {
            if (!(type = virXMLPropString(forwardAddrNodes[ii], "type"))) {
                virReportError(VIR_ERR_XML_ERROR,
                               _("missing address type in network %s"),
                               networkName);
                goto cleanup;
            }

            if ((def->ifs[ii].type = virNetworkForwardHostdevDeviceTypeFromString(type)) < 0) {
                virReportError(VIR_ERR_XML_ERROR,
                               _("unknown address type '%s' in network %s"),
                               type, networkName);
                goto cleanup;
            }

            switch (def->ifs[ii].type) {
            case VIR_NETWORK_FORWARD_HOSTDEV_DEVICE_PCI:
                if (virDevicePCIAddressParseXML(forwardAddrNodes[ii],
                                                &def->ifs[ii].device.pci) < 0) {
                    goto cleanup;
                }
                break;

            /* Add USB case here if we ever find a reason to support it */

            default:
                virReportError(VIR_ERR_XML_ERROR,
                               _("unsupported address type '%s' in network %s"),
                               type, networkName);
                goto cleanup;
            }
            VIR_FREE(type);
            def->nifs++;
        }

    } else if (nForwardPfs > 1) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("Only one <pf> element is allowed in <forward> of network %s"),
                       networkName);
        goto cleanup;
    } else if (nForwardPfs == 1) {

        if (VIR_ALLOC_N(def->pfs, nForwardPfs) < 0) {
            virReportOOMError();
            goto cleanup;
        }

        forwardDev = virXMLPropString(*forwardPfNodes, "dev");
        if (!forwardDev) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("Missing required dev attribute "
                             "in <pf> element of network '%s'"),
                           networkName);
            goto cleanup;
        }

        def->pfs->dev = forwardDev;
        forwardDev = NULL;
        def->npfs++;

    }

    ret = 0;
cleanup:
    VIR_FREE(type);
    VIR_FREE(forwardDev);
    VIR_FREE(forwardManaged);
    VIR_FREE(forwardPfNodes);
    VIR_FREE(forwardIfNodes);
    VIR_FREE(forwardAddrNodes);
1622
    VIR_FREE(forwardNatNodes);
1623 1624 1625 1626
    ctxt->node = save;
    return ret;
}

1627
static virNetworkDefPtr
1628
virNetworkDefParseXML(xmlXPathContextPtr ctxt)
1629 1630 1631
{
    virNetworkDefPtr def;
    char *tmp;
1632
    char *stp = NULL;
1633
    xmlNodePtr *ipNodes = NULL;
1634
    xmlNodePtr *portGroupNodes = NULL;
1635
    int nIps, nPortGroups;
1636
    xmlNodePtr dnsNode = NULL;
1637 1638
    xmlNodePtr virtPortNode = NULL;
    xmlNodePtr forwardNode = NULL;
1639
    char *ipv6nogwStr = NULL;
1640
    xmlNodePtr save = ctxt->node;
1641
    xmlNodePtr bandwidthNode = NULL;
1642
    xmlNodePtr vlanNode;
1643 1644

    if (VIR_ALLOC(def) < 0) {
1645
        virReportOOMError();
1646 1647 1648 1649
        return NULL;
    }

    /* Extract network name */
1650
    def->name = virXPathString("string(./name[1])", ctxt);
1651
    if (!def->name) {
1652
        virReportError(VIR_ERR_NO_NAME, NULL);
1653 1654 1655 1656
        goto error;
    }

    /* Extract network uuid */
1657
    tmp = virXPathString("string(./uuid[1])", ctxt);
1658
    if (!tmp) {
1659
        if (virUUIDGenerate(def->uuid)) {
1660 1661
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("Failed to generate UUID"));
1662 1663 1664 1665 1666
            goto error;
        }
    } else {
        if (virUUIDParse(tmp, def->uuid) < 0) {
            VIR_FREE(tmp);
1667 1668
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           "%s", _("malformed uuid element"));
1669 1670 1671
            goto error;
        }
        VIR_FREE(tmp);
M
Matthias Bolte 已提交
1672
        def->uuid_specified = true;
1673 1674
    }

1675 1676 1677 1678 1679 1680 1681 1682 1683 1684 1685 1686 1687 1688 1689 1690
    /* check if definitions with no IPv6 gateway addresses is to
     * allow guest-to-guest communications.
     */
    ipv6nogwStr = virXPathString("string(./@ipv6)", ctxt);
    if (ipv6nogwStr) {
        if (STREQ(ipv6nogwStr, "yes")) {
            def->ipv6nogw = true;
        } else if (STRNEQ(ipv6nogwStr, "no")) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("Invalid ipv6 setting '%s' in network '%s'"),
                           ipv6nogwStr, def->name);
            goto error;
        }
        VIR_FREE(ipv6nogwStr);
    }

1691
    /* Parse network domain information */
1692
    def->domain = virXPathString("string(./domain[1]/@name)", ctxt);
1693

1694
    if ((bandwidthNode = virXPathNode("./bandwidth", ctxt)) != NULL &&
1695
        (def->bandwidth = virNetDevBandwidthParse(bandwidthNode, -1)) == NULL)
1696 1697
        goto error;

1698 1699 1700 1701
    vlanNode = virXPathNode("./vlan", ctxt);
    if (vlanNode && virNetDevVlanParse(vlanNode, ctxt, &def->vlan) < 0)
        goto error;

1702
    /* Parse bridge information */
1703
    def->bridge = virXPathString("string(./bridge[1]/@name)", ctxt);
1704
    stp = virXPathString("string(./bridge[1]/@stp)", ctxt);
1705
    def->stp = (stp && STREQ(stp, "off")) ? 0 : 1;
1706

1707
    if (virXPathULong("string(./bridge[1]/@delay)", ctxt, &def->delay) < 0)
1708 1709
        def->delay = 0;

1710 1711
    tmp = virXPathString("string(./mac[1]/@address)", ctxt);
    if (tmp) {
1712
        if (virMacAddrParse(tmp, &def->mac) < 0) {
1713 1714 1715
            virReportError(VIR_ERR_XML_ERROR,
                           _("Invalid bridge mac address '%s' in network '%s'"),
                           tmp, def->name);
1716 1717 1718
            VIR_FREE(tmp);
            goto error;
        }
1719
        if (virMacAddrIsMulticast(&def->mac)) {
1720 1721 1722
            virReportError(VIR_ERR_XML_ERROR,
                           _("Invalid multicast bridge mac address '%s' in network '%s'"),
                           tmp, def->name);
1723 1724 1725
            VIR_FREE(tmp);
            goto error;
        }
1726 1727 1728 1729
        VIR_FREE(tmp);
        def->mac_specified = true;
    }

1730
    dnsNode = virXPathNode("./dns", ctxt);
1731 1732 1733
    if (dnsNode != NULL &&
        virNetworkDNSDefParseXML(def->name, dnsNode, ctxt, &def->dns) < 0) {
        goto error;
1734 1735
    }

1736 1737
    virtPortNode = virXPathNode("./virtualport", ctxt);
    if (virtPortNode &&
1738 1739
        (!(def->virtPortProfile = virNetDevVPortProfileParse(virtPortNode,
                                                             VIR_VPORT_XML_REQUIRE_TYPE)))) {
1740
        goto error;
1741
    }
1742 1743 1744 1745 1746 1747 1748 1749 1750 1751 1752 1753 1754 1755 1756 1757 1758 1759 1760 1761 1762 1763 1764 1765

    nPortGroups = virXPathNodeSet("./portgroup", ctxt, &portGroupNodes);
    if (nPortGroups < 0)
        goto error;

    if (nPortGroups > 0) {
        int ii;

        /* allocate array to hold all the portgroups */
        if (VIR_ALLOC_N(def->portGroups, nPortGroups) < 0) {
            virReportOOMError();
            goto error;
        }
        /* parse each portgroup */
        for (ii = 0; ii < nPortGroups; ii++) {
            int ret = virNetworkPortGroupParseXML(&def->portGroups[ii],
                                                  portGroupNodes[ii], ctxt);
            if (ret < 0)
                goto error;
            def->nPortGroups++;
        }
    }
    VIR_FREE(portGroupNodes);

1766
    nIps = virXPathNodeSet("./ip", ctxt, &ipNodes);
1767 1768 1769
    if (nIps < 0)
        goto error;

1770 1771
    if (nIps > 0) {
        int ii;
1772

1773 1774 1775
        /* allocate array to hold all the addrs */
        if (VIR_ALLOC_N(def->ips, nIps) < 0) {
            virReportOOMError();
1776 1777
            goto error;
        }
1778 1779
        /* parse each addr */
        for (ii = 0; ii < nIps; ii++) {
1780 1781
            int ret = virNetworkIPDefParseXML(def->name, ipNodes[ii],
                                              ctxt, &def->ips[ii]);
1782 1783 1784
            if (ret < 0)
                goto error;
            def->nips++;
1785
        }
1786
    }
E
Eric Blake 已提交
1787
    VIR_FREE(ipNodes);
1788

1789
    forwardNode = virXPathNode("./forward", ctxt);
1790 1791 1792 1793
    if (forwardNode &&
        virNetworkForwardDefParseXML(def->name, forwardNode, ctxt, &def->forward) < 0) {
        goto error;
    }
1794

1795 1796 1797 1798 1799 1800 1801 1802 1803 1804 1805 1806 1807 1808 1809 1810 1811 1812
    /* Validate some items in the main NetworkDef that need to align
     * with the chosen forward mode.
     */
    switch (def->forward.type) {
    case VIR_NETWORK_FORWARD_NONE:
        break;

    case VIR_NETWORK_FORWARD_ROUTE:
    case VIR_NETWORK_FORWARD_NAT:
        /* It's pointless to specify L3 forwarding without specifying
         * the network we're on.
         */
        if (def->nips == 0) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("%s forwarding requested, "
                             "but no IP address provided for network '%s'"),
                           virNetworkForwardTypeToString(def->forward.type),
                           def->name);
1813
            goto error;
1814
        }
1815 1816 1817 1818 1819
        if (def->forward.nifs > 1) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("multiple forwarding interfaces specified "
                             "for network '%s', only one is supported"),
                           def->name);
1820 1821
            goto error;
        }
1822
        break;
1823

1824 1825 1826 1827 1828 1829 1830 1831 1832
    case VIR_NETWORK_FORWARD_PRIVATE:
    case VIR_NETWORK_FORWARD_VEPA:
    case VIR_NETWORK_FORWARD_PASSTHROUGH:
    case VIR_NETWORK_FORWARD_HOSTDEV:
        if (def->bridge) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("bridge name not allowed in %s mode (network '%s')"),
                           virNetworkForwardTypeToString(def->forward.type),
                           def->name);
1833 1834
            goto error;
        }
1835 1836 1837 1838 1839 1840 1841
        /* fall through to next case */
    case VIR_NETWORK_FORWARD_BRIDGE:
        if (def->delay || stp) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("bridge delay/stp options only allowed in route, nat, and isolated mode, not in %s (network '%s')"),
                           virNetworkForwardTypeToString(def->forward.type),
                           def->name);
1842 1843
            goto error;
        }
1844 1845 1846 1847 1848 1849 1850 1851
        if (def->bridge && (def->forward.nifs || def->forward.npfs)) {
            virReportError(VIR_ERR_XML_ERROR,
                           _("A network with forward mode='%s' can specify "
                             "a bridge name or a forward dev, but not "
                             "both (network '%s')"),
                           virNetworkForwardTypeToString(def->forward.type),
                           def->name);
            goto error;
1852
        }
1853
        break;
1854
    }
1855

1856 1857
    VIR_FREE(stp);
    ctxt->node = save;
1858 1859
    return def;

1860
error:
1861
    VIR_FREE(stp);
1862
    virNetworkDefFree(def);
E
Eric Blake 已提交
1863
    VIR_FREE(ipNodes);
1864
    VIR_FREE(portGroupNodes);
1865
    VIR_FREE(ipv6nogwStr);
1866
    ctxt->node = save;
1867 1868 1869
    return NULL;
}

J
Jiri Denemark 已提交
1870 1871 1872
static virNetworkDefPtr
virNetworkDefParse(const char *xmlStr,
                   const char *filename)
1873
{
J
Jiri Denemark 已提交
1874
    xmlDocPtr xml;
1875
    virNetworkDefPtr def = NULL;
1876

1877
    if ((xml = virXMLParse(filename, xmlStr, _("(network_definition)")))) {
J
Jiri Denemark 已提交
1878 1879
        def = virNetworkDefParseNode(xml, xmlDocGetRootElement(xml));
        xmlFreeDoc(xml);
1880 1881 1882 1883 1884
    }

    return def;
}

J
Jiri Denemark 已提交
1885
virNetworkDefPtr virNetworkDefParseString(const char *xmlStr)
1886
{
J
Jiri Denemark 已提交
1887 1888
    return virNetworkDefParse(xmlStr, NULL);
}
1889

J
Jiri Denemark 已提交
1890 1891 1892
virNetworkDefPtr virNetworkDefParseFile(const char *filename)
{
    return virNetworkDefParse(NULL, filename);
1893 1894 1895
}


1896
virNetworkDefPtr virNetworkDefParseNode(xmlDocPtr xml,
1897 1898 1899 1900 1901 1902
                                        xmlNodePtr root)
{
    xmlXPathContextPtr ctxt = NULL;
    virNetworkDefPtr def = NULL;

    if (!xmlStrEqual(root->name, BAD_CAST "network")) {
1903 1904 1905 1906
        virReportError(VIR_ERR_XML_ERROR,
                       _("unexpected root element <%s>, "
                         "expecting <network>"),
                       root->name);
1907 1908 1909 1910 1911
        return NULL;
    }

    ctxt = xmlXPathNewContext(xml);
    if (ctxt == NULL) {
1912
        virReportOOMError();
1913 1914 1915 1916
        goto cleanup;
    }

    ctxt->node = root;
1917
    def = virNetworkDefParseXML(ctxt);
1918 1919 1920 1921 1922 1923

cleanup:
    xmlXPathFreeContext(ctxt);
    return def;
}

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
int
virNetworkObjUpdateParseFile(const char *filename,
                             virNetworkObjPtr net)
{
    int ret = -1;
    xmlDocPtr xml = NULL;
    xmlNodePtr node = NULL;
    virNetworkDefPtr tmp = NULL;
    xmlXPathContextPtr ctxt = NULL;

    xml = virXMLParse(filename, NULL, _("(network status)"));
    if (!xml)
        return -1;

    ctxt = xmlXPathNewContext(xml);
    if (ctxt == NULL) {
        virReportOOMError();
        goto cleanup;
    }

    node = xmlDocGetRootElement(xml);
    if (xmlStrEqual(node->name, BAD_CAST "networkstatus")) {
        /* Newer network status file. Contains useful
         * info which are not to be found in bare config XML */
        char *class_id = NULL;
        char *floor_sum = NULL;

        ctxt->node = node;
        class_id = virXPathString("string(./class_id[1]/@bitmap)", ctxt);
        if (class_id &&
P
Peter Krempa 已提交
1954
            virBitmapParse(class_id, 0,
1955 1956 1957 1958 1959 1960 1961 1962 1963 1964 1965 1966 1967 1968 1969 1970 1971 1972 1973 1974 1975 1976 1977 1978 1979 1980 1981 1982 1983 1984 1985 1986 1987 1988 1989 1990 1991 1992
                           &net->class_id, CLASS_ID_BITMAP_SIZE) < 0) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("Malformed 'class_id' attribute: %s"),
                           class_id);
            VIR_FREE(class_id);
            goto cleanup;
        }
        VIR_FREE(class_id);

        floor_sum = virXPathString("string(./floor[1]/@sum)", ctxt);
        if (floor_sum &&
            virStrToLong_ull(floor_sum, NULL, 10, &net->floor_sum) < 0) {
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("Malformed 'floor_sum' attribute: %s"),
                           floor_sum);
            VIR_FREE(floor_sum);
        }
        VIR_FREE(floor_sum);
    }

    node = virXPathNode("//network", ctxt);
    if (!node) {
        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                       _("Could not find any 'network' element"));
        goto cleanup;
    }

    ctxt->node = node;
    tmp = virNetworkDefParseXML(ctxt);

    if (tmp) {
        net->newDef = net->def;
        net->def = tmp;
    }

    ret = 0;

cleanup:
1993
    xmlFreeDoc(xml);
1994 1995 1996 1997
    xmlXPathFreeContext(ctxt);
    return ret;
}

1998 1999 2000 2001 2002 2003 2004
static int
virNetworkDNSDefFormat(virBufferPtr buf,
                       virNetworkDNSDefPtr def)
{
    int result = 0;
    int i;

2005
    if (!(def->nhosts || def->nsrvs || def->ntxts))
2006 2007
        goto out;

2008 2009
    virBufferAddLit(buf, "<dns>\n");
    virBufferAdjustIndent(buf, 2);
2010

2011
    for (i = 0 ; i < def->ntxts ; i++) {
2012
        virBufferAsprintf(buf, "<txt name='%s' value='%s' />\n",
2013 2014
                              def->txts[i].name,
                              def->txts[i].value);
2015 2016
    }

2017 2018
    for (i = 0 ; i < def->nsrvs ; i++) {
        if (def->srvs[i].service && def->srvs[i].protocol) {
2019
            virBufferAsprintf(buf, "<srv service='%s' protocol='%s'",
2020 2021 2022 2023 2024 2025 2026 2027 2028 2029 2030 2031 2032
                                  def->srvs[i].service,
                                  def->srvs[i].protocol);

            if (def->srvs[i].domain)
                virBufferAsprintf(buf, " domain='%s'", def->srvs[i].domain);
            if (def->srvs[i].target)
                virBufferAsprintf(buf, " target='%s'", def->srvs[i].target);
            if (def->srvs[i].port)
                virBufferAsprintf(buf, " port='%d'", def->srvs[i].port);
            if (def->srvs[i].priority)
                virBufferAsprintf(buf, " priority='%d'", def->srvs[i].priority);
            if (def->srvs[i].weight)
                virBufferAsprintf(buf, " weight='%d'", def->srvs[i].weight);
2033 2034 2035 2036 2037

            virBufferAsprintf(buf, "/>\n");
        }
    }

2038 2039 2040 2041
    if (def->nhosts) {
        int ii, j;

        for (ii = 0 ; ii < def->nhosts; ii++) {
2042
            char *ip = virSocketAddrFormat(&def->hosts[ii].ip);
2043

2044 2045
            virBufferAsprintf(buf, "<host ip='%s'>\n", ip);
            virBufferAdjustIndent(buf, 2);
2046
            for (j = 0; j < def->hosts[ii].nnames; j++)
2047 2048
                virBufferAsprintf(buf, "<hostname>%s</hostname>\n",
                                  def->hosts[ii].names[j]);
2049

2050 2051
            virBufferAdjustIndent(buf, -2);
            virBufferAsprintf(buf, "</host>\n");
2052
            VIR_FREE(ip);
2053 2054
        }
    }
2055 2056
    virBufferAdjustIndent(buf, -2);
    virBufferAddLit(buf, "</dns>\n");
2057 2058 2059 2060
out:
    return result;
}

2061 2062 2063 2064 2065 2066
static int
virNetworkIpDefFormat(virBufferPtr buf,
                      const virNetworkIpDefPtr def)
{
    int result = -1;

2067
    virBufferAddLit(buf, "<ip");
2068 2069

    if (def->family) {
2070
        virBufferAsprintf(buf, " family='%s'", def->family);
2071
    }
2072 2073
    if (VIR_SOCKET_ADDR_VALID(&def->address)) {
        char *addr = virSocketAddrFormat(&def->address);
2074 2075
        if (!addr)
            goto error;
2076
        virBufferAsprintf(buf, " address='%s'", addr);
2077 2078
        VIR_FREE(addr);
    }
2079 2080
    if (VIR_SOCKET_ADDR_VALID(&def->netmask)) {
        char *addr = virSocketAddrFormat(&def->netmask);
2081 2082
        if (!addr)
            goto error;
2083
        virBufferAsprintf(buf, " netmask='%s'", addr);
2084 2085 2086
        VIR_FREE(addr);
    }
    if (def->prefix > 0) {
2087
        virBufferAsprintf(buf," prefix='%u'", def->prefix);
2088 2089
    }
    virBufferAddLit(buf, ">\n");
2090
    virBufferAdjustIndent(buf, 2);
2091 2092

    if (def->tftproot) {
2093
        virBufferEscapeString(buf, "<tftp root='%s' />\n",
2094 2095 2096 2097
                              def->tftproot);
    }
    if ((def->nranges || def->nhosts)) {
        int ii;
2098 2099 2100
        virBufferAddLit(buf, "<dhcp>\n");
        virBufferAdjustIndent(buf, 2);

2101
        for (ii = 0 ; ii < def->nranges ; ii++) {
2102
            char *saddr = virSocketAddrFormat(&def->ranges[ii].start);
2103 2104
            if (!saddr)
                goto error;
2105
            char *eaddr = virSocketAddrFormat(&def->ranges[ii].end);
2106 2107 2108 2109
            if (!eaddr) {
                VIR_FREE(saddr);
                goto error;
            }
2110
            virBufferAsprintf(buf, "<range start='%s' end='%s' />\n",
2111 2112 2113 2114 2115
                              saddr, eaddr);
            VIR_FREE(saddr);
            VIR_FREE(eaddr);
        }
        for (ii = 0 ; ii < def->nhosts ; ii++) {
2116
            virBufferAddLit(buf, "<host ");
2117
            if (def->hosts[ii].mac)
2118
                virBufferAsprintf(buf, "mac='%s' ", def->hosts[ii].mac);
2119
            if (def->hosts[ii].name)
2120
                virBufferAsprintf(buf, "name='%s' ", def->hosts[ii].name);
2121 2122
            if (VIR_SOCKET_ADDR_VALID(&def->hosts[ii].ip)) {
                char *ipaddr = virSocketAddrFormat(&def->hosts[ii].ip);
2123 2124
                if (!ipaddr)
                    goto error;
2125
                virBufferAsprintf(buf, "ip='%s' ", ipaddr);
2126 2127 2128 2129 2130
                VIR_FREE(ipaddr);
            }
            virBufferAddLit(buf, "/>\n");
        }
        if (def->bootfile) {
2131
            virBufferEscapeString(buf, "<bootp file='%s' ",
2132
                                  def->bootfile);
2133 2134
            if (VIR_SOCKET_ADDR_VALID(&def->bootserver)) {
                char *ipaddr = virSocketAddrFormat(&def->bootserver);
2135 2136 2137 2138 2139 2140
                if (!ipaddr)
                    goto error;
                virBufferEscapeString(buf, "server='%s' ", ipaddr);
                VIR_FREE(ipaddr);
            }
            virBufferAddLit(buf, "/>\n");
2141

2142 2143
        }

2144 2145
        virBufferAdjustIndent(buf, -2);
        virBufferAddLit(buf, "</dhcp>\n");
2146 2147
    }

2148 2149
    virBufferAdjustIndent(buf, -2);
    virBufferAddLit(buf, "</ip>\n");
2150 2151 2152 2153 2154 2155

    result = 0;
error:
    return result;
}

2156
static int
2157 2158 2159
virPortGroupDefFormat(virBufferPtr buf,
                      const virPortGroupDefPtr def)
{
2160
    virBufferAsprintf(buf, "<portgroup name='%s'", def->name);
2161 2162 2163 2164
    if (def->isDefault) {
        virBufferAddLit(buf, " default='yes'");
    }
    virBufferAddLit(buf, ">\n");
2165
    virBufferAdjustIndent(buf, 2);
2166 2167
    if (virNetDevVlanFormat(&def->vlan, buf) < 0)
        return -1;
2168 2169
    if (virNetDevVPortProfileFormat(def->virtPortProfile, buf) < 0)
        return -1;
2170
    virNetDevBandwidthFormat(def->bandwidth, buf);
2171 2172
    virBufferAdjustIndent(buf, -2);
    virBufferAddLit(buf, "</portgroup>\n");
2173
    return 0;
2174 2175
}

2176 2177 2178 2179 2180 2181 2182 2183 2184 2185 2186 2187 2188 2189 2190 2191 2192 2193 2194 2195 2196 2197 2198 2199 2200 2201 2202 2203 2204 2205 2206 2207 2208 2209 2210 2211 2212 2213 2214 2215 2216
static int
virNetworkForwardNatDefFormat(virBufferPtr buf,
                              const virNetworkForwardDefPtr fwd)
{
    char *addrStart = NULL;
    char *addrEnd = NULL;
    int ret = -1;

    if (VIR_SOCKET_ADDR_VALID(&fwd->addrStart)) {
        addrStart = virSocketAddrFormat(&fwd->addrStart);
        if (!addrStart)
            goto cleanup;
    }

    if (VIR_SOCKET_ADDR_VALID(&fwd->addrEnd)) {
        addrEnd = virSocketAddrFormat(&fwd->addrEnd);
        if (!addrEnd)
            goto cleanup;
    }

    if (!addrEnd && !addrStart)
        return 0;

    virBufferAddLit(buf, "<nat>\n");
    virBufferAdjustIndent(buf, 2);

    virBufferAsprintf(buf, "<address start='%s'", addrStart);
    if (addrEnd)
        virBufferAsprintf(buf, " end='%s'", addrEnd);
    virBufferAddLit(buf, "/>\n");

    virBufferAdjustIndent(buf, -2);
    virBufferAddLit(buf, "</nat>\n");
    ret = 0;

cleanup:
    VIR_FREE(addrStart);
    VIR_FREE(addrEnd);
    return ret;
}

2217 2218 2219 2220
static int
virNetworkDefFormatInternal(virBufferPtr buf,
                            const virNetworkDefPtr def,
                            unsigned int flags)
2221 2222 2223
{
    unsigned char *uuid;
    char uuidstr[VIR_UUID_STRING_BUFLEN];
2224
    int ii, shortforward;
2225

2226
    virBufferAddLit(buf, "<network");
2227
    if (!(flags & VIR_NETWORK_XML_INACTIVE) && (def->connections > 0)) {
2228
        virBufferAsprintf(buf, " connections='%d'", def->connections);
2229
    }
2230
    if (def->ipv6nogw)
2231 2232 2233 2234
        virBufferAddLit(buf, " ipv6='yes'");
    virBufferAddLit(buf, ">\n");
    virBufferAdjustIndent(buf, 2);
    virBufferEscapeString(buf, "<name>%s</name>\n", def->name);
2235 2236 2237

    uuid = def->uuid;
    virUUIDFormat(uuid, uuidstr);
2238
    virBufferAsprintf(buf, "<uuid>%s</uuid>\n", uuidstr);
2239

2240
    if (def->forward.type != VIR_NETWORK_FORWARD_NONE) {
2241
        const char *dev = NULL;
2242
        if (!def->forward.npfs)
2243
            dev = virNetworkDefForwardIf(def, 0);
2244
        const char *mode = virNetworkForwardTypeToString(def->forward.type);
2245 2246

        if (!mode) {
2247 2248
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("Unknown forward type %d in network '%s'"),
2249
                           def->forward.type, def->name);
2250 2251
            goto error;
        }
2252 2253 2254
        virBufferAddLit(buf, "<forward");
        virBufferEscapeString(buf, " dev='%s'", dev);
        virBufferAsprintf(buf, " mode='%s'", mode);
2255 2256
        if (def->forward.type == VIR_NETWORK_FORWARD_HOSTDEV) {
            if (def->forward.managed)
2257
                virBufferAddLit(buf, " managed='yes'");
2258
            else
2259
                virBufferAddLit(buf, " managed='no'");
2260
        }
2261 2262 2263 2264
        shortforward = !(def->forward.nifs || def->forward.npfs
                         || VIR_SOCKET_ADDR_VALID(&def->forward.addrStart)
                         || VIR_SOCKET_ADDR_VALID(&def->forward.addrEnd));
        virBufferAsprintf(buf, "%s>\n", shortforward ? "/" : "");
2265
        virBufferAdjustIndent(buf, 2);
2266

2267 2268 2269 2270 2271
        if (def->forward.type == VIR_NETWORK_FORWARD_NAT) {
            if (virNetworkForwardNatDefFormat(buf, &def->forward) < 0)
                goto error;
        }

2272 2273
        /* For now, hard-coded to at most 1 forward.pfs */
        if (def->forward.npfs)
2274
            virBufferEscapeString(buf, "<pf dev='%s'/>\n",
2275
                                  def->forward.pfs[0].dev);
2276

2277 2278 2279 2280
        if (def->forward.nifs &&
            (!def->forward.npfs || !(flags & VIR_NETWORK_XML_INACTIVE))) {
            for (ii = 0; ii < def->forward.nifs; ii++) {
                if (def->forward.type != VIR_NETWORK_FORWARD_HOSTDEV) {
2281
                    virBufferEscapeString(buf, "<interface dev='%s'",
2282
                                          def->forward.ifs[ii].device.dev);
2283
                    if (!(flags & VIR_NETWORK_XML_INACTIVE) &&
2284
                        (def->forward.ifs[ii].connections > 0)) {
2285
                        virBufferAsprintf(buf, " connections='%d'",
2286
                                          def->forward.ifs[ii].connections);
2287
                    }
2288
                    virBufferAddLit(buf, "/>\n");
2289 2290
                }
                else {
2291
                    if (def->forward.ifs[ii].type ==  VIR_NETWORK_FORWARD_HOSTDEV_DEVICE_PCI) {
2292
                        if (virDevicePCIAddressFormat(buf,
2293
                                                      def->forward.ifs[ii].device.pci,
2294 2295 2296
                                                      true) < 0)
                            goto error;
                    }
2297
                }
2298 2299
            }
        }
2300
        virBufferAdjustIndent(buf, -2);
2301
        if (!shortforward)
2302
            virBufferAddLit(buf, "</forward>\n");
2303 2304
    }

2305 2306 2307
    if (def->forward.type == VIR_NETWORK_FORWARD_NONE ||
         def->forward.type == VIR_NETWORK_FORWARD_NAT ||
         def->forward.type == VIR_NETWORK_FORWARD_ROUTE) {
2308

2309
        virBufferAddLit(buf, "<bridge");
2310
        if (def->bridge)
2311 2312
            virBufferEscapeString(buf, " name='%s'", def->bridge);
        virBufferAsprintf(buf, " stp='%s' delay='%ld' />\n",
2313 2314
                          def->stp ? "on" : "off",
                          def->delay);
2315
    } else if (def->forward.type == VIR_NETWORK_FORWARD_BRIDGE &&
2316
               def->bridge) {
2317
        virBufferEscapeString(buf, "<bridge name='%s' />\n", def->bridge);
2318 2319 2320
    }


2321 2322
    if (def->mac_specified) {
        char macaddr[VIR_MAC_STRING_BUFLEN];
2323
        virMacAddrFormat(&def->mac, macaddr);
2324
        virBufferAsprintf(buf, "<mac address='%s'/>\n", macaddr);
2325
    }
2326

2327
    if (def->domain)
2328
        virBufferAsprintf(buf, "<domain name='%s'/>\n", def->domain);
2329

2330
    if (virNetworkDNSDefFormat(buf, &def->dns) < 0)
2331 2332
        goto error;

2333
    if (virNetDevVlanFormat(&def->vlan, buf) < 0)
2334
        goto error;
2335
    if (virNetDevBandwidthFormat(def->bandwidth, buf) < 0)
2336 2337
        goto error;

2338
    for (ii = 0; ii < def->nips; ii++) {
2339
        if (virNetworkIpDefFormat(buf, &def->ips[ii]) < 0)
2340
            goto error;
2341 2342
    }

2343
    if (virNetDevVPortProfileFormat(def->virtPortProfile, buf) < 0)
2344
        goto error;
2345 2346

    for (ii = 0; ii < def->nPortGroups; ii++)
2347
        if (virPortGroupDefFormat(buf, &def->portGroups[ii]) < 0)
2348
            goto error;
2349

2350 2351 2352 2353 2354 2355 2356 2357 2358 2359 2360 2361 2362 2363 2364 2365 2366 2367 2368 2369 2370 2371 2372 2373 2374 2375 2376 2377 2378 2379 2380 2381 2382 2383 2384 2385 2386 2387 2388 2389 2390 2391 2392 2393 2394 2395 2396 2397 2398
    virBufferAdjustIndent(buf, -2);
    virBufferAddLit(buf, "</network>\n");

    return 0;

error:
    return -1;
}

char *
virNetworkDefFormat(virNetworkDefPtr def,
                    unsigned int flags)
{
    virBuffer buf = VIR_BUFFER_INITIALIZER;

    if (virNetworkDefFormatInternal(&buf, def, flags) < 0)
        goto error;

    if (virBufferError(&buf))
        goto no_memory;

    return virBufferContentAndReset(&buf);

no_memory:
    virReportOOMError();
error:
    virBufferFreeAndReset(&buf);
    return NULL;
}

static char *
virNetworkObjFormat(virNetworkObjPtr net,
                    unsigned int flags)
{
    virBuffer buf = VIR_BUFFER_INITIALIZER;
    char *class_id = virBitmapFormat(net->class_id);

    if (!class_id)
        goto no_memory;

    virBufferAddLit(&buf, "<networkstatus>\n");
    virBufferAsprintf(&buf, "  <class_id bitmap='%s'/>\n", class_id);
    virBufferAsprintf(&buf, "  <floor sum='%llu'/>\n", net->floor_sum);
    VIR_FREE(class_id);

    virBufferAdjustIndent(&buf, 2);
    if (virNetworkDefFormatInternal(&buf, net->def, flags) < 0)
        goto error;

2399
    virBufferAdjustIndent(&buf, -2);
2400
    virBufferAddLit(&buf, "</networkstatus>");
2401 2402 2403 2404 2405 2406

    if (virBufferError(&buf))
        goto no_memory;

    return virBufferContentAndReset(&buf);

2407
no_memory:
2408
    virReportOOMError();
2409
error:
2410
    virBufferFreeAndReset(&buf);
2411 2412 2413
    return NULL;
}

2414 2415 2416 2417 2418 2419 2420 2421 2422 2423 2424 2425 2426 2427 2428 2429
virPortGroupDefPtr virPortGroupFindByName(virNetworkDefPtr net,
                                          const char *portgroup)
{
    int ii;
    for (ii = 0; ii < net->nPortGroups; ii++) {
        if (portgroup) {
            if (STREQ(portgroup, net->portGroups[ii].name))
                return &net->portGroups[ii];
        } else {
            if (net->portGroups[ii].isDefault)
                return &net->portGroups[ii];
        }
    }
    return NULL;
}

2430
int virNetworkSaveXML(const char *configDir,
2431 2432
                      virNetworkDefPtr def,
                      const char *xml)
2433
{
J
Ján Tomko 已提交
2434
    char uuidstr[VIR_UUID_STRING_BUFLEN];
2435
    char *configFile = NULL;
2436
    int ret = -1;
2437

2438
    if ((configFile = virNetworkConfigFile(configDir, def->name)) == NULL)
2439 2440
        goto cleanup;

2441 2442
    if (virFileMakePath(configDir) < 0) {
        virReportSystemError(errno,
2443 2444
                             _("cannot create config directory '%s'"),
                             configDir);
2445 2446 2447
        goto cleanup;
    }

J
Ján Tomko 已提交
2448 2449 2450 2451
    virUUIDFormat(def->uuid, uuidstr);
    ret = virXMLSaveFile(configFile,
                         virXMLPickShellSafeComment(def->name, uuidstr),
                         "net-edit", xml);
2452 2453

 cleanup:
2454 2455 2456 2457
    VIR_FREE(configFile);
    return ret;
}

2458
int virNetworkSaveConfig(const char *configDir,
2459 2460 2461 2462 2463
                         virNetworkDefPtr def)
{
    int ret = -1;
    char *xml;

2464
    if (!(xml = virNetworkDefFormat(def, VIR_NETWORK_XML_INACTIVE)))
2465 2466
        goto cleanup;

2467
    if (virNetworkSaveXML(configDir, def, xml))
2468 2469 2470 2471 2472
        goto cleanup;

    ret = 0;
cleanup:
    VIR_FREE(xml);
2473 2474 2475
    return ret;
}

2476

2477 2478 2479 2480
int virNetworkSaveStatus(const char *statusDir,
                         virNetworkObjPtr network)
{
    int ret = -1;
2481
    int flags = 0;
2482 2483
    char *xml;

2484
    if (!(xml = virNetworkObjFormat(network, flags)))
2485 2486 2487 2488 2489 2490 2491 2492 2493 2494 2495
        goto cleanup;

    if (virNetworkSaveXML(statusDir, network->def, xml))
        goto cleanup;

    ret = 0;
cleanup:
    VIR_FREE(xml);
    return ret;
}

2496
virNetworkObjPtr virNetworkLoadConfig(virNetworkObjListPtr nets,
2497 2498
                                      const char *configDir,
                                      const char *autostartDir,
2499
                                      const char *name)
2500 2501 2502 2503 2504 2505
{
    char *configFile = NULL, *autostartLink = NULL;
    virNetworkDefPtr def = NULL;
    virNetworkObjPtr net;
    int autostart;

2506
    if ((configFile = virNetworkConfigFile(configDir, name)) == NULL)
2507
        goto error;
2508
    if ((autostartLink = virNetworkConfigFile(autostartDir, name)) == NULL)
2509 2510 2511 2512 2513
        goto error;

    if ((autostart = virFileLinkPointsTo(autostartLink, configFile)) < 0)
        goto error;

2514
    if (!(def = virNetworkDefParseFile(configFile)))
2515 2516
        goto error;

2517
    if (!STREQ(name, def->name)) {
2518 2519 2520 2521
        virReportError(VIR_ERR_INTERNAL_ERROR,
                       _("Network config filename '%s'"
                         " does not match network name '%s'"),
                       configFile, def->name);
2522 2523 2524
        goto error;
    }

2525 2526 2527
    if (def->forward.type == VIR_NETWORK_FORWARD_NONE ||
        def->forward.type == VIR_NETWORK_FORWARD_NAT ||
        def->forward.type == VIR_NETWORK_FORWARD_ROUTE) {
2528 2529 2530 2531 2532 2533 2534

        /* Generate a bridge if none is specified, but don't check for collisions
         * if a bridge is hardcoded, so the network is at least defined.
         */
        if (virNetworkSetBridgeName(nets, def, 0))
            goto error;
    }
2535

2536
    if (!(net = virNetworkAssignDef(nets, def, false)))
2537 2538 2539
        goto error;

    net->autostart = autostart;
2540
    net->persistent = 1;
2541

2542 2543 2544
    VIR_FREE(configFile);
    VIR_FREE(autostartLink);

2545 2546 2547 2548 2549 2550 2551 2552 2553
    return net;

error:
    VIR_FREE(configFile);
    VIR_FREE(autostartLink);
    virNetworkDefFree(def);
    return NULL;
}

2554
int virNetworkLoadAllConfigs(virNetworkObjListPtr nets,
2555 2556 2557 2558 2559 2560 2561 2562 2563
                             const char *configDir,
                             const char *autostartDir)
{
    DIR *dir;
    struct dirent *entry;

    if (!(dir = opendir(configDir))) {
        if (errno == ENOENT)
            return 0;
2564
        virReportSystemError(errno,
2565 2566
                             _("Failed to open dir '%s'"),
                             configDir);
2567 2568 2569 2570
        return -1;
    }

    while ((entry = readdir(dir))) {
2571 2572
        virNetworkObjPtr net;

2573 2574 2575
        if (entry->d_name[0] == '.')
            continue;

2576
        if (!virFileStripSuffix(entry->d_name, ".xml"))
2577 2578 2579 2580
            continue;

        /* NB: ignoring errors, so one malformed config doesn't
           kill the whole process */
2581
        net = virNetworkLoadConfig(nets,
2582 2583 2584 2585 2586
                                   configDir,
                                   autostartDir,
                                   entry->d_name);
        if (net)
            virNetworkObjUnlock(net);
2587 2588 2589 2590 2591 2592 2593
    }

    closedir(dir);

    return 0;
}

2594
int virNetworkDeleteConfig(const char *configDir,
2595
                           const char *autostartDir,
2596 2597
                           virNetworkObjPtr net)
{
2598 2599
    char *configFile = NULL;
    char *autostartLink = NULL;
R
Ryota Ozaki 已提交
2600
    int ret = -1;
2601

2602
    if ((configFile = virNetworkConfigFile(configDir, net->def->name)) == NULL)
2603
        goto error;
2604
    if ((autostartLink = virNetworkConfigFile(autostartDir, net->def->name)) == NULL)
2605
        goto error;
2606 2607

    /* Not fatal if this doesn't work */
2608
    unlink(autostartLink);
2609

2610
    if (unlink(configFile) < 0) {
2611
        virReportSystemError(errno,
2612
                             _("cannot remove config file '%s'"),
2613 2614
                             configFile);
        goto error;
2615 2616
    }

R
Ryota Ozaki 已提交
2617
    ret = 0;
2618 2619 2620 2621

error:
    VIR_FREE(configFile);
    VIR_FREE(autostartLink);
R
Ryota Ozaki 已提交
2622
    return ret;
2623 2624
}

2625
char *virNetworkConfigFile(const char *dir,
2626 2627 2628 2629 2630
                           const char *name)
{
    char *ret = NULL;

    if (virAsprintf(&ret, "%s/%s.xml", dir, name) < 0) {
2631
        virReportOOMError();
2632 2633 2634 2635
        return NULL;
    }

    return ret;
2636
}
D
Daniel P. Berrange 已提交
2637

2638 2639 2640 2641 2642 2643 2644 2645 2646 2647 2648 2649 2650 2651 2652 2653 2654 2655 2656
int virNetworkBridgeInUse(const virNetworkObjListPtr nets,
                          const char *bridge,
                          const char *skipname)
{
    unsigned int i;
    unsigned int ret = 0;

    for (i = 0 ; i < nets->count ; i++) {
        virNetworkObjLock(nets->objs[i]);
        if (nets->objs[i]->def->bridge &&
            STREQ(nets->objs[i]->def->bridge, bridge) &&
            !(skipname && STREQ(nets->objs[i]->def->name, skipname)))
                ret = 1;
        virNetworkObjUnlock(nets->objs[i]);
    }

    return ret;
}

2657
char *virNetworkAllocateBridge(const virNetworkObjListPtr nets,
2658
                               const char *template)
2659 2660 2661 2662 2663
{

    int id = 0;
    char *newname;

2664 2665 2666
    if (!template)
        template = "virbr%d";

2667
    do {
2668 2669 2670 2671 2672
        if (virAsprintf(&newname, template, id) < 0) {
            virReportOOMError();
            return NULL;
        }
        if (!virNetworkBridgeInUse(nets, newname, NULL)) {
2673 2674
            return newname;
        }
2675
        VIR_FREE(newname);
2676 2677

        id++;
2678
    } while (id <= MAX_BRIDGE_ID);
2679

2680 2681 2682
    virReportError(VIR_ERR_INTERNAL_ERROR,
                   _("Bridge generation exceeded max id %d"),
                   MAX_BRIDGE_ID);
2683 2684 2685
    return NULL;
}

2686
int virNetworkSetBridgeName(const virNetworkObjListPtr nets,
2687 2688
                            virNetworkDefPtr def,
                            int check_collision) {
2689 2690 2691

    int ret = -1;

2692
    if (def->bridge && !strstr(def->bridge, "%d")) {
2693 2694 2695 2696 2697
        /* We may want to skip collision detection in this case (ex. when
         * loading configs at daemon startup, so the network is at least
         * defined. */
        if (check_collision &&
            virNetworkBridgeInUse(nets, def->bridge, def->name)) {
2698 2699 2700
            virReportError(VIR_ERR_INTERNAL_ERROR,
                           _("bridge name '%s' already in use."),
                           def->bridge);
2701 2702 2703 2704
            goto error;
        }
    } else {
        /* Allocate a bridge name */
2705
        if (!(def->bridge = virNetworkAllocateBridge(nets, def->bridge)))
2706 2707 2708 2709 2710 2711 2712
            goto error;
    }

    ret = 0;
error:
    return ret;
}
2713

2714

2715 2716 2717 2718 2719 2720
void virNetworkSetBridgeMacAddr(virNetworkDefPtr def)
{
    if (!def->mac_specified) {
        /* if the bridge doesn't have a mac address explicitly defined,
         * autogenerate a random one.
         */
2721
        virMacAddrGenerate((unsigned char[]){ 0x52, 0x54, 0 },
2722
                           &def->mac);
2723 2724 2725 2726
        def->mac_specified = true;
    }
}

2727 2728 2729 2730 2731 2732 2733 2734 2735
/* NetworkObj backend of the virNetworkUpdate API */

static void
virNetworkDefUpdateNoSupport(virNetworkDefPtr def, const char *section)
{
    virReportError(VIR_ERR_NO_SUPPORT,
                   _("can't update '%s' section of network '%s'"),
                   section, def->name);
}
2736 2737 2738 2739 2740 2741
static void
virNetworkDefUpdateUnknownCommand(unsigned int command)
{
    virReportError(VIR_ERR_NO_SUPPORT,
                   _("unrecognized network update command code %d"), command);
}
2742 2743 2744 2745 2746 2747 2748 2749 2750 2751 2752 2753 2754 2755 2756 2757 2758 2759 2760 2761 2762 2763 2764 2765 2766 2767 2768 2769 2770 2771 2772 2773 2774 2775 2776 2777 2778 2779 2780 2781 2782 2783 2784 2785 2786 2787 2788 2789 2790 2791 2792 2793

static int
virNetworkDefUpdateCheckElementName(virNetworkDefPtr def,
                                    xmlNodePtr node,
                                    const char *section)
{
    if (!xmlStrEqual(node->name, BAD_CAST section)) {
        virReportError(VIR_ERR_XML_ERROR,
                       _("unexpected element <%s>, expecting <%s>, "
                         "while updating network '%s'"),
                       node->name, section, def->name);
        return -1;
    }
    return 0;
}

static int
virNetworkDefUpdateBridge(virNetworkDefPtr def,
                          unsigned int command ATTRIBUTE_UNUSED,
                          int parentIndex ATTRIBUTE_UNUSED,
                          xmlXPathContextPtr ctxt ATTRIBUTE_UNUSED,
                          /* virNetworkUpdateFlags */
                          unsigned int fflags ATTRIBUTE_UNUSED)
{
    virNetworkDefUpdateNoSupport(def, "bridge");
    return -1;
}

static int
virNetworkDefUpdateDomain(virNetworkDefPtr def,
                          unsigned int command ATTRIBUTE_UNUSED,
                          int parentIndex ATTRIBUTE_UNUSED,
                          xmlXPathContextPtr ctxt ATTRIBUTE_UNUSED,
                          /* virNetworkUpdateFlags */
                          unsigned int fflags ATTRIBUTE_UNUSED)
{
    virNetworkDefUpdateNoSupport(def, "domain");
    return -1;
}

static int
virNetworkDefUpdateIP(virNetworkDefPtr def,
                      unsigned int command ATTRIBUTE_UNUSED,
                      int parentIndex ATTRIBUTE_UNUSED,
                      xmlXPathContextPtr ctxt ATTRIBUTE_UNUSED,
                      /* virNetworkUpdateFlags */
                      unsigned int fflags ATTRIBUTE_UNUSED)
{
    virNetworkDefUpdateNoSupport(def, "ip");
    return -1;
}

2794 2795 2796 2797 2798 2799 2800 2801 2802
static virNetworkIpDefPtr
virNetworkIpDefByIndex(virNetworkDefPtr def, int parentIndex)
{
    virNetworkIpDefPtr ipdef = NULL;
    int ii;

    /* first find which ip element's dhcp host list to work on */
    if (parentIndex >= 0) {
        ipdef = virNetworkDefGetIpByIndex(def, AF_UNSPEC, parentIndex);
G
Gene Czarcinski 已提交
2803
        if (!(ipdef)) {
2804
            virReportError(VIR_ERR_OPERATION_INVALID,
G
Gene Czarcinski 已提交
2805
                           _("couldn't update dhcp host entry - no <ip> "
2806 2807 2808 2809 2810 2811 2812 2813 2814 2815 2816 2817
                             "element found at index %d in network '%s'"),
                           parentIndex, def->name);
        }
        return ipdef;
    }

    /* -1 means "find the most appropriate", which in this case
     * means the one and only <ip> that has <dhcp> element
     */
    for (ii = 0;
         (ipdef = virNetworkDefGetIpByIndex(def, AF_UNSPEC, ii));
         ii++) {
G
Gene Czarcinski 已提交
2818
        if (ipdef->nranges || ipdef->nhosts)
2819 2820
            break;
    }
G
Gene Czarcinski 已提交
2821
    if (!ipdef) {
2822
        ipdef = virNetworkDefGetIpByIndex(def, AF_INET, 0);
G
Gene Czarcinski 已提交
2823 2824 2825
        if (!ipdef)
            ipdef = virNetworkDefGetIpByIndex(def, AF_INET6, 0);
    }
2826 2827
    if (!ipdef) {
        virReportError(VIR_ERR_OPERATION_INVALID,
G
Gene Czarcinski 已提交
2828
                       _("couldn't update dhcp host entry - no <ip> "
2829 2830 2831 2832 2833
                         "element found in network '%s'"), def->name);
    }
    return ipdef;
}

2834 2835
static int
virNetworkDefUpdateIPDHCPHost(virNetworkDefPtr def,
2836 2837 2838
                              unsigned int command,
                              int parentIndex,
                              xmlXPathContextPtr ctxt,
2839 2840 2841
                              /* virNetworkUpdateFlags */
                              unsigned int fflags ATTRIBUTE_UNUSED)
{
2842 2843 2844 2845 2846 2847 2848 2849 2850 2851 2852 2853 2854 2855 2856 2857
    int ii, ret = -1;
    virNetworkIpDefPtr ipdef = virNetworkIpDefByIndex(def, parentIndex);
    virNetworkDHCPHostDef host;

    memset(&host, 0, sizeof(host));

    if (virNetworkDefUpdateCheckElementName(def, ctxt->node, "host") < 0)
        goto cleanup;

    /* ipdef is the ip element that needs its host array updated */
    if (!ipdef)
        goto cleanup;

    /* parse the xml into a virNetworkDHCPHostDef */
    if (command == VIR_NETWORK_UPDATE_COMMAND_MODIFY) {

G
Gene Czarcinski 已提交
2858 2859
        if (virNetworkDHCPHostDefParseXML(def->name, ipdef,
                                          ctxt->node, &host, false) < 0) {
2860
            goto cleanup;
G
Gene Czarcinski 已提交
2861
        }
2862 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

        /* search for the entry with this (mac|name),
         * and update the IP+(mac|name) */
        for (ii = 0; ii < ipdef->nhosts; ii++) {
            if ((host.mac &&
                 !virMacAddrCompare(host.mac, ipdef->hosts[ii].mac)) ||
                (host.name &&
                 STREQ_NULLABLE(host.name, ipdef->hosts[ii].name))) {
                break;
            }
        }

        if (ii == ipdef->nhosts) {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("couldn't locate an existing dhcp host entry with "
                             "\"mac='%s'\" in network '%s'"),
                           host.mac, def->name);
            goto cleanup;
        }

        /* clear the existing hosts entry, move the new one in its place,
         * then clear out the extra copy to get rid of the duplicate pointers
         * to its data (mac and name strings).
         */
        virNetworkDHCPHostDefClear(&ipdef->hosts[ii]);
        ipdef->hosts[ii] = host;
        memset(&host, 0, sizeof(host));

    } else if ((command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST) ||
               (command == VIR_NETWORK_UPDATE_COMMAND_ADD_LAST)) {

G
Gene Czarcinski 已提交
2893 2894
        if (virNetworkDHCPHostDefParseXML(def->name, ipdef,
                                          ctxt->node, &host, true) < 0) {
2895
            goto cleanup;
G
Gene Czarcinski 已提交
2896
        }
2897 2898 2899 2900 2901 2902 2903 2904 2905 2906 2907 2908 2909 2910 2911 2912 2913 2914 2915 2916 2917

        /* log error if an entry with same name/address/ip already exists */
        for (ii = 0; ii < ipdef->nhosts; ii++) {
            if ((host.mac &&
                 !virMacAddrCompare(host.mac, ipdef->hosts[ii].mac)) ||
                (host.name &&
                 STREQ_NULLABLE(host.name, ipdef->hosts[ii].name)) ||
                (VIR_SOCKET_ADDR_VALID(&host.ip) &&
                 virSocketAddrEqual(&host.ip, &ipdef->hosts[ii].ip))) {
                char *ip = virSocketAddrFormat(&host.ip);

                virReportError(VIR_ERR_OPERATION_INVALID,
                               _("there is an existing dhcp host entry in "
                                 "network '%s' that matches "
                                 "\"<host mac='%s' name='%s' ip='%s'/>\""),
                               def->name, host.mac, host.name,
                               ip ? ip : "unknown");
                VIR_FREE(ip);
                goto cleanup;
            }
        }
2918

2919
        /* add to beginning/end of list */
2920 2921 2922 2923
        if (VIR_INSERT_ELEMENT(ipdef->hosts,
                               command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST
                               ? 0 : ipdef->nhosts,
                               ipdef->nhosts, host) < 0) {
2924 2925 2926 2927 2928
            virReportOOMError();
            goto cleanup;
        }
    } else if (command == VIR_NETWORK_UPDATE_COMMAND_DELETE) {

G
Gene Czarcinski 已提交
2929 2930
        if (virNetworkDHCPHostDefParseXML(def->name, ipdef,
                                          ctxt->node, &host, false) < 0) {
2931
            goto cleanup;
G
Gene Czarcinski 已提交
2932
        }
2933 2934 2935 2936 2937 2938 2939 2940 2941 2942 2943 2944 2945 2946 2947 2948 2949 2950 2951 2952 2953

        /* find matching entry - all specified attributes must match */
        for (ii = 0; ii < ipdef->nhosts; ii++) {
            if ((!host.mac ||
                 !virMacAddrCompare(host.mac, ipdef->hosts[ii].mac)) &&
                (!host.name ||
                 STREQ_NULLABLE(host.name, ipdef->hosts[ii].name)) &&
                (!VIR_SOCKET_ADDR_VALID(&host.ip) ||
                 virSocketAddrEqual(&host.ip, &ipdef->hosts[ii].ip))) {
                break;
            }
        }
        if (ii == ipdef->nhosts) {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("couldn't locate a matching dhcp host entry "
                             "in network '%s'"), def->name);
            goto cleanup;
        }

        /* remove it */
        virNetworkDHCPHostDefClear(&ipdef->hosts[ii]);
2954 2955
        VIR_DELETE_ELEMENT(ipdef->hosts, ii, ipdef->nhosts);

2956 2957 2958
    } else {
        virNetworkDefUpdateUnknownCommand(command);
        goto cleanup;
2959 2960 2961 2962 2963 2964
    }

    ret = 0;
cleanup:
    virNetworkDHCPHostDefClear(&host);
    return ret;
2965 2966 2967 2968
}

static int
virNetworkDefUpdateIPDHCPRange(virNetworkDefPtr def,
2969
                               unsigned int command,
2970
                               int parentIndex ATTRIBUTE_UNUSED,
2971
                               xmlXPathContextPtr ctxt,
2972 2973 2974
                               /* virNetworkUpdateFlags */
                               unsigned int fflags ATTRIBUTE_UNUSED)
{
2975 2976 2977 2978 2979 2980 2981 2982 2983 2984 2985 2986 2987 2988 2989 2990 2991 2992 2993 2994 2995 2996
    int ii, ret = -1;
    virNetworkIpDefPtr ipdef = virNetworkIpDefByIndex(def, parentIndex);
    virNetworkDHCPRangeDef range;

    memset(&range, 0, sizeof(range));

    if (virNetworkDefUpdateCheckElementName(def, ctxt->node, "range") < 0)
        goto cleanup;

    /* ipdef is the ip element that needs its range array updated */
    if (!ipdef)
        goto cleanup;

    /* parse the xml into a virNetworkDHCPRangeDef */
    if (command == VIR_NETWORK_UPDATE_COMMAND_MODIFY) {

        virReportError(VIR_ERR_NO_SUPPORT, "%s",
                       _("dhcp ranges cannot be modified, "
                         "only added or deleted"));
        goto cleanup;
    }

2997
    if (virNetworkDHCPRangeDefParseXML(def->name, ctxt->node, &range) < 0)
2998 2999 3000 3001 3002 3003 3004 3005 3006 3007 3008 3009 3010 3011 3012 3013 3014 3015 3016 3017 3018 3019 3020 3021 3022 3023 3024 3025
        goto cleanup;

    /* check if an entry with same name/address/ip already exists */
    for (ii = 0; ii < ipdef->nranges; ii++) {
        if (virSocketAddrEqual(&range.start, &ipdef->ranges[ii].start) &&
            virSocketAddrEqual(&range.end, &ipdef->ranges[ii].end)) {
            break;
        }
    }

    if ((command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST) ||
        (command == VIR_NETWORK_UPDATE_COMMAND_ADD_LAST)) {

        if (ii < ipdef->nranges) {
            char *startip = virSocketAddrFormat(&range.start);
            char *endip = virSocketAddrFormat(&range.end);

            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("there is an existing dhcp range entry in "
                             "network '%s' that matches "
                             "\"<range start='%s' end='%s'/>\""),
                           def->name,
                           startip ? startip : "unknown",
                           endip ? endip : "unknown");
            goto cleanup;
        }

        /* add to beginning/end of list */
3026 3027 3028 3029
        if (VIR_INSERT_ELEMENT(ipdef->ranges,
                               command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST
                               ? 0 : ipdef->nranges,
                               ipdef->nranges, range) < 0) {
3030 3031 3032 3033 3034 3035 3036 3037 3038 3039 3040 3041 3042 3043 3044
            virReportOOMError();
            goto cleanup;
        }

    } else if (command == VIR_NETWORK_UPDATE_COMMAND_DELETE) {

        if (ii == ipdef->nranges) {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("couldn't locate a matching dhcp range entry "
                             "in network '%s'"), def->name);
            goto cleanup;
        }

        /* remove it */
        /* NB: nothing to clear from a RangeDef that's being freed */
3045 3046
        VIR_DELETE_ELEMENT(ipdef->ranges, ii, ipdef->nranges);

3047 3048 3049
    } else {
        virNetworkDefUpdateUnknownCommand(command);
        goto cleanup;
3050 3051 3052 3053 3054
    }

    ret = 0;
cleanup:
    return ret;
3055 3056 3057 3058 3059 3060 3061 3062 3063 3064 3065 3066 3067 3068 3069 3070
}

static int
virNetworkDefUpdateForward(virNetworkDefPtr def,
                           unsigned int command ATTRIBUTE_UNUSED,
                           int parentIndex ATTRIBUTE_UNUSED,
                           xmlXPathContextPtr ctxt ATTRIBUTE_UNUSED,
                           /* virNetworkUpdateFlags */
                           unsigned int fflags ATTRIBUTE_UNUSED)
{
    virNetworkDefUpdateNoSupport(def, "forward");
    return -1;
}

static int
virNetworkDefUpdateForwardInterface(virNetworkDefPtr def,
3071
                                    unsigned int command,
3072
                                    int parentIndex ATTRIBUTE_UNUSED,
3073
                                    xmlXPathContextPtr ctxt,
3074 3075 3076
                                    /* virNetworkUpdateFlags */
                                    unsigned int fflags ATTRIBUTE_UNUSED)
{
3077 3078 3079 3080 3081 3082 3083 3084 3085 3086 3087 3088 3089 3090 3091 3092 3093 3094 3095 3096 3097 3098 3099 3100
    int ii, ret = -1;
    virNetworkForwardIfDef iface;

    memset(&iface, 0, sizeof(iface));

    if (virNetworkDefUpdateCheckElementName(def, ctxt->node, "interface") < 0)
        goto cleanup;

    if (command == VIR_NETWORK_UPDATE_COMMAND_MODIFY) {
        virReportError(VIR_ERR_NO_SUPPORT, "%s",
                       _("forward interface entries cannot be modified, "
                         "only added or deleted"));
        goto cleanup;
    }

    /* parsing this is so simple that it doesn't have its own function */
    iface.type = VIR_NETWORK_FORWARD_HOSTDEV_DEVICE_NETDEV;
    if (!(iface.device.dev = virXMLPropString(ctxt->node, "dev"))) {
        virReportError(VIR_ERR_XML_ERROR, "%s",
                       _("missing dev attribute in <interface> element"));
        goto cleanup;
    }

    /* check if an <interface> with same dev name already exists */
3101 3102
    for (ii = 0; ii < def->forward.nifs; ii++) {
        if (def->forward.ifs[ii].type
3103
            == VIR_NETWORK_FORWARD_HOSTDEV_DEVICE_NETDEV &&
3104
            STREQ(iface.device.dev, def->forward.ifs[ii].device.dev))
3105 3106 3107 3108 3109 3110
            break;
    }

    if ((command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST) ||
        (command == VIR_NETWORK_UPDATE_COMMAND_ADD_LAST)) {

3111
        if (ii < def->forward.nifs) {
3112 3113 3114 3115 3116 3117 3118 3119 3120
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("there is an existing interface entry "
                             "in network '%s' that matches "
                             "\"<interface dev='%s'>\""),
                           def->name, iface.device.dev);
            goto cleanup;
        }

        /* add to beginning/end of list */
3121
        if (VIR_INSERT_ELEMENT(def->forward.ifs,
3122
                               command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST
3123 3124
                               ? 0 : def->forward.nifs,
                               def->forward.nifs, iface) < 0) {
3125 3126 3127 3128 3129 3130
            virReportOOMError();
            goto cleanup;
        }

    } else if (command == VIR_NETWORK_UPDATE_COMMAND_DELETE) {

3131
        if (ii == def->forward.nifs) {
3132 3133 3134 3135 3136 3137 3138 3139
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("couldn't find an interface entry "
                             "in network '%s' matching <interface dev='%s'>"),
                           def->name, iface.device.dev);
            goto cleanup;
        }

        /* fail if the interface is being used */
3140
        if (def->forward.ifs[ii].connections > 0) {
3141 3142 3143 3144 3145
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("unable to delete interface '%s' "
                             "in network '%s'. It is currently being used "
                             " by %d domains."),
                           iface.device.dev, def->name,
3146
                           def->forward.ifs[ii].connections);
3147 3148 3149 3150
            goto cleanup;
        }

        /* remove it */
3151 3152
        virNetworkForwardIfDefClear(&def->forward.ifs[ii]);
        VIR_DELETE_ELEMENT(def->forward.ifs, ii, def->forward.nifs);
3153

3154 3155 3156 3157 3158 3159 3160 3161 3162
    } else {
        virNetworkDefUpdateUnknownCommand(command);
        goto cleanup;
    }

    ret = 0;
cleanup:
    virNetworkForwardIfDefClear(&iface);
    return ret;
3163 3164 3165 3166 3167 3168 3169 3170 3171 3172 3173 3174 3175 3176 3177
}

static int
virNetworkDefUpdateForwardPF(virNetworkDefPtr def,
                             unsigned int command ATTRIBUTE_UNUSED,
                             int parentIndex ATTRIBUTE_UNUSED,
                             xmlXPathContextPtr ctxt ATTRIBUTE_UNUSED,
                             /* virNetworkUpdateFlags */
                             unsigned int fflags ATTRIBUTE_UNUSED)
{
    virNetworkDefUpdateNoSupport(def, "forward pf");
    return -1;
}

static int
3178 3179
virNetworkDefUpdatePortGroup(virNetworkDefPtr def,
                             unsigned int command,
3180
                             int parentIndex ATTRIBUTE_UNUSED,
3181
                             xmlXPathContextPtr ctxt,
3182 3183 3184
                             /* virNetworkUpdateFlags */
                             unsigned int fflags ATTRIBUTE_UNUSED)
{
3185 3186
    int ii, foundName = -1, foundDefault = -1;
    int ret = -1;
3187 3188 3189 3190 3191 3192 3193 3194 3195 3196 3197 3198 3199
    virPortGroupDef portgroup;

    memset(&portgroup, 0, sizeof(portgroup));

    if (virNetworkDefUpdateCheckElementName(def, ctxt->node, "portgroup") < 0)
        goto cleanup;

    if (virNetworkPortGroupParseXML(&portgroup, ctxt->node, ctxt) < 0)
        goto cleanup;

    /* check if a portgroup with same name already exists */
    for (ii = 0; ii < def->nPortGroups; ii++) {
        if (STREQ(portgroup.name, def->portGroups[ii].name))
3200 3201 3202
            foundName = ii;
        if (def->portGroups[ii].isDefault)
            foundDefault = ii;
3203
    }
3204
    if (foundName == -1 &&
3205 3206 3207 3208 3209 3210 3211
        ((command == VIR_NETWORK_UPDATE_COMMAND_MODIFY) ||
         (command == VIR_NETWORK_UPDATE_COMMAND_DELETE))) {
        virReportError(VIR_ERR_OPERATION_INVALID,
                       _("couldn't find a portgroup entry "
                         "in network '%s' matching <portgroup name='%s'>"),
                       def->name, portgroup.name);
        goto cleanup;
3212
    } else if (foundName >= 0 &&
3213 3214 3215 3216 3217 3218 3219 3220 3221 3222
               ((command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST) ||
                (command == VIR_NETWORK_UPDATE_COMMAND_ADD_LAST))) {
        virReportError(VIR_ERR_OPERATION_INVALID,
                       _("there is an existing portgroup entry in "
                         "network '%s' that matches "
                         "\"<portgroup name='%s'>\""),
                       def->name, portgroup.name);
        goto cleanup;
    }

3223 3224 3225 3226 3227 3228 3229 3230 3231 3232 3233 3234 3235 3236
    /* if there is already a different default, we can't make this
     * one the default.
     */
    if (command != VIR_NETWORK_UPDATE_COMMAND_DELETE &&
        portgroup.isDefault &&
        foundDefault >= 0 && foundDefault != foundName) {
        virReportError(VIR_ERR_OPERATION_INVALID,
                       _("a different portgroup entry in "
                         "network '%s' is already set as the default. "
                         "Only one default is allowed."),
                       def->name);
        goto cleanup;
    }

3237 3238 3239
    if (command == VIR_NETWORK_UPDATE_COMMAND_MODIFY) {

        /* replace existing entry */
3240 3241
        virPortGroupDefClear(&def->portGroups[foundName]);
        def->portGroups[foundName] = portgroup;
3242 3243 3244 3245 3246 3247
        memset(&portgroup, 0, sizeof(portgroup));

    } else if ((command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST) ||
        (command == VIR_NETWORK_UPDATE_COMMAND_ADD_LAST)) {

        /* add to beginning/end of list */
3248 3249 3250 3251
        if (VIR_INSERT_ELEMENT(def->portGroups,
                               command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST
                               ? 0 : def->nPortGroups,
                               def->nPortGroups, portgroup) < 0) {
3252 3253 3254 3255 3256 3257 3258
            virReportOOMError();
            goto cleanup;
        }

    } else if (command == VIR_NETWORK_UPDATE_COMMAND_DELETE) {

        /* remove it */
3259
        virPortGroupDefClear(&def->portGroups[foundName]);
3260 3261
        VIR_DELETE_ELEMENT(def->portGroups, foundName, def->nPortGroups);

3262 3263 3264
    } else {
        virNetworkDefUpdateUnknownCommand(command);
        goto cleanup;
3265 3266 3267 3268 3269 3270
    }

    ret = 0;
cleanup:
    virPortGroupDefClear(&portgroup);
    return ret;
3271 3272 3273 3274 3275 3276 3277 3278 3279 3280
}

static int
virNetworkDefUpdateDNSHost(virNetworkDefPtr def,
                           unsigned int command ATTRIBUTE_UNUSED,
                           int parentIndex ATTRIBUTE_UNUSED,
                           xmlXPathContextPtr ctxt ATTRIBUTE_UNUSED,
                           /* virNetworkUpdateFlags */
                           unsigned int fflags ATTRIBUTE_UNUSED)
{
E
Eric Blake 已提交
3281
    int ii, jj, kk, foundIdx = -1, ret = -1;
3282 3283 3284 3285
    virNetworkDNSDefPtr dns = &def->dns;
    virNetworkDNSHostDef host;
    bool isAdd = (command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST ||
                  command == VIR_NETWORK_UPDATE_COMMAND_ADD_LAST);
3286
    int foundCt = 0;
3287 3288 3289 3290 3291 3292 3293 3294 3295 3296 3297 3298 3299 3300 3301 3302 3303 3304 3305 3306 3307 3308 3309 3310 3311 3312 3313 3314 3315 3316 3317 3318 3319 3320 3321 3322 3323 3324 3325 3326 3327 3328 3329 3330 3331 3332 3333 3334 3335 3336 3337 3338 3339 3340 3341 3342 3343 3344 3345 3346 3347 3348 3349 3350 3351 3352 3353 3354 3355 3356 3357 3358 3359 3360 3361 3362 3363 3364 3365 3366

    memset(&host, 0, sizeof(host));

    if (command == VIR_NETWORK_UPDATE_COMMAND_MODIFY) {
        virReportError(VIR_ERR_NO_SUPPORT, "%s",
                       _("DNS HOST records cannot be modified, "
                         "only added or deleted"));
        goto cleanup;
    }

    if (virNetworkDefUpdateCheckElementName(def, ctxt->node, "host") < 0)
        goto cleanup;

    if (virNetworkDNSHostDefParseXML(def->name, ctxt->node, &host, !isAdd) < 0)
        goto cleanup;

    for (ii = 0; ii < dns->nhosts; ii++) {
        bool foundThisTime = false;

        if (virSocketAddrEqual(&host.ip, &dns->hosts[ii].ip))
            foundThisTime = true;

        for (jj = 0; jj < host.nnames && !foundThisTime; jj++) {
            for (kk = 0; kk < dns->hosts[ii].nnames && !foundThisTime; kk++) {
                if (STREQ(host.names[jj], dns->hosts[ii].names[kk]))
                    foundThisTime = true;
            }
        }
        if (foundThisTime) {
            foundCt++;
            foundIdx = ii;
        }
    }

    if (isAdd) {

        if (foundCt > 0) {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("there is already at least one DNS HOST "
                             "record with a matching field in network %s"),
                           def->name);
            goto cleanup;
        }

        /* add to beginning/end of list */
        if (VIR_INSERT_ELEMENT(dns->hosts,
                               command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST
                               ? 0 : dns->nhosts, dns->nhosts, host) < 0) {
            virReportOOMError();
            goto cleanup;
        }

    } else if (command == VIR_NETWORK_UPDATE_COMMAND_DELETE) {

        if (foundCt == 0) {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("couldn't locate a matching DNS HOST "
                             "record in network %s"), def->name);
            goto cleanup;
        }
        if (foundCt > 1) {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("multiple matching DNS HOST records were "
                             "found in network %s"), def->name);
            goto cleanup;
        }

        /* remove it */
        virNetworkDNSHostDefClear(&dns->hosts[foundIdx]);
        VIR_DELETE_ELEMENT(dns->hosts, foundIdx, dns->nhosts);

    } else {
        virNetworkDefUpdateUnknownCommand(command);
        goto cleanup;
    }

    ret = 0;
cleanup:
    virNetworkDNSHostDefClear(&host);
    return ret;
3367 3368 3369
}

static int
3370
virNetworkDefUpdateDNSSrv(virNetworkDefPtr def,
3371 3372 3373 3374 3375 3376
                          unsigned int command ATTRIBUTE_UNUSED,
                          int parentIndex ATTRIBUTE_UNUSED,
                          xmlXPathContextPtr ctxt ATTRIBUTE_UNUSED,
                          /* virNetworkUpdateFlags */
                          unsigned int fflags ATTRIBUTE_UNUSED)
{
3377
    int ii, foundIdx = -1, ret = -1;
3378 3379 3380 3381
    virNetworkDNSDefPtr dns = &def->dns;
    virNetworkDNSSrvDef srv;
    bool isAdd = (command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST ||
                  command == VIR_NETWORK_UPDATE_COMMAND_ADD_LAST);
3382
    int foundCt = 0;
3383 3384 3385 3386 3387 3388 3389 3390 3391 3392 3393 3394 3395 3396 3397 3398 3399 3400 3401 3402 3403 3404 3405 3406 3407 3408 3409 3410 3411 3412 3413 3414 3415 3416 3417 3418 3419 3420 3421 3422 3423 3424 3425 3426 3427 3428 3429 3430 3431 3432 3433 3434 3435 3436 3437 3438 3439 3440 3441 3442 3443 3444 3445 3446 3447 3448 3449 3450 3451 3452 3453 3454

    memset(&srv, 0, sizeof(srv));

    if (command == VIR_NETWORK_UPDATE_COMMAND_MODIFY) {
        virReportError(VIR_ERR_NO_SUPPORT, "%s",
                       _("DNS SRV records cannot be modified, "
                         "only added or deleted"));
        goto cleanup;
    }

    if (virNetworkDefUpdateCheckElementName(def, ctxt->node, "srv") < 0)
        goto cleanup;

    if (virNetworkDNSSrvDefParseXML(def->name, ctxt->node, ctxt, &srv, !isAdd) < 0)
        goto cleanup;

    for (ii = 0; ii < dns->nsrvs; ii++) {
        if ((!srv.domain || STREQ_NULLABLE(srv.domain, dns->srvs[ii].domain)) &&
            (!srv.service || STREQ_NULLABLE(srv.service, dns->srvs[ii].service)) &&
            (!srv.protocol || STREQ_NULLABLE(srv.protocol, dns->srvs[ii].protocol)) &&
            (!srv.target || STREQ_NULLABLE(srv.target, dns->srvs[ii].target))) {
            foundCt++;
            foundIdx = ii;
        }
    }

    if (isAdd) {

        if (foundCt > 0) {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("there is already at least one DNS SRV "
                             "record matching all specified fields in network %s"),
                           def->name);
            goto cleanup;
        }

        /* add to beginning/end of list */
        if (VIR_INSERT_ELEMENT(dns->srvs,
                               command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST
                               ? 0 : dns->nsrvs, dns->nsrvs, srv) < 0) {
            virReportOOMError();
            goto cleanup;
        }

    } else if (command == VIR_NETWORK_UPDATE_COMMAND_DELETE) {

        if (foundCt == 0) {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("couldn't locate a matching DNS SRV "
                             "record in network %s"), def->name);
            goto cleanup;
        }
        if (foundCt > 1) {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("multiple DNS SRV records matching all specified "
                             "fields were found in network %s"), def->name);
            goto cleanup;
        }

        /* remove it */
        virNetworkDNSSrvDefClear(&dns->srvs[foundIdx]);
        VIR_DELETE_ELEMENT(dns->srvs, foundIdx, dns->nsrvs);

    } else {
        virNetworkDefUpdateUnknownCommand(command);
        goto cleanup;
    }

    ret = 0;
cleanup:
    virNetworkDNSSrvDefClear(&srv);
    return ret;
3455 3456 3457
}

static int
3458
virNetworkDefUpdateDNSTxt(virNetworkDefPtr def,
3459 3460 3461 3462 3463 3464
                          unsigned int command ATTRIBUTE_UNUSED,
                          int parentIndex ATTRIBUTE_UNUSED,
                          xmlXPathContextPtr ctxt ATTRIBUTE_UNUSED,
                          /* virNetworkUpdateFlags */
                          unsigned int fflags ATTRIBUTE_UNUSED)
{
3465 3466 3467 3468 3469 3470 3471 3472 3473 3474 3475 3476 3477 3478 3479 3480 3481 3482 3483 3484 3485 3486 3487 3488 3489 3490 3491 3492 3493 3494 3495 3496 3497 3498 3499 3500 3501 3502 3503 3504 3505 3506 3507 3508 3509 3510 3511 3512 3513 3514 3515 3516 3517 3518 3519 3520 3521 3522 3523 3524 3525 3526 3527 3528 3529 3530
    int foundIdx, ret = -1;
    virNetworkDNSDefPtr dns = &def->dns;
    virNetworkDNSTxtDef txt;
    bool isAdd = (command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST ||
                  command == VIR_NETWORK_UPDATE_COMMAND_ADD_LAST);

    memset(&txt, 0, sizeof(txt));

    if (command == VIR_NETWORK_UPDATE_COMMAND_MODIFY) {
        virReportError(VIR_ERR_NO_SUPPORT, "%s",
                       _("DNS TXT records cannot be modified, "
                         "only added or deleted"));
        goto cleanup;
    }

    if (virNetworkDefUpdateCheckElementName(def, ctxt->node, "txt") < 0)
        goto cleanup;

    if (virNetworkDNSTxtDefParseXML(def->name, ctxt->node, &txt, !isAdd) < 0)
        goto cleanup;

    for (foundIdx = 0; foundIdx < dns->ntxts; foundIdx++) {
        if (STREQ(txt.name, dns->txts[foundIdx].name))
            break;
    }

    if (isAdd) {

        if (foundIdx < dns->ntxts) {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("there is already a DNS TXT record "
                             "with name '%s' in network %s"),
                           txt.name, def->name);
            goto cleanup;
        }

        /* add to beginning/end of list */
        if (VIR_INSERT_ELEMENT(dns->txts,
                               command == VIR_NETWORK_UPDATE_COMMAND_ADD_FIRST
                               ? 0 : dns->ntxts, dns->ntxts, txt) < 0) {
            virReportOOMError();
            goto cleanup;
        }

    } else if (command == VIR_NETWORK_UPDATE_COMMAND_DELETE) {

        if (foundIdx == dns->ntxts) {
            virReportError(VIR_ERR_OPERATION_INVALID,
                           _("couldn't locate a matching DNS TXT "
                             "record in network %s"), def->name);
            goto cleanup;
        }

        /* remove it */
        virNetworkDNSTxtDefClear(&dns->txts[foundIdx]);
        VIR_DELETE_ELEMENT(dns->txts, foundIdx, dns->ntxts);

    } else {
        virNetworkDefUpdateUnknownCommand(command);
        goto cleanup;
    }

    ret = 0;
cleanup:
    virNetworkDNSTxtDefClear(&txt);
    return ret;
3531 3532 3533 3534 3535 3536 3537 3538 3539 3540 3541 3542 3543 3544 3545 3546 3547 3548 3549 3550 3551 3552 3553 3554 3555 3556 3557 3558 3559 3560 3561 3562 3563 3564 3565 3566 3567 3568 3569 3570 3571 3572 3573 3574 3575 3576 3577 3578 3579
}

static int
virNetworkDefUpdateSection(virNetworkDefPtr def,
                           unsigned int command, /* virNetworkUpdateCommand */
                           unsigned int section, /* virNetworkUpdateSection */
                           int parentIndex,
                           const char *xml,
                           unsigned int flags)  /* virNetworkUpdateFlags */
{
    int ret = -1;
    xmlDocPtr doc;
    xmlXPathContextPtr ctxt = NULL;

    if (!(doc = virXMLParseStringCtxt(xml, _("network_update_xml"), &ctxt)))
        goto cleanup;

    switch (section) {
    case VIR_NETWORK_SECTION_BRIDGE:
       ret = virNetworkDefUpdateBridge(def, command, parentIndex, ctxt, flags);
        break;

    case VIR_NETWORK_SECTION_DOMAIN:
        ret = virNetworkDefUpdateDomain(def, command, parentIndex, ctxt, flags);
        break;
    case VIR_NETWORK_SECTION_IP:
        ret = virNetworkDefUpdateIP(def, command, parentIndex, ctxt, flags);
        break;
    case VIR_NETWORK_SECTION_IP_DHCP_HOST:
        ret = virNetworkDefUpdateIPDHCPHost(def, command,
                                            parentIndex, ctxt, flags);
        break;
    case VIR_NETWORK_SECTION_IP_DHCP_RANGE:
        ret = virNetworkDefUpdateIPDHCPRange(def, command,
                                             parentIndex, ctxt, flags);
        break;
    case VIR_NETWORK_SECTION_FORWARD:
        ret = virNetworkDefUpdateForward(def, command,
                                         parentIndex, ctxt, flags);
        break;
    case VIR_NETWORK_SECTION_FORWARD_INTERFACE:
        ret = virNetworkDefUpdateForwardInterface(def, command,
                                                  parentIndex, ctxt, flags);
        break;
    case VIR_NETWORK_SECTION_FORWARD_PF:
        ret = virNetworkDefUpdateForwardPF(def, command,
                                           parentIndex, ctxt, flags);
        break;
    case VIR_NETWORK_SECTION_PORTGROUP:
3580
        ret = virNetworkDefUpdatePortGroup(def, command,
3581 3582 3583 3584 3585 3586 3587 3588 3589 3590 3591 3592 3593 3594 3595 3596 3597 3598 3599 3600 3601 3602 3603 3604 3605 3606 3607 3608 3609 3610 3611 3612 3613 3614 3615 3616 3617 3618 3619 3620 3621 3622 3623 3624 3625 3626 3627
                                           parentIndex, ctxt, flags);
        break;
    case VIR_NETWORK_SECTION_DNS_HOST:
        ret = virNetworkDefUpdateDNSHost(def, command,
                                         parentIndex, ctxt, flags);
        break;
    case VIR_NETWORK_SECTION_DNS_TXT:
        ret = virNetworkDefUpdateDNSTxt(def, command, parentIndex, ctxt, flags);
        break;
    case VIR_NETWORK_SECTION_DNS_SRV:
        ret = virNetworkDefUpdateDNSSrv(def, command, parentIndex, ctxt, flags);
        break;
    default:
        virReportError(VIR_ERR_NO_SUPPORT, "%s",
                       _("can't update unrecognized section of network"));
        break;
    }

cleanup:
    xmlFreeDoc(doc);
    xmlXPathFreeContext(ctxt);
    return ret;
}

/*
 * virNetworkObjUpdate:
 *
 * Apply the supplied update to the given virNetworkObj. Except for
 * @network pointing to an actual network object rather than the
 * opaque virNetworkPtr, parameters are identical to the public API
 * virNetworkUpdate.
 *
 * The original virNetworkDefs are copied, and all modifications made
 * to these copies. The originals are replaced with the copies only
 * after success has been guaranteed.
 *
 * Returns: -1 on error, 0 on success.
 */
int
virNetworkObjUpdate(virNetworkObjPtr network,
                    unsigned int command, /* virNetworkUpdateCommand */
                    unsigned int section, /* virNetworkUpdateSection */
                    int parentIndex,
                    const char *xml,
                    unsigned int flags)  /* virNetworkUpdateFlags */
{
    int ret = -1;
3628
    virNetworkDefPtr livedef = NULL, configdef = NULL;
3629 3630 3631 3632 3633 3634

    /* normalize config data, and check for common invalid requests. */
    if (virNetworkConfigChangeSetup(network, flags) < 0)
       goto cleanup;

    if (flags & VIR_NETWORK_UPDATE_AFFECT_LIVE) {
3635 3636
        virNetworkDefPtr checkdef;

3637
        /* work on a copy of the def */
3638
        if (!(livedef = virNetworkDefCopy(network->def, 0)))
3639
            goto cleanup;
3640
        if (virNetworkDefUpdateSection(livedef, command, section,
3641 3642 3643
                                       parentIndex, xml, flags) < 0) {
            goto cleanup;
        }
3644 3645 3646 3647 3648 3649
        /* run a final format/parse cycle to make sure we didn't
         * add anything illegal to the def
         */
        if (!(checkdef = virNetworkDefCopy(livedef, 0)))
            goto cleanup;
        virNetworkDefFree(checkdef);
3650 3651 3652
    }

    if (flags & VIR_NETWORK_UPDATE_AFFECT_CONFIG) {
3653 3654
        virNetworkDefPtr checkdef;

3655
        /* work on a copy of the def */
3656 3657
        if (!(configdef = virNetworkDefCopy(virNetworkObjGetPersistentDef(network),
                                            VIR_NETWORK_XML_INACTIVE))) {
3658 3659
            goto cleanup;
        }
3660
        if (virNetworkDefUpdateSection(configdef, command, section,
3661 3662 3663
                                       parentIndex, xml, flags) < 0) {
            goto cleanup;
        }
3664 3665 3666 3667 3668 3669 3670 3671
        if (!(checkdef = virNetworkDefCopy(configdef,
                                           VIR_NETWORK_XML_INACTIVE))) {
            goto cleanup;
        }
        virNetworkDefFree(checkdef);
    }

    if (configdef) {
3672
        /* successfully modified copy, now replace original */
3673
        if (virNetworkObjReplacePersistentDef(network, configdef) < 0)
3674
           goto cleanup;
3675 3676 3677 3678 3679 3680 3681
        configdef = NULL;
    }
    if (livedef) {
        /* successfully modified copy, now replace original */
        virNetworkDefFree(network->def);
        network->def = livedef;
        livedef = NULL;
3682 3683 3684 3685
    }

    ret = 0;
cleanup:
3686 3687
    virNetworkDefFree(livedef);
    virNetworkDefFree(configdef);
3688 3689 3690
    return ret;
}

3691 3692 3693 3694 3695 3696 3697 3698 3699 3700 3701 3702 3703
/*
 * virNetworkObjIsDuplicate:
 * @doms : virNetworkObjListPtr to search
 * @def  : virNetworkDefPtr definition of network to lookup
 * @check_active: If true, ensure that network is not active
 *
 * Returns: -1 on error
 *          0 if network is new
 *          1 if network is a duplicate
 */
int
virNetworkObjIsDuplicate(virNetworkObjListPtr doms,
                         virNetworkDefPtr def,
3704
                         bool check_active)
3705 3706 3707 3708 3709 3710 3711 3712 3713 3714 3715 3716
{
    int ret = -1;
    int dupVM = 0;
    virNetworkObjPtr vm = NULL;

    /* See if a VM with matching UUID already exists */
    vm = virNetworkFindByUUID(doms, def->uuid);
    if (vm) {
        /* UUID matches, but if names don't match, refuse it */
        if (STRNEQ(vm->def->name, def->name)) {
            char uuidstr[VIR_UUID_STRING_BUFLEN];
            virUUIDFormat(vm->def->uuid, uuidstr);
3717 3718 3719
            virReportError(VIR_ERR_OPERATION_FAILED,
                           _("network '%s' is already defined with uuid %s"),
                           vm->def->name, uuidstr);
3720 3721 3722 3723 3724 3725
            goto cleanup;
        }

        if (check_active) {
            /* UUID & name match, but if VM is already active, refuse it */
            if (virNetworkObjIsActive(vm)) {
3726 3727 3728
                virReportError(VIR_ERR_OPERATION_INVALID,
                               _("network is already active as '%s'"),
                               vm->def->name);
3729 3730 3731 3732 3733 3734 3735 3736 3737 3738 3739
                goto cleanup;
            }
        }

        dupVM = 1;
    } else {
        /* UUID does not match, but if a name matches, refuse it */
        vm = virNetworkFindByName(doms, def->name);
        if (vm) {
            char uuidstr[VIR_UUID_STRING_BUFLEN];
            virUUIDFormat(vm->def->uuid, uuidstr);
3740 3741 3742
            virReportError(VIR_ERR_OPERATION_FAILED,
                           _("network '%s' already exists with uuid %s"),
                           def->name, uuidstr);
3743 3744 3745 3746 3747 3748 3749 3750 3751 3752 3753 3754
            goto cleanup;
        }
    }

    ret = dupVM;
cleanup:
    if (vm)
        virNetworkObjUnlock(vm);
    return ret;
}


3755 3756
void virNetworkObjLock(virNetworkObjPtr obj)
{
3757
    virMutexLock(&obj->lock);
3758 3759 3760 3761
}

void virNetworkObjUnlock(virNetworkObjPtr obj)
{
3762
    virMutexUnlock(&obj->lock);
D
Daniel P. Berrange 已提交
3763
}
3764 3765 3766

#define MATCH(FLAG) (flags & (FLAG))
static bool
3767 3768
virNetworkMatch(virNetworkObjPtr netobj,
                unsigned int flags)
3769 3770 3771 3772 3773 3774 3775 3776 3777 3778 3779 3780 3781 3782 3783 3784 3785 3786 3787 3788 3789 3790 3791 3792 3793 3794 3795 3796 3797 3798 3799 3800 3801 3802 3803 3804 3805 3806 3807 3808 3809 3810 3811 3812 3813 3814 3815 3816 3817 3818 3819 3820 3821 3822 3823 3824 3825 3826 3827 3828 3829 3830 3831 3832 3833 3834 3835 3836 3837 3838 3839 3840 3841 3842 3843 3844 3845 3846 3847 3848 3849 3850 3851 3852 3853 3854
{
    /* filter by active state */
    if (MATCH(VIR_CONNECT_LIST_NETWORKS_FILTERS_ACTIVE) &&
        !((MATCH(VIR_CONNECT_LIST_NETWORKS_ACTIVE) &&
           virNetworkObjIsActive(netobj)) ||
          (MATCH(VIR_CONNECT_LIST_NETWORKS_INACTIVE) &&
           !virNetworkObjIsActive(netobj))))
        return false;

    /* filter by persistence */
    if (MATCH(VIR_CONNECT_LIST_NETWORKS_FILTERS_PERSISTENT) &&
        !((MATCH(VIR_CONNECT_LIST_NETWORKS_PERSISTENT) &&
           netobj->persistent) ||
          (MATCH(VIR_CONNECT_LIST_NETWORKS_TRANSIENT) &&
           !netobj->persistent)))
        return false;

    /* filter by autostart option */
    if (MATCH(VIR_CONNECT_LIST_NETWORKS_FILTERS_AUTOSTART) &&
        !((MATCH(VIR_CONNECT_LIST_NETWORKS_AUTOSTART) &&
           netobj->autostart) ||
          (MATCH(VIR_CONNECT_LIST_NETWORKS_NO_AUTOSTART) &&
           !netobj->autostart)))
        return false;

    return true;
}
#undef MATCH

int
virNetworkList(virConnectPtr conn,
               virNetworkObjList netobjs,
               virNetworkPtr **nets,
               unsigned int flags)
{
    virNetworkPtr *tmp_nets = NULL;
    virNetworkPtr net = NULL;
    int nnets = 0;
    int ret = -1;
    int i;

    if (nets) {
        if (VIR_ALLOC_N(tmp_nets, netobjs.count + 1) < 0) {
            virReportOOMError();
            goto cleanup;
        }
    }

    for (i = 0; i < netobjs.count; i++) {
        virNetworkObjPtr netobj = netobjs.objs[i];
        virNetworkObjLock(netobj);
        if (virNetworkMatch(netobj, flags)) {
            if (nets) {
                if (!(net = virGetNetwork(conn,
                                          netobj->def->name,
                                          netobj->def->uuid))) {
                    virNetworkObjUnlock(netobj);
                    goto cleanup;
                }
                tmp_nets[nnets] = net;
            }
            nnets++;
        }
        virNetworkObjUnlock(netobj);
    }

    if (tmp_nets) {
        /* trim the array to the final size */
        ignore_value(VIR_REALLOC_N(tmp_nets, nnets + 1));
        *nets = tmp_nets;
        tmp_nets = NULL;
    }

    ret = nnets;

cleanup:
    if (tmp_nets) {
        for (i = 0; i < nnets; i++) {
            if (tmp_nets[i])
                virNetworkFree(tmp_nets[i]);
        }
    }

    VIR_FREE(tmp_nets);
    return ret;
}