comring.h

Go to the documentation of this file.

#ifndef COMRING_COMMUNICATOR_H
#define COMRING_COMMUNICATOR_H

#include <lwpp/global.h>
#include <lwcomring.h>
#include <string>

namespace lwpp
{

  class comRingCommunicator : public GlobalBase<LWComRing> // needs to be declared as a global properly in global.cpp
  {
    std::string lastTopic;
  protected:

    virtual void RingEvent(void *portData, int eventCode, void *eventData) 
    {
      return;
    }
    static void RingEventCB(void *clientData, void *portData,int eventCode,void *eventData) 
    {
      // cast the instance back to the base class 
      comRingCommunicator *plugin = static_cast<comRingCommunicator *>(clientData); 
      // pass through the remaining arguments to the function
      plugin->RingEvent(portData, eventCode, eventData); 
    }
  public:
    comRingCommunicator() {;}
    comRingCommunicator(const char *topic) 
    {
      if (available())
      {
        if (ringAttach (topic))
        {
          ;
        }
      }
    }
    virtual ~comRingCommunicator()
    {
      if (!lastTopic.empty()) ringDetach (lastTopic.c_str());
    }
    bool ringAttach (const char *topic)
    {
      if (globPtr->ringAttach(const_cast<char *>(topic), this, RingEventCB))
      {
        lastTopic = topic;
        return true;
      }
      return false;
    }
    
    void ringDetach (const char *topic)
    {
      globPtr->ringDetach(const_cast<char *>(topic), this);
    }
    
    void ringMessage (const char *topic,int eventCode,void *eventData = 0)
    {
      if (globPtr) globPtr->ringMessage(const_cast<char *>(topic), eventCode, eventData);
    }
  };

#ifndef LW_PLUGIN_LIMBO_STATES
#define LW_PLUGIN_LIMBO_STATES "LW Plugin Limbo States"

#define LW_LIMBO_START 0x00000001
#define LW_LIMBO_END   0x00000002
#endif


  class LimboComRing : private comRingCommunicator
  {
  public:
    LimboComRing()
    {
      ringMessage(LW_PLUGIN_LIMBO_STATES, LW_LIMBO_START);
    }
    ~LimboComRing()
    {
      ringMessage(LW_PLUGIN_LIMBO_STATES, LW_LIMBO_END);
    }
  };

} // end namespace
#endif // COMRING_COMMUNICATOR_H