Glitch with threading

client/lobby.cpp

@@ -26,10 +26,17 @@ Lobby::Lobby() {
 	serverList.push_back({"bar",{0,0}});
 	serverList.push_back({"foobar",{0,0}});
 
+	queueThread = SDL_CreateThread(networkQueue, nullptr);
+
+	if (!queueThread) {
+		throw(runtime_error("Failed to create the network thread"));
+	}
+
 	BroadcastNetwork();
 }
 
 Lobby::~Lobby() {
+	SDL_KillThread(queueThread);
 #ifdef DEBUG
 	cout << "leaving Lobby" << endl;
 #endif
@@ -44,7 +51,13 @@ void Lobby::FrameStart() {
 }
 
 void Lobby::Update(double delta) {
-	Receive();
+	try {
+		//process all packets on the network queue
+		while(HandlePacket(popNetworkPacket()));
+	}
+	catch(exception& e) {
+		cerr << "Network Error: " << e.what() << endl;
+	}
 }
 
 void Lobby::FrameEnd() {
@@ -126,50 +139,51 @@ void Lobby::KeyUp(SDL_KeyboardEvent const& key) {
 //Utilities
 //-------------------------
 
-void Lobby::Receive() {
-	Packet p;
-	while(netUtil->Receive()) {
-		memcpy(&p, netUtil->GetInData(), sizeof(Packet));
-		switch(p.type) {
-			case PacketType::PING:
-				//quick pong
-				p.type = PacketType::PONG;
-				netUtil->Send(&netUtil->GetInPacket()->address, &p, sizeof(Packet));
-			break;
-			case PacketType::PONG:
-				//
-			break;
-//			case PacketType::BROADCAST_REQUEST:
-//				//
-//			break;
-			case PacketType::BROADCAST_RESPONSE:
-				PushServer(p.broadcastResponse);
-			break;
-//			case PacketType::JOIN_REQUEST:
-//				//
-//			break;
-//			case PacketType::JOIN_RESPONSE:
-//				//
-//			break;
-//			case PacketType::DISCONNECT:
-//				//
-//			break;
-//			case PacketType::SYNCHRONIZE:
-//				//
-//			break;
-//			case PacketType::PLAYER_NEW:
-//				//
-//			break;
-//			case PacketType::PLAYER_DELETE:
-//				//
-//			break;
-//			case PacketType::PLAYER_MOVE:
-//				//
-//			break;
-			default:
-				throw(runtime_error("Failed to recognize the packet type"));
-		}
+int Lobby::HandlePacket(Packet p) {
+	switch(p.type) {
+		case PacketType::NONE:
+			//DO NOTHING
+			return 0;
+		break;
+		case PacketType::PING:
+			//quick pong
+			p.type = PacketType::PONG;
+			netUtil->Send(&netUtil->GetInPacket()->address, &p, sizeof(Packet));
+		break;
+		case PacketType::PONG:
+			//
+		break;
+//		case PacketType::BROADCAST_REQUEST:
+//			//
+//		break;
+		case PacketType::BROADCAST_RESPONSE:
+			PushServer(p.broadcastResponse);
+		break;
+//		case PacketType::JOIN_REQUEST:
+//			//
+//		break;
+//		case PacketType::JOIN_RESPONSE:
+//			//
+//		break;
+//		case PacketType::DISCONNECT:
+//			//
+//		break;
+//		case PacketType::SYNCHRONIZE:
+//			//
+//		break;
+//		case PacketType::PLAYER_NEW:
+//			//
+//		break;
+//		case PacketType::PLAYER_DELETE:
+//			//
+//		break;
+//		case PacketType::PLAYER_MOVE:
+//			//
+//		break;
+		default:
+			throw(runtime_error("Failed to recognize the packet type"));
 	}
+	return 1;
 }
 
 void Lobby::BroadcastNetwork() {

client/lobby.hpp

@@ -4,6 +4,7 @@
 #include "base_scene.hpp"
 #include "service_locator.hpp"
 #include "packet_type.hpp"
+#include "network_queue.hpp"
 
 #include "config_utility.hpp"
 #include "surface_manager.hpp"
@@ -11,6 +12,8 @@
 #include "button.hpp"
 #include "raster_font.hpp"
 
+#include "SDL/SDL_thread.h"
+
 #include <vector>
 #include <string>
 
@@ -40,7 +43,7 @@ protected:
 	void KeyUp(SDL_KeyboardEvent const&);
 
 	//utilities
-	void Receive();
+	int HandlePacket(Packet p);
 	void BroadcastNetwork();
 	void PushServer(BroadcastResponse&);
 
@@ -58,6 +61,8 @@ protected:
 	SDL_Rect listBox;
 	std::vector<ServerEntry> serverList;
 	ServerEntry* selectedServer = nullptr;
+
+	SDL_Thread* queueThread = nullptr;
 };
 
 #endif

libs/common/network_queue.cpp

@@ -1,15 +1,37 @@
 #include "network_queue.hpp"
+#include "service_locator.hpp"
+
+#include "udp_network_utility.hpp"
 
 #include "SDL/SDL_thread.h"
 
 #include <deque>
 
+static SDL_sem* lock = SDL_CreateSemaphore(1);
+
 static std::deque<Packet> queue;
 
 int networkQueue(void*) {
-	//
+	UDPNetworkUtility* netUtil = ServiceLocator<UDPNetworkUtility>::Get();
+	Packet p;
+	for(;;) {
+		SDL_SemWait(lock);
+		while(netUtil->Receive()) {
+			memcpy(&p, netUtil->GetInData(), sizeof(Packet));
+			queue.push_back(p);
+		}
+		SDL_SemPost(lock);
+		SDL_Delay(10);
+	}
 }
 
-Packet getPacket() {
-	//
+Packet popNetworkPacket() {
+	SDL_SemWait(lock);
+	Packet p;
+	if (queue.size() > 0) {
+		Packet p = queue[0];
+		queue.pop_front();
+	}
+	SDL_SemPost(lock);
+	return p;
 }

libs/common/network_queue.hpp

@@ -4,6 +4,6 @@
 #include "packet_type.hpp"
 
 int networkQueue(void*);
-Packet getPacket();
+Packet popNetworkPacket();
 
 #endif