fff_deleter Namespace Reference

Classes
class	FileDeleter

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

Variables
tuple	deleter
tuple	flog_ch = logging.StreamHandler()
tuple	formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
tuple	log = logging.getLogger(__name__)
	log_capture = None
tuple	log_capture_ch = logging.StreamHandler(log_capture)
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/ramdisk"

Function Documentation

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

Definition at line 54 of file fff_deleter.py.

References iterate(), and AlCaHLTBitMon_ParallelJobs.p.

Referenced by fff_deleter.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)