GOSTSec/poolserver
1
0
Fork 0
mirror of https://github.com/GOSTSec/poolserver synced 2025-01-15 01:00:10 +00:00
Code Issues Releases Wiki Activity

Prevent multiple thread writes

Browse Source
This commit is contained in:
Intel 2014-05-05 10:32:08 -04:00
parent 43c05ff10e
commit 62fcdc805a
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/server/poolserver/Stratum/Client.h
View File

@ -56,6 +56,8 @@ namespace Stratum
void SendMessage(JSON msg) void SendMessage(JSON msg)
{ {
boost::unique_lock<boost::mutex> lock(_mtxWrite);
std::string data = msg.ToString(); std::string data = msg.ToString();
data += '\n'; data += '\n';
sLog.Debug(LOG_SERVER, "Sending: %s", data.c_str()); sLog.Debug(LOG_SERVER, "Sending: %s", data.c_str());
@ -139,6 +141,7 @@ namespace Stratum
std::string _recvMessage; std::string _recvMessage;
tcp::socket _socket; tcp::socket _socket;
asio::strand _ioStrand; asio::strand _ioStrand;
boost::mutex _mtxWrite;
uint32 _ip; uint32 _ip;
uint64 _id; uint64 _id;