com.sleepycat.je.rep.stream

Class MasterFeederSource

java.lang.Object

com.sleepycat.je.rep.stream.MasterFeederSource

All Implemented Interfaces:

FeederSource

public class MasterFeederSource
extends java.lang.Object
implements FeederSource

Implementation of a master node acting as a FeederSource. The MasterFeederSource is stateful, because it keeps its own FeederReader which acts as a cursor or scanner across the log files, so it can only be used by a single Feeder.

Constructor Summary

Constructors

Constructor and Description
MasterFeederSource(EnvironmentImpl envImpl, VLSNIndex vlsnIndex, NameIdPair nameIdPair)

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	dumpState()
OutputWireRecord	getWireRecord(VLSN vlsn, int waitTime)
void	init(VLSN startVLSN)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MasterFeederSource

public MasterFeederSource(EnvironmentImpl envImpl,
                  VLSNIndex vlsnIndex,
                  NameIdPair nameIdPair)
                   throws DatabaseException

Throws:

DatabaseException

Method Detail

init

public void init(VLSN startVLSN)
          throws DatabaseException,
                 java.io.IOException

Specified by:

init in interface FeederSource

Throws:

DatabaseException

java.io.IOException

getWireRecord

public OutputWireRecord getWireRecord(VLSN vlsn,
                             int waitTime)
                               throws DatabaseException,
                                      java.lang.InterruptedException,
                                      java.io.IOException

Specified by:

getWireRecord in interface FeederSource

Throws:

DatabaseException

java.lang.InterruptedException

java.io.IOException

dumpState

public java.lang.String dumpState()

Specified by:

dumpState in interface FeederSource