Skip to content

Commit 1a36b6b

Browse files
committed
refactor: replace try/catch blocks with assertThrows for exception testing
Signed-off-by: Rian-Ismael <rian.melo@ccc.ufcg.edu.br>
1 parent 869f248 commit 1a36b6b

2 files changed

Lines changed: 26 additions & 30 deletions

File tree

janusgraph-backend-testutils/src/main/java/org/janusgraph/diskstorage/log/LogTest.java

Lines changed: 22 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -146,6 +146,28 @@ public void testLogIsDurableAcrossReopenSerial() throws Exception {
146146
assertEquals(3L, count.totalValue.get());
147147
}
148148

149+
@Test
150+
public void testSeparateReadersAndLogsInSharedManager() throws Exception {
151+
final int n = 5;
152+
Log[] logs = new Log[n];
153+
CountingReader[] counts = new CountingReader[n];
154+
for (int i = 0; i < n; i++) {
155+
counts[i] = new CountingReader(1, true);
156+
logs[i] = manager.openLog("loner" + i);
157+
}
158+
for (int i = 0; i < n; i++) {
159+
logs[i].registerReader(ReadMarker.fromNow(),counts[i]);
160+
logs[i].add(BufferUtil.getLongBuffer(1L << (i + 1)));
161+
}
162+
// Check message receipt.
163+
for (int i = 0; i < n; i++) {
164+
log.debug("Awaiting CountingReader[{}]", i);
165+
counts[i].await(TIMEOUT_MS);
166+
assertEquals(1L << (i + 1), counts[i].totalValue.get());
167+
assertEquals(1, counts[i].totalMsg.get());
168+
}
169+
}
170+
149171
@Test
150172
@Tag(LogTest.requiresOrderPreserving)
151173
public void testMultipleLogsWithSingleReaderSerial() throws Exception {
@@ -174,28 +196,6 @@ public void testMultipleLogsWithSingleReaderSerial() throws Exception {
174196
assertEquals(value - 1, count.totalValue.get());
175197
}
176198

177-
@Test
178-
public void testSeparateReadersAndLogsInSharedManager() throws Exception {
179-
final int n = 5;
180-
Log[] logs = new Log[n];
181-
CountingReader[] counts = new CountingReader[n];
182-
for (int i = 0; i < n; i++) {
183-
counts[i] = new CountingReader(1, true);
184-
logs[i] = manager.openLog("loner" + i);
185-
}
186-
for (int i = 0; i < n; i++) {
187-
logs[i].registerReader(ReadMarker.fromNow(),counts[i]);
188-
logs[i].add(BufferUtil.getLongBuffer(1L << (i + 1)));
189-
}
190-
// Check message receipt.
191-
for (int i = 0; i < n; i++) {
192-
log.debug("Awaiting CountingReader[{}]", i);
193-
counts[i].await(TIMEOUT_MS);
194-
assertEquals(1L << (i + 1), counts[i].totalValue.get());
195-
assertEquals(1, counts[i].totalMsg.get());
196-
}
197-
}
198-
199199
@Test
200200
@Tag(LogTest.requiresOrderPreserving)
201201
public void testFuzzMessagesSerial() throws Exception {

janusgraph-backend-testutils/src/main/java/org/janusgraph/graphdb/database/management/ManagementTest.java

Lines changed: 4 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,7 @@
2323

2424
import java.util.Set;
2525

26+
import static org.junit.jupiter.api.Assertions.assertThrows;
2627
import static org.junit.jupiter.api.Assertions.fail;
2728

2829
public abstract class ManagementTest extends JanusGraphBaseTest {
@@ -47,14 +48,9 @@ public abstract class ManagementTest extends JanusGraphBaseTest {
4748
public void testReservedNamesRejectedForPropertyKeys() {
4849
for (String s : ILLEGAL_USER_DEFINED_NAMES) {
4950
JanusGraphManagement tm = graph.openManagement();
50-
try {
51-
tm.makePropertyKey(s);
52-
fail("Property key \"" + s + "\" must be rejected");
53-
} catch (IllegalArgumentException e) {
54-
log.debug("Caught expected exception", e);
55-
} finally {
56-
tm.commit();
57-
}
51+
assertThrows(IllegalArgumentException.class, () -> tm.makePropertyKey(s), "Property key \"" + s + "\" must be rejected");
52+
log.debug("Caught expected exception");
53+
tm.commit();
5854
}
5955
}
6056

0 commit comments

Comments
 (0)