diff --git a/dev/n_osync.sh b/dev/n_osync.sh index 56b830c..41bdc1d 100755 --- a/dev/n_osync.sh +++ b/dev/n_osync.sh @@ -1,16 +1,13 @@ #!/usr/bin/env bash #TODO(critical): handle conflict prevalance, especially in sync_attrs function -#TODO(high): test resume system #TODO(critical): test new WaitForTaskCompletion behavior with self=true -#TODO(low): add keep logging & preserve attr conf entries to preflight check -#TODO(low): test failed _CreateStateDirsRemote should stop osync PROGRAM="osync" # Rsync based two way sync engine with fault tolerance AUTHOR="(C) 2013-2016 by Orsiris de Jong" CONTACT="http://www.netpower.fr/osync - ozy@netpower.fr" PROGRAM_VERSION=1.2-dev-parallel -PROGRAM_BUILD=2016081802 +PROGRAM_BUILD=2016081901 IS_STABLE=no # Function Name Is parallel #__WITH_PARANOIA_DEBUG @@ -157,7 +154,7 @@ function CheckCurrentConfig { done # Check all variables that should contain a numerical value >= 0 - declare -a num_vars=(MINIMUM_SPACE BANDWIDTH SOFT_MAX_EXEC_TIME HARD_MAX_EXEC_TIME MIN_WAIT MAX_WAIT CONFLICT_BACKUP_DAYS SOFT_DELETE_DAYS RESUME_TRY MAX_EXEC_TIME_PER_CMD_BEFORE MAX_EXEC_TIME_PER_CMD_AFTER) + declare -a num_vars=(MINIMUM_SPACE BANDWIDTH SOFT_MAX_EXEC_TIME HARD_MAX_EXEC_TIME KEEP_LOGGING MIN_WAIT MAX_WAIT CONFLICT_BACKUP_DAYS SOFT_DELETE_DAYS RESUME_TRY MAX_EXEC_TIME_PER_CMD_BEFORE MAX_EXEC_TIME_PER_CMD_AFTER) for i in "${num_vars[@]}"; do test="if [ $(IsNumeric \"\$$i\") -eq 0 ]; then Logger \"Bogus $i value defined in config file. Correct your config file or update it using the update script if using and old version.\" \"CRITICAL\"; exit 1; fi" eval "$test" @@ -603,6 +600,11 @@ function tree_list { __CheckArguments 3 $# ${FUNCNAME[0]} "$@" #__WITH_PARANOIA_DEBUG + #WIP + #if [ "$replica_type" == "${INITIATOR[0]}" ]; then + # exit 12 + #fi + escaped_replica_path=$(EscapeSpaces "$replica_path") Logger "Creating $replica_type replica file list [$replica_path]." "NOTICE" @@ -1132,6 +1134,8 @@ function Sync { local initiatorPid local targetPid + local initiatorFail + local targetFail Logger "Starting synchronization task." "NOTICE" CheckConnectivity3rdPartyHosts @@ -1199,14 +1203,27 @@ function Sync { WaitForTaskCompletion "$initiatorPid;$targetPid" $SOFT_MAX_EXEC_TIME $HARD_MAX_EXEC_TIME ${FUNCNAME[0]} false $KEEP_LOGGING if [ $? != 0 ]; then IFS=';' read -r -a pidArray <<< "$WAIT_FOR_TASK_COMPLETION" + initiatorFail=false + targetFail=false for pid in "${pidArray[@]}"; do pid=${pid%:*} if [ $pid == $initiatorPid ]; then echo "${SYNC_ACTION[0]}" > "${INITIATOR[7]}" + initiatorFail=true elif [ $pid == $targetPid ]; then echo "${SYNC_ACTION[0]}" > "${INITIATOR[8]}" + targetFail=true fi done + + if [ $initiatorFail == false ]; then + echo "${SYNC_ACTION[1]}" > "${INITIATOR[7]}" + fi + + if [ $targetFail == false ]; then + echo "${SYNC_ACTION[1]}" > "${INITIATOR[8]}" + fi + exit 1 else echo "${SYNC_ACTION[1]}" > "${INITIATOR[7]}" @@ -1231,14 +1248,27 @@ function Sync { WaitForTaskCompletion "$initiatorPid;$targetPid" $SOFT_MAX_EXEC_TIME $HARD_MAX_EXEC_TIME ${FUNCNAME[0]} false $KEEP_LOGGING if [ $? != 0 ]; then IFS=';' read -r -a pidArray <<< "$WAIT_FOR_TASK_COMPLETION" + initiatorFail=false + targetFail=false for pid in "${pidArray[@]}"; do pid=${pid%:*} if [ $pid == $initiatorPid ]; then echo "${SYNC_ACTION[1]}" > "${INITIATOR[7]}" + initiatorFail=true elif [ $pid == $targetPid ]; then echo "${SYNC_ACTION[1]}" > "${INITIATOR[8]}" + targetFail=true fi done + + if [ $initiatorFail == false ]; then + echo "${SYNC_ACTION[2]}" > "${INITIATOR[7]}" + fi + + if [ $targetFail == false ]; then + echo "${SYNC_ACTION[2]}" > "${INITIATOR[8]}" + fi + exit 1 else echo "${SYNC_ACTION[2]}" > "${INITIATOR[7]}" @@ -1287,14 +1317,27 @@ function Sync { WaitForTaskCompletion "$initiatorPid;$targetPid" $SOFT_MAX_EXEC_TIME $HARD_MAX_EXEC_TIME ${FUNCNAME[0]} false $KEEP_LOGGING if [ $? != 0 ]; then IFS=';' read -r -a pidArray <<< "$WAIT_FOR_TASK_COMPLETION" + initiatorFail=false + targetFail=false for pid in "${pidArray[@]}"; do pid=${pid%:*} if [ $pid == $initiatorPid ]; then echo "${SYNC_ACTION[3]}" > "${INITIATOR[7]}" + initiatorFail=true elif [ $pid == $targetPid ]; then echo "${SYNC_ACTION[3]}" > "${INITIATOR[8]}" + targetFail=true fi done + + if [ $initiatorFail == false ]; then + echo "${SYNC_ACTION[4]}" > "${INITIATOR[7]}" + fi + + if [ $targetFail == false ]; then + echo "${SYNC_ACTION[4]}" > "${INITIATOR[8]}" + fi + exit 1 else echo "${SYNC_ACTION[4]}" > "${INITIATOR[7]}" @@ -1319,14 +1362,27 @@ function Sync { WaitForTaskCompletion "$initiatorPid;$targetPid" $SOFT_MAX_EXEC_TIME $HARD_MAX_EXEC_TIME ${FUNCNAME[0]} false $KEEP_LOGGING if [ $? != 0 ]; then IFS=';' read -r -a pidArray <<< "$WAIT_FOR_TASK_COMPLETION" + initiatorFail=false + targetFail=false for pid in "${pidArray[@]}"; do pid=${pid%:*} if [ $pid == $initiatorPid ]; then echo "${SYNC_ACTION[4]}" > "${INITIATOR[7]}" + initiatorFail=true elif [ $pid == $targetPid ]; then echo "${SYNC_ACTION[4]}" > "${INITIATOR[8]}" + targetFail=true fi done + + if [ $initiatorFail == false ]; then + echo "${SYNC_ACTION[5]}" > "${INITIATOR[7]}" + fi + + if [ $targetFail == false ]; then + echo "${SYNC_ACTION[5]}" > "${INITIATOR[8]}" + fi + exit 1 else echo "${SYNC_ACTION[5]}" > "${INITIATOR[7]}" @@ -1352,14 +1408,27 @@ function Sync { WaitForTaskCompletion "$initiatorPid;$targetPid" $SOFT_MAX_EXEC_TIME $HARD_MAX_EXEC_TIME ${FUNCNAME[0]} false $KEEP_LOGGING if [ $? != 0 ]; then IFS=';' read -r -a pidArray <<< "$WAIT_FOR_TASK_COMPLETION" + initiatorFail=false + targetFail=false for pid in "${pidArray[@]}"; do pid=${pid%:*} if [ $pid == $initiatorPid ]; then echo "${SYNC_ACTION[5]}" > "${INITIATOR[7]}" + initiatorFail=true elif [ $pid == $targetPid ]; then echo "${SYNC_ACTION[5]}" > "${INITIATOR[8]}" + targetFail=true fi done + + if [ $initiatorFail == false ]; then + echo "${SYNC_ACTION[6]}" > "${INITIATOR[7]}" + fi + + if [ $targetFail == false ]; then + echo "${SYNC_ACTION[6]}" > "${INITIATOR[8]}" + fi + exit 1 else echo "${SYNC_ACTION[6]}" > "${INITIATOR[7]}"