diff --git a/src/server/poolserver/Stratum/Client.h b/src/server/poolserver/Stratum/Client.h index 8af5183..a929f34 100644 --- a/src/server/poolserver/Stratum/Client.h +++ b/src/server/poolserver/Stratum/Client.h @@ -56,6 +56,8 @@ namespace Stratum void SendMessage(JSON msg) { + boost::unique_lock lock(_mtxWrite); + std::string data = msg.ToString(); data += '\n'; sLog.Debug(LOG_SERVER, "Sending: %s", data.c_str()); @@ -139,6 +141,7 @@ namespace Stratum std::string _recvMessage; tcp::socket _socket; asio::strand _ioStrand; + boost::mutex _mtxWrite; uint32 _ip; uint64 _id;