comparison include/OSCServer.h @ 278:3c3d042dad12 prerelease

merge

+/***** OSCServer.h *****/
+#ifndef __OSCServer_H_INCLUDED__
+#define __OSCServer_H_INCLUDED__ 
+
+#include <UdpServer.h>
+#include <oscpkt.hh>
+#include <BeagleRT.h>
+#include <queue>
+
+#define UDP_RECIEVE_TIMEOUT_MS 20
+#define UDP_RECIEVE_MAX_LENGTH 16384
+
+class OSCServer{
+    public:
+        OSCServer();
+
+        // must be called once during setup
+        void setup(int port);
+        
+        // returns true if messages are queued
+        // audio-thread safe
+        bool messageWaiting();
+        
+        // removes and returns the oldest message from the queue
+        // audio-thread safe, but don't call unless messageWaiting() returns true
+        oscpkt::Message popMessage();
+        
+        // if there are OSC messages waiting, decode and queue them
+        // not audio-thread safe!
+        void recieveMessageNow(int timeout);
+        
+    private:
+        int port;
+        UdpServer socket;
+
+        AuxiliaryTask OSCRecieveTask;
+        
+        void createAuxTasks();
+        void messageCheck();
+        
+        static void checkMessages(void*);
+        
+        int inBuffer[UDP_RECIEVE_MAX_LENGTH];
+        std::queue<oscpkt::Message> inQueue;
+        oscpkt::Message poppedMessage;
+        oscpkt::PacketReader pr;
+};
+
+
+#endif