Skip to content

Commit 3df8b9d

Browse files
committed
fix failing tests
1 parent 8043b6d commit 3df8b9d

2 files changed

Lines changed: 13 additions & 1 deletion

File tree

core/sail/shacl/src/main/java/org/eclipse/rdf4j/sail/shacl/ast/planNodes/FilterByPredicateObject.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,10 @@ public FilterByPredicateObject(SailConnection connection, Resource[] dataGraph,
7373
if (connection instanceof MemoryStoreConnection) {
7474
cache = null;
7575
} else {
76-
cache = CacheBuilder.newBuilder().maximumSize(10000).build();
76+
cache = CacheBuilder.newBuilder()
77+
.concurrencyLevel(Runtime.getRuntime().availableProcessors() * 2)
78+
.maximumSize(10000)
79+
.build();
7780
}
7881

7982
this.connectionsGroup = connectionsGroup;

core/sail/shacl/src/test/java/org/eclipse/rdf4j/sail/shacl/ShutdownDuringValidationIT.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -115,6 +115,7 @@ void tearDown() {
115115
@ParameterizedTest
116116
@MethodSource("sleepTimes")
117117
public void shutdownDuringValidation(int sleepMillis) {
118+
System.out.println(Thread.currentThread() + " shutdownDuringValidation with sleepMillis=" + sleepMillis);
118119
try {
119120
// clear interrupted flag
120121
Thread.interrupted();
@@ -174,6 +175,8 @@ public void shutdownDuringValidation(int sleepMillis) {
174175
@ParameterizedTest
175176
@MethodSource("sleepTimes")
176177
public void shutdownDuringValidationTransactional(int sleepMillis) {
178+
System.out.println(
179+
Thread.currentThread() + " shutdownDuringValidationTransactional with sleepMillis=" + sleepMillis);
177180
try {
178181
// clear interrupted flag
179182
Thread.interrupted();
@@ -239,6 +242,7 @@ public void shutdownDuringValidationTransactional(int sleepMillis) {
239242
@ParameterizedTest
240243
@MethodSource("sleepTimes")
241244
public void shutdownDuringValidationFailure(int sleepMillis) {
245+
System.out.println(Thread.currentThread() + " shutdownDuringValidationFailure with sleepMillis=" + sleepMillis);
242246
try {
243247

244248
// clear interrupted flag
@@ -298,6 +302,8 @@ public void shutdownDuringValidationFailure(int sleepMillis) {
298302
@ParameterizedTest
299303
@MethodSource("sleepTimes")
300304
public void shutdownDuringValidationFailureNonParallel(int sleepMillis) {
305+
System.out.println(
306+
Thread.currentThread() + " shutdownDuringValidationFailureNonParallel with sleepMillis=" + sleepMillis);
301307
try {
302308
// clear interrupted flag
303309
Thread.interrupted();
@@ -358,6 +364,8 @@ public void shutdownDuringValidationFailureNonParallel(int sleepMillis) {
358364
@ParameterizedTest
359365
@MethodSource("sleepTimes")
360366
public void shutdownDuringValidationTransactionalNonParallel(int sleepMillis) {
367+
System.out.println(Thread.currentThread()
368+
+ " shutdownDuringValidationTransactionalNonParallel with sleepMillis=" + sleepMillis);
361369
try {
362370
// clear interrupted flag
363371
boolean interrupted = Thread.interrupted();
@@ -430,6 +438,7 @@ public void shutdownDuringValidationTransactionalNonParallel(int sleepMillis) {
430438

431439
@Test
432440
void nestedInterruptedExceptionShouldBeDetected() {
441+
System.out.println(Thread.currentThread() + " nestedInterruptedExceptionShouldBeDetected");
433442
InterruptedException interruptedException = new InterruptedException("nested");
434443
SailException sailException = new SailException("wrapper", new SailException("inner", interruptedException));
435444
RepositoryException repositoryException = new RepositoryException("top", sailException);

0 commit comments

Comments
 (0)