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.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.protocols.relay | |
org.jgroups.protocols.rules | |
org.jgroups.stack |
Support for managing protocol stacks.
|
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Method and Description |
---|---|
protected TimeScheduler |
JChannel.getTimer() |
Modifier and Type | Field and Description |
---|---|
protected TimeScheduler |
RELAY.timer |
protected TimeScheduler |
MAKE_BATCH.timer |
protected TimeScheduler |
RSVP.timer |
protected TimeScheduler |
UNICAST.timer
Deprecated.
|
protected TimeScheduler |
MERGE3.timer |
protected TimeScheduler |
FD_SOCK.timer |
protected TimeScheduler |
SHUFFLE.timer |
protected TimeScheduler |
FD.timer |
protected TimeScheduler |
ABP.timer |
protected TimeScheduler |
MERGE2.timer
Deprecated.
|
protected TimeScheduler |
Discovery.timer |
protected TimeScheduler |
UNICAST3.timer |
protected TimeScheduler |
TP.timer |
protected TimeScheduler |
BARRIER.timer |
protected TimeScheduler |
FD_ALL.timer |
protected TimeScheduler |
FD_ALL2.timer |
protected TimeScheduler |
UNICAST2.timer
Deprecated.
|
protected TimeScheduler |
SCOPE.timer
Deprecated.
|
protected TimeScheduler |
FD_HOST.timer
Timer used to run the ping task on
|
Modifier and Type | Method and Description |
---|---|
TimeScheduler |
TP.getTimer() |
TimeScheduler |
UNICAST2.getTimer()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
TP.setTimer(TimeScheduler timer)
Sets a new timer.
|
void |
UNICAST2.setTimer(TimeScheduler timer)
Deprecated.
Only used for unit tests, don't use !
|
Modifier and Type | Field and Description |
---|---|
protected TimeScheduler |
GMS.timer |
protected TimeScheduler |
STABLE.timer |
protected TimeScheduler |
NAKACK2.timer |
Modifier and Type | Method and Description |
---|---|
void |
NAKACK.setTimer(TimeScheduler timer)
Deprecated.
Only used for unit tests, don't use !
|
void |
NAKACK2.setTimer(TimeScheduler timer)
Only used for unit tests, don't use !
|
Modifier and Type | Field and Description |
---|---|
protected TimeScheduler |
RELAY2.timer |
Modifier and Type | Method and Description |
---|---|
TimeScheduler |
RELAY2.getTimer() |
Modifier and Type | Field and Description |
---|---|
protected TimeScheduler |
SUPERVISOR.timer |
Modifier and Type | Field and Description |
---|---|
protected TimeScheduler |
Retransmitter.timer
Deprecated.
|
protected TimeScheduler |
RouterStubManager.timer |
Constructor and Description |
---|
DefaultRetransmitter(Address sender,
Retransmitter.RetransmitCommand cmd,
TimeScheduler sched)
Create a new Retransmitter associated with the given sender address
|
NakReceiverWindow(Address sender,
Retransmitter.RetransmitCommand cmd,
long highest_delivered_seqno,
TimeScheduler sched)
Deprecated.
Creates a new instance with the given retransmit command
|
NakReceiverWindow(Address sender,
Retransmitter.RetransmitCommand cmd,
long highest_delivered_seqno,
TimeScheduler sched,
boolean use_range_based_retransmitter)
Deprecated.
|
NakReceiverWindow(Address sender,
Retransmitter.RetransmitCommand cmd,
long highest_delivered_seqno,
TimeScheduler sched,
boolean use_range_based_retransmitter,
int num_rows,
int msgs_per_row,
double resize_factor,
long max_compaction_time,
boolean automatic_purging)
Deprecated.
|
RangeBasedRetransmitter(Address sender,
Retransmitter.RetransmitCommand cmd,
TimeScheduler sched)
Create a new Retransmitter associated with the given sender address
|
Retransmitter(Address sender,
Retransmitter.RetransmitCommand cmd,
TimeScheduler sched)
Deprecated.
Create a new Retransmitter associated with the given sender address
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultTimeScheduler
Implementation of
TimeScheduler by extending
ScheduledThreadPoolExecutor to keep tasks sorted. |
class |
HashedTimingWheel
Implementation of
TimeScheduler . |
class |
MockTimeScheduler
Mock implementation of
TimeScheduler , used by unit tests |
class |
TimeScheduler2
Deprecated.
Use
TimeScheduler3 instead |
class |
TimeScheduler3
Implementation of
TimeScheduler . |
Modifier and Type | Field and Description |
---|---|
protected TimeScheduler |
TimeService.timer |
Modifier and Type | Method and Description |
---|---|
ResponseCollectorTask<T> |
ResponseCollectorTask.start(TimeScheduler timer,
long initial_delay,
long interval) |
Constructor and Description |
---|
AgeOutCache(TimeScheduler timer,
long timeout) |
AgeOutCache(TimeScheduler timer,
long timeout,
AgeOutCache.Handler handler) |
TimeService(TimeScheduler timer) |
TimeService(TimeScheduler timer,
long interval) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.