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 191 of file BesVisAlg.h.

Constructor & Destructor Documentation

BesVisAlg()

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

Definition at line 18 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;
 
}

~BesVisAlg()

BesVisAlg::~BesVisAlg

(

)

Definition at line 50 of file BesVisAlg.cxx.

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

Member Function Documentation

execute()

StatusCode BesVisAlg::execute

(

)

Definition at line 178 of file BesVisAlg.cxx.

                              {
 
    // Part 1: Get the messaging service, print where you are
    MsgStream log(msgSvc(), name());
    log << MSG::INFO << "BesVisAlg execute()" << endreq;
 
    // 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 193 of file BesVisAlg.cxx.

                               {
 
    // Part 1: Get the messaging service, print where you are
    MsgStream log(msgSvc(), name());
    log << MSG::INFO << "BesVisAlg finalize()" << endreq;
 
    // 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" << endreq;
    else
        log << MSG::INFO <<  "Delete semaphore" << endreq;
 
    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 << endreq;
        if (wait_pid == -1) break;
        sleep(5);
    }
    cout << "finalize" << endl;
    return StatusCode::SUCCESS;
}

initialize()

StatusCode BesVisAlg::initialize

(

)

Definition at line 71 of file BesVisAlg.cxx.

                                {
 
    // Part 1: Get the messaging service, print where you are
    MsgStream log(msgSvc(), name());
    log << MSG::INFO << " BesVisAlg initialize()" << endreq;
    StatusCode status = StatusCode::SUCCESS;
 
    // Part 2: Print out the property values
//############################################################
    IService* isvc = 0;
    status = serviceLocator()->service("RootCnvSvc", isvc, false);
    if ( !status.isSuccess() )
        status = serviceLocator()->service("EventCnvSvc", isvc, true);
    if ( status.isSuccess() )
        status = isvc->queryInterface(IID_IRootCnvSvc, (void**)&m_cnvSvc);
    status = hasWrite();
    if ( status.isSuccess()){
        log << MSG::INFO << "share file writed -- success"
        << endreq;
    }
    else {
        log << MSG::ERROR << "share file writed -- ERROR!!!!!"
        << endreq;
    }
//############################################################
 
    // Part 2: Print out the property values
    log << MSG::INFO << "  OutputFile = " << f_rootOutputFile << endreq;
 
    for (unsigned int i=0; i<testVec.size(); i++) {
        log << MSG::INFO << "  MyStringVec[" << i << "] = "
        << testVec[i] << endreq;
    }
 
    // Part 3: Initialize semphore
    m_pid = getpid();
    log << MSG::ERROR << "BesVisAlg process PID: [" << m_pid << "]"
    << endreq;
 
    log << MSG::ERROR << "Create and initialize semaphore" << endreq;
    if ((semid = semget((int)m_pid, 2, IPC_CREAT | IPC_EXCL | 0666)) != -1){
        arg.array = start_val;
        log << MSG::ERROR << "Semaphore ID:" << semid << endreq;
 
        if (semctl(semid, 0, SETALL, arg) == -1){
            log << MSG::ERROR << "semctl -- parent -- initialization"
            << endreq;
            exit(1);
        }
 
        if ((sem_value_F = semctl(semid, FREE_SPACE, GETVAL, 0)) == -1){
            log << MSG::ERROR << "semctl -- GETVAL" << endreq;
            exit(1);
        }
 
        if ((sem_value_O = semctl(semid, OUTPUT_STORE, GETVAL, 0)) == -1){
            log << MSG::ERROR << "semctl -- GETVAL" << endreq;
            exit(1);
        }
    }
    else {
        log << MSG::INFO << "semget -- parent -- creation" << endreq;
        exit(2);
    }
    //******************************
    // Debug information
    //*******************************
    //log << MSG::INFO << "semaphore ID: " << semid << endreq;
    //log << MSG::ERROR << "set init sem_value_FREE-SPACE: " << sem_value_F << endreq;
    //log << MSG::ERROR << "set init sem_value_OUTPUT-STORE: " << sem_value_O << endreq;
 
    // Part 4: fork consumer process
    if ((c_pid = fork()) == -1){
        log << MSG::ERROR << "fork -- consumer" << endreq;
        exit(5);
    }
    else if (c_pid == 0){
        // enter consumer logic
        log << MSG::INFO << "Parent fork consumer: ppid = " << getppid()
        << "; pid = " << getpid() << endreq;
 
        // 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 << endreq;
        log << MSG::INFO << "Consumer sleep time: " << msg_sleep
        << " seconds." << endreq;
 
        //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" << endreq;
        exit(6);
    }
 
 
    return StatusCode::SUCCESS;
}

---

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

• BesVisAlg.h
• BesVisAlg.cxx