Package de.dlr.proseo.api.edipmon

Class EdipMonitor

java.lang.Object

java.lang.Thread

de.dlr.proseo.api.basemon.BaseMonitor

de.dlr.proseo.api.edipmon.EdipMonitor

All Implemented Interfaces:

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").

Author:

Dr. Thomas Bassler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	EdipMonitor.DataSessionInformationBlock	Class describing a download channel
static class	EdipMonitor.TransferSession	Class describing a download session

Nested classes/interfaces inherited from class de.dlr.proseo.api.basemon.BaseMonitor

BaseMonitor.TransferControl

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
(package private) Map<String,Boolean>	copySuccess	Indicator for parallel copying processes

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
EdipMonitor()

Method Summary

Modifier and Type	Method	Description
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 private) 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.

Methods inherited from class de.dlr.proseo.api.basemon.BaseMonitor

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

Methods inherited from class 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, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Details

copySuccess

Map<String,Boolean> copySuccess

Indicator for parallel copying processes

Constructor Details

EdipMonitor

public EdipMonitor()

Method Details

getMaxFileDownloadThreads

public int getMaxFileDownloadThreads()

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

Returns:

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

Parameters:

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

getFileWaitInterval

public int getFileWaitInterval()

Gets the interval to check for completed file downloads

Returns:

the check interval in millliseconds

setFileWaitInterval

public void setFileWaitInterval(int fileWaitInterval)

Sets the interval to check for completed file downloads

Parameters:

fileWaitInterval - the check interval in millliseconds to set

getMaxFileWaitCycles

public int getMaxFileWaitCycles()

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

Returns:

the maximum number of wait cycles

setMaxFileWaitCycles

public void setMaxFileWaitCycles(int maxFileWaitCycles)

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

Parameters:

maxFileWaitCycles - the maximum number of wait cycles to set

getLastCopyPerformance

public Double getLastCopyPerformance()

Gets the last copy performance for monitoring purposes

Returns:

the last copy performance in MiB/s

setLastCopyPerformance

void setLastCopyPerformance(Double copyPerformance)

Records the last copy performance for monitoring purposes

Parameters:

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

Specified by:

checkAvailableDownloads in class BaseMonitor

transferToTargetDir

protected boolean transferToTargetDir(TransferObject object)

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

Specified by:

transferToTargetDir in class BaseMonitor

triggerParallelAction

protected boolean triggerParallelAction(EdipMonitor.TransferSession transferSession)

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

Parameters:

transferSession - the transfer session to start the action on

Returns:

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

triggerFollowOnAction

protected boolean triggerFollowOnAction(TransferObject transferObject)

Specified by:

triggerFollowOnAction in class BaseMonitor