memartel_loc/SQCSimulator2023
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

440hz

Browse Source
This commit is contained in:
MarcEricMartel 2023-11-24 15:32:53 -05:00
parent 0c1714dd14
commit 775c8cf26f
3 changed files with 11 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
SQCSim-srv/connection.cpp
View File

@ -50,6 +50,7 @@ sockaddr_in* Connection::getAddr() const { return (sockaddr_in*)&m_addr; }
void Connection::getPacks(SOCKET sock) { void Connection::getPacks(SOCKET sock) {
std::vector<char*> lsPck; std::vector<char*> lsPck;
Input in; Input in;
Sync sync;
lsPck = recvPacksFrom(sock, &m_buf, m_addr); lsPck = recvPacksFrom(sock, &m_buf, m_addr);
for (auto& pck : lsPck) { for (auto& pck : lsPck) {
@ -62,6 +63,10 @@ void Connection::getPacks(SOCKET sock) {
m_input_vector.push_back(in); m_input_vector.push_back(in);
} }
break; break;
case SYNC:
if (Deserialize(&sync, pck, &bsize))
m_nsync = true;
break;
default: break; default: break;
} }
} }

2
SQCSim-srv/connection.h
View File

@ -39,6 +39,8 @@ public:
void Run(World* world); void Run(World* world);
void CleanInputManifest(Timestamp time); void CleanInputManifest(Timestamp time);
bool m_nsync = true;
private: private:
std::unordered_map<Timestamp, Input> m_input_manifest; std::unordered_map<Timestamp, Input> m_input_manifest;
std::vector<Input> m_input_vector; std::vector<Input> m_input_vector;

22
SQCSim-srv/server.cpp
View File

@ -200,28 +200,14 @@ void Server::Run() {
sync.timer = m_game.countdown; sync.timer = m_game.countdown;
sendPack<Sync>(conn->getSock(), &sync, &m_buf); sendPack<Sync>(conn->getSock(), &sync, &m_buf);
} }
int clients_ready = 0;
while (clients_ready < players) {
Packet pck = getPack(&m_buf);
if (pck.type != PACKET_TYPE::SYNC) {
Log("Paquet invalide.", true, false);
if (pck.type != PACKET_TYPE::ERR)
netprot::emptyPack(pck);
continue;
}
Sync* sync = (Sync*)pck.ptr;
clients_ready++;
//m_players[sync->sid]
delete sync;
}
while (!endgame) { while (!endgame) {
for (auto& [key, conn] : m_players) { for (auto& [key, conn] : m_players) {
conn->getPacks(m_sock_udp); conn->getPacks(m_sock_udp);
conn->Run(m_world); if (conn->m_nsync) {
conn->sendPacks(m_sock_udp, m_players); conn->Run(m_world);
conn->sendPacks(m_sock_udp, m_players);
}
} }
} }