mame vector receiver

8 files changed, 838 insertions, 0 deletions

diff --git a/oscReceiveExample/Makefile b/oscReceiveExample/Makefile
new file mode 100644
index 0000000..177e172
--- /dev/null
+++ b/oscReceiveExample/Makefile
@@ -0,0 +1,13 @@
+# Attempt to load a config.make file.
+# If none is found, project defaults in config.project.make will be used.
+ifneq ($(wildcard config.make),)
+	include config.make
+endif
+
+# make sure the the OF_ROOT location is defined
+ifndef OF_ROOT
+	OF_ROOT=$(realpath ../../..)
+endif
+
+# call the project makefile!
+include $(OF_ROOT)/libs/openFrameworksCompiled/project/makefileCommon/compile.project.mk
diff --git a/oscReceiveExample/addons.make b/oscReceiveExample/addons.make
new file mode 100644
index 0000000..1b8f1d2
--- /dev/null
+++ b/oscReceiveExample/addons.make
@@ -0,0 +1,2 @@
+ofxOsc
+ofxHelios
diff --git a/oscReceiveExample/config.make b/oscReceiveExample/config.make
new file mode 100644
index 0000000..a2f4f86
--- /dev/null
+++ b/oscReceiveExample/config.make
@@ -0,0 +1,142 @@
+################################################################################
+# CONFIGURE PROJECT MAKEFILE (optional)
+#   This file is where we make project specific configurations.
+################################################################################
+
+################################################################################
+# OF ROOT
+#   The location of your root openFrameworks installation
+#       (default) OF_ROOT = ../../.. 
+################################################################################
+OF_ROOT = ../../openFrameworks
+
+################################################################################
+# PROJECT ROOT
+#   The location of the project - a starting place for searching for files
+#       (default) PROJECT_ROOT = . (this directory)
+#    
+################################################################################
+# PROJECT_ROOT = .
+
+################################################################################
+# PROJECT SPECIFIC CHECKS
+#   This is a project defined section to create internal makefile flags to 
+#   conditionally enable or disable the addition of various features within 
+#   this makefile.  For instance, if you want to make changes based on whether
+#   GTK is installed, one might test that here and create a variable to check. 
+################################################################################
+# None
+
+################################################################################
+# PROJECT EXTERNAL SOURCE PATHS
+#   These are fully qualified paths that are not within the PROJECT_ROOT folder.
+#   Like source folders in the PROJECT_ROOT, these paths are subject to 
+#   exlclusion via the PROJECT_EXLCUSIONS list.
+#
+#     (default) PROJECT_EXTERNAL_SOURCE_PATHS = (blank) 
+#
+#   Note: Leave a leading space when adding list items with the += operator
+################################################################################
+# PROJECT_EXTERNAL_SOURCE_PATHS = 
+
+################################################################################
+# PROJECT EXCLUSIONS
+#   These makefiles assume that all folders in your current project directory 
+#   and any listed in the PROJECT_EXTERNAL_SOURCH_PATHS are are valid locations
+#   to look for source code. The any folders or files that match any of the 
+#   items in the PROJECT_EXCLUSIONS list below will be ignored.
+#
+#   Each item in the PROJECT_EXCLUSIONS list will be treated as a complete 
+#   string unless teh user adds a wildcard (%) operator to match subdirectories.
+#   GNU make only allows one wildcard for matching.  The second wildcard (%) is
+#   treated literally.
+#
+#      (default) PROJECT_EXCLUSIONS = (blank)
+#
+#		Will automatically exclude the following:
+#
+#			$(PROJECT_ROOT)/bin%
+#			$(PROJECT_ROOT)/obj%
+#			$(PROJECT_ROOT)/%.xcodeproj
+#
+#   Note: Leave a leading space when adding list items with the += operator
+################################################################################
+# PROJECT_EXCLUSIONS =
+
+################################################################################
+# PROJECT LINKER FLAGS
+#	These flags will be sent to the linker when compiling the executable.
+#
+#		(default) PROJECT_LDFLAGS = -Wl,-rpath=./libs
+#
+#   Note: Leave a leading space when adding list items with the += operator
+################################################################################
+
+# Currently, shared libraries that are needed are copied to the 
+# $(PROJECT_ROOT)/bin/libs directory.  The following LDFLAGS tell the linker to
+# add a runtime path to search for those shared libraries, since they aren't 
+# incorporated directly into the final executable application binary.
+# TODO: should this be a default setting?
+# PROJECT_LDFLAGS=-Wl,-rpath=./libs
+
+################################################################################
+# PROJECT DEFINES
+#   Create a space-delimited list of DEFINES. The list will be converted into 
+#   CFLAGS with the "-D" flag later in the makefile.
+#
+#		(default) PROJECT_DEFINES = (blank)
+#
+#   Note: Leave a leading space when adding list items with the += operator
+################################################################################
+# PROJECT_DEFINES = 
+
+################################################################################
+# PROJECT CFLAGS
+#   This is a list of fully qualified CFLAGS required when compiling for this 
+#   project.  These CFLAGS will be used IN ADDITION TO the PLATFORM_CFLAGS 
+#   defined in your platform specific core configuration files. These flags are
+#   presented to the compiler BEFORE the PROJECT_OPTIMIZATION_CFLAGS below. 
+#
+#		(default) PROJECT_CFLAGS = (blank)
+#
+#   Note: Before adding PROJECT_CFLAGS, note that the PLATFORM_CFLAGS defined in 
+#   your platform specific configuration file will be applied by default and 
+#   further flags here may not be needed.
+#
+#   Note: Leave a leading space when adding list items with the += operator
+################################################################################
+# PROJECT_CFLAGS = 
+
+################################################################################
+# PROJECT OPTIMIZATION CFLAGS
+#   These are lists of CFLAGS that are target-specific.  While any flags could 
+#   be conditionally added, they are usually limited to optimization flags. 
+#   These flags are added BEFORE the PROJECT_CFLAGS.
+#
+#   PROJECT_OPTIMIZATION_CFLAGS_RELEASE flags are only applied to RELEASE targets.
+#
+#		(default) PROJECT_OPTIMIZATION_CFLAGS_RELEASE = (blank)
+#
+#   PROJECT_OPTIMIZATION_CFLAGS_DEBUG flags are only applied to DEBUG targets.
+#
+#		(default) PROJECT_OPTIMIZATION_CFLAGS_DEBUG = (blank)
+#
+#   Note: Before adding PROJECT_OPTIMIZATION_CFLAGS, please note that the 
+#   PLATFORM_OPTIMIZATION_CFLAGS defined in your platform specific configuration 
+#   file will be applied by default and further optimization flags here may not 
+#   be needed.
+#
+#   Note: Leave a leading space when adding list items with the += operator
+################################################################################
+# PROJECT_OPTIMIZATION_CFLAGS_RELEASE = 
+# PROJECT_OPTIMIZATION_CFLAGS_DEBUG = 
+
+################################################################################
+# PROJECT COMPILERS
+#   Custom compilers can be set for CC and CXX
+#		(default) PROJECT_CXX = (blank)
+#		(default) PROJECT_CC = (blank)
+#   Note: Leave a leading space when adding list items with the += operator
+################################################################################
+# PROJECT_CXX = 
+# PROJECT_CC = 
diff --git a/oscReceiveExample/mame/vector.cpp b/oscReceiveExample/mame/vector.cpp
new file mode 100644
index 0000000..89c27c2
--- /dev/null
+++ b/oscReceiveExample/mame/vector.cpp
@@ -0,0 +1,264 @@
+// license:BSD-3-Clause
+// copyright-holders:Brad Oliver,Aaron Giles,Bernd Wiebelt,Allard van der Bas
+/******************************************************************************
+ *
+ * vector.c
+ *
+ *        anti-alias code by Andrew Caldwell
+ *        (still more to add)
+ *
+ * 040227 Fixed miny clip scaling which was breaking in mhavoc. AREK
+ * 010903 added support for direct RGB modes MLR
+ * 980611 use translucent vectors. Thanks to Peter Hirschberg
+ *        and Neil Bradley for the inspiration. BW
+ * 980307 added cleverer dirty handling. BW, ASG
+ *        fixed antialias table .ac
+ * 980221 rewrote anti-alias line draw routine
+ *        added inline assembly multiply fuction for 8086 based machines
+ *        beam diameter added to draw routine
+ *        beam diameter is accurate in anti-alias line draw (Tcosin)
+ *        flicker added .ac
+ * 980203 moved LBO's routines for drawing into a buffer of vertices
+ *        from avgdvg.c to this location. Scaling is now initialized
+ *        by calling vector_init(...). BW
+ * 980202 moved out of msdos.c ASG
+ * 980124 added anti-alias line draw routine
+ *        modified avgdvg.c and sega.c to support new line draw routine
+ *        added two new tables Tinten and Tmerge (for 256 color support)
+ *        added find_color routine to build above tables .ac
+ *
+ * Vector Team
+ *
+ *        Brad Oliver
+ *        Aaron Giles
+ *        Bernd Wiebelt
+ *        Allard van der Bas
+ *        Al Kossow (VECSIM)
+ *        Hedley Rainnie (VECSIM)
+ *        Eric Smith (VECSIM)
+ *        Neil Bradley (technical advice)
+ *        Andrew Caldwell (anti-aliasing)
+ *
+ **************************************************************************** */
+
+#include "emu.h"
+#include "emuopts.h"
+#include "rendutil.h"
+#include "vector.h"
+
+//make SUBTARGET=arcade
+
+//#include "libheliosdac/HeliosDacAPI.h"
+#include "osc/OscOutboundPacketStream.h"
+
+#include "ip/IpEndpointName.h"
+
+#define ADDRESS "127.0.0.1"
+#define PORT 7070
+
+#define VECTOR_WIDTH_DENOM 512
+
+#define MAX_POINTS 10000
+
+float vector_options::s_flicker = 0.0f;
+float vector_options::s_beam_width_min = 0.0f;
+float vector_options::s_beam_width_max = 0.0f;
+float vector_options::s_beam_intensity_weight = 0.0f;
+
+void vector_options::init(emu_options& options)
+{
+	s_beam_width_min = options.beam_width_min();
+	s_beam_width_max = options.beam_width_max();
+	s_beam_intensity_weight = options.beam_intensity_weight();
+	s_flicker = options.flicker();
+}
+
+// device type definition
+DEFINE_DEVICE_TYPE(VECTOR, vector_device, "vector_device", "VECTOR")
+
+vector_device::vector_device(const machine_config &mconfig, const char *tag, device_t *owner, uint32_t clock)
+	: device_t(mconfig, VECTOR, tag, owner, clock),
+		device_video_interface(mconfig, *this),
+		m_vector_list(nullptr),
+		m_min_intensity(255),
+		m_max_intensity(0),
+		transmitSocket(IpEndpointName( ADDRESS, PORT ))
+{
+}
+
+void vector_device::device_start()
+{
+	vector_options::init(machine().options());
+
+	m_vector_index = 0;
+
+	/* allocate memory for tables */
+	m_vector_list = make_unique_clear<point[]>(MAX_POINTS);
+}
+
+/*
+ * www.dinodini.wordpress.com/2010/04/05/normalized-tunable-sigmoid-functions/
+ */
+float vector_device::normalized_sigmoid(float n, float k)
+{
+	// valid for n and k in range of -1.0 and 1.0
+	return (n - n * k) / (k - fabs(n) * 2.0f * k + 1.0f);
+}
+
+
+/*
+ * Adds a line end point to the vertices list. The vector processor emulation
+ * needs to call this.
+ */
+void vector_device::add_point(int x, int y, rgb_t color, int intensity)
+{
+	point *newpoint;
+
+	intensity = std::max(0, std::min(255, intensity));
+
+	m_min_intensity = intensity > 0 ? std::min(m_min_intensity, intensity) : m_min_intensity;
+	m_max_intensity = intensity > 0 ? std::max(m_max_intensity, intensity) : m_max_intensity;
+
+	if (vector_options::s_flicker && (intensity > 0))
+	{
+		float random = (float)(machine().rand() & 255) / 255.0f; // random value between 0.0 and 1.0
+
+		intensity -= (int)(intensity * random * vector_options::s_flicker);
+
+		intensity = std::max(0, std::min(255, intensity));
+	}
+
+	newpoint = &m_vector_list[m_vector_index];
+	newpoint->x = x;
+	newpoint->y = y;
+	newpoint->col = color;
+	newpoint->intensity = intensity;
+
+	m_vector_index++;
+	if (m_vector_index >= MAX_POINTS)
+	{
+		m_vector_index--;
+		logerror("*** Warning! Vector list overflow!\n");
+	}
+}
+
+
+/*
+ * The vector CPU creates a new display list. We save the old display list,
+ * but only once per refresh.
+ */
+void vector_device::clear_list(void)
+{
+	m_vector_index = 0;
+}
+
+#define OSC_BUFFER_SIZE 65535
+#define OSC_PACKET_LENGTH 5
+
+uint32_t vector_device::screen_update(screen_device &screen, bitmap_rgb32 &bitmap, const rectangle &cliprect)
+{
+	uint32_t flags = PRIMFLAG_ANTIALIAS(1) | PRIMFLAG_BLENDMODE(BLENDMODE_ADD) | PRIMFLAG_VECTOR(1);
+	const rectangle &visarea = screen.visible_area();
+	float xscale = 1.0f / (65536 * visarea.width());
+	float yscale = 1.0f / (65536 * visarea.height());
+	float xoffs = (float)visarea.min_x;
+	float yoffs = (float)visarea.min_y;
+
+	point *curpoint;
+	int lastx = 0;
+	int lasty = 0;
+
+	curpoint = m_vector_list.get();
+
+	screen.container().empty();
+	screen.container().add_rect(0.0f, 0.0f, 1.0f, 1.0f, rgb_t(0xff,0x00,0x00,0x00), PRIMFLAG_BLENDMODE(BLENDMODE_ALPHA) | PRIMFLAG_VECTORBUF(1));
+
+	float m1,m2,m3,m4;
+	m1=m2=m3=m4=0.0f;
+
+	char buffer[OSC_BUFFER_SIZE];
+    osc::OutboundPacketStream p( buffer, OSC_BUFFER_SIZE );
+
+
+    int MAX_PACKETS=OSC_BUFFER_SIZE/(OSC_PACKET_LENGTH*sizeof(float));
+
+    //theres a limit of ~54000 bytes for a udp packet this way
+    //hmm, this is failing with far less, like 14k
+
+    int recorded=0;
+
+    float oscdata[m_vector_index*5];
+    int osccounter=0;
+
+	for (int i = 0; i < m_vector_index; i++)
+	{
+		render_bounds coords;
+
+		float intensity = (float)curpoint->intensity / 255.0f;
+		float intensity_weight = normalized_sigmoid(intensity, vector_options::s_beam_intensity_weight);
+
+		// check for static intensity
+		float beam_width = m_min_intensity == m_max_intensity
+			? vector_options::s_beam_width_min
+			: vector_options::s_beam_width_min + intensity_weight * (vector_options::s_beam_width_max - vector_options::s_beam_width_min);
+
+		// normalize width
+		beam_width *= 1.0f / (float)VECTOR_WIDTH_DENOM;
+
+		coords.x0 = ((float)lastx - xoffs) * xscale;
+		coords.y0 = ((float)lasty - yoffs) * yscale;
+		coords.x1 = ((float)curpoint->x - xoffs) * xscale;
+		coords.y1 = ((float)curpoint->y - yoffs) * yscale;
+
+		if (coords.x0<m1) m1=coords.x0;
+		if (coords.y0<m2) m2=coords.y0;
+		if (coords.x0>m3) m3=coords.x0;
+		if (coords.y0>m4) m4=coords.y0;
+
+		if ((recorded<MAX_PACKETS)&&((coords.x0!=coords.x1)||(coords.y0!=coords.y1))){
+			oscdata[osccounter]=(coords.x0);
+			oscdata[++osccounter]=(coords.y0);
+			oscdata[++osccounter]=(beam_width);
+			*((uint32_t*)(&oscdata[++osccounter]))=(osc::int32)((curpoint->intensity << 24) | (curpoint->col & 0xffffff));
+			osccounter++;
+			//p <<  coords.x1 << coords.y1 << beam_width;
+			//p << 1.0f; //(osc::int32)((curpoint->intensity << 24) | (curpoint->col & 0xffffff));
+			recorded++;
+		}
+
+		if (curpoint->intensity != 0)
+		{
+			screen.container().add_line(
+				coords.x0, coords.y0, coords.x1, coords.y1,
+				beam_width,
+				(curpoint->intensity << 24) | (curpoint->col & 0xffffff),
+				flags);
+		}
+
+		lastx = curpoint->x;
+		lasty = curpoint->y;
+
+		curpoint++;
+
+		//std::cout << std::hex << (osc::int32)((curpoint->intensity << 24) | (curpoint->col & 0xffffff)) << std::endl;
+	}
+
+	//(osc::int32)((curpoint->intensity << 24) | (curpoint->col & 0xffffff)
+	
+ /*   
+    Tims-MacBook-Pro:mame tim$ sudo sysctl -w net.inet.udp.maxdgram=65535
+	Password:
+	net.inet.udp.maxdgram: 9216 -> 65535
+ */  
+	osc::Blob points=osc::Blob(oscdata,recorded*sizeof(float)*4);
+
+    p << osc::BeginBundleImmediate << osc::BeginMessage( "/points" ) << recorded << points << osc::EndMessage << osc::EndBundle;
+    
+    transmitSocket.Send( p.Data(), p.Size() );
+
+    //if (recorded<m_vector_index){ 
+	//std::cout << "Capacity: "<< p.Capacity()  << " Sending " << p.Size() << " bytes, " << recorded << " packets of " << m_vector_index << std::endl;
+	//}
+
+	return 0;
+}
diff --git a/oscReceiveExample/mame/vector.h b/oscReceiveExample/mame/vector.h
new file mode 100644
index 0000000..658789e
--- /dev/null
+++ b/oscReceiveExample/mame/vector.h
@@ -0,0 +1,71 @@
+// license:BSD-3-Clause
+// copyright-holders:Brad Oliver,Aaron Giles,Bernd Wiebelt,Allard van der Bas
+#ifndef MAME_VIDEO_VECTOR_H
+#define MAME_VIDEO_VECTOR_H
+
+#pragma once
+
+#include "ip/UdpSocket.h"
+
+class vector_device;
+
+class vector_options
+{
+public:
+	friend class vector_device;
+
+	static float s_flicker;
+	static float s_beam_width_min;
+	static float s_beam_width_max;
+	static float s_beam_intensity_weight;
+
+protected:
+	static void init(emu_options& options);
+};
+
+class vector_device : public device_t, public device_video_interface
+{
+public:
+	template <typename T> static constexpr rgb_t color111(T c) { return rgb_t(pal1bit(c >> 2), pal1bit(c >> 1), pal1bit(c >> 0)); }
+	template <typename T> static constexpr rgb_t color222(T c) { return rgb_t(pal2bit(c >> 4), pal2bit(c >> 2), pal2bit(c >> 0)); }
+	template <typename T> static constexpr rgb_t color444(T c) { return rgb_t(pal4bit(c >> 8), pal4bit(c >> 4), pal4bit(c >> 0)); }
+
+	// construction/destruction
+	vector_device(const machine_config &mconfig, const char *tag, device_t *owner, uint32_t clock);
+
+	uint32_t screen_update(screen_device &screen, bitmap_rgb32 &bitmap, const rectangle &cliprect);
+	void clear_list();
+
+	void add_point(int x, int y, rgb_t color, int intensity);
+
+	// device-level overrides
+	virtual void device_start() override;
+
+private:
+	/* The vertices are buffered here */
+	struct point
+	{
+		point() : x(0), y(0), col(0), intensity(0) { }
+
+		int x; int y;
+		rgb_t col;
+		int intensity;
+	};
+
+	std::unique_ptr<point[]> m_vector_list;
+	int m_vector_index;
+	int m_min_intensity;
+	int m_max_intensity;
+
+	float normalized_sigmoid(float n, float k);
+
+	UdpTransmitSocket transmitSocket;
+};
+
+// device type definition
+DECLARE_DEVICE_TYPE(VECTOR, vector_device)
+
+#define MCFG_VECTOR_ADD(_tag) \
+	MCFG_DEVICE_ADD(_tag, VECTOR, 0)
+
+#endif // MAME_VIDEO_VECTOR_H
diff --git a/oscReceiveExample/src/main.cpp b/oscReceiveExample/src/main.cpp
new file mode 100644
index 0000000..b156efd
--- /dev/null
+++ b/oscReceiveExample/src/main.cpp
@@ -0,0 +1,14 @@
+#include "ofMain.h"
+#include "ofApp.h"
+
+//========================================================================
+int main( ){
+
+	ofSetupOpenGL(640,480, OF_WINDOW);			// <-------- setup the GL context
+
+	// this kicks off the running of my app
+	// can be OF_WINDOW or OF_FULLSCREEN
+	// pass in width and height too:
+	ofRunApp( new ofApp());
+
+}
diff --git a/oscReceiveExample/src/ofApp.cpp b/oscReceiveExample/src/ofApp.cpp
new file mode 100644
index 0000000..b7dbc8f
--- /dev/null
+++ b/oscReceiveExample/src/ofApp.cpp
@@ -0,0 +1,282 @@
+#include "ofApp.h"
+
+//--------------------------------------------------------------
+void ofApp::setup(){
+    // listen on the given port
+    cout << "listening for osc messages on port " << PORT << "\n";
+    receiver.setup(PORT);
+
+/*
+    ofxUDPSettings settings;
+    settings.receiveOn(PORT);
+    settings.blocking = false;
+
+    udpConnection.Setup(settings);
+*/
+    current_msg_string = 0;
+    mouseX = 0;
+    mouseY = 0;
+    mouseButtonState = "";
+
+    ofSetWindowTitle("osc receiver");
+
+    poly.clear();
+
+    //ofSetFrameRate(50);
+
+    copy_polys=1000;
+    create_polys=0;
+
+    ofSetFrameRate(60);
+}
+
+//--------------------------------------------------------------
+void ofApp::update(){
+
+    // hide old messages
+    for(int i = 0; i < NUM_MSG_STRINGS; i++){
+        if(timers[i] < ofGetElapsedTimef()){
+            msg_strings[i] = "";
+        }
+    }
+
+    int received_frames=0;
+    int dumped_frames=0;
+
+    int numpoints=0;
+    ofBuffer buf;
+
+    // check for waiting messages
+    while(receiver.hasWaitingMessages()){
+
+        // get the next message
+        ofxOscMessage m;
+        receiver.getNextMessage(m);
+
+        //cout << "got a message " << m.getAddress() << " args: "<< m.getNumArgs() << std::endl;;
+
+        if(m.getAddress() == "/points"){
+            // both the arguments are float's
+
+            
+
+            //for (int i=0;i<m.getNumArgs();i+=4){
+            //    poly.addVertex(
+            //        m.getArgAsFloat(i)*ofGetScreenWidth(),
+            //        m.getArgAsFloat(i+1)*ofGetScreenWidth(),
+            //        ofColor(m.getArgAsInt32(i+3)));
+            //}
+
+            numpoints=m.getArgAsInt(0);    
+
+            buf=m.getArgAsBlob(1);
+
+            received_frames++;
+
+            //cout << "got a message: " << numpoints << " points, " << buf.size() << " bytes" << std::endl;;
+
+
+        }
+
+        // check for mouse moved message
+        else if(m.getAddress() == "/mouse/position"){
+            // both the arguments are float's
+            mouseXf = m.getArgAsFloat(0);
+            mouseYf = m.getArgAsFloat(1);
+        }
+        // check for mouse button message
+        else if(m.getAddress() == "/mouse/button"){
+            // first argument is int32, second is a string
+            mouseButtonInt = m.getArgAsInt32(0);
+            mouseButtonState = m.getArgAsString(1);
+        }
+        // check for an image being sent (note: the size of the image depends greatly on your network buffer sizes - if an image is too big the message won't come through )
+        else if(m.getAddress() == "/image" ){
+            ofBuffer buffer = m.getArgAsBlob(0);
+            receivedImage.load(buffer);
+        }
+        else{
+            dumped_frames++;
+            // unrecognized message: display on the bottom of the screen
+            string msg_string;
+            msg_string = m.getAddress();
+            msg_string += ":";
+            for(int i = 0; i < m.getNumArgs(); i++){
+                // get the argument type
+                msg_string += " ";
+                msg_string += m.getArgTypeName(i);
+                msg_string += ":";
+                // display the argument - make sure we get the right type
+                if(m.getArgType(i) == OFXOSC_TYPE_INT32){
+                    msg_string += ofToString(m.getArgAsInt32(i));
+                }
+                else if(m.getArgType(i) == OFXOSC_TYPE_FLOAT){
+                    msg_string += ofToString(m.getArgAsFloat(i));
+                }
+                else if(m.getArgType(i) == OFXOSC_TYPE_STRING){
+                    msg_string += m.getArgAsString(i);
+                }
+                else{
+                    msg_string += "unknown";
+                }
+            }
+            // add to the list of strings to display
+            msg_strings[current_msg_string] = msg_string;
+            timers[current_msg_string] = ofGetElapsedTimef() + 5.0f;
+            current_msg_string = (current_msg_string + 1) % NUM_MSG_STRINGS;
+            // clear the next line
+            msg_strings[current_msg_string] = "";
+        }
+
+    }
+
+    //cout << "got " << received_frames << " vector frames ";
+    //if (received_frames){
+    //    cout << poly[0] <<" "<<poly.getColourAt(0);
+    //}
+    //cout << std::endl;
+
+    if (numpoints){
+        poly.clear();
+
+        ofPolyline p;
+
+        char* data=buf.getData();
+
+        int bufpoints=buf.size()/(sizeof(float)*4);
+
+        float* floats=(float*) data; //new float[buf.size()/sizeof(float)];
+        //memcpy(floats,data,buf.size());
+
+        uint32_t* ints=(uint32_t*)(floats);
+
+        //for some reason this maxes out at ~600 points per second???
+        //in the laser show we routinely copy 1000 per frame, at leat 25k?
+
+        for (int i=0;i<min(copy_polys,numpoints);i++){
+            uint8_t* pixel=(uint8_t*)(&ints[i*4+3]);
+            poly.addVertex( //why does this get shite performance? ridiculous
+            floats[i*4]*ofGetWidth(),
+            floats[i*4+1]*ofGetHeight(),
+            ofColor(pixel[2],pixel[1],pixel[0],pixel[3]));
+
+            //cout << floats[i*4] << "," << floats[i*4+1] << " " << std::hex << ofColor(pixel[0],pixel[1],pixel[2],pixel[3]) << std::endl;;
+
+        }
+
+        //delete[] floats;
+
+        stats_message=ofToString(received_frames)+": "+ofToString(poly.size()); //+" dumped: "+ofToString(dumped_frames);
+    
+        unsigned long points_to_dump=0;
+
+        for (int i=0;i<min(points_to_dump,poly.size());i++){
+            std::cout << poly[i].x << "," << poly[i].y << " " << ofToString(poly.getColourAt(i)) << std::endl;
+        }
+    }
+
+/*
+    char udpMessage[100000];
+    if (udpConnection.Receive(udpMessage,100000)){
+        cout << "got a packet "<<  std::endl;;
+
+    }
+*/    
+
+    
+}
+
+
+//--------------------------------------------------------------
+void ofApp::draw(){
+
+    colourPolyline testpoly;
+
+    for (int i=0;i<create_polys;i++) testpoly.addVertex(ofRandom(ofGetWidth()),ofRandom(ofGetHeight()));
+
+    std::stringstream strm;
+    strm << "fps: " << ofGetFrameRate();
+    ofSetWindowTitle(strm.str());
+
+    ofBackground(0,0,0);
+
+    ofSetColor(255,255,255);
+
+    if(poly.size()) poly.drawDebug(SHOWBLACK);
+
+    ofSetColor(255,255,255);
+
+    ofDrawBitmapString(stats_message,10,ofGetHeight()-20);
+
+    ofDrawBitmapString(ofToString(create_polys),10,ofGetHeight()-40);
+
+}
+
+//--------------------------------------------------------------
+void ofApp::keyPressed(int key){
+
+    switch(key){
+        case ',':
+            copy_polys=max(0,copy_polys-10);
+            break;
+        case '.':
+            copy_polys+=10;
+            break;
+        case '<':
+            create_polys=max(0,create_polys-10);
+            break;
+        case '>':
+            create_polys+=10;
+            break;
+    }
+    
+}
+
+//--------------------------------------------------------------
+void ofApp::keyReleased(int key){
+
+}
+
+//--------------------------------------------------------------
+void ofApp::mouseMoved(int x, int y){
+
+}
+
+//--------------------------------------------------------------
+void ofApp::mouseDragged(int x, int y, int button){
+
+}
+
+//--------------------------------------------------------------
+void ofApp::mousePressed(int x, int y, int button){
+}
+
+//--------------------------------------------------------------
+void ofApp::mouseReleased(int x, int y, int button){
+
+}
+
+//--------------------------------------------------------------
+void ofApp::mouseEntered(int x, int y){
+
+}
+
+//--------------------------------------------------------------
+void ofApp::mouseExited(int x, int y){
+
+}
+
+//--------------------------------------------------------------
+void ofApp::windowResized(int w, int h){
+
+}
+
+//--------------------------------------------------------------
+void ofApp::gotMessage(ofMessage msg){
+
+}
+
+//--------------------------------------------------------------
+void ofApp::dragEvent(ofDragInfo dragInfo){
+
+}
diff --git a/oscReceiveExample/src/ofApp.h b/oscReceiveExample/src/ofApp.h
new file mode 100644
index 0000000..bc91852
--- /dev/null
+++ b/oscReceiveExample/src/ofApp.h
@@ -0,0 +1,50 @@
+#pragma once
+
+#include "ofMain.h"
+#include "ofxOsc.h"
+#include "colourPolyline.h"
+
+#define PORT 7070
+#define NUM_MSG_STRINGS 20
+
+class ofApp : public ofBaseApp {
+	public:
+
+		void setup();
+		void update();
+		void draw();
+		~ofApp(){
+			receiver.stop();
+		}
+
+		void keyPressed(int key);
+		void keyReleased(int key);
+		void mouseMoved(int x, int y);
+		void mouseDragged(int x, int y, int button);
+		void mousePressed(int x, int y, int button);
+		void mouseReleased(int x, int y, int button);
+		void mouseEntered(int x, int y);
+		void mouseExited(int x, int y);
+		void windowResized(int w, int h);
+		void dragEvent(ofDragInfo dragInfo);
+		void gotMessage(ofMessage msg);
+
+		ofTrueTypeFont font;
+		ofxOscReceiver receiver;
+
+		int current_msg_string;
+		string msg_strings[NUM_MSG_STRINGS];
+		float timers[NUM_MSG_STRINGS];
+
+		float mouseXf, mouseYf;
+		int mouseButtonInt;
+		string mouseButtonState;
+
+		ofImage receivedImage;
+		colourPolyline poly;
+
+		string stats_message;
+
+		int copy_polys;
+		int create_polys;
+};