BoilerPlate-LightweightLogging Service OMG Formal/03-11-03

LogConsumerActivator_Impl.h

Go to the documentation of this file.

#ifndef LOGCONSUMERACTIVATOR_IMPL
#define LOGCONSUMERACTIVATOR_IMPL

#include "BP_CosLw_Log.h"
#include <map>
#include <deque>
#include <string>
#include <pthread.h>

#include "LogState.h"
#include "Consumer_Impl.h"
#include "EvictionMngr.h"


class LogConsumerActivator_Impl : 
   public virtual PortableServer::ServantActivator,
   public virtual CORBA::LocalObject,
   public virtual EvictionMngr
{
   public:
      LogConsumerActivator_Impl(const unsigned long q_size, LogState& state);

      virtual ~LogConsumerActivator_Impl();

      virtual PortableServer::Servant
         incarnate(
               const PortableServer::ObjectId& oid,
               PortableServer::POA_ptr adapter
               ) throw(CORBA::SystemException, PortableServer::ForwardRequest);

      virtual void
         etherealize(
               const PortableServer::ObjectId& oid,
               PortableServer::POA_ptr poa,
               PortableServer::Servant servant,
               CORBA::Boolean cleanup_in_progress,
               CORBA::Boolean activations_remain
               ) throw(CORBA::SystemException);
       
      virtual void 
         invocation_active(const std::string& evictable_id);

   private:

      typedef std::deque<std::string> OID_Queue;

      OID_Queue _oid_queue;

      LogState& _state;

      const unsigned long _max_q_size;

      pthread_mutex_t _storage_mutex;

};
#endif

---