ofxOscReceiver.h
Go to the documentation of this file.
00001 /* 00002 00003 Copyright 2007, 2008 Damian Stewart damian@frey.co.nz 00004 Distributed under the terms of the GNU Lesser General Public License v3 00005 00006 This file is part of the ofxOsc openFrameworks OSC addon. 00007 00008 ofxOsc is free software: you can redistribute it and/or modify 00009 it under the terms of the GNU Lesser General Public License as published by 00010 the Free Software Foundation, either version 3 of the License, or 00011 (at your option) any later version. 00012 00013 ofxOsc is distributed in the hope that it will be useful, 00014 but WITHOUT ANY WARRANTY; without even the implied warranty of 00015 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 00016 GNU General Public License for more details. 00017 00018 You should have received a copy of the GNU Lesser General Public License 00019 along with ofxOsc. If not, see <http://www.gnu.org/licenses/>. 00020 */ 00021 00022 00023 #ifndef _ofxOscRECEIVER_H 00024 #define _ofxOscRECEIVER_H 00025 00026 #include <deque> 00027 #include <ofMain.h> 00028 00029 #ifdef TARGET_WIN32 00030 // threads 00031 #include <windows.h> 00032 #else 00033 // threads 00034 #include <pthread.h> 00035 #endif 00036 00037 // osc 00038 #include <OscTypes.h> 00039 #include <OscPacketListener.h> 00040 #include <UdpSocket.h> 00041 00042 // ofxOsc 00043 #include "ofxOscMessage.h" 00044 00045 class ofxOscReceiver : public osc::OscPacketListener 00046 { 00047 public: 00048 ofxOscReceiver(); 00049 ~ofxOscReceiver(); 00050 00052 void setup( int listen_port ); 00053 00055 bool hasWaitingMessages(); 00059 bool getNextMessage( ofxOscMessage* ); 00060 00061 protected: 00063 virtual void ProcessMessage( const osc::ReceivedMessage &m, const IpEndpointName& remoteEndpoint ); 00064 00065 private: 00066 00067 // start the listening thread 00068 #ifdef TARGET_WIN32 00069 static DWORD WINAPI startThread( void* listen_socket ); 00070 #else 00071 static void* startThread( void* listen_socket ); 00072 #endif 00073 // queue of osc messages 00074 std::deque< ofxOscMessage* > messages; 00075 00076 // socket to listen on 00077 UdpListeningReceiveSocket* listen_socket; 00078 00079 // mutex helpers 00080 void grabMutex(); 00081 void releaseMutex(); 00082 00083 #ifdef TARGET_WIN32 00084 // thread to listen with 00085 HANDLE thread; 00086 // mutex for the thread queue 00087 HANDLE mutex; 00088 #else 00089 // thread to listen with 00090 pthread_t thread; 00091 // mutex for the message queue 00092 pthread_mutex_t mutex; 00093 #endif 00094 }; 00095 00096 #endif
