Gossips this node's pending updates with the given peer.

@param member the peer with which to gossip this node's updates
@param updates the updated members to gossip
359442
private void gossip(SwimMember member, Collection<ImmutableMember> updates) {
    LOGGER.trace("{} - Gossipping updates {} to {}", localMember.id(), updates, member);
    bootstrapService.getUnicastService().unicast(
        member.address(),
        MEMBERSHIP_GOSSIP,
        SERIALIZER.encode(updates));
  }
448273
void synchronizeFromFollower(String peerId)
      throws IOException, TimeoutException, InterruptedException {
    LOG.debug("Begins synchronizing from follower {}.", peerId);
    Zxid lastZxid = persistence.getLatestZxid();
    Message pullTxn = MessageBuilder.buildPullTxnReq(lastZxid);
    LOG.debug("Last zxid of {} is {}", this.serverId, lastZxid);
    sendMessage(peerId, pullTxn);
    // Waits until the synchronization is finished.
    waitForSync(peerId);
  }
24830
@Override
    public synchronized void update(SessionEvent evt) {
        if (evt instanceof NewParticipantEvent) {
            Participant p = ((NewParticipantEvent) evt).getParticipant();
            LOGGER.fine("  - A new participant had just joined: " + p.getCNAME());
        }
    }
1139938
private void updateMember(GossipMember remoteMember, boolean direct) {
    GossipMember localMember = members.get(remoteMember.id());
    if (localMember == null) {
      remoteMember.setActive(true);
      remoteMember.setReachable(true);
      members.put(remoteMember.id(), remoteMember);
      post(new GroupMembershipEvent(GroupMembershipEvent.Type.MEMBER_ADDED, remoteMember));
    } else if (!Objects.equals(localMember.version(), remoteMember.version())) {
      members.remove(localMember.id());
      localMember.setReachable(false);
      post(new GroupMembershipEvent(GroupMembershipEvent.Type.REACHABILITY_CHANGED, localMember));
      localMember.setActive(false);
      post(new GroupMembershipEvent(GroupMembershipEvent.Type.MEMBER_REMOVED, localMember));
      members.put(remoteMember.id(), remoteMember);
      remoteMember.setActive(true);
      remoteMember.setReachable(true);
      post(new GroupMembershipEvent(GroupMembershipEvent.Type.MEMBER_ADDED, remoteMember));
    } else if (!Objects.equals(localMember.properties(), remoteMember.properties())) {
      if (!localMember.isReachable()) {
        localMember.setReachable(true);
        post(new GroupMembershipEvent(GroupMembershipEvent.Type.REACHABILITY_CHANGED, localMember));
      }
      localMember.properties().putAll(remoteMember.properties());
      post(new GroupMembershipEvent(GroupMembershipEvent.Type.METADATA_CHANGED, localMember));
    } else if (!localMember.isReachable() && direct) {
      localMember.setReachable(true);
      localMember.setTerm(localMember.getTerm() + 1);
      post(new GroupMembershipEvent(GroupMembershipEvent.Type.REACHABILITY_CHANGED, localMember));
    } else if (!localMember.isReachable() && remoteMember.getTerm() > localMember.getTerm()) {
      localMember.setReachable(true);
      localMember.setTerm(remoteMember.getTerm());
      post(new GroupMembershipEvent(GroupMembershipEvent.Type.REACHABILITY_CHANGED, localMember));
    }
  }
567599
@ObjectiveCName("changeNotificationsEnabledWithPeer:withValue:")
    public void changeNotificationsEnabled(Peer peer, boolean val) {
        modules.getSettingsModule().changeNotificationsEnabled(peer, val);
    }
552935
void fireMemberAdded(AsteriskQueueMemberImpl member)
    {
        synchronized (listeners)
        {
            for (AsteriskQueueListener listener : listeners)
            {
                try
                {
                    listener.onMemberAdded(member);
                }
                catch (Exception e)
                {
                    logger.warn("Exception in onMemberAdded()", e);
                }
            }
        }
    }
940237
@Override
    public void updateMembers(IEntityGroup eg) throws GroupsException {
        Connection conn = null;
        EntityGroupImpl egi = (EntityGroupImpl) eg;
        if (egi.isDirty())
            try {
                conn = RDBMServices.getConnection();
                setAutoCommit(conn, false);

                try {
                    primUpdateMembers(egi, conn);
                    commit(conn);
                } catch (SQLException sqle) {
                    rollback(conn);
                    throw new GroupsException("Problem updating memberships for " + egi, sqle);
                }
            } catch (SQLException sqlex) {
                throw new GroupsException(sqlex);
            } finally {
                if (conn != null) {
                    try {
                        setAutoCommit(conn, true);
                    } catch (SQLException sqle) {
                        throw new GroupsException(sqle);
                    } finally {
                        RDBMServices.releaseConnection(conn);
                    }
                }
            }
    }
