placement6-submit

############
#
# Parallel Job 
#
############

universe = parallel
executable = placement6.py

EXPERIMENT=wisc2gce
# Set for an adminstrative job
# +IsIDPLAdminJob = true
TIMEOUT=60
MOVERARGS=gitclone:{pull}
#MOVERARGS=gitclone:{clone}

DST_HOST = idpl-gce-west.c.focal-road-163817.internal
DST_HOST_DNS = 126.234.196.104.bc.googleusercontent.com  
DST_PATH = 500M
SRC_HOST = komatsu.chtc.wisc.edu
SRC_HOST_DNS = $(SRC_HOST)
SRC_PATH =  /home/idpl/500M
TESTSEQUENCE = iperf,fdt,netcat,gridftp,scp



### Crondor Settings
# A run is allowed to take this long (in seconds) to set up; otherwise
# that run is skipped
# cron_window=420

# Try to run jobs on this schedule
#cron_minute=10
#cron_hour=24/2
#
# Keep running the job
#on_exit_remove=false

# Arguments are:
# 1. File to send (on the sending host)
# 2. Location to write file (on the receiving host)

arguments = -i $(SRC_PATH) -o $(DST_PATH) -s $(TESTSEQUENCE) -t $(TIMEOUT) -a $(MOVERARGS) --src $(SRC_HOST_DNS) --dest $(DST_HOST_DNS)

## Enable Chirp
+WantIOProxy = true

input   = /dev/null
output = $(EXPERIMENT)/detail/placement6.out.$(Cluster).$(Node)
error  = $(EXPERIMENT)/detail/placement6.err.$(Cluster).$(Node)
log    = $(EXPERIMENT)/placement6.log
# getenv = true

+SrcHost = "$(SRC_HOST)"
+SrcPath = "$(SRC_PATH)"
+DstHost = "$(DST_HOST)"
+DstPath = "$(DST_PATH)"
+ExperimentName = "$(EXPERIMENT):$(executable)"
+ExperimentDescription = "$(SRC_HOST) to $(DST_HOST) file $(SRC_PATH)"

+ParallelShutdownPolicy = "WAIT_FOR_ALL"

transfer_input_files = TimedExec.py,IDPLException.py,CondorTools.py,ChirpTools.py,DataMover.py, SCPMover.py,NetcatMover.py,IperfMover.py, IrodsMover.py, IrodsPutMover.py, FDTMover.py, fdt.jar, UDTMover.py, GitClone.py, TracerouteMover.py, udtxfer, empty

should_transfer_files = YES
when_to_transfer_output = ON_EXIT
                                                  
machine_count = 1
requirements = (Machine == "$(SRC_HOST)")
transfer_output_files = empty
queue

machine_count = 1
requirements = (Machine == "$(DST_HOST)")
transfer_output_files = empty 
queue