Changeset ce2abc5 for server

Timestamp:

Dec 28, 2011, 12:10:35 AM (12 years ago)

Author:

Jessica B. Hamrick <jhamrick@…>

Branches:

no-cups

Children:

ffbe41d

Parents:

e58af05

git-author:

Jessica B. Hamrick <jhamrick@…> (12/28/11 00:10:35)

git-committer:

Jessica B. Hamrick <jhamrick@…> (12/28/11 00:10:35)

Message:

Queueing jobs (and playing them through mplayer) works

Location:

server/lib/gutenbach

Files:

• ipp/core/request.py (modified) (1 diff)
• server/job.py (modified) (3 diffs)
• server/printer.py (modified) (2 diffs)

server/lib/gutenbach/ipp/core/request.py

@@ -188 +188 @@
                 raise ClientErrorBadRequest("length (%d) < 0" % length)
             
-            self.data = tempfile.TemporaryFile()
+            self.data = tempfile.NamedTemporaryFile()
             self.data.write(request.read(length))
             self.data.seek(0)

server/lib/gutenbach/server/job.py

@@ -3 +3 @@
 import gutenbach.ipp as ipp
 import logging
+import subprocess
+import time
 
 # initialize logger
@@ -36 +38 @@
         self.document = None
         self.document_name = None
+        self.player = None
 
         self.status   = ipp.JobStates.HELD
@@ -99 +102 @@
         # TODO: add external call to music player
         self.status = ipp.JobStates.PROCESSING
+        self.player = subprocess.Popen(
+            "/usr/bin/mplayer -quiet %s" % self.document.name,
+            shell=True)
+            #stderr=subprocess.PIPE,
+            #stdout=subprocess.PIPE)
+        while self.player.poll() is None:
+            time.sleep(0.1)
+        logger.info("mplayer finished with code %d" % self.player.returncode)
+        #if self.player.returncode < 0:
+        #    logger.error(self.player.stderr)
+        #logger.debug(self.player.stdout)
+        self.player = None
         self.printer.complete_job(self.jid)
 

server/lib/gutenbach/server/printer.py

@@ -227 +227 @@
                 "Invalid job state: %d" % job.status)
         job.document = document
+        logger.debug("document for job %d is '%s'" % (jobid, job.document.name))
         job.status = ipp.JobStates.PENDING
 
@@ -251 +252 @@
         else:
             job = self.active_jobs[0]
-        return job        
+        return job
+
+    def stop(self):
+        if len(self.active_jobs) == 0:
+            return
+        job = self.jobs[self.active_jobs[0]]
+        if job.player is not None:
+            logger.info("stopping printer %s" % self.name)
+            job.player.terminate()
 
     def get_job(self, jobid):