RomanRom2/whoa
1
0
Fork 0
mirror of https://github.com/whoahq/whoa.git synced 2026-02-01 00:02:45 +03:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

feat(net): add NETEVENTQUEUE dtor

Browse Source
This commit is contained in:
fallenoak 2025-10-10 20:06:58 -05:00
parent 93edfe896e
commit b925836c2c
No known key found for this signature in database
GPG Key ID: 7628F8E61AEA070D
2 changed files with 14 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/net/connection/NetClient.cpp
View File

@ -20,6 +20,10 @@ void InitializePropContext() {
} }
} }
NETEVENTQUEUE::~NETEVENTQUEUE() {
this->Clear();
}
void NETEVENTQUEUE::AddEvent(EVENTID eventId, void* conn, NetClient* client, const void* data, uint32_t bytes) { void NETEVENTQUEUE::AddEvent(EVENTID eventId, void* conn, NetClient* client, const void* data, uint32_t bytes) {
this->m_critSect.Enter(); this->m_critSect.Enter();
@ -43,6 +47,14 @@ void NETEVENTQUEUE::AddEvent(EVENTID eventId, void* conn, NetClient* client, con
this->m_critSect.Leave(); this->m_critSect.Leave();
} }
void NETEVENTQUEUE::Clear() {
this->m_critSect.Enter();
this->m_eventQueue.Clear();
this->m_critSect.Leave();
}
void NETEVENTQUEUE::Poll() { void NETEVENTQUEUE::Poll() {
this->m_critSect.Enter(); this->m_critSect.Enter();

2
src/net/connection/NetClient.hpp
View File

@ -41,7 +41,9 @@ class NETEVENTQUEUE {
NETEVENTQUEUE(NetClient* client) NETEVENTQUEUE(NetClient* client)
: m_client(client) : m_client(client)
{}; {};
~NETEVENTQUEUE();
void AddEvent(EVENTID eventId, void* conn, NetClient* client, const void* data, uint32_t bytes); void AddEvent(EVENTID eventId, void* conn, NetClient* client, const void* data, uint32_t bytes);
void Clear();
void Poll(); void Poll();
}; };