shaba/virt-manager
1
0
Fork 0
mirror of https://github.com/virt-manager/virt-manager.git synced 2024-12-23 17:34:21 +03:00
Code Issues Projects Releases Wiki Activity

Change how we thread off connection when creating new pool or vol.

Browse Source
This commit is contained in:
Cole Robinson 2008-09-05 09:27:14 -04:00
parent e3c1d80ece
commit d7a23e1f26
2 changed files with 22 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
src/virtManager/createpool.py
View File

@ -24,6 +24,8 @@ import gtk.glade
import traceback
import logging
import libvirt
from virtManager.error import vmmErrorDialog
from virtManager.asyncjob import vmmAsyncJob
from virtManager.createmeter import vmmCreateMeter
@ -272,16 +274,17 @@ class vmmCreatePool(gobject.GObject):
self.close()
def _async_pool_create(self, asyncjob):
vmmconn = None
newconn = None
try:
# Open a seperate connection to install on since this is async
logging.debug("Threading off connection to create pool.")
vmmconn = vmmConnection(self.config, self.conn.get_uri(),
self.conn.is_read_only())
vmmconn.open()
vmmconn.connectThreadEvent.wait()
#newconn = vmmConnection(self.config, self.conn.get_uri(),
# self.conn.is_read_only())
#newconn.open()
#newconn.connectThreadEvent.wait()
newconn = libvirt.open(self._pool.conn.getURI())
meter = vmmCreateMeter(asyncjob)
self._pool.conn = vmmconn.vmm
self._pool.conn = newconn
logging.debug("Starting backround pool creation.")
build = self.window.get_widget("pool-build").get_active()
@ -293,8 +296,8 @@ class vmmCreatePool(gobject.GObject):
self.error_details = "".join(traceback.format_exc())
logging.error(self.error_msg + "\n" + self.error_details)
finally:
if vmmconn:
vmmconn.close()
if newconn:
newconn.close()
def page_changed(self, notebook, page, page_number):
if page_number == PAGE_NAME:

19
src/virtManager/createvol.py
View File

@ -24,6 +24,8 @@ import gtk.glade
import traceback
import logging
import libvirt
from virtManager.error import vmmErrorDialog
from virtManager.asyncjob import vmmAsyncJob
from virtManager.createmeter import vmmCreateMeter
@ -162,17 +164,18 @@ class vmmCreateVolume(gobject.GObject):
self.close()
def _async_vol_create(self, asyncjob):
vmmconn = None
newconn = None
try:
# Open a seperate connection to install on since this is async
logging.debug("Threading off connection to create vol.")
vmmconn = vmmConnection(self.config, self.conn.get_uri(),
self.conn.is_read_only())
vmmconn.open()
vmmconn.connectThreadEvent.wait()
#newconn = vmmConnection(self.config, self.conn.get_uri(),
# self.conn.is_read_only())
#newconn.open()
#newconn.connectThreadEvent.wait()
newconn = libvirt.open(self.conn.get_uri())
# Lookup different pool obj
newpool = vmmconn.vmm.storagePoolLookupByName(self.parent_pool.get_name())
newpool = newconn.storagePoolLookupByName(self.parent_pool.get_name())
self.vol.pool = newpool
meter = vmmCreateMeter(asyncjob)
@ -183,8 +186,8 @@ class vmmCreateVolume(gobject.GObject):
self.error_details = "".join(traceback.format_exc())
logging.error(self.error_msg + "\n" + self.error_details)
finally:
if vmmconn:
vmmconn.close()
if newconn:
newconn.close()
def validate(self):
name = self.window.get_widget("vol-name").get_text()