## -- Overview of all default local settings that one can change 
## -- The default values are also shown.

## ------------------------------------------- flags set in: RecExOnline_jobOptions.py  
isOnline          = True
isOnlineStateless = True

# for testing on lxplus
isOfflineTest     = False

#for the time being, running over file is not possible ONLINE (please see RecExOnline_File_Offline.py) 
useEmon           = True
## KeyCount value in the EMON service defined as 1-byte, i.e. the maximum allowed value is 255. 
keycount          = 150
buffersize        = 10
updateperiod      = 200
# timeout is in ms
timeout           = 600000

#keyname           = 'efd'   #AK: 21-05-2014
keyname           = 'dcm'

import os

partitionName     = os.environ.get("TDAQ_PARTITION", "ATLAS")
publishNumber     = os.environ.get("GLOBAL_JOB_NUMBER", "1")
publishName       = os.environ.get("TDAQ_APPLICATION_NAME", "GlobalMonitoring")

printfunc (publishName)
isserverName = 'Histogramming-Global-iss'  # Ak: 26-05-2014 - needed to write out the gathere hsitograms to the correct server

#streamName       = 'MinBias'
streamName        = 'express'
streamLogic       = 'Or'

# When using ATLAS partition
# Use different streams for "atlas standby" and "atlas ready"
#
if (partitionName == 'ATLAS'):
    streamLogic       = 'Or'
    
    import RecExOnline.OnlineISConfiguration
    import ispy
    from ispy import *
    from ipc import IPCPartition
    from ispy import ISObject

    obj = ispy.ISObject(ispy.IPCPartition(partitionName), 'RunParams.RunParams', 'RunParams')
    obj.checkout()
    ### if ( obj.T0_project_tag == 'data15_comm' or obj.T0_project_tag == 'data15_13TeV'):
    if ( obj.T0_project_tag == 'data15_comm' or obj.T0_project_tag == 'data15_13TeV' or obj.T0_project_tag == 'data15_5TeV' or obj.T0_project_tag == 'data16_comm' or obj.T0_project_tag == 'data16_13TeV' or obj.T0_project_tag == 'data16_5TeV' or obj.T0_project_tag == 'data16_1beam' or obj.T0_project_tag == 'data16_hip'):
        #streamName        = 'MinBias'
        #streamName        = 'Main' # Switching due to missingg Minbias stream -= 13/06/2015 AK
        try:
            if RecExOnline.OnlineISConfiguration.GetAtlasReady():
                printfunc ("ATLAS READY, reading express stream")
                streamName = 'express'
            else:
                printfunc ("ATLAS NOT READY, reading standby stream")
                ### streamName = 'standby'
                ### streamName = 'physics_Standby'
                streamName = 'Standby'
        except:
            streamName = 'express'
    else:
        streamName        = 'express:IDCosmic:HLT_IDCosmic:CosmicMuons:MinBias'
else:
    streamLogic       = 'Ignore'
    #projectName       = 'data13_hip'


is_T0_project_tag = 'data13_hip'

#
# When NOT using ATLAS partition
#
if (partitionName != 'ATLAS'):
    publishName     = 'YJ_GM_data13_hip_HI_tri_noprtag_HIMON'
    isserverName    = 'Histogramming'


printfunc ("GlobalMonitoring : streamName streamLogic= ",streamName,streamLogic)
printfunc ("publishName      : ",publishName)


#import time
#myfloat = float(publishNumber)
#tosleep = myfloat*5
#time.sleep(tosleep)

from future import standard_library
standard_library.install_aliases()
import subprocess
pids=subprocess.getoutput("/sbin/pidof -o %u python" % os.getpid()).split(" ")
printfunc ("pids",pids)

for pid in pids:
  printfunc ("pid",pid)
  #if (False):
  #if (1):
  if (0):
    printfunc ("pid = ",pid)
    #thisnumber=subprocess.getoutput("grep GLOBAL_JOB_NUMBER /proc/%u/fd/1 -m 1 | cut -f2 -d'='" % int(pid))
    thisname=subprocess.getoutput("grep TDAQ_APPLICATION_NAME /proc/%u/fd/1 -m 1 | cut -f2 -d'='" % int(pid))
    printfunc ("thisname = ",thisname)
    printfunc ("publishName = ",publishName)
    if (thisname == publishName):
      printfunc ("found a match! Will Kill pid = ",pid)
      killreturn = subprocess.getoutput("kill %u" % int(pid))


