o2o Namespace Reference

Functions
def	get_iovs
def	get_tags
def	guess_condition_from_tag
def	make_popcon_config_file
def	run_popcon

Variables
string	base_dir = "."
list	condition_type = guessed_condition['condition_type']
string	dropbox_comment = 'generated by CaloOnlineTools/HcalOnlineDb/test/o2o.py script'
string	dropbox_destination_db = 'oracle://cms_orcon_prod/CMS_COND_31X_HCAL'
string	dropbox_dir = "./dropbox"
tuple	dropbox_file_name_prefix = str(output_dir)
tuple	dropbox_txt_file = open(dropbox_txt_file_name, "w")
tuple	dropbox_txt_file_name = str(dropbox_file_name_prefix)
tuple	gotten_iovs = get_iovs(tag, input_pool_connect_string, mode)
tuple	guessed_condition = guess_condition_from_tag(tag)
int	i = 0
string	input_pool_connect_string = "sqlite_file:/nfshome0/kukartse/hcal/dcs/HcalDcsValues_v1.00_offline.db"
tuple	iov = int(line)
list	isnewtag = gotten_iovs['newtag']
string	mode = 'online'
list	o2o_iovs = gotten_iovs['iovs']
string	o2o_tag_list_file = "o2o_tag_list.txt"
string	omds_accessor_string = "occi://CMS_HCL_APPUSER_R@anyhost/cms_omds_lb?PASSWORD=HCAL_Reader_44"
string	output_dir = "."
string	output_pool_connect_string = "sqlite_file:/nfshome0/kukartse/hcal/dcs/HcalDcsValues_v1.00_offline.db"
string	pool_auth_path = "/nfshome0/popcondev/conddb"
	pool_iov = iov
string	pool_logconnect = "sqlite_file:/nfshome0/kukartse/hcal/dcs/log.db"
list	pool_record = guessed_condition['pool_record']
string	python_popcon_file = "dbwrite_o2o.py"
string	python_popcon_template_file = "dbwrite_o2o_template.py"
tuple	query = query_file.read()
tuple	query_file = open(query_file_name, "r")
list	query_file_name = guessed_condition['query_file_name']
	query_save = query
tuple	run_result = run_popcon()
tuple	tag = tag_name.strip()
tuple	tags = get_tags(base_dir+"/"+o2o_tag_list_file)
string	use_dropbox = 'false'

Function Documentation

def o2o.get_iovs	(		tag,
			input_pool_connect_string,
			mode
	)

Definition at line 171 of file o2o.py.

References python.multivaluedict.append(), and communicate().

def get_iovs(tag, input_pool_connect_string, mode):
    result = "fail" # default
    newtag = False  # default
    # nominal mode of operations
    if mode == "online" or mode == "online_dropbox":
        try:
            iovs = subprocess.Popen(["./xmlToolsRun", "--list-iovs-for-o2o", "--tag-name", tag, "--pool-connect-string", input_pool_connect_string, "--pool-auth-path", pool_auth_path], stdout=subprocess.PIPE).communicate()[0]
            iov_list = iovs.splitlines()
            result = "success"
        except:
            print "ERROR: Cannot get the IOV update list for tag", tag+". This tag will not be updated. Now continue to the next tag..."
            iov_list=[]
            result = "fail"

    # script development mode, DB interfaces substituted with dummies
    if mode == "offline_development":
        #iovs = subprocess.Popen(["cat", tag+"_iov_to_update.devel"], stdout=subprocess.PIPE).communicate()[0]
        try:
            iov_list_file = open(base_dir+"/o2o/"+tag+"_iov_to_update.devel")
        except:
            print "ERROR: Cannot open file with the IOV list for tag", tag+". This tag will not be updated. Now continue to the next tag..."
            result = "fail"
        result = "success"
        iov_list = []
        for line in iov_list_file:
            iov_list . append(line.strip())
        iov_list_file.close()
    # now parse iov_list.
    # May contain various important output. Prefix defines the type of instruction.
    # IOVs start with O2O_IOV_LIST:
    # CONNECTION ERROR: indicates problems with connection to Pool and invalidates
    #                   the IOV list
    iovs=[]
    for line in iov_list:
        line_stripped = line.strip()
        if line.strip()[0:13] == "O2O_IOV_LIST:":
           iovs.append(line.lstrip("O2O_IOV_LIST:"))
        if line_stripped[0:line_stripped.find(":")] == "CONNECTION ERROR":
            result = "fail_connect"
        if line_stripped[0:line_stripped.find(":")] == "NEW_POOL_TAG_TRUE":
            newtag = True
    return {'iovs':iovs,
            'result':result,
            'newtag':newtag}