1
1
use test_log:: test;
2
- use value_log:: { Compressor , Config , IndexWriter , MockIndex , MockIndexWriter , ValueLog } ;
2
+ use value_log:: { Compressor , Config , ValueLog } ;
3
3
4
4
#[ derive( Clone , Default ) ]
5
5
struct NoCompressor ;
@@ -19,41 +19,23 @@ fn recovery_mac_ds_store() -> value_log::Result<()> {
19
19
let folder = tempfile:: tempdir ( ) ?;
20
20
let vl_path = folder. path ( ) ;
21
21
22
- let index = MockIndex :: default ( ) ;
23
-
24
- let items = [ "a" , "b" , "c" , "d" , "e" ] ;
25
-
26
22
{
27
23
let value_log = ValueLog :: open ( vl_path, Config :: < NoCompressor > :: default ( ) ) ?;
28
24
29
- {
30
- let mut index_writer = MockIndexWriter ( index. clone ( ) ) ;
31
- let mut writer = value_log. get_writer ( ) ?;
32
-
33
- for key in & items {
34
- let value = key. repeat ( 10_000 ) ;
35
- let value = value. as_bytes ( ) ;
36
-
37
- let key = key. as_bytes ( ) ;
38
-
39
- let vhandle = writer. get_next_value_handle ( ) ;
40
- index_writer. insert_indirect ( key, vhandle, value. len ( ) as u32 ) ?;
41
-
42
- writer. write ( key, value) ?;
43
- }
44
-
45
- value_log. register_writer ( writer) ?;
46
- }
25
+ let mut writer = value_log. get_writer ( ) ?;
26
+ writer. write ( "a" , "a" ) ?;
27
+ value_log. register_writer ( writer) ?;
47
28
}
48
29
49
- {
50
- std:: fs:: File :: create ( vl_path . join ( "segments" ) . join ( ".DS_Store" ) ) ?;
51
- }
30
+ let ds_store = vl_path . join ( "segments" ) . join ( ".DS_Store" ) ;
31
+ std:: fs:: File :: create ( & ds_store ) ?;
32
+ assert ! ( ds_store . try_exists ( ) ? ) ;
52
33
53
34
{
54
35
let value_log = ValueLog :: open ( vl_path, Config :: < NoCompressor > :: default ( ) ) ?;
55
36
assert_eq ! ( 1 , value_log. segment_count( ) ) ;
56
37
}
38
+ assert ! ( ds_store. try_exists( ) ?) ;
57
39
58
40
Ok ( ( ) )
59
41
}
0 commit comments