blob: ed09315fd7723904b2efc459805103f6674248f3 (
plain) (
blame)
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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
|
// SPDX-FileCopyrightText: 2017 Niels Ole Salscheider <niels_ole@salscheider-online.de>
//
// SPDX-License-Identifier: LGPL-2.1-or-later
#ifndef QXMPPSTREAMMANAGEMENT_P_H
#define QXMPPSTREAMMANAGEMENT_P_H
#include "QXmppGlobal.h"
#include "QXmppStanza.h"
#include <QDomDocument>
#include <QXmlStreamWriter>
class QXmppStream;
class QXmppPacket;
//
// W A R N I N G
// -------------
//
// This file is not part of the QXmpp API. It exists for the convenience
// of the QXmppIncomingClient and QXmppOutgoingClient classes.
//
// This header file may change from version to version without notice,
// or even be removed.
//
// We mean it.
//
/// \cond
class QXMPP_AUTOTEST_EXPORT QXmppStreamManagementEnable
{
public:
QXmppStreamManagementEnable(const bool resume = false, const unsigned max = 0);
bool resume() const;
void setResume(const bool resume);
unsigned max() const;
void setMax(const unsigned max);
static bool isStreamManagementEnable(const QDomElement &element);
void parse(const QDomElement &element);
void toXml(QXmlStreamWriter *writer) const;
private:
bool m_resume;
unsigned m_max;
};
class QXMPP_AUTOTEST_EXPORT QXmppStreamManagementEnabled
{
public:
QXmppStreamManagementEnabled(const bool resume = false, const QString id = QString(),
const unsigned max = 0, const QString location = QString());
bool resume() const;
void setResume(const bool resume);
QString id() const;
void setId(const QString id);
unsigned max() const;
void setMax(const unsigned max);
QString location() const;
void setLocation(const QString location);
static bool isStreamManagementEnabled(const QDomElement &element);
void parse(const QDomElement &element);
void toXml(QXmlStreamWriter *writer) const;
private:
bool m_resume;
QString m_id;
unsigned m_max;
QString m_location;
};
class QXMPP_AUTOTEST_EXPORT QXmppStreamManagementResume
{
public:
QXmppStreamManagementResume(const unsigned h = 0, const QString &previd = QString());
unsigned h() const;
void setH(const unsigned h);
QString prevId() const;
void setPrevId(const QString &id);
static bool isStreamManagementResume(const QDomElement &element);
void parse(const QDomElement &element);
void toXml(QXmlStreamWriter *writer) const;
private:
unsigned m_h;
QString m_previd;
};
class QXMPP_AUTOTEST_EXPORT QXmppStreamManagementResumed
{
public:
QXmppStreamManagementResumed(const unsigned h = 0, const QString &previd = QString());
unsigned h() const;
void setH(const unsigned h);
QString prevId() const;
void setPrevId(const QString &id);
static bool isStreamManagementResumed(const QDomElement &element);
void parse(const QDomElement &element);
void toXml(QXmlStreamWriter *writer) const;
private:
unsigned m_h;
QString m_previd;
};
class QXMPP_AUTOTEST_EXPORT QXmppStreamManagementFailed
{
public:
QXmppStreamManagementFailed(const QXmppStanza::Error::Condition error = QXmppStanza::Error::UndefinedCondition);
QXmppStanza::Error::Condition error() const;
void setError(const QXmppStanza::Error::Condition error);
static bool isStreamManagementFailed(const QDomElement &element);
void parse(const QDomElement &element);
void toXml(QXmlStreamWriter *writer) const;
private:
QXmppStanza::Error::Condition m_error;
};
class QXMPP_AUTOTEST_EXPORT QXmppStreamManagementAck
{
public:
QXmppStreamManagementAck(const unsigned seqNo = 0);
unsigned seqNo() const;
void setSeqNo(const unsigned seqNo);
static bool isStreamManagementAck(const QDomElement &element);
void parse(const QDomElement &element);
void toXml(QXmlStreamWriter *writer) const;
private:
unsigned m_seqNo;
};
class QXMPP_AUTOTEST_EXPORT QXmppStreamManagementReq
{
public:
static bool isStreamManagementReq(const QDomElement &element);
static void toXml(QXmlStreamWriter *writer);
};
//
// This manager is used in the QXmppStream. It contains the parts of stream
// management that are shared between server and client connections.
//
class QXmppStreamManager
{
public:
explicit QXmppStreamManager(QXmppStream *stream);
~QXmppStreamManager();
bool enabled() const;
unsigned int lastIncomingSequenceNumber() const;
void handleDisconnect();
void handleStart();
void handlePacketSent(QXmppPacket &packet, bool sentData);
bool handleStanza(const QDomElement &stanza);
void resetCache();
void enableStreamManagement(bool resetSequenceNumber);
void setAcknowledgedSequenceNumber(unsigned int sequenceNumber);
private:
void handleAcknowledgement(const QDomElement &element);
void sendAcknowledgement();
void sendAcknowledgementRequest();
QXmppStream *stream;
bool m_enabled = false;
QMap<unsigned int, QXmppPacket> m_unacknowledgedStanzas;
unsigned int m_lastOutgoingSequenceNumber = 0;
unsigned int m_lastIncomingSequenceNumber = 0;
};
/// \endcond
#endif
|
