SyslogMMAPOperator.h

Go to the documentation of this file.

#ifndef CARMA_DBMS_SYSLOGMMAPOPERATOR_H
#define CARMA_DBMS_SYSLOGMMAPOPERATOR_H

#include "carma/dbms/SyslogMMAPFile.h"
#include <string>
#include <map>

#include <sys/types.h>
#include <regex.h>

namespace carma
{
  namespace dbms
  {

    class SyslogMMAPOperator
    {
      public:

        SyslogMMAPOperator( SyslogMMAPFile &smapf );

        ~SyslogMMAPOperator();

        void setWayBackMachine( double mjd );
        void resetWayBackMachine();
        SyslogMessage *nextMessage();
        int messagesWaiting()
        {
          int adj = 0;

          if ( _pos > _cpos )
            adj = _pos;

          return ( (_cpos + adj) - _pos );
        };

        void setFilter( ::std::string &myFilter );
        ::std::string::size_type instantSetSize() { return _setSize; };

        ::std::string toString();

        bool hasFilter() { return _hasFilter; };
        void resetFilter();
        bool doesMatch( SyslogMessage *msg );

        ::std::string getFilter() { return _filter; };

        typedef enum
        {
          ALL,
          PROGRAM,
          LOGNAME,
          NDC,
          MESSAGE
        } fieldList;

      private:
        SyslogMMAPFile &_smapf;
        ::std::string _filter;
        ::std::string::size_type _setSize;
        ::std::string _mjdOffsetString;
        ::std::string _opString;
        bool _opGreater;
        ::std::string _valString;
        ::std::string _textString;
        ::std::string _fieldString;
        int _fieldCheck;
        regex_t *_regex;

        int _prioInt;

        double _mjdOffset;
        long _cpos, _pos;
        bool _current;
        bool _hasFilter;
    };
  }
}

#endif // CARMA_DBMS_SYSLOGMMAPOPERATOR_H