Reference Manual

def fff_deletion.FileDeleter.delete	(	self,
		f
	)

Definition at line 101 of file fff_deletion.py.

References fff_deletion.FileDeleter.fake, and ValidationMisalignedTracker.fake.

Referenced by Vispa.Gui.PortConnection.PointToPointConnection.keyPressEvent(), Vispa.Views.LineDecayView.LineDecayContainer.keyPressEvent(), Vispa.Gui.VispaWidget.VispaWidget.keyPressEvent(), and fff_deletion.FileDeleter.run().

 
     def delete(self, f):
         if not f.endswith(".deleted"):
             return
     
         if self.fake:
             log.warning("Truncating file (fake): %s", f)
         else:
             log.warning("Truncating file: %s", f)
             open(f, "w").close()

fff_deletion.FileDeleter.fake

fake

Definition: fff_deletion.py:78

fff_deletion.FileDeleter.delete

def delete

Definition: fff_deletion.py:101

def fff_deletion.FileDeleter.rename	(	self,
		f
	)

Definition at line 86 of file fff_deletion.py.

References fff_deletion.FileDeleter.fake, and ValidationMisalignedTracker.fake.

Referenced by fff_deletion.FileDeleter.run().

 
     def rename(self, f):
         if f.endswith(".deleted"):
             return
 
         fn = f + ".deleted"
 
         if self.fake:
             log.warning("Renaming file (fake): %s -> %s", f, 
                 os.path.relpath(fn, os.path.dirname(f)))
         else:
             log.warning("Renaming file: %s -> %s", f, 
                 os.path.relpath(fn, os.path.dirname(f)))
 
             os.rename(f, fn)

fff_deletion.FileDeleter.fake

fake

Definition: fff_deletion.py:78

fff_deletion.FileDeleter.rename

def rename

Definition: fff_deletion.py:86

def fff_deletion.FileDeleter.run ( self )

Definition at line 133 of file fff_deletion.py.

References fff_deletion.cleanup_threshold(), fff_deletion.FileDeleter.delete(), fff_deletion.diskusage(), fff_deletion.FileDeleter.rename(), fff_deletion.FileDeleter.thresholds, and fff_deletion.FileDeleter.top.

Referenced by Types.EventID.cppID(), and Types.LuminosityBlockID.cppID().

 
     def run(self):            
         cleanup_threshold(self.top, self.thresholds['rename'], self.rename, "rename")
         cleanup_threshold(self.top, self.thresholds['delete'], self.delete, "delete")
    
         du = diskusage(self.top)
         if du > self.thresholds['email']: 
             deleter.send_smg(du)
 
 # use a named socket check if we are running
 # this is very clean and atomic and leave no files
# from: http://stackoverflow.com/a/7758075

fff_deletion.diskusage

def diskusage

Definition: fff_deletion.py:69

fff_deletion.FileDeleter.run

def run

Definition: fff_deletion.py:133

fff_deletion.cleanup_threshold

def cleanup_threshold

Definition: fff_deletion.py:51

fff_deletion.FileDeleter.delete

def delete

Definition: fff_deletion.py:101

fff_deletion.FileDeleter.rename

def rename

Definition: fff_deletion.py:86

fff_deletion.FileDeleter.top

top

Definition: fff_deletion.py:77

fff_deletion.FileDeleter.thresholds

thresholds

Definition: fff_deletion.py:80

def fff_deletion.FileDeleter.send_smg	(	self,
		used_pc
	)

Definition at line 111 of file fff_deletion.py.

References fff_deletion.FileDeleter.email_to, fff_deletion.FileDeleter.hostname, fff_deletion.FileDeleter.last_email, and fff_deletion.FileDeleter.min_interval.

 
     def send_smg(self, used_pc):
         now = datetime.datetime.now()
 
         if (self.last_email is not None):
             if (now - self.last_email) < self.min_interval:
                 return
 
         self.last_email = now
 
         # sms service does not accept an email with a several recipients
         # so we send one-by-one
         for email in self.email_to:
             subject = "Disk out of space (%.02f%%) on %s." % (used_pc, self.hostname)
             if "mail2sms" in email:
                 text = ""
             else:
                 text = subject
 
             log.info("Sending email: %s", repr(["/bin/mail", "-s", subject, email]))
             p = subprocess.Popen(["/bin/mail", "-s", subject, email], stdin=subprocess.PIPE, shell=False)
             p.communicate(input=text)