acsThreadTest.h

Go to the documentation of this file.

#ifndef _ACS_THREAD_TEST_H
#define _ACS_THREAD_TEST_H
/*******************************************************************************
* ALMA - Atacama Large Millimiter Array
* (c) European Southern Observatory, 2005 
* 
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
* 
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
* Lesser General Public License for more details.
* 
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
*
* "@(#) $Id: acsThreadTest.h,v 1.4 2006/03/24 12:12:49 vwang Exp $"
*
* Classes used in ACS Thread modular tests
*
*/

#include "acsThread.h"


class TestACSThread :public ACS::Thread
{
  public:
    TestACSThread(const ACE_CString& name, 
                  const ACS::TimeInterval& responseTime=ThreadBase::defaultResponseTime, 
                  const ACS::TimeInterval& sleepTime=ThreadBase::defaultSleepTime,
                  bool del=false
        ) :
        ACS::Thread(name, responseTime, sleepTime, del)
        {
            ACS_TRACE("TestACSThread::TestACSThread");
            loopCounter_m = 0;
        }

    TestACSThread(const ACE_CString& name,
                  const ACS::TimeInterval& responseTime, 
                  const ACS::TimeInterval& sleepTime,
                  bool del,
                  const long _thrFlags
        ) :
        ACS::Thread(name, responseTime, sleepTime, del, _thrFlags)
        {
            ACS_TRACE("TestACSThread::TestACSThread");
            loopCounter_m = 0;
        }

    ~TestACSThread() 
        { 
            ACS_TRACE("TestACSThread::~TestACSThread"); 

            terminate(); 
        }

    virtual void runLoop()
        {
            if (loopCounter_m==10)
            {
                exit();
            }
            
            ACS_LOG(LM_SOURCE_INFO,
                    "TestACSThread::runLoop", 
                    (LM_INFO, "%s: runLoop (%d)", getName().c_str(), loopCounter_m));
            ++ loopCounter_m;
        }

  protected:
    int loopCounter_m;

};

#endif /* end _ACS_THREAD_TEST_H */