2002-08-02 10:01:35 +00:00
|
|
|
#ifndef __CBZIP2_H__
|
|
|
|
#define __CBZIP2_H__
|
|
|
|
|
|
|
|
#include "compressor.h"
|
|
|
|
#include "bzip2/bzlib.h"
|
|
|
|
|
|
|
|
class CBzip2 : public ICompressor {
|
|
|
|
public:
|
|
|
|
int Init(int level) {
|
2004-01-05 14:22:14 +00:00
|
|
|
last_ret = !BZ_STREAM_END;
|
2002-08-02 10:01:35 +00:00
|
|
|
stream = new bz_stream;
|
|
|
|
if (!stream) return BZ_MEM_ERROR;
|
|
|
|
return BZ2_bzCompressInit(stream, level, 0, 30);
|
|
|
|
}
|
|
|
|
|
|
|
|
int End() {
|
|
|
|
int ret = BZ2_bzCompressEnd(stream);
|
|
|
|
delete stream;
|
|
|
|
return ret;
|
|
|
|
}
|
|
|
|
|
|
|
|
int Compress(BOOL finish) {
|
2004-01-05 14:22:14 +00:00
|
|
|
// act like zlib when it comes to stream ending
|
|
|
|
if (last_ret == BZ_STREAM_END)
|
|
|
|
return BZ_STREAM_END;
|
|
|
|
last_ret = BZ2_bzCompress(stream, finish?BZ_FINISH:0);
|
|
|
|
return last_ret;
|
2002-08-02 10:01:35 +00:00
|
|
|
}
|
|
|
|
|
|
|
|
void SetNextIn(char *in, unsigned int size) {
|
|
|
|
stream->next_in = in;
|
|
|
|
stream->avail_in = size;
|
|
|
|
}
|
|
|
|
|
|
|
|
void SetNextOut(char *out, unsigned int size) {
|
|
|
|
stream->next_out = out;
|
|
|
|
stream->avail_out = size;
|
|
|
|
}
|
|
|
|
|
|
|
|
virtual char* GetNextOut() {
|
|
|
|
return stream->next_out;
|
|
|
|
}
|
|
|
|
|
|
|
|
virtual unsigned int GetAvailIn() {
|
|
|
|
return stream->avail_in;
|
|
|
|
}
|
|
|
|
|
|
|
|
virtual unsigned int GetAvailOut() {
|
|
|
|
return stream->avail_out;
|
|
|
|
}
|
|
|
|
|
2003-11-24 00:08:58 +00:00
|
|
|
const char* GetName() {
|
2003-02-07 23:04:25 +00:00
|
|
|
return "bzip2";
|
|
|
|
}
|
|
|
|
|
2002-08-02 10:01:35 +00:00
|
|
|
private:
|
|
|
|
bz_stream *stream;
|
2004-01-05 14:22:14 +00:00
|
|
|
int last_ret;
|
2002-08-02 10:01:35 +00:00
|
|
|
};
|
|
|
|
|
|
|
|
#endif
|