com.sleepycat.je.rep.stream
Class MasterFeederSource

java.lang.Object
  extended by com.sleepycat.je.rep.stream.MasterFeederSource
All Implemented Interfaces:
FeederSource

public class MasterFeederSource
extends 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
MasterFeederSource(EnvironmentImpl envImpl, VLSNIndex vlsnIndex, NameIdPair nameIdPair)
           
 
Method Summary
 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,
                 IOException
Specified by:
init in interface FeederSource
Throws:
DatabaseException
IOException

getWireRecord

public OutputWireRecord getWireRecord(VLSN vlsn,
                                      int waitTime)
                               throws DatabaseException,
                                      InterruptedException,
                                      IOException
Specified by:
getWireRecord in interface FeederSource
Throws:
DatabaseException
InterruptedException
IOException

dumpState

public String dumpState()
Specified by:
dumpState in interface FeederSource


Copyright (c) 2004-2012 Oracle. All rights reserved.