Changeset 1516 for pykota/trunk/pykota/tool.py

Timestamp:

06/03/04 10:51:03 (20 years ago)

Author:

jalet

Message:

logs job's size in bytes now

Files:

• pykota/trunk/pykota/tool.py (modified) (5 diffs)

pykota/trunk/pykota/tool.py

@@ -22 +22 @@
 #
 # $Log$
+# Revision 1.94  2004/06/03 08:51:03  jalet
+# logs job's size in bytes now
+#
 # Revision 1.93  2004/06/02 21:51:02  jalet
 # Moved the sigterm capturing elsewhere
@@ -813 +816 @@
         self.exportJobInfo()
         self.jobdatastream = self.openJobDataStream()
+        os.putenv("PYKOTAJOBSIZEBYTES", str(self.JobSizeBytes))
+        self.logdebug("Job size is %s bytes" % self.JobSizeBytes)
         self.logdebug("Capturing SIGTERM events.")
         signal.signal(signal.SIGTERM, self.sigterm_handler)
@@ -824 +829 @@
             self.logdebug("Duplicating data stream from stdin to temporary file")
             MEGABYTE = 1024*1024
+            self.JobSizeBytes = 0
             infile = tempfile.TemporaryFile()
             while 1 :
@@ -829 +835 @@
                 if not data :
                     break
+                self.JobSizeBytes += len(data)    
                 infile.write(data)
             infile.flush()    
@@ -836 +843 @@
             # real file, just open it
             self.logdebug("Opening data stream %s" % self.preserveinputfile)
+            self.JobSizeBytes = os.stat(self.preserveinputfile)[6]
             return open(self.preserveinputfile, "rb")