pmu-query.py

#!/usr/bin/python
import urllib2
import json, csv
import subprocess
import sys
import platform
import getopt

all_flag = False
download_flag = False
filename=None
offcore_events=[]
core_events=[]

try:
    opts, args = getopt.getopt(sys.argv[1:],'a,f:,d',['all','file=','download'])
    for o, a in opts:
        if o in ('-a','--all'):
            all_flag=True
        if o in ('-f','--file'):
            filename=a
        if o in ('-d','--download'):
            download_flag=True
except getopt.GetoptError, err:
    print("parse error: %s\n" %(str(err)))
    exit(-2)

if filename == None:
    map_file_raw=urllib2.urlopen('https://download.01.org/perfmon/mapfile.csv')
    map_dict = csv.DictReader(map_file_raw)
    map_file = []
    core_path = ''
    offcore_path = ''

    while True:
        try:
            map_file.append(map_dict.next())
        except StopIteration:
            break

    if platform.system() == 'CYGWIN_NT-6.1':
        p = subprocess.Popen(['./pcm-core.exe -c'],stdout=subprocess.PIPE,shell=True) 
    elif platform.system() == 'Windows':
        p = subprocess.Popen(['pcm-core.exe -c'],stdout=subprocess.PIPE,shell=True)
    else:
        p = subprocess.Popen(['./pcm-core.x -c'],stdout=subprocess.PIPE,shell=True)

    (output, err) = p.communicate()
    p_status = p.wait()
    for model in map_file:
        if model['Family-model'] in output:
            if(model['EventType'] == 'core'):
                core_path = model['Filename']
            elif(model['EventType'] == 'offcore'):
                offcore_path = model['Filename']
            print (model)

    if core_path != '':
        json_core_data=urllib2.urlopen('https://download.01.org/perfmon'+core_path)
        core_events=json.load(json_core_data)
        if(download_flag == True):
            with open(core_path.split('/')[-1],'w') as outfile:
                json.dump(core_events, outfile, sort_keys=True, indent=4)
    else:
        print ('no core event found for %s CPU, program abort...' % (output))
        exit(-1)

    if offcore_path != '':
        json_offcore_data=urllib2.urlopen('https://download.01.org/perfmon'+offcore_path)
        offcore_events=json.load(json_offcore_data)
        if(download_flag == True):
            with open(offcore_path.split('/')[-1],'w') as outfile:
                json.dump(offcore_events, outfile, sort_keys=True, indent=4)
else:
    for f in filename.split(','):
        print f
        core_events.extend(json.load(open(f)))

if all_flag == True:
    for event in core_events+offcore_events:
        if event.has_key('EventName') and event.has_key('BriefDescription'):
            print (event['EventName']+':'+event['BriefDescription'])
    sys.exit(0) 

name=raw_input("Event to query (empty enter to quit):")
while(name != ''):
    for event in core_events+offcore_events:
        if event.has_key('EventName') and name.lower() in event['EventName'].lower():
            print (event['EventName']+':'+event['BriefDescription'])
            for ev_code in event['EventCode'].split(', '):
                print ('cpu/umask=%s,event=%s,name=%s%s%s%s%s%s/' % (
                        event['UMask'], ev_code, event['EventName'],
                        (',offcore_rsp=%s' % (event['MSRValue'])) if event['MSRValue'] != '0' else '',
                        (',inv=%s' % (event['Invert'])) if event['Invert'] != '0' else '',
                        (',any=%s' % (event['AnyThread'])) if event['AnyThread'] != '0' else '',
                        (',edge=%s'% (event['EdgeDetect'])) if event['EdgeDetect'] != '0' else '',
                        (',cmask=%s' % (event['CounterMask'])) if event['CounterMask'] != '0' else ''))
    name=raw_input("Event to query (empty enter to quit):")