|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
AbstractService
is a superclass for all service implementations.sender
.
msgs
, removing them also from retransmission.
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.
org.javagroups.conf.magicNumberFile
.mode
responses.
dests
and receive responses
via the RspCollector interface.
mode
responses.
flush
) but does not
close the output stream (System.err or System.out).
flush
) and closes
the output file, stream, writer, or socket associated with this tracer.
true
, this tracer has been closed and no further output
will be accepted.
send
and releases all locks associated with
this transaction.
o
.
Channel
interface.
Channel.close()
.
flush
) and closes
the output file, stream, writer, or socket associated with this tracer.
flush
) and closes
the output stream 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.
execute()
).
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_CANCELED
or LEASE_RENEWED
.
LEASE_GRANTED
or LEASE_RENEWED
.
LockManager
represents generic lock manager that allows
obtaining and releasing locks on objects.Trace
level value, return a string describing the
level.
lockId
on behalf of the specified
owner
.
obj
for specified owner
.
Tracer
that matches the specified module
name.
MembershipListener
instances.MessageListener
instances.SetName
has been called
println
.
javax.jms.MessageListener
interface.
PrintStream
.Down
(when done).
fqn
.
message
to it.
MethodCall
object from the message's buffer and prints it.
message
and calls
print
.
ObjectInput
groupname
.
addr
from connection table.
addr
from connection table.
key
from the node's hashmap
obj
from all receiver sets and wake up
retransmission thread.
next_to_remove
, increments the latter.
head
.
obj
from the list, checking for equality using the equals
operator.
Tracer
for the specified module.
membership
variable to the value of
members
.
STDOUT
.
first_seqno
and last_seqno
.
getState()
object when calling receive()
.
getState()
object when
calling receive()
.send
and releases all locks associated with
this transaction.
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.TUNNEL
-
- run() -
Method in class org.javagroups.protocols.UDP.UcastReceiver
-
- run() -
Method in class org.javagroups.protocols.UDP
-
- run() -
Method in class org.javagroups.protocols.VERIFY_SUSPECT
- Will be started when a suspect is added to the suspects hashtable.
- run() -
Method in class org.javagroups.protocols.pbcast.FD
-
- run() -
Method in class org.javagroups.protocols.pbcast.PBCAST
- Gossip thread.
- 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
-
ServiceRunner
is utility class that runs services in standalone
mode.Channel.receive()
, as requested by
Channel.getState(s)
previously.System.err
.System.out
.SystemOutTracer
and
SystemErrTracer
; avoids ever closing output stream.RequestCorrelator.sendRequest(long,List,Message,RspCollector)
.
Clear
method.
Clear
method.
PrintStream
and
trace level.
PrintStream
.
PrintWriter
and
trace level.
PrintWriter
.
host
on
port
with the given trace level.
host
on
port
.
addr
on
port
at the specified trace level.
addr
on
port
.
PullPushAdapter.addMembershipListener(org.javagroups.MembershipListener)
module
.
PrintStream
.
PrintWriter
.
host
on
port
.
addr
on
port
.
int
Limits the window size to a reasonable value.
listener
for state notification events.
messagesHandler<\code>
- start() -
Method in class org.javagroups.protocols.STABLE
- Start the layer:
i.
- start() -
Method in class org.javagroups.protocols.STATE_TRANSFER
-
- start() -
Method in class org.javagroups.protocols.TCP
-
- start() -
Method in class org.javagroups.protocols.TOTAL
- Prepare this layer to receive messages from above
- start() -
Method in class org.javagroups.protocols.TOTAL_OLD
-
- start() -
Method in class org.javagroups.protocols.TOTAL_TOKEN
-
- start() -
Method in class org.javagroups.protocols.TUNNEL
-
- start() -
Method in class org.javagroups.protocols.UDP.UcastReceiver
-
- start() -
Method in class org.javagroups.protocols.UDP
- Creates the unicast and multicast sockets and starts the unicast and multicast receiver threads
- start() -
Method in class org.javagroups.protocols.UNICAST
-
- start() -
Method in class org.javagroups.protocols.WANPIPE
-
- start() -
Method in class org.javagroups.protocols.pbcast.GMS
-
- start() -
Method in class org.javagroups.protocols.pbcast.GmsImpl
-
- start() -
Method in class org.javagroups.protocols.pbcast.NAKACK
-
- start() -
Method in class org.javagroups.protocols.pbcast.STABLE
-
- start() -
Method in class org.javagroups.protocols.pbcast.STATE_TRANSFER
-
- start() -
Method in class org.javagroups.service.AbstractService
- Start standalone thread that will run until explicitly stopped.
- start() -
Method in class org.javagroups.stack.AckMcastSenderWindow
- Start the retransmitter.
- start() -
Method in class org.javagroups.stack.MessageProtocol
-
- start() -
Method in class org.javagroups.stack.Protocol
- This method is called on a
Channel.connect(String)
.
- start() -
Method in class org.javagroups.stack.ProtocolStack
- Start all layers.
- start() -
Method in class org.javagroups.stack.Router
-
- start() -
Method in class org.javagroups.util.Proxy1_4
-
- start() -
Method in class org.javagroups.util.ReusableThread
-
- start() -
Method in class org.javagroups.util.Scheduler
-
- start() -
Method in class org.javagroups.util.TimeScheduler
- Start the scheduler, if it's suspended or stopped
- startDownHandler() -
Method in class org.javagroups.protocols.AUTOCONF
- Leave empty: no down_thread will be created, but the down_thread of the neighbor above us will be used
- startDownHandler() -
Method in class org.javagroups.protocols.BSH
- We have no down handler thread
- startDownHandler() -
Method in class org.javagroups.protocols.MERGE2
- DON'T REMOVE ! This prevents the down-handler thread to be created, which is not needed in the protocol.
- startDownHandler() -
Method in class org.javagroups.stack.Protocol
- Used internally.
- startDownHandler() -
Method in class org.javagroups.stack.ProtocolStack
-
- startProtocolStack(Protocol) -
Method in class org.javagroups.stack.Configurator
-
- startService(ResourceBundle) -
Static method in class org.javagroups.service.ServiceRunner
- Method to start service.
- startUpHandler() -
Method in class org.javagroups.protocols.AUTOCONF
- Leave empty: no up_thread will be created, but the up_thread of the neighbor below us will be used
- startUpHandler() -
Method in class org.javagroups.protocols.BSH
- We have no up handler thread
- startUpHandler() -
Method in class org.javagroups.protocols.MERGE2
- DON'T REMOVE ! This prevents the up-handler thread to be created, which is not needed in the protocol.
- startUpHandler() -
Method in class org.javagroups.protocols.TCP
- DON'T REMOVE ! This prevents the up-handler thread to be created, which essentially is superfluous:
messages are received from the network rather than from a layer below.
- startUpHandler() -
Method in class org.javagroups.protocols.UDP
- DON'T REMOVE ! This prevents the up-handler thread to be created, which essentially is superfluous:
messages are received from the network rather than from a layer below.
- startUpHandler() -
Method in class org.javagroups.stack.Protocol
- Used internally.
- startUpHandler() -
Method in class org.javagroups.stack.ProtocolStack
-
- startWork() -
Method in class org.javagroups.stack.ProtocolStack
- Override with null functionality: we don't need any threads to be started !
- started(Runnable) -
Method in interface org.javagroups.util.SchedulerListener
-
- stateListener -
Variable in class org.javagroups.blocks.MessageListenerAdapter
-
- stateTransferCompleted(boolean) -
Method in interface org.javagroups.blocks.ReplicatedHashtable.StateTransferListener
-
- stateTransferRunning() -
Method in class org.javagroups.blocks.ReplicatedHashtable
-
- stateTransferStarted() -
Method in interface org.javagroups.blocks.ReplicatedHashtable.StateTransferListener
-
- state_timeout -
Variable in class org.javagroups.blocks.TransactionalHashtable
-
- stop() -
Method in class org.javagroups.blocks.ConnectionTable
- Closes all open sockets, the server socket and all threads waiting for incoming messages
- stop() -
Method in class org.javagroups.blocks.ConnectionTable1_4
- Closes all open sockets, the server socket and all threads waiting for incoming messages
- stop() -
Method in class org.javagroups.blocks.DistributedHashtable
-
- stop() -
Method in class org.javagroups.blocks.DistributedQueue
-
- stop() -
Method in class org.javagroups.blocks.DistributedTree
-
- stop() -
Method in class org.javagroups.blocks.Link
-
- stop() -
Method in class org.javagroups.blocks.LogicalLink
- Stop all links
- stop() -
Method in class org.javagroups.blocks.MessageDispatcher
-
- stop() -
Method in class org.javagroups.blocks.NotificationBus
-
- stop() -
Method in class org.javagroups.blocks.PullPushAdapter
-
- stop() -
Method in class org.javagroups.blocks.ReplicatedTree
-
- stop() -
Method in class org.javagroups.blocks.ReplicationManager
-
- stop() -
Method in class org.javagroups.blocks.RequestCorrelator
-
- stop() -
Method in class org.javagroups.blocks.TransactionalHashtable
- Leaves the group.
- stop(String) -
Static method in class org.javagroups.debug.Profiler
-
- stop() -
Method in class org.javagroups.debug.ProtocolTester
-
- stop() -
Method in class org.javagroups.demos.wb.GraphPanel
-
- stop() -
Method in class org.javagroups.protocols.BSH
-
- stop() -
Method in class org.javagroups.protocols.DEADLOCK
-
- stop() -
Method in class org.javagroups.protocols.FD
-
- stop() -
Method in class org.javagroups.protocols.FD_PID
-
- stop() -
Method in class org.javagroups.protocols.FD_PROB
-
- stop() -
Method in class org.javagroups.protocols.FD_SIMPLE
-
- stop() -
Method in class org.javagroups.protocols.FD_SOCK
-
- stop() -
Method in class org.javagroups.protocols.JMS
- Stops the work of the JMS protocol.
- stop() -
Method in class org.javagroups.protocols.MERGE
-
- stop() -
Method in class org.javagroups.protocols.MERGE2
-
- stop() -
Method in class org.javagroups.protocols.NAKACK
-
- stop() -
Method in class org.javagroups.protocols.PIGGYBACK
-
- stop() -
Method in class org.javagroups.protocols.PING
-
- stop() -
Method in class org.javagroups.protocols.SHUFFLE
- Stops the messagesHandler
- stop() -
Method in class org.javagroups.protocols.SMACK
-
- stop() -
Method in class org.javagroups.protocols.STABLE
- Stop scheduling the gossip task
- stop() -
Method in class org.javagroups.protocols.STATE_TRANSFER
-
- stop() -
Method in class org.javagroups.protocols.TCP
-
- stop() -
Method in class org.javagroups.protocols.TOTAL
- Handle the stop() method travelling down the stack.
- stop() -
Method in class org.javagroups.protocols.TOTAL_OLD
-
- stop() -
Method in class org.javagroups.protocols.TOTAL_TOKEN
- Overrides @org.javagroups.stack.MessageProtocol#stop().
- stop() -
Method in class org.javagroups.protocols.TUNNEL
-
- stop() -
Method in class org.javagroups.protocols.UDP.UcastReceiver
-
- stop() -
Method in class org.javagroups.protocols.UDP
-
- stop() -
Method in class org.javagroups.protocols.UNICAST
-
- stop() -
Method in class org.javagroups.protocols.VERIFY_SUSPECT
-
- stop() -
Method in class org.javagroups.protocols.WANPIPE
-
- stop() -
Method in class org.javagroups.protocols.pbcast.CoordGmsImpl
-
- stop() -
Method in class org.javagroups.protocols.pbcast.FD
-
- stop() -
Method in class org.javagroups.protocols.pbcast.GMS
-
- stop() -
Method in class org.javagroups.protocols.pbcast.GmsImpl
-
- stop() -
Method in class org.javagroups.protocols.pbcast.NAKACK
-
- stop() -
Method in class org.javagroups.protocols.pbcast.PBCAST
-
- stop() -
Method in class org.javagroups.protocols.pbcast.STABLE
-
- stop() -
Method in class org.javagroups.service.AbstractService
- Stop standalone thread started with
AbstractService.start()
method.
- stop() -
Method in class org.javagroups.stack.AckMcastSenderWindow
- Stop the rentransmition and clear all pending msgs.
- stop() -
Method in class org.javagroups.stack.GossipClient
-
- stop() -
Method in class org.javagroups.stack.MessageProtocol
-
- stop() -
Method in class org.javagroups.stack.Protocol
- This method is called on a
Channel.disconnect()
.
- stop() -
Method in class org.javagroups.stack.ProtocolStack
- Iterates through all the protocols from top to bottom and does the following:
Waits until all messages in the down queue have been flushed (ie., size is 0)
Calls stop() on the protocol
- stop() -
Method in class org.javagroups.stack.Retransmitter
- Stop the rentransmition and clear all pending msgs.
- stop() -
Method in class org.javagroups.stack.Router
-
- stop() -
Method in class org.javagroups.util.ReusableThread
- Stops the thread by setting thread=null and interrupting it.
- stop() -
Method in class org.javagroups.util.Scheduler
- Stop the scheduler thread.
- stop() -
Method in class org.javagroups.util.TimeScheduler
- Stop the scheduler if it's running.
- stopEnsThread() -
Method in class org.javagroups.ensemble.Hot_Ensemble
-
- stopInternal() -
Method in class org.javagroups.stack.Protocol
- Used internally.
- stopInternal() -
Method in class org.javagroups.stack.ProtocolStack
-
- stopProtocolStack(Protocol) -
Method in class org.javagroups.stack.Configurator
-
- stopWork() -
Method in class org.javagroups.stack.ProtocolStack
- Override with null functionality: we don't need any threads to be started !
- stopped(Runnable) -
Method in interface org.javagroups.util.SchedulerListener
-
- string2Level(String) -
Static method in class org.javagroups.log.Trace
-
- subgroups -
Variable in class org.javagroups.MergeView
-
- suspect(Address) -
Method in interface org.javagroups.MembershipListener
- Called when a member is suspected
- suspect(Address) -
Method in class org.javagroups.blocks.DistributedHashtable
- Called when a member is suspected
- suspect(Address) -
Method in class org.javagroups.blocks.DistributedQueue
- Called when a member is suspected
- suspect(Address) -
Method in class org.javagroups.blocks.DistributedTree
- Called when a member is suspected
- suspect(Address) -
Method in class org.javagroups.blocks.GroupRequest
- Callback (called by RequestCorrelator or Transport).
- suspect(Address) -
Method in class org.javagroups.blocks.MembershipListenerAdapter
- Notify membership listener that some node was suspected.
- suspect(Address) -
Method in class org.javagroups.blocks.NotificationBus
-
- suspect(Address) -
Method in class org.javagroups.blocks.ReplicatedHashtable
- Called when a member is suspected
- suspect(Address) -
Method in class org.javagroups.blocks.ReplicatedTree
- Called when a member is suspected
- suspect(Address) -
Method in interface org.javagroups.blocks.RspCollector
-
- suspect(Address) -
Method in class org.javagroups.blocks.VotingAdapter
- Callback for notification that one node is suspected
- suspect(Address) -
Method in class org.javagroups.demos.Chat
-
- suspect(Address) -
Method in class org.javagroups.demos.QuoteClient
-
- suspect(Address) -
Method in class org.javagroups.demos.QuoteServer
-
- suspect(Address) -
Method in class org.javagroups.demos.Topology
-
- suspect(Address) -
Method in class org.javagroups.demos.ViewDemo
- Called when a member is suspected
- suspect(Address) -
Method in class org.javagroups.demos.wb.Whiteboard
-
- suspect(Hot_GroupContext, Hot_Endpoint[]) -
Method in class org.javagroups.ensemble.Hot_Ensemble
- NOT SUPPORTED CURRENTLY IN THE ML
- suspect(Address) -
Method in class org.javagroups.protocols.ClientGmsImpl
-
- suspect(Address) -
Method in class org.javagroups.protocols.CoordGmsImpl
-
- suspect(Address) -
Method in class org.javagroups.protocols.GMS
-
- suspect(Address) -
Method in class org.javagroups.protocols.GmsImpl
-
- suspect(Address) -
Method in class org.javagroups.protocols.ParticipantGmsImpl
-
- suspect(Address) -
Method in class org.javagroups.protocols.pbcast.ClientGmsImpl
-
- suspect(Address) -
Method in class org.javagroups.protocols.pbcast.CoordGmsImpl
-
- suspect(Address) -
Method in class org.javagroups.protocols.pbcast.GmsImpl
-
- suspect(Address) -
Method in class org.javagroups.protocols.pbcast.ParticipantGmsImpl
-
- suspect(Address) -
Method in class org.javagroups.service.AbstractService
- This method is called when a member of service group is suspected to
be failed.
- suspect(Object) -
Method in class org.javagroups.stack.AckMcastReceiverWindow
-
- suspect(Address) -
Method in class org.javagroups.stack.AckMcastSenderWindow
- Process with address
suspected
is suspected: remove it
from all receiver sets.
- suspend() -
Method in class org.javagroups.util.ReusableThread
- Suspends the thread.
- suspended(Runnable) -
Method in interface org.javagroups.util.SchedulerListener
-
Tracer
s.
Trace.setTimestampFormat()
and used in the
timestamp
method.
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.SIZE
-
- up(Event) -
Method in class org.javagroups.protocols.SMACK
-
- up(Event) -
Method in class org.javagroups.protocols.STATE_TRANSFER
-
- up(Event) -
Method in class org.javagroups.protocols.TCPGOSSIP
-
- up(Event) -
Method in class org.javagroups.protocols.TCPPING
-
- up(Event) -
Method in class org.javagroups.protocols.TOTAL
-
- 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.TRACE
-
- up(Event) -
Method in class org.javagroups.protocols.UDP
- handle the UP event.
- up(Event) -
Method in class org.javagroups.protocols.UNICAST
-
- up(Event) -
Method in class org.javagroups.protocols.VERIFY_SUSPECT
-
- 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.pbcast.FD
-
- up(Event) -
Method in class org.javagroups.protocols.pbcast.GMS
-
- up(Event) -
Method in class org.javagroups.protocols.pbcast.NAKACK
- Callback.
- up(Event) -
Method in class org.javagroups.protocols.pbcast.PBCAST
-
- 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.stack.MessageProtocol
- Handle an event coming from the layer above
- up(Event) -
Method in class org.javagroups.stack.Protocol
- An event was received from the layer below.
- 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).
- up(Event) -
Method in class org.javagroups.stack.ProtocolStack
-
- up_handler -
Variable in class org.javagroups.Channel
-
- up_handler -
Variable in class org.javagroups.stack.Protocol
-
- up_prot -
Variable in class org.javagroups.stack.Protocol
-
- up_queue -
Variable in class org.javagroups.stack.Protocol
-
- up_thread -
Variable in class org.javagroups.stack.Protocol
-
- up_thread_prio -
Variable in class org.javagroups.stack.Protocol
-
- 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
-
- useLocks() -
Method in class org.javagroups.blocks.ReplicationData
-
- use_properties -
Variable in class org.javagroups.ensemble.Hot_JoinOps
-
true
or false
messages.
Writer
.ObjectOutput
.
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |