Changeset e58af05 for server/lib/gutenbach/server/server.py

Timestamp:

Dec 27, 2011, 11:33:55 PM (12 years ago)

Author:

Jessica B. Hamrick <jhamrick@…>

Branches:

no-cups

Children:

ce2abc5

Parents:

7c143c9

git-author:

Jessica B. Hamrick <jhamrick@…> (12/27/11 23:33:55)

git-committer:

Jessica B. Hamrick <jhamrick@…> (12/27/11 23:33:55)

Message:

Implement send-document operation and add threading so that the gutenbach server can play jobs

File:

• server/lib/gutenbach/server/server.py (modified) (2 diffs)

server/lib/gutenbach/server/server.py

@@ -1 @@
-from gutenbach.server.requests import GutenbachRequestHandler
+import gutenbach.ipp as ipp
+
+from . import InvalidPrinterStateException, InvalidJobException
+from . import GutenbachPrinter
+from . import GutenbachRequestHandler
+
 import BaseHTTPServer
-import gutenbach.ipp as ipp
 import logging
 import sys
 import traceback
 import tempfile
+import threading
+import time
 
 # initialize logger
 logger = logging.getLogger(__name__)
 
-# initialize handler
-handler = GutenbachRequestHandler()
+class GutenbachServer(threading.Thread):
 
-class GutenbachIPPServer(BaseHTTPServer.BaseHTTPRequestHandler):
+    def run(self):
+        self.printer = GutenbachPrinter(name="test")
+        self.request_stop = False
+
+        while not self.request_stop:
+            job = self.printer.next_job
+            if job is not None:
+                try:
+                    self.printer.start_job(job)
+                except InvalidPrinterStateException:
+                    pass
+                except:
+                    logger.fatal(traceback.format_exc())
+                    sys.exit(1)
+            time.sleep(0.1)
+
+class IPPServer(BaseHTTPServer.BaseHTTPRequestHandler):
+    
     def send_continue(self):
         self.send_response(100, "continue")
@@ -83 +105 @@
         # throw a fatal error.
         logger.debug("request: %s" % repr(request))
-        response = handler.handle(request)
+        response = GutenbachRequestHandler(self.server.gutenbach_server).handle(request)
         self.send_ok(response)