From 5bd2c434f63ff4a039e854d647f02ef660c544d1 Mon Sep 17 00:00:00 2001
From: Magnus Auvinen <magnus.auvinen@gmail.com>
Date: Tue, 24 Jul 2007 22:53:43 +0000
Subject: epic commit. removed tga support, removed BGR support. fixed one
 config for editor, server and client, optimized tilemap rendering (this needs
 some cleanup), added tools to fix alpha outline quirk and glitches in the
 tilemap reindering

---
 src/tools/crapnet.cpp | 126 ++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 126 insertions(+)
 create mode 100644 src/tools/crapnet.cpp

(limited to 'src/tools/crapnet.cpp')

diff --git a/src/tools/crapnet.cpp b/src/tools/crapnet.cpp
new file mode 100644
index 00000000..f87803b5
--- /dev/null
+++ b/src/tools/crapnet.cpp
@@ -0,0 +1,126 @@
+#include <baselib/system.h>
+#include <baselib/network.h>
+
+#include <cstdlib>
+
+using namespace baselib;
+
+struct packet
+{
+	packet *prev;
+	packet *next;
+	
+	netaddr4 send_to;
+	int64 timestamp;
+	int id;
+	int data_size;
+	char data[1];
+};
+
+static packet *first = (packet *)0;
+static packet *last = (packet *)0;
+static int current_latency = 0;
+static int debug = 0;
+
+int run(int port, netaddr4 dest)
+{
+	netaddr4 src(0,0,0,0,0);
+	socket_udp4 socket;
+	socket.open(port);
+	char buffer[1024*2];
+	int id = 0;
+	
+	while(1)
+	{
+		// handle incomming packets
+		while(1)
+		{
+			// fetch data
+			netaddr4 from;
+			int bytes = socket.recv(&from, buffer, 1024*2);
+			if(bytes <= 0)
+				break;
+
+			// create new packet				
+			packet *p = (packet *)mem_alloc(sizeof(packet)+bytes, 1);
+
+			if(from == dest)
+				p->send_to = src;
+			else
+			{
+				src = from;
+				p->send_to = dest;
+			}
+
+			// queue packet
+			p->prev = last;
+			p->next = 0;
+			if(last)
+				last->next = p;
+			else
+			{
+				first = p;
+				last = p;
+			}
+			last = p;
+
+			// set data in packet			
+			p->timestamp = time_get();
+			p->data_size = bytes;
+			p->id = id++;
+			mem_copy(p->data, buffer, bytes);
+
+			if(debug)
+				dbg_msg("crapnet", "<< %08d %d.%d.%d.%d:%5d (%d)", p->id, from.ip[0], from.ip[1], from.ip[2], from.ip[3], from.port, p->data_size);
+		}
+		
+		//
+		while(1)
+		{
+			//dbg_msg("crapnet", "%p", first);
+			if(first && (time_get()-first->timestamp) > current_latency)
+			{
+				packet *p = first;
+				first = first->next;
+				if(first)
+					first->prev = 0;
+				else
+					last = 0;
+				
+				if(debug)
+				{
+					dbg_msg("crapnet", ">> %08d %d.%d.%d.%d:%5d (%d)", p->id,
+						p->send_to.ip[0], p->send_to.ip[1],
+						p->send_to.ip[2], p->send_to.ip[3],
+						p->send_to.port, p->data_size);
+				}
+				
+				// send and remove packet
+				//if((rand()%10) != 0) // heavy packetloss
+				socket.send(&p->send_to, p->data, p->data_size);
+				
+				// update lag
+				double flux = rand()/(double)RAND_MAX;
+				int ms_spike = 0;
+				int ms_flux = 100;
+				int ms_ping = 50;
+				current_latency = ((time_freq()*ms_ping)/1000) + (int64)(((time_freq()*ms_flux)/1000)*flux); // 50ms
+				
+				if((p->id%100) == 0)
+					current_latency += (time_freq()*ms_spike)/1000;
+
+				mem_free(p);
+			}
+			else
+				break;
+		}
+		
+		thread_sleep(1);
+	}
+}
+
+int main(int argc, char **argv)
+{
+	run(8302, netaddr4(127,0,0,1,8303));
+	return 0;
+}
-- 
cgit 1.4.1