|
||||||||||
| 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()).
ChannelListenerfalse.
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