Package de.dlr.proseo.api.edipmon

Klasse EdipMonitor

java.lang.Object

java.lang.Thread

de.dlr.proseo.api.basemon.BaseMonitor

de.dlr.proseo.api.edipmon.EdipMonitor

Alle implementierten Schnittstellen:

Runnable

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

Monitor for EDRS Interface Points EDRS Interface Points are FTP-S servers. The FTP-S directory must be mounted as a network volume (e. g. using "rclone").

Autor:

Dr. Thomas Bassler

Verschachtelte Klassen - Übersicht

Verschachtelte Klassen

Modifizierer und Typ	Klasse	Beschreibung
static class	EdipMonitor.DataSessionInformationBlock	Class describing a download channel
static class	EdipMonitor.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
EdipMonitor()

Methodenübersicht

Modifizierer und Typ	Methode	Beschreibung
protected BaseMonitor.TransferControl	checkAvailableDownloads(Instant referenceTimeStamp)	Check the configured EDIP satellite directory for sessions (without filtering); note that the passed reference time stamp is ignored, as on the EDIP 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)
protected boolean	triggerParallelAction(EdipMonitor.TransferSession transferSession)	Trigger any necessary parallel action on the transfer session (e. g.

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

EdipMonitor

public EdipMonitor()

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 EDIP satellite directory for sessions (without filtering); note that the passed reference time stamp is ignored, as on the EDIP 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

triggerParallelAction

protected boolean triggerParallelAction(EdipMonitor.TransferSession transferSession)

Trigger any necessary parallel action on the transfer session (e. g. L0 processing)

Parameter:

transferSession - the transfer session to start the action on

Gibt zurück:

true, if starting the action succeeded (not necessarily the action itself), false otherwise

triggerFollowOnAction

protected boolean triggerFollowOnAction(TransferObject transferObject)

Angegeben von:

triggerFollowOnAction in Klasse BaseMonitor