|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Event | |
org.jgroups | Provides top-level public JGroups classes such as Channel, Message, etc. |
org.jgroups.blocks | Provides building blocks that are layered on top of channels. |
org.jgroups.debug | Provides debug support, including testing, profiling, and a graphical view of a protocol stack. |
org.jgroups.jmx | |
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.stack | Support for managing protocol stacks. |
org.jgroups.util | Provides useful functionality which cannot be assigned to any particular other package. |
Uses of Event in org.jgroups |
Fields in org.jgroups declared as Event | |
static Event |
Event.FIND_INITIAL_MBRS_EVT
|
static Event |
Event.GET_DIGEST_EVT
|
Methods in org.jgroups with parameters of type Event | |
void |
JChannel.up(Event evt)
Callback method Called by the ProtocolStack when a message is received. |
void |
JChannel.down(Event evt)
Sends a message through the protocol stack if the stack is available |
void |
UpHandler.up(Event evt)
Invoked for all channel events except connection management and state transfer. |
void |
Channel.down(Event evt)
Access to event mechanism of channels. |
Uses of Event in org.jgroups.blocks |
Methods in org.jgroups.blocks with parameters of type Event | |
void |
RequestCorrelator.receive(Event evt)
Callback. |
Uses of Event in org.jgroups.debug |
Methods in org.jgroups.debug with parameters of type Event | |
void |
Simulator.send(Event evt)
|
void |
Simulator.receive(Event evt)
|
void |
Simulator.Receiver.receive(Event evt)
|
boolean |
ProtocolView.up(Event evt,
int num_evts)
|
boolean |
ProtocolView.passUp(Event evt)
|
boolean |
ProtocolView.down(Event evt,
int num_evts)
|
boolean |
ProtocolView.passDown(Event evt)
|
Uses of Event in org.jgroups.jmx |
Methods in org.jgroups.jmx with parameters of type Event | |
void |
JChannelMBean.down(Event evt)
Deprecated. |
void |
JChannel.down(Event evt)
|
Uses of Event in org.jgroups.protocols |
Methods in org.jgroups.protocols with parameters of type Event | |
void |
WANPIPE.down(Event evt)
Sent to destination(s) using the WAN pipe. |
void |
VIEW_ENFORCER.up(Event evt)
|
void |
VERIFY_SUSPECT.up(Event evt)
|
void |
UDP_NIO.up(Event evt)
handle the UP event. |
void |
UDP_NIO.down(Event evt)
Caller by the layer above this layer. |
void |
TUNNEL.down(Event evt)
Caller by the layer above this layer. |
void |
TRACE.up(Event evt)
|
void |
TRACE.down(Event evt)
|
boolean |
TOTAL_TOKEN.handleUpEvent(Event evt)
|
boolean |
TOTAL_TOKEN.handleDownEvent(Event evt)
|
void |
TOTAL_OLD.up(Event evt)
handles an Event coming up the Protocol Stack |
void |
TOTAL_OLD.down(Event evt)
handles an Event coming down the Protocol Stack |
void |
TOTAL.up(Event event)
|
void |
TOTAL.down(Event event)
|
void |
STATE_TRANSFER.up(Event evt)
|
void |
STATE_TRANSFER.down(Event evt)
|
boolean |
STABLE.handleUpEvent(Event evt)
Callback. |
boolean |
STABLE.handleDownEvent(Event evt)
Callback. |
void |
SMACK.up(Event evt)
|
void |
SMACK.down(Event evt)
|
void |
SIZE.up(Event evt)
|
void |
SIZE.down(Event evt)
|
void |
SHUFFLE.up(Event evt)
Adds upcoming messages to the messages List<\code> where the |
boolean |
RpcProtocolEXAMPLE.handleUpEvent(Event evt)
Callback. |
boolean |
RpcProtocolEXAMPLE.handleDownEvent(Event evt)
Callback. |
void |
QUEUE.up(Event evt)
Queues or passes up events. |
void |
QUEUE.down(Event evt)
|
boolean |
QUEUE.Observer.addingToUpVector(Event evt,
int num_events)
Called before event is added. |
boolean |
QUEUE.Observer.addingToDownVector(Event evt,
int num_events)
Called before event is added. |
void |
PRINTOBJS.up(Event evt)
|
void |
PRINTOBJS.down(Event evt)
|
void |
PRINTMETHODS.up(Event evt)
|
void |
PRINTMETHODS.down(Event evt)
|
void |
PIGGYBACK.up(Event evt)
|
void |
PIGGYBACK.down(Event evt)
|
void |
PERF_TP.down(Event evt)
Caller by the layer above this layer. |
void |
PERF_TP.up(Event evt)
|
void |
PERF.up(Event evt)
|
void |
PERF.down(Event evt)
|
void |
PARTITIONER.up(Event evt)
Discards Messages with the wrong partition number and sets local partition number if it receives a COMMAND Header |
void |
PARTITIONER.down(Event evt)
Adds to Messages a Header with the local partitin number and if receives a SET_PARTITIONS Event sends a new Message with a PartitionerHeader set to COMMAND that carries the Hashtable |
void |
NAKACK.up(Event evt)
Callback. |
void |
NAKACK.down(Event evt)
Callback. |
boolean |
MessageProtocolEXAMPLE.handleUpEvent(Event evt)
Callback. |
boolean |
MessageProtocolEXAMPLE.handleDownEvent(Event evt)
Callback. |
void |
MERGEFAST.down(Event evt)
|
void |
MERGEFAST.up(Event evt)
|
void |
MERGE3.up(Event evt)
|
void |
MERGE3.down(Event evt)
|
void |
MERGE.up(Event evt)
|
void |
MERGE.down(Event evt)
|
void |
LOSS.down(Event evt)
|
void |
LOOPBACK.down(Event evt)
Caller by the layer above this layer. |
protected void |
JMS.handleDownEvent(Event evt)
Handle down event, if it is not a Event.MSG type. |
void |
JMS.down(Event evt)
Called by the protocol above this. |
void |
HTOTAL.down(Event evt)
|
void |
HTOTAL.up(Event evt)
|
void |
HDRS.up(Event evt)
|
void |
HDRS.down(Event evt)
|
boolean |
FLUSH.handleUpEvent(Event evt)
Callback. |
boolean |
FLUSH.handleDownEvent(Event evt)
Callback. |
void |
FLUSH.receiveDownEvent(Event evt)
The default handling adds the event to the down-queue where events are handled in order of addition by a thread. |
boolean |
FLOW_CONTROL.handleDownEvent(Event evt)
If Event.MSG type is received count is incremented by one, and message is passed to the down_prot. |
boolean |
FLOW_CONTROL.handleUpEvent(Event evt)
If Event.MSG type is received message, number of received messages from the sender is incremented. |
void |
FLOWCONTROL.up(Event evt)
Checs if up messages are from myaddr and in the case sends down queued messages or decremnts sentMsgs if there are no queued messages |
void |
FLOWCONTROL.down(Event evt)
Checs if it can send the message, else puts the message in the queue. |
void |
FD_SIMPLE.up(Event evt)
|
void |
FD_SIMPLE.down(Event evt)
|
void |
FD_PROB.up(Event evt)
|
void |
FD_PROB.down(Event evt)
|
void |
FD_PID.up(Event evt)
|
void |
FD_PID.down(Event evt)
|
void |
EXAMPLE.up(Event evt)
|
void |
EXAMPLE.down(Event evt)
|
void |
ENCRYPT1_4.up(Event evt)
|
void |
ENCRYPT1_4.down(Event evt)
|
void |
ENCRYPT.up(Event evt)
|
void |
ENCRYPT.down(Event evt)
|
void |
DUMMY_TP.down(Event evt)
Caller by the layer above this layer. |
void |
DUMMY.up(Event evt)
|
void |
DUMMY.down(Event evt)
|
void |
DISCARD.up(Event evt)
|
void |
DISCARD.down(Event evt)
|
void |
DELAY.up(Event evt)
|
void |
DELAY.down(Event evt)
|
boolean |
DEADLOCK.handleUpEvent(Event evt)
Callback. |
boolean |
DEADLOCK.handleDownEvent(Event evt)
Callback. |
boolean |
GMS.handleUpEvent(Event evt)
Callback. |
boolean |
GMS.handleDownEvent(Event evt)
Callback. |
void |
GMS.receiveDownEvent(Event evt)
|
boolean |
GmsImpl.handleUpEvent(Event evt)
|
boolean |
GmsImpl.handleDownEvent(Event evt)
|
boolean |
ClientGmsImpl.handleUpEvent(Event evt)
|
void |
COMPRESS.up(Event evt)
If there is no header, we pass the message up. |
void |
COMPRESS.down(Event evt)
We compress the payload if it is larger than min_size . |
void |
CAUSAL.down(Event evt)
Processes Event going down in the stack |
void |
CAUSAL.up(Event evt)
Processes Event going up through the stack |
void |
BSH.up(Event evt)
|
void |
VIEW_SYNC.up(Event evt)
|
void |
VIEW_SYNC.down(Event evt)
|
void |
UNICAST.up(Event evt)
|
void |
UNICAST.down(Event evt)
|
void |
TP.up(Event evt)
handle the UP event. |
void |
TP.down(Event evt)
Caller by the layer above this layer. |
protected void |
TP.handleDownEvent(Event evt)
|
protected void |
TCP.handleDownEvent(Event evt)
|
void |
STATS.up(Event evt)
|
void |
STATS.down(Event evt)
|
void |
MERGE2.up(Event evt)
|
void |
MERGE2.down(Event evt)
|
void |
FRAG2.down(Event evt)
Fragment a packet if larger than frag_size (add a header). |
void |
FRAG2.up(Event evt)
If event is a message, if it is fragmented, re-assemble fragments into big message and pass up the stack. |
void |
FRAG.down(Event evt)
Fragment a packet if larger than frag_size (add a header). |
void |
FRAG.up(Event evt)
If event is a message, if it is fragmented, re-assemble fragments into big message and pass up the stack. |
void |
FD_SOCK.up(Event evt)
|
void |
FD_SOCK.down(Event evt)
|
void |
FD.up(Event evt)
|
void |
FD.down(Event evt)
|
protected void |
FC.receiveDownEvent(Event evt)
We need to receive view changes concurrent to messages on the down events: a message might blocks, e.g. |
void |
FC.down(Event evt)
|
void |
FC.up(Event evt)
|
void |
Discovery.up(Event evt)
An event was received from the layer below. |
void |
Discovery.down(Event evt)
An event is to be sent down the stack. |
Uses of Event in org.jgroups.protocols.pbcast |
Methods in org.jgroups.protocols.pbcast with parameters of type Event | |
void |
PBCAST.up(Event evt)
|
void |
PBCAST.down(Event evt)
|
void |
FD.up(Event evt)
|
void |
FD.down(Event evt)
|
boolean |
ClientGmsImpl.handleUpEvent(Event evt)
|
void |
STATE_TRANSFER.up(Event evt)
|
void |
STATE_TRANSFER.down(Event evt)
|
void |
STABLE.up(Event evt)
|
void |
STABLE.down(Event evt)
|
void |
NAKACK.down(Event evt)
Callback. |
void |
NAKACK.up(Event evt)
Callback. |
boolean |
GmsImpl.handleUpEvent(Event evt)
|
boolean |
GmsImpl.handleDownEvent(Event evt)
|
void |
GMS.up(Event evt)
|
void |
GMS.receiveUpEvent(Event evt)
This method is overridden to avoid hanging on getDigest(): when a JOIN is received, the coordinator needs to retrieve the digest from the NAKACK layer. |
void |
GMS.down(Event evt)
|
Uses of Event in org.jgroups.stack |
Methods in org.jgroups.stack with parameters of type Event | |
void |
MessageProtocol.up(Event evt)
Handle an event coming from the layer above |
void |
MessageProtocol.down(Event evt)
This message is not originated by this layer, therefore we can just pass it down without having to go through the request correlator. |
protected boolean |
MessageProtocol.handleUpEvent(Event evt)
Handle up event. |
protected boolean |
MessageProtocol.handleDownEvent(Event evt)
Handle down event. |
boolean |
RpcProtocol.handleUpEvent(Event evt)
Handle up event. |
boolean |
RpcProtocol.handleDownEvent(Event evt)
Handle down event. |
boolean |
ProtocolObserver.up(Event evt,
int num_evts)
Called when an event is about to be dispatched to the protocol (before it is dispatched). |
boolean |
ProtocolObserver.passUp(Event evt)
Called when an event is about to be passed up to the next higher protocol. |
boolean |
ProtocolObserver.down(Event evt,
int num_evts)
Called when an event is about to be dispatched to the protocol (before it is dispatched). |
boolean |
ProtocolObserver.passDown(Event evt)
Called when an event is about to be passed down to the next lower protocol. |
protected void |
Protocol.receiveUpEvent(Event evt)
Internal method, should not be called by clients. |
protected void |
Protocol.receiveDownEvent(Event evt)
Internal method, should not be called by clients. |
void |
Protocol.passUp(Event evt)
Causes the event to be forwarded to the next layer up in the hierarchy. |
void |
Protocol.passDown(Event evt)
Causes the event to be forwarded to the next layer down in the hierarchy.Typically called by the implementation of Down (when done). |
void |
Protocol.up(Event evt)
An event was received from the layer below. |
void |
Protocol.down(Event evt)
An event is to be sent down the stack. |
protected boolean |
Protocol.handleSpecialDownEvent(Event evt)
These are special internal events that should not be handled by protocols |
void |
ProtocolStack.up(Event evt)
|
void |
ProtocolStack.down(Event evt)
|
protected void |
ProtocolStack.receiveUpEvent(Event evt)
|
Uses of Event in org.jgroups.util |
Methods in org.jgroups.util with parameters of type Event | |
static java.lang.String |
Util.printEvent(Event evt)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |