libre.sh/keycloak-scim
3
0
Fork 0
Code Issues 15 Pull requests Releases 1 Packages Activity Actions

trace log

Browse source
This commit is contained in:
Bill Burke 2016-03-10 13:29:05 -05:00
parent 82ad26189f
commit b0264d528d
1 changed files with 16 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

32
model/infinispan/src/main/java/org/keycloak/models/cache/infinispan/UserCacheSession.java vendored
View file

@ -123,33 +123,33 @@ public class UserCacheSession implements CacheUserProvider {
@Override @Override
public UserModel getUserById(String id, RealmModel realm) { public UserModel getUserById(String id, RealmModel realm) {
logger.infov("getuserById {0}", id); logger.tracev("getuserById {0}", id);
if (isRegisteredForInvalidation(realm, id)) { if (isRegisteredForInvalidation(realm, id)) {
logger.info("registered for invalidation return delegate"); logger.trace("registered for invalidation return delegate");
return getDelegate().getUserById(id, realm); return getDelegate().getUserById(id, realm);
} }
CachedUser cached = cache.get(id, CachedUser.class); CachedUser cached = cache.get(id, CachedUser.class);
if (cached == null) { if (cached == null) {
logger.info("not cached"); logger.trace("not cached");
Long loaded = cache.getCurrentRevision(id); Long loaded = cache.getCurrentRevision(id);
UserModel model = getDelegate().getUserById(id, realm); UserModel model = getDelegate().getUserById(id, realm);
if (model == null) { if (model == null) {
logger.info("delegate returning null"); logger.trace("delegate returning null");
return null; return null;
} }
if (managedUsers.containsKey(id)) { if (managedUsers.containsKey(id)) {
logger.info("return managedusers"); logger.trace("return managedusers");
return managedUsers.get(id); return managedUsers.get(id);
} }
if (invalidations.contains(id)) return model; if (invalidations.contains(id)) return model;
cached = new CachedUser(loaded, realm, model); cached = new CachedUser(loaded, realm, model);
cache.addRevisioned(cached, startupRevision); cache.addRevisioned(cached, startupRevision);
} else if (managedUsers.containsKey(id)) { } else if (managedUsers.containsKey(id)) {
logger.info("return managedusers"); logger.trace("return managedusers");
return managedUsers.get(id); return managedUsers.get(id);
} }
logger.info("returning new cache adapter"); logger.trace("returning new cache adapter");
UserAdapter adapter = new UserAdapter(cached, this, session, realm); UserAdapter adapter = new UserAdapter(cached, this, session, realm);
managedUsers.put(id, adapter); managedUsers.put(id, adapter);
return adapter; return adapter;
@ -165,26 +165,26 @@ public class UserCacheSession implements CacheUserProvider {
@Override @Override
public UserModel getUserByUsername(String username, RealmModel realm) { public UserModel getUserByUsername(String username, RealmModel realm) {
logger.infov("getUserByUsername: {0}", username); logger.tracev("getUserByUsername: {0}", username);
username = username.toLowerCase(); username = username.toLowerCase();
if (realmInvalidations.contains(realm.getId())) { if (realmInvalidations.contains(realm.getId())) {
logger.infov("realmInvalidations"); logger.tracev("realmInvalidations");
return getDelegate().getUserByUsername(username, realm); return getDelegate().getUserByUsername(username, realm);
} }
String cacheKey = getUserByUsernameCacheKey(realm.getId(), username); String cacheKey = getUserByUsernameCacheKey(realm.getId(), username);
if (invalidations.contains(cacheKey)) { if (invalidations.contains(cacheKey)) {
logger.infov("invalidations"); logger.tracev("invalidations");
return getDelegate().getUserByUsername(username, realm); return getDelegate().getUserByUsername(username, realm);
} }
UserListQuery query = cache.get(cacheKey, UserListQuery.class); UserListQuery query = cache.get(cacheKey, UserListQuery.class);
String userId = null; String userId = null;
if (query == null) { if (query == null) {
logger.infov("query null"); logger.tracev("query null");
Long loaded = cache.getCurrentRevision(cacheKey); Long loaded = cache.getCurrentRevision(cacheKey);
UserModel model = getDelegate().getUserByUsername(username, realm); UserModel model = getDelegate().getUserByUsername(username, realm);
if (model == null) { if (model == null) {
logger.infov("model from delegate null"); logger.tracev("model from delegate null");
return null; return null;
} }
userId = model.getId(); userId = model.getId();
@ -192,7 +192,7 @@ public class UserCacheSession implements CacheUserProvider {
cache.addRevisioned(query, startupRevision); cache.addRevisioned(query, startupRevision);
if (invalidations.contains(userId)) return model; if (invalidations.contains(userId)) return model;
if (managedUsers.containsKey(userId)) { if (managedUsers.containsKey(userId)) {
logger.infov("return managed user"); logger.tracev("return managed user");
return managedUsers.get(userId); return managedUsers.get(userId);
} }
@ -201,18 +201,18 @@ public class UserCacheSession implements CacheUserProvider {
cached = new CachedUser(loaded, realm, model); cached = new CachedUser(loaded, realm, model);
cache.addRevisioned(cached, startupRevision); cache.addRevisioned(cached, startupRevision);
} }
logger.info("return new cache adapter"); logger.trace("return new cache adapter");
UserAdapter adapter = new UserAdapter(cached, this, session, realm); UserAdapter adapter = new UserAdapter(cached, this, session, realm);
managedUsers.put(userId, adapter); managedUsers.put(userId, adapter);
return adapter; return adapter;
} else { } else {
userId = query.getUsers().iterator().next(); userId = query.getUsers().iterator().next();
if (invalidations.contains(userId)) { if (invalidations.contains(userId)) {
logger.infov("invalidated cache return delegate"); logger.tracev("invalidated cache return delegate");
return getDelegate().getUserByUsername(username, realm); return getDelegate().getUserByUsername(username, realm);
} }
logger.info("return getUserById"); logger.trace("return getUserById");
return getUserById(userId, realm); return getUserById(userId, realm);
} }
} }