ztee Namespace Reference

Classes
class	GZipLog

Functions
def	capture (fd, args)
def	log (s)

Variables
	action
	args
	description
	fd
	help
	metavar
	parser
	str
	type

Function Documentation

capture()

def ztee.capture	(		fd,
			args
	)

Definition at line 94 of file ztee.py.

def capture(fd, args):
    log_handler = GZipLog(log_file=args.log)

    def sigusr1_handle(*kargs, **kwargs):
        log_handler._sigusr_interrupt = True
        if log_handler.file:
            log_handler.flush_block()

    signal.signal(signal.SIGUSR1, sigusr1_handle)

    try:
        while True:
            try:
                log_handler._sigusr_interrupt = False
                rlist, wlist, xlist = select.select([fd], [], [], 5)
            except select.error as e:
                if e[0] != errno.EINTR: raise
                if not log_handler._sigusr_interrupt: raise

                continue

            if not rlist:
                log_handler.handle_timeout()
                continue

            bytes = os.read(fd, 4096)
            if (bytes == ''):
                break

            log_handler.write(bytes)
            if not args.q:
                sys.stdout.write(bytes)
    finally:
        log_handler.finish()

log()

def ztee.log

(

s

)

Definition at line 9 of file ztee.py.

def log(s):
    sys.stderr.write("m: " + s + "\n");
    sys.stderr.flush()

Variable Documentation

action

ztee.action

Definition at line 131 of file ztee.py.

args

ztee.args

Definition at line 133 of file ztee.py.

description

ztee.description

Definition at line 130 of file ztee.py.

fd

ztee.fd

Definition at line 136 of file ztee.py.

Referenced by hcaldqm::DQTask._getCalibType(), addFile(), addFilesWithFork(), METAnalyzer.analyze(), ExternalLHEProducer.closeDescriptors(), CosmicGenFilterHelix.createHistsEnd(), CosmicGenFilterHelix.createHistsStart(), edm::storage::File.flush(), WatcherStreamFileReader.getInputFile(), edm::storage::LocalCacheFile.LocalCacheFile(), gen::Py8HMC3InterfaceBase.makeTmpSLHA(), gen::Py8InterfaceBase.makeTmpSLHA(), spu.md5_File(), edm::storage::File.position(), TShapeAnalysis.printshapeData(), pps::RawDataUnpacker.processVFATDataParallel(), gen::Py8HMC3InterfaceBase.Py8HMC3InterfaceBase(), gen::Py8InterfaceBase.Py8InterfaceBase(), edm::storage::File.read(), edm::storage::File.readv(), edm::storage::File.resize(), gen::Pythia6Service.setSLHAFromHeader(), edm::storage::File.size(), edm::storage::File.sysclose(), edm::storage::File.sysduplicate(), edm::storage::File.syswrite(), edm::storage::File.syswritev(), and edm::storage::File.write().

help

ztee.help

Definition at line 131 of file ztee.py.

metavar

ztee.metavar

Definition at line 132 of file ztee.py.

parser

ztee.parser

Definition at line 130 of file ztee.py.

str

ztee.str

Definition at line 132 of file ztee.py.

type

ztee.type

Definition at line 132 of file ztee.py.