|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
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
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
-
- 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
-
- connectionPeerReceiver -
Variable in class org.jgroups.blocks.TCPConnectionMap.TCPConnection
-
- 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
-
- 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.Message
-
- 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
-
- 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.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) -
Static method in class org.jgroups.protocols.UNICAST.UnicastHeader
-
- 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
-
- 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
-
- 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
-
- 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) -
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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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
-
- 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.MutableDigest
-
- 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.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).
UUID.
TimeScheduler.null).default handler.
Channel.connect(String) has been
called, but hasn't returned yet
JChannel instance with the protocol stack
specified by the DEFAULT_PROTOCOL_STACK member.
Log instances.Message or a state transfer
events arrives to a node.setName() has been called.
TimeScheduler, used by unit testsRspFilter.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.fqn.
// 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);
key from the node's hashmap
addrfrom connection table.
ConcurrentMap 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.
execute()).
first_seqno and last_seqno.
Channel.send(Message).
Clear method.
true.
AddressGenerator.
DiagnosticsHandler.
Message.setFlag(Flag...) except that transient flags are not marshalled
Channel.connect(String).
Channel.connect(String).
STATE_SOCK has the state provider create a server socket to which the state
requester connects and from which the latter reads the state.StateTransferException is thrown to indicate a failure of a state transfer between
cluster members.Channel.disconnect().
Channel.disconnect().
MessageListener.getState(java.io.OutputStream) in the applicationSuppressCache) which suppresses (certain) messages from the same member for a given timeStreamingStateTransfer.max_pool and StreamingStateTransfer.pool_thread_keep_alive) to run
StreamingStateTransfer.StateGetter threads on
TimeScheduler.scheduleWithDynamicInterval(org.jgroups.util.TimeScheduler.Task)) must implementTimeScheduler.TimeScheduler.UUID which adds 3 strings (siteId, rackId and machineId)as payload.charsetName.
String object representing this UUID.
Table.forEach(long,long,org.jgroups.util.Table.Visitor).
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 | |||||||||