natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ninja: fix tests after CASSANDRA-21074 landed

This commit is contained in:
Stefan Miklosovic 2025-12-22 10:32:10 +01:00
parent b08da36770
commit 3c69bd2367
No known key found for this signature in database
GPG Key ID: 32F35CB2F546D93E
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
test/unit/org/apache/cassandra/io/compress/CompressionMetadataTest.java
View File

@ -101,9 +101,10 @@ public class CompressionMetadataTest
byte[] dictBytes = "sample dictionary data for compression".getBytes(); byte[] dictBytes = "sample dictionary data for compression".getBytes();
ZstdCompressionDictionary dictionary = new ZstdCompressionDictionary(dictId, dictBytes); ZstdCompressionDictionary dictionary = new ZstdCompressionDictionary(dictId, dictBytes);
assertThat(dictionary.selfRef().globalCount()).isOne(); assertThat(dictionary.selfRef()).isNull();
CompressionDictionaryCache cache = new CompressionDictionaryCache(); CompressionDictionaryCache cache = new CompressionDictionaryCache();
cache.add(dictionary); cache.add(dictionary);
assertThat(dictionary.selfRef().globalCount()).isOne();
// Verify dictionary is in cache // Verify dictionary is in cache
CompressionDictionary cachedDict = cache.get(dictId); CompressionDictionary cachedDict = cache.get(dictId);
@ -187,10 +188,12 @@ public class CompressionMetadataTest
byte[] dictBytes = "shared dictionary data".getBytes(); byte[] dictBytes = "shared dictionary data".getBytes();
ZstdCompressionDictionary dictionary = new ZstdCompressionDictionary(dictId, dictBytes); ZstdCompressionDictionary dictionary = new ZstdCompressionDictionary(dictId, dictBytes);
assertThat(dictionary.selfRef().globalCount()).isOne(); assertThat(dictionary.selfRef()).isNull();
CompressionDictionaryCache cache = new CompressionDictionaryCache(); CompressionDictionaryCache cache = new CompressionDictionaryCache();
cache.add(dictionary); cache.add(dictionary);
assertThat(dictionary.selfRef().globalCount()).isOne();
// Create multiple CompressionMetadata instances (simulating multiple SSTables) // Create multiple CompressionMetadata instances (simulating multiple SSTables)
Memory memory1 = Memory.allocate(100); Memory memory1 = Memory.allocate(100);
CompressionMetadata metadata1 = new CompressionMetadata( CompressionMetadata metadata1 = new CompressionMetadata(

1
test/unit/org/apache/cassandra/io/compress/ZstdDictionaryCompressorTest.java
View File

@ -281,6 +281,7 @@ public class ZstdDictionaryCompressorTest
{ {
ZstdDictionaryCompressor.invalidateCache(); ZstdDictionaryCompressor.invalidateCache();
ZstdCompressionDictionary closedDict = createTestDictionary(); ZstdCompressionDictionary closedDict = createTestDictionary();
closedDict.initRefLazily();
closedDict.close(); closedDict.close();
// This should throw IllegalStateException // This should throw IllegalStateException