Package org.jboss.ha.framework.interfaces

Examples of org.jboss.ha.framework.interfaces.ClusterNode

323
324
325
326
327
328
329
330
    * @return the discrepancy data. Will return <code>null</code> if no data
    *         for <code>node</code> is stored.
    */
   public TimestampDiscrepancy getTimestampDiscrepancy(String nodeName, boolean allowStatusCheck)
   {
      ClusterNode node = nodesByName.get(nodeName);
      return node == null ? null : getTimestampDiscrepancy(node, allowStatusCheck);
   }
View Full Code Here
631
632
633
634
635
636
637
638
639
640
641
642
      {
         try
         {
            DistributedReplicantManager drm = partition.getDistributedReplicantManager();
            List<ClusterNode> nodes = drm.lookupReplicantsNodes(getServiceHAName());
            ClusterNode coord = (nodes != null && nodes.size() > 0 ? nodes.get(0) : null);
            if (coord != null && coord.equals(partition.getClusterNode()) == false)
            {
               Object rsp = partition.callMethodOnNode(getServiceHAName(), "getDiscrepancies", NULL_ARGS, NULL_TYPES, 60000, coord);
               if (rsp instanceof RemoteDiscrepancies)
               {
                  handleRemoteDiscrepancies((RemoteDiscrepancies) rsp);
View Full Code Here
836
837
838
839
840
841
842
843
844
845
846
   /**
    * Handles a pushRemoteDiscrepancies call from a remote node.
    */
   private void handleRemoteDiscrepancies(RemoteDiscrepancies remote)
   {
      ClusterNode sender = remote.getSender();
      Map<Server, TimestampDiscrepancy> remoteDiscrepancies = remote.getDiscrepancies();
     
      synchronized (discrepancies)
      {
         TimestampDiscrepancy senderDiscrepancy = discrepancies.get(new Server(sender));
View Full Code Here
875
876
877
878
879
880
881
882
883
884
         if (discrepancies.get(key) == null)
         {
            // A node we didn't know about
            discrepancies.put(new Server(key, senderDiscrepancy),
                              new TimestampDiscrepancy(entry.getValue(), senderDiscrepancy));
            ClusterNode node = key.getNode();
            nodesByName.put(node.getName(), node);
         }
      }
   }
View Full Code Here
286
287
288
289
290
291
292
293
      return this.partition == null ? null : this.partition.getPartitionName();
   }

   public String getLocalNodeName()
   {
      ClusterNode localNode = this.partition == null ? null : this.partition.getClusterNode();
      return localNode == null ? null : localNode.getName();
   }
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
   @Override
   public ClusterNode elect(List<ClusterNode> candidates)
   {
      InetSocketAddress sockAddress = this.preferredMaster;
     
      ClusterNode master = null;
     
      // If preferred master is defined and contained in cluster, return it
      if (sockAddress != null)
      {
         InetAddress address = sockAddress.getAddress();
View Full Code Here
1160
1161
1162
1163
1164
1165
1166
1167
1168
            }
         }
        
         if (merge)
         {
            ClusterNode master = (ClusterNode) (newReplicants.size() > 0 ? newReplicants.get(0) : null);
            inSync = (master != null && oldView.contains(master));
         }
      }     
View Full Code Here
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
  
   // ------------------------------------------------------------------ Public
  
   public void unlock(Serializable lockId)
   {
      ClusterNode myself = getLocalClusterNode();
      if (myself == null)
      {
         throw new IllegalStateException("Must call start() before first call to unlock()");
      }
     
      ClusterLockState lockState = getClusterLockState(lockId, false);
     
      if (lockState != null && myself.equals(lockState.getHolder()))
      {
         getLocalHandler().unlockFromCluster(lockId, myself);
         lockState.release();
        
         try
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
  
   // ------------------------------------------------------ ClusterLockManager
  
   public void unlock(Serializable lockId)
   {
      ClusterNode myself = getLocalClusterNode();
      if (myself == null)
      {
         throw new IllegalStateException("Must call start() before first call to unlock()");
      }
     
      ClusterLockState category = getClusterLockState(lockId, false);
     
      if (category != null && myself.equals(category.getHolder()))
      {
         category.invalidate();
         getLocalHandler().unlockFromCluster(lockId, myself);
         removeLockState(category);
      }
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
      long start = System.currentTimeMillis();
      while (left > 0)
      {
         // Another node we lost to who should take precedence
         // over ourself in competition for the lock
         ClusterNode superiorCompetitor = null;
        
         // Only continue if category is unlocked
         if (category.state.compareAndSet(ClusterLockState.State.UNLOCKED, ClusterLockState.State.REMOTE_LOCKING))
         {           
            // Category state is now REMOTE_LOCKING, so other nodes will fail
View Full Code Here
TOP

Related Classes of org.jboss.ha.framework.interfaces.ClusterNode

  • org.jboss.ha.framework.server.ClusterFileTransfer
  • org.jboss.ha.framework.server.HASingletonImpl
  • org.jboss.ha.framework.server.lock.AbstractClusterLockSupport
  • org.jboss.ha.framework.server.lock.NonGloballyExclusiveClusterLockSupport
  • org.jboss.ha.framework.server.lock.SharedLocalYieldingClusterLockManager$LockState
  • org.jboss.ha.framework.server.lock.YieldingGloballyExclusiveClusterLockSupport
  • org.jboss.ha.singleton.HASingletonElectionPolicySimple
  • org.jboss.ha.singleton.PreferredMasterElectionPolicy
  • org.jboss.ha.timestamp.TimestampDiscrepancyService
  • org.jboss.profileservice.cluster.repository.DefaultRepositoryClusteringHandler
    • 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.