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

hearbeat

Browse Source
This commit is contained in:
Benjamin Sergeant
2019-01-24 12:42:49 -08:00
parent fdbd213fa2
commit 05033714bf
7 changed files with 85 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
ixwebsocket/IXWebSocketTransport.cpp
View File

@ -33,12 +33,16 @@
namespace ix
{
const std::string WebSocketTransport::kHeartBeatPingMessage("ixwebsocket::hearbeat");
const int WebSocketTransport::kDefaultHeartBeatPeriod(-1);
WebSocketTransport::WebSocketTransport() :
_readyState(CLOSED),
_closeCode(0),
_closeWireSize(0),
_enablePerMessageDeflate(false),
_requestInitCancellation(false)
_requestInitCancellation(false),
_heartBeatPeriod(kDefaultHeartBeatPeriod)
{
}
@ -48,10 +52,12 @@ namespace ix
;
}
void WebSocketTransport::configure(const WebSocketPerMessageDeflateOptions& perMessageDeflateOptions)
void WebSocketTransport::configure(const WebSocketPerMessageDeflateOptions& perMessageDeflateOptions,
int hearBeatPeriod)
{
_perMessageDeflateOptions = perMessageDeflateOptions;
_enablePerMessageDeflate = _perMessageDeflateOptions.enabled();
_heartBeatPeriod = hearBeatPeriod;
}
// Client
@ -152,8 +158,14 @@ namespace ix
void WebSocketTransport::poll()
{
_socket->poll(
[this]()
[this](PollResultType pollResult)
{
if (pollResult == PollResultType_Timeout)
{
sendPing(kHeartBeatPingMessage);
return;
}
while (true)
{
int N = (int) _rxbuf.size();
@ -185,7 +197,8 @@ namespace ix
_socket->close();
setReadyState(CLOSED);
}
});
},
_heartBeatPeriod);
}
bool WebSocketTransport::isSendBufferEmpty() const