summaryrefslogtreecommitdiffhomepage
path: root/NetEx/NetServer.cpp
diff options
context:
space:
mode:
authorAki <please@ignore.pl>2022-03-27 22:11:07 +0200
committerAki <please@ignore.pl>2022-03-27 22:11:07 +0200
commit1cf689a6ad9d6c5cd29e11a6a96cb075eb2bbbb8 (patch)
tree3b31cdfcefe051a9a31972703b4d738812467abf /NetEx/NetServer.cpp
parent2ba515370864b85bd29b0d23083248c74a868691 (diff)
downloadstarshatter-1cf689a6ad9d6c5cd29e11a6a96cb075eb2bbbb8.zip
starshatter-1cf689a6ad9d6c5cd29e11a6a96cb075eb2bbbb8.tar.gz
starshatter-1cf689a6ad9d6c5cd29e11a6a96cb075eb2bbbb8.tar.bz2
Replaced ThreadSync with stl's mutex
Diffstat (limited to 'NetEx/NetServer.cpp')
-rw-r--r--NetEx/NetServer.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/NetEx/NetServer.cpp b/NetEx/NetServer.cpp
index 7681aa1..665b69b 100644
--- a/NetEx/NetServer.cpp
+++ b/NetEx/NetServer.cpp
@@ -117,7 +117,7 @@ NetServer::Listener()
NetSock* s = sock.accept(&client_addr);
while (s) {
- sync.acquire();
+ sync.lock();
for (int i = 0; i < poolsize; i++) {
if (conn[i] == 0) {
@@ -128,7 +128,7 @@ NetServer::Listener()
}
}
- sync.release();
+ sync.unlock();
// wait for a thread to become not busy
if (s)
@@ -164,9 +164,9 @@ NetServer::Reader(int index)
srand(timeGetTime());
while (!server_shutdown) {
- sync.acquire();
+ sync.lock();
NetSock* s = conn[index];
- sync.release();
+ sync.unlock();
if (s) {
const int MAX_REQUEST = 4096;
@@ -202,10 +202,10 @@ NetServer::Reader(int index)
}
}
- sync.acquire();
+ sync.lock();
delete conn[index];
conn[index] = 0;
- sync.release();
+ sync.unlock();
}
else {
Sleep(5);