baciBACICallback.h

Go to the documentation of this file.

#ifndef baciBACICallback_H
#define baciBACICallback_H

/*******************************************************************
* ALMA - Atacama Large Millimiter Array
* (c) European Southern Observatory, 2003 
*
*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: baciBACICallback.h,v 1.5 2006/09/01 02:20:54 cparedes Exp $"
*
* who       when      what
* --------  --------  ----------------------------------------------
* dfugate 2005-01-17 created
*/

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

#include "baciExport.h"
#include "baciValue.h"
#include "baciRegistrar.h"

namespace baci {


// forwards
class BACIComponent;

class baci_EXPORT BACICallback 
{

public:

  BACICallback(const int& id_, Callback_ptr callback_, 
               const BACIValue::Type type_, 
               const CBDescIn& descIn_, BACIComponent* component_p): 
    id_m(id_), type_m(type_), descIn_m(descIn_), component_mp(component_p), 
    failureCount_m(0), removeOnFailure_m(true) 
  { 
    callback_mp = Callback::_duplicate(callback_); 
  }

  ~BACICallback() { 
    CORBA::release(callback_mp);
  }
  
  BACICallback& operator=(const BACICallback& cb) 
  {
    if (this!=&cb) 
      { 
        id_m=cb.id_m; 
        type_m=cb.type_m; 
        callback_mp=Callback::_duplicate(cb.callback_mp); 
        descIn_m=cb.descIn_m;
        component_mp=cb.component_mp;
        failureCount_m=cb.failureCount_m;
        removeOnFailure_m=cb.removeOnFailure_m;
      }
    return *this;
  }
  
  bool operator==(const BACICallback& cb) const { return id_m==cb.id_m; }

   int getID() const { return id_m; }
 
   void succeeded() { 
     //ACS_TRACE("baci::BACICallback::succeeded");
     failureCount_m=0;
   }

  
  void failed();

  bool isOK() { return (failureCount_m <= failureLimitCount_m); }

  void setRemoveOnFailure(bool removeOnFailure_) { removeOnFailure_m=removeOnFailure_; }
  
  bool doRemoveOnFailure() const { return removeOnFailure_m; }

   Callback_ptr getCallback() const { return callback_mp; }

   BACIValue::Type getType() const { return type_m; }

   CBDescIn getDescIn() const { return descIn_m; }

   BACIComponent* getComponent() const { return component_mp; }
  
private:

  int id_m;

  Callback_ptr callback_mp;

  BACIValue::Type type_m;

  CBDescIn descIn_m;

  BACIComponent* component_mp;

  int failureCount_m;

  bool removeOnFailure_m;
  
  static const int failureLimitCount_m;

    BACICallback(const BACICallback&);  

};   /* BACICallback */

/* ------------------------------------------------------------------------ */
typedef Registrar<int, BACICallback*> BACICallbackTable;
/* ------------------------------------------------------------------------ */

 }; 

#endif /* baciBACICallback_H */