|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
sender
.
msgs
, and cancels their retransmission
first_seqno
to last_seqno
for retransmission
UUID
which adds a string as payload.ThreadDecorator.threadReleased(Thread)
on the current thread.
RetransmitTable.purge(long)
is called.
MembershipListener
or
BlockEvent
received from call to Receive
).
MembershipListener
or
BlockEvent
received from call to receive()
).
ChannelListener
false
.
IpAddress.compareTo(org.jgroups.Address)
instead
IpAddress.compareTo(org.jgroups.Address)
instead
group
.
JChannel
's conversion to type-specific
construction, and the subsequent deprecation of its
JChannel(Object)
constructor, necessitate the
deprecation of this factory method as well. Type-specific
protocol stack configuration should be specfied during
construction of an instance of this factory.
JChannel
implementation of the
Channel interface using the protocol stack configuration
information specfied during construction of an instance of this factory.
- createChannel(String) -
Method in class org.jgroups.JChannelFactory
- Deprecated.
- createConcurrentMap(int, float, int) -
Static method in class org.jgroups.util.Util
-
- createConcurrentMap(int) -
Static method in class org.jgroups.util.Util
-
- createConcurrentMap() -
Static method in class org.jgroups.util.Util
-
- createConnectionMap(long, long, InetAddress, InetAddress, int, int) -
Method in class org.jgroups.protocols.TCP
-
- createDaemons -
Variable in class org.jgroups.util.DefaultThreadFactory
-
- createDatagramSocket(String) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createDatagramSocket(String, SocketAddress) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createDatagramSocket(String, int) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createDatagramSocket(String, int, InetAddress) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createDatagramSocket(String) -
Method in interface org.jgroups.util.SocketFactory
-
- createDatagramSocket(String, SocketAddress) -
Method in interface org.jgroups.util.SocketFactory
-
- createDatagramSocket(String, int) -
Method in interface org.jgroups.util.SocketFactory
-
- createDatagramSocket(String, int, InetAddress) -
Method in interface org.jgroups.util.SocketFactory
-
- createDatagramSocket(SocketFactory, String, InetAddress, int) -
Static method in class org.jgroups.util.Util
- Creates a DatagramSocket bound to addr.
- createDatagramSocketWithBindPort() -
Method in class org.jgroups.protocols.UDP
- Creates a DatagramSocket when bind_port > 0.
- createDataHeader(long, short, boolean) -
Static method in class org.jgroups.protocols.UNICAST.UnicastHeader
-
- createDataHeader(long, short, boolean) -
Static method in class org.jgroups.protocols.UNICAST2.Unicast2Header
-
- createDisseminateHeader(Address) -
Static method in class org.jgroups.protocols.RELAY.RelayHeader
-
- createEphemeralDatagramSocket() -
Method in class org.jgroups.protocols.UDP
- Creates a DatagramSocket with a random port.
- createExpireHeader(short) -
Static method in class org.jgroups.protocols.SCOPE.ScopeHeader
-
- createHashMap() -
Static method in class org.jgroups.util.Util
-
- createHeader(STOMP.StompHeader.Type, String...) -
Static method in class org.jgroups.protocols.STOMP.StompHeader
- Creates a new header
- createHeader(STOMP.StompHeader.Type, Map<String, String>) -
Static method in class org.jgroups.protocols.STOMP.StompHeader
-
- createInetAddressMap(List<ProtocolConfiguration>, List<Protocol>) -
Static method in class org.jgroups.stack.Configurator
-
- createLayer(ProtocolStack, ProtocolConfiguration) -
Static method in class org.jgroups.stack.Configurator
-
- createLocalAddress() -
Method in class org.jgroups.protocols.UDP
-
- createLock(String) -
Method in class org.jgroups.protocols.Locking
-
- createLock(String) -
Method in class org.jgroups.protocols.PEER_LOCK
-
- createManager() -
Method in class org.jgroups.persistence.PersistenceFactory
- Deprecated. Reads the default properties and creates a persistencemanager
The default properties are picked up from the $USER_HOME or
from the classpath.
- createManager(String) -
Method in class org.jgroups.persistence.PersistenceFactory
- Deprecated. Duplicated signature to create PersistenceManager to allow user to
provide property path.
- createMessageHeader(long) -
Static method in class org.jgroups.protocols.pbcast.NakAckHeader
-
- createMessageHeader(short) -
Static method in class org.jgroups.protocols.SCOPE.ScopeHeader
-
- createMonitor() -
Method in class org.jgroups.protocols.FD
-
- createMonitor() -
Method in class org.jgroups.protocols.FD_ICMP
-
- createMonitor() -
Method in class org.jgroups.protocols.FD_PING
-
- createMulticastSocket(String) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createMulticastSocket(String, int) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createMulticastSocket(String, SocketAddress) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createMulticastSocket(String) -
Method in interface org.jgroups.util.SocketFactory
-
- createMulticastSocket(String, int) -
Method in interface org.jgroups.util.SocketFactory
-
- createMulticastSocket(String, SocketAddress) -
Method in interface org.jgroups.util.SocketFactory
-
- createMulticastSocket(SocketFactory, String, InetAddress, int, Log) -
Static method in class org.jgroups.util.Util
-
- createMultiplexerChannel(String, String, boolean, String) -
Method in interface org.jgroups.ChannelFactory
- Deprecated. Creates an implementation of the Channel using a given stack name and
registering it under a given identity.
- createMultiplexerChannel(String, String) -
Method in interface org.jgroups.ChannelFactory
- Deprecated. Creates an implementation of the Channel using a given stack name and
registering it under a given identity.
- createMultiplexerChannel(String, String) -
Method in class org.jgroups.JChannelFactory
- Deprecated. Use a shared transport instead of the multiplexer
- createMultiplexerChannel(String, String, boolean, String) -
Method in class org.jgroups.JChannelFactory
- Deprecated. Use a shared transport instead of the multiplexer
- createMuxChannel(String, String) -
Method in class org.jgroups.mux.Multiplexer
- Deprecated.
- createNewFile() -
Method in class org.jgroups.blocks.GridFile
-
- createProtocol(String, ProtocolStack) -
Static method in class org.jgroups.stack.Configurator
- Creates a new protocol given the protocol specification.
- createProtocol(String) -
Method in class org.jgroups.stack.ProtocolStack
-
- createRandomAddress() -
Static method in class org.jgroups.util.Util
-
- createRandomAddress(String) -
Static method in class org.jgroups.util.Util
-
- createRequestCorrelator(Object, RequestHandler, Address) -
Method in class org.jgroups.blocks.MessageDispatcher
-
- createRequestCorrelator(Object, RequestHandler, Address) -
Method in class org.jgroups.blocks.mux.MuxMessageDispatcher
-
- createRequestCorrelator(Object, RequestHandler, Address) -
Method in class org.jgroups.blocks.mux.MuxRpcDispatcher
-
- createRootDir() -
Method in class org.jgroups.protocols.FILE_PING
-
- createRootDir() -
Method in class org.jgroups.protocols.JDBC_PING
-
- createRootDir() -
Method in class org.jgroups.protocols.S3_PING
-
- createSendFirstSeqnoHeader() -
Static method in class org.jgroups.protocols.UNICAST.UnicastHeader
-
- createSendFirstSeqnoHeader(long) -
Static method in class org.jgroups.protocols.UNICAST2.Unicast2Header
-
- createServerSocket(int, int) -
Method in class org.jgroups.blocks.ConnectionTableNIO
- Finds first available port starting at start_port and returns server socket.
- createServerSocket(String) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createServerSocket(String, int) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createServerSocket(String, int, int) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createServerSocket(String, int, int, InetAddress) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createServerSocket(String) -
Method in interface org.jgroups.util.SocketFactory
-
- createServerSocket(String, int) -
Method in interface org.jgroups.util.SocketFactory
-
- createServerSocket(String, int, int) -
Method in interface org.jgroups.util.SocketFactory
-
- createServerSocket(String, int, int, InetAddress) -
Method in interface org.jgroups.util.SocketFactory
-
- createServerSocket(SocketFactory, String, int) -
Static method in class org.jgroups.util.Util
- Finds first available port starting at start_port and returns server socket
- createServerSocket(SocketFactory, String, InetAddress, int) -
Static method in class org.jgroups.util.Util
-
- createServerSocket(SocketFactory, String, InetAddress, int, int) -
Static method in class org.jgroups.util.Util
- Finds first available port starting at start_port and returns server
socket.
- createSocket(String) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createSocket(String, String, int) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createSocket(String, InetAddress, int) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createSocket(String, String, int, InetAddress, int) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createSocket(String, InetAddress, int, InetAddress, int) -
Method in class org.jgroups.util.DefaultSocketFactory
-
- createSocket(String) -
Method in interface org.jgroups.util.SocketFactory
-
- createSocket(String, String, int) -
Method in interface org.jgroups.util.SocketFactory
-
- createSocket(String, InetAddress, int) -
Method in interface org.jgroups.util.SocketFactory
-
- createSocket(String, String, int, InetAddress, int) -
Method in interface org.jgroups.util.SocketFactory
-
- createSocket(String, InetAddress, int, InetAddress, int) -
Method in interface org.jgroups.util.SocketFactory
-
- createSockets() -
Method in class org.jgroups.protocols.UDP
- Create UDP sender and receiver sockets.
- createStableHeader(long, long) -
Static method in class org.jgroups.protocols.UNICAST2.Unicast2Header
-
- createThreadPool() -
Method in class org.jgroups.mux.Multiplexer
- Deprecated.
- createThreadPool(int, int, long, ThreadFactory) -
Static method in class org.jgroups.protocols.SCOPE
-
- createThreadPool(int, int, long, String, BlockingQueue<Runnable>, ThreadFactory) -
Static method in class org.jgroups.protocols.TP
-
- createTimer() -
Static method in class org.jgroups.util.Util
-
- createView(Address, long, Address...) -
Static method in class org.jgroups.util.Util
-
- createXmitReqHeader(long, long) -
Static method in class org.jgroups.protocols.UNICAST2.Unicast2Header
-
- createXmitRequestHeader(long, long, Address) -
Static method in class org.jgroups.protocols.pbcast.NakAckHeader
-
- createXmitResponseHeader() -
Static method in class org.jgroups.protocols.pbcast.NakAckHeader
-
- CREDIT_REQUEST -
Static variable in class org.jgroups.protocols.FcHeader
-
- CREDIT_REQUEST -
Static variable in class org.jgroups.protocols.SFC.Header
- Deprecated.
- CREDIT_REQUEST_HDR -
Static variable in class org.jgroups.protocols.FlowControl
-
- CreditMap - Class in org.jgroups.util
- Maintains credits for senders, when credits fall below 0, a sender blocks until new credits have been received.
- CreditMap(long) -
Constructor for class org.jgroups.util.CreditMap
-
- credits -
Variable in class org.jgroups.protocols.MFC
- Maintains credits per member
- credits -
Variable in class org.jgroups.util.CreditMap
-
- credits_available -
Variable in class org.jgroups.util.CreditMap
-
- credits_left -
Variable in class org.jgroups.protocols.FlowControl.Credit
-
- current_owner -
Variable in class org.jgroups.protocols.Locking.ServerLock
-
- CUSTOM_LOG_FACTORY -
Static variable in class org.jgroups.Global
-
- CustomLogFactory - Interface in org.jgroups.logging
- An extension interface allowing to plug in a custom log provider.
TimeScheduler
by extending
ScheduledThreadPoolExecutor
to keep tasks sorted.Channel.close()
.
Util.determineMergeParticipants(java.util.Map)
and contains only members
which are currently sub-partition coordinators.
LockService
.min_size
.
TP.getTimer()
instead to fetch the timer from the
transport and then invoke the method on it
RspList.entrySet()
or RspList.values()
instead
CompletionService
that uses a supplied ExecutionService
to execute tasks.LinkedBlockingQueue
as a completion queue.
Executors
class which
contains RunnableAdapter.ByteArrayInputStream
so that it uses buf
as its
buffer array.
ByteArrayInputStream
that uses buf
as its
buffer array.
ExtendedMessageListener
has additional callbacks for:
partial state transfer - http://jira.jboss.com/jira/browse/JGRP-118
streaming state transfer - http://jira.jboss.com/jira/browse/JGRP-89
org.jgroups.demos.DistributedHashtableDemo
to work.
BitSet
.0
through
size-1
.
data
map.
AddressGenerator
, or null if none is set
JChannel.getState(org.jgroups.Address, long)
instead
TP.isReceiveOnAllInterfaces()
instead
Channel.getClusterName()
instead
JChannel.getClusterName()
instead
remove()
).
data
map.
Channel.getAddress()
instead
Protocol.getThreadFactory()
instead
TP.getTimer()
to fetch the timer and call getCorePoolSize() directly
UUID
.
TimeScheduler
.null
).default handler
.
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).
JChannel
instance with the protocol stack
specified by the DEFAULT_PROTOCOL_STACK
member.
JChannel
instance with the protocol stack
configuration contained by the specified file.
JChannel
instance with the protocol stack
configuration contained by the specified XML element.
JChannel
instance with the protocol stack
configuration indicated by the specified URL.
JChannel
instance with the protocol stack
configuration based upon the specified properties parameter.
JChannel
instance with the protocol stack
configuration contained by the protocol stack configurator parameter.
JChannelFactory
instance that contains no
protocol stack configuration.
JChannelFactory
instance that utilizes the
specified file for protocl stack configuration.
JChannelFactory
instance that utilizes the
specified file for protocl stack configuration.
JChannelFactory
instance that utilizes the
specified file for protocl stack configuration.
JChannel
instance with the protocol stack
configuration based upon the specified properties parameter.
lockId
on behalf of the specified
owner
.
obj
for specified owner
.
DistributedLockManager.unlock(Object, Object, boolean)
method if a lock is only locally released, because it is locked
by multiple DistributedLockManagers.Log
instances.MembershipListener
instances.MessageListener
instances.setName()
has been called.
RspFilter.isAcceptable(Object, org.jgroups.Address)
, this method is called to see whether
we are done with the request and can unblock the caller
false
that occurs on or after the specified starting index.
true
that occurs on or after
the specified starting index.
MuxUpHandler
when a message is received with a specific MuxHeader
, but no corresponding handler is registered.NoMuxHandler
responses.UUID
which adds a string as payload.Receiver
instead, this method will not be available in JGroups 3.0
fqn
.
MethodCall
object from the message's buffer and prints it.
// Create a message to send to everyone
Message message = new Message( null, null, messagePayload );
// Add the priority protocol header
PrioHeader header = new PrioHeader( 1 );
short protocolId = ClassConfigurator.getProtocolId(PRIO.class);
message.putHeader( protocolId, header);
Receiver
instead, this class will be removed in JGroups 3.0Receiver
instead
Receiver
instead
FilePersistenceManager
or DBPersistenceManager
.
key
from the node's hashmap
obj
from all receiver sets and wake up
retransmission thread.
next_to_remove
, increments the latter.
addr
from connection table.
ConcurrentHashMap
with replication
of the contents across a cluster.count
field of this byte array output
stream to zero, so that all currently accumulated output in the
output stream is discarded.
RspList.clear()
instead
execute()
).
first_seqno
and last_seqno
.
getState()
object when calling receive()
.
getState()
object when
calling receive()
.
MessageDispatcher.sendMessage(org.jgroups.Message, RequestOptions)
instead
Clear
method.
Clear
method.
true
.
AddressGenerator
.
PullPushAdapter.addMembershipListener(org.jgroups.MembershipListener)
Channel.receive()
, as requested by
Channel.getState(s)
previously.listener
for state notification events.
Protocol.getThreadFactory()
instead
TP.setTimerThreadFactory(org.jgroups.util.ThreadFactory)
instead
Message.setFlag(byte)
but transient flags are never marshalled
Util.shutdown(Channel)
instead. This method will be removed in 3.0
Channel.connect(String)
.
Channel.connect(String)
.
StateTransferException
is thrown to indicate failure of
state transfer between cluster members.Channel.disconnect()
.
Channel.disconnect()
.
STREAMING_STATE_TRANSFER
, as its name implies, allows a
streaming state transfer between two channel instances.channel.receive()
, as a result
of another channel instance requesting a state from this channel.channel.receive()
, as requested by
channel.getState()
previously.suspected
is suspected: remove it
from all receiver sets.
thread
has just been created.
ThreadManager
notifying
it that the thread has been created or released from use.ThreadDecorator
to allow it to alter their state.thread
has just been released from use
(e.g.
TimeScheduler.scheduleWithDynamicInterval(org.jgroups.util.TimeScheduler.Task)
) must implementTimeScheduler
.UUID
which adds 3 strings (siteId, rackId and machineId)as payload.charsetName
.
toString(String enc)
method, which takes an encoding-name
argument, or the toString()
method, which uses the
platform's default character encoding.
String
object representing this UUID
.
lockId
on behalf of the specified
owner
.
lockId
on behalf of the specified
owner
.
obj
owned by specified owner
.
obj
owned by specified owner
.
true
or false
messages.
len
bytes from the specified byte array
starting at offset off
to this byte array output stream.
len
bytes from the specified byte array
starting at offset off
to the underlying output stream.
out.write(buf, 0, count)
.
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |