X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcommon%2Fcompressor.h;h=85817f1f3f6a3ef794e425669e82de0d1a0d2485;hp=b8b9e718e6f0d94d05814d0586119fc5bb21ae9d;hb=bdb3b8a3086fcd871d2a099fa4a40376f4040e6e;hpb=3156b80615b3783bde9399d0925c745fe3af262e;ds=sidebyside diff --git a/src/common/compressor.h b/src/common/compressor.h index b8b9e718..85817f1f 100644 --- a/src/common/compressor.h +++ b/src/common/compressor.h @@ -25,6 +25,8 @@ class QTcpSocket; +typedef struct mz_stream_s *z_streamp; + class Compressor : public QObject { Q_OBJECT @@ -49,6 +51,7 @@ public: }; Compressor(QTcpSocket *socket, CompressionLevel level, QObject *parent = 0); + ~Compressor(); CompressionLevel compressionLevel() const { return _level; } @@ -61,12 +64,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 +79,12 @@ private: QByteArray _readBuffer; QByteArray _writeBuffer; + + QByteArray _inputBuffer; + QByteArray _outputBuffer; + + z_streamp _inflater; + z_streamp _deflater; }; #endif