@@ -3,7 +3,7 @@ use value_log::{
3
3
Compressor , Config , IndexReader , IndexWriter , MockIndex , MockIndexWriter , ValueLog ,
4
4
} ;
5
5
6
- #[ derive( Clone , Default ) ]
6
+ #[ derive( Clone , Debug , Default ) ]
7
7
struct Lz4Compressor ;
8
8
impl Compressor for Lz4Compressor {
9
9
fn compress ( & self , bytes : & [ u8 ] ) -> value_log:: Result < Vec < u8 > > {
@@ -45,9 +45,18 @@ fn compression() -> value_log::Result<()> {
45
45
) ;
46
46
}
47
47
48
+ {
49
+ let segments = value_log. manifest . list_segments ( ) ;
50
+ let segment = segments. first ( ) . unwrap ( ) ;
51
+ assert_eq ! ( segment. meta. compressed_bytes, 32 ) ;
52
+ assert_eq ! ( segment. meta. total_uncompressed_bytes, value. len( ) as u64 ) ;
53
+ }
54
+
48
55
{
49
56
let index_writer = MockIndexWriter ( index. clone ( ) ) ;
50
- value_log. major_compact ( & index, index_writer) ?;
57
+ let bytes_saved = value_log. major_compact ( & index, index_writer) ?;
58
+
59
+ assert_eq ! ( 0 , bytes_saved) ;
51
60
52
61
let vhandle = index. get ( key. as_bytes ( ) ) ?. unwrap ( ) ;
53
62
@@ -57,5 +66,12 @@ fn compression() -> value_log::Result<()> {
57
66
) ;
58
67
}
59
68
69
+ {
70
+ let segments = value_log. manifest . list_segments ( ) ;
71
+ let segment = segments. first ( ) . unwrap ( ) ;
72
+ assert_eq ! ( segment. meta. compressed_bytes, 32 ) ;
73
+ assert_eq ! ( segment. meta. total_uncompressed_bytes, value. len( ) as u64 ) ;
74
+ }
75
+
60
76
Ok ( ( ) )
61
77
}
0 commit comments