Examples of com.sun.appserv.util.cache.BaseCache.values()

Class com.sun.appserv.util.cache.BaseCache

Examples of com.sun.appserv.util.cache.BaseCache.values()

com.sun.appserv.util.cache.BaseCache.values()
get an Iterator for the values stored in the cache @returns an Iterator

     * Get the SAS' expat list from the replica cache for all the surviving instances.
     */
    private void getSASExpatIdsFromReplica(ExpatListQueryResults results) {
        //iterate over sip application session replicas
        BaseCache replicatedSipApplicationSessionsCache = getReplicatedSipApplicationSessions();
        Iterator it = replicatedSipApplicationSessionsCache.values();
        long version = -1L;
        while (it.hasNext()) {
            ReplicationState state = (ReplicationState) it.next();
            String sasId = (String) state.getId();
            if (sasId != null) {

View Full Code Here

*/


    void purgeSipSessionsForOwningInstance(String owningInstanceName) {
        List idsToRemove = new ArrayList();
        BaseCache replicatedSipSessionsCache = getReplicatedSipSessions();
        Iterator it = replicatedSipSessionsCache.values();
        while(it.hasNext()) {
            ReplicationState nextState 
                = (ReplicationState)it.next();
            SipSessionExtraParams extraParams =
                SipSessionExtraParams.getDeserializedExtraParams(

View Full Code Here

    }
    
    void purgeServletTimersForOwningInstance(String owningInstanceName) {        
        List idsToRemove = new ArrayList();
        BaseCache replicatedServletTimersCache = getReplicatedServletTimers();
        Iterator it = replicatedServletTimersCache.values();
        while(it.hasNext()) {
            ReplicationState nextState 
                = (ReplicationState)it.next();
            ServletTimerExtraParams extraParams =
                ServletTimerExtraParams.getDeserializedExtraParams(

View Full Code Here

        ReplicationHealthChecker healthChecker = ReplicationHealthChecker.getInstance();
        String correctBuddyReplicaName
            = healthChecker.getReshapeReplicateToInstanceName(null, owningInstanceName, 0L);
        //iterate over http replicas
        BaseCache replicatedSipApplicationSessionsCache = getReplicatedSipApplicationSessions();
        Iterator it = replicatedSipApplicationSessionsCache.values();
        while(it.hasNext()) {
            ReplicationState nextState
                = (ReplicationState)it.next();
            if(!RollingUpgradeUtil.filterOwnership(owningInstanceName, correctBuddyReplicaName, nextState, sessionIdsSet)) {
                //we remove this entry if it is not on the correct replica partner - i.e. it is a zombie

View Full Code Here

        ReplicationHealthChecker healthChecker = ReplicationHealthChecker.getInstance();
        String correctBuddyReplicaName
            = healthChecker.getReshapeReplicateToInstanceName(null, owningInstanceName, 0L);
        //iterate over http replicas
        BaseCache replicatedSipSessionsCache = getReplicatedSipSessions();
        Iterator it = replicatedSipSessionsCache.values();
        while(it.hasNext()) {
            ReplicationState nextState
                = (ReplicationState)it.next();
            if(!RollingUpgradeUtil.filterOwnership(owningInstanceName, correctBuddyReplicaName, nextState, sessionIdsSet)) {
                //we remove this entry if it is not on the correct replica partner - i.e. it is a zombie

View Full Code Here

        ReplicationHealthChecker healthChecker = ReplicationHealthChecker.getInstance();
        String correctBuddyReplicaName
            = healthChecker.getReshapeReplicateToInstanceName(null, owningInstanceName, 0L);
        //iterate over http replicas
        BaseCache replicatedServletTimersCache = getReplicatedServletTimers();
        Iterator it = replicatedServletTimersCache.values();
        while(it.hasNext()) {
            ReplicationState nextState
                = (ReplicationState)it.next();
            if(!RollingUpgradeUtil.filterOwnership(owningInstanceName, correctBuddyReplicaName, nextState, servletTimerIdsSet)) {
                //we remove this entry if it is not on the correct replica partner - i.e. it is a zombie

View Full Code Here

        List<ReplicationState> sessionIds = new ArrayList();
        //using set to avoid dups
        HashSet sessionIdsSet = new HashSet();
        //iterate over sip application session replicas
        BaseCache replicatedSipApplicationSessionsCache = getReplicatedSipApplicationSessions();
        Iterator it = replicatedSipApplicationSessionsCache.values();
        while(it.hasNext()) {
            ReplicationState nextState
                = (ReplicationState)it.next();
            RollingUpgradeUtil.filterOwnershipOfReplicas(owningInstanceName, nextState, sessionIdsSet);
        }

View Full Code Here

0 1 2

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.