public abstract class AbstractArchiveBuffer extends Object implements IArchiveBuffer
Modifier and Type | Field and Description |
---|---|
protected List<org.thales.punch.libraries.objectstorage.tuples.ArchiveDevice> |
destinations |
protected String |
filename |
protected int |
maxWrites |
protected int |
minWrites |
protected String |
pool |
Constructor and Description |
---|
AbstractArchiveBuffer(int minWrites,
int maxWrites,
List<org.thales.punch.libraries.objectstorage.tuples.ArchiveDevice> destinations) |
Modifier and Type | Method and Description |
---|---|
protected void |
exit(Exception cause)
Exit archiving.
|
protected String |
getBatchOutputPath()
Return full batch path from metadata.
|
protected void |
handleDeviceFailure(String stage,
String device,
Exception e,
int remaining)
When device fails to open, write or close, the device is considered down.
|
IArchiveBuffer |
prepare(org.thales.punch.libraries.objectstorage.indexing.BatchMetadata metaData)
Before using the archive buffer call this.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, getDigest, getSize, getUncompressedSize, put
protected final int minWrites
protected final int maxWrites
protected final List<org.thales.punch.libraries.objectstorage.tuples.ArchiveDevice> destinations
protected String filename
protected String pool
public AbstractArchiveBuffer(int minWrites, int maxWrites, List<org.thales.punch.libraries.objectstorage.tuples.ArchiveDevice> destinations)
public IArchiveBuffer prepare(org.thales.punch.libraries.objectstorage.indexing.BatchMetadata metaData)
IArchiveBuffer
prepare
in interface IArchiveBuffer
metaData
- the provided context information.protected void handleDeviceFailure(String stage, String device, Exception e, int remaining)
stage
- open,write or closedevice
- device failinge
- exception raisedremaining
- remaining devices countprotected String getBatchOutputPath()
protected void exit(Exception cause)
cause
- : Exception raised.Copyright © 2023. All rights reserved.