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

    {
      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

        channel.connect("testgroup1");
        channel.disconnect();
        channel.connect("testgroup2");
        View view=channel.getView();
        assertEquals(1, view.size());
        assertTrue(view.containsMember(channel.getLocalAddress()));
        channel.close();
        System.out.println("Remaining threads are:");
        Util.printThreads();
    }

View Full Code Here

        channel.connect("testgroup");
        view=channel.getView();
        System.out.println("-- view for channel: " + view);


        assertEquals(2, view.size());
        assertTrue(view.containsMember(channel.getLocalAddress()));
        assertTrue(view.containsMember(coordinator.getLocalAddress()));
        coordinator.close();
        channel.close();
        System.out.println("Remaining threads are:");
        Util.printThreads();

View Full Code Here

        view=channel.getView();
        System.out.println("-- view for channel: " + view);


        assertEquals(2, view.size());
        assertTrue(view.containsMember(channel.getLocalAddress()));
        assertTrue(view.containsMember(coordinator.getLocalAddress()));
        coordinator.close();
        channel.close();
        System.out.println("Remaining threads are:");
        Util.printThreads();
    }

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

               winningPartition = p;
               break;
            }
         }


         if (!winningPartition.containsMember(channel.getAddress())) return true;
      }
      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

   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

            }


            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

               winningPartition = p;
               break;
            }
         }


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


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

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.