acstimeTimerImpl.h

Go to the documentation of this file.

/* @(#) $Id: acstimeTimerImpl.h,v 1.22 2008/10/01 03:11:48 cparedes Exp $
 *
 * Copyright (C) 2001
 * Associated Universities, Inc. Washington DC, USA.
 *
 * Produced for the ALMA project
 *
 * This library is free software; you can redistribute it and/or modify it it 
 * under the terms of the GNU Library General Public License as published by 
 * the Free Software Foundation; either version 2 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 Library General Public 
 * License for more details.
 *
 * You should have received a copy of the GNU Library General Public License 
 * along with this library; if not, write to the Free Software Foundation, 
 * Inc., 675 Massachusetts Ave, Cambridge, MA, 02139, USA.
 *
 * Correspondence concerning ALMA should be addressed as follows:
 * Internet email: alma-sw-admin@nrao.edu
 */
#ifndef ACSTIME_TIMER_IMPL_H
#define ACSTIME_TIMER_IMPL_H

#ifndef __cplusplus
#error This is a C++ include file and cannot be used from plain C
#endif

#include <baciCharacteristicComponentImpl.h>
#include <baci.h>
#include <ace/Timer_Heap_T.h>
#include <ace/Timer_Queue_Adapters.h>
#include <loggingLogger.h>
#include "acstimeS.h"
#include "ACSTimeError.h"
#include "acstimeTimeUtil.h"
#include "loggingLoggable.h"

class TimerImpl : public virtual acscomponent::ACSComponentImpl,
                  public virtual POA_acstime::Timer
{
  public:
    TimerImpl(
              const ACE_CString &name,
              maci::ContainerServices * containerServices);
    
    virtual ~TimerImpl();

    virtual CORBA::Long 
    schedule(acstime::TimeoutHandler_ptr callBack,
             const acstime::Epoch &time,
             const acstime::Duration &interval);
    
    virtual void 
    cancel(CORBA::Long id);
    
  private:
    
    typedef ACE_Event_Handler_Handle_Timeout_Upcall<ACE_Null_Mutex> Upcall;
    
    typedef ACE_Timer_Heap_T<ACE_Event_Handler*,Upcall,ACE_Null_Mutex> Timer_Heap;
    
    typedef ACE_Timer_Heap_Iterator_T<ACE_Event_Handler*,Upcall,ACE_Null_Mutex> Timer_Heap_Iterator;
    
    typedef ACE_Thread_Timer_Queue_Adapter<Timer_Heap> Thread_Timer_Queue;
    
    Thread_Timer_Queue *m_timerQueue;
    
    TimerImpl(const TimerImpl&);
    
    void operator= (const TimerImpl&);
    

    class Handler : public ACE_Event_Handler,
                    public Logging::Loggable

    {
      public:
        Handler(acstime::TimeoutHandler_ptr callBack,
                bool oneShotFlag);

        virtual ~Handler();
        
        int 
        handle_timeout(const ACE_Time_Value&,
                       const void*);
        
        acstime::TimeoutHandler_var m_handler;

        bool m_oneShotFlag;
        
    };
};
#endif