module.py

Go to the documentation of this file.

#
# Collective Mind
#
# See cM LICENSE.txt for licensing details.
# See cM Copyright.txt for copyright details.
#
# Developer(s): (C) Grigori Fursin, started on 2011.09
#

# Should always be here
ini={}
cm_kernel=None

# Local settings
import json

# ============================================================================
def init(i):
    return {'cm_return':0}

# ============================================================================
def explore(i):

    """
    Explore a few points from mobile, cloud, etc 

    Input:  {
              predefined_uoa                     - data UOA with pre-defined input to compiler optimization scenario

              mobile_mode - 'build' or 'process' - mode during crowdsourcing auto-tuning using mobiles

              (system_info)                      - detected system info by the mobile/cloud/grid system

              (new_src_uoa)                      - new src UOA in tmp repository
              (measured_frequency)               - measured frequency (if supported)
              (execution_info)                   - list of list of execution times per binary - 1 coarse-grain exploration step
              (execution_info_min)               - list of minimal execution times per 1 coarse-grain exploration step
              (execution_info_ct_repeat_main)    - CT_REPEAT_MAIN got during calibration
              (built_files)                      - list of unique built files (with UIDs)
            }

    Output: {
              cm_return     - if =0, success

              (new_src_uoa) - if src were copied, new UID in tmp repo
            }

    """

    pi=i.get('predefined_uoa','')
    if pi=='':
       return {'cm_return':1, 'cm_error':'"predefined_uoa" is not defined'}

    mm=i.get('mobile_mode','')
    if mm=='':
       return {'cm_return':1, 'cm_error':'"mobile_mode" is not defined'}

    # Loading predefined input
    r=cm_kernel.access({'cm_run_module_uoa':ini['cm_module_uid'],
                         'cm_action':'load',
                         'cm_data_uoa':pi})
    if r['cm_return']>0: return r

    dpi=r['cm_data_obj']['cfg']

    api=dpi.get('predefined_input',{})
    if len(api)==0:
       return {'cm_return':1, 'cm_error':'"predefined_input" is not found in predefined entry'}

    system_info=i.get('system_info',{})
    if len(system_info)>0:
       api['system_info']=system_info

    api['mobile_mode']=mm
    if mm=='build':
       api['copy_built_executables']='yes'
       api['copy_src_to_tmp']='yes'
    elif mm=='report':
       new_src_uoa=i.get('new_src_uoa','')
       if new_src_uoa=='':
          return {'cm_return':1, 'cm_error':'"new_src_uoa" is not defined'}
       api['new_src_uoa']=new_src_uoa

       api['measured_frequency']=i.get('measured_frequency','')

       ei=i.get('execution_info',[])
       if len(ei)==0:
          return {'cm_return':1, 'cm_error':'"execution_info" is empty'}
       api['execution_info']=ei

       eim=i.get('execution_info_min',[])
       if len(ei)==0:
          return {'cm_return':1, 'cm_error':'"execution_info_min" is empty'}
       api['execution_info_min']=eim

       ct_repeat_main=i.get('execution_info_ct_repeat_main','')
       if ct_repeat_main=='':
          return {'cm_return':1, 'cm_error':'"execution_info_ct_repeat_main" is not defined'}
       api['execution_info_ct_repeat_main']=ct_repeat_main

       built_files=i.get('built_files',[])
       if len(built_files)==0:
          return {'cm_return':1, 'cm_error':'"built_files" is empty'}
       api['built_files']=built_files

       # Set recording to repository
       api['exploration_scenario']['save_results_in_repository']='yes'
       api['original_input']['#form_4df5b2509a4feabf_1##profitable_results_module']='e480890e45f8ad4f'

    # Run scenario
    api['cm_run_module_uoa']=ini['cfg']['cm_modules']['ctuning.pipeline.build_and_run_program']
    return cm_kernel.access(api)