Changeset 723:3b5177cf4780 in hatta-dev

Timestamp:

01/10/10 20:13:06 (2 years ago)

Author:

Radomir Dopieralski <devel@…>

Branch:

default

Message:

make WikiStorage thread-safe

File:

• hatta.py (modified) (1 diff)

hatta.py

@@ -322 +322 @@
             create = False
         self.repo_prefix = self.path[len(self.repo_path):].strip('/')
-        self.repo = mercurial.hg.repository(self.ui, self.repo_path,
-                                            create=create)
+        self._repos = {}
+        # Create the repository if needed.
+        mercurial.hg.repository(self.ui, self.repo_path, create=create)
 
     def reopen(self):
         """Close and reopen the repo, to make sure we are up to date."""
 
-        self.repo = mercurial.hg.repository(self.ui, self.repo_path)
-
+        #self.repo = mercurial.hg.repository(self.ui, self.repo_path)
+        self._repos = {}
+
+    @property
+    def repo(self):
+        """Keep one open repository per thread."""
+
+        thread_id = thread.get_ident()
+        try:
+            return self._repos[thread_id]
+        except KeyError:
+            repo = mercurial.hg.repository(self.ui, self.repo_path)
+            self._repos[thread_id] = repo
+            return repo
 
     def _find_repo_path(self, path):