Changeset 173 in tracdarcs for tracdarcs/components.py

Timestamp:

05/08/10 21:28:22 (2 years ago)

Author:

lele@…

Hash name:

20100508192822-97f81-b1bb7bbbea66114acc0c79d962bd856ff264cf23

Message:

Optional constraint on the number of concurrent darcs processes
A new option "darcs.max_concurrent_darcses" may set a limit on the
number of concurrent running darcs subprocesses. It is eventually
applied on a per repository basis. By default there are no limits, as
before.

File:

• tracdarcs/components.py (modified) (2 diffs)

tracdarcs/components.py

@@ -37 +37 @@
     darcs_command = Option('darcs', 'command', 'darcs',
                            "Name of the external darcs binary.")
+
+    max_concurrent_darcses = Option('darcs', 'max_concurrent_darcses', 'false',
+                                    "Max number of concurrent darcses running per repository.")
 
     possible_encodings = Option('darcs', 'possible_encodings', 'utf-8,iso8859-1',
@@ -56 +59 @@
             possible_encodings = [e.strip()
                                   for e in self.possible_encodings.split(',')]
+
+        # Setup the semaphore used to limit the number of concurrent running
+        # darcs within a single repository.
+
+        if self.max_concurrent_darcses and int(self.max_concurrent_darcses)>0:
+            from command import DarcsCommand
+            if DarcsCommand.RUNNING_DARCSES is None:
+                from threading import BoundedSemaphore
+                DarcsCommand.RUNNING_DARCSES = BoundedSemaphore(value=int(self.max_concurrent_darcses))
+
         return DarcsRepository(db, dir, self.env.log, darcs, possible_encodings, params)