Package | Description |
---|---|
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<PingData> |
Discovery.findAllMembers(Promise<JoinRsp> promise) |
java.util.List<View> |
Discovery.findAllViews(Promise<JoinRsp> promise)
Finds the views: sends a GET_MBRS_REQ to all members, waits 'timeout' ms or
until 'num_initial_members' have been retrieved
|
java.util.List<PingData> |
Discovery.findInitialMembers(Promise<JoinRsp> promise)
Finds initial members
|
protected java.util.List<PingData> |
Discovery.findInitialMembers(Promise<JoinRsp> promise,
int num_expected_rsps,
boolean break_on_coord,
boolean return_views_only) |
Constructor and Description |
---|
Discovery.Responses(int num_expected_rsps,
int num_expected_srv_rsps,
boolean break_on_coord_rsp,
Promise<JoinRsp> promise) |
Modifier and Type | Method and Description |
---|---|
void |
GMS.castViewChangeWithDest(View new_view,
Digest digest,
JoinRsp jr,
java.util.Collection<Address> newMembers)
Broadcasts the new view and digest, and waits for acks from all members in the list given as argument.
|
void |
GmsImpl.handleJoinResponse(JoinRsp join_rsp) |
void |
ParticipantGmsImpl.handleJoinResponse(JoinRsp join_rsp)
In case we get a different JOIN_RSP from a previous JOIN_REQ sent by us (as a client), we simply apply the
new view if it is greater than ours
|
void |
ClientGmsImpl.handleJoinResponse(JoinRsp join_rsp) |
void |
GMS.sendJoinResponse(JoinRsp rsp,
Address dest) |
Constructor and Description |
---|
GMS.GmsHeader(byte type,
JoinRsp join_rsp)
Used for JOIN_RSP header
|
Copyright © 1998-2009 Bela Ban / Red Hat. All Rights Reserved.