Changeset 1606 for pykota/trunk/bin/cupspykota

Timestamp:

07/21/04 00:19:45 (20 years ago)

Author:

jalet

Message:

Sanitized a bit + use of gettext

Files:

• pykota/trunk/bin/cupspykota (modified) (18 diffs)

pykota/trunk/bin/cupspykota

@@ -24 +24 @@
 #
 # $Log$
+# Revision 1.68  2004/07/20 22:19:44  jalet
+# Sanitized a bit + use of gettext
+#
 # Revision 1.67  2004/07/16 12:22:45  jalet
 # LPRng support early version
@@ -348 +351 @@
             pagelog.close()        
             if matchingline is None :
-                self.logdebug("No matching line found in page_log")
+                self.logdebug("No matching line found in %s" % pagelogpath)
                 return # correct line not found, job-originating-hostname unknown
             else :    
@@ -376 +379 @@
                 self.softwareJobSize = self.precomputeJobSize()
                 self.softwareJobPrice = userpquota.computeJobPrice(self.softwareJobSize)
-                self.sendBackChannelData("Precomputed job's size is %s pages, price is %s units" % (self.softwareJobSize, self.softwareJobPrice))
+                self.logdebug("Precomputed job's size is %s pages, price is %s units" % (self.softwareJobSize, self.softwareJobPrice))
             os.environ["PYKOTAPRECOMPUTEDJOBSIZE"] = str(self.softwareJobSize)
             os.environ["PYKOTAPRECOMPUTEDJOBPRICE"] = str(self.softwareJobPrice)
-            
-            # checks the user's quota
-            action = self.warnUserPQuota(userpquota)
             
             # if no data to pass to real backend, probably a filter
@@ -389 +389 @@
                 self.printInfo(_("Job contains no data. Printing is denied."), "warn")
                 action = "DENY"
+            else :    
+                # checks the user's quota
+                action = self.warnUserPQuota(userpquota)
             
             # exports some new environment variables
@@ -396 +399 @@
             self.prehook(userpquota)
             
-            self.sendBackChannelData("Job accounting begins.")
+            self.printInfo(_("Job accounting begins."))
             self.accounter.beginJob(userpquota)
         else :    
@@ -417 +420 @@
             # stops accounting. 
             self.accounter.endJob(userpquota)
-            self.sendBackChannelData("Job accounting ends.")
+            self.printInfo(_("Job accounting ends."))
                 
             # retrieve the job size    
             if action == "DENY" :
                 jobsize = 0
-                self.sendBackChannelData("Job size forced to 0 because printing is denied.")
+                self.printInfo(_("Job size forced to 0 because printing is denied."))
             else :    
                 jobsize = self.accounter.getJobSize()
-            self.sendBackChannelData("Job size : %i" % jobsize)
+            self.printInfo(_("Job size : %i") % jobsize)
             
             # update the quota for the current user on this printer 
-            self.sendBackChannelData("Updating user %s's quota on printer %s" % (user.Name, printer.Name))
+            self.printInfo(_("Updating user %s's quota on printer %s") % (user.Name, printer.Name))
             jobprice = userpquota.increasePagesUsage(jobsize)
             
             # adds the current job to history    
             printer.addJobToHistory(self.jobid, user, self.accounter.getLastPageCounter(), action, jobsize, jobprice, self.preserveinputfile, self.title, self.copies, self.options, clienthost, self.jobSizeBytes)
-            self.sendBackChannelData("Job added to history.")
+            self.printInfo(_("Job added to history."))
             
             # exports some new environment variables
@@ -481 +484 @@
         
         # And launch it
-        self.sendBackChannelData("Starting real backend %s with args %s" % (realbackend, " ".join(['"%s"' % a for a in ([os.environ["DEVICE_URI"]] + sys.argv[1:])])))
+        self.logdebug("Starting real backend %s with args %s" % (realbackend, " ".join(['"%s"' % a for a in ([os.environ["DEVICE_URI"]] + sys.argv[1:])])))
         subprocess = PyKotaPopen4([realbackend] + sys.argv[1:], bufsize=0, arg0=os.environ["DEVICE_URI"])
         
@@ -511 +514 @@
             # job's data is in a file, no need to pass the data
             # to the real backend
