Examples of org.jgroups.View.containsMember()

org.jgroups.View.containsMember()
returns true, if this view contains a certain member @param mbr - the address of the member, @return true if this view contains the member, false if it doesn'tif the argument mbr is null, this operation returns false

   private List<Address> checkBuddyStatus(List<Address> members)
   {
      Channel ch = configuration.getRuntimeConfig().getChannel();
      View currentView = ch.getView();
      List<Address> deadBuddies = new LinkedList<Address>();
      for (Address a : members) if (!currentView.containsMember(a)) deadBuddies.add(a);
      return deadBuddies;
   }


   // -------------- methods to be called by the tree cache  --------------------

View Full Code Here

   private List<Address> checkBuddyStatus(List<Address> members)
   {
      Channel ch = configuration.getRuntimeConfig().getChannel();
      View currentView = ch.getView();
      List<Address> deadBuddies = new LinkedList<Address>();
      for (Address a : members) if (!currentView.containsMember(a)) deadBuddies.add(a);
      return deadBuddies;
   }


   // -------------- methods to be called by the tree cache  --------------------

View Full Code Here

   private List<Address> checkBuddyStatus(List<Address> members)
   {
      Channel ch = configuration.getRuntimeConfig().getChannel();
      View currentView = ch.getView();
      List<Address> deadBuddies = new LinkedList<Address>();
      for (Address a : members) if (!currentView.containsMember(a)) deadBuddies.add(a);
      return deadBuddies;
   }


   // -------------- methods to be called by the tree cache  --------------------

View Full Code Here

         case Event.VIEW_CHANGE :
            //if this is channel's first view and its the only member of the group then the
            //goal is to pass BLOCK,VIEW,UNBLOCK to application space on the same thread as VIEW.
            View newView = (View) evt.getArg();
            boolean firstView = onViewChange(newView);
            boolean singletonMember = newView.size()==1 && newView.containsMember(localAddress);
            if(firstView && singletonMember){
               passUp(evt);
               synchronized (blockMutex)
               {
                  isBlockingFlushDown = false;

View Full Code Here

               winningPartition = p;
               break;
            }
         }


         return winningPartition == null || !winningPartition.containsMember(channel.getAddress());
      }
      return false;
   }


   public void suspect(org.jgroups.Address suspected_mbr) {

View Full Code Here

   private List<Address> checkBuddyStatus(List<Address> members)
   {
      Channel ch = configuration.getRuntimeConfig().getChannel();
      View currentView = ch.getView();
      List<Address> deadBuddies = new LinkedList<Address>();
      for (Address a : members) if (!currentView.containsMember(a)) deadBuddies.add(a);
      return deadBuddies;
   }


   // -------------- methods to be called by the tree cache  --------------------

View Full Code Here

               winningPartition = p;
               break;
            }
         }


         return winningPartition == null || !winningPartition.containsMember(channel.getAddress());
      }
      return false;
   }


   public void suspect(org.jgroups.Address suspected_mbr) {

View Full Code Here

               winningPartition = p;
               break;
            }
         }


         return winningPartition == null || !winningPartition.containsMember(channel.getAddress());
      }
      return false;
   }


   public void suspect(org.jgroups.Address suspected_mbr) {

View Full Code Here

               winningPartition = p;
               break;
            }
         }


         return winningPartition == null || !winningPartition.containsMember(channel.getAddress());
      }
      return false;
   }


   public void suspect(org.jgroups.Address suspected_mbr) {

View Full Code Here

    {
      View oldView = this.viewReference.getAndSet(view);
      
      for (Address address: view.getMembers())
      {
        if ((oldView == null) || !oldView.containsMember(address))
        {
          this.membershipListener.added(new AddressMember(address));
        }
      }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.