search for: endt

This is a patch which Daniel Erez wrote originally. I have modified it only to fix a small bug in the debug() statement, and Ilanit kindly tested it here: https://bugzilla.redhat.com/show_bug.cgi?id=1680361#c38 Rich.

...at belongs to datacenter '%s', " "using any host" % (vdsm_id, datacenter.name)) return None @@ -193,15 +193,15 @@ def open(readonly): if transfer.phase != types.ImageTransferPhase.INITIALIZING: break if time.time() > endt: - raise RuntimeError("timed out waiting for transfer status " + + raise RuntimeError("timed out waiting for transfer status " "!= INITIALIZING") # Now we have permission to start the transfer. if params...

...00644 > --- a/v2v/rhv-upload-plugin.py > +++ b/v2v/rhv-upload-plugin.py > @@ -523,15 +523,23 @@ def close(h): > # waiting for the transfer object to cease to exist, which > # falls through to the exception case and then we can > # continue. > - endt = time.time() + timeout > + disk_id = disk.id > + start = time.time() > try: > while True: > time.sleep(1) > - tmp = transfer_service.get() > - if time.time() > endt: > -...

...-upload-plugin.py >> +++ b/v2v/rhv-upload-plugin.py >> @@ -523,14 +523,30 @@ def close(h): >> # waiting for the transfer object to cease to exist, which >> # falls through to the exception case and then we can >> # continue. >> - endt = time.time() + timeout >> + start = time.time() >> try: >> while True: >> time.sleep(1) >> - tmp = transfer_service.get() >> - if time.time() > endt: >> - rai...

...39;s phase change from INITIALIZING to TRANSFERRING. On + # errors transfer's phase can change to PAUSED_SYSTEM or FINISHED_FAILURE. + # If the transfer was paused, we need to cancel it to remove the disk, + # otherwise the system will remove the disk and transfer shortly after. + endt = time.time() + timeout while True: - transfer = transfer_service.get() - if transfer.phase != types.ImageTransferPhase.INITIALIZING: + time.sleep(1) + try: + transfer = transfer_service.get() + except sdk.NotFoundError: + # The system h...

...gin.py index 2a950c5ed..873c11ce1 100644 --- a/v2v/rhv-upload-plugin.py +++ b/v2v/rhv-upload-plugin.py @@ -523,14 +523,30 @@ def close(h): # waiting for the transfer object to cease to exist, which # falls through to the exception case and then we can # continue. - endt = time.time() + timeout + start = time.time() try: while True: time.sleep(1) - tmp = transfer_service.get() - if time.time() > endt: - raise RuntimeError("timed out waiting for transfer " -...

...00644 > --- a/v2v/rhv-upload-plugin.py > +++ b/v2v/rhv-upload-plugin.py > @@ -549,16 +549,23 @@ def close(h): > # waiting for the transfer object to cease to exist, which > # falls through to the exception case and then we can > # continue. > - endt = time.time() + timeout > + disk_id = disk.id > + start = time.time() > try: > while True: > time.sleep(1) > - tmp = transfer_service.get() > - if time.time() > endt: > -...

...v/rhv-upload-plugin.py > index 9b433bd7e..e79e7ddf7 100644 > --- a/v2v/rhv-upload-plugin.py > +++ b/v2v/rhv-upload-plugin.py > @@ -575,6 +575,11 @@ def create_disk(connection): > if disk.status == types.DiskStatus.OK: > break > if time.time() > endt: > - raise RuntimeError("timed out waiting for disk to become unlocked") > + try: > + disk_service.remove() > + except Exception as e: > + debug("error removing disk %s: %s" % (disk.id, e)) > +...

...ITIALIZING to TRANSFERRING. On > + # errors transfer's phase can change to PAUSED_SYSTEM or FINISHED_FAILURE. > + # If the transfer was paused, we need to cancel it to remove the disk, > + # otherwise the system will remove the disk and transfer shortly after. > + > endt = time.time() + timeout > while True: > - transfer = transfer_service.get() > - if transfer.phase != types.ImageTransferPhase.INITIALIZING: > + time.sleep(1) > + try: > + transfer = transfer_service.get() > + except sdk.NotFoun...

...icular order? The queen2 ring should be 16 cells, why in the 'SR2[]' expression divides by 8 and not by 16? Do anyone know if the dispersed seed are properly included in the SB for the next iteration? Here I attach you the full model to be this message understandable: width = 10 height= 10 endt = 6 nPop = 1 SBLL = 1 SBUL = 10 LrD <- matrix(0, width, height) x <- as.integer(runif(nPop,min=1,max=10)) #uniform random x ccordinates for occupied cells y <- as.integer(runif(nPop,min=1,max=10)) #uniform random y ccordinates for occupied cells z <- cbind(x,y) LrD[z] = runif(nPop,min...

