External-Mirrors/keycloak
2
0
Fork 0
mirror of https://github.com/keycloak/keycloak.git synced 2026-01-10 15:32:05 -03:30
Code Issues Packages Projects Releases Wiki Activity

Increase thread sleep time when testing two different locks

Browse Source 
Closes #35448

Signed-off-by: Stefan Guilhen <sguilhen@redhat.com>
This commit is contained in:
Stefan Guilhen 2024-12-04 12:25:19 -03:00 committed by Pedro Igor
parent 944512b32f
commit 6f5077ddcb
1 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
testsuite/model/src/test/java/org/keycloak/testsuite/model/DBLockTest.java
View File

@ -42,6 +42,7 @@ public class DBLockTest extends KeycloakModelTest {
private static final Logger log = Logger.getLogger(DBLockTest.class);
private static final int SLEEP_TIME_MILLIS = 10;
private static final int SLEEP_TIME_MILLIS_FOR_TWO_LOCKS = 50;
private static final int THREADS_COUNT = 20;
private static final int THREADS_COUNT_MEDIUM = 12;
private static final int ITERATIONS_PER_THREAD = 2;
@ -192,7 +193,7 @@ public class DBLockTest extends KeycloakModelTest {
Thread thread = new Thread(() -> {
IntStream.range(0, ITERATIONS_PER_THREAD_LONG).parallel().forEach(j -> {
try {
KeycloakModelUtils.runJobInTransaction(sessionFactory, session1 -> lock(session1, lock, semaphore));
KeycloakModelUtils.runJobInTransaction(sessionFactory, session1 -> lock(session1, lock, semaphore, SLEEP_TIME_MILLIS_FOR_TWO_LOCKS));
} catch (RuntimeException e) {
semaphore.setException(e);
}
@ -255,11 +256,15 @@ public class DBLockTest extends KeycloakModelTest {
}
private void lock(KeycloakSession session, DBLockProvider.Namespace lock, Semaphore semaphore) {
this.lock(session, lock, semaphore, SLEEP_TIME_MILLIS);
}
private void lock(KeycloakSession session, DBLockProvider.Namespace lock, Semaphore semaphore, long sleepTime) {
DBLockProvider dbLock = new DBLockManager(session).getDBLock();
dbLock.waitForLock(lock);
try {
semaphore.increase();
Thread.sleep(SLEEP_TIME_MILLIS);
Thread.sleep(sleepTime);
semaphore.decrease();
} catch (InterruptedException ie) {
throw new RuntimeException(ie);