Package | Description |
---|---|
org.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Field and Description |
---|---|
protected Promise<StateTransferResult> |
JChannel.state_promise |
Modifier and Type | Field and Description |
---|---|
protected Promise<Long> |
SEQUENCER.ack_promise
Used for each resent message to wait until the message has been received
|
protected Promise<Map<Address,IpAddress>> |
FD_SOCK.get_cache_promise
Used to rendezvous on GET_CACHE and GET_CACHE_RSP
|
protected Promise<IpAddress> |
FD_SOCK.ping_addr_promise |
Modifier and Type | Field and Description |
---|---|
protected Map<Owner,Tuple<COUNTER.Request,Promise>> |
COUNTER.pending_requests |
Modifier and Type | Method and Description |
---|---|
List<PingData> |
Discovery.findAllViews(Promise<JoinRsp> promise) |
List<PingData> |
Discovery.findInitialMembers(Promise<JoinRsp> promise)
Finds initial members
|
protected List<PingData> |
Discovery.findMembers(Promise<JoinRsp> promise,
int num_expected_rsps,
boolean break_on_coord,
ViewId view_id) |
void |
Discovery.sendDiscoveryRequest(String cluster_name,
Promise promise,
ViewId view_id) |
Constructor and Description |
---|
Responses(int num_expected_rsps,
boolean break_on_coord_rsp,
Promise<JoinRsp> promise) |
Modifier and Type | Field and Description |
---|---|
protected Promise<Long> |
ForwardQueue.ack_promise
Used for each resent message to wait until the message has been received
|
protected Promise<Boolean> |
AckCollector.all_acks_received |
Copyright © 2014 JBoss, a division of Red Hat. All rights reserved.