Reference Manual

def fff_deleter.FileDeleter.delete	(	self,
		f
	)

Definition at line 114 of file fff_deleter.py.

References ValidationMisalignedTracker.fake, and fff_deleter.FileDeleter.fake.

Referenced by Vispa.Gui.PortConnection.PointToPointConnection.keyPressEvent(), Vispa.Views.LineDecayView.LineDecayContainer.keyPressEvent(), Vispa.Gui.VispaWidget.VispaWidget.keyPressEvent(), and fff_deleter.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_deleter.FileDeleter.delete

def delete

Definition: fff_deleter.py:114

fff_deleter.FileDeleter.fake

fake

Definition: fff_deleter.py:89

def fff_deleter.FileDeleter.make_report	(	self,
		logout
	)

Definition at line 146 of file fff_deleter.py.

References python.multivaluedict.dict, fff_deleter.diskusage_bytes(), fff_deleter.FileDeleter.hostname, list(), python.multivaluedict.map(), fff_deleter.FileDeleter.report_directory, fff_deleter.FileDeleter.sequence, ConfigBuilder.ConfigBuilder.sequence, and fff_deleter.FileDeleter.top.

 
     def make_report(self, logout):
         if not os.path.isdir(self.report_directory):
             log.warning("Directory %s does not exists. Reports disabled.", self.report_directory)
             return
         
         meminfo = list(open("/proc/meminfo", "r").readlines())
         def entry_to_dict(line):
             key, value = line.split()[:2]
             value = int(value)
             return (key.strip(":"), value, )
         meminfo = dict(map(entry_to_dict, meminfo))
 
         if os.path.isdir(self.top): 
             used, free, total = diskusage_bytes(self.top)
         else:
             used, free, total = -1, -1, -1
 
         doc = {
             "sequence": self.sequence,
             "memory_used": (meminfo["MemTotal"] - meminfo["MemFree"]) * 1024,
             "memory_free": meminfo["MemFree"] * 1024,
             "memory_total": meminfo["MemTotal"] * 1024,
             "disk_used": used,
             "disk_free": free,
             "disk_total": total,
             "hostname": self.hostname,
             "extra": {
                 "meminfo": meminfo,
                 "last_log": logout.split("\n"),
             },
             "pid": os.getpid(),
             "_id": "dqm-diskspace-%s" % self.hostname,
             "type": "dqm-diskspace"
         }
 
         fn = "dqm-diskspace-seq%06d" % (doc["sequence"], )
         tmp_fp = os.path.join(self.report_directory, "." + fn + ".tmp")
         final_fp = os.path.join(self.report_directory, fn + ".jsn")
         fd = open(tmp_fp, "w")
 
         json.dump(doc, fd, indent=True)
         fd.write("\n")
         fd.close()
 
         os.rename(tmp_fp, final_fp)

fff_deleter.FileDeleter.hostname

hostname

Definition: fff_deleter.py:97

python.multivaluedict.dict

dict

Definition: multivaluedict.py:25

fff_deleter.FileDeleter.sequence

sequence

Definition: fff_deleter.py:93

fff_deleter.diskusage_bytes

def diskusage_bytes

Definition: fff_deleter.py:78

python.multivaluedict.map

def map

Definition: multivaluedict.py:125

fff_deleter.FileDeleter.report_directory

report_directory

Definition: fff_deleter.py:92

fff_deleter.FileDeleter.top

top

Definition: fff_deleter.py:88

list

How EventSelector::AcceptEvent() decides whether to accept an event for output otherwise it is excluding the probing of A single or multiple positive and the trigger will pass if any such matching triggers are PASS or EXCEPTION[A criterion thatmatches no triggers at all is detected and causes a throw.] A single negative with an expectation of appropriate bit checking in the decision and the trigger will pass if any such matching triggers are FAIL or EXCEPTION A wildcarded negative criterion that matches more than one trigger in the trigger list("!*","!HLTx*"if it matches 2 triggers or more) will accept the event if all the matching triggers are FAIL.It will reject the event if any of the triggers are PASS or EXCEPTION(this matches the behavior of"!*"before the partial wildcard feature was incorporated).Triggers which are in the READY state are completely ignored.(READY should never be returned since the trigger paths have been run

fff_deleter.FileDeleter.make_report

def make_report

Definition: fff_deleter.py:146

def fff_deleter.FileDeleter.rename	(	self,
		f
	)

Definition at line 99 of file fff_deleter.py.

References ValidationMisalignedTracker.fake, and fff_deleter.FileDeleter.fake.

Referenced by fff_deleter.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_deleter.FileDeleter.rename

def rename

Definition: fff_deleter.py:99

fff_deleter.FileDeleter.fake

fake

Definition: fff_deleter.py:89

def fff_deleter.FileDeleter.run ( self )

Definition at line 192 of file fff_deleter.py.

References fff_deleter.cleanup_threshold(), fff_deleter.FileDeleter.delete(), fff_deleter.diskusage(), fff_deleter.FileDeleter.rename(), fff_deleter.FileDeleter.sequence, ConfigBuilder.ConfigBuilder.sequence, fff_deleter.FileDeleter.thresholds, and fff_deleter.FileDeleter.top.

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

 
     def run(self):
         self.sequence += 1
         if not os.path.isdir(self.top):
             log.warning("Directory %s does not exists.", self.top)
             return
 
         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_deleter.FileDeleter.sequence

sequence

Definition: fff_deleter.py:93

fff_deleter.FileDeleter.rename

def rename

Definition: fff_deleter.py:99

fff_deleter.FileDeleter.delete

def delete

Definition: fff_deleter.py:114

fff_deleter.diskusage

def diskusage

Definition: fff_deleter.py:72

fff_deleter.FileDeleter.run

def run

Definition: fff_deleter.py:192

fff_deleter.FileDeleter.thresholds

thresholds

Definition: fff_deleter.py:91

fff_deleter.cleanup_threshold

def cleanup_threshold

Definition: fff_deleter.py:54

fff_deleter.FileDeleter.top

top

Definition: fff_deleter.py:88

def fff_deleter.FileDeleter.send_smg	(	self,
		used_pc
	)

Definition at line 124 of file fff_deleter.py.

References fff_deleter.FileDeleter.email_to, fff_deleter.FileDeleter.hostname, fff_deleter.FileDeleter.last_email, and fff_deleter.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)