diff options
author | Aki <please@ignore.pl> | 2022-03-27 22:11:07 +0200 |
---|---|---|
committer | Aki <please@ignore.pl> | 2022-03-27 22:11:07 +0200 |
commit | 1cf689a6ad9d6c5cd29e11a6a96cb075eb2bbbb8 (patch) | |
tree | 3b31cdfcefe051a9a31972703b4d738812467abf /NetEx/NetServer.cpp | |
parent | 2ba515370864b85bd29b0d23083248c74a868691 (diff) | |
download | starshatter-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.cpp | 12 |
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); |