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

rename _blocking to _backgroundThreadRunning and invert the naming

Browse Source
This commit is contained in:
Benjamin Sergeant 2019-04-29 16:54:08 -07:00
parent e37e69311b
commit e3444e666b
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ixwebsocket/IXWebSocket.cpp
View File

@ -38,7 +38,7 @@ namespace ix
WebSocket::WebSocket() :
_onMessageCallback(OnMessageCallback()),
_stop(false),
_blocking(true),
_backgroundThreadRunning(false),
_automaticReconnection(true),
_handshakeTimeoutSecs(kDefaultHandShakeTimeoutSecs),
_enablePong(kDefaultEnablePong),
@ -136,7 +136,7 @@ namespace ix
{
if (_thread.joinable()) return; // we've already been started
_blocking = false;
_backgroundThreadRunning = true;
_thread = std::thread(&WebSocket::run, this);
}
@ -157,8 +157,8 @@ namespace ix
_stop = true;
_thread.join();
_backgroundThreadRunning = false;
_stop = false;
_blocking = true;
_automaticReconnection = automaticReconnection;
}
@ -321,7 +321,7 @@ namespace ix
// an explicit disconnection from the callback, or by the remote end
// closing the connection, ie isConnected() == false.
// closing the connection, ie isConnectedOrClosing() == false.
if (_blocking && !isConnectedOrClosing() && !_automaticReconnection) return;
if (!_backgroundThreadRunning && !isConnected() && !_automaticReconnection) return;
}
}

2
ixwebsocket/IXWebSocket.h
View File

@ -154,7 +154,7 @@ namespace ix
static OnTrafficTrackerCallback _onTrafficTrackerCallback;
std::atomic<bool> _stop;
std::atomic<bool> _blocking;
std::atomic<bool> _backgroundThreadRunning;
std::atomic<bool> _automaticReconnection;
std::thread _thread;
std::mutex _writeMutex;