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

Consumer_Impl.h

Go to the documentation of this file.

#ifndef CONSUMER_IMPL_H
#define CONSUMER_IMPL_H

#include "BP_CosLw_Log.h"
#include "LogState.h"
#include "LogBrowser.h"
#include "EvictionMngr.h"

class Consumer_Impl : 
   public virtual POA_CosLwLog::LogConsumer,
   public virtual Evictable
{

   public:

      Consumer_Impl(
            LogState& state, 
            EvictionMngr& evictmngr,
            const std::string& consumer_id
            );

      virtual ~Consumer_Impl();

      
      virtual CORBA::ULongLong get_max_size()
         throw(CORBA::SystemException);

      virtual CORBA::ULongLong get_current_size()
         throw(CORBA::SystemException);

      virtual CORBA::ULongLong get_n_records()
         throw(CORBA::SystemException);

      virtual CosLwLog::LogFullAction get_log_full_action()
         throw(CORBA::SystemException);

      virtual CosLwLog::AvailabilityStatus get_availability_status()
         throw(CORBA::SystemException);

      virtual CosLwLog::AdministrativeState get_administrative_state()
         throw(CORBA::SystemException);

      virtual CosLwLog::OperationalState get_operational_state()
         throw(CORBA::SystemException);

      virtual CosLwLog::RecordId
         get_record_id_from_time(const CosLwLog::LogTime& from_time)
         throw(CosLwLog::InvalidParam, CORBA::SystemException);

      virtual CosLwLog::LogRecordSequence*
         retrieve_records(
               CosLwLog::RecordId& recid,
               CORBA::ULong& how_many
               )
         throw(CosLwLog::InvalidParam, CORBA::SystemException);

      virtual CosLwLog::LogRecordSequence*
         retrieve_records_by_level(
               CosLwLog::RecordId& current_id,
               CORBA::ULong& how_many,
               const CosLwLog::LogLevelSequence& levels)
         throw(CosLwLog::InvalidParam, CORBA::SystemException);

      virtual CosLwLog::LogRecordSequence*
         retrieve_records_by_producer_id(
               CosLwLog::RecordId& current_id,
               CORBA::ULong& how_many,
               const CosLwLog::StringSeq& value_list
               )
         throw(CosLwLog::InvalidParam, CORBA::SystemException);

      virtual CosLwLog::LogRecordSequence*
         retrieve_records_by_producer_name(
               CosLwLog::RecordId& current_id,
               CORBA::ULong& how_many,
               const CosLwLog::StringSeq& value_list
               )
         throw(CosLwLog::InvalidParam, CORBA::SystemException);

      
      virtual bool evicted();

   private:

      LogState&   _state;

      LogBrowser  _browser;

      EvictionMngr& _mngr;

      const std::string _me;

      void _collect_records(const CORBA::ULong& how_many,
            std::list<CosLwLog::LogRecord>& recd_list,
            const LogRecordFilter& filter
            );

      CosLwLog::RecordId _transfer_records(
            CosLwLog::LogRecordSequence_var& recd_seq,
            std::list<CosLwLog::LogRecord>& recd_list
            );
};
#endif

---