ConditionsExample.cpp

//==========================================================================
//  AIDA Detector description implementation 
//--------------------------------------------------------------------------
// Copyright (C) Organisation europeenne pour la Recherche nucleaire (CERN)
// All rights reserved.
//
// For the licensing terms see $DD4hepINSTALL/LICENSE.
// For the list of contributors see $DD4hepINSTALL/doc/CREDITS.
//
// Author     : M.Frank
//
//==========================================================================
#if 0
// Framework include files
#include "ConditionsTest.h"

using namespace std;
using namespace dd4hep;
using namespace dd4hep::cond;

namespace  {

  typedef ConditionKey _Key;

  void print_tpc_epoch_conditions(Test::TestEnv& env, const IOV& iov_epoch, bool check = true)   {
    DetConditions dc(env.detector);
    ConditionsAccess access(env.manager);
    Condition cond = access.get(_Key(env.detector,"AmbientTemperature"),iov_epoch);
    Test::print_condition<void>(cond);
    cond = dc.get("AmbientTemperature",iov_epoch);
    if ( check ) Test::check_discrete_condition(cond, iov_epoch);
    Test::print_condition<void>(cond);
    cond = dc.get("ExternalPressure",iov_epoch);
    if ( check ) Test::check_discrete_condition(cond, iov_epoch);
    Test::print_condition<void>(cond);
    cond = dc.get("SomeMultiParams",iov_epoch);
    if ( check ) Test::check_discrete_condition(cond, iov_epoch);
    Test::print_condition<void>(cond);
    cond->value = "[5,6,7,8,9,10,11,12,13,14]";
    cond.rebind();
    Test::print_condition<void>(cond);
  }
  void print_tpc_run_conditions(Test::TestEnv& env, const IOV& iov_run, bool check = true)   {
    DetConditions dc(env.detector);
    Condition cond = dc.get("alignment",iov_run);
    if ( check ) Test::check_discrete_condition(cond, iov_run);
    Test::print_condition<void>(cond);
    cond = dc.get("TPC_A_align",iov_run);
    if ( check ) Test::check_discrete_condition(cond, iov_run);
    Test::print_condition<void>(cond);
    cond = DetConditions(env.daughter("TPC_SideA")).get("alignment",iov_run);
    if ( check ) Test::check_discrete_condition(cond, iov_run);
    Test::print_condition<void>(cond);
  }
  void print_tpc_discrete_conditions(Test::TestEnv& env, const IOV& iov_epoch, const IOV& iov_run)   {
    print_tpc_epoch_conditions(env, iov_epoch);
    printout(INFO,"Example","SUCCESS: +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
    printout(INFO,"Example","SUCCESS: +++ Conditions access OK for iov:%s!",iov_epoch.str().c_str());
    printout(INFO,"Example","SUCCESS: +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
    print_tpc_run_conditions(env, iov_run);
    printout(INFO,"Example","SUCCESS: +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
    printout(INFO,"Example","SUCCESS: +++ DISCRETE Conditions access OK for iov:%s!",iov_run.str().c_str());
    printout(INFO,"Example","SUCCESS: +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
  }

  void print_tpc_discrete_conditions(Test::TestEnv& env, int epoch_min, int epoch_max, int run_min, int run_max)   {
    dd4hep_ptr<UserPool> pool_run, pool_epoch;
    IOV iov_epoch(env.epoch), iov_run(env.run);
    iov_epoch.set(epoch_min, epoch_max);
    iov_run.set(run_min, run_max);

    env.manager.prepare(iov_run, pool_run);
    env.manager.prepare(iov_epoch, pool_epoch);
    print_tpc_discrete_conditions(env, iov_epoch, iov_run);
  }

  void print_tpc_discrete_conditions(Test::TestEnv& env)   {
    print_tpc_discrete_conditions(env, 1396887257, 1396887257, 563543, 563543);
    print_tpc_discrete_conditions(env, 1396887257, 1396887257, 234567, 234567);
    print_tpc_discrete_conditions(env, 1396887257, 1396887257, 563543, 563543);
  }

  void print_tpc_range_conditions(Test::TestEnv& env, int run_min, int run_max)   {
    RangeConditions cond;
    IOV iov_run(env.run);
    iov_run.set(run_min, run_max);
    try {
      ConditionsAccess access(env.manager);
      cond = access.getRange(_Key(env.detector,"TPC_A_align"),iov_run);
      Test::print_conditions<void>(cond);
      printout(INFO,"Example","SUCCESS: +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
      printout(INFO,"Example","SUCCESS: +++ RANGE Conditions access OK for iov:%s!",iov_run.str().c_str());
      printout(INFO,"Example","SUCCESS: +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
    }
    catch(const std::exception& e)   {
      printout(INFO,"Example","FAILED:  +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
      printout(INFO,"Example","FAILED:  +++ RANGE Conditions access FAILED for iov:%s!",iov_run.str().c_str());
      printout(INFO,"Example","FAILED:  +++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
    }
  }

  int example1(Detector& description, int, char** )  {
    printout(INFO,"Example1","+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
    printout(INFO,"Example1","+++ Executing Conditions example No. 1: Test conditions access.    ");
    printout(INFO,"Example1","+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
    Test::TestEnv env(description, "TPC");

    env.add_xml_data_source("/examples/Conditions/xml/TPC.xml","1396887257,1396887257#epoch");
    env.add_xml_data_source("/examples/Conditions/xml/TPC_run_563543.xml","563543#run");
    env.add_xml_data_source("/examples/Conditions/xml/TPC_run_234567.xml","234567#run");
    print_tpc_discrete_conditions(env);
    description.apply("DD4hep_ConditionsDump",0,0);

    print_tpc_range_conditions(env,234567,563543);  // Should fail !
    print_tpc_range_conditions(env,123456,563543);  // Should fail !

    env.add_xml_data_source("/examples/Conditions/xml/TPC_run_filler.xml","0,999999#run");
    env.add_xml_data_source("/examples/Conditions/xml/TPC_run_123456.xml","123456#run");
    print_tpc_range_conditions(env,123456,900000);  // Now it should succeed
    return 1;
  }

  int example2(Detector& description, int argc, char** argv)  {
    printout(INFO,"Example2","+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
    printout(INFO,"Example2","+++ Executing Conditions example No. 2: Dump conditions tree.      ");
    printout(INFO,"Example2","+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
    DetElement det = description.world();
    string args = "";
    for(int i=0; i<argc; ++i) { args += argv[i], args += " "; };
    printout(INFO,"Example2","Args: %s",args.c_str());
    Test::TestEnv::dump_conditions_tree(det);
    return 1;
  }

  int example3(Detector& description, int, char** )  {
    printout(INFO,"Example1","+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
    printout(INFO,"Example1","+++ Executing Conditions example No. 3: Conditions registration    ");
    printout(INFO,"Example1","+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
    Test::TestEnv env(description, "TPC");
    
    env.add_xml_data_source("/examples/Conditions/xml/TPC.xml","1396887257,1396887257#epoch");
    env.add_xml_data_source("/examples/Conditions/xml/TPC_run_563543.xml","563543#run");
    env.add_xml_data_source("/examples/Conditions/xml/TPC_run_234567.xml","234567#run");
    env.add_xml_data_source("/examples/Conditions/xml/TPC_run_filler.xml","0,999999#run");
    env.add_xml_data_source("/examples/Conditions/xml/TPC_run_123456.xml","123456#run");

    
    IOV iov_epoch(env.epoch), iov_run(env.run);
    dd4hep_ptr<UserPool> pool_run, pool_epoch;
    iov_epoch.set(1396887257);
    iov_run.set(563543);

    env.manager.prepare(iov_run, pool_run);
    env.manager.prepare(iov_epoch, pool_epoch);
    print_tpc_epoch_conditions(env, iov_epoch);
    print_tpc_run_conditions(env, iov_run, true);
    printout(INFO,"Example1","===================================================================");

    printout(INFO,"Example1","===================================================================");
    iov_run.set(123456);
    env.manager.prepare(iov_run, pool_run);
    iov_run.set(563543);
    print_tpc_run_conditions(env, iov_run, false);
    printout(INFO,"Example1","===================================================================");

    printout(INFO,"Example1","===================================================================");
    iov_run.set(123456);
    print_tpc_run_conditions(env, iov_run, true);
    return 1;
  }

  struct Callee  {
    int m_param;
    Callee() : m_param(0) {}
    void call(unsigned long tags, DetElement& det, void* param)    {
      if ( (tags&DetElement::CONDITIONS_CHANGED) )
        printout(INFO,"Callee","+++ Conditions update %s param:%p",det.path().c_str(),param);
      if ( (tags&DetElement::PLACEMENT_CHANGED) )  
        printout(INFO,"Callee","+++ Alignment update %s param:%p",det.path().c_str(),param);
    }
  };

  /// Callback conditions tree of a detector element
  void callback_install(DetElement elt, Callee* c) {
    Position local, global;
    const DetElement::Children& children = elt.children();
    elt.localToWorld(local, global);
    elt.callAtUpdate(DetElement::CONDITIONS_CHANGED|DetElement::PLACEMENT_CHANGED,c,&Callee::call);
    for(DetElement::Children::const_iterator j=children.begin(); j!=children.end(); ++j)
      callback_install((*j).second,c);
  }

  int dd4hep_CallbackInstallTest(Detector& description, int argc, char** argv)  {
    printout(INFO,"Example3","+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
    printout(INFO,"Example3","+++ Executing dd4hepCallbackInstallTest: Install user callbacks.   ");
    printout(INFO,"Example3","+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++");
    string args = "";
    for(int i=0; i<argc; ++i) { args += argv[i], args += " "; };
    printout(INFO,"Example3","Args: %s",args.c_str());
    DetElement det = description.world();
    callback_install(det, new Callee());
    return 1;
  }
}


DECLARE_APPLY(DD4hep_Test_ConditionsAccess,example1)
DECLARE_APPLY(DD4hep_Test_ConditionsExample3,example3)
DECLARE_APPLY(DD4hep_Test_ConditionsTreeDump,example2)
DECLARE_APPLY(DD4hep_Test_CallbackInstall,dd4hep_CallbackInstallTest)
#endif