From 235dc0292c733bed4297d9bbe6f53efd4cf6015d Mon Sep 17 00:00:00 2001 From: vzikratyi Date: Wed, 24 Jun 2020 17:40:21 +0300 Subject: [PATCH] Small refactoring --- .../server/dao/oauth2/OAuth2ServiceImpl.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/dao/src/main/java/org/thingsboard/server/dao/oauth2/OAuth2ServiceImpl.java b/dao/src/main/java/org/thingsboard/server/dao/oauth2/OAuth2ServiceImpl.java index e23dbf4a20..ca85f79511 100644 --- a/dao/src/main/java/org/thingsboard/server/dao/oauth2/OAuth2ServiceImpl.java +++ b/dao/src/main/java/org/thingsboard/server/dao/oauth2/OAuth2ServiceImpl.java @@ -23,7 +23,6 @@ import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; import com.google.common.util.concurrent.MoreExecutors; import lombok.extern.slf4j.Slf4j; -import org.apache.commons.collections.ListUtils; import org.apache.commons.lang3.tuple.ImmutablePair; import org.apache.commons.lang3.tuple.Pair; import org.springframework.beans.factory.annotation.Autowired; @@ -61,7 +60,7 @@ public class OAuth2ServiceImpl implements OAuth2Service { private static final String SYSTEM_SETTINGS_OAUTH2_VALUE = "value"; private static final String OAUTH2_AUTHORIZATION_PATH_TEMPLATE = "/oauth2/authorization/%s"; - private final ReentrantLock lock = new ReentrantLock(); + private final ReentrantLock cacheWriteLock = new ReentrantLock(); private final Map clientsParams = new ConcurrentHashMap<>(); @Autowired @@ -130,14 +129,14 @@ public class OAuth2ServiceImpl implements OAuth2Service { validate(oAuth2ClientsParams); validateRegistrationIdUniqueness(oAuth2ClientsParams, TenantId.SYS_TENANT_ID); - lock.lock(); + cacheWriteLock.lock(); try { validateRegistrationIdUniqueness(oAuth2ClientsParams, TenantId.SYS_TENANT_ID); AdminSettings clientRegistrationParamsSettings = createSystemAdminSettings(oAuth2ClientsParams); adminSettingsService.saveAdminSettings(TenantId.SYS_TENANT_ID, clientRegistrationParamsSettings); clientsParams.put(TenantId.SYS_TENANT_ID, oAuth2ClientsParams); } finally { - lock.unlock(); + cacheWriteLock.unlock(); } return getSystemOAuth2ClientsParams(TenantId.SYS_TENANT_ID); @@ -149,7 +148,7 @@ public class OAuth2ServiceImpl implements OAuth2Service { validate(oAuth2ClientsParams); validateRegistrationIdUniqueness(oAuth2ClientsParams, tenantId); - lock.lock(); + cacheWriteLock.lock(); try { String adminSettingsId = processTenantAdminSettings(tenantId, oAuth2ClientsParams.getDomainName(), oAuth2ClientsParams.getAdminSettingsId()); oAuth2ClientsParams.setAdminSettingsId(adminSettingsId); @@ -165,7 +164,7 @@ public class OAuth2ServiceImpl implements OAuth2Service { clientsParams.put(tenantId, oAuth2ClientsParams); } finally { - lock.unlock(); + cacheWriteLock.unlock(); } return getTenantOAuth2ClientsParams(tenantId);