Package | Description |
---|---|
org.jgroups.auth | |
org.jgroups.blocks.cs |
This package contains all client-server related interfaces and classes
|
org.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
org.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
org.jgroups.stack |
Support for managing protocol stacks.
|
Modifier and Type | Method and Description |
---|---|
boolean |
FixedMembershipToken.isInMembersList(IpAddress sender) |
static boolean |
FixedMembershipToken.match(IpAddress sender,
java.net.InetSocketAddress addr) |
Modifier and Type | Method and Description |
---|---|
NioClient |
NioClient.remoteAddress(IpAddress addr)
Sets the address of the server.
|
TcpClient |
TcpClient.remoteAddress(IpAddress addr)
Sets the address of the server.
|
Constructor and Description |
---|
NioClient(IpAddress bind_addr,
IpAddress server_addr)
Creates an instance of an
NioClient that acts as a client: no server channel is created and
no acceptor is started to listen for incoming connections. |
NioServer(IpAddress bind_addr)
Creates an instance of NioServer.
|
TcpClient(IpAddress bind_addr,
IpAddress server_addr)
Creates an instance of an
TcpClient that acts as a client: no server socket is created and
no acceptor is started to listen for incoming connections. |
TcpServer(IpAddress bind_addr)
Creates an instance of TcpServer.
|
Modifier and Type | Field and Description |
---|---|
protected IpAddress |
UDP.mcast_addr
The multicast address (mcast address and port) this member uses
|
protected IpAddress |
FD_SOCK.FdHeader.sock_addr |
protected IpAddress |
FD_SOCK.srv_sock_addr |
Modifier and Type | Field and Description |
---|---|
protected LazyRemovalCache<Address,IpAddress> |
FD_SOCK.cache
Cache of member addresses and their ServerSocket addresses
|
protected Promise<java.util.Map<Address,IpAddress>> |
FD_SOCK.get_cache_promise
Used to rendezvous on GET_CACHE and GET_CACHE_RSP
|
protected Promise<IpAddress> |
FD_SOCK.ping_addr_promise |
Modifier and Type | Method and Description |
---|---|
protected IpAddress |
UDP.createLocalAddress() |
protected IpAddress |
FD_SOCK.fetchPingAddress(Address mbr)
Attempts to obtain the ping_addr first from the cache, then by unicasting q request to
mbr ,
then by multicasting a request to all members. |
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<Address,IpAddress> |
FD_SOCK.unmarshal(byte[] buffer,
int offset,
int length) |
Modifier and Type | Method and Description |
---|---|
protected void |
FD_SOCK.sendIHaveSockMessage(Address dst,
Address mbr,
IpAddress addr)
Sends or broadcasts a I_HAVE_SOCK response.
|
protected boolean |
FD_SOCK.setupPingSocket(IpAddress dest)
Creates a socket to
dest , and assigns it to ping_sock. |
Modifier and Type | Method and Description |
---|---|
static Buffer |
FD_SOCK.marshal(LazyRemovalCache<Address,IpAddress> addrs) |
Constructor and Description |
---|
FdHeader(byte type,
Address mbr,
IpAddress sock_addr) |
Modifier and Type | Field and Description |
---|---|
protected IpAddress |
STATE_SOCK.StateProviderAcceptor.address |
protected IpAddress |
StreamingStateTransfer.StateHeader.bind_addr |
Modifier and Type | Method and Description |
---|---|
IpAddress |
STATE_SOCK.StateProviderAcceptor.getServerSocketAddress() |
Constructor and Description |
---|
StateHeader(byte type,
IpAddress bind_addr,
Digest digest) |
Modifier and Type | Field and Description |
---|---|
protected IpAddress |
RouterStubManager.Target.bind_addr |
protected IpAddress |
RouterStub.local |
protected IpAddress |
RouterStub.remote |
protected IpAddress |
RouterStubManager.Target.router_addr |
Modifier and Type | Method and Description |
---|---|
IpAddress |
IpAddress.copy() |
IpAddress |
RouterStub.gossipRouterAddress() |
IpAddress |
RouterStub.local() |
IpAddress |
RouterStub.remote() |
Modifier and Type | Method and Description |
---|---|
RouterStub |
RouterStubManager.createAndRegisterStub(IpAddress local,
IpAddress router_addr) |
protected RouterStub |
RouterStubManager.find(IpAddress router_addr) |
RouterStub |
RouterStubManager.unregisterStub(IpAddress router_addr) |
Constructor and Description |
---|
RouterStub(IpAddress local,
IpAddress remote,
boolean use_nio,
RouterStub.CloseListener l) |
Target(IpAddress bind_addr,
IpAddress router_addr,
RouterStub.StubReceiver receiver) |
Copyright © 1998-2020 Red Hat. All Rights Reserved.