From afa1de13f0576ace6dcbb0176490fd20922950cd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ren=C3=A9=20=27Necoro=27=20Neumann?= <necoro@necoro.net>
Date: Tue, 2 Sep 2008 13:01:17 +0200
Subject: Switch from tabs to 4 spaces

---
 portato/waiting_queue.py | 88 ++++++++++++++++++++++++------------------------
 1 file changed, 44 insertions(+), 44 deletions(-)

(limited to 'portato/waiting_queue.py')

diff --git a/portato/waiting_queue.py b/portato/waiting_queue.py
index 32839d3..bc2c50c 100644
--- a/portato/waiting_queue.py
+++ b/portato/waiting_queue.py
@@ -17,47 +17,47 @@ from Queue import Queue
 
 class WaitingQueue (Queue):
 
-	def __init__ (self, setTrue = True, threadClass = Thread):
-		if not issubclass(threadClass, Thread):
-			raise ValueError, "Only subclasses of threading.Thread are allowed."
-		
-		Queue.__init__(self)
-		self.event = Event()
-		self.counter = 0
-		self.threadClass = threadClass
-
-		if setTrue:
-			self.event.set() # true at the beginning
-
-		waitingThread = self.threadClass(name = "Waiting-Queue-Thread", target = self.runThread)
-		waitingThread.setDaemon(True)
-		waitingThread.start()
-
-	def put (self, method, *args, **kwargs):
-		self.counter += 1;
-		
-		if "caller" in kwargs:
-			name = "Waiting Thread #%d (called by:%s)" % (self.counter, kwargs["caller"])
-			del kwargs["caller"]
-		else:
-			name = "Waiting Thread #%d" % self.counter
-
-		t = self.threadClass(name = name, target = method, args = args, kwargs = kwargs)
-		t.setDaemon(True)
-		Queue.put(self, t, False)
-
-	def runThread (self):
-		while True:
-			self.event.wait()
-			t = self.get(True)
-			self.event.clear()
-			t.run()
-
-	def next (self):
-		self.event.set()
-
-	def clear (self):
-		self.mutex.acquire()
-		self.queue.clear()
-		self.mutex.release()
-		self.event.set()
+    def __init__ (self, setTrue = True, threadClass = Thread):
+        if not issubclass(threadClass, Thread):
+            raise ValueError, "Only subclasses of threading.Thread are allowed."
+        
+        Queue.__init__(self)
+        self.event = Event()
+        self.counter = 0
+        self.threadClass = threadClass
+
+        if setTrue:
+            self.event.set() # true at the beginning
+
+        waitingThread = self.threadClass(name = "Waiting-Queue-Thread", target = self.runThread)
+        waitingThread.setDaemon(True)
+        waitingThread.start()
+
+    def put (self, method, *args, **kwargs):
+        self.counter += 1;
+        
+        if "caller" in kwargs:
+            name = "Waiting Thread #%d (called by:%s)" % (self.counter, kwargs["caller"])
+            del kwargs["caller"]
+        else:
+            name = "Waiting Thread #%d" % self.counter
+
+        t = self.threadClass(name = name, target = method, args = args, kwargs = kwargs)
+        t.setDaemon(True)
+        Queue.put(self, t, False)
+
+    def runThread (self):
+        while True:
+            self.event.wait()
+            t = self.get(True)
+            self.event.clear()
+            t.run()
+
+    def next (self):
+        self.event.set()
+
+    def clear (self):
+        self.mutex.acquire()
+        self.queue.clear()
+        self.mutex.release()
+        self.event.set()
-- 
cgit v1.2.3