edu.iu.dsc.tws.rsched.uploaders.k8s

Class UploaderToPod

java.lang.Object

java.lang.Thread

edu.iu.dsc.tws.rsched.uploaders.k8s.UploaderToPod

All Implemented Interfaces:

java.lang.Runnable

public class UploaderToPod
extends java.lang.Thread

upload the job package to a worker it assumes the target pod is ready so MAX_FILE_TRANSFER_TRY_COUNT is set to only a few

Nested Class Summary

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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
static long	MAX_FILE_TRANSFER_TRY_COUNT
static long	SLEEP_INTERVAL_BETWEEN_TRANSFER_ATTEMPTS

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
UploaderToPod(java.lang.String namespace, java.lang.String podName, java.lang.String jobPackageFile, java.lang.String podFile)

Method Summary

Modifier and Type	Method and Description
void	cancelTransfer()
java.lang.String	getPodName()
boolean	packageTransferred() return true if the file is transferred successfully
void	run()

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Field Detail

MAX_FILE_TRANSFER_TRY_COUNT

public static final long MAX_FILE_TRANSFER_TRY_COUNT

See Also:

Constant Field Values

SLEEP_INTERVAL_BETWEEN_TRANSFER_ATTEMPTS

public static final long SLEEP_INTERVAL_BETWEEN_TRANSFER_ATTEMPTS

See Also:

Constant Field Values

Constructor Detail

UploaderToPod

public UploaderToPod(java.lang.String namespace,
                     java.lang.String podName,
                     java.lang.String jobPackageFile,
                     java.lang.String podFile)

Method Detail

getPodName

public java.lang.String getPodName()

packageTransferred

public boolean packageTransferred()

return true if the file is transferred successfully

Returns:

cancelTransfer

public void cancelTransfer()

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread