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()
 

Referenced by CMSHadronPhysicsFTFP_BERT106.ExtraConfiguration().

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(), File.abort(), addFile(), addFilesWithFork(), METAnalyzer.analyze(), File.attach(), File.close(), ExternalLHEProducer.closeDescriptors(), CosmicGenFilterHelix.createHistsEnd(), CosmicGenFilterHelix.createHistsStart(), File.duplicate(), File.File(), File.flush(), WatcherStreamFileReader.getInputFile(), LocalCacheFile.LocalCacheFile(), gen::Py8InterfaceBase.makeTmpSLHA(), spu.md5_File(), File.open(), File.position(), File.prefetch(), TShapeAnalysis.printshapeData(), pps::RawDataUnpacker.processVFATDataParallel(), gen::Py8InterfaceBase.Py8InterfaceBase(), File.read(), File.resize(), gen::Pythia6Service.setSLHAFromHeader(), File.size(), File.sysclose(), File.sysduplicate(), and 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.