Reference Manual

def dqm-mbProfile.find_and_write_html	(	p,
		args
	)

Definition at line 244 of file dqm-mbProfile.py.

 
 def find_and_write_html(p, args):
     # create the dir if necessary
     if p and not os.path.exists(p):
         os.makedirs(p)
 
     html_paths = [
         os.path.join(os.getenv("CMSSW_RELEASE_BASE"), "src/DQMServices/Components/data/html"),
         os.path.join(os.getenv("CMSSW_BASE"),"src/DQMServices/Components/data/html"),
     ]
 
     def find_file(f):
         fails = []
         for p in html_paths:
             x = os.path.join(p, f)
             if os.path.exists(x):
                 return x
             else:
                 fails.append(x)
 
         log.warning("Could not find html file: %s (%s)", f, fails)
 
     for f in ['mbGraph.js', 'mbGraph.html']:
         target_fn = os.path.join(p, f)
         source_fn = find_file(f)
         if source_fn:
             log.info("Copying %s to %s", source_fn, target_fn)
             shutil.copyfile(source_fn, target_fn)

dqm-mbProfile.find_and_write_html

def find_and_write_html

Definition: dqm-mbProfile.py:244

def dqm-mbProfile.get_children ( ppid )

Select all processes which are descendant from ppid (exclusive).

Definition at line 65 of file dqm-mbProfile.py.

References bitset_utilities.append(), build_process_list(), and list().

Referenced by dqm-mbProfile.Profile.update_proc().

 
 def get_children(ppid):
     """ Select all processes which are descendant from ppid (exclusive). """
 
     pid_dct = {}
     for proc in build_process_list():
         proc["_children"] = []
         pid_dct[proc["pid"]] = proc
 
     # fill in children array
     for pid in list(pid_dct.keys()):
         parent_pid = pid_dct[pid]["parent_pid"]
 
         if pid_dct.has_key(parent_pid):
             pid_dct[parent_pid]["_children"].append(pid)
 
     # now just walk down the tree
     if ppid is None or not pid_dct.has_key(ppid):
         # process has quit, we exit
         return []
 
     accepted = []
     to_accept = collections.deque([ppid, ])
     
     while to_accept:
         head = pid_dct[to_accept.popleft()]
 
         # do not include the monitoring pid
         if head["pid"] != ppid:
             accepted.append(head)
 
         to_accept.extend(head.get("_children", []))
         head["children"] = head["_children"]
         del head["_children"]
 
         # deleting children breaks infinite loops
         # but Dima, can a process tree contain a loop? yes - via race-condition in reading procfs
 
     return accepted

dqm-mbProfile.build_process_list

def build_process_list

Definition: dqm-mbProfile.py:56

bitset_utilities::append

boost::dynamic_bitset append(const boost::dynamic_bitset<> &bs1, const boost::dynamic_bitset<> &bs2)

this method takes two bitsets bs1 and bs2 and returns result of bs2 appended to the end of bs1 ...

Definition: bitset_append.cc:10

dqm-mbProfile.get_children

def get_children

Definition: dqm-mbProfile.py:65

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

def dqm-mbProfile.handle_alarm	(	num,
		frame
	)

Definition at line 223 of file dqm-mbProfile.py.

 
 def handle_alarm(num, frame):
     if ALARM_P_OBJECT:
         ALARM_P_OBJECT.update()
 
     signal.alarm(ALARM_TIMER)

dqm-mbProfile.handle_alarm

def handle_alarm

Definition: dqm-mbProfile.py:223

def dqm-mbProfile.read_procfs	(	ppath,
		only_ppid = `True`
	)

Definition at line 20 of file dqm-mbProfile.py.

References SiPixelLorentzAngle_cfi.read, and python.rootplot.root2matplotlib.replace().

Referenced by build_process_list().

 
 def read_procfs(ppath, only_ppid=True):
     def read(f):
         fp = os.path.join(ppath, f)
         with open(fp) as fd:
             return fd.read()
 
     def read_status():
         st = {}
 
         fp = os.path.join(ppath, "status")
         with open(fp) as fd:
             for line in fd.readlines():
                 if not line: continue
 
                 key, value = line.split(":", 1)
                 st[key] = value.strip()
 
         return st
 
     try:
         dct = {}
 
         dct["statm"] = read("statm").strip()
         dct["stat"] = read("stat").strip()
         dct["cmdline"] = read("cmdline").strip().replace("\0", " ")
 
         status = read_status()
         dct["status"] = status
         dct["pid"] = int(status["Pid"])
         dct["parent_pid"] = int(status["PPid"])
 
         return dct
     except:
         log.warning("Exception in read_procfs.", exc_info=True)
         pass

python.rootplot.root2matplotlib.replace

def replace

Definition: root2matplotlib.py:443

dqm-mbProfile.read_procfs

def read_procfs

Definition: dqm-mbProfile.py:20

SiPixelLorentzAngle_cfi.read

tuple read

Definition: SiPixelLorentzAngle_cfi.py:7

def dqm-mbProfile.run_and_monitor ( args )

Definition at line 229 of file dqm-mbProfile.py.

 
 def run_and_monitor(args):
     profile = Profile(args)
 
     proc = subprocess.Popen(args.pargs)
     profile.pid = proc.pid
 
     global ALARM_P_OBJECT
     ALARM_P_OBJECT = profile
 
     signal.signal(signal.SIGALRM, handle_alarm)
     signal.alarm(ALARM_TIMER)
 
     proc.wait()
     profile.finish()

dqm-mbProfile.run_and_monitor

def run_and_monitor

Definition: dqm-mbProfile.py:229

dqm-mbProfile.Profile

Definition: dqm-mbProfile.py:104

dqm-mbProfile.ALARM_P_OBJECT = None

Definition at line 221 of file dqm-mbProfile.py.

dqm-mbProfile.ALARM_TIMER = 1

Definition at line 220 of file dqm-mbProfile.py.

tuple dqm-mbProfile.args = parser.parse_args()

Definition at line 280 of file dqm-mbProfile.py.

tuple dqm-mbProfile.log = logging.getLogger("mbProfile")

Definition at line 17 of file dqm-mbProfile.py.

string dqm-mbProfile.LOG_FORMAT = '%(asctime)s: %(name)-20s - %(levelname)-8s - %(message)s'

Definition at line 15 of file dqm-mbProfile.py.

tuple dqm-mbProfile.p = os.path.dirname(args.file)

Definition at line 295 of file dqm-mbProfile.py.

tuple dqm-mbProfile.parser = argparse.ArgumentParser(description="Profile child processes and produce data for rss and such graphs.")

Definition at line 273 of file dqm-mbProfile.py.

Classes

Functions

Variables

Function Documentation

Variable Documentation

Functions
def	build_process_list

def	find_and_write_html

def	get_children

def	handle_alarm

def	read_procfs

def	run_and_monitor

Variables
	ALARM_P_OBJECT = None

int	ALARM_TIMER = 1

tuple	args = parser.parse_args()

tuple	log = logging.getLogger("mbProfile")

string	LOG_FORMAT = '%(asctime)s: %(name)-20s - %(levelname)-8s - %(message)s'

tuple	p = os.path.dirname(args.file)

tuple	parser = argparse.ArgumentParser(description="Profile child processes and produce data for rss and such graphs.")

Classes
class	Profile