org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.ViewChangeListener クラス

org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.ViewChangeListener 連携図

公開メンバ関数
void	viewChanged (ViewChangedEvent event)

非公開メンバ関数
Set< String >	convertAddresses (Collection< Address > addresses)

詳解

関数詳解

convertAddresses()

Set<String> org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.ViewChangeListener.convertAddresses ( Collection< Address >  addresses )

inlineprivate

                                                                            {
            return addresses.stream().map(new Function<Address, String>() {

                @Override
                public String apply(Address address) {
                    return address.toString();
                }

            }).collect(Collectors.toSet());
        }

viewChanged()

void org.keycloak.cluster.infinispan.InfinispanClusterProviderFactory.ViewChangeListener.viewChanged ( ViewChangedEvent  event )

inline

                                                        {
            EmbeddedCacheManager cacheManager = event.getCacheManager();
            Transport transport = cacheManager.getTransport();

            // Coordinator makes sure that entries for outdated nodes are cleaned up
            if (transport != null && transport.isCoordinator()) {

                Set<String> newAddresses = convertAddresses(event.getNewMembers());
                Set<String> removedNodesAddresses = convertAddresses(event.getOldMembers());
                removedNodesAddresses.removeAll(newAddresses);

                if (removedNodesAddresses.isEmpty()) {
                    return;
                }

                logger.debugf("Nodes %s removed from cluster. Removing tasks locked by this nodes", removedNodesAddresses.toString());

                Cache<String, Serializable> cache = cacheManager.getCache(InfinispanConnectionProvider.WORK_CACHE_NAME);

                Iterator<String> toRemove = cache.entrySet().stream().filter(new Predicate<Map.Entry<String, Serializable>>() {

                    @Override
                    public boolean test(Map.Entry<String, Serializable> entry) {
                        if (!(entry.getValue() instanceof LockEntry)) {
                            return false;
                        }

                        LockEntry lock = (LockEntry) entry.getValue();
                        return removedNodesAddresses.contains(lock.getNode());
                    }

                }).map(new Function<Map.Entry<String, Serializable>, String>() {

                    @Override
                    public String apply(Map.Entry<String, Serializable> entry) {
                        return entry.getKey();
                    }

                }).iterator();

                while (toRemove.hasNext()) {
                    String rem = toRemove.next();
                    if (logger.isTraceEnabled()) {
                        logger.tracef("Removing task %s due it's node left cluster", rem);
                    }

                    // If we have task in progress, it needs to be notified
                    notificationsManager.taskFinished(rem, false);

                    cache.remove(rem);
                }
            }
        }

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/doxygen/keycloak/src/keycloak/src/main/java/org/keycloak/cluster/infinispan/InfinispanClusterProviderFactory.java