1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
#include "Bzip2Compressor.h"
ACE_RCSID (BZIP2,
Bzip2Compressor,
"$Id$")
#include "bzlib.h"
TAO_BEGIN_VERSIONED_NAMESPACE_DECL
namespace TAO
{
Bzip2Compressor::Bzip2Compressor (
::Compression::CompressionLevel compression_level,
::Compression::CompressorFactory_ptr compressor_factory) :
BaseCompressor (compression_level, compressor_factory)
{
}
void
Bzip2Compressor::compress (
const ::Compression::Buffer & source,
::Compression::Buffer & target
)
{
unsigned int max_length =
static_cast <unsigned int> (source.length () * 1.01) + 600;
target.length (static_cast <CORBA::ULong> (max_length));
int const retval = ::BZ2_bzBuffToBuffCompress (reinterpret_cast <char*>(target.get_buffer ()),
&max_length,
reinterpret_cast <char*>(const_cast<CORBA::Octet*>(source.get_buffer ())),
source.length (),
9,
1,
this->compression_level () * 25);
if (retval != BZ_OK)
{
throw ::Compression::CompressionException (retval, "");
}
else
{
target.length (static_cast <CORBA::ULong> (max_length));
}
// Update statistics for this compressor
this->update_stats (source.length (), target.length ());
}
void
Bzip2Compressor::decompress (
const ::Compression::Buffer & source,
::Compression::Buffer & target)
{
unsigned int max_length = static_cast <unsigned int> (target.length ());
// todo, check 0,1 values
int const retval = ::BZ2_bzBuffToBuffDecompress (reinterpret_cast <char*>(target.get_buffer ()),
&max_length,
reinterpret_cast <char*>(const_cast<CORBA::Octet*>(source.get_buffer ())),
source.length (),
0,
1);
if (retval != BZ_OK)
{
throw ::Compression::CompressionException (retval, "");
}
else
{
target.length (static_cast <CORBA::ULong> (max_length));
}
}
}
TAO_END_VERSIONED_NAMESPACE_DECL
|
