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

IdxRecordId.h

Go to the documentation of this file.

#ifndef IDX_RECORDID_H
#define IDX_RECORDID_H

#include <fstream>
#include <string> 
#include <pthread.h>

#include "BP_CosLw_Log.h"
#include "CorbaServer.h"


class IdxRecordId
{

   public:
      IdxRecordId(std::string logname)
         throw(OrbInit::InitializationError);

      virtual ~IdxRecordId();


      struct IdxRecord
      {
         CosLwLog::RecordId start_rcd_id;
         CosLwLog::RecordId stop_rcd_id;
         unsigned long start_seconds;
         unsigned long start_nanos;
         unsigned long end_seconds;
         unsigned long end_nanos;
      };

      IdxRecord get_last_record();
     
      IdxRecord get_next_record_id(IdxRecord last);

      IdxRecord find_by_time(const CosLwLog::LogTime& time);

      IdxRecord find_by_recid(const CosLwLog::RecordId& recid);

      const bool is_the_future(const CosLwLog::RecordId& recid) const;

      CosLwLog::RecordId future_id();



   private:

      std::fstream   _idx;

      std::fstream   _momento;

      const std::string    _idx_name;
      const std::string    _momento_name;

      CosLwLog::RecordId   _recordId;

      pthread_mutex_t   _idx_mutex;

      pthread_mutex_t   _recdid_mutex;

      pthread_mutex_t   _momento_mutex;

      std::string _make_idx_name(std::string log_name);

      std::string _make_momento_name(std::string log_name);
     
      unsigned long _find_middle(long start, long end);
     
      IdxRecord _arch_find_by_time( const unsigned long& seconds);

      IdxRecord _arch_find_by_recid(const CosLwLog::RecordId& recid);

      void _init()
         throw(OrbInit::InitializationError);

      void _make_momento_entry(const IdxRecord& recd);

      void _make_idx_entry(const IdxRecord& recd);

      unsigned long _arch_size();
};

#endif

---