mirrors/keycloak
1
0
Fork 0
mirror of https://github.com/keycloak/keycloak.git synced 2026-01-25 16:42:34 +00:00
Code Issues Packages Projects Releases Wiki Activity

Reuse InfinispanConnectionProvider instances in DefaultInfinispanConnectionProviderFactory (#39263)

Browse Source 
Closes #39253

Signed-off-by: Ryan Emerson <remerson@redhat.com>
This commit is contained in:
Ryan Emerson
2025-04-28 14:54:34 +01:00
committed by GitHub
parent eafe08a73a
commit 7eb7eb286d
1 changed files with 19 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
model/infinispan/src/main/java/org/keycloak/connections/infinispan/DefaultInfinispanConnectionProviderFactory.java
View File

@@ -82,18 +82,13 @@ public class DefaultInfinispanConnectionProviderFactory implements InfinispanCon
private volatile EmbeddedCacheManager cacheManager;
private volatile TopologyInfo topologyInfo;
private volatile RemoteCacheManager remoteCacheManager;
private volatile InfinispanConnectionProvider connectionProvider;
@Override
public InfinispanConnectionProvider create(KeycloakSession session) {
lazyInit(session);
return InfinispanUtils.isRemoteInfinispan() ?
new RemoteInfinispanConnectionProvider(cacheManager, remoteCacheManager, topologyInfo) :
new DefaultInfinispanConnectionProvider(cacheManager, topologyInfo);
return lazyInit(session);
}
/*
@@ -152,22 +147,26 @@ public class DefaultInfinispanConnectionProviderFactory implements InfinispanCon
factory.register(this);
}
protected void lazyInit(KeycloakSession keycloakSession) {
if (cacheManager != null) {
return;
protected InfinispanConnectionProvider lazyInit(KeycloakSession keycloakSession) {
if (connectionProvider != null) {
return connectionProvider;
}
synchronized (this) {
// if cacheManager it not null, the remoteCacheManager must be visible too.
if (cacheManager != null) {
return;
if (connectionProvider != null) {
return connectionProvider;
}
var cm = createEmbeddedCacheManager(keycloakSession);
this.remoteCacheManager = createRemoteCacheManager(keycloakSession);
this.topologyInfo = new TopologyInfo(cm);
injectKeycloakTimeService(cm);
// set cacheManager field last
this.cacheManager = cm;
this.cacheManager = createEmbeddedCacheManager(keycloakSession);
injectKeycloakTimeService(cacheManager);
var topologyInfo = new TopologyInfo(cacheManager);
logger.infof(topologyInfo.toString());
this.remoteCacheManager = createRemoteCacheManager(keycloakSession);
this.connectionProvider = InfinispanUtils.isRemoteInfinispan() ?
new RemoteInfinispanConnectionProvider(cacheManager, remoteCacheManager, topologyInfo) :
new DefaultInfinispanConnectionProvider(cacheManager, topologyInfo);
return connectionProvider;
}
}