- Devel - libvirt List Archives

[libvirt] VBOX driver : "An error occurred, but the cause is unknown" when trying to start a Virtualbox domain
by Jean-Christophe Guillain 28 Nov '11

28 Nov '11

Hello, I opened a bug (http://bugzilla.redhat.com/show_bug.cgi?id=757138) about this issue, but I was told to mention it to this list too. Here is my problem : when I try to start a virtualbox domain with virsh, an error occurs. (But when the domain is started using Virtualbox GUI it works, and I have no problem to stop it with virsh...) Example : virsh # start freenas1 error: Failed to start domain freenas1 error: An error occurred, but the cause is unknown I use libvirt 0.9.2-7 and virtualbox 4.0.10 on a Debian with 2.6.32-5-amd64 kernel. The XML config file of the domain : <domain type='vbox' id='1'> <name>freenas1</name> <uuid>07aadf11-2090-4690-9518-52766722c544</uuid> <memory>524288</memory> <currentMemory>524288</currentMemory> <vcpu>1</vcpu> <os> <type arch='x86_64'>hvm</type> <boot dev='hd'/> </os> <features> <acpi/> <apic/> </features> <clock offset='localtime'/> <on_poweroff>destroy</on_poweroff> <on_reboot>destroy</on_reboot> <on_crash>destroy</on_crash> <devices> <disk type='file' device='disk'> <source file='/data/Freenas1Disk1.vdi'/> <target dev='hda' bus='ide'/> </disk> <input type='mouse' bus='ps2'/> <graphics type='desktop' display='localhost:10.0'/> <video> <model type='vbox' vram='8192' heads='1'> <acceleration accel3d='no' accel2d='no'/> </model> </video> </devices> </domain> virsh debug output : virsh # start freenas1 15:51:31.043: 5796: debug : virConnectOpenAuth:1328 : name=(null), auth=0x7f19ee32d320, flags=0 15:51:31.043: 5796: debug : do_open:1065 : no name, allowing driver auto-select 15:51:31.043: 5796: debug : do_open:1102 : trying driver 0 (Test) ... 15:51:31.043: 5796: debug : do_open:1108 : driver 0 Test returned DECLINED 15:51:31.043: 5796: debug : do_open:1102 : trying driver 1 (Xen) ... 15:51:31.043: 5796: debug : do_open:1108 : driver 1 Xen returned DECLINED 15:51:31.043: 5796: debug : do_open:1102 : trying driver 2 (OPENVZ) ... 15:51:31.043: 5796: debug : do_open:1108 : driver 2 OPENVZ returned DECLINED 15:51:31.043: 5796: debug : do_open:1102 : trying driver 3 (VMWARE) ... 15:51:31.043: 5796: debug : do_open:1108 : driver 3 VMWARE returned DECLINED 15:51:31.043: 5796: debug : do_open:1102 : trying driver 4 (VBOX) ... 15:51:31.050: 5796: debug : vboxOpen:1035 : in vboxOpen 15:51:31.050: 5796: debug : do_open:1108 : driver 4 VBOX returned SUCCESS 15:51:31.050: 5796: debug : do_open:1130 : network driver 0 Test returned DECLINED 15:51:31.050: 5796: debug : vboxNetworkOpen:6953 : network initialized 15:51:31.050: 5796: debug : do_open:1130 : network driver 1 VBOX returned SUCCESS 15:51:31.050: 5796: debug : do_open:1145 : interface driver 0 Test returned DECLINED 15:51:31.051: 5796: debug : doRemoteOpen:596 : proceeding with name = vbox:///system 15:51:31.051: 5796: debug : remoteIO:5824 : Do proc=66 serial=0 length=28 wait=(nil) 15:51:31.051: 5796: debug : remoteIO:5896 : We have the buck 66 0x7f19e6c37010 0x7f19e6c37010 15:51:31.051: 5796: debug : remoteIODecodeMessageLength:5214 : Got length, now need 64 total (60 more) 15:51:31.051: 5796: debug : remoteIOEventLoop:5750 : Giving up the buck 66 0x7f19e6c37010 (nil) 15:51:31.051: 5796: debug : remoteIO:5924 : All done with our call 66 (nil) 0x7f19e6c37010 15:51:31.051: 5796: debug : remoteIO:5824 : Do proc=1 serial=1 length=56 wait=(nil) 15:51:31.051: 5796: debug : remoteIO:5896 : We have the buck 1 0x7f19e003fec0 0x7f19e003fec0 15:51:31.052: 5796: debug : remoteIODecodeMessageLength:5214 : Got length, now need 176 total (172 more) 15:51:31.052: 5796: debug : remoteIOEventLoop:5750 : Giving up the buck 1 0x7f19e003fec0 (nil) 15:51:31.052: 5796: debug : remoteIO:5924 : All done with our call 1 (nil) 0x7f19e003fec0 15:51:31.052: 5796: debug : do_open:1145 : interface driver 1 remote returned ERROR 15:51:31.052: 5796: debug : do_open:1161 : storage driver 0 Test returned DECLINED 15:51:31.052: 5796: debug : vboxStorageOpen:7764 : vbox storage initialized 15:51:31.052: 5796: debug : do_open:1161 : storage driver 1 VBOX returned SUCCESS 15:51:31.052: 5796: debug : do_open:1177 : node driver 0 Test returned DECLINED 15:51:31.053: 5796: debug : doRemoteOpen:596 : proceeding with name = vbox:///system 15:51:31.053: 5796: debug : remoteIO:5824 : Do proc=66 serial=0 length=28 wait=(nil) 15:51:31.053: 5796: debug : remoteIO:5896 : We have the buck 66 0x7f19e0081f90 0x7f19e0081f90 15:51:31.054: 5796: debug : remoteIODecodeMessageLength:5214 : Got length, now need 64 total (60 more) 15:51:31.054: 5796: debug : remoteIOEventLoop:5750 : Giving up the buck 66 0x7f19e0081f90 (nil) 15:51:31.054: 5796: debug : remoteIO:5924 : All done with our call 66 (nil) 0x7f19e0081f90 15:51:31.054: 5796: debug : remoteIO:5824 : Do proc=1 serial=1 length=56 wait=(nil) 15:51:31.054: 5796: debug : remoteIO:5896 : We have the buck 1 0x7f19e0081f90 0x7f19e0081f90 15:51:31.055: 5796: debug : remoteIODecodeMessageLength:5214 : Got length, now need 176 total (172 more) 15:51:31.055: 5796: debug : remoteIOEventLoop:5750 : Giving up the buck 1 0x7f19e0081f90 (nil) 15:51:31.055: 5796: debug : remoteIO:5924 : All done with our call 1 (nil) 0x7f19e0081f90 15:51:31.055: 5796: debug : do_open:1177 : node driver 1 remote returned ERROR 15:51:31.055: 5796: debug : do_open:1193 : secret driver 0 Test returned DECLINED 15:51:31.055: 5796: debug : doRemoteOpen:596 : proceeding with name = vbox:///system 15:51:31.055: 5796: debug : remoteIO:5824 : Do proc=66 serial=0 length=28 wait=(nil) 15:51:31.055: 5796: debug : remoteIO:5896 : We have the buck 66 0x7f19e0081f90 0x7f19e0081f90 15:51:31.056: 5796: debug : remoteIODecodeMessageLength:5214 : Got length, now need 64 total (60 more) 15:51:31.056: 5796: debug : remoteIOEventLoop:5750 : Giving up the buck 66 0x7f19e0081f90 (nil) 15:51:31.056: 5796: debug : remoteIO:5924 : All done with our call 66 (nil) 0x7f19e0081f90 15:51:31.056: 5796: debug : remoteIO:5824 : Do proc=1 serial=1 length=56 wait=(nil) 15:51:31.056: 5796: debug : remoteIO:5896 : We have the buck 1 0x7f19e0081f90 0x7f19e0081f90 15:51:31.057: 5796: debug : remoteIODecodeMessageLength:5214 : Got length, now need 176 total (172 more) 15:51:31.057: 5796: debug : remoteIOEventLoop:5750 : Giving up the buck 1 0x7f19e0081f90 (nil) 15:51:31.057: 5796: debug : remoteIO:5924 : All done with our call 1 (nil) 0x7f19e0081f90 15:51:31.057: 5796: debug : do_open:1193 : secret driver 1 remote returned ERROR 15:51:31.057: 5796: debug : do_open:1209 : nwfilter driver 0 Test returned DECLINED 15:51:31.057: 5796: debug : doRemoteOpen:596 : proceeding with name = vbox:///system 15:51:31.057: 5796: debug : remoteIO:5824 : Do proc=66 serial=0 length=28 wait=(nil) 15:51:31.057: 5796: debug : remoteIO:5896 : We have the buck 66 0x7f19e0081f90 0x7f19e0081f90 15:51:31.058: 5796: debug : remoteIODecodeMessageLength:5214 : Got length, now need 64 total (60 more) 15:51:31.058: 5796: debug : remoteIOEventLoop:5750 : Giving up the buck 66 0x7f19e0081f90 (nil) 15:51:31.058: 5796: debug : remoteIO:5924 : All done with our call 66 (nil) 0x7f19e0081f90 15:51:31.058: 5796: debug : remoteIO:5824 : Do proc=1 serial=1 length=56 wait=(nil) 15:51:31.058: 5796: debug : remoteIO:5896 : We have the buck 1 0x7f19e0081f90 0x7f19e0081f90 15:51:31.059: 5796: debug : remoteIODecodeMessageLength:5214 : Got length, now need 176 total (172 more) 15:51:31.059: 5796: debug : remoteIOEventLoop:5750 : Giving up the buck 1 0x7f19e0081f90 (nil) 15:51:31.059: 5796: debug : remoteIO:5924 : All done with our call 1 (nil) 0x7f19e0081f90 15:51:31.059: 5796: debug : do_open:1209 : nwfilter driver 1 remote returned ERROR 15:51:31.060: 5796: debug : virDomainLookupByName:2030 : conn=0x6f6350, name=freenas1 15:51:31.061: 5796: debug : virDomainGetID:2718 : dom=0x7f19e002db00, (VM: name=freenas1, uuid=07aadf11-2090-4690-9518-52766722c544), 15:51:31.061: 5796: debug : virDomainCreate:6300 : dom=0x7f19e002db00, (VM: name=freenas1, uuid=07aadf11-2090-4690-9518-52766722c544), 15:51:31.566: 5796: debug : virDomainGetName:2623 : domain=0x7f19e002db00 error: Failed to start domain freenas1 15:51:31.566: 5796: debug : virDomainFree:2118 : dom=0x7f19e002db00, (VM: name=freenas1, uuid=07aadf11-2090-4690-9518-52766722c544), 15:51:31.566: 5796: debug : virUnrefDomain:276 : unref domain 0x7f19e002db00 freenas1 1 15:51:31.566: 5796: debug : virReleaseDomain:238 : release domain 0x7f19e002db00 freenas1 07aadf11-2090-4690-9518-52766722c544 15:51:31.566: 5796: debug : virReleaseDomain:246 : unref connection 0x6f6350 2 error: An error occurred, but the cause is unknown ##### I f you have an idea of what the problem is... Thank you, jC

1 0

[libvirt] RE : Re: [PATCH] util: fix thinko in runIO
by Bastien ROUCARIES 28 Nov '11

28 Nov '11

Malloc page than realloc to smaller does not work ? Bastien Le 25 nov. 2011 14:38, "Eric Blake" <eblake(a)redhat.com> a écrit : [adding bug-gnulib; replies can drop libvirt] On 11/25/2011 05:51 AM, Paolo Bonzini wrote: >> Indeed; Linux has posix_memalign, and mingw never runs the io helper >> (although it does compile it, hence the #if). If gnulib would give >> us posix_memalign on mingw, we could nuke this #if altogether. > > That's pretty difficult (unless you also add a posix_memalign_free) > because at the time posix_memalign returns you have lost the base > pointer for free(). Providing a posix_memalign_free defeats the purpose - POSIX requires that plain free() will cover the memory returned by posix_memalign. The list of platforms missing posix_memalign is a bit daunting: MacOS X 10.5, FreeBSD 6.0, NetBSD 3.0, OpenBSD 3.8, Minix 3.1.8, AIX 5.1, HP-UX 11, IRIX 6.5, OSF/1 5.1, Solaris 10, Cygwin 1.5.x, mingw, MSVC 9, Interix 3.5, BeOS. but what would be interesting to know is how many of those platforms return page-aligned pointers for any malloc() request of a page or more of memory. That is, we may be able to coerce malloc into aligned results by over-allocating and over-aligning the user's request, if the system malloc() has at least one mode of returning page-aligned memory. Another alternative is to override free() at the same time as providing posix_memalign(). The gnulib malloca module provides a freea() function that can distinguish whether it is paired with an alloca() (nop) or mmalloca() (call the real free()), by over-allocating and probing for a magic header. Similar concepts could be used in writing an rpl_free() that determines whether it was allocated by posix_memalign(): if we guarantee that posix_memalign always returns something aligned to at least a page, then rpl_free() can make a quick check for whether the pointer passed in is page-aligned; if so, do a hash lookup to see if it was a page reserved by our posix_memalign (if so, we know the real address to free); if not or the hash lookup fails, it came from malloc (in which case, regular free should work). Of course, unlike freea() that probes for a magic header, we can't safely probe a header by crossing page boundaries, since that would fault if we didn't allocate the previous page at the same time. -- Eric Blake eblake(a)redhat.com +1-919-301-3266 Libvirt virtualization library http://libvirt.org

2 1

Re: [libvirt] Upgrade-problems from qemu-0.14.1 + libvirt-0.8.4 to qemu-0.15.1 + libvirt-0.9.6: Why I think multifunction=on is a bad idea...
by Philipp Hahn 28 Nov '11

28 Nov '11

Hello, On Thursday 17 November 2011 18:39:15 Eric Blake wrote: > Is any of this worth keeping on the public libvir-list? Not much but to be careful when you upgrade any part of libvirt, qemu(-kvm) or it's (external*) dependencies like etherboot/iPXE, vgabios and seabios, because it can invalidate your snapshots and saved state. (*): As Debian does for DFSG-compliance, since it replaces the seabios / vgabios / pxe-bios as shipped with qemu by a version compiled from (different) sources. Sincerely Philipp -- Philipp Hahn Open Source Software Engineer hahn(a)univention.de Univention GmbH Linux for Your Business fon: +49 421 22 232- 0 Mary-Somerville-Str.1 D-28359 Bremen fax: +49 421 22 232-99 http://www.univention.de/

1 0

Re: [libvirt] [PATCH v2] avoid false pool creation discard pool definition
by Wen Ruo Lv 27 Nov '11

27 Nov '11

wrong patch,pls just ignore me,send patch v3

1 1

[libvirt] [PATCHv3] avoid false creation discard pool definition
by Wen Ruo Lv 27 Nov '11

27 Nov '11

False pool creation will clear previous definition. This patch roll back to previous definition after pool-creat fails ref: http://www.redhat.com/archives/libvir-list/2011-November/msg01152.html http://www.redhat.com/archives/libvir-list/2011-November/msg01152.html Signed-off-by: Wen Ruo Lv <lvroyce(a)linux.vnet.ibm.com> --- src/conf/storage_conf.c | 30 +++++++++++++++++++++++++----- src/conf/storage_conf.h | 4 ++-- src/libvirt_private.syms | 1 + src/storage/storage_driver.c | 36 ++++++++++++++++++++++++------------ src/test/test_driver.c | 18 +++++++++--------- 5 files changed, 61 insertions(+), 28 deletions(-) diff --git a/src/conf/storage_conf.c b/src/conf/storage_conf.c index dadc115..bf82eb6 100644 --- a/src/conf/storage_conf.c +++ b/src/conf/storage_conf.c @@ -1385,17 +1385,20 @@ virStorageVolDefFindByName(virStoragePoolObjPtr pool, virStoragePoolObjPtr virStoragePoolObjAssignDef(virStoragePoolObjListPtr pools, - virStoragePoolDefPtr def) { + virStoragePoolDefPtr *pdef) { virStoragePoolObjPtr pool; + virStoragePoolDefPtr lastDef; + virStoragePoolDefPtr def = *pdef; if ((pool = virStoragePoolObjFindByName(pools, def->name))) { if (!virStoragePoolObjIsActive(pool)) { - virStoragePoolDefFree(pool->def); + lastDef = pool->def; pool->def = def; } else { - virStoragePoolDefFree(pool->newDef); + lastDef = pool->newDef; pool->newDef = def; } + *pdef = lastDef; return pool; } @@ -1421,11 +1424,26 @@ virStoragePoolObjAssignDef(virStoragePoolObjListPtr pools, virReportOOMError(); return NULL; } + *pdef = NULL; pools->objs[pools->count++] = pool; return pool; } +void virStoragePoolObjDefRollBack(virStoragePoolObjPtr pool, virStoragePoolDefPtr *lastDef) +{ + virStoragePoolDefPtr tmpDef; + + if (pool->active) { + tmpDef = pool->newDef; + pool->newDef = *lastDef; + } + else { + tmpDef = pool->def; + pool->def = *lastDef; + } + *lastDef = tmpDef; +} static virStoragePoolObjPtr virStoragePoolObjLoad(virStoragePoolObjListPtr pools, const char *file, @@ -1446,7 +1464,7 @@ virStoragePoolObjLoad(virStoragePoolObjListPtr pools, return NULL; } - if (!(pool = virStoragePoolObjAssignDef(pools, def))) { + if (!(pool = virStoragePoolObjAssignDef(pools, &def))) { virStoragePoolDefFree(def); return NULL; } @@ -1455,6 +1473,7 @@ virStoragePoolObjLoad(virStoragePoolObjListPtr pools, pool->configFile = strdup(path); if (pool->configFile == NULL) { virReportOOMError(); + virStoragePoolObjDefRollBack(pool, &def); virStoragePoolDefFree(def); return NULL; } @@ -1462,13 +1481,14 @@ virStoragePoolObjLoad(virStoragePoolObjListPtr pools, pool->autostartLink = strdup(autostartLink); if (pool->autostartLink == NULL) { virReportOOMError(); + virStoragePoolObjDefRollBack(pool, &def); virStoragePoolDefFree(def); return NULL; } pool->autostart = virFileLinkPointsTo(pool->autostartLink, pool->configFile); - + virStoragePoolDefFree(def); return pool; } diff --git a/src/conf/storage_conf.h b/src/conf/storage_conf.h index 19bbd2c..dc9dc05 100644 --- a/src/conf/storage_conf.h +++ b/src/conf/storage_conf.h @@ -364,8 +364,8 @@ char *virStorageVolDefFormat(virStoragePoolDefPtr pool, virStorageVolDefPtr def); virStoragePoolObjPtr virStoragePoolObjAssignDef(virStoragePoolObjListPtr pools, - virStoragePoolDefPtr def); - + virStoragePoolDefPtr *def); +void virStoragePoolObjDefRollBack(virStoragePoolObjPtr pool,virStoragePoolDefPtr *lastDef); int virStoragePoolObjSaveDef(virStorageDriverStatePtr driver, virStoragePoolObjPtr pool, virStoragePoolDefPtr def); diff --git a/src/libvirt_private.syms b/src/libvirt_private.syms index 0b21cdc..391998c 100644 --- a/src/libvirt_private.syms +++ b/src/libvirt_private.syms @@ -975,6 +975,7 @@ virStoragePoolLoadAllConfigs; virStoragePoolObjAssignDef; virStoragePoolObjClearVols; virStoragePoolObjDeleteDef; +virStoragePoolObjDefRollBack; virStoragePoolObjFindByName; virStoragePoolObjFindByUUID; virStoragePoolObjIsDuplicate; diff --git a/src/storage/storage_driver.c b/src/storage/storage_driver.c index 8c2d6e1..4ea22d5 100644 --- a/src/storage/storage_driver.c +++ b/src/storage/storage_driver.c @@ -526,6 +526,7 @@ storagePoolCreate(virConnectPtr conn, virStoragePoolObjPtr pool = NULL; virStoragePoolPtr ret = NULL; virStorageBackendPtr backend; + int dupPool; virCheckFlags(0, NULL); @@ -533,7 +534,7 @@ storagePoolCreate(virConnectPtr conn, if (!(def = virStoragePoolDefParseString(xml))) goto cleanup; - if (virStoragePoolObjIsDuplicate(&driver->pools, def, 1) < 0) + if ((dupPool = virStoragePoolObjIsDuplicate(&driver->pools, def, 1)) < 0) goto cleanup; if (virStoragePoolSourceFindDuplicate(&driver->pools, def) < 0) @@ -542,22 +543,29 @@ storagePoolCreate(virConnectPtr conn, if ((backend = virStorageBackendForType(def->type)) == NULL) goto cleanup; - if (!(pool = virStoragePoolObjAssignDef(&driver->pools, def))) + if (!(pool = virStoragePoolObjAssignDef(&driver->pools, &def))) goto cleanup; - def = NULL; if (backend->startPool && backend->startPool(conn, pool) < 0) { - virStoragePoolObjRemove(&driver->pools, pool); - pool = NULL; + if (dupPool) + virStoragePoolObjDefRollBack(pool, &def); + else { + virStoragePoolObjRemove(&driver->pools, pool); + pool = NULL; + } goto cleanup; } if (backend->refreshPool(conn, pool) < 0) { if (backend->stopPool) backend->stopPool(conn, pool); - virStoragePoolObjRemove(&driver->pools, pool); - pool = NULL; + if (dupPool) + virStoragePoolObjDefRollBack(pool, &def); + else { + virStoragePoolObjRemove(&driver->pools, pool); + pool = NULL; + } goto cleanup; } VIR_INFO("Creating storage pool '%s'", pool->def->name); @@ -582,6 +590,7 @@ storagePoolDefine(virConnectPtr conn, virStoragePoolDefPtr def; virStoragePoolObjPtr pool = NULL; virStoragePoolPtr ret = NULL; + int dupPool; virCheckFlags(0, NULL); @@ -589,7 +598,7 @@ storagePoolDefine(virConnectPtr conn, if (!(def = virStoragePoolDefParseString(xml))) goto cleanup; - if (virStoragePoolObjIsDuplicate(&driver->pools, def, 0) < 0) + if ((dupPool = virStoragePoolObjIsDuplicate(&driver->pools, def, 0)) < 0) goto cleanup; if (virStoragePoolSourceFindDuplicate(&driver->pools, def) < 0) @@ -598,15 +607,18 @@ storagePoolDefine(virConnectPtr conn, if (virStorageBackendForType(def->type) == NULL) goto cleanup; - if (!(pool = virStoragePoolObjAssignDef(&driver->pools, def))) + if (!(pool = virStoragePoolObjAssignDef(&driver->pools, &def))) goto cleanup; if (virStoragePoolObjSaveDef(driver, pool, def) < 0) { - virStoragePoolObjRemove(&driver->pools, pool); - def = NULL; + if (dupPool) + virStoragePoolObjDefRollBack(pool, &def); + else { + virStoragePoolObjRemove(&driver->pools, pool); + pool = NULL; + } goto cleanup; } - def = NULL; VIR_INFO("Defining storage pool '%s'", pool->def->name); ret = virGetStoragePool(conn, pool->def->name, pool->def->uuid); diff --git a/src/test/test_driver.c b/src/test/test_driver.c index ce94a17..65dd606 100644 --- a/src/test/test_driver.c +++ b/src/test/test_driver.c @@ -594,10 +594,8 @@ static int testOpenDefault(virConnectPtr conn) { goto error; if (!(poolobj = virStoragePoolObjAssignDef(&privconn->pools, - pooldef))) { - virStoragePoolDefFree(pooldef); + &pooldef))) goto error; - } if (testStoragePoolObjSetDefaults(poolobj) == -1) { virStoragePoolObjUnlock(poolobj); @@ -614,13 +612,14 @@ static int testOpenDefault(virConnectPtr conn) { virNodeDeviceDefFree(nodedef); goto error; } + virStoragePoolDefFree(pooldef); virNodeDeviceObjUnlock(nodeobj); testDriverUnlock(privconn); return VIR_DRV_OPEN_SUCCESS; - error: + virStoragePoolDefFree(pooldef); virDomainObjListDeinit(&privconn->domains); virNetworkObjListFree(&privconn->networks); virInterfaceObjListFree(&privconn->ifaces); @@ -1016,12 +1015,13 @@ static int testOpenFromFile(virConnectPtr conn, } if (!(pool = virStoragePoolObjAssignDef(&privconn->pools, - def))) { + &def))) { virStoragePoolDefFree(def); goto error; } if (testStoragePoolObjSetDefaults(pool) == -1) { + virStoragePoolDefFree(def); virStoragePoolObjUnlock(pool); goto error; } @@ -1029,10 +1029,12 @@ static int testOpenFromFile(virConnectPtr conn, /* Find storage volumes */ if (testOpenVolumesForPool(xml, ctxt, file, pool, i+1) < 0) { + virStoragePoolDefFree(def); virStoragePoolObjUnlock(pool); goto error; } + virStoragePoolDefFree(def); virStoragePoolObjUnlock(pool); } VIR_FREE(pools); @@ -4123,9 +4125,8 @@ testStoragePoolCreate(virConnectPtr conn, goto cleanup; } - if (!(pool = virStoragePoolObjAssignDef(&privconn->pools, def))) + if (!(pool = virStoragePoolObjAssignDef(&privconn->pools, &def))) goto cleanup; - def = NULL; if (testStoragePoolObjSetDefaults(pool) == -1) { virStoragePoolObjRemove(&privconn->pools, pool); @@ -4164,9 +4165,8 @@ testStoragePoolDefine(virConnectPtr conn, def->allocation = defaultPoolAlloc; def->available = defaultPoolCap - defaultPoolAlloc; - if (!(pool = virStoragePoolObjAssignDef(&privconn->pools, def))) + if (!(pool = virStoragePoolObjAssignDef(&privconn->pools, &def))) goto cleanup; - def = NULL; if (testStoragePoolObjSetDefaults(pool) == -1) { virStoragePoolObjRemove(&privconn->pools, pool); -- 1.7.4.1

1 0

[libvirt] [PATCH v2] avoid false pool creation discard pool definition
by Wen Ruo Lv 26 Nov '11

26 Nov '11

False pool creation will clear previous definition. This patch roll back to previous definition after pool-creat fails ref: http://www.redhat.com/archives/libvir-list/2011-November/msg01152.html http://www.redhat.com/archives/libvir-list/2011-November/msg01152.html Signed-off-by: Wen Ruo Lv <lvroyce(a)linux.vnet.ibm.com> --- src/conf/storage_conf.c | 15 +++++++++++++-- src/conf/storage_conf.h | 2 +- src/libvirt_private.syms | 1 + src/storage/storage_driver.c | 32 ++++++++++++++++++++++---------- 4 files changed, 37 insertions(+), 13 deletions(-) diff --git a/src/conf/storage_conf.c b/src/conf/storage_conf.c index dadc115..4186036 100644 --- a/src/conf/storage_conf.c +++ b/src/conf/storage_conf.c @@ -1387,15 +1387,17 @@ virStoragePoolObjPtr virStoragePoolObjAssignDef(virStoragePoolObjListPtr pools, virStoragePoolDefPtr def) { virStoragePoolObjPtr pool; + virStoragePoolDefPtr lastDef; if ((pool = virStoragePoolObjFindByName(pools, def->name))) { if (!virStoragePoolObjIsActive(pool)) { - virStoragePoolDefFree(pool->def); + lastDef = pool->def; pool->def = def; } else { - virStoragePoolDefFree(pool->newDef); + lastDef = pool->newDef; pool->newDef = def; } + def = lastDef; return pool; } @@ -1413,6 +1415,7 @@ virStoragePoolObjAssignDef(virStoragePoolObjListPtr pools, virStoragePoolObjLock(pool); pool->active = 0; pool->def = def; + def = NULL; if (VIR_REALLOC_N(pools->objs, pools->count+1) < 0) { pool->def = NULL; @@ -1426,6 +1429,14 @@ virStoragePoolObjAssignDef(virStoragePoolObjListPtr pools, return pool; } +void virStoragePoolObjDefRollBack(virStoragePoolDefPtr def,virStoragePoolDefPtr lastDef) +{ + virStoragePoolDefPtr tmpDef; + + tmpDef = def; + def = lastDef; + lastDef = tmpDef; +} static virStoragePoolObjPtr virStoragePoolObjLoad(virStoragePoolObjListPtr pools, const char *file, diff --git a/src/conf/storage_conf.h b/src/conf/storage_conf.h index 19bbd2c..bfd8904 100644 --- a/src/conf/storage_conf.h +++ b/src/conf/storage_conf.h @@ -365,7 +365,7 @@ char *virStorageVolDefFormat(virStoragePoolDefPtr pool, virStoragePoolObjPtr virStoragePoolObjAssignDef(virStoragePoolObjListPtr pools, virStoragePoolDefPtr def); - +void virStoragePoolObjDefRollBack(virStoragePoolDefPtr def,virStoragePoolDefPtr lastDef); int virStoragePoolObjSaveDef(virStorageDriverStatePtr driver, virStoragePoolObjPtr pool, virStoragePoolDefPtr def); diff --git a/src/libvirt_private.syms b/src/libvirt_private.syms index 0b21cdc..391998c 100644 --- a/src/libvirt_private.syms +++ b/src/libvirt_private.syms @@ -975,6 +975,7 @@ virStoragePoolLoadAllConfigs; virStoragePoolObjAssignDef; virStoragePoolObjClearVols; virStoragePoolObjDeleteDef; +virStoragePoolObjDefRollBack; virStoragePoolObjFindByName; virStoragePoolObjFindByUUID; virStoragePoolObjIsDuplicate; diff --git a/src/storage/storage_driver.c b/src/storage/storage_driver.c index 8c2d6e1..2e6ae05 100644 --- a/src/storage/storage_driver.c +++ b/src/storage/storage_driver.c @@ -526,6 +526,7 @@ storagePoolCreate(virConnectPtr conn, virStoragePoolObjPtr pool = NULL; virStoragePoolPtr ret = NULL; virStorageBackendPtr backend; + int dupPool; virCheckFlags(0, NULL); @@ -533,7 +534,7 @@ storagePoolCreate(virConnectPtr conn, if (!(def = virStoragePoolDefParseString(xml))) goto cleanup; - if (virStoragePoolObjIsDuplicate(&driver->pools, def, 1) < 0) + if ((dupPool = virStoragePoolObjIsDuplicate(&driver->pools, def, 1)) < 0) goto cleanup; if (virStoragePoolSourceFindDuplicate(&driver->pools, def) < 0) @@ -544,20 +545,27 @@ storagePoolCreate(virConnectPtr conn, if (!(pool = virStoragePoolObjAssignDef(&driver->pools, def))) goto cleanup; - def = NULL; if (backend->startPool && backend->startPool(conn, pool) < 0) { - virStoragePoolObjRemove(&driver->pools, pool); - pool = NULL; + if (dupPool) + virStoragePoolObjDefRollBack(pool->def, def); + else { + virStoragePoolObjRemove(&driver->pools, pool); + pool = NULL; + } goto cleanup; } if (backend->refreshPool(conn, pool) < 0) { if (backend->stopPool) backend->stopPool(conn, pool); - virStoragePoolObjRemove(&driver->pools, pool); - pool = NULL; + if (dupPool) + virStoragePoolObjDefRollBack(pool->def, def); + else { + virStoragePoolObjRemove(&driver->pools, pool); + pool = NULL; + } goto cleanup; } VIR_INFO("Creating storage pool '%s'", pool->def->name); @@ -582,6 +590,7 @@ storagePoolDefine(virConnectPtr conn, virStoragePoolDefPtr def; virStoragePoolObjPtr pool = NULL; virStoragePoolPtr ret = NULL; + int dupPool; virCheckFlags(0, NULL); @@ -589,7 +598,7 @@ storagePoolDefine(virConnectPtr conn, if (!(def = virStoragePoolDefParseString(xml))) goto cleanup; - if (virStoragePoolObjIsDuplicate(&driver->pools, def, 0) < 0) + if ((dupPool = virStoragePoolObjIsDuplicate(&driver->pools, def, 0)) < 0) goto cleanup; if (virStoragePoolSourceFindDuplicate(&driver->pools, def) < 0) @@ -602,11 +611,14 @@ storagePoolDefine(virConnectPtr conn, goto cleanup; if (virStoragePoolObjSaveDef(driver, pool, def) < 0) { - virStoragePoolObjRemove(&driver->pools, pool); - def = NULL; + if (dupPool) + virStoragePoolObjDefRollBack(pool->def, def); + else { + virStoragePoolObjRemove(&driver->pools, pool); + pool = NULL; + } goto cleanup; } - def = NULL; VIR_INFO("Defining storage pool '%s'", pool->def->name); ret = virGetStoragePool(conn, pool->def->name, pool->def->uuid); -- 1.7.4.1

1 0

[libvirt] [PATCH 5/5] If a system has 64 or more VF's, it is quite tedious to mention each VF in the interface pool. The following modification find a Free VF given a Physical Function when mode=passthrough. We also save the state of each VF. Hence modifications to networkAllocateActualDevice, networkNotifyActualDevice and networkReleaseActualDevice were required. The following patch does just that.
by Shradha Shah 25 Nov '11

25 Nov '11

--- src/network/bridge_driver.c | 208 +++++++++++++++++++++++++++++++++++++------ 1 files changed, 179 insertions(+), 29 deletions(-) diff --git a/src/network/bridge_driver.c b/src/network/bridge_driver.c index c49c25b..a2e3119 100644 --- a/src/network/bridge_driver.c +++ b/src/network/bridge_driver.c @@ -55,6 +55,7 @@ #include "memory.h" #include "uuid.h" #include "iptables.h" +#include "pci.h" #include "logging.h" #include "dnsmasq.h" #include "configmake.h" @@ -2823,8 +2824,11 @@ networkAllocateActualDevice(virDomainNetDefPtr iface) goto cleanup; } else { int ii; - virNetworkForwardIfDefPtr dev = NULL; - + virNetworkForwardVfDefPtr dev = NULL; + unsigned int vf_found = 0; + unsigned int num_virt_fns = 0; + struct pci_config_address **virt_fns = NULL; + /* pick an interface from the pool */ /* PASSTHROUGH mode, and PRIVATE Mode + 802.1Qbh both require @@ -2832,32 +2836,105 @@ networkAllocateActualDevice(virDomainNetDefPtr iface) * 0. Other modes can share, so just search for the one with * the lowest usageCount. */ - if ((netdef->forwardType == VIR_NETWORK_FORWARD_PASSTHROUGH) || - ((netdef->forwardType == VIR_NETWORK_FORWARD_PRIVATE) && - iface->data.network.actual->data.direct.virtPortProfile && - (iface->data.network.actual->data.direct.virtPortProfile->virtPortType - == VIR_NETDEV_VPORT_PROFILE_8021QBH))) { - /* pick first dev with 0 usageCount */ + if (netdef->forwardType == VIR_NETWORK_FORWARD_PASSTHROUGH) { + if (netdef->nForwardIfs == 1) { + if (netdef->forwardIfs[0].vfs_in_use_count == 0) { + if ((virNetDevGetVirtualFunctions(netdef->forwardIfs[0].dev, + &virt_fns, &num_virt_fns)) < 0){ + networkReportError(VIR_ERR_INTERNAL_ERROR, + _("Could not get Virtual functions on %s"), + netdef->forwardIfs[0].dev); + goto out; + } + + netdef->forwardIfs[0].nForwardVfs = num_virt_fns; + + if ((VIR_ALLOC_N(netdef->forwardIfs[0].forwardVfs, + netdef->forwardIfs[0].nForwardVfs)) < 0) { + virReportOOMError(); + goto out; + } + + for (ii = 0; ii < netdef->forwardIfs[0].nForwardVfs; ii++) { + if ((virNetDevGetNetName(virt_fns[ii], + &netdef->forwardIfs[0].forwardVfs[ii].dev)) < 0) { + networkReportError(VIR_ERR_INTERNAL_ERROR, + _("Could not get Interface name")); + goto out; + } + netdef->forwardIfs[0].forwardVfs[ii].usageCount = 0; + } + } + + for (ii = 0; ii < netdef->forwardIfs[0].nForwardVfs; ii++) { + if (netdef->forwardIfs[0].forwardVfs[ii].usageCount == 0) { + netdef->forwardIfs[0].vfs_in_use_count++; + dev = &netdef->forwardIfs[0].forwardVfs[ii]; + vf_found = 1; + break; + } + } + /* If No Vf's are present or if Vf's are in use + * check whether the PF is free and assign PF + * to dev + */ + if(vf_found == 0) { + networkReportError(VIR_ERR_INTERNAL_ERROR, + _("No Free Vf's on %s, checking if PF is free"), + netdef->forwardIfs[0].dev); + if (netdef->forwardIfs[0].usageCount == 0) { + dev = (virNetworkForwardVfDef *)&netdef->forwardIfs[0]; + } + } + vf_found = 0; + } + /* If more than 1 ForwardIfs are present check usagecount of each + * find the one that is free + */ + else { + for (ii = 0; ii < netdef->nForwardIfs; ii++) { + if (netdef->forwardIfs[ii].usageCount == 0) { + dev = (virNetworkForwardVfDef *)&netdef->forwardIfs[ii]; + break; + } + } + } + } + else if ((netdef->forwardType == VIR_NETWORK_FORWARD_PRIVATE) && + iface->data.network.actual->data.direct.virtPortProfile && + (iface->data.network.actual->data.direct.virtPortProfile->virtPortType + == VIR_NETDEV_VPORT_PROFILE_8021QBH)) { + + + /* pick first dev with 0 usageCount */ + for (ii = 0; ii < netdef->nForwardIfs; ii++) { if (netdef->forwardIfs[ii].usageCount == 0) { - dev = &netdef->forwardIfs[ii]; + dev = (virNetworkForwardVfDef *)&netdef->forwardIfs[ii]; break; } } - } else { + } + else { /* pick least used dev */ - dev = &netdef->forwardIfs[0]; + dev = (virNetworkForwardVfDef *)&netdef->forwardIfs[0]; for (ii = 1; ii < netdef->nForwardIfs; ii++) { if (netdef->forwardIfs[ii].usageCount < dev->usageCount) - dev = &netdef->forwardIfs[ii]; + dev = (virNetworkForwardVfDef *)&netdef->forwardIfs[ii]; } } + + out: + for (ii = 0; ii < num_virt_fns; ii++) + VIR_FREE(virt_fns[ii]); + VIR_FREE(virt_fns); + /* dev points at the physical device we want to use */ if (!dev) { networkReportError(VIR_ERR_INTERNAL_ERROR, _("network '%s' requires exclusive access to interfaces, but none are available"), - netdef->name); + netdef->name); goto cleanup; } iface->data.network.actual->data.direct.linkdev = strdup(dev->dev); @@ -2871,7 +2948,7 @@ networkAllocateActualDevice(virDomainNetDefPtr iface) dev->dev, dev->usageCount); } } - + ret = 0; cleanup: if (network) @@ -2935,17 +3012,55 @@ networkNotifyActualDevice(virDomainNetDefPtr iface) netdef->name); goto cleanup; } else { - int ii; - virNetworkForwardIfDefPtr dev = NULL; - + int ii, jj, isVf; + virNetworkForwardVfDefPtr dev = NULL; + char *pfDeviceName; + /* find the matching interface in the pool and increment its usageCount */ + + isVf = virNetDevIsVirtualFunction(actualDev); - for (ii = 0; ii < netdef->nForwardIfs; ii++) { - if (STREQ(actualDev, netdef->forwardIfs[ii].dev)) { - dev = &netdef->forwardIfs[ii]; - break; + if (isVf == 1) { + /*If Vf get PF : pciGetPhysicalFunction */ + if ((virNetDevGetPhysicalFunction(actualDev, &pfDeviceName)) < 0) { + networkReportError(VIR_ERR_INTERNAL_ERROR, + _("Could not get Physical functions for %s"), + actualDev); + goto out; + } + + /* Find the matching PF from the list of netdef->forwardIfs + * Search through the ForwardVfs list of the PF to find the VF + */ + for (ii = 0; ii < netdef->nForwardIfs; ii++) { + if (STREQ(pfDeviceName, netdef->forwardIfs[ii].dev)) { + for (jj = 0; jj < netdef->forwardIfs[ii].nForwardVfs; jj++) { + if (STREQ(actualDev, netdef->forwardIfs[ii].forwardVfs[jj].dev)) { + dev = &netdef->forwardIfs[ii].forwardVfs[jj]; + break; + } + } + } } } + else if (isVf == 0) { + /*If the actual dev is a PF do the following code*/ + for (ii = 0; ii < netdef->nForwardIfs; ii++) { + if (STREQ(actualDev, netdef->forwardIfs[ii].dev)) { + dev = (virNetworkForwardVfDef *)&netdef->forwardIfs[ii]; + break; + } + } + } + else { + networkReportError(VIR_ERR_INTERNAL_ERROR, + _("Could not find whether %s is PF or VF"), + actualDev); + goto out; + } + + out: + /* dev points at the physical device we want to use */ if (!dev) { networkReportError(VIR_ERR_INTERNAL_ERROR, @@ -2953,7 +3068,7 @@ networkNotifyActualDevice(virDomainNetDefPtr iface) netdef->name, actualDev); goto cleanup; } - + /* PASSTHROUGH mode, and PRIVATE Mode + 802.1Qbh both require * exclusive access to a device, so current usageCount must be * 0 in those cases. @@ -3036,15 +3151,50 @@ networkReleaseActualDevice(virDomainNetDefPtr iface) netdef->name); goto cleanup; } else { - int ii; - virNetworkForwardIfDefPtr dev = NULL; - - for (ii = 0; ii < netdef->nForwardIfs; ii++) { - if (STREQ(actualDev, netdef->forwardIfs[ii].dev)) { - dev = &netdef->forwardIfs[ii]; - break; + int ii, jj, isVf; + virNetworkForwardVfDefPtr dev = NULL; + char *pfDeviceName; + + isVf = virNetDevIsVirtualFunction(actualDev); + + if (isVf == 1) { + /*If Vf get PF */ + if ((virNetDevGetPhysicalFunction(actualDev, &pfDeviceName)) < 0) { + networkReportError(VIR_ERR_INTERNAL_ERROR, + _("Could not get Physical functions for %s"), + actualDev); + goto out; } + + /* Find the matching PF from the list of netdef->forwardIfs + * search through the ForwardVfs list of the PF to find the VF + */ + for (ii = 0; ii < netdef->nForwardIfs; ii++) { + if (STREQ(pfDeviceName, netdef->forwardIfs[ii].dev)) { + for (jj = 0; jj < netdef->forwardIfs[ii].nForwardVfs; jj++) { + if (STREQ(actualDev, netdef->forwardIfs[ii].forwardVfs[jj].dev)) { + dev = &netdef->forwardIfs[ii].forwardVfs[jj]; + break; + } + } + } + } + } + else if (isVf == 0) { + for (ii = 0; ii < netdef->nForwardIfs; ii++) { + if (STREQ(actualDev, netdef->forwardIfs[ii].dev)) { + dev = (virNetworkForwardVfDef *)&netdef->forwardIfs[ii]; + break; + } + } + } + else { + networkReportError(VIR_ERR_INTERNAL_ERROR, + _("Could not find whether %s is PF or VF"), + actualDev); + goto out; } + out: /* dev points at the physical device we've been using */ if (!dev) { networkReportError(VIR_ERR_INTERNAL_ERROR, -- 1.7.4.4

1 0

[libvirt] [PATCH 4/5] Addition of a new device structure to store the state of a Virtual Function Modifications to the Physical Device Structure to store state of its Virtual Functions
by Shradha Shah 25 Nov '11

25 Nov '11

--- src/conf/network_conf.c | 19 ++++++++++++++++++- src/conf/network_conf.h | 10 ++++++++++ 2 files changed, 28 insertions(+), 1 deletions(-) diff --git a/src/conf/network_conf.c b/src/conf/network_conf.c index 10afcde..d30d757 100644 --- a/src/conf/network_conf.c +++ b/src/conf/network_conf.c @@ -43,6 +43,7 @@ #include "buf.h" #include "c-ctype.h" #include "virfile.h" +#include "logging.h" #define MAX_BRIDGE_ID 256 #define VIR_FROM_THIS VIR_FROM_NETWORK @@ -103,6 +104,12 @@ virNetworkForwardIfDefClear(virNetworkForwardIfDefPtr def) VIR_FREE(def->dev); } +static void +virNetworkForwardVfDefClear(virNetworkForwardVfDefPtr def) +{ + VIR_FREE(def->dev); +} + static void virNetworkIpDefClear(virNetworkIpDefPtr def) { int ii; @@ -144,7 +151,7 @@ static void virNetworkDNSDefFree(virNetworkDNSDefPtr def) void virNetworkDefFree(virNetworkDefPtr def) { - int ii; + int ii, jj; if (!def) return; @@ -154,6 +161,10 @@ void virNetworkDefFree(virNetworkDefPtr def) VIR_FREE(def->domain); for (ii = 0 ; ii < def->nForwardIfs && def->forwardIfs ; ii++) { + for (jj = 0 ; jj < (def->forwardIfs[ii]).nForwardVfs ; jj++) { + virNetworkForwardVfDefClear(&(def->forwardIfs[ii].forwardVfs[jj])); + } + VIR_FREE(def->forwardIfs[ii].forwardVfs); virNetworkForwardIfDefClear(&def->forwardIfs[ii]); } VIR_FREE(def->forwardIfs); @@ -979,6 +990,9 @@ virNetworkDefParseXML(xmlXPathContextPtr ctxt) if (forwardDev) { def->forwardIfs[0].usageCount = 0; + def->forwardIfs[0].vfs_in_use_count = 0; + def->forwardIfs[0].nForwardVfs = 0; + def->forwardIfs[0].forwardVfs = NULL; def->forwardIfs[0].dev = forwardDev; forwardDev = NULL; def->nForwardIfs++; @@ -1011,6 +1025,9 @@ virNetworkDefParseXML(xmlXPathContextPtr ctxt) def->forwardIfs[ii].dev = forwardDev; forwardDev = NULL; def->forwardIfs[ii].usageCount = 0; + def->forwardIfs[ii].vfs_in_use_count = 0; + def->forwardIfs[ii].nForwardVfs = 0; + def->forwardIfs[ii].forwardVfs = NULL; def->nForwardIfs++; } } diff --git a/src/conf/network_conf.h b/src/conf/network_conf.h index 1be20f8..d1dba94 100644 --- a/src/conf/network_conf.h +++ b/src/conf/network_conf.h @@ -112,11 +112,21 @@ struct _virNetworkIpDef { virSocketAddr bootserver; }; +typedef struct _virNetworkForwardVfDef virNetworkForwardVfDef; +typedef virNetworkForwardVfDef *virNetworkForwardVfDefPtr; +struct _virNetworkForwardVfDef { + char *dev; + int usageCount; +}; + typedef struct _virNetworkForwardIfDef virNetworkForwardIfDef; typedef virNetworkForwardIfDef *virNetworkForwardIfDefPtr; struct _virNetworkForwardIfDef { char *dev; /* name of device */ int usageCount; /* how many guest interfaces are bound to this device? */ + int vfs_in_use_count; /*if SRIOV, Are any of the Vf's on the dev in use? */ + size_t nForwardVfs; + virNetworkForwardVfDefPtr forwardVfs; }; typedef struct _virPortGroupDef virPortGroupDef; -- 1.7.4.4

1 0

[libvirt] [PATCH 3/5] Adding functions virNetDevGetVirtualFunctions and virNetDevGetNetName virNetDevGetVirtualFunctions: Gets the BDF of all the Virtual Functions given a physical function virNetDevGetNetName: Gets the interface name of the PCI Device.
by Shradha Shah 25 Nov '11

25 Nov '11

--- src/util/virnetdev.c | 89 ++++++++++++++++++++++++++++++++++++++++++++++++++ src/util/virnetdev.h | 10 ++++++ 2 files changed, 99 insertions(+), 0 deletions(-) diff --git a/src/util/virnetdev.c b/src/util/virnetdev.c index 86196a1..d07d8fa 100644 --- a/src/util/virnetdev.c +++ b/src/util/virnetdev.c @@ -968,6 +968,76 @@ virNetDevSysfsDeviceFile(char **pf_sysfs_device_link, const char *ifname, } /** + * virNetDevGetVirtualFunctions: + * + * @pfname : name of the physical function interface name + * @virt_fns: array that will hold the pointers to the virtual_functions + * @num_virt_fns: number of virtual functions + * + * Returns 0 on success and -1 on failure + */ + +int +virNetDevGetVirtualFunctions(const char *pfname, + struct pci_config_address ***virt_fns, + unsigned int *num_virt_fns) +{ + int ret = -1; + char *pf_sysfs_device_link = NULL; + + + if (virNetDevSysfsFile(&pf_sysfs_device_link, pfname, "device") < 0) + return ret; + + if (pciGetVirtualFunctions(pf_sysfs_device_link, virt_fns, + num_virt_fns) < 0) + goto out; + ret = 0; + +out: + VIR_FREE(pf_sysfs_device_link); + return ret; +} + +/** + * virNetDevGetNetName: + * + * @vf : pci address (BDF) of the Virtual Function + * @vfname: interface name of the virtual function returned by this function + * + * Returns 0 on success and -1 on failure + */ + +int +virNetDevGetNetName(struct pci_config_address *vf, char **vfname) +{ + int ret = -1; + pciDevice *dev = NULL; + char *pci_sysfs_device_link = NULL; + + dev = pciGetDevice(vf->domain, vf->bus, vf->slot, vf->function); + if (dev != NULL) { + if (pciSysfsFile(&pci_sysfs_device_link, dev->name) < 0) { + virReportSystemError(ENOSYS, "%s", + _("Failed to get PCI SYSFS file")); + goto out; + } + + if (pciDeviceNetName(pci_sysfs_device_link, vfname) < 0) { + virReportSystemError(ENOSYS, "%s", + _("Failed to get interface name of the VF")); + goto out; + } + } + ret = 0; + +out: + VIR_FREE(pci_sysfs_device_link); + pciFreeDevice(dev); + return ret; +} + +/** * virNetDevIsVirtualFunction: * @ifname : name of the interface * @@ -1055,6 +1125,25 @@ virNetDevGetPhysicalFunction(const char *ifname, char **pfname) } #else /* !__linux__ */ int +virNetDevGetVirtualFunctions(const char *pfname ATTRIBUTE_UNUSED, + struct pci_config_address ***virt_fns ATTRIBUTE_UNUSED, + unsigned int *num_virt_fns ATTRIBUTE_UNUSED) +{ + virReportSystemError(ENOSYS, "%s", + _("Unable to get virtual functions on this platfornm")); + return -1; +} + +int +virNetDevGetNetName(struct pci_config_address *vf ATTRIBUTE_UNUSED, + char **vfname ATTRIBUTE_UNUSED) +{ + virReportSystemError(ENOSYS, "%s", + _("Unable to get Device name on this platfornm")); + return -1; +} + +int virNetDevIsVirtualFunction(const char *ifname ATTRIBUTE_UNUSED) { virReportSystemError(ENOSYS, "%s", diff --git a/src/util/virnetdev.h b/src/util/virnetdev.h index 13ba1da..4d1573a 100644 --- a/src/util/virnetdev.h +++ b/src/util/virnetdev.h @@ -24,6 +24,7 @@ # define __VIR_NETDEV_H__ # include "virsocketaddr.h" +# include "pci.h" int virNetDevExists(const char *brname) ATTRIBUTE_NONNULL(1) ATTRIBUTE_RETURN_CHECK; @@ -99,4 +100,13 @@ int virNetDevGetVirtualFunctionIndex(const char *pfname, const char *vfname, int virNetDevGetPhysicalFunction(const char *ifname, char **pfname) ATTRIBUTE_NONNULL(1) ATTRIBUTE_NONNULL(2) ATTRIBUTE_RETURN_CHECK; +int virNetDevGetVirtualFunctions(const char *pfname, + struct pci_config_address ***virt_fns, + unsigned int *num_virt_fns) + ATTRIBUTE_NONNULL(1) ATTRIBUTE_NONNULL(2) ATTRIBUTE_NONNULL(3) + ATTRIBUTE_RETURN_CHECK; + +int virNetDevGetNetName(struct pci_config_address *vf, char **vfname) + ATTRIBUTE_NONNULL(1) ATTRIBUTE_NONNULL(2) ATTRIBUTE_RETURN_CHECK; + #endif /* __VIR_NETDEV_H__ */ -- 1.7.4.4

1 0

[libvirt] [PATCH 2/5] Added function pciSysfsFile to enable access to the PCI SYSFS files.
by Shradha Shah 25 Nov '11

25 Nov '11

--- src/util/pci.c | 17 +++++++++++++++++ src/util/pci.h | 2 ++ 2 files changed, 19 insertions(+), 0 deletions(-) diff --git a/src/util/pci.c b/src/util/pci.c index 857078d..89a9d12 100644 --- a/src/util/pci.c +++ b/src/util/pci.c @@ -39,6 +39,7 @@ #include "command.h" #include "virterror_internal.h" #include "virfile.h" +#include "virnetdev.h" /* avoid compilation breakage on some systems */ #ifndef MODPROBE @@ -1991,6 +1992,22 @@ out: return ret; } + /* + * Returns a path to the PCI sysfs file given the BDF of the PCI function + */ + +int +pciSysfsFile(char **pci_sysfs_device_link, char *pciDeviceName) +{ + if (virAsprintf(pci_sysfs_device_link, PCI_SYSFS "devices/%s", + pciDeviceName) < 0) { + virReportOOMError(); + return -1; + } + + return 0; +} + /* * Returns the network device name of a pci device */ diff --git a/src/util/pci.h b/src/util/pci.h index 8e47fc2..3800d98 100644 --- a/src/util/pci.h +++ b/src/util/pci.h @@ -143,4 +143,6 @@ int pciGetVirtualFunctionIndex(const char *pf_sysfs_device_link, int pciDeviceNetName(char *device_link_sysfs_path, char **netname); +int pciSysfsFile(char **pci_sysfs_device_link, char *pciDeviceName); + #endif /* __VIR_PCI_H__ */ -- 1.7.4.4

1 0