fixed wrong thread synchronization

job could not be finished on rare occasions

1 files changed, 7 insertions, 4 deletions

diff --git a/src/software/openlmi/software/yumdb/__init__.py b/src/software/openlmi/software/yumdb/__init__.py
index dc77689..2f41783 100644
--- a/src/software/openlmi/software/yumdb/__init__.py
+++ b/src/software/openlmi/software/yumdb/__init__.py
@@ -132,12 +132,13 @@ class YumDB(singletonmixin.Singleton):
         @return result of job
         """
         with self._reply_lock:
-            # until our job is not at the head of 
             self._expected.append(job.jobid)
-            while job.jobid != self._expected[0]:
+            while True:
                 if job.jobid in self._replies:
                     self._expected.remove(job.jobid)
                     return self._replies.pop(job.jobid)
+                elif job.jobid == self._expected[0]:
+                    break
                 else:
                     cmpi_logging.logger.debug(
                         "[jobid=%d] another %s threads expecting reply,"
@@ -201,9 +202,11 @@ class YumDB(singletonmixin.Singleton):
             uplink = JoinableQueue()
             downlink = Queue()
             self._process = YumWorker(uplink, downlink,
-                    yum_args=self._yum_args[0], yum_kwargs=self._yum_args[1])
-                    #logging_config=YUM_WORKER_DEBUG_LOGGING_CONFIG)
+                    yum_args=self._yum_args[0], yum_kwargs=self._yum_args[1],
+                    logging_config=YUM_WORKER_DEBUG_LOGGING_CONFIG)
             self._process.start()
+            cmpi_logging.logger.trace_info(
+                    "YumDB: YumWorker started with pid=%s", self._process.pid)
         return self._process
 
     # *************************************************************************