BesVisAlg Class Reference

#include <BesVisAlg.h>

Inheritance diagram for BesVisAlg:

Public Member Functions
	BesVisAlg (const std::string &name, ISvcLocator *pSvcLocator)
	~BesVisAlg ()
StatusCode	initialize ()
StatusCode	execute ()
StatusCode	finalize ()

Detailed Description

Definition at line 187 of file BesVisAlg.h.

Constructor & Destructor Documentation

BesVisAlg()

BesVisAlg::BesVisAlg	(	const std::string &	name,
		ISvcLocator *	pSvcLocator )

Definition at line 21 of file BesVisAlg.cxx.

    : Algorithm( name, pSvcLocator ) {
  // Part 1: Declare the properties
  declareProperty( "TestVec", testVec );
  declareProperty( "OutputShareFile", f_rootOutputFile );
  declareProperty( "InputGeometryFile", f_geoInputFile );
  declareProperty( "DisplayMode", m_mode = 0 ); // offline mode: 0 online mode:1
  // Part 2: Define some semaphore operate flag
  // semaphore start_value
  start_val[0] = 1; // free-space = 1
  start_val[1] = 0; // output-shore = 0
 
  // acquire semaphore, decrease resource supply
  acquire.sem_num = 0;
  acquire.sem_op  = -1;
  acquire.sem_flg = SEM_UNDO;
 
  // release semaphore, increase resource supply
  release.sem_num = 0;
  release.sem_op  = 1;
  release.sem_flg = SEM_UNDO;
 
  recdis    = NULL;
  recTrack1 = NULL;
  mdchit    = NULL;
  tofTrack  = NULL;
  muctrk    = NULL;
}

Referenced by BesVisAlg().

~BesVisAlg()

BesVisAlg::~BesVisAlg

(

)

Definition at line 51 of file BesVisAlg.cxx.

                      {
  // Part 1: Get the messaging service, print where you are
  MsgStream log( msgSvc(), name() );
  log << MSG::INFO << " BesVisAlg ~BesVisAlg()" << endmsg;
 
  // Part 2: Delete semaphore
  // if (semctl(semid, 0, IPC_RMID, 0) == -1)
  //    log << MSG::ERROR << "Delete semaphore" << endmsg;
  // else
  //    log << MSG::INFO <<  "Delete semaphore" << endmsg;
 
  // Part 3: Delete temp file
  // if (remove(BUFFER) == -1)
  //    log << MSG::ERROR << "delete -- temp file" << endmsg;
  // else
  //    log << MSG::INFO << "Delete temp file" << endmsg;
}

Member Function Documentation

execute()

StatusCode BesVisAlg::execute

(

)

Definition at line 168 of file BesVisAlg.cxx.

                              {
 
  // Part 1: Get the messaging service, print where you are
  MsgStream log( msgSvc(), name() );
  log << MSG::INFO << "BesVisAlg execute()" << endmsg;
 
  // Part 2: Producer execute
  const char* msg_sleep = testVec[0].c_str();
  producer( atoi( msg_sleep ) );
 
  return StatusCode::SUCCESS;
}

finalize()

StatusCode BesVisAlg::finalize

(

)

Definition at line 183 of file BesVisAlg.cxx.

                               {
 
  // Part 1: Get the messaging service, print where you are
  MsgStream log( msgSvc(), name() );
  log << MSG::INFO << "BesVisAlg finalize()" << endmsg;
 
  // Part 2: Waiting consumer process accessing the data
  // and then kill it
  while ( 1 )
  {
    if ( hasRead() ) break;
    else sleep( 5 );
  }
 
  // Part 3: Delete semaphore
  if ( semctl( semid, 0, IPC_RMID, 0 ) == -1 )
    log << MSG::ERROR << "Delete semaphore" << endmsg;
  else log << MSG::INFO << "Delete semaphore" << endmsg;
 
  int   status;
  pid_t wait_pid;
  cout << "wait for besvis terminate" << endl;
  while ( wait_pid = waitpid( c_pid, &status, 0 ) )
  {
    log << MSG::INFO << "Wait on PID: " << c_pid << " returns status of: " << status << endmsg;
    if ( wait_pid == -1 ) break;
    sleep( 5 );
  }
  cout << "finalize" << endl;
  return StatusCode::SUCCESS;
}

