Package org.apache.catalina.ha

Examples of org.apache.catalina.ha.ClusterManager

488
489
490
491
492
493
494
495
496
497
498
499
500
501
        } finally {
            Thread.currentThread().setContextClassLoader(oldCtxLoader);
            if(manager != null) {
                manager.setDistributable(true);
                if (manager instanceof ClusterManager) {
                    ClusterManager cmanager = (ClusterManager) manager ;
                    cmanager.setDefaultMode(true);
                    cmanager.setName(getManagerName(name,manager));
                    cmanager.setCluster(this);
                }
            }
        }
        return manager;
    }
View Full Code Here
533
534
535
536
537
538
539
540
541
542
543
544
545
546
        }
        // Notify our interested LifecycleListeners
        lifecycle.fireLifecycleEvent(BEFORE_MANAGERREGISTER_EVENT, manager);
        String clusterName = getManagerName(name, manager);
        if (manager instanceof ClusterManager) {
            ClusterManager cmanager = (ClusterManager) manager ;
            cmanager.setName(clusterName);
            cmanager.setCluster(this);
            if(cmanager.isDefaultMode()) transferProperty("manager",cmanager);
        }
        managers.put(clusterName, manager);
        // Notify our interested LifecycleListeners
        lifecycle.fireLifecycleEvent(AFTER_MANAGERREGISTER_EVENT, manager);
    }
View Full Code Here
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
  if (ctxname == null) {
      java.util.Iterator i = managers.keySet().iterator();
      while (i.hasNext()) {
    String key = (String) i.next();
    ClusterManager mgr = (ClusterManager) managers.get(key);
    if (mgr != null) {
        try {
      session = mgr.findSession(sessionId);
        } catch (IOException io) {
      log.error("Session doesn't exist:" + io);
        }
        return session;
    } else {
        //this happens a lot before the system has started
        // up
        if (log.isDebugEnabled())
      log.debug("Context manager doesn't exist:"
          + key);
    }
      }
  } else {
      ClusterManager mgr = (ClusterManager) managers.get(ctxname);
      if (mgr != null) {
    try {
        session = mgr.findSession(sessionId);
    } catch (IOException io) {
        log.error("Session doesn't exist:" + io);
    }
    return session;
      } else if (log.isErrorEnabled())
View Full Code Here
516
517
518
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
   
        if (! (manager instanceof ClusterManager)) {
            log.warn("Manager [ " + manager + "] does not implement ClusterManager, addition to cluster has been aborted.");
            return;
        }
        ClusterManager cmanager = (ClusterManager) manager ;
        cmanager.setDistributable(true);
        // Notify our interested LifecycleListeners
        lifecycle.fireLifecycleEvent(BEFORE_MANAGERREGISTER_EVENT, manager);
        String clusterName = getManagerName(cmanager.getName(), manager);
        cmanager.setName(clusterName);
        cmanager.setCluster(this);
        cmanager.setDefaultMode(false);
   
        managers.put(clusterName, manager);
        // Notify our interested LifecycleListeners
        lifecycle.fireLifecycleEvent(AFTER_MANAGERREGISTER_EVENT, manager);   
    }
View Full Code Here
537
538
539
540
541
542
543
544
545
546
547
548
549
550
     *
     * @see org.apache.catalina.ha.CatalinaCluster#removeManager(java.lang.String,Manager)
     */
    public void removeManager(Manager manager) {
        if (manager != null && manager instanceof ClusterManager ) {
            ClusterManager cmgr = (ClusterManager) manager;
            // Notify our interested LifecycleListeners
            lifecycle.fireLifecycleEvent(BEFORE_MANAGERUNREGISTER_EVENT,manager);
            managers.remove(getManagerName(cmgr.getName(),manager));
            cmgr.setCluster(null);
            // Notify our interested LifecycleListeners
            lifecycle.fireLifecycleEvent(AFTER_MANAGERUNREGISTER_EVENT, manager);
        }
    }
View Full Code Here
519
520
521
522
523
524
525
526
527
528
529
530
531
532
533
534
535
   
        if (! (manager instanceof ClusterManager)) {
            log.warn("Manager [ " + manager + "] does not implement ClusterManager, addition to cluster has been aborted.");
            return;
        }
        ClusterManager cmanager = (ClusterManager) manager ;
        cmanager.setDistributable(true);
        // Notify our interested LifecycleListeners
        fireLifecycleEvent(BEFORE_MANAGERREGISTER_EVENT, manager);
        String clusterName = getManagerName(cmanager.getName(), manager);
        cmanager.setName(clusterName);
        cmanager.setCluster(this);
   
        managers.put(clusterName, cmanager);
        // Notify our interested LifecycleListeners
        fireLifecycleEvent(AFTER_MANAGERREGISTER_EVENT, manager);   
    }
View Full Code Here
540
541
542
543
544
545
546
547
548
549
550
551
552
553
     * @see org.apache.catalina.Cluster#removeManager(Manager)
     */
    @Override
    public void removeManager(Manager manager) {
        if (manager != null && manager instanceof ClusterManager ) {
            ClusterManager cmgr = (ClusterManager) manager;
            // Notify our interested LifecycleListeners
            fireLifecycleEvent(BEFORE_MANAGERUNREGISTER_EVENT,manager);
            managers.remove(getManagerName(cmgr.getName(),manager));
            cmgr.setCluster(null);
            // Notify our interested LifecycleListeners
            fireLifecycleEvent(AFTER_MANAGERUNREGISTER_EVENT, manager);
        }
    }
View Full Code Here
368
369
370
371
372
373
374
375
376
377
378
            ((DeltaSession) catalinaSession).resetDeltaRequest();
        changeRequestSessionID(request, sessionId, newSessionID);

        if (getCluster() != null) {
            // now sending the change to all other clusternodes!
            ClusterManager manager = (ClusterManager)catalinaSession.getManager();
            sendSessionIDClusterBackup(manager,request,sessionId, newSessionID);
        }

        fireLifecycleEvent("After session migration", catalinaSession);
        if (log.isDebugEnabled()) {
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
175
176
177
                if (log.isDebugEnabled())
                    log.debug("Context manager doesn't exist:"
                              + entry.getKey());
            }
        } else {
            ClusterManager mgr = managers.get(ctxname);
            if (mgr != null) {
                try {
                    session = mgr.findSession(sessionId);
                } catch (IOException io) {
                    log.error("Session doesn't exist:" + io);
                }
                return session;
            } else if (log.isErrorEnabled())
View Full Code Here
207
208
209
210
211
212
213
214
215
216
217
            diffLock.unlock();
        }

        public void setOwner(Object owner) {
            if ( owner instanceof ClusterManager && getManager()==null) {
                ClusterManager cm = (ClusterManager)owner;
                this.setManager(cm);
                this.setValid(true);
                this.setPrimarySession(false);
                this.access();
                this.resetDeltaRequest();
View Full Code Here
TOP

Related Classes of org.apache.catalina.ha.ClusterManager

  • org.apache.catalina.ha.authenticator.ClusterSingleSignOnListener
  • org.apache.catalina.ha.session.ClusterSessionListener
  • org.apache.catalina.ha.session.DeltaSession
  • org.apache.catalina.ha.session.JvmRouteBinderValve
  • org.apache.catalina.ha.tcp.ReplicationValve
  • org.apache.catalina.ha.tcp.SimpleTcpCluster
  • org.apache.catalina.storeconfig.CatalinaClusterSF
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.