This series extract oVirt SDK and imageio code to make it eaiser to follow the code and improve error handing in open() and close(). The first small patches can be consider as fixes for downstream. Tested based on libguestfs v1.41.5, since I had trouble building virt-v2v and libguestfs from master. Nir Soffer (18): rhv-upload: Remove unused exception class rhv-upload: Check status more

...00644 > --- a/v2v/rhv-upload-plugin.py > +++ b/v2v/rhv-upload-plugin.py > @@ -523,16 +523,23 @@ def close(h): > # waiting for the transfer object to cease to exist, which > # falls through to the exception case and then we can > # continue. > - endt = time.time() + timeout > + disk_id = disk.id > + start = time.time() > try: > while True: > time.sleep(1) > - tmp = transfer_service.get() > - if time.time() > endt: > -...

...-upload-plugin.py b/v2v/rhv-upload-plugin.py index 1a217b6dc..3272c3ce3 100644 --- a/v2v/rhv-upload-plugin.py +++ b/v2v/rhv-upload-plugin.py @@ -193,41 +193,41 @@ def open(readonly): if transfer.phase != types.ImageTransferPhase.INITIALIZING: break if time.time() > endt: raise RuntimeError("timed out waiting for transfer status " "!= INITIALIZING") # Now we have permission to start the transfer. if params['rhv_direct']: if transfer.transfer_url is None: raise...

...G. On > > + # errors transfer's phase can change to PAUSED_SYSTEM or FINISHED_FAILURE. > > + # If the transfer was paused, we need to cancel it to remove the disk, > > + # otherwise the system will remove the disk and transfer shortly after. > > + > > endt = time.time() + timeout > > while True: > > - transfer = transfer_service.get() > > - if transfer.phase != types.ImageTransferPhase.INITIALIZING: > > + time.sleep(1) > > + try: > > + transfer = transfer_service.get() &g...

...9;, " > "using any host" % (vdsm_id, datacenter.name)) > return None > > @@ -193,15 +193,15 @@ def open(readonly): > if transfer.phase != types.ImageTransferPhase.INITIALIZING: > break > if time.time() > endt: > - raise RuntimeError("timed out waiting for transfer status " + > + raise RuntimeError("timed out waiting for transfer status " > "!= INITIALIZING") > > # Now we have permission to start the...

...gin.py index 2a950c5ed..6f65e034b 100644 --- a/v2v/rhv-upload-plugin.py +++ b/v2v/rhv-upload-plugin.py @@ -523,15 +523,23 @@ def close(h): # waiting for the transfer object to cease to exist, which # falls through to the exception case and then we can # continue. - endt = time.time() + timeout + disk_id = disk.id + start = time.time() try: while True: time.sleep(1) - tmp = transfer_service.get() - if time.time() > endt: - raise RuntimeError("timed out wait...

...gin.py index 2a950c5ed..2cefe94b0 100644 --- a/v2v/rhv-upload-plugin.py +++ b/v2v/rhv-upload-plugin.py @@ -523,16 +523,23 @@ def close(h): # waiting for the transfer object to cease to exist, which # falls through to the exception case and then we can # continue. - endt = time.time() + timeout + disk_id = disk.id + start = time.time() try: while True: time.sleep(1) - tmp = transfer_service.get() - if time.time() > endt: - raise RuntimeError("timed out wait...

...-plugin.py index 9e71021..8f13ce1 100644 --- a/v2v/rhv-upload-plugin.py +++ b/v2v/rhv-upload-plugin.py @@ -549,16 +549,23 @@ def close(h): # waiting for the transfer object to cease to exist, which # falls through to the exception case and then we can # continue. - endt = time.time() + timeout + disk_id = disk.id + start = time.time() try: while True: time.sleep(1) - tmp = transfer_service.get() - if time.time() > endt: - raise RuntimeError("timed out wait...

...> 1 file changed, 2 insertions(+), 2 deletions(-) > > diff --git a/v2v/rhv-upload-plugin.py b/v2v/rhv-upload-plugin.py > index fdd2012f5..472d483f2 100644 > --- a/v2v/rhv-upload-plugin.py > +++ b/v2v/rhv-upload-plugin.py > @@ -161,7 +161,7 @@ def open(readonly): > > endt = time.time() + timeout > while True: > - time.sleep(5) > + time.sleep(1) > disk = disk_service.get() > if disk.status == types.DiskStatus.OK: > break > @@ -197,7 +197,7 @@ def open(readonly): > transfer_service....

...00644 > --- a/v2v/rhv-upload-plugin.py > +++ b/v2v/rhv-upload-plugin.py > @@ -523,14 +523,30 @@ def close(h): > # waiting for the transfer object to cease to exist, which > # falls through to the exception case and then we can > # continue. > - endt = time.time() + timeout > + start = time.time() > try: > while True: > time.sleep(1) > - tmp = transfer_service.get() > - if time.time() > endt: > - raise RuntimeError("timed...