97693
func (gd *GossipDelegate) NotifyUpdate(node *memberlist.Node) {
	nodeName := gd.parseMemberlistNodeName(node.Name)
	logrus.Infof("gossip: Update Notification from %v %v", nodeName, node.Addr)
}
1356539
private void unicast(SwimMember member, ImmutableMember update) {
    bootstrapService.getUnicastService().unicast(
        member.address(),
        MEMBERSHIP_GOSSIP,
        SERIALIZER.encode(Lists.newArrayList(update)));
  }
782078
private void update(Peer peer) {
		String id = peer.getId();
		Peer previous = peers.get(id);
		switch(previous.getStatus()) {
			case ACTIVE:
				timeouts.get(id).cancel(true);
				timeouts.put(id, executor.schedule(new Deactivate(id), delay, MILLISECONDS));
				break;
			case INACTIVE:
				peers.put(peer.getId(), peer);
				timeouts.get(id).cancel(true);
				timeouts.put(id, executor.schedule(new Deactivate(id), delay, MILLISECONDS));
				notifyActive(peer);
				break;
			default:
				String error = "Unexpected peer status: " + previous.getStatus();
				throw new RuntimeException(error);
		}
	}
1093857
function updateConnectedPeer( oSockets )
{
	if ( ! oSockets )
	{
		console.error( `GOSSIPER ))) call updateConnectedPeer with null oSockets.` );
		return 0;
	}
	if ( ! DeUtilsCore.isPlainObject( oSockets ) )
	{
		console.error( `GOSSIPER ))) call updateConnectedPeer with invalid oSockets.` );
		return 0;
	}
	if ( ! DeUtilsCore.isPlainObjectWithKeys( oSockets, 'url' ) )
	{
		console.error( `GOSSIPER ))) call updateConnectedPeer with invalid oSockets, no url property.` );
		return 0;
	}
	if ( ! GossiperUtils.isValidPeerUrl( oSockets.url ) )
	{
		console.error( `GOSSIPER ))) call updateConnectedPeer with invalid oSockets.url: ${ JSON.stringify( oSockets.url ) }.` );
		return 0;
	}


	//
	//	copy the socket to pending memory cache
	//
	_oPendingUpdatePeerSockets[ oSockets.url ] = oSockets;

	if ( _oGossiper )
	{
		//
		//	try to update them
		//
		_oGossiper.updatePeerList( Object.assign( {}, _oPendingUpdatePeerSockets ) );
		_oPendingUpdatePeerSockets = {};
	}
	else
	{
		//
		//	Ops, our gossiper service is not ready yet!
		//	we have added the socket to associated memory cache, they will be safely updated in the future.
		//
	}
}
453292
public void updateReplicasForJoin(TransactionState snapshotTransactionState) {
        long[] replicasAdded = new long[0];
        if (m_term != null) {
            replicasAdded = ((SpTerm) m_term).updateReplicas(snapshotTransactionState);
        }
        m_scheduler.forwardPendingTaskToRejoinNode(replicasAdded, snapshotTransactionState.m_spHandle);
    }
193252
private void nextStatusUpdate() {
		this.nextStatusUpdateNode = NeoUtils.getNextSingleNode(
				this.nextStatusUpdateNode, SocialGraphRelationshipType.UPDATE);

		// load status update time stamp if existing
		if (this.nextStatusUpdateNode != null) {
			this.statusUpdateTimestamp = (long) this.nextStatusUpdateNode
					.getProperty(Properties.StatusUpdate.TIMESTAMP);
		}
	}
474322
private void removeMemberships(Node groupNode, boolean broadcast) throws RepositoryException
   {
      NodeIterator refUsers = groupNode.getNode(JCROrganizationServiceImpl.JOS_MEMBERSHIP).getNodes();
      while (refUsers.hasNext())
      {
         refUsers.nextNode().remove();
      }
   }
1033852
public void setNodeGroupMembers(java.util.Collection<NodeGroupMember> nodeGroupMembers) {
        if (nodeGroupMembers == null) {
            this.nodeGroupMembers = null;
            return;
        }

        this.nodeGroupMembers = new com.amazonaws.internal.SdkInternalList<NodeGroupMember>(nodeGroupMembers);
    }
771230
function (update) {
    LOG.warn('onPosition called, mover: ' + update.ident + ' pos:');
    LOG.warn(update.pos);
    
    // notify client
    LOG.warn('notify: ' + update.to);
    if (l_nodes.hasOwnProperty(update.to)) {
        var node = l_nodes[update.to];
        SR.EventManager.send('NODE_UPDATE', {ident: update.ident, pos: update.pos}, [node.conn.connID]);
    }
}
1310705
private void handleJoinEvent(Node node) {
    GossipMember member = new GossipMember(MemberId.from(node.id().id()), node.address());
    if (!members.containsKey(member.id())) {
      sendHeartbeat(member);
    }
  }