---

rmEvent.h

Go to the documentation of this file.

#ifndef __rmEvent_h_
#define __rmEvent_h_

#include <queue>
#include <string>
#include <posix_evlog.h>

#include <ResourceMonitor/ResourceMonitorTypes.h>

#include "rmClientError.h"
#include "rmSysInfo.h"

typedef enum _EventType
{
  THRESHOLD,
  THRESHOLDCANCEL,
  LEAKYBUCKET,

  SUBSYSTEM,
  RESOURCE,
} EventType;

typedef enum _EventName
{
  SUBSYSTEM_ADDED,
  SUBSYSTEM_REMOVED,
  RESOURCE_ADDED,
  RESOURCE_REMOVED,
  DATACAPTURE_ADDED,
  DATACAPTURE_REMOVED
} EventName;

class rmEvent 
{
  public:

    rmEvent(subsystemInfo * aSubsystemInfo, 
            resourceInfo * aResourceInfo, 
            dataCaptureInfo * aDataCaptureInfo) : 
                                   mSubsystemInfo(aSubsystemInfo), 
                                   mResourceInfo(aResourceInfo), 
                                   mDataCaptureInfo(aDataCaptureInfo) {}

    virtual ~rmEvent(){posix_log_notify_remove(mSystemNotifyHandle);}

    int init();

    void addEvent(posix_log_recid_t aRecID, unsigned long aMonID);

    void processEvents();

  private:

    int getEventType(posix_log_recid_t aRecID, long & aType);

    int getEventText(posix_log_recid_t aRecID, char * * aText);

    int sendMonitorEvent(EventType aType, eventData & aEvent);

    int processSystemEvent(EventType aType, eventData & aEvent);

    int sendSubSystemEvent(EventName aEvent, uuid_t aUUID);

    int sendResourceEvent(EventName aEvent, uuid_t aUUID, unsigned long aID, string aName);

    int sendPluginEvent(EventName aEvent, uuid_t aUUID, unsigned long aID, string aName);

    queue<eventData> mEventQueue;

    bool mUpdating;

    posix_log_notify_t mSystemNotifyHandle;

    subsystemInfo * mSubsystemInfo;
    resourceInfo * mResourceInfo;
    dataCaptureInfo * mDataCaptureInfo;
};

#endif // __rmEvent_h_

---