X-Git-Url: https://git.quassel-irc.org/?p=quassel.git;a=blobdiff_plain;f=src%2Fcommon%2Fcompressor.h;h=d91032215f736efb350ad933be046f4cb9cee6c7;hp=b8b9e718e6f0d94d05814d0586119fc5bb21ae9d;hb=db5fe27be95654222c02ccd0e5d365b90ad93630;hpb=9ad83fb2c64caf43b3f565cc79def6d43d30a5c1;ds=sidebyside

diff --git a/src/common/compressor.h b/src/common/compressor.h
index b8b9e718..d9103221 100644
--- a/src/common/compressor.h
+++ b/src/common/compressor.h
@@ -25,6 +25,12 @@
 
 class QTcpSocket;
 
+#ifdef HAVE_ZLIB
+    typedef struct z_stream_s *z_streamp;
+#else
+    typedef struct mz_stream_s *z_streamp;
+#endif
+
 class Compressor : public QObject
 {
     Q_OBJECT
@@ -49,6 +55,7 @@ public:
     };
 
     Compressor(QTcpSocket *socket, CompressionLevel level, QObject *parent = 0);
+    ~Compressor();
 
     CompressionLevel compressionLevel() const { return _level; }
 
@@ -61,12 +68,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 +83,12 @@ private:
 
     QByteArray _readBuffer;
     QByteArray _writeBuffer;
+
+    QByteArray _inputBuffer;
+    QByteArray _outputBuffer;
+
+    z_streamp _inflater;
+    z_streamp _deflater;
 };
 
 #endif