session.h
3.28 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
/*
This file is part of FlashMQ (https://www.flashmq.org)
Copyright (C) 2021 Wiebe Cazemier
FlashMQ is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as
published by the Free Software Foundation, version 3.
FlashMQ is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU Affero General Public License for more details.
You should have received a copy of the GNU Affero General Public
License along with FlashMQ. If not, see <https://www.gnu.org/licenses/>.
*/
#ifndef SESSION_H
#define SESSION_H
#include <memory>
#include <list>
#include <mutex>
#include <set>
#include "forward_declarations.h"
#include "logger.h"
#include "sessionsandsubscriptionsdb.h"
#include "qospacketqueue.h"
#include "publishcopyfactory.h"
class Session
{
#ifdef TESTING
friend class MainTests;
#endif
friend class SessionsAndSubscriptionsDB;
std::weak_ptr<Client> client;
std::string client_id;
std::string username;
QoSPublishQueue qosPacketQueue;
std::set<uint16_t> incomingQoS2MessageIds;
std::set<uint16_t> outgoingQoS2MessageIds;
std::mutex qosQueueMutex;
uint16_t nextPacketId = 0;
/**
* Even though flow control data is not part of the session state, I'm keeping it here because there are already
* mutexes that they can be placed under, saving additional synchronization.
*/
int flowControlCealing = 0xFFFF;
int flowControlQuota = 0xFFFF;
uint32_t sessionExpiryInterval = 0;
uint16_t QoSLogPrintedAtId = 0;
bool destroyOnDisconnect = false;
std::shared_ptr<WillPublish> willPublish;
bool removalQueued = false;
std::chrono::time_point<std::chrono::steady_clock> removalQueuedAt;
Logger *logger = Logger::getInstance();
void increaseFlowControlQuota();
bool requiresQoSQueueing() const;
void increasePacketId();
Session(const Session &other);
public:
Session();
Session(Session &&other) = delete;
~Session();
std::unique_ptr<Session> getCopy() const;
const std::string &getClientId() const { return client_id; }
std::shared_ptr<Client> makeSharedClient() const;
void assignActiveConnection(std::shared_ptr<Client> &client);
void writePacket(PublishCopyFactory ©Factory, const char max_qos);
bool clearQosMessage(uint16_t packet_id, bool qosHandshakeEnds);
void sendAllPendingQosData();
bool hasActiveClient() const;
void clearWill();
std::shared_ptr<WillPublish> &getWill();
void setWill(WillPublish &&pub);
void addIncomingQoS2MessageId(uint16_t packet_id);
bool incomingQoS2MessageIdInTransit(uint16_t packet_id);
bool removeIncomingQoS2MessageId(u_int16_t packet_id);
void addOutgoingQoS2MessageId(uint16_t packet_id);
void removeOutgoingQoS2MessageId(u_int16_t packet_id);
bool getDestroyOnDisconnect() const;
void setSessionProperties(uint16_t clientReceiveMax, uint32_t sessionExpiryInterval, bool clean_start, ProtocolVersion protocol_version);
void setSessionExpiryInterval(uint32_t newVal);
void setQueuedRemovalAt();
uint32_t getSessionExpiryInterval() const;
uint32_t getCurrentSessionExpiryInterval() const;
};
#endif // SESSION_H