Package de.dlr.proseo.api.xbipmon

Klasse XbipMonitor

java.lang.Object

java.lang.Thread

de.dlr.proseo.api.basemon.BaseMonitor

de.dlr.proseo.api.xbipmon.XbipMonitor

Alle implementierten Schnittstellen:

Runnable

@Component
@Scope("singleton")
public class XbipMonitor
extends BaseMonitor

Monitor for X-band Interface Points X-band Interface Points are WebDAV volumes, so from within the Monitor they just look like plain POSIX volumes.

Autor:

Dr. Thomas Bassler

Verschachtelte Klassen - Übersicht

Verschachtelte Klassen

Modifizierer und Typ	Klasse	Beschreibung
static class	XbipMonitor.DataSessionInformationBlock	Class describing a download channel
static class	XbipMonitor.TransferSession	Class describing a download session

Von Klasse geerbte verschachtelte Klassen/Schnittstellen de.dlr.proseo.api.basemon.BaseMonitor

BaseMonitor.TransferControl

Von Klasse geerbte verschachtelte Klassen/Schnittstellen java.lang.Thread

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Feldübersicht

Felder

Modifizierer und Typ	Feld	Beschreibung
(Package privat) Map<String,Boolean>	copySuccess	Indicator for parallel copying processes

Von Klasse geerbte Felder java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Konstruktorübersicht

Konstruktoren

Konstruktor	Beschreibung
XbipMonitor()

Methodenübersicht

Modifizierer und Typ	Methode	Beschreibung
protected BaseMonitor.TransferControl	checkAvailableDownloads(Instant referenceTimeStamp)	Check the configured XBIP satellite directory for sessions (without filtering); note that the passed reference time stamp is ignored, as on the XBIP there is no reliable value to compare it against
int	getFileWaitInterval()	Gets the interval to check for completed file downloads
Double	getLastCopyPerformance()	Gets the last copy performance for monitoring purposes
int	getMaxFileDownloadThreads()	Gets the maximum number of parallel file download threads within a download session
int	getMaxFileWaitCycles()	Gets the maximum number of wait cycles for file download completion checks
void	setFileWaitInterval(int fileWaitInterval)	Sets the interval to check for completed file downloads
(Package privat) void	setLastCopyPerformance(Double copyPerformance)	Records the last copy performance for monitoring purposes
void	setMaxFileDownloadThreads(int maxFileDownloadThreads)	Sets the maximum number of parallel file download threads within a download session
void	setMaxFileWaitCycles(int maxFileWaitCycles)	Sets the maximum number of wait cycles for file download completion checks
protected boolean	transferToTargetDir(TransferObject object)	Transfer the data in the session data directory to the configured CADU target directory for L0 processing
protected boolean	triggerFollowOnAction(TransferObject transferObject)	Trigger L0 processing on the given downlink session transfer object (spawns a separate process taking just the path to the session CADU data as parameter)

Von Klasse geerbte Methoden de.dlr.proseo.api.basemon.BaseMonitor

getCheckInterval, getHistoryRetentionDuration, getMaxDownloadThreads, getMaxWaitCycles, getTaskWaitInterval, getTransferHistoryFile, getTruncateInterval, run, run, setCheckInterval, setHistoryRetentionDuration, setMaxDownloadThreads, setMaxWaitCycles, setTaskWaitInterval, setTransferHistoryFile, setTruncateInterval

Von Klasse geerbte Methoden java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, toString, yield

Von Klasse geerbte Methoden java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Felddetails

copySuccess

Map<String,Boolean> copySuccess

Indicator for parallel copying processes

Konstruktordetails

XbipMonitor

public XbipMonitor()

Methodendetails

getMaxFileDownloadThreads

public int getMaxFileDownloadThreads()

Gets the maximum number of parallel file download threads within a download session

Gibt zurück:

the maximum number of parallel file download threads

setMaxFileDownloadThreads

public void setMaxFileDownloadThreads(int maxFileDownloadThreads)

Sets the maximum number of parallel file download threads within a download session

Parameter:

maxFileDownloadThreads - the maximum number of parallel file download threads to set

getFileWaitInterval

public int getFileWaitInterval()

Gets the interval to check for completed file downloads

Gibt zurück:

the check interval in millliseconds

setFileWaitInterval

public void setFileWaitInterval(int fileWaitInterval)

Sets the interval to check for completed file downloads

Parameter:

fileWaitInterval - the check interval in millliseconds to set

getMaxFileWaitCycles

public int getMaxFileWaitCycles()

Gets the maximum number of wait cycles for file download completion checks

Gibt zurück:

the maximum number of wait cycles

setMaxFileWaitCycles

public void setMaxFileWaitCycles(int maxFileWaitCycles)

Sets the maximum number of wait cycles for file download completion checks

Parameter:

maxFileWaitCycles - the maximum number of wait cycles to set

getLastCopyPerformance

public Double getLastCopyPerformance()

Gets the last copy performance for monitoring purposes

Gibt zurück:

the last copy performance in MiB/s

setLastCopyPerformance

void setLastCopyPerformance(Double copyPerformance)

Records the last copy performance for monitoring purposes

Parameter:

copyPerformance - the copy performance in MiB/s

checkAvailableDownloads

protected BaseMonitor.TransferControl checkAvailableDownloads(Instant referenceTimeStamp)

Check the configured XBIP satellite directory for sessions (without filtering); note that the passed reference time stamp is ignored, as on the XBIP there is no reliable value to compare it against

Angegeben von:

checkAvailableDownloads in Klasse BaseMonitor

transferToTargetDir

protected boolean transferToTargetDir(TransferObject object)

Transfer the data in the session data directory to the configured CADU target directory for L0 processing

Angegeben von:

transferToTargetDir in Klasse BaseMonitor

triggerFollowOnAction

protected boolean triggerFollowOnAction(TransferObject transferObject)

Trigger L0 processing on the given downlink session transfer object (spawns a separate process taking just the path to the session CADU data as parameter)

Angegeben von:

triggerFollowOnAction in Klasse BaseMonitor