@@ -17,7 +17,7 @@ pub fn SegmentMerger(comptime Segment: type) type {
17
17
18
18
const Source = struct {
19
19
reader : Segment.Reader ,
20
- skip_docs : std .AutoHashMap (u32 , void ),
20
+ skip_docs : std .AutoHashMapUnmanaged (u32 , void ) = .{} ,
21
21
22
22
pub fn read (self : * Source ) ! ? Item {
23
23
while (true ) {
@@ -54,7 +54,7 @@ pub fn SegmentMerger(comptime Segment: type) type {
54
54
pub fn deinit (self : * Self ) void {
55
55
for (self .sources .items ) | * source | {
56
56
source .reader .close ();
57
- source .skip_docs .deinit ();
57
+ source .skip_docs .deinit (self . allocator );
58
58
}
59
59
self .sources .deinit ();
60
60
self .segment .docs .deinit (self .allocator );
@@ -64,7 +64,6 @@ pub fn SegmentMerger(comptime Segment: type) type {
64
64
pub fn addSource (self : * Self , source : * Segment ) ! void {
65
65
try self .sources .append (.{
66
66
.reader = source .reader (),
67
- .skip_docs = std .AutoHashMap (u32 , void ).init (self .allocator ),
68
67
});
69
68
}
70
69
@@ -111,7 +110,7 @@ pub fn SegmentMerger(comptime Segment: type) type {
111
110
try self .segment .docs .put (self .allocator , doc_id , doc_status );
112
111
docs_added += 1 ;
113
112
} else {
114
- try source .skip_docs .put (doc_id , {});
113
+ try source .skip_docs .put (self . allocator , doc_id , {});
115
114
}
116
115
}
117
116
if (docs_found > 0 ) {
0 commit comments