OscUdp.h

Go to the documentation of this file.

 
#ifndef _GAMS_UTILITY_OSC_HELPER_H_
#define _GAMS_UTILITY_OSC_HELPER_H_
 
#ifdef _GAMS_OSC_
 
#include <memory>
#include <map>
#include <vector>
#include <string>
 
#include "madara/transport/udp/UdpTransport.h"
#include "madara/transport/multicast/MulticastTransport.h"
#include "madara/transport/broadcast/BroadcastTransport.h"
#include "madara/utility/EpochEnforcer.h"
 
#include "madara/knowledge/KnowledgeRecord.h"
 
#include "gams/GamsExport.h"
#include "gams/loggers/GlobalLogger.h"
 
#include "osc/OscReceivedElements.h"
 
namespace gams
{
  namespace utility
  {
    class GAMS_EXPORT OscUdp
    {
      private:
        std::shared_ptr<madara::transport::UdpTransport> transport_ = 0;
 
        madara::transport::QoSTransportSettings settings_;
 
        madara::knowledge::KnowledgeBase kb_;
 
        madara::utility::ScopedArray<char> buffer_ =
          new char[64000];
        
      public:
        typedef  std::map<std::string,
          madara::knowledge::KnowledgeRecord>  OscMap;
 
        OscUdp() = default;
 
        ~OscUdp()
        {
          // force transport to clear first then kb should clean
          transport_ = 0;
        }
 
        size_t pack (void* buffer, size_t size, const OscMap& map);
 
        void unpack (void* buffer, size_t size, OscMap & map);
 
        inline bool has_socket (void)
        {
          return transport_.get() != 0;
        }
 
        void create_socket (
          madara::transport::QoSTransportSettings& settings);
 
        int receive (OscMap & values, double max_wait_seconds = 0.5);
 
        int send (const OscMap & values);
 
 
        void process_bundle(const osc::ReceivedBundle& b, OscMap & map);
        void process_message(const osc::ReceivedMessage& m, OscMap & map);
    };
  }
}
 
#endif //  #ifdef _GAMS_OSC_
#endif // _GAMS_UTILITY_OSC_HELPER_H_