kapitan/IXWebSocket
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

disable socket mutex usage in WebSocketTransport

Browse Source
This commit is contained in:
Benjamin Sergeant 2019-05-16 15:46:32 -07:00
parent 58f17ddb09
commit 5a2c070898
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ixwebsocket/IXWebSocketTransport.cpp
View File

@ -142,7 +142,7 @@ namespace ix
std::string errorMsg; std::string errorMsg;
{ {
bool tls = protocol == "wss"; bool tls = protocol == "wss";
std::lock_guard<std::mutex> lock(_socketMutex); // std::lock_guard<std::mutex> lock(_socketMutex);
_socket = createSocket(tls, errorMsg); _socket = createSocket(tls, errorMsg);
if (!_socket) if (!_socket)
@ -174,7 +174,7 @@ namespace ix
std::string errorMsg; std::string errorMsg;
{ {
std::lock_guard<std::mutex> lock(_socketMutex); // std::lock_guard<std::mutex> lock(_socketMutex);
_socket = createSocket(fd, errorMsg); _socket = createSocket(fd, errorMsg);
if (!_socket) if (!_socket)
@ -962,7 +962,7 @@ namespace ix
ssize_t WebSocketTransport::send() ssize_t WebSocketTransport::send()
{ {
std::lock_guard<std::mutex> lock(_socketMutex); // std::lock_guard<std::mutex> lock(_socketMutex);
return _socket->send((char*)&_txbuf[0], _txbuf.size()); return _socket->send((char*)&_txbuf[0], _txbuf.size());
} }
@ -1016,7 +1016,7 @@ namespace ix
void WebSocketTransport::closeSocket() void WebSocketTransport::closeSocket()
{ {
std::lock_guard<std::mutex> lock(_socketMutex); // std::lock_guard<std::mutex> lock(_socketMutex);
_socket->close(); _socket->close();
} }