Skip to content

Commit

Permalink
fixup: flaky tests
Browse files Browse the repository at this point in the history
Signed-off-by: Todd Baert <todd.baert@dynatrace.com>
  • Loading branch information
toddbaert committed Oct 18, 2023
1 parent f35c909 commit 217e733
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 3 deletions.
3 changes: 2 additions & 1 deletion src/main/java/dev/openfeature/sdk/OpenFeatureAPI.java
Original file line number Diff line number Diff line change
Expand Up @@ -305,7 +305,8 @@ void removeHandler(String clientName, ProviderEvent event, Consumer<EventDetails
void addHandler(String clientName, ProviderEvent event, Consumer<EventDetails> handler) {
try (AutoCloseableLock __ = lock.writeLockAutoCloseable()) {
// if the provider is in the state associated with event, run immediately
if (this.providerRepository.getProvider(clientName).getState().matchesEvent(event)) {
if (Optional.ofNullable(this.providerRepository.getProvider(clientName).getState())
.orElse(ProviderState.READY).matchesEvent(event)) {
eventSupport.runHandler(handler, EventDetails.builder().clientName(clientName).build());
}
eventSupport.addClientHandler(clientName, event, handler);
Expand Down
2 changes: 1 addition & 1 deletion src/test/java/dev/openfeature/sdk/EventsTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@

class EventsTest {

private static final int TIMEOUT = 200;
private static final int TIMEOUT = 300;
private static final int INIT_DELAY = TIMEOUT / 2;

@AfterAll
Expand Down
5 changes: 4 additions & 1 deletion src/test/java/dev/openfeature/sdk/LockingTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -12,9 +12,11 @@
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Nested;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.parallel.Isolated;

import dev.openfeature.sdk.internal.AutoCloseableReentrantReadWriteLock;

@Isolated()
class LockingTest {

private static OpenFeatureAPI api;
Expand All @@ -26,11 +28,12 @@ class LockingTest {
@BeforeAll
static void beforeAll() {
api = OpenFeatureAPI.getInstance();
OpenFeatureAPI.getInstance().setProvider("LockingTest", new NoOpProvider());
}

@BeforeEach
void beforeEach() {
client = (OpenFeatureClient) api.getClient();
client = (OpenFeatureClient) api.getClient("LockingTest");

apiLock = setupLock(apiLock, mockInnerReadLock(), mockInnerWriteLock());
OpenFeatureAPI.lock = apiLock;
Expand Down

0 comments on commit 217e733

Please sign in to comment.