Kayne Ruse
81 lines
1.4 KiB
C++
81 lines
1.4 KiB
C++
#include "network_queue.hpp"
|
|
#include "service_locator.hpp"
|
|
|
|
#include "udp_network_utility.hpp"
|
|
|
|
#include "SDL/SDL_thread.h"
|
|
|
|
#include <stdexcept>
|
|
#include <deque>
|
|
|
|
static SDL_sem* lock = SDL_CreateSemaphore(1);
|
|
static SDL_Thread* queueThread = nullptr;
|
|
|
|
static std::deque<Packet> queue;
|
|
|
|
static bool running = false;
|
|
|
|
static int networkQueue(void*) {
|
|
UDPNetworkUtility* netUtil = ServiceLocator<UDPNetworkUtility>::Get();
|
|
while(running) {
|
|
SDL_SemWait(lock);
|
|
while(netUtil->Receive()) {
|
|
Packet p;
|
|
memcpy(&p, netUtil->GetInData(), sizeof(Packet));
|
|
p.meta.address = netUtil->GetInPacket()->address;
|
|
queue.push_back(p);
|
|
}
|
|
SDL_SemPost(lock);
|
|
SDL_Delay(10);
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
void BeginQueueThread() {
|
|
if (running) {
|
|
return;
|
|
}
|
|
running = true;
|
|
if (!(queueThread = SDL_CreateThread(networkQueue, nullptr))) {
|
|
throw(std::runtime_error("Failed to create the network thread"));
|
|
}
|
|
}
|
|
|
|
void EndQueueThread() {
|
|
if (!running) {
|
|
return;
|
|
}
|
|
running = false;
|
|
SDL_WaitThread(queueThread, nullptr);
|
|
queueThread = nullptr;
|
|
}
|
|
|
|
void KillQueueThread() {
|
|
if (!running) {
|
|
return;
|
|
}
|
|
running = false;
|
|
SDL_KillThread(queueThread);
|
|
queueThread = nullptr;
|
|
}
|
|
|
|
Packet peekNetworkPacket() {
|
|
SDL_SemWait(lock);
|
|
Packet p;
|
|
if (queue.size() > 0) {
|
|
Packet p = queue[0];
|
|
}
|
|
SDL_SemPost(lock);
|
|
return p;
|
|
}
|
|
|
|
Packet popNetworkPacket() {
|
|
SDL_SemWait(lock);
|
|
Packet p;
|
|
if (queue.size() > 0) {
|
|
p = queue[0];
|
|
queue.pop_front();
|
|
}
|
|
SDL_SemPost(lock);
|
|
return p;
|
|
} |