程序包 | 说明 |
---|---|
com.fr.third.jgroups |
Provides top-level public JGroups classes such as Channel, Message, etc.
|
com.fr.third.jgroups.blocks |
Provides building blocks that are layered on top of channels.
|
com.fr.third.jgroups.protocols |
Provides implementations of transport protocols which are
responsible for sending and receiving messages to/from the network.
|
com.fr.third.jgroups.protocols.pbcast |
Supports probabilistic broadcasts.
|
com.fr.third.jgroups.tests.perf | |
com.fr.third.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
限定符和类型 | 方法和说明 |
---|---|
Message |
Message.setBuffer(Buffer buf)
Note that the byte[] buffer passed as argument must not be modified.
|
限定符和类型 | 方法和说明 |
---|---|
Buffer |
RpcDispatcher.Marshaller.objectToBuffer(java.lang.Object obj)
Marshals the object into a byte[] buffer and returns a Buffer with a ref to the underlying byte[] buffer,
offset and length.
|
限定符和类型 | 方法和说明 |
---|---|
static Buffer |
FD_SOCK.marshal(java.util.Map<Address,IpAddress> addrs) |
static Buffer |
Discovery.marshal(PingData data) |
static Buffer |
MERGE3.marshal(View view) |
protected static Buffer |
COUNTER.requestToBuffer(COUNTER.Request req) |
protected static Buffer |
COUNTER.responseToBuffer(COUNTER.Response rsp) |
protected static Buffer |
COUNTER.streamableToBuffer(byte req_or_rsp,
byte type,
Streamable obj) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
COUNTER.send(Address dest,
Buffer buffer) |
限定符和类型 | 方法和说明 |
---|---|
protected static Buffer |
GMS.marshal(java.util.Collection<? extends Address> mbrs) |
protected static Buffer |
FLUSH.marshal(java.util.Collection<? extends Address> participants,
Digest digest) |
static Buffer |
STABLE.marshal(Digest digest) |
static Buffer |
GMS.marshal(JoinRsp join_rsp) |
protected static Buffer |
GMS.marshal(View view,
Digest digest) |
protected static Buffer |
GMS.marshal(ViewId view_id) |
限定符和类型 | 方法和说明 |
---|---|
Buffer |
MPerfRpc.MperfMarshaller.objectToBuffer(java.lang.Object obj) |
限定符和类型 | 方法和说明 |
---|---|
Buffer |
Buffer.copy() |
Buffer |
ByteArrayDataOutputStream.getBuffer() |
Buffer |
ByteBufferOutputStream.getBufferAsBuffer() |
static Buffer |
Util.messageToByteBuffer(Message msg) |
static Buffer |
Util.streamableToBuffer(Streamable obj) |