useAtlantisEmon   = False

### evtMax            = -1
### evtMax            = 50

if (partitionName == 'ATLAS'):
    evtMax            = -1

if (partitionName != 'ATLAS'):
    # evtMax            = 200
    evtMax            = 30


## ------------------------------------------- flags set in: RecExOnline_emonsvc.py (from RecExOnline_jobOptions.py)                    

isGlobalMonitoring = True

## ------------------------------------------- flags set in: RecExOnline_globalconfig.py  (from RecExOnline_jobOptions.py)
#read the pickle file if you want to use the AMI tag info
#stored in ami_recotrf.pickle (produced by 'tct_getAmiTag.py f140 ami_recotrf.cmdargs ami_recotrf.pickle') 
usePickleConfig   = False
pickleconfigfile  = './ami_recotrf.pickle'
DataSource        = 'data'
InputFormat       = 'bytestream'
fileName          = './0.data'
#beamType          = 'cosmics'  
beamType          = 'collisions'  #AK: 21-05-2014

#COND tag and GEO are needed for running over a test partition online
### test run1
#ConditionsTag     = 'COMCOND-HLTP-004-03'
#DetDescrVersion   = 'ATLAS-GEO-20-00-01'

ConditionsTag     = 'CONDBR2-HLTP-2016-01' # 2016-02-05 Based on CONDBR2-HLTP-2015-08, for M11.
###ConditionsTag     = 'CONDBR2-HLTP-2015-08' # 20160317
### ConditionsTag     = 'CONDBR2-HLTP-2015-07'   # created 2015-08-10
### ConditionsTag     = 'CONDBR2-HLTP-2015-05'
### ConditionsTag     = 'CONDBR2-HLTP-2015-04'
### ConditionsTag     = 'CONDBR2-HLTP-2015-01'
### ConditionsTag     = 'CONDBR2-ES1PA-2014-01'  ### new for offline (19.3.0.1)

### DetDescrVersion   = 'ATLAS-R2-2015-01-01-00'
### DetDescrVersion   = 'ATLAS-R2-2015-02-00-00'  ### new for offline (19.3.0.1)
DetDescrVersion   = 'ATLAS-R2-2015-03-01-00'  ### new for offline (19.3.0.1)


doESD             = True
writeESD          = False
doAOD             = False
writeAOD          = False
IOVDbSvcMessage   = False

## ------------------------------------------ flags set in: RecExOnline_recoflags.py (from RecExOnline_jobOptions.py)
doAllReco   = True

doInDet     = doAllReco
### doInDet     = False

doMuon      = doAllReco
###doMuon      = False

doLArg      = doAllReco
doTile      = doAllReco

doTrigger   = doAllReco
#doTrigger   = False

doHist      = doAllReco
doJiveXML   = False

doEgammaTau = doAllReco
### doEgammaTau = False

doHIRec     = doAllReco
### doHIRec     = False

#set to True in the JO
#doCommissioning = False

## ------------------------------------------ flags set in : RecExOnline_monitoring.py (from from RecExOnline_jobOptions.py)
doAllMon  = True

doCaloMon = doAllMon

doTileMon = doAllMon #AK: new since 09 july 2014 (M4)
# doTileMon = False

doPhysMon = doAllMon

doTrigMon = doAllMon
#doTrigMon = False

doIDMon   = doAllMon
###doIDMon   = False

doTRTMon  = doAllMon
###doTRTMon  = False

doMuonMon = doAllMon
### doMuonMon = False

doCTPMon  = False #doAllMon #AK: 25-01-2014

doHIMon   = doAllMon
### doHIMon   = False # doAllMon

## ------------------------------------------ flags set in : RecExOnline_postconfig.py    (called from RecExOnline_jobOptions.py)

from AthenaCommon.GlobalFlags import globalflags
globalflags.DatabaseInstance.set_Value_and_Lock("CONDBR2")
#globalflags.DatabaseInstance.set_Value_and_Lock("COMP200")

