public class SplitFileFetcherCrossSegmentStorage
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
int |
crossSegmentNumber |
SplitFileFetcherStorage |
parent |
Constructor and Description |
---|
SplitFileFetcherCrossSegmentStorage(SplitFileFetcherStorage parent,
int segNo,
java.io.DataInputStream dis) |
Modifier and Type | Method and Description |
---|---|
void |
addDataBlock(SplitFileFetcherSegmentStorage seg,
int blockNum) |
void |
cancel() |
void |
checkBlocks()
Should be called before scheduling, unlike restart().
|
boolean |
isDecoding() |
void |
onFetchedRelevantBlock(SplitFileFetcherSegmentStorage segment,
int blockNo)
Called when a segment fetches a block that it believes to be relevant to us
|
void |
restart()
Check for blocks and try to decode.
|
void |
writeFixedMetadata(java.io.DataOutputStream dos) |
public final int crossSegmentNumber
public final SplitFileFetcherStorage parent
public SplitFileFetcherCrossSegmentStorage(SplitFileFetcherStorage parent, int segNo, java.io.DataInputStream dis) throws java.io.IOException, StorageFormatException
java.io.IOException
StorageFormatException
public void onFetchedRelevantBlock(SplitFileFetcherSegmentStorage segment, int blockNo)
public void addDataBlock(SplitFileFetcherSegmentStorage seg, int blockNum)
public boolean isDecoding()
public void writeFixedMetadata(java.io.DataOutputStream dos) throws java.io.IOException
java.io.IOException
public void checkBlocks()
public void restart()
public void cancel()