Changes in server/lib/gutenbach/server/printer.py [c1dc25f:9225351]

File:

• server/lib/gutenbach/server/printer.py (modified) (5 diffs)

server/lib/gutenbach/server/printer.py

@@ -9 +9 @@
 import traceback
 import sys
+from . import sync
 
 
@@ -100 +101 @@
             with self.lock:
                 try:
-                    if self.current_job is None:
+                    if not self.paused and self.current_job is None:
                         self.start_job()
                     elif self.current_job.is_done:
@@ -124 +125 @@
 
     @property
+    @sync
     def state(self):
-        with self.lock:
-            if self.current_job is not None:
-                val = States.PROCESSING
-            elif len(self.pending_jobs) == 0:
-                val = States.IDLE
-            else:
-                val = States.STOPPED
-        return val
-
-    @property
+        if self.current_job is not None:
+            return States.PROCESSING
+        elif len(self.pending_jobs) == 0:
+            return States.IDLE
+        else:
+            return States.STOPPED
+
+    @property
+    @sync
     def active_jobs(self):
-        with self.lock:
-            jobs = self.pending_jobs[:]
-            if self.current_job is not None:
-                jobs.insert(0, self.current_job.id)
+        jobs = self.pending_jobs[:]
+        if self.current_job is not None:
+            jobs.insert(0, self.current_job.id)
         return jobs
 
@@ -146 +146 @@
     ######################################################################
 
+    @sync
     def start_job(self):
-        with self.lock:
-            if self.current_job is None:
-                try:
-                    job_id = heapq.heappop(self.pending_jobs)
-                    self.current_job = self.get_job(job_id)
-                    self.current_job.play()
-                except IndexError:
-                    self.current_job = None
-                except InvalidJobStateException:
-                    heapq.heappush(self.pending_jobs, self.current_job.id)
-                    self.current_job = None
+        if self.current_job is None:
+            try:
+                job_id = heapq.heappop(self.pending_jobs)
+                self.current_job = self.get_job(job_id)
+                self.current_job.play()
+            except IndexError:
+                self.current_job = None
+            except InvalidJobStateException:
+                heapq.heappush(self.pending_jobs, self.current_job.id)
+                self.current_job = None
                     
+    @sync
     def complete_job(self):
-        with self.lock:
-            if self.current_job is None:
-                return
-
-            try:
-                if not self.current_job.is_done:
-                    self.current_job.stop()
-            finally:
-                self.finished_jobs.append(self.current_job.id)
-                self.current_job = None
-
+        if self.current_job is None:
+            return
+
+        try:
+            if not self.current_job.is_done:
+                self.current_job.stop()
+        finally:
+            self.finished_jobs.append(self.current_job.id)
+            self.current_job = None
+
+    @sync
     def get_job(self, job_id):
-        with self.lock:
-            if job_id not in self.jobs:
-                raise InvalidJobException(job_id)
-            job = self.jobs[job_id]
-        return job
+        if job_id not in self.jobs:
+            raise InvalidJobException(job_id)
+        return self.jobs[job_id]
 
     ######################################################################
@@ -412 +411 @@
         return job_id
 
+    @sync
     def pause_printer(self):
-        pass
-
+        """Pause the printer.
+
+        Does nothing if the printer is already paused.
+        """
+        if self.paused:
+            return
+
+        if self.current_job is not None and self.current_job.is_playing:
+            self.current_job.pause()
+
+        self.paused = True
+
+
+
+    @sync
     def resume_printer(self):
-        pass
+        """Resume the printer.
+
+        Does nothing if the printer is not paused.
+        """
+        if not self.paused:
+            return
+
+        if self.current_job is not None:
+            self.current_job.resume()
+
+        self.paused = False
 
     def get_printer_attributes(self, requested_attributes=None):