from AthenaCommon.BFieldFlags import jobproperties
jobproperties.BField.barrelToroidOn.set_Value_and_Lock(True)
jobproperties.BField.endcapToroidOn.set_Value_and_Lock(True)
jobproperties.BField.solenoidOn.set_Value_and_Lock(True)
###jobproperties.BField.solenoidOn.set_Value_and_Lock(False)


from CaloRec.CaloCellFlags import jobproperties
jobproperties.CaloCellFlags.doLArHVCorr.set_Value_and_Lock(False)
jobproperties.CaloCellFlags.doPileupOffsetBCIDCorr.set_Value_and_Lock(False)
jobproperties.CaloCellFlags.doLArDeadOTXCorr.set_Value_and_Lock(False)  ####? for trigger, added 11th March, 2015, by CY


from InDetRecExample.InDetJobProperties import InDetFlags
InDetFlags.doInnerDetectorCommissioning.set_Value_and_Lock(True)
InDetFlags.useBroadClusterErrors.set_Value_and_Lock(False)

from AthenaMonitoring.DQMonFlags import DQMonFlags
DQMonFlags.doStreamAwareMon.set_Value_and_Lock(False)
DQMonFlags.enableLumiAccess.set_Value_and_Lock(False)
DQMonFlags.doCTPMon.set_Value_and_Lock(False)         
DQMonFlags.doLVL1CaloMon.set_Value_and_Lock(False)    
### DQMonFlags.doMuonTrkPhysMon.set_Value_and_Lock(False) #xx
DQMonFlags.doMuonTrkPhysMon.set_Value_and_Lock(True) #xx
### DQMonFlags.doJetTagMon.set_Value_and_Lock(False)
#printfunc ("#### yunju Here is DQMonFlags.monManEnvironment:"+DQMonFlags.monManEnvironment)
## for egmma monitoring in lxplus
#DQMonFlags.monManEnvironment.set_Value_and_Lock('tier0')

from RecExConfig.RecFlags import rec
rec.doBTagging.set_Value_and_Lock(True)
rec.doHIP.set_Value_and_Lock(True)

from JetRec.JetRecFlags import jetFlags
jetFlags.useBTagging.set_Value_and_Lock(True)

### from JetRec.JetRecFlags import jetFlags
### jetFlags.useTracks.set_Value_and_Lock(False)

from MuonDQAMonFlags.MuonDQAProperFlags import MuonDQADetFlags
### MuonDQADetFlags.doMDTTGCL1Mon.set_Value_and_Lock(True)
MuonDQADetFlags.doTGCL1Mon.set_Value_and_Lock(True)
MuonDQADetFlags.doTGCMon.set_Value_and_Lock(True)


##---------------------------------------ID suggestion from Alex 18.Feb.2015  --------
jobproperties.InDetJobProperties.doTrackSegmentsSCT.set_Value_and_Lock(False)
jobproperties.InDetJobProperties.doTrackSegmentsPixel.set_Value_and_Lock(False)
jobproperties.InDetJobProperties.doTrackSegmentsTRT.set_Value_and_Lock(False)


##---------------------------------------Bunch Spacing 25ns  --------
from InDetRecExample.InDetJobProperties import InDetFlags
InDetFlags.InDet25nsec.set_Value_and_Lock(True)

jobproperties.Beam.bunchSpacing.set_Value_and_Lock(25)

# --------------------------------------------- Monitoring
### replaced by MuonTrackMonitoring (SMW Jan 23 2016)
### from AthenaMonitoring.DQMonFlags import DQMonFlags
### DQMonFlags.doMuonPhysicsMon.set_Value_and_Lock(True)


### ------------------- inherited from 20.1.0.2 -----------
#from RecExConfig.RecFlags import rec
#rec.doJetMissingETTag.set_Value_and_Lock(False)


#from TrigHLTMonitoring.HLTMonFlags import HLTMonFlags
#HLTMonFlags.doBphys=False


#jobproperties.CaloCellFlags.doLArDeadOTXCorr.set_Value_and_Lock(False)

#from LArConditionsCommon.LArCondFlags import larCondFlags
#larCondFlags.OFCShapeFolder.set_Value_and_Lock("")

## main online reco scripts
include ("RecExOnline/RecExOnline_jobOptions.py")

include ("HIRecExample/hip_outputPostExec.py")