Changeset d21198f for server/lib
- Timestamp:
- Jan 11, 2012, 3:27:02 PM (12 years ago)
- Branches:
- no-cups
- Children:
- 34a4e5d
- Parents:
- eee389a
- git-author:
- Jessica B. Hamrick <jhamrick@…> (01/11/12 15:27:02)
- git-committer:
- Jessica B. Hamrick <jhamrick@…> (01/11/12 15:27:02)
- Location:
- server/lib/gutenbach/server
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
server/lib/gutenbach/server/__init__.py
reee389a rd21198f 23 23 24 24 # configure and initialize logging 25 logging.basicConfig(level=logging. INFO)25 logging.basicConfig(level=logging.DEBUG) 26 26 logger = logging.getLogger(__name__) 27 27 -
server/lib/gutenbach/server/job.py
reee389a rd21198f 138 138 self.state = States.PROCESSING 139 139 self.player.callback = self._completed 140 self.player. run()140 self.player.start() 141 141 142 142 def pause(self): -
server/lib/gutenbach/server/printer.py
reee389a rd21198f 50 50 51 51 def __init__(self, name, *args, **kwargs): 52 53 super(GutenbachPrinter, self).__init__(*args, **kwargs) 54 55 self.name = name 56 self.time_created = int(time.time()) 57 58 self.finished_jobs = [] 59 self.pending_jobs = [] 60 self.current_job = None 61 self.jobs = {} 62 52 63 self.lock = threading.RLock() 53 54 with self.lock: 55 super(GutenbachPrinter, self).__init__(*args, **kwargs) 56 57 self.name = name 58 self.time_created = int(time.time()) 59 60 self.finished_jobs = [] 61 self.pending_jobs = [] 62 self.current_job = None 63 self.jobs = {} 64 65 self.running = False 66 self.paused = False 67 68 # CUPS ignores jobs with id 0, so we have to start at 1 69 self._next_job_id = 1 64 self.running = False 65 self.paused = False 66 67 # CUPS ignores jobs with id 0, so we have to start at 1 68 self._next_job_id = 1 70 69 71 70 def __repr__(self): … … 132 131 job_id = heapq.heappop(self.pending_jobs) 133 132 self.current_job = self.get_job(job_id) 133 print "before play" 134 134 self.current_job.play() 135 print "after play" 135 136 except IndexError: 136 pass137 self.current_job = None 137 138 except InvalidJobStateException: 138 139 heapq.heappush(self.pending_jobs, self.current_job.id) 139 finally:140 140 self.current_job = None 141 141
Note: See TracChangeset
for help on using the changeset viewer.