diff --git a/src/WebSocketSession.cpp b/src/WebSocketSession.cpp index ed1015a8..ff1a4be4 100644 --- a/src/WebSocketSession.cpp +++ b/src/WebSocketSession.cpp @@ -3,6 +3,7 @@ #include "plugin-macros.generated.h" WebSocketSession::WebSocketSession() : + _connectedAt(0), _incomingMessages(0), _outgoingMessages(0), _encoding(0), @@ -15,6 +16,16 @@ WebSocketSession::WebSocketSession() : { } +uint64_t WebSocketSession::ConnectedAt() +{ + return _connectedAt.load(); +} + +void WebSocketSession::SetConnectedAt(uint64_t at); +{ + _connectedAt.store(at); +} + uint64_t WebSocketSession::IncomingMessages() { return _incomingMessages.load(); diff --git a/src/WebSocketSession.h b/src/WebSocketSession.h index 142f4292..5a1c4594 100644 --- a/src/WebSocketSession.h +++ b/src/WebSocketSession.h @@ -9,6 +9,9 @@ class WebSocketSession public: WebSocketSession(); + uint64_t ConnectedAt(); + void SetConnectedAt(uint64_t at); + uint64_t IncomingMessages(); void IncrementIncomingMessages(); @@ -37,6 +40,7 @@ class WebSocketSession void SetEventSubscriptions(uint64_t subscriptions); private: + std::atomic _connectedAt; std::atomic _incomingMessages; std::atomic _outgoingMessages; std::atomic _encoding;