|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
Protocol.up(org.jgroups.util.MessageBatch) for each message to determine
if the message should be removed from the message batch (and handled by the current protocol) or not.
first_seqno to last_seqno for retransmission
UUID which adds a string as payload.RetransmitTable.purge(long) is called.
UUID which adds a boolean as payload.TopologyUUID which adds a boolean as payload.false.
BlockingInputStream.close() is called
Rule.eval() returning true
TCPConnection#TCPConnection(org.jgroups.Address)
connect() and then getState.
If the FLUSH protocol is in the channel's stack definition, only one flush round is executed for both connecting and
fetching the state rather than two flushes if we invoke connect and getState in succession.
- connect(RouterStub, String, Address) -
Method in class org.jgroups.protocols.TCPGOSSIP
-
- connect(List<RouterStub>, String, Address, String, List<PhysicalAddress>) -
Method in interface org.jgroups.protocols.TUNNEL.TUNNELPolicy
-
- CONNECT -
Static variable in class org.jgroups.stack.GossipRouter
-
- connect(String, Address, String, List<PhysicalAddress>) -
Method in class org.jgroups.stack.RouterStub
- Register this process with the router under
group.
- connect(Socket, SocketAddress, int) -
Static method in class org.jgroups.util.Util
- Utility method.
- connect_count -
Variable in class org.jgroups.protocols.TP
- Keeps track of connects and disconnects, in order to start and stop threads
- CONNECT_OK -
Static variable in class org.jgroups.stack.GossipRouter
-
- CONNECT_USE_FLUSH -
Static variable in class org.jgroups.Event
-
- CONNECT_WITH_STATE_TRANSFER -
Static variable in class org.jgroups.Event
-
- CONNECT_WITH_STATE_TRANSFER_USE_FLUSH -
Static variable in class org.jgroups.Event
-
- connectAllStubs(String, Address) -
Method in class org.jgroups.protocols.TCPGOSSIP
-
- Connection - Interface in org.jgroups.blocks
-
- connection_driver -
Variable in class org.jgroups.protocols.JDBC_PING
-
- connection_password -
Variable in class org.jgroups.protocols.JDBC_PING
-
- connection_reaper -
Variable in class org.jgroups.protocols.UNICAST
-
- connection_reaper -
Variable in class org.jgroups.protocols.UNICAST2
-
- connection_url -
Variable in class org.jgroups.protocols.JDBC_PING
-
- connection_username -
Variable in class org.jgroups.protocols.JDBC_PING
-
- connectionClosed(Address) -
Method in interface org.jgroups.blocks.AbstractConnectionMap.ConnectionMapListener
-
- connectionClosed(Address) -
Method in interface org.jgroups.blocks.BasicConnectionTable.ConnectionListener
-
- connectionEstablished(Address) -
Method in class org.jgroups.protocols.UNICAST2
- Is the send connection to target established
- connectionEstablishedTo(Address) -
Method in class org.jgroups.blocks.TCPConnectionMap
-
- connectionEstablishedTo(Address) -
Method in class org.jgroups.blocks.TCPConnectionMap.Mapper
-
- ConnectionMap<V extends Connection> - Interface in org.jgroups.blocks
-
- connectionOpened(Address, V) -
Method in interface org.jgroups.blocks.AbstractConnectionMap.ConnectionMapListener
-
- connectionOpened(Address) -
Method in interface org.jgroups.blocks.BasicConnectionTable.ConnectionListener
-
- connections -
Variable in class org.jgroups.protocols.STOMP
-
- connectionState -
Variable in class org.jgroups.stack.RouterStub
-
- connectionStateChanged(RouterStub.ConnectionStatus) -
Method in class org.jgroups.stack.RouterStub
-
- connectionStatusChange(RouterStub, RouterStub.ConnectionStatus) -
Method in interface org.jgroups.stack.RouterStub.ConnectionListener
-
- connectionStatusChange(RouterStub, RouterStub.ConnectionStatus) -
Method in class org.jgroups.stack.RouterStubManager
-
- ConnectionTableNIO - Class in org.jgroups.blocks
- Manages incoming and outgoing TCP connections.
- ConnectionTableNIO(int) -
Constructor for class org.jgroups.blocks.ConnectionTableNIO
-
- ConnectionTableNIO(int, long, long) -
Constructor for class org.jgroups.blocks.ConnectionTableNIO
-
- ConnectionTableNIO(BasicConnectionTable.Receiver, InetAddress, InetAddress, int, int, int) -
Constructor for class org.jgroups.blocks.ConnectionTableNIO
-
- ConnectionTableNIO(BasicConnectionTable.Receiver, InetAddress, InetAddress, int, int, int, boolean) -
Constructor for class org.jgroups.blocks.ConnectionTableNIO
-
- ConnectionTableNIO(BasicConnectionTable.Receiver, InetAddress, InetAddress, int, int, int, long, long) -
Constructor for class org.jgroups.blocks.ConnectionTableNIO
-
- ConnectionTableNIO(BasicConnectionTable.Receiver, InetAddress, InetAddress, int, int, int, long, long, boolean) -
Constructor for class org.jgroups.blocks.ConnectionTableNIO
-
- ConnectionTableNIO.MyFuture - Class in org.jgroups.blocks
-
- ConnectionTableNIO.MyFuture() -
Constructor for class org.jgroups.blocks.ConnectionTableNIO.MyFuture
-
- ConnectionTableNIO.SelectorWriteHandler - Class in org.jgroups.blocks
-
- ConnectionTableNIO.WriteRequest - Class in org.jgroups.blocks
-
- connectionTearListeners -
Variable in class org.jgroups.stack.GossipRouter
-
- connectionTorn(GossipRouter.ConnectionHandler, Exception) -
Method in interface org.jgroups.stack.GossipRouter.ConnectionTearListener
-
- connectLock -
Variable in class org.jgroups.protocols.TP
-
- connectProtocols(List<Protocol>) -
Static method in class org.jgroups.stack.Configurator
- Creates a protocol stack by iterating through the protocol list and connecting
adjacent layers.
- connectToDestination(String) -
Method in class org.jgroups.client.StompConnection
-
- connEstablished() -
Method in class org.jgroups.protocols.UNICAST2.SenderEntry
-
- connEstablished(boolean) -
Method in class org.jgroups.protocols.UNICAST2.SenderEntry
-
- connId() -
Method in class org.jgroups.protocols.UNICAST3.Header
-
- conns -
Variable in class org.jgroups.blocks.AbstractConnectionMap
-
- CONSUMER_READY -
Static variable in class org.jgroups.blocks.executor.ExecutorEvent
-
- container -
Variable in class org.jgroups.protocols.RACKSPACE_PING
-
- container -
Variable in class org.jgroups.protocols.SWIFT_PING
-
- contains(Address) -
Method in class org.jgroups.Membership
- Returns true if the provided member belongs to this membership
- contains(K) -
Method in class org.jgroups.util.AgeOutCache
-
- contains(Address) -
Method in class org.jgroups.util.Digest
-
- contains(K) -
Method in class org.jgroups.util.ExpiryCache
-
- contains(long) -
Method in class org.jgroups.util.Seqno
-
- contains(long) -
Method in class org.jgroups.util.SeqnoRange
-
- contains(T, T[]) -
Static method in class org.jgroups.util.Util
-
- containsAll(Digest) -
Method in class org.jgroups.util.Digest
- Returns true if our 'members' array contains all of the elements in other.members
- containsId(short, short[]) -
Static method in class org.jgroups.util.Util
-
- containsKey(K) -
Method in class org.jgroups.blocks.LazyRemovalCache
-
- containsKey(Object) -
Method in class org.jgroups.blocks.ReplicatedHashMap
-
- containsKey(Object) -
Method in class org.jgroups.util.RspList
-
- containsKeys(Collection<K>) -
Method in class org.jgroups.blocks.LazyRemovalCache
- Returns true if all of the keys in keys are present.
- containsMember(Address) -
Method in class org.jgroups.View
- Returns true, if this view contains a certain member
- containsValue(Object) -
Method in class org.jgroups.blocks.ReplicatedHashMap
-
- containsValue(Object) -
Method in class org.jgroups.util.RspList
-
- containsViewId(Collection<View>, ViewId) -
Static method in class org.jgroups.util.Util
-
- contents() -
Method in class org.jgroups.blocks.LazyRemovalCache
-
- contentsCleared() -
Method in interface org.jgroups.blocks.ReplicatedHashMap.Notification
-
- contentsCleared() -
Method in class org.jgroups.demos.ReplicatedHashMapDemo
-
- contentsSet(Map<K, V>) -
Method in interface org.jgroups.blocks.ReplicatedHashMap.Notification
-
- contentsSet(Map<Object, Object>) -
Method in class org.jgroups.demos.ReplicatedHashMapDemo
-
- convert(String, Class<?>) -
Static method in class org.jgroups.blocks.MethodCall
-
- convert(Object, Class<?>, String, String, boolean) -
Method in interface org.jgroups.conf.PropertyConverter
-
- convert(Object, Class<?>, String, String, boolean) -
Method in class org.jgroups.conf.PropertyConverters.BindInterface
-
- convert(Object, Class<?>, String, String, boolean) -
Method in class org.jgroups.conf.PropertyConverters.Default
-
- convert(Object, Class<?>, String, String, boolean) -
Method in class org.jgroups.conf.PropertyConverters.FlushInvoker
-
- convert(Object, Class<?>, String, String, boolean) -
Method in class org.jgroups.conf.PropertyConverters.InitialHosts
-
- convert(Object, Class<?>, String, String, boolean) -
Method in class org.jgroups.conf.PropertyConverters.InitialHosts2
-
- convert(Object, Class<?>, String, String, boolean) -
Method in class org.jgroups.conf.PropertyConverters.IntegerArray
-
- convert(Object, Class<?>, String, String, boolean) -
Method in class org.jgroups.conf.PropertyConverters.LongArray
-
- convert(Object, Class<?>, String, String, boolean) -
Method in class org.jgroups.conf.PropertyConverters.NetworkInterfaceList
-
- cookie -
Variable in class org.jgroups.blocks.TCPConnectionMap.TCPConnection
-
- coord -
Variable in class org.jgroups.protocols.CENTRAL_EXECUTOR
-
- coord -
Variable in class org.jgroups.protocols.CENTRAL_LOCK
-
- coord -
Variable in class org.jgroups.protocols.COUNTER
- The address of the cluster coordinator.
- coord -
Variable in class org.jgroups.protocols.FORWARD_TO_COORD
- the address of the current coordinator, all msgs are forwarded to it
- coord -
Variable in class org.jgroups.protocols.RELAY
-
- coord -
Variable in class org.jgroups.protocols.relay.RELAY2
-
- coord -
Variable in class org.jgroups.protocols.SEQUENCER
-
- CoordGmsImpl - Class in org.jgroups.protocols.pbcast
- Coordinator role of the Group MemberShip (GMS) protocol.
- CoordGmsImpl(GMS) -
Constructor for class org.jgroups.protocols.pbcast.CoordGmsImpl
-
- coordinator -
Variable in class org.jgroups.protocols.pbcast.STABLE
-
- coordinatorChosen() -
Method in class org.jgroups.demos.Topology
-
- copy() -
Method in class org.jgroups.Membership
- Returns a copy of this membership
- copy() -
Method in class org.jgroups.MergeView
-
- copy() -
Method in class org.jgroups.Message
-
- copy(boolean) -
Method in class org.jgroups.Message
- Create a copy of the message.
- copy(boolean, boolean) -
Method in class org.jgroups.Message
- Create a copy of the message.
- copy(boolean, short) -
Method in class org.jgroups.Message
- Doesn't copy any headers except for those with ID >= copy_headers_above
- copy(boolean, short, short...) -
Method in class org.jgroups.Message
- Copies a message.
- copy() -
Method in class org.jgroups.protocols.pbcast.NakAckHeader
-
- copy() -
Method in class org.jgroups.protocols.pbcast.NakAckHeader2
-
- copy(Message) -
Method in class org.jgroups.protocols.relay.RELAY2
- Copies the message, but only the headers above the current protocol (RELAY) (or RpcDispatcher related headers)
- copy() -
Method in class org.jgroups.protocols.relay.SiteMaster
-
- copy() -
Method in class org.jgroups.protocols.relay.SiteUUID
-
- copy() -
Method in class org.jgroups.protocols.tom.MessageID
-
- copy() -
Method in class org.jgroups.protocols.UNICAST.UnicastHeader
-
- copy() -
Method in class org.jgroups.protocols.UNICAST2.Unicast2Header
-
- copy() -
Method in class org.jgroups.protocols.UNICAST3.Header
-
- copy() -
Method in class org.jgroups.stack.ExponentialInterval
- We don't need to copy as we don't have any state
- copy() -
Method in interface org.jgroups.stack.Interval
- Returns a copy of the state.
- copy() -
Method in class org.jgroups.stack.IpAddress
-
- copy() -
Method in class org.jgroups.stack.StateTransferInfo
-
- copy() -
Method in class org.jgroups.stack.StaticInterval
-
- copy() -
Method in class org.jgroups.util.Buffer
-
- copy() -
Method in class org.jgroups.util.Digest
-
- copy() -
Method in class org.jgroups.util.Headers
-
- copy() -
Method in class org.jgroups.util.MutableDigest
-
- copy(Reader, Writer) -
Static method in class org.jgroups.util.PropertiesToXML
-
- copy() -
Method in class org.jgroups.util.UUID
-
- copy() -
Method in class org.jgroups.View
-
- copy() -
Method in class org.jgroups.ViewId
-
- copy_multicast_msgs -
Variable in class org.jgroups.protocols.DUPL
-
- copy_unicast_msgs -
Variable in class org.jgroups.protocols.DUPL
-
- copyLocksTo(List<Address>) -
Method in class org.jgroups.protocols.CENTRAL_LOCK
-
- copyProtocols(ProtocolStack) -
Method in class org.jgroups.stack.ProtocolStack
-
- copyQueueTo(List<Address>) -
Method in class org.jgroups.protocols.CENTRAL_EXECUTOR
-
- corr -
Variable in class org.jgroups.blocks.MessageDispatcher
-
- corr -
Variable in class org.jgroups.blocks.Request
-
- correlatorStarted() -
Method in class org.jgroups.blocks.MessageDispatcher
-
- correlatorStarted() -
Method in class org.jgroups.blocks.RpcDispatcher
-
- corrId -
Variable in class org.jgroups.blocks.RequestCorrelator.Header
- The unique ID of the associated RequestCorrelator
- count(boolean) -
Method in class org.jgroups.util.RingBuffer
-
- count(boolean) -
Method in class org.jgroups.util.RingBufferLockless
-
- count -
Variable in class org.jgroups.util.SuppressCache.Value
-
- count() -
Method in class org.jgroups.util.SuppressCache.Value
-
- count_size -
Variable in class org.jgroups.protocols.pbcast.NAKACK2.Counter
-
- Counter - Interface in org.jgroups.blocks.atomic
-
- COUNTER - Class in org.jgroups.protocols
- Protocol which is used by
CounterService to provide a distributed atomic counter - COUNTER() -
Constructor for class org.jgroups.protocols.COUNTER
-
- counter -
Static variable in class org.jgroups.protocols.Executing
- This keeps track of all the requests we send.
- counter -
Variable in class org.jgroups.util.DefaultThreadFactory
-
- COUNTER.AddAndGetRequest - Class in org.jgroups.protocols
-
- COUNTER.AddAndGetRequest() -
Constructor for class org.jgroups.protocols.COUNTER.AddAndGetRequest
-
- COUNTER.AddAndGetRequest(Owner, String, long) -
Constructor for class org.jgroups.protocols.COUNTER.AddAndGetRequest
-
- COUNTER.BooleanResponse - Class in org.jgroups.protocols
-
- COUNTER.BooleanResponse() -
Constructor for class org.jgroups.protocols.COUNTER.BooleanResponse
-
- COUNTER.BooleanResponse(Owner, long, boolean) -
Constructor for class org.jgroups.protocols.COUNTER.BooleanResponse
-
- COUNTER.CompareAndSetRequest - Class in org.jgroups.protocols
-
- COUNTER.CompareAndSetRequest() -
Constructor for class org.jgroups.protocols.COUNTER.CompareAndSetRequest
-
- COUNTER.CompareAndSetRequest(Owner, String, long, long) -
Constructor for class org.jgroups.protocols.COUNTER.CompareAndSetRequest
-
- COUNTER.CounterHeader - Class in org.jgroups.protocols
-
- COUNTER.CounterHeader() -
Constructor for class org.jgroups.protocols.COUNTER.CounterHeader
-
- COUNTER.CounterImpl - Class in org.jgroups.protocols
-
- COUNTER.CounterImpl(String) -
Constructor for class org.jgroups.protocols.COUNTER.CounterImpl
-
- COUNTER.DeleteRequest - Class in org.jgroups.protocols
-
- COUNTER.DeleteRequest() -
Constructor for class org.jgroups.protocols.COUNTER.DeleteRequest
-
- COUNTER.DeleteRequest(Owner, String) -
Constructor for class org.jgroups.protocols.COUNTER.DeleteRequest
-
- COUNTER.ExceptionResponse - Class in org.jgroups.protocols
-
- COUNTER.ExceptionResponse() -
Constructor for class org.jgroups.protocols.COUNTER.ExceptionResponse
-
- COUNTER.ExceptionResponse(Owner, String) -
Constructor for class org.jgroups.protocols.COUNTER.ExceptionResponse
-
- COUNTER.GetOrCreateRequest - Class in org.jgroups.protocols
-
- COUNTER.GetOrCreateRequest() -
Constructor for class org.jgroups.protocols.COUNTER.GetOrCreateRequest
-
- COUNTER.GetOrCreateResponse - Class in org.jgroups.protocols
-
- COUNTER.GetOrCreateResponse() -
Constructor for class org.jgroups.protocols.COUNTER.GetOrCreateResponse
-
- COUNTER.GetOrCreateResponse(Owner, long, long) -
Constructor for class org.jgroups.protocols.COUNTER.GetOrCreateResponse
-
- COUNTER.ReconcileRequest - Class in org.jgroups.protocols
-
- COUNTER.ReconcileRequest() -
Constructor for class org.jgroups.protocols.COUNTER.ReconcileRequest
-
- COUNTER.ReconcileRequest(String[], long[], long[]) -
Constructor for class org.jgroups.protocols.COUNTER.ReconcileRequest
-
- COUNTER.ReconcileResponse - Class in org.jgroups.protocols
-
- COUNTER.ReconcileResponse() -
Constructor for class org.jgroups.protocols.COUNTER.ReconcileResponse
-
- COUNTER.ReconcileResponse(String[], long[], long[]) -
Constructor for class org.jgroups.protocols.COUNTER.ReconcileResponse
-
- COUNTER.ReconciliationTask - Class in org.jgroups.protocols
-
- COUNTER.ReconciliationTask() -
Constructor for class org.jgroups.protocols.COUNTER.ReconciliationTask
-
- COUNTER.Request - Class in org.jgroups.protocols
-
- COUNTER.Request() -
Constructor for class org.jgroups.protocols.COUNTER.Request
-
- COUNTER.RequestType - Enum in org.jgroups.protocols
-
- COUNTER.ResendPendingRequests - Class in org.jgroups.protocols
-
- COUNTER.ResendPendingRequests() -
Constructor for class org.jgroups.protocols.COUNTER.ResendPendingRequests
-
- COUNTER.Response - Class in org.jgroups.protocols
-
- COUNTER.Response() -
Constructor for class org.jgroups.protocols.COUNTER.Response
-
- COUNTER.ResponseType - Enum in org.jgroups.protocols
-
- COUNTER.SetRequest - Class in org.jgroups.protocols
-
- COUNTER.SetRequest() -
Constructor for class org.jgroups.protocols.COUNTER.SetRequest
-
- COUNTER.SetRequest(Owner, String, long) -
Constructor for class org.jgroups.protocols.COUNTER.SetRequest
-
- COUNTER.SimpleRequest - Class in org.jgroups.protocols
-
- COUNTER.SimpleRequest() -
Constructor for class org.jgroups.protocols.COUNTER.SimpleRequest
-
- COUNTER.SimpleRequest(Owner, String) -
Constructor for class org.jgroups.protocols.COUNTER.SimpleRequest
-
- COUNTER.SimpleResponse - Class in org.jgroups.protocols
- Response without data
- COUNTER.SimpleResponse() -
Constructor for class org.jgroups.protocols.COUNTER.SimpleResponse
-
- COUNTER.SimpleResponse(Owner, long) -
Constructor for class org.jgroups.protocols.COUNTER.SimpleResponse
-
- COUNTER.UpdateRequest - Class in org.jgroups.protocols
-
- COUNTER.UpdateRequest() -
Constructor for class org.jgroups.protocols.COUNTER.UpdateRequest
-
- COUNTER.UpdateRequest(String, long, long) -
Constructor for class org.jgroups.protocols.COUNTER.UpdateRequest
-
- COUNTER.ValueResponse - Class in org.jgroups.protocols
-
- COUNTER.ValueResponse() -
Constructor for class org.jgroups.protocols.COUNTER.ValueResponse
-
- COUNTER.ValueResponse(Owner, long, long) -
Constructor for class org.jgroups.protocols.COUNTER.ValueResponse
-
- COUNTER.VersionedValue - Class in org.jgroups.protocols
-
- COUNTER.VersionedValue(long) -
Constructor for class org.jgroups.protocols.COUNTER.VersionedValue
-
- COUNTER.VersionedValue(long, long) -
Constructor for class org.jgroups.protocols.COUNTER.VersionedValue
-
- counter_prot -
Variable in class org.jgroups.blocks.atomic.CounterService
-
- counters -
Variable in class org.jgroups.protocols.COUNTER
-
- CounterService - Class in org.jgroups.blocks.atomic
- Provides a distributed counter (similar to AtomicLong) which can be atomically updated across a cluster.
- CounterService(JChannel) -
Constructor for class org.jgroups.blocks.atomic.CounterService
-
- CounterServiceDemo - Class in org.jgroups.demos
-
- CounterServiceDemo() -
Constructor for class org.jgroups.demos.CounterServiceDemo
-
- crash() -
Static method in class org.jgroups.util.Util
-
- create() -
Method in interface org.jgroups.blocks.ReplCache.HashFunctionFactory
-
- create(RELAY.RelayHeader.Type) -
Static method in class org.jgroups.protocols.RELAY.RelayHeader
-
- create(View, View) -
Static method in class org.jgroups.protocols.RELAY.ViewData
-
- create(Address) -
Static method in class org.jgroups.util.MergeId
-
- createAcceptor() -
Method in class org.jgroups.protocols.pbcast.STATE_SOCK
-
- createAckHeader(long, short) -
Static method in class org.jgroups.protocols.UNICAST.UnicastHeader
-
- createAckHeader(long, short) -
Static method in class org.jgroups.protocols.UNICAST2.Unicast2Header
-
- createAckHeader(long, short) -
Static method in class org.jgroups.protocols.UNICAST3.Header
-
- createAndRegisterStub(String, int, InetAddress) -
Method in class org.jgroups.stack.RouterStubManager
-
- createArrays(int) -
Method in class org.jgroups.util.Digest
-
- createArrays(Map<Address, long[]>) -
Method in class org.jgroups.util.Digest
-
- createAuthenticationDigest(String, long, double) -
Static method in class org.jgroups.util.Util
-
- createBridge() -
Method in class org.jgroups.protocols.RELAY
-
- createChannel() -
Method in class org.jgroups.protocols.relay.config.RelayConfig.BridgeConfig
-
- createChannel() -
Method in class org.jgroups.protocols.relay.config.RelayConfig.ProgrammaticBridgeConfig
-
- createChannel() -
Method in class org.jgroups.protocols.relay.config.RelayConfig.PropertiesBridgeConfig
-
- createChannel(Protocol...) -
Static method in class org.jgroups.util.Util
-
- createCloseHeader(short) -
Static method in class org.jgroups.protocols.UNICAST3.Header
-
- 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, int) -
Method in class org.jgroups.protocols.TCP
-
- createContainer(String) -
Method in class org.jgroups.protocols.SWIFT_PING.SwiftClient
- Create a container, which is equivalent to a bucket
- 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
-
- createDataHeader(long, short, boolean) -
Static method in class org.jgroups.protocols.UNICAST3.Header
-
- createDigest(String, long, double) -
Static method in class org.jgroups.util.Util
-
- createDiskCacheFile() -
Method in class org.jgroups.protocols.PDC
-
- 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
- Deprecated.
- 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
-
- createHeaders(int) -
Static method in class org.jgroups.Message
-
- createHeaders(Headers) -
Static method in class org.jgroups.Message
-
- createInetAddressMap(List<ProtocolConfiguration>, List<Protocol>) -
Static method in class org.jgroups.stack.Configurator
-
- createInfo(ViewId, String, Collection<PhysicalAddress>) -
Static method in class org.jgroups.protocols.MERGE3.MergeHeader
-
- createInstance(RspFilter) -
Static method in class org.jgroups.blocks.mux.NoMuxHandlerRspFilter
-
- createLayer(ProtocolStack, ProtocolConfiguration) -
Static method in class org.jgroups.stack.Configurator
-
- createLocalAddress() -
Method in class org.jgroups.protocols.UDP
-
- createLock(String, Owner) -
Method in class org.jgroups.protocols.Locking
-
- createLock(String) -
Method in class org.jgroups.protocols.PEER_LOCK
-
- createMessage(Address, Address, Address, Message) -
Method in class org.jgroups.protocols.relay.Relayer.Route
-
- createMessageHeader(long) -
Static method in class org.jgroups.protocols.pbcast.NakAckHeader
-
- createMessageHeader(long) -
Static method in class org.jgroups.protocols.pbcast.NakAckHeader2
-
- createMessageHeader(short) -
Static method in class org.jgroups.protocols.SCOPE.ScopeHeader
- Deprecated.
- 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
-
- createNewFile() -
Method in class org.jgroups.blocks.GridFile
-
- createNewHeader(byte, MessageID) -
Static method in class org.jgroups.protocols.tom.ToaHeader
-
- createObject(String, String, byte[]) -
Method in class org.jgroups.protocols.SWIFT_PING.SwiftClient
- Create an object (=file)
- 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
-
- createReceiverEntry(Address, long, short) -
Method in class org.jgroups.protocols.UNICAST3
-
- createRequest(COUNTER.RequestType) -
Static method in class org.jgroups.protocols.COUNTER
-
- createRequestCorrelator(Protocol, RequestHandler, Address) -
Method in class org.jgroups.blocks.MessageDispatcher
-
- createRequestCorrelator(Protocol, RequestHandler, Address) -
Method in class org.jgroups.blocks.mux.MuxMessageDispatcher
-
- createRequestCorrelator(Protocol, RequestHandler, Address) -
Method in class org.jgroups.blocks.mux.MuxRpcDispatcher
-
- createResponse(COUNTER.ResponseType) -
Static method in class org.jgroups.protocols.COUNTER
-
- 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.RACKSPACE_PING
-
- createRootDir() -
Method in class org.jgroups.protocols.S3_PING
-
- createRootDir() -
Method in class org.jgroups.protocols.SWIFT_PING
-
- createSendFirstSeqnoHeader(long) -
Static method in class org.jgroups.protocols.UNICAST.UnicastHeader
-
- createSendFirstSeqnoHeader(long) -
Static method in class org.jgroups.protocols.UNICAST2.Unicast2Header
-
- createSendFirstSeqnoHeader() -
Static method in class org.jgroups.protocols.UNICAST3.Header
-
- 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, 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.
- createSingleDestinationHeader() -
Static method in class org.jgroups.protocols.tom.ToaHeader
-
- 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(short, long, long) -
Static method in class org.jgroups.protocols.UNICAST2.Unicast2Header
-
- createStreamToProvider(Address, StreamingStateTransfer.StateHeader) -
Method in class org.jgroups.protocols.pbcast.STATE
-
- createStreamToProvider(Address, StreamingStateTransfer.StateHeader) -
Method in class org.jgroups.protocols.pbcast.STATE_SOCK
-
- createStreamToProvider(Address, StreamingStateTransfer.StateHeader) -
Method in class org.jgroups.protocols.pbcast.StreamingStateTransfer
- Creates an InputStream to the state provider to read the state
- createStreamToRequester(Address) -
Method in class org.jgroups.protocols.pbcast.STATE
-
- createStreamToRequester(Address) -
Method in class org.jgroups.protocols.pbcast.STATE_SOCK
-
- createStreamToRequester(Address) -
Method in class org.jgroups.protocols.pbcast.StreamingStateTransfer
- Creates an OutputStream to the state requester to write the state
- createTable(long) -
Method in class org.jgroups.protocols.pbcast.NAKACK2
-
- createThreadPool() -
Method in class org.jgroups.protocols.pbcast.StreamingStateTransfer
-
- createThreadPool(int, int, long, ThreadFactory) -
Static method in class org.jgroups.protocols.SCOPE
- Deprecated.
- 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
-
- createViewRequest() -
Static method in class org.jgroups.protocols.MERGE3.MergeHeader
-
- createViewResponse(View) -
Static method in class org.jgroups.protocols.MERGE3.MergeHeader
-
- createXmitReqHeader() -
Static method in class org.jgroups.protocols.UNICAST2.Unicast2Header
-
- createXmitReqHeader() -
Static method in class org.jgroups.protocols.UNICAST3.Header
-
- createXmitRequestHeader(long, long, Address) -
Static method in class org.jgroups.protocols.pbcast.NakAckHeader
-
- createXmitRequestHeader(Address) -
Static method in class org.jgroups.protocols.pbcast.NakAckHeader2
-
- createXmitResponseHeader() -
Static method in class org.jgroups.protocols.pbcast.NakAckHeader
-
- createXmitResponseHeader() -
Static method in class org.jgroups.protocols.pbcast.NakAckHeader2
-
- creator -
Variable in class org.jgroups.ViewId
-
- CREDIT_REQUEST -
Static variable in class org.jgroups.protocols.FcHeader
-
- 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
-
- curr_id -
Variable in class org.jgroups.protocols.FRAG2
- Used to assign fragmentation-specific sequence IDs (monotonically increasing)
- current -
Variable in class org.jgroups.util.RingBuffer.RingBufferIterator
-
- current -
Variable in class org.jgroups.util.RingBufferLockless.RingBufferIterator
-
- current_coord -
Variable in class org.jgroups.protocols.Discovery
-
- current_id -
Variable in class org.jgroups.protocols.FORWARD_TO_COORD
- ID to be used to identify forwarded messages.
- current_id -
Variable in class org.jgroups.protocols.RSVP
- ID to be used to identify messages.
- current_index -
Variable in class org.jgroups.util.MessageBatch.BatchIterator
-
- current_index -
Variable in class org.jgroups.util.MutableDigest
-
- current_owner -
Variable in class org.jgroups.protocols.Locking.ServerLock
-
- CUSTOM_LOG_FACTORY -
Static variable in class org.jgroups.Global
-
- custom_log_factory -
Static variable in class org.jgroups.logging.LogFactory
-
- CustomLogFactory - Interface in org.jgroups.logging
- An extension interface allowing to plug in a custom log provider.
- CustomRejectionPolicy - Class in org.jgroups.util
- // TODO: Document this
- CustomRejectionPolicy(String) -
Constructor for class org.jgroups.util.CustomRejectionPolicy
-
TimeScheduler by extending
ScheduledThreadPoolExecutor to keep tasks sorted.Channel.close().
Util.determineMergeCoords(java.util.Map) but only actual coordinators are counted: an actual
coord is when the sender of a view is the first member of that view
Util.determineMergeParticipants(java.util.Map) and contains only members
which are currently sub-partition coordinators.
min_size.
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.
BitSet.0 through
size-1.
data
map.
AddressGenerator, or null if none is set
remove()).
data map.
Channel.setReceiver(Receiver) , null otherwise
sender (create if not).
sender (create if not).
sender (create if not).
UUID.
TimeScheduler.null).default handler.
Channel.connect(String) has been
called, but hasn't returned yet