DefaultMetaStore extends AbstractMetaStore { @Override public ReplicationStoreMeta rdbBegun(String replId, long beginOffset, String rdbFile, EofType eofType, String cmdFilePrefix) throws IOException { synchronized (metaRef) { ReplicationStoreMeta metaDup = dupReplicationStoreMeta(); metaDup.setReplId(replId); metaDup.setBeginOffset(beginOffset); metaDup.setRdbFile(rdbFile); setRdbFileInfo(metaDup, eofType); metaDup.setCmdFilePrefix(cmdFilePrefix); metaDup.setRdbLastOffset(beginOffset - 1); clearReplicationId2(metaDup); saveMeta(metaDup); return metaDup; } } DefaultMetaStore(File baseDir, String keeperRunid); @Override String getReplId(); @Override String getReplId2(); @Override Long getSecondReplIdOffset(); @Override Long beginOffset(); @Override DefaultEndPoint getMasterAddress(); @Override ReplicationStoreMeta rdbBegun(String replId, long beginOffset, String rdbFile, EofType eofType,
			String cmdFilePrefix); @Override void masterChanged(long keeperOffset, DefaultEndPoint newMasterEndpoint, String newMasterRunid,
			long newMasterReplOffset); @Override ReplicationStoreMeta shiftReplicationId(String newReplId, Long currentOffset);  }
@Test public void testRdbBegun() { }