X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcommon%2Fcompressor.h;h=1360b67860746ef3a216e94d50e1384ee85ecb70;hp=b8b9e718e6f0d94d05814d0586119fc5bb21ae9d;hb=39328183a6a87c6eb10a9dbbffcd5d65bf154a1f;hpb=9ad83fb2c64caf43b3f565cc79def6d43d30a5c1 diff --git a/src/common/compressor.h b/src/common/compressor.h index b8b9e718..1360b678 100644 --- a/src/common/compressor.h +++ b/src/common/compressor.h @@ -1,5 +1,5 @@ /*************************************************************************** - * Copyright (C) 2005-2014 by the Quassel Project * + * Copyright (C) 2005-2018 by the Quassel Project * * devel@quassel-irc.org * * * * This program is free software; you can redistribute it and/or modify * @@ -18,8 +18,9 @@ * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * ***************************************************************************/ -#ifndef COMPRESSOR_H -#define COMPRESSOR_H +#pragma once + +#include #include @@ -48,7 +49,8 @@ public: Flush }; - Compressor(QTcpSocket *socket, CompressionLevel level, QObject *parent = 0); + Compressor(QTcpSocket *socket, CompressionLevel level, QObject *parent = nullptr); + ~Compressor(); CompressionLevel compressionLevel() const { return _level; } @@ -61,12 +63,13 @@ public: signals: void readyRead(); - void error(Compressor::Error errorCode); + void error(Compressor::Error errorCode = StreamError); private slots: void readData(); private: + bool initStreams(); void writeData(); private: @@ -75,6 +78,10 @@ private: QByteArray _readBuffer; QByteArray _writeBuffer; -}; -#endif + QByteArray _inputBuffer; + QByteArray _outputBuffer; + + z_streamp _inflater; + z_streamp _deflater; +};