Skip to content
Snippets Groups Projects
Select Git revision
  • 56de4c43f7c8cbd3ea3d69a65a20bd14c44dda99
  • master default protected
  • rocky_8
  • rocky_9
  • pasture
  • testing
  • query
  • v0.2.9
  • v0.2.8
  • v0.2.7
  • v0.2.6
  • v0.2.5
  • v0.2.4
  • v0.2.3
  • v0.2.2
  • v0.2.1
  • v0.2.0
  • v0.1.2
  • v0.1.1
  • v0.1
20 results

import_executor.py

Blame
  • WorkerThread.h 1.65 KiB
    #ifndef WORKER_THREAD_H
    #define WORKER_THREAD_H
    
    #include <Configuration.h>
    #include <EventBuffer.h>
    #include <ScriptManager.h>
    
    #include <tango.h>
    
    #include <boost/shared_ptr.hpp>
    #include <boost/filesystem.hpp>
    
    namespace PreProcessor_ns
    {
    
    class PreProcessor;
    
    class WorkerThread : public Tango::LogAdapter
    {
    public:
    //------------------------------------------------------------------------------
    //	[Public] Constructor destructor
    //------------------------------------------------------------------------------
    	WorkerThread(PreProcessor*, EventBuffer::SP,
            ScriptManager::SP, Configuration::SP);
    
    	virtual ~WorkerThread();
    
    //------------------------------------------------------------------------------
    //	[Public] Users method
    //------------------------------------------------------------------------------
    	virtual void workerLoop();
    
    protected:
    //------------------------------------------------------------------------------
    //	[Protected] Utilities methods
    //------------------------------------------------------------------------------
        virtual void copyToDestination(boost::filesystem::path&)
            throw (std::runtime_error);
    
    //------------------------------------------------------------------------------
    //	[Protected] Class variables
    //------------------------------------------------------------------------------
        //Tango server class pointer
        PreProcessor* m_preProcessor_p;
    
    	//Event buffer shared pointer
    	EventBuffer::SP m_eventBuffer_sp;
    
        //File manager shared pointer
        ScriptManager::SP m_fileManager_sp;
    
    	//Configuration shared pointer
    	Configuration::SP m_configuration_sp;
    };
    
    }   //End of namespace
    
    #endif /*!WORKER_THREAD_H*/