public final class Feeder
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
Feeder.ExitException
A marker exception that wraps the real exception.
|
Constructor and Description |
---|
Feeder() |
Feeder(FeederManager feederManager,
java.nio.channels.SocketChannel socketChannel) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
adviseMasterTransferProgress() |
java.lang.String |
dumpState()
For debugging and exception messages.
|
StatGroup |
getProtocolStats(StatsConfig config) |
NameIdPair |
getReplicaNameIdPair() |
VLSN |
getReplicaTxnEndVLSN()
Returns the latest commit VLSN that was acked by the replica, or
NULL_VLSN if no commit was acked since the time the feeder was
established.
|
RepNode |
getRepNode() |
boolean |
isShutdown() |
(package private) void |
resetStats() |
(package private) void |
setMasterTransfer(MasterTransfer mt) |
static void |
setSprayAfterNMessagesCount(long sANMC) |
(package private) void |
shutdown(java.lang.Exception shutdownException)
Shutdown the feeder, closing its channel and releasing its threads.
|
(package private) void |
startFeederThreads() |
Feeder(FeederManager feederManager, java.nio.channels.SocketChannel socketChannel) throws DatabaseException, java.io.IOException
DatabaseException
java.io.IOException
public Feeder()
void startFeederThreads()
public StatGroup getProtocolStats(StatsConfig config)
void resetStats()
void setMasterTransfer(MasterTransfer mt)
void adviseMasterTransferProgress()
public RepNode getRepNode()
public NameIdPair getReplicaNameIdPair()
public VLSN getReplicaTxnEndVLSN()
void shutdown(java.lang.Exception shutdownException)
public boolean isShutdown()
public static void setSprayAfterNMessagesCount(long sANMC)
public java.lang.String dumpState()
Copyright (c) 2004-2012 Oracle. All rights reserved.