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.IOExceptionStorageFormatExceptionpublic 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.IOExceptionpublic void checkBlocks()
public void restart()
public void cancel()