fff_deletion Namespace Reference

Classes
class	FileDeleter

Functions
def	cleanup_threshold
def	daemon
def	diskusage
def	iterate
def	lock
def	parse_file_name

Variables
tuple	deleter
tuple	fake = not(len(sys.argv) > 1 and sys.argv[1] == "doit")
	log = logging
tuple	re_files = re.compile(r"^run(?P<run>\d+)/run(?P<runf>\d+)_ls(?P<ls>\d+)_.+\.(dat|raw)+(\.deleted)*")
tuple	sock = lock("fff_deleter")
dictionary	thresholds
string	top = "/fff.changeme/ramdisk"

Function Documentation

def fff_deletion.cleanup_threshold	(		top,
			threshold,
			action,
			string
	)

Definition at line 51 of file fff_deletion.py.

References iterate(), and AlCaHLTBitMon_ParallelJobs.p.

Referenced by fff_deletion.FileDeleter.run().

def cleanup_threshold(top, threshold, action, string):
    st = os.statvfs(top)
    total = st.f_blocks * st.f_frsize
    used = total - (st.f_bavail * st.f_frsize)
    threshold = used - float(total * threshold) / 100

    def p(x):
        return float(x) * 100 / total

    log.info("Using %d (%.02f%%) of %d space, %d (%.02f%%) above %s threshold.",
        used, p(used), total, threshold, p(threshold), string)

    if threshold > 0:
        iterate(top, threshold, action)
        log.info("Done cleaning up for %s threshold.", string)
    else:
        log.info("Threshold %s not reached, doing nothing.", string)