|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
AbstractService
is a superclass for all service implementations.msgs
, removing them also from retransmission.
sender
.
Tracer
.
true
, every call to print
will call
flush
.
MembershipListener
or
BlockEvent
received from call to Receive
).
MembershipListener
or
BlockEvent
received from call to receive()
).
true
if the specified module name is illegal.
dests
and receive responses
via the RspCollector interface.
mode
responses.
mode
responses.
flush
) and closes
the output file, stream, writer, or socket associated with this tracer.
flush
) but does not
close the output stream (System.err or System.out).
true
, this tracer has been closed and no further output
will be accepted.
o
.
Channel
interface.
flush
) and closes
the output file, stream, writer, or socket associated with this tracer.
flush
) and closes
the output file, stream, writer, or socket associated with this tracer.
flush
) and closes
the output file, stream, writer, or socket associated with this tracer.
flush
) and closes
the output stream associated with this tracer.
message
to the output file,
stream, writer, or socket associated with this tracer.
message
to the output file,
stream, writer, or socket associated with this tracer.
message
to the output file,
stream, writer, or socket associated with this tracer.
message
to the output file,
stream, writer, or socket associated with this tracer.
obj
.
Tracer
to be used for output for the specified
module name.
date
as a formatted string using the ISO 8601 date
format ("yyyy-MM-dd'T'hh:mm:ss,S").
date
as a formatted string.
data
map.
true
if this tracer performs auto-flushing after
every print.
LeaseFactory.DURATION_ANY
.
Tracer
to be used when no other
appropriate one is found.
LeaseFactory
that created this lease.
data
map.
LeaseFactory.DURATION_FOREVER
.
seqno
(excluding
seqno
).
missing_msgs
.
sender
mbr
from the membership.
mbr
from the membership.
true
if inter-service communication
processes should temporarily stop sending messages to service channel.
ACQUIRE_EXPIRATION
time after creation and if the lock is still valid (in the
future locks will be leased for a predefined period of time).
Address
representing the JMS node ID or JMS topic group.Lease
interface represents a token granted by lease manager
that allows access to some resource for a limited period of time.LeaseFactory
is responsible for granting new leases, renewing
existing leases and canceling leases when it is no longer needed.LeaseFactoryClient
is an implementation of LeaseFactory
interface that delegates lease granting to group containing one or more
LeaseFactoryService
instances.LeaseFactoryService
is service that is able to lease resources
to clients.LEASE_GRANTED
or LEASE_RENEWED
.
LEASE_CANCELED
or LEASE_RENEWED
.
Trace
level value, return a string describing the
level.
lockId
on behalf of the specified
owner
.
obj
for specified owner
.
LockManager
represents generic lock manager that allows
obtaining and releasing locks on objects.Tracer
that matches the specified module
name.
MembershipListener
instances.MessageListener
instances.SetName
has been called
println
.
javax.jms.MessageListener
interface.
Down
(when done).
fqn
.
message
to it.
message
and calls
print
.
MethodCall
object from the message's buffer and prints it.
PrintStream
.ObjectInput
groupname
.
next_to_remove
, increments the latter.
head
.
addr
from connection table.
obj
from all receiver sets and wake up
retransmission thread.
key
from the node's hashmap
obj
from the list, checking for equality using the equals
operator.
Tracer
for the specified module.
STDOUT
.
first_seqno
and last_seqno
.
GetState
object when
calling Receive
.
getState()
object when
calling receive()
.messages List<\code> if there
are less than 10 messages in the List it waits some time to ensure to chose from
a set of messages > 1.
- run() -
Method in class org.javagroups.protocols.UDP
-
- run() -
Method in class org.javagroups.protocols.UDP.UcastReceiver
-
- run() -
Method in class org.javagroups.protocols.MERGE
- If IP multicast: periodically mcast a HELLO message
If gossiping: periodically retrieve the membership.
- run() -
Method in class org.javagroups.protocols.TUNNEL
-
- run() -
Method in class org.javagroups.protocols.GMS
-
- run() -
Method in class org.javagroups.protocols.FD_SOCK
- Runs as long as there are 2 members and more.
- run() -
Method in class org.javagroups.protocols.FD_SHUN
-
- run() -
Method in class org.javagroups.protocols.FD_RAND
- Loop while more than 1 member available.
- run() -
Method in class org.javagroups.protocols.pbcast.PBCAST
- Gossip thread.
- run() -
Method in class org.javagroups.protocols.pbcast.FD
-
- run() -
Method in class org.javagroups.stack.GossipServer
-
- run() -
Method in class org.javagroups.util.ReusableThread
- Delicate piece of code (means very important :-)).
- run() -
Method in class org.javagroups.util.Scheduler
-
- run() -
Method in interface org.javagroups.util.TimeScheduler.Task
- Execute the task
- runThread -
Variable in class org.javagroups.service.AbstractService
-
- RWLock - class org.javagroups.util.RWLock.
- Lock allowing multiple reads or a single write.
- RWLock.BlockException - exception org.javagroups.util.RWLock.BlockException.
- Exception thrown when a lock request would block the caller
- RWLock.BlockException() -
Constructor for class org.javagroups.util.RWLock.BlockException
-
- RWLock.BlockException(String) -
Constructor for class org.javagroups.util.RWLock.BlockException
-
- RWLock.IntException - exception org.javagroups.util.RWLock.IntException.
- Interrupted exception wrapped in a RuntimeException
- RWLock.IntException() -
Constructor for class org.javagroups.util.RWLock.IntException
-
- RWLock.IntException(String) -
Constructor for class org.javagroups.util.RWLock.IntException
-
- RWLock() -
Constructor for class org.javagroups.util.RWLock
-
ServiceRunner
is utility class that runs services in standalone
mode.Clear
method.
Clear
method.
addr
on
port
.
addr
on
port
at the specified trace level.
PrintStream
and
trace level.
PrintWriter
and
trace level.
host
on
port
with the given trace level.
PrintStream
.
PrintWriter
.
host
on
port
.
addMembershipListener
module
.
addr
on
port
.
PrintStream
.
PrintWriter
.
host
on
port
.
Channel.receive()
, as requested by
Channel.getState(s)
previously.listener
for state notification events.
AbstractService.start()
method.
suspected
is suspected: remove it
from all receiver sets.
System.err
.System.out
.SystemOutTracer
and
SystemErrTracer
; avoids ever closing output stream.Trace.setTimestampFormat()
and used in the
timestamp
method.
Tracer
s.
lockId
on behalf of the specified
owner
.
obj
owned by specified owner
.
messages List<\code> where the messagesHandler<\code>
retrieves them.
- up(Event) -
Method in class org.javagroups.protocols.FD
-
- up(Event) -
Method in class org.javagroups.protocols.DUMMY
-
- up(Event) -
Method in class org.javagroups.protocols.CAUSAL
- Processes Event going up through the stack
- up(Event) -
Method in class org.javagroups.protocols.TCP
-
- up(Event) -
Method in class org.javagroups.protocols.STATE_TRANSFER
-
- up(Event) -
Method in class org.javagroups.protocols.EXAMPLE
-
- up(Event) -
Method in class org.javagroups.protocols.SIZE
-
- up(Event) -
Method in class org.javagroups.protocols.DELAY
-
- up(Event) -
Method in class org.javagroups.protocols.UDP
- handle the UP event.
- up(Event) -
Method in class org.javagroups.protocols.MERGE
-
- up(Event) -
Method in class org.javagroups.protocols.WANPIPE
-
- up(Event) -
Method in class org.javagroups.protocols.VIEW_ENFORCER
-
- up(Event) -
Method in class org.javagroups.protocols.WANPING
-
- up(Event) -
Method in class org.javagroups.protocols.HDRS
-
- up(Event) -
Method in class org.javagroups.protocols.LOOPBACK
-
- up(Event) -
Method in class org.javagroups.protocols.FRAG
- If event is a message, if it is fragmented, re-assemble fragments into big message and pass up
the stack.
- up(Event) -
Method in class org.javagroups.protocols.TUNNEL
-
- up(Event) -
Method in class org.javagroups.protocols.PARTITIONER
- Discards Messages with the wrong partition number and sets local partition number if
it receives a COMMAND Header
- up(Event) -
Method in class org.javagroups.protocols.PRINTMETHODS
-
- up(Event) -
Method in class org.javagroups.protocols.FLOWCONTROL
- Checs if up messages are from myaddr and in the case sends down queued messages or
decremnts sentMsgs if there are no queued messages
- up(Event) -
Method in class org.javagroups.protocols.UNICAST
-
- up(Event) -
Method in class org.javagroups.protocols.TOTAL_OLD
- handles an Event coming up the Protocol Stack
- up(Event) -
Method in class org.javagroups.protocols.TCPGOSSIP
-
- up(Event) -
Method in class org.javagroups.protocols.FD_SIMPLE
-
- up(Event) -
Method in class org.javagroups.protocols.SMACK
-
- up(Event) -
Method in class org.javagroups.protocols.TOTAL
-
- up(Event) -
Method in class org.javagroups.protocols.MERGE2
-
- up(Event) -
Method in class org.javagroups.protocols.FD_SOCK
-
- up(Event) -
Method in class org.javagroups.protocols.NAKACK
- Callback.
- up(Event) -
Method in class org.javagroups.protocols.AUTOCONF
-
- up(Event) -
Method in class org.javagroups.protocols.PIGGYBACK
-
- up(Event) -
Method in class org.javagroups.protocols.DISCARD
-
- up(Event) -
Method in class org.javagroups.protocols.TRACE
-
- up(Event) -
Method in class org.javagroups.protocols.QUEUE
- Queues or passes up events.
- up(Event) -
Method in class org.javagroups.protocols.PING
- An event was received from the layer below.
- up(Event) -
Method in class org.javagroups.protocols.JMS
- handle the UP event.
- up(Event) -
Method in class org.javagroups.protocols.TCPPING
-
- up(Event) -
Method in class org.javagroups.protocols.PRINTOBJS
-
- up(Event) -
Method in class org.javagroups.protocols.FD_PID
-
- up(Event) -
Method in class org.javagroups.protocols.UNIFORM
-
- up(Event) -
Method in class org.javagroups.protocols.FD_SHUN
-
- up(Event) -
Method in class org.javagroups.protocols.ENCRYPT
-
- up(Event) -
Method in class org.javagroups.protocols.FD_RAND
-
- up(Event) -
Method in class org.javagroups.protocols.pbcast.PBCAST
-
- up(Event) -
Method in class org.javagroups.protocols.pbcast.FD
-
- up(Event) -
Method in class org.javagroups.protocols.pbcast.NAKACK
- Callback.
- up(Event) -
Method in class org.javagroups.protocols.pbcast.STABLE
-
- up(Event) -
Method in class org.javagroups.protocols.pbcast.STATE_TRANSFER
-
- up(Event) -
Method in class org.javagroups.protocols.pbcast.GMS
-
- up(Event) -
Method in class org.javagroups.stack.Protocol
- An event was received from the layer below.
- up(Event) -
Method in class org.javagroups.stack.MessageProtocol
- Handle an event coming from the layer above
- up(Event) -
Method in class org.javagroups.stack.ProtocolStack
-
- up(Event, int) -
Method in class org.javagroups.debug.ProtocolView
-
- up(Event, int) -
Method in interface org.javagroups.stack.ProtocolObserver
- Called when an event is about to be dispatched to the protocol (before it is dispatched).
- update(Graphics) -
Method in class org.javagroups.demos.wb.GraphPanel
-
- updateView(View) -
Method in class org.javagroups.protocols.TOTAL_TOKEN
-
- updateView(View) -
Method in class org.javagroups.stack.MessageProtocol
-
- updateWindow(RingToken) -
Method in class org.javagroups.protocols.ring.RingNodeFlowControl
-
- UpHandler - interface org.javagroups.UpHandler.
-
- use_properties -
Variable in class org.javagroups.ensemble.Hot_JoinOps
-
- useMethodObject -
Variable in class org.javagroups.blocks.MethodCall
-
- USER_DEFINED -
Static variable in class org.javagroups.Event
-
- UserInfoDialog - class org.javagroups.demos.wb.UserInfoDialog.
-
- UserInfoDialog(Frame) -
Constructor for class org.javagroups.demos.wb.UserInfoDialog
-
- Util - class org.javagroups.util.Util.
- Collection of various utility routines that can not be assigned to other classes.
- Util() -
Constructor for class org.javagroups.util.Util
-
true
or false
messages.
ObjectOutput
.
Writer
.
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |