WebSocketSession: Add challenge var

This commit is contained in:
tt2468 2021-04-28 08:52:23 -07:00
parent 98bc18cedd
commit 0f7683af4e
2 changed files with 20 additions and 0 deletions

View File

@ -13,6 +13,19 @@ WebSocketSession::WebSocketSession() :
{ {
} }
std::string WebSocketSession::Challenge()
{
std::lock_guard<std::mutex> lock(challengeMutex);
std::string ret(challenge);
return ret;
}
void WebSocketSession::SetChallenge(std::string challengeString)
{
std::lock_guard<std::mutex> lock(challengeMutex);
challenge = challengeString;
}
uint64_t WebSocketSession::IncomingMessages() uint64_t WebSocketSession::IncomingMessages()
{ {
return incomingMessages.load(); return incomingMessages.load();

View File

@ -1,5 +1,7 @@
#pragma once #pragma once
#include <mutex>
#include <string>
#include <atomic> #include <atomic>
class WebSocketSession class WebSocketSession
@ -7,6 +9,9 @@ class WebSocketSession
public: public:
WebSocketSession(); WebSocketSession();
std::string Challenge();
void SetChallenge(std::string challenge);
uint64_t IncomingMessages(); uint64_t IncomingMessages();
void IncrementIncomingMessages(); void IncrementIncomingMessages();
@ -29,6 +34,8 @@ class WebSocketSession
void SetEventSubscriptions(uint64_t subscriptions); void SetEventSubscriptions(uint64_t subscriptions);
private: private:
std::mutex challengeMutex;
std::string challenge;
std::atomic<uint64_t> incomingMessages; std::atomic<uint64_t> incomingMessages;
std::atomic<uint64_t> outgoingMessages; std::atomic<uint64_t> outgoingMessages;
std::atomic<uint8_t> rpcVersion; std::atomic<uint8_t> rpcVersion;