30
30
import java .util .stream .LongStream ;
31
31
32
32
import static org .hamcrest .CoreMatchers .equalTo ;
33
- import static org .hamcrest .Matchers .lessThanOrEqualTo ;
34
33
35
34
public class MultiSnapshotTests extends ESTestCase {
36
35
@@ -40,14 +39,8 @@ public void testTrackSeqNoSimpleRange() throws Exception {
40
39
Randomness .shuffle (values );
41
40
for (int i = 0 ; i < 1023 ; i ++) {
42
41
assertThat (bitSet .getAndSet (values .get (i )), equalTo (false ));
43
- assertThat (bitSet .ongoingSetsSize (), equalTo (1L ));
44
- assertThat (bitSet .completeSetsSize (), equalTo (0L ));
45
42
}
46
-
47
43
assertThat (bitSet .getAndSet (values .get (1023 )), equalTo (false ));
48
- assertThat (bitSet .ongoingSetsSize (), equalTo (0L ));
49
- assertThat (bitSet .completeSetsSize (), equalTo (1L ));
50
-
51
44
assertThat (bitSet .getAndSet (between (0 , 1023 )), equalTo (true ));
52
45
assertThat (bitSet .getAndSet (between (1024 , Integer .MAX_VALUE )), equalTo (false ));
53
46
}
@@ -59,7 +52,6 @@ public void testTrackSeqNoDenseRanges() throws Exception {
59
52
long seq = between (0 , 5000 );
60
53
boolean existed = normalSet .add (seq ) == false ;
61
54
assertThat ("SeqNoSet != Set" + seq , bitSet .getAndSet (seq ), equalTo (existed ));
62
- assertThat (bitSet .ongoingSetsSize () + bitSet .completeSetsSize (), lessThanOrEqualTo (5L ));
63
55
});
64
56
}
65
57
@@ -78,12 +70,8 @@ public void testTrackSeqNoMimicTranslogRanges() throws Exception {
78
70
final LongSet normalSet = new LongHashSet ();
79
71
long currentSeq = between (10_000_000 , 1_000_000_000 );
80
72
final int iterations = scaledRandomIntBetween (100 , 2000 );
81
- assertThat (bitSet .completeSetsSize (), equalTo (0L ));
82
- assertThat (bitSet .ongoingSetsSize (), equalTo (0L ));
83
- long totalDocs = 0 ;
84
73
for (long i = 0 ; i < iterations ; i ++) {
85
74
int batchSize = between (1 , 1500 );
86
- totalDocs += batchSize ;
87
75
currentSeq -= batchSize ;
88
76
List <Long > batch = LongStream .range (currentSeq , currentSeq + batchSize )
89
77
.boxed ()
@@ -92,11 +80,7 @@ public void testTrackSeqNoMimicTranslogRanges() throws Exception {
92
80
batch .forEach (seq -> {
93
81
boolean existed = normalSet .add (seq ) == false ;
94
82
assertThat ("SeqNoSet != Set" , bitSet .getAndSet (seq ), equalTo (existed ));
95
- assertThat (bitSet .ongoingSetsSize (), lessThanOrEqualTo (4L ));
96
83
});
97
- assertThat (bitSet .ongoingSetsSize (), lessThanOrEqualTo (2L ));
98
84
}
99
- assertThat (bitSet .completeSetsSize (), lessThanOrEqualTo (totalDocs / 1024 ));
100
- assertThat (bitSet .ongoingSetsSize (), lessThanOrEqualTo (2L ));
101
85
}
102
86
}
0 commit comments