initialize()

StatusCode BesVisAlg::initialize

(

)

Definition at line 70 of file BesVisAlg.cxx.

                                 {
 
  // Part 1: Get the messaging service, print where you are
  MsgStream log( msgSvc(), name() );
  log << MSG::INFO << " BesVisAlg initialize()" << endmsg;
  StatusCode status = StatusCode::SUCCESS;
 
  // Part 2: Print out the property values
  // ############################################################
  IService* isvc = 0;
  status         = service( "RootCnvSvc", m_cnvSvc, false );
  if ( !status.isSuccess() ) status = service( "EventCnvSvc", m_cnvSvc, true );
  status = hasWrite();
  if ( status.isSuccess() ) { log << MSG::INFO << "share file writed -- success" << endmsg; }
  else { log << MSG::ERROR << "share file writed -- ERROR!!!!!" << endmsg; }
  // ############################################################
 
  // Part 2: Print out the property values
  log << MSG::INFO << "  OutputFile = " << f_rootOutputFile << endmsg;
 
  for ( unsigned int i = 0; i < testVec.size(); i++ )
  { log << MSG::INFO << "  MyStringVec[" << i << "] = " << testVec[i] << endmsg; }
 
  // Part 3: Initialize semphore
  m_pid = getpid();
  log << MSG::ERROR << "BesVisAlg process PID: [" << m_pid << "]" << endmsg;
 
  log << MSG::ERROR << "Create and initialize semaphore" << endmsg;
  if ( ( semid = semget( (int)m_pid, 2, IPC_CREAT | IPC_EXCL | 0666 ) ) != -1 )
  {
    arg.array = start_val;
    log << MSG::ERROR << "Semaphore ID:" << semid << endmsg;
 
    if ( semctl( semid, 0, SETALL, arg ) == -1 )
    {
      log << MSG::ERROR << "semctl -- parent -- initialization" << endmsg;
      exit( 1 );
    }
 
    if ( ( sem_value_F = semctl( semid, FREE_SPACE, GETVAL, 0 ) ) == -1 )
    {
      log << MSG::ERROR << "semctl -- GETVAL" << endmsg;
      exit( 1 );
    }
 
    if ( ( sem_value_O = semctl( semid, OUTPUT_STORE, GETVAL, 0 ) ) == -1 )
    {
      log << MSG::ERROR << "semctl -- GETVAL" << endmsg;
      exit( 1 );
    }
  }
  else
  {
    log << MSG::INFO << "semget -- parent -- creation" << endmsg;
    exit( 2 );
  }
  //******************************
  // Debug information
  //*******************************
  // log << MSG::INFO << "semaphore ID: " << semid << endmsg;
  // log << MSG::ERROR << "set init sem_value_FREE-SPACE: " << sem_value_F << endmsg;
  // log << MSG::ERROR << "set init sem_value_OUTPUT-STORE: " << sem_value_O << endmsg;
 
  // Part 4: fork consumer process
  if ( ( c_pid = fork() ) == -1 )
  {
    log << MSG::ERROR << "fork -- consumer" << endmsg;
    exit( 5 );
  }
  else if ( c_pid == 0 )
  {
    // enter consumer logic
    log << MSG::INFO << "Parent fork consumer: ppid = " << getppid() << "; pid = " << getpid()
        << endmsg;
 
    // convert msg to char[] and transfer them to child process
    char msg_pid[25];
    sprintf( msg_pid, "%d", m_pid );
 
    const char* msg_sleep = testVec[1].c_str();
 
    log << MSG::INFO << "msg_pid: " << msg_pid << endmsg;
    log << MSG::INFO << "Consumer sleep time: " << msg_sleep << " seconds." << endmsg;
 
    // execute besvis.exe
    execlp( "besvis.exe", "besvis.exe", "-B", msg_pid, "-e", f_rootOutputFile.c_str(), "-g",
            f_geoInputFile.c_str(), (char*)NULL );
 
    // execlp("./a.out", "consumer", msg_pid, "5", (char *)NULL);
    log << MSG::ERROR << "exec -- consumer" << endmsg;
    exit( 6 );
  }
 
  return StatusCode::SUCCESS;
}

---

The documentation for this class was generated from the following files:

• BesVisAlg.h
• BesVisAlg.cxx