de.bsvrz.ars.ars.mgmt.tasks
Class RequestGapTask.GapMarker
java.lang.Object
de.bsvrz.ars.ars.mgmt.tasks.RequestGapTask.GapMarker
- Enclosing class:
- RequestGapTask
public static class RequestGapTask.GapMarker
- extends Object
Speichert pro Archivsystem die Luecken, die von diesem nicht geschlossen werden konnten. Am Schluss wird die gesamte Lueckenliste aller Archivsysteme
durchgegangen und so zusammengefasst, dass nur die Luecken erhalten bleiben, die von keinem Archivsystem geschlossen werden konnten.
Method Summary |
void |
addGap(String[] parentFailedArS,
String archive,
long gapStart,
long gapEnd)
|
void |
addGap(String archive,
long gapStart,
long gapEnd)
|
private long |
getDIdx(String archive)
|
private String |
getNext()
|
private boolean |
isFullGap(long didx)
|
String |
reduce()
Geht die gesamte Lueckenliste aller Archivsysteme durch und fasst sie so zusammen, dass nur die Luecken erhalten bleiben, die von keinem Archivsystem
geschlossen werden konnten. |
void |
reset()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
gaps
private Map<String,List<Long>> gaps
pos
private Map<String,Integer> pos
RequestGapTask.GapMarker
public RequestGapTask.GapMarker()
reset
public void reset()
addGap
public void addGap(String archive,
long gapStart,
long gapEnd)
addGap
public void addGap(String[] parentFailedArS,
String archive,
long gapStart,
long gapEnd)
reduce
public String reduce()
- Geht die gesamte Lueckenliste aller Archivsysteme durch und fasst sie so zusammen, dass nur die Luecken erhalten bleiben, die von keinem Archivsystem
geschlossen werden konnten. Diese Liste wird in Zeilen der Form 100-200archiv1#archiv2 ausgegeben.
isFullGap
private boolean isFullGap(long didx)
- Parameters:
didx
-
- Returns:
- Wahr, wenn der Datenindex von allen Archivsystemen nicht geliefert werden konnte.
getNext
private String getNext()
- Returns:
- Das Archivsystem, das den naechstkleinsten Datenindex vermerkt hat
getDIdx
private long getDIdx(String archive)