ToDqm.h

Go to the documentation of this file.

// $Id: ToDqm.h,v 1.3 2008/10/23 14:35:33 vpatras Exp $

/*************************************************************************
 * XDAQ Components for Distributed Data Acquisition                      *
 * Copyright (C) 2000-2004, CERN.                            *
 * All rights reserved.                                                  *
 * Authors: J. Gutleber and L. Orsini                    *
 *                                                                       *
 * For the licensing terms see LICENSE.                              *
 * For the list of contributors see CREDITS.                     *
 *************************************************************************/

#ifndef _xmas2dqm_wse_ToDqm_h_
#define _xmas2dqm_wse_ToDqm_h_

#include <string>
#include <map>
#include "xdaq/ApplicationDescriptor.h"
#include "Exception.h"

#include "xdata/String.h"
#include "xdata/Vector.h"
#include "xdata/Boolean.h"
#include "xdata/ActionListener.h"
#include "xdata/UnsignedInteger64.h"
#include "xdata/Table.h"

#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "DQMServices/Core/interface/DQMStore.h"
#include "DQMServices/Core/interface/MonitorElement.h"

#include <queue>
#include "toolbox/BSem.h"
#include <pthread.h>

/*#ifndef Qsize_max
#define Qsize_max 1000
#endif*/

#include "DQMServices/XdaqCollector/interface/FlashlistElements.h"

namespace xmas2dqm
{
    namespace wse
    {
        class ToDqm 
        {
            public:
        
            void digest(
                    const std::string& flashListName, 
                    const std::string& originator, 
                    const std::string& tag, 
                    /*xdata::Table::Reference table*/
                    xdata::Table *table
                    )
                    throw (xmas2dqm::wse::exception::Exception );
                    
            void free_memory();
            
            xdata::String runNumber_;
            
            std::queue<xdata::Table::Reference> QTable_;
            
            std::queue<xdata::Table *> MemoryTable_;
            
            xdata::Bag<xmas2dqm::wse::FlashlistElements> flashlistMonitor_;
            
            //semaphore to protect access to runNumber_
            toolbox::BSem BSem_;        
            
            //allows syncronized access to the queue of LAS data
            pthread_mutex_t LASmutex_;
    
                        //represents if the queue is (q.size reached max size)  
            pthread_cond_t more_;
            
            //represents if there is space in queue (q.size less than max size)
            pthread_cond_t less_;
            
                    
            static ToDqm *instance();
        private:
            ToDqm();
            ~ToDqm();
            static ToDqm* instance_;
            //DQMStore *be_;
            //MonitorElement *me_;
            int messageCount_;
                
            
        };
    
    }
}   

#endif