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

               winningPartition = p;
               break;
            }
         }


         if (!winningPartition.containsMember(channel.getAddress())) return true;
      }
      return false;
   }


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

View Full Code Here

/*     */             }
/*     */ 
/* 521 */             for (i = this.val$newView.getMembers().iterator(); i.hasNext(); )
/*     */             {
/* 523 */               Address address = (Address)i.next();
/* 524 */               if ((oldView == null) || (!oldView.containsMember(address)))
/*     */               {
/* 526 */                 this.this$1.this$0.groupListener.nodeJoined(address);
/*     */               }
/*     */             }
/*     */           }

View Full Code Here

               winningPartition = p;
               break;
            }
         }


         if (!winningPartition.containsMember(channel.getAddress())) return true;
      }
      return false;
   }


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

View Full Code Here

                 }
     
                 for (Iterator i = newView.getMembers().iterator(); i.hasNext(); )
                 {
                    Address address = (Address)i.next();
                    if (oldView == null || !oldView.containsMember(address))
                    {
                       groupListener.nodeJoined(address);
                    }
                 }
              }

View Full Code Here

                 }
     
                 for (Iterator i = newView.getMembers().iterator(); i.hasNext(); )
                 {
                    Address address = (Address)i.next();
                    if (oldView == null || !oldView.containsMember(address))
                    {
                       groupListener.nodeJoined(address);
                    }
                 }
              }

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

        channel.disconnect();
        channel.connect(GROUP);
        View view = channel.getView();
        assert view.size() == 2;
        assert view.containsMember(channel.getAddress());
        assert view.containsMember(coordinator.getAddress());
    }
    
    public void testAddInitialHosts() throws Exception {
        coordinator=createTcpgossipChannel("A");
        channel=createTcpgossipChannel("B");

View Full Code Here

        assert p.removeInitialHost(tmp_bind_addr, gossip_router_port);
        p.addInitialHost(tmp_bind_addr, gossip_router_port);
       
        View view = channel.getView();
        assert view.size() == 2;
        assert view.containsMember(channel.getAddress());
        assert view.containsMember(coordinator.getAddress());
    }


    public void testConnectThree() throws Exception {
        JChannel third = null;

View Full Code Here

        p.addInitialHost(tmp_bind_addr, gossip_router_port);
       
        View view = channel.getView();
        assert view.size() == 2;
        assert view.containsMember(channel.getAddress());
        assert view.containsMember(coordinator.getAddress());
    }


    public void testConnectThree() throws Exception {
        JChannel third = null;
        try {

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.