public class Protocol extends BinaryProtocol
Modifier and Type | Class and Description |
---|---|
class |
Protocol.Ack |
class |
Protocol.AlternateMatchpoint |
class |
Protocol.Commit |
class |
Protocol.DuplicateNodeReject |
class |
Protocol.Entry
A message containing a log entry in the replication stream.
|
class |
Protocol.EntryNotFound
Response when the EntryRequest asks for a VLSN that is below the VLSN
range covered by the Feeder.
|
class |
Protocol.EntryRequest
A replica node asks a feeder for the log entry at this VLSN.
|
class |
Protocol.FeederJEVersions |
class |
Protocol.FeederProtocolVersion
The feeder sends the replica its proposed version.
|
(package private) class |
Protocol.HandshakeMessage
Base class for all protocol handshake messages.
|
class |
Protocol.Heartbeat |
class |
Protocol.HeartbeatResponse |
(package private) class |
Protocol.JEVersions
Abstract message used as the basis for the exchange of software versions
between replicated nodes
|
class |
Protocol.JEVersionsReject |
class |
Protocol.NodeGroupInfo |
class |
Protocol.NodeGroupInfoOK |
class |
Protocol.NodeGroupInfoReject |
(package private) class |
Protocol.ProtocolVersion
Version broadcasts the sending node's protocol version.
|
class |
Protocol.ReplicaJEVersions |
class |
Protocol.ReplicaProtocolVersion
The replica sends the feeder its protocol version.
|
class |
Protocol.RestoreRequest
Request from the replica to the feeder for sufficient information to
start a network restore.
|
class |
Protocol.RestoreResponse
Response when the replica needs information to instigate a network
restore.
|
class |
Protocol.ShutdownRequest
Message used to shutdown a node
|
class |
Protocol.ShutdownResponse
Message in response to a shutdown request.
|
class |
Protocol.SNTPRequest |
class |
Protocol.SNTPResponse |
class |
Protocol.StartStream
StartStream indicates that the replica would like the feeder to start
the replication stream at the proposed vlsn.
|
(package private) class |
Protocol.VLSNMessage
Base class for messages which contain only a VLSN
|
BinaryProtocol.ClientVersion, BinaryProtocol.IncompatibleVersion, BinaryProtocol.Message, BinaryProtocol.MessageOp, BinaryProtocol.ProtocolError, BinaryProtocol.ProtocolException, BinaryProtocol.RejectMessage, BinaryProtocol.ServerVersion, BinaryProtocol.SimpleMessage
CLIENT_VERSION, codeVersion, configuredVersion, envImpl, formatter, header, INCOMPATIBLE_VERSION, logger, MESSAGE_HEADER_SIZE, nameIdPair, nBytesRead, nBytesWritten, nMessagesRead, nMessagesWritten, nReadNanos, nWriteNanos, PROTOCOL_ERROR, SERVER_VERSION, stats
Modifier and Type | Method and Description |
---|---|
static Protocol |
get(RepNode repNode,
int version)
Returns a protocol object that supports the specific requested version.
|
static int |
getDefaultVersion() |
(package private) static Protocol |
getProtocol(RepNode repNode) |
static void |
setDefaultVersion(int testVersion) |
getPredefinedMessageCount, getStats, getString, getVersion, initializeMessageOps, messageCount, putString, read, read, resetStats, stringSize, write, write
public static final BinaryProtocol.MessageOp REPLICA_PROTOCOL_VERSION
public static final BinaryProtocol.MessageOp FEEDER_PROTOCOL_VERSION
public static final BinaryProtocol.MessageOp DUP_NODE_REJECT
public static final BinaryProtocol.MessageOp REPLICA_JE_VERSIONS
public static final BinaryProtocol.MessageOp FEEDER_JE_VERSIONS
public static final BinaryProtocol.MessageOp JE_VERSIONS_REJECT
public static final BinaryProtocol.MessageOp MEMBERSHIP_INFO
public static final BinaryProtocol.MessageOp MEMBERSHIP_INFO_OK
public static final BinaryProtocol.MessageOp MEMBERSHIP_INFO_REJECT
public static final BinaryProtocol.MessageOp SNTP_REQUEST
public static final BinaryProtocol.MessageOp SNTP_RESPONSE
public static final BinaryProtocol.MessageOp ENTRY
public static final BinaryProtocol.MessageOp START_STREAM
public static final BinaryProtocol.MessageOp HEARTBEAT
public static final BinaryProtocol.MessageOp HEARTBEAT_RESPONSE
public static final BinaryProtocol.MessageOp COMMIT
public static final BinaryProtocol.MessageOp ACK
public static final BinaryProtocol.MessageOp ENTRY_REQUEST
public static final BinaryProtocol.MessageOp ENTRY_NOTFOUND
public static final BinaryProtocol.MessageOp ALT_MATCHPOINT
public static final BinaryProtocol.MessageOp RESTORE_REQUEST
public static final BinaryProtocol.MessageOp RESTORE_RESPONSE
public static final BinaryProtocol.MessageOp SHUTDOWN_REQUEST
public static final BinaryProtocol.MessageOp SHUTDOWN_RESPONSE
public static Protocol get(RepNode repNode, int version)
public static int getDefaultVersion()
public static void setDefaultVersion(int testVersion)
testVersion
- the version to set as the supported default version.Copyright (c) 2004-2012 Oracle. All rights reserved.