-            self.sendBackChannelData("Job's data is in %s" % self.preserveinputfile)
+            self.logdebug("Job's data is in %s" % self.preserveinputfile)
             infno = None
             endinput = 1
         
-        self.sendBackChannelData("Entering streams polling loop...")
+        self.logdebug("Entering streams polling loop...")
         MEGABYTE = 1024*1024
         killed = 0
@@ -531 +534 @@
                     self.logdebug("Error while sending signal to pid %s : %s" % (subprocess.pid, msg))
                 else :    
-                    self.sendBackChannelData(_("SIGTERM was sent to real backend %s (pid: %s)") % (realbackend, subprocess.pid))
+                    self.printInfo(_("SIGTERM was sent to real backend %s (pid: %s)") % (realbackend, subprocess.pid))
                     killed = 1
             
@@ -541 +544 @@
                 availablefds = []
             if not availablefds :
-                self.sendBackChannelData("Nothing to do, sleeping a bit...")
+                self.logdebug("Nothing to do, sleeping a bit...")
                 time.sleep(0.01) # give some time to the system
             else :
@@ -558 +561 @@
                                         indata = ""
                                 else :        
-                                    self.sendBackChannelData("No data to send to real backend yet, sleeping a bit...")
+                                    self.logdebug("No data to send to real backend yet, sleeping a bit...")
                                     time.sleep(0.01)
                                     
                                 if endinput :    
                                     self.unregisterFileNo(pollster, tocfno)        
-                                    self.sendBackChannelData("Closing real backend's stdin.")
+                                    self.logdebug("Closing real backend's stdin.")
                                     os.close(tocfno)
                                     inputclosed = 1
@@ -595 +598 @@
                                     if not data :    # If yes, then no more input data
                                         self.unregisterFileNo(pollster, infno)
-                                        self.sendBackChannelData("Input data ends.")
+                                        self.logdebug("Input data ends.")
                                         endinput = 1 # this happens with real files.
                                     else :    
@@ -601 +604 @@
                                 elif fd == fromcfno :
                                     if not data :
-                                        self.sendBackChannelData("No back channel data to read from real backend yet, sleeping a bit...")
+                                        self.logdebug("No back channel data to read from real backend yet, sleeping a bit...")
                                         time.sleep(0.01)
                                     else :
@@ -616 +619 @@
                                 # Here we are in the case where the input file is stdin.
                                 # which has no more data to be read.
-                                self.sendBackChannelData("Input data ends.")
+                                self.logdebug("Input data ends.")
                                 endinput = 1
                             elif fd == fromcfno :    
                                 # We are no more interested in this file descriptor        
-                                self.sendBackChannelData("Closing real backend's stdout+stderr.")
+                                self.logdebug("Closing real backend's stdout+stderr.")
                                 os.close(fromcfno)
                                 endoutput = 1
@@ -628 +631 @@
                                 
                         if mask & select.POLLNVAL :        
-                            self.sendBackChannelData("File %s was closed. Unregistering from polling object." % fd)
+                            self.logdebug("File %s was closed. Unregistering from polling object." % fd)
                             self.unregisterFileNo(pollster, fd)
                     except IOError, msg :            
@@ -635 +638 @@
         # We must close the real backend's input stream
         if killed and not inputclosed :
-            self.sendBackChannelData("Forcing close of real backend's stdin.")
+            self.logdebug("Forcing close of real backend's stdin.")
             os.close(tocfno)
         
-        self.sendBackChannelData("Exiting streams polling loop...")
+        self.logdebug("Exiting streams polling loop...")
         
         # Check exit code of original CUPS backend.    
@@ -644 +647 @@
             # we exited the loop before the real backend exited
             # now we have to wait for it to finish and get its status
-            self.sendBackChannelData("Waiting for real backend to exit...")
+            self.logdebug("Waiting for real backend to exit...")
             try :
                 status = subprocess.wait()
@@ -652 +655 @@
             retcode = os.WEXITSTATUS(status)
         elif not killed :    
-            self.printInfo(_("CUPS backend %s died abnormally.") % realbackend, "error")
+            self.sendBackChannelData(_("CUPS backend %s died abnormally.") % realbackend, "error")
             retcode = -1
         else :