--- a/src/modules/server/repository.py Tue Sep 07 13:23:42 2010 -0700
+++ b/src/modules/server/repository.py Tue Sep 07 18:07:58 2010 -0700
@@ -318,7 +318,7 @@
self.__lockfile = None
# Initialize.
- self.__lock_rstore()
+ self.__lock_rstore(blocking=True)
try:
self.__init_state()
finally:
@@ -470,7 +470,7 @@
storage_locked = False
try:
- self.__lock_rstore(blocking=False)
+ self.__lock_rstore()
except RepositoryLockedError:
storage_locked = True
except:
@@ -486,7 +486,7 @@
self._get_manifest, self.manifest,
log=self.__index_log,
sort_file_max_size=self.__sort_file_max_size)
- ind.lock()
+ ind.lock(blocking=False)
except se.IndexLockedException:
index_locked = True
except:
@@ -532,7 +532,7 @@
"status": rstatus,
}
- def __lock_rstore(self, blocking=True, process=True):
+ def __lock_rstore(self, blocking=False, process=True):
"""Locks the repository preventing multiple consumers from
modifying it during operations."""
@@ -1126,7 +1126,7 @@
if not self.catalog_root or self.catalog_version < 1:
raise RepositoryUnsupportedOperationError()
- self.__lock_rstore()
+ self.__lock_rstore(blocking=True)
try:
self.__add_package(pfmri)
self.__save_catalog()
@@ -1144,7 +1144,7 @@
if not self.catalog_root or self.catalog_version < 1:
raise RepositoryUnsupportedOperationError()
- self.__lock_rstore()
+ self.__lock_rstore(blocking=True)
try:
self.__replace_package(pfmri)
self.__save_catalog()