}
if (!frame.isContinuationFrame())
{
- m_opCode = frame.getOpCode();
+ m_opCode = frame.opCode();
m_isFragmented = !frame.isFinalFrame();
}
quint64 messageLength = (quint64)(m_opCode == QWebSocketProtocol::OC_TEXT) ? m_textMessage.length() : m_binaryMessage.length();
- if ((messageLength + quint64(frame.getPayload().length())) > MAX_MESSAGE_SIZE_IN_BYTES)
+ if ((messageLength + quint64(frame.payload().length())) > MAX_MESSAGE_SIZE_IN_BYTES)
{
clear();
Q_EMIT errorEncountered(QWebSocketProtocol::CC_TOO_MUCH_DATA, tr("Received message is too big."));
if (m_opCode == QWebSocketProtocol::OC_TEXT)
{
- QString frameTxt = m_pTextCodec->toUnicode(frame.getPayload().constData(), frame.getPayload().size(), m_pConverterState);
+ QString frameTxt = m_pTextCodec->toUnicode(frame.payload().constData(), frame.payload().size(), m_pConverterState);
bool failed = (m_pConverterState->invalidChars != 0) || (frame.isFinalFrame() && (m_pConverterState->remainingChars != 0));
if (failed)
{
}
else
{
- m_binaryMessage.append(frame.getPayload());
- Q_EMIT binaryFrameReceived(frame.getPayload(), frame.isFinalFrame());
+ m_binaryMessage.append(frame.payload());
+ Q_EMIT binaryFrameReceived(frame.payload(), frame.isFinalFrame());
}
if (frame.isFinalFrame())
}
else
{
- Q_EMIT errorEncountered(frame.getCloseCode(), frame.getCloseReason());
+ Q_EMIT errorEncountered(frame.closeCode(), frame.closeReason());
clear();
isDone = true;
}
bool QWebSocketDataProcessor::processControlFrame(const QWebSocketFrame &frame)
{
bool mustStopProcessing = true; //control frames never expect additional frames to be processed
- switch (frame.getOpCode())
+ switch (frame.opCode())
{
case QWebSocketProtocol::OC_PING:
{
- Q_EMIT pingReceived(frame.getPayload());
+ Q_EMIT pingReceived(frame.payload());
break;
}
case QWebSocketProtocol::OC_PONG:
{
- Q_EMIT pongReceived(frame.getPayload());
+ Q_EMIT pongReceived(frame.payload());
break;
}
case QWebSocketProtocol::OC_CLOSE:
{
quint16 closeCode = QWebSocketProtocol::CC_NORMAL;
QString closeReason;
- QByteArray payload = frame.getPayload();
+ QByteArray payload = frame.payload();
if (payload.size() == 1) //size is either 0 (no close code and no reason) or >= 2 (at least a close code of 2 bytes)
{
closeCode = QWebSocketProtocol::CC_PROTOCOL_ERROR;
}
default:
{
- qDebug() << "DataProcessor::processControlFrame: Invalid opcode detected:" << static_cast<int>(frame.getOpCode());
+ qDebug() << "DataProcessor::processControlFrame: Invalid opcode detected:" << static_cast<int>(frame.opCode());
//Do nothing
break;
}
/*!
\internal
*/
-QWebSocketProtocol::CloseCode QWebSocketFrame::getCloseCode() const
+QWebSocketProtocol::CloseCode QWebSocketFrame::closeCode() const
{
return m_closeCode;
}
/*!
\internal
*/
-QString QWebSocketFrame::getCloseReason() const
+QString QWebSocketFrame::closeReason() const
{
return m_closeReason;
}
/*!
\internal
*/
-quint32 QWebSocketFrame::getMask() const
+quint32 QWebSocketFrame::mask() const
{
return m_mask;
}
/*!
\internal
*/
-int QWebSocketFrame::getRsv1() const
+int QWebSocketFrame::rsv1() const
{
return m_rsv1;
}
/*!
\internal
*/
-int QWebSocketFrame::getRsv2() const
+int QWebSocketFrame::rsv2() const
{
return m_rsv2;
}
/*!
\internal
*/
-int QWebSocketFrame::getRsv3() const
+int QWebSocketFrame::rsv3() const
{
return m_rsv3;
}
/*!
\internal
*/
-QWebSocketProtocol::OpCode QWebSocketFrame::getOpCode() const
+QWebSocketProtocol::OpCode QWebSocketFrame::opCode() const
{
return m_opCode;
}
/*!
\internal
*/
-QByteArray QWebSocketFrame::getPayload() const
+QByteArray QWebSocketFrame::payload() const
{
return m_payload;
}
#ifndef QWEBSOCKETFRAME_P_H
#define QWEBSOCKETFRAME_P_H
-#include "qwebsocketprotocol.h"
+#include <QString>
+#include <QByteArray>
+#include <limits.h>
-#include <QIODevice>
+#include "qwebsocketprotocol.h"
+#include "qwebsockets_global.h"
QT_BEGIN_NAMESPACE
+class QIODevice;
+
const quint64 MAX_FRAME_SIZE_IN_BYTES = INT_MAX - 1;
const quint64 MAX_MESSAGE_SIZE_IN_BYTES = INT_MAX - 1;
const QWebSocketFrame &operator =(const QWebSocketFrame &other);
- QWebSocketProtocol::CloseCode getCloseCode() const;
- QString getCloseReason() const;
+ QWebSocketProtocol::CloseCode closeCode() const;
+ QString closeReason() const;
bool isFinalFrame() const;
bool isControlFrame() const;
bool isDataFrame() const;
bool isContinuationFrame() const;
bool hasMask() const;
- quint32 getMask() const; //returns 0 if no mask
- int getRsv1() const;
- int getRsv2() const;
- int getRsv3() const;
- QWebSocketProtocol::OpCode getOpCode() const;
- QByteArray getPayload() const;
+ quint32 mask() const; //returns 0 if no mask
+ int rsv1() const;
+ int rsv2() const;
+ int rsv3() const;
+ QWebSocketProtocol::OpCode opCode() const;
+ QByteArray payload() const;
void clear(); //resets all member variables, and invalidates the object