Merge branch 'bug6209' into bug5959

+We want all local variables, fields, and parameters to be declared "final" as far as possible.

+

+We want all literals used as parameters (true, false, numeric literals, Optional.empty() and null) to be prefixed with a comment telling the parameter name.

+

+We want a single exit point in any method only, so no multiple "return" statements.

+

+Avoid unnecessary empty lines. If you feel like you need to separate code within a single method into "sections", consider using double-slash comments to explain what the next section is.

+ SDK_MANAGER="$ANDROID_HOME/tools/bin/sdkmanager"

+# Call with three arguments:

+# - the Github repository {owner}/{repo}, such as SAP/sailing-analytics

+

+# Function to check a workflow run and all its previous attempts

+# Arguments: $1 = workflow run JSON

+# Sets LAST_WORKFLOW_FOR_BRANCH and LATEST_RUN_STARTED_AT if a better match is found

+check_run_and_previous_attempts() {

+ local RUN_JSON="${1}"

+ local CURRENT_RUN="${RUN_JSON}"

+

+ while [ -n "${CURRENT_RUN}" ] && [ "${CURRENT_RUN}" != "null" ]; do

+ local RUN_STATUS=$( echo "${CURRENT_RUN}" | jq -r '.status' )

+ local RUN_NAME=$( echo "${CURRENT_RUN}" | jq -r '.name' )

+ local RUN_HEAD_BRANCH=$( echo "${CURRENT_RUN}" | jq -r '.head_branch' )

+

+ # Check if this run matches our criteria

+ if [ "${RUN_STATUS}" == "completed" ] && [ "${RUN_NAME}" == "release" ]; then

+ if [[ "${RUN_HEAD_BRANCH}" == ${BRANCH}* ]] || [[ "${RUN_HEAD_BRANCH}" == releases/${BRANCH}* ]]; then

+ local RUN_STARTED_AT=$( echo "${CURRENT_RUN}" | jq -r '.run_started_at' )

+ echo "Found completed run (or previous attempt) started at ${RUN_STARTED_AT}"

+ if [[ "${RUN_STARTED_AT}" > "${LATEST_RUN_STARTED_AT}" ]]; then

+ echo "This is later than the latest run so far (${LATEST_RUN_STARTED_AT})"

+ LAST_WORKFLOW_FOR_BRANCH="${CURRENT_RUN}"

+ LATEST_RUN_STARTED_AT="${RUN_STARTED_AT}"

+ fi

+ fi

+ fi

+ # Check for previous attempt

+ local PREVIOUS_ATTEMPT_URL=$( echo "${CURRENT_RUN}" | jq -r '.previous_attempt_url // empty' )

+ if [ -n "${PREVIOUS_ATTEMPT_URL}" ]; then

+ echo "Checking previous attempt at ${PREVIOUS_ATTEMPT_URL} ..."

+ CURRENT_RUN=$( curl --silent -L -H 'Authorization: Bearer '${BEARER_TOKEN} "${PREVIOUS_ATTEMPT_URL}" 2>/dev/null )

+ # Validate we got a proper response

+ if [ -z "${CURRENT_RUN}" ] || [ "$( echo "${CURRENT_RUN}" | jq -r '.id // empty' )" == "" ]; then

+ echo "Could not fetch previous attempt, stopping chain"

+ break

+ fi

+ else

+ break

+ fi

+ done

+}

+

+ NEXT_PAGE_CONTENTS=$( curl -D "${HEADERS_FILE}" --silent -L -H 'Authorization: Bearer '${BEARER_TOKEN} "${NEXT_PAGE}" 2>/dev/null )

+ # Get all workflow runs that match our branch criteria (completed or not, we'll check status in the function)

+ MATCHING_RUNS=$( echo "${NEXT_PAGE_CONTENTS}" | jq -c '.workflow_runs | map(select(.name == "release" and ((.head_branch | startswith("'${BRANCH}'")) or (.head_branch | startswith("releases/'${BRANCH}'"))))) | .[]' 2>/dev/null )

+ if [ -n "${MATCHING_RUNS}" ]; then

+ # Process each matching run

+ while IFS= read -r RUN_JSON; do

+ if [ -n "${RUN_JSON}" ] && [ "${RUN_JSON}" != "null" ]; then

+ echo "Checking run and its previous attempts..."

+ check_run_and_previous_attempts "${RUN_JSON}"

+ fi

+ done <<< "${MATCHING_RUNS}"

+ echo "Found no runs for branch ${BRANCH} on page"

+ final Duration APPROXIMATE_AVERAGE_MANEUVER_DURATION = Duration.ONE_SECOND.times(10);

+ final double aBitOverMinimumManeuverAngleDegrees = boatClass.getManeuverDegreeAngleThreshold() * 1.5;

+ double cog = 0.0;

+ cog = ((double) i+1.0)/((double) NUMBER_OF_FIXES_FOR_MANEUVER) * aBitOverMinimumManeuverAngleDegrees;

+ next = travel(next, samplingInterval.asMillis(), speed.getKnots(), cog);

+ track.add(next);

+ }

+ // now go straight for the maneuver duration to ensure that the approximation has read buffered fixes up to and including the end of the maneuver:

+ for (int i=0; i<boatClass.getApproximateManeuverDurationInMilliseconds()/1000; i++) {

+ next = travel(next, Duration.ONE_SECOND.asMillis(), speed.getKnots(), cog);

+ // now go straight for the maneuver duration to ensure that the approximation has read buffered fixes up to and including the end of the maneuver:

+ for (int i=0; i<boatClass.getApproximateManeuverDurationInMilliseconds()/1000; i++) {

+ next = travel(next, Duration.ONE_SECOND.asMillis(), speed.getKnots(), cog);

+ track.add(next);

+ }

+ final DynamicGPSFixTrack<Competitor, GPSFixMoving> trackCopy = new DynamicGPSFixMovingTrackImpl<Competitor>(

+ sampleCompetitor,

+ /* millisecondsOverWhichToAverage */ boatClass.getApproximateManeuverDurationInMilliseconds());

+ * 4 hull lengths, or the time difference <= getApproximatedManeuverDuration().

+ final boolean result;

+ result = false;

+ } else {

+ Distance fourHullLengths = trackedRace.getRace().getBoatOfCompetitor(competitor).getBoatClass().getHullLength().scale(4);

+ if (currentFix.getTimePoint().asMillis()

+ - previousFix.getTimePoint().asMillis() > getApproximateManeuverDuration().asMillis()

+ && currentFix.getPosition().getDistance(previousFix.getPosition()).compareTo(fourHullLengths) > 0) {

+ result = false;

+ } else {

+ result = true;

+ }

+ return result;

+import java.util.Deque;

+ * New fixes shall be inserted into the {@link FixWindow} only when it is unlikely that newer fixes will still

+ * influence the calculation of its {@link GPSFixMoving#getCachedEstimatedSpeed() estimated speed}. This way,

+ * the differences between seeing and not seeing newer fixes is reduced, and so it isn't so relevant anymore

+ * whether the approximation is updated incrementally as fixes arrive, or after a race has been fully loaded.

+ * <p>

+ *

+ * See also bug 6209.

+ */

+ private final Deque<GPSFixMoving> queueOfNewFixes;

+

+ /**

+ this.queueOfNewFixes = new LinkedList<>();

+ final GPSFixMoving result;

+ queueOfNewFixes.add(next); // FIXME bug6209: the queueOfNewFixes needs to remain ordered by fix TimePoint!

+ final GPSFixMoving first = queueOfNewFixes.getFirst();

+ if (first.getTimePoint().until(next.getTimePoint()).asMillis() > track.getMillisecondsOverWhichToAverageSpeed()/2) {

+ result = addOldEnoughFix(queueOfNewFixes.removeFirst());

+ } else {

+ result = null;

+ }

+ return result;

+ }

+

+ private GPSFixMoving addOldEnoughFix(GPSFixMoving next) {

+import java.lang.management.ManagementFactory;

+import java.util.concurrent.ScheduledExecutorService;

+import java.util.concurrent.ThreadPoolExecutor;

+import com.sap.sse.common.Duration;

+import com.sap.sse.common.Util;

+import com.sap.sse.util.ThreadPoolUtil;

+ final ScheduledExecutorService defaultBackgroundTaskThreadPoolExecutor = ThreadPoolUtil.INSTANCE.getDefaultBackgroundTaskThreadPoolExecutor();

+ if (defaultBackgroundTaskThreadPoolExecutor instanceof ThreadPoolExecutor) {

+ final long queueLengthDefaultBackgroundThreadPoolExecutor = ((ThreadPoolExecutor) defaultBackgroundTaskThreadPoolExecutor).getQueue().size();

+ result.put("defaultbackgroundthreadpoolexecutorqueuelength", queueLengthDefaultBackgroundThreadPoolExecutor);

+ final long nonDelayedQueueLengthDefaultBackgroundThreadPoolExecutor = Util.size(ThreadPoolUtil.INSTANCE.getTasksDelayedByLessThan((ThreadPoolExecutor) defaultBackgroundTaskThreadPoolExecutor, Duration.ONE_SECOND));

+ result.put("defaultbackgroundthreadpoolexecutorqueuelengthnondelayed", nonDelayedQueueLengthDefaultBackgroundThreadPoolExecutor);

+ }

+ final ScheduledExecutorService defaultForegroundTaskThreadPoolExecutor = ThreadPoolUtil.INSTANCE.getDefaultForegroundTaskThreadPoolExecutor();

+ if (defaultForegroundTaskThreadPoolExecutor instanceof ThreadPoolExecutor) {

+ final long queueLengthDefaultForegroundThreadPoolExecutor = ((ThreadPoolExecutor) defaultForegroundTaskThreadPoolExecutor).getQueue().size();

+ result.put("defaultforegroundthreadpoolexecutorqueuelength", queueLengthDefaultForegroundThreadPoolExecutor);

+ final long nonDelayedQueueLengthDefaultForegroundThreadPoolExecutor = Util.size(ThreadPoolUtil.INSTANCE.getTasksDelayedByLessThan((ThreadPoolExecutor) defaultForegroundTaskThreadPoolExecutor, Duration.ONE_SECOND));

+ result.put("defaultforegroundthreadpoolexecutorqueuelengthnondelayed", nonDelayedQueueLengthDefaultForegroundThreadPoolExecutor);

+ }

+ final double systemLoadAverageLastMinute = ManagementFactory.getOperatingSystemMXBean().getSystemLoadAverage();

+ result.put("systemloadaveragelastminute", systemLoadAverageLastMinute);

+

+ String ARCHIVE_SERVER_INSTANCE_NAME = "SL Archive";

+

+ String ARCHIVE_SERVER_NEW_CANDIDATE_INSTANCE_NAME = ARCHIVE_SERVER_INSTANCE_NAME+" (New Candidate)";

+

+ String ARCHIVE_SERVER_FAILOVER_INSTANCE_NAME = ARCHIVE_SERVER_INSTANCE_NAME+" (Failover)";

+

+ String ARCHIVE_CANDIDATE_SUBDOMAIN = "archive-candidate";

+ javax.servlet;version="[3.1.0,4.0.0)",

+ javax.servlet.http;version="[3.1.0,4.0.0)",

+ releaseNameBox = LandscapeDialogUtil.createReleaseNameBox(stringMessages, releaseNames, this);

+package com.sap.sailing.landscape.ui.client;

+

+import com.google.gwt.user.client.ui.Grid;

+import com.google.gwt.user.client.ui.Label;

+import com.google.gwt.user.client.ui.ListBox;

+import com.google.gwt.user.client.ui.TextBox;

+import com.sap.sailing.landscape.ui.client.i18n.StringMessages;

+import com.sap.sse.gwt.client.ErrorReporter;

+import com.sap.sse.gwt.client.controls.IntegerBox;

+import com.sap.sse.gwt.client.dialog.DataEntryDialog;

+

+/**

+ * Allows the user to specify the parameters required for moving a replica set's master process to a different

+ * instance.

+ * <p>

+ *

+ * @author Axel Uhl (d043530)

+ *

+ */

+public abstract class AbstractNewProcessDialog<T> extends DataEntryDialog<T> {

+ public static class NewProcessInstructions {

+ private final String instanceTypeOrNull;

+ private final Integer optionalMemoryInMegabytesOrNull;

+ private final Integer optionalMemoryTotalSizeFactorOrNull;

+ private final String masterReplicationBearerToken;

+ private final String replicaReplicationBearerToken;

+

+ public NewProcessInstructions(String instanceTypeOrNull,

+ String masterReplicationBearerToken, String replicaReplicationBearerToken, Integer optionalMemoryInMegabytesOrNull,

+ Integer optionalMemoryTotalSizeFactorOrNull) {

+ this.instanceTypeOrNull = instanceTypeOrNull;

+ this.optionalMemoryInMegabytesOrNull = optionalMemoryInMegabytesOrNull;

+ this.optionalMemoryTotalSizeFactorOrNull = optionalMemoryTotalSizeFactorOrNull;

+ this.masterReplicationBearerToken = masterReplicationBearerToken;

+ this.replicaReplicationBearerToken = replicaReplicationBearerToken;

+ }

+ public String getDedicatedInstanceType() {

+ return instanceTypeOrNull;

+ }

+ public Integer getOptionalMemoryInMegabytesOrNull() {

+ return optionalMemoryInMegabytesOrNull;

+ }

+ public Integer getOptionalMemoryTotalSizeFactorOrNull() {

+ return optionalMemoryTotalSizeFactorOrNull;

+ }

+ public String getInstanceTypeOrNull() {

+ return instanceTypeOrNull;

+ }

+ public String getMasterReplicationBearerToken() {

+ return masterReplicationBearerToken;

+ }

+ public String getReplicaReplicationBearerToken() {

+ return replicaReplicationBearerToken;

+ }

+ }

+

+ protected final StringMessages stringMessages;

+ private final ListBox instanceTypeListBox;

+ private final Label instanceTypeLabel;

+ private final TextBox masterReplicationBearerTokenBox;

+ private final TextBox replicaReplicationBearerTokenBox;

+ private final IntegerBox memoryInMegabytesBox;

+ private final IntegerBox memoryTotalSizeFactorBox;

+

+ public AbstractNewProcessDialog(String title, String defaultInstanceTypeName,

+ LandscapeManagementWriteServiceAsync landscapeManagementService, StringMessages stringMessages,

+ ErrorReporter errorReporter, DialogCallback<T> callback) {

+ super(title, /* message */ null, stringMessages.ok(), stringMessages.cancel(), /* validator */ null, callback);

+ this.stringMessages = stringMessages;

+ instanceTypeListBox = LandscapeDialogUtil.createInstanceTypeListBox(this, landscapeManagementService,

+ stringMessages, defaultInstanceTypeName, errorReporter, /* canBeDeployedInNlbInstanceBasedTargetGroup */ false);

+ instanceTypeLabel = new Label();

+ masterReplicationBearerTokenBox = createTextBox("", 40);

+ replicaReplicationBearerTokenBox = createTextBox("", 40);

+ memoryInMegabytesBox = createIntegerBox(null, 7);

+ memoryTotalSizeFactorBox = createIntegerBox(null, 2);

+ getMemoryInMegabytesBox().addValueChangeHandler(e->getMemoryTotalSizeFactorBox().setEnabled(e.getValue() == null));

+ }

+

+ @Override

+ protected Grid getAdditionalWidget() {

+ final Grid result = new Grid(5, 2);

+ int row=0;

+ result.setWidget(row, 0, getInstanceTypeLabel());

+ result.setWidget(row++, 1, getInstanceTypeListBox());

+ result.setWidget(row, 0, new Label(stringMessages.bearerTokenForSecurityReplication()));

+ result.setWidget(row++, 1, getMasterReplicationBearerTokenBox());

+ result.setWidget(row, 0, new Label(stringMessages.replicaReplicationBearerToken()));

+ result.setWidget(row++, 1, getReplicaReplicationBearerTokenBox());

+ result.setWidget(row, 0, new Label(stringMessages.memoryInMegabytes()));

+ result.setWidget(row++, 1, getMemoryInMegabytesBox());

+ result.setWidget(row, 0, new Label(stringMessages.memoryTotalSizeFactor()));

+ result.setWidget(row++, 1, getMemoryTotalSizeFactorBox());

+ return result;

+ }

+

+ protected IntegerBox getMemoryTotalSizeFactorBox() {

+ return memoryTotalSizeFactorBox;

+ }

+

+ protected IntegerBox getMemoryInMegabytesBox() {

+ return memoryInMegabytesBox;

+ }

+

+ protected TextBox getReplicaReplicationBearerTokenBox() {

+ return replicaReplicationBearerTokenBox;

+ }

+

+ protected TextBox getMasterReplicationBearerTokenBox() {

+ return masterReplicationBearerTokenBox;

+ }

+

+ protected Label getInstanceTypeLabel() {

+ return instanceTypeLabel;

+ }

+

+ protected ListBox getInstanceTypeListBox() {

+ return instanceTypeListBox;

+ }

+}

+ static final String ACTION_ACTIVATE_ARCHIVE_CANDIDATE = "ACTIVATE_ARCHIVE_CANDIDATE";

+ if (!applicationReplicaSet.isLocalReplicaSet(userService)) {

+ if (applicationReplicaSet.isArchive()) {

+ result.add(new ImageSpec(ACTION_ACTIVATE_ARCHIVE_CANDIDATE, stringMessages.activateArchiveCandidate(), IconResources.INSTANCE.check()));

+ }

+ LandscapeDialogUtil.getReleaseNameBoxValue(getReleaseNameBox(), stringMessages), dynamicLoadBalancerCheckBox==null?false:dynamicLoadBalancerCheckBox.getValue(),

+import java.util.Comparator;

+import java.util.LinkedList;

+import java.util.List;

+import com.google.gwt.user.client.ui.MultiWordSuggestOracle;

+import com.google.gwt.user.client.ui.SuggestBox;

+import com.sap.sse.common.Util;

+

+ public static SuggestBox createReleaseNameBox(StringMessages stringMessages, Iterable<String> releaseNames, DataEntryDialog<?> dialog) {

+ final List<String> releaseNamesAndLatestMaster = new LinkedList<>();

+ Util.addAll(releaseNames, releaseNamesAndLatestMaster);

+ final Comparator<String> newestFirstComaprator = (r1, r2)->r2.compareTo(r1);

+ Collections.sort(releaseNamesAndLatestMaster, newestFirstComaprator);

+ releaseNamesAndLatestMaster.add(0, stringMessages.latestMasterRelease());

+ SuggestBox releaseNameBox = dialog.createSuggestBox(releaseNamesAndLatestMaster);

+ if (releaseNameBox.getSuggestOracle() instanceof MultiWordSuggestOracle) {

+ ((MultiWordSuggestOracle) releaseNameBox.getSuggestOracle()).setComparator(newestFirstComaprator);

+ }

+ releaseNameBox.setValue(stringMessages.latestMasterRelease());

+ return releaseNameBox;

+ }

+

+ public static String getReleaseNameBoxValue(SuggestBox releaseNameBox, StringMessages stringMessages) {

+ return (!Util.hasLength(releaseNameBox.getValue()) || Util.equalsWithNull(releaseNameBox.getValue(), stringMessages.latestMasterRelease()))

+ ? null : releaseNameBox.getValue();

+ }

+import com.sap.sailing.landscape.ui.client.UpgradeArchiveServerDialog.UpgradeArchiveServerInstructions;

+ applicationReplicaSetToUpgrade -> {

+ if (applicationReplicaSetToUpgrade.isArchive()) {

+ upgradeArchiveServer(stringMessages,

+ regionsTable.getSelectionModel().getSelectedObject(), applicationReplicaSetToUpgrade);

+ } else {

+ upgradeApplicationReplicaSet(stringMessages,

+ regionsTable.getSelectionModel().getSelectedObject(), Collections.singleton(applicationReplicaSetToUpgrade));

+ }

+ }

+ );

+ applicationReplicaSetsActionColumn.addAction(ApplicationReplicaSetsImagesBarCell.ACTION_ACTIVATE_ARCHIVE_CANDIDATE,

+ applicationReplicaSetToActivateAsNewArchive -> makeCandidateArchiveServerGoLive(stringMessages,

+ regionsTable.getSelectionModel().getSelectedObject(), applicationReplicaSetToActivateAsNewArchive));

+ landscapeManagementService.upgradeApplicationReplicaSet(regionId, replicaSet,

+

+ private void upgradeArchiveServer(StringMessages stringMessages, String regionId,

+ SailingApplicationReplicaSetDTO<String> archiveReplicaSet) {

+ applicationReplicaSetsBusy.setBusy(true);

+ landscapeManagementService.getReleases(new AsyncCallback<ArrayList<ReleaseDTO>>() {

+ @Override

+ public void onFailure(Throwable caught) {

+ applicationReplicaSetsBusy.setBusy(false);

+ errorReporter.reportError(caught.getMessage());

+ }

+

+ @Override

+ public void onSuccess(ArrayList<ReleaseDTO> releases) {

+ new UpgradeArchiveServerDialog(landscapeManagementService, archiveReplicaSet.getMaster().getHost().getInstanceType(),

+ releases.stream().map(r->r.getName())::iterator,

+ stringMessages, errorReporter, new DialogCallback<UpgradeArchiveServerDialog.UpgradeArchiveServerInstructions>() {

+ @Override

+ public void ok(UpgradeArchiveServerInstructions upgradeInstructions) {

+ landscapeManagementService.createArchiveReplicaSet(regionId, archiveReplicaSet, upgradeInstructions.getInstanceTypeOrNull(),

+ upgradeInstructions.getReleaseNameOrNullForLatestMaster(), sshKeyManagementPanel.getSelectedKeyPair()==null?null:sshKeyManagementPanel.getSelectedKeyPair().getName(),

+ sshKeyManagementPanel.getPassphraseForPrivateKeyDecryption() != null

+ ? sshKeyManagementPanel.getPassphraseForPrivateKeyDecryption().getBytes() : null,

+ upgradeInstructions.getMasterReplicationBearerToken(), upgradeInstructions.getReplicaReplicationBearerToken(),

+ upgradeInstructions.getOptionalMemoryInMegabytesOrNull(), upgradeInstructions.getOptionalMemoryTotalSizeFactorOrNull(),

+ new AsyncCallback<Void>() {

+ @Override

+ public void onFailure(Throwable caught) {

+ applicationReplicaSetsBusy.setBusy(false);

+ errorReporter.reportError(caught.getMessage());

+ }

+

+ @Override

+ public void onSuccess(Void result) {

+ applicationReplicaSetsBusy.setBusy(false);

+ Notification.notify(

+ stringMessages.successfullyLaunchedNewArchiveCandidate(

+ archiveReplicaSet.getName(),

+ upgradeInstructions

+ .getReleaseNameOrNullForLatestMaster() == null

+ ? "Default"

+ : upgradeInstructions

+ .getReleaseNameOrNullForLatestMaster()),

+ NotificationType.SUCCESS);

+ }

+ });

+ }

+

+ @Override

+ public void cancel() {

+ applicationReplicaSetsBusy.setBusy(false);

+ }

+ }).show();

+ }

+ });

+ }

+

+ private void makeCandidateArchiveServerGoLive(StringMessages stringMessages, String regionId, SailingApplicationReplicaSetDTO<String> archiveReplicaSetToUpgrade) {

+ if (Window.confirm(stringMessages.reallySwitchToNewArchiveCandidate())) {

+ applicationReplicaSetsBusy.setBusy(true);

+ landscapeManagementService.makeCandidateArchiveServerGoLive(regionId, archiveReplicaSetToUpgrade,

+ sshKeyManagementPanel.getSelectedKeyPair() == null ? null

+ : sshKeyManagementPanel.getSelectedKeyPair().getName(),

+ sshKeyManagementPanel.getPassphraseForPrivateKeyDecryption() != null

+ ? sshKeyManagementPanel.getPassphraseForPrivateKeyDecryption().getBytes()

+ : null,

+ new AsyncCallback<Void>() {

+ @Override

+ public void onFailure(Throwable caught) {

+ applicationReplicaSetsBusy.setBusy(false);

+ errorReporter.reportError(caught.getMessage());

+ }

+

+ @Override

+ public void onSuccess(Void result) {

+ applicationReplicaSetsBusy.setBusy(false);

+ Notification.notify(stringMessages.successfullySwitchedToNewArchiveCandidate(archiveReplicaSetToUpgrade.getName()), NotificationType.SUCCESS);

+ }

+ });

+ }

+ }

+ void createArchiveReplicaSet(

+ String regionId, SailingApplicationReplicaSetDTO<String> applicationReplicaSetToUpgrade, String optionalSharedInstanceType, String releaseOrNullForLatestMaster,

+ String optionalKeyName, byte[] privateKeyEncryptionPassphrase, String securityReplicationBearerToken, String replicaReplicationBearerToken,

+ Integer optionalMemoryInMegabytesOrNull, Integer optionalMemoryTotalSizeFactorOrNull) throws Exception;

+

+

+ void makeCandidateArchiveServerGoLive(String regionId,

+ SailingApplicationReplicaSetDTO<String> archiveReplicaSetToUpgrade, String optionalKeyName,

+ byte[] privateKeyEncryptionPassphrase) throws Exception;

+

+ void createArchiveReplicaSet(String regionId, SailingApplicationReplicaSetDTO<String> applicationReplicaSetToUpgrade,

+ String optionalSharedInstanceType, String releaseOrNullForLatestMaster, String optionalKeyName,

+ byte[] privateKeyEncryptionPassphrase, String securityReplicationBearerToken, String replicaReplicationBearerToken,

+ Integer optionalMemoryInMegabytesOrNull, Integer optionalMemoryTotalSizeFactorOrNull, AsyncCallback<Void> callback);

+

+ void makeCandidateArchiveServerGoLive(String regionId,

+ SailingApplicationReplicaSetDTO<String> archiveReplicaSetToUpgrade, String optionalKeyName,

+ byte[] privateKeyEncryptionPassphrase, AsyncCallback<Void> callback);

+public class MoveMasterProcessDialog extends AbstractNewProcessDialog<MoveMasterProcessDialog.MoveMasterToOtherInstanceInstructions> {

+ public static class MoveMasterToOtherInstanceInstructions extends AbstractNewProcessDialog.NewProcessInstructions {

+ super(instanceTypeOrNull, masterReplicationBearerToken, replicaReplicationBearerToken, optionalMemoryInMegabytesOrNull, optionalMemoryTotalSizeFactorOrNull);

+ StringMessages stringMessages, ErrorReporter errorReporter,

+ DialogCallback<MoveMasterToOtherInstanceInstructions> callback) {

+ super(stringMessages.moveMasterToOtherInstance(), SharedLandscapeConstants.DEFAULT_DEDICATED_INSTANCE_TYPE_NAME,

+ landscapeManagementService, stringMessages, errorReporter, callback);

+ getMemoryTotalSizeFactorBox().addValueChangeHandler(e->memoryAsFactorToTotalMemoryAdjusted=true);

+ getInstanceTypeLabel().setText(sharedMasterInstanceBox.getValue() ? stringMessages.sharedMasterInstanceType() : stringMessages.dedicatedInstanceType());

+ LandscapeDialogUtil.selectInstanceType(getInstanceTypeListBox(),

+ getMemoryTotalSizeFactorBox().setValue(SharedLandscapeConstants.DEFAULT_NUMBER_OF_PROCESSES_IN_MEMORY);

+ getMemoryTotalSizeFactorBox().setText("");

+ protected Grid getAdditionalWidget() {

+ final Grid result = super.getAdditionalWidget();

+ result.insertRow(row);

+ getInstanceTypeListBox().getSelectedValue(),

+ getMasterReplicationBearerTokenBox().getValue(), getReplicaReplicationBearerTokenBox().getValue(),

+ getMemoryInMegabytesBox().getValue(), getMemoryTotalSizeFactorBox().getValue());

+ return new UpgradeApplicationReplicaSetInstructions(

+ LandscapeDialogUtil.getReleaseNameBoxValue(getReleaseNameBox(), stringMessages),

+ getMasterReplicationBearerTokenBox().getValue(), getReplicaReplicationBearerTokenBox().getValue());

+package com.sap.sailing.landscape.ui.client;

+

+import com.google.gwt.user.client.ui.FocusWidget;

+import com.google.gwt.user.client.ui.Grid;

+import com.google.gwt.user.client.ui.Label;

+import com.google.gwt.user.client.ui.SuggestBox;

+import com.sap.sailing.landscape.ui.client.i18n.StringMessages;

+import com.sap.sse.gwt.client.ErrorReporter;

+

+public class UpgradeArchiveServerDialog extends AbstractNewProcessDialog<UpgradeArchiveServerDialog.UpgradeArchiveServerInstructions> {

+

+ public static class UpgradeArchiveServerInstructions extends AbstractNewProcessDialog.NewProcessInstructions {

+ private final String releaseNameOrNullForLatestMaster;

+

+ public UpgradeArchiveServerInstructions(String releaseNameOrNullForLatestMaster,

+ String masterReplicationBearerToken, String replicaReplicationBearerToken, String optionalInstanceType,

+ Integer optionalMemoryInMegabytesOrNull, Integer optionalMemoryTotalSizeFactorOrNull) {

+ super(optionalInstanceType, masterReplicationBearerToken, replicaReplicationBearerToken, optionalMemoryInMegabytesOrNull, optionalMemoryTotalSizeFactorOrNull);

+ this.releaseNameOrNullForLatestMaster = releaseNameOrNullForLatestMaster;

+ }

+

+ public String getReleaseNameOrNullForLatestMaster() {

+ return releaseNameOrNullForLatestMaster;

+ }

+ }

+

+ private final SuggestBox releaseNameBox;

+

+ public UpgradeArchiveServerDialog(LandscapeManagementWriteServiceAsync landscapeManagementService, String defaultInstanceTypeName,

+ Iterable<String> releaseNames,

+ StringMessages stringMessages, ErrorReporter errorReporter, DialogCallback<UpgradeArchiveServerInstructions> callback) {

+ super(stringMessages.upgradeArchiveServer(), defaultInstanceTypeName, landscapeManagementService, stringMessages, errorReporter, callback);

+ releaseNameBox = LandscapeDialogUtil.createReleaseNameBox(stringMessages, releaseNames, this);

+ }

+

+ @Override

+ protected Grid getAdditionalWidget() {

+ final Grid result = super.getAdditionalWidget();

+ int row=0;

+ result.insertRow(row);

+ result.setWidget(row, 0, new Label(stringMessages.release()));

+ result.setWidget(row++, 1, releaseNameBox);

+ return result;

+ }

+

+ @Override

+ public FocusWidget getInitialFocusWidget() {

+ return releaseNameBox.getValueBox();

+ }

+

+ @Override

+ protected UpgradeArchiveServerInstructions getResult() {

+ return new UpgradeArchiveServerInstructions(LandscapeDialogUtil.getReleaseNameBoxValue(releaseNameBox, stringMessages), getMasterReplicationBearerTokenBox().getValue(),

+ getReplicaReplicationBearerTokenBox().getValue(), getInstanceTypeListBox().getSelectedValue(),

+ getMemoryInMegabytesBox().getValue(), getMemoryTotalSizeFactorBox().getValue());

+ }

+}

+ String upgradeArchiveServer();

+ String successfullyLaunchedNewArchiveCandidate(String replicaSetName, String releaseName);

+ String successfullySwitchedToNewArchiveCandidate(String replicaSetName);

+ String activateArchiveCandidate();

+ String reallySwitchToNewArchiveCandidate();

+upgradeArchiveServer=Upgrade archive server

+examplePort=e.g., {0}

+successfullyLaunchedNewArchiveCandidate=Successfully launched new {0} candidate with release {1}. You will receive an e-mail when the candidate is ready for spot checks and rotation to production. This can take several hours, depending on the number of events to load.

+successfullySwitchedToNewArchiveCandidate=Successfully switched to new {0} server

+activateArchiveCandidate=Activate ARCHIVE candidate (must have run an upgrade before and received the success e-mail!)

+reallySwitchToNewArchiveCandidate=Really switch to new ARCHIVE candidate? You confirm that you have previously received a success notification from a prior ARCHIVE upgrade request and that you have done a few spot checks to ensure the ARCHIVE candidate looks good.

+ugradeArchvieServer=Archiv-Server aktualisieren

+examplePort=z.B. {0}

+successfullyLaunchedNewArchiveCandidate=Neuen Kandidaten für {0} mit Version {1} gestartet. Es erfolgt eine Benachrichtigung per e-Mail. Das kann, je nach Umfang der zu ladenden Daten, etliche Stunden dauern.

+successfullySwitchedToNewArchiveCandidate=Erfolgreich auf neuen Server {0} umgeschaltet

+activateArchiveCandidate=ARCHIVE-Kandidaten aktivieren (zuvor muss ein Upgrade-Versuch per e-Mail als erfolgreich markiert worden sein!)

+reallySwitchToNewArchiveCandidate=Wirklich auf dne neuen ARCHIVE-Kandidaten umschalten? Du bestätigst damit, dass Du eine Erfolgs-Benachrichtigung zu einer vorangegangenen Update-Prozedur für den ARCHIVE-Server erhalten hast und Du Dich wenigstens stichprobenartig von der Korrektheit des neuen Kandidaten überzeugt hast.

+import java.net.URL;

+import com.sap.sse.landscape.DefaultProcessConfigurationVariables;

+import com.sap.sse.landscape.mongodb.Database;

+ instance.getInstanceType().name(), instance.getPrivateAddress().getHostAddress(),

+ instance.getPublicAddress().getHostAddress(), region, instance.getLaunchTimePoint(),

+ instance.isSharedHost(), instance.getNameTag(), instance.getImageId(),

+ extractHealth(healths, instance), isDisposable, new AvailabilityZoneDTO(instance.getAvailabilityZone().getName(), instance.getRegion().getId(), instance.getAvailabilityZone().getId()));

+ return new AwsInstanceDTO(host.getId().toString(),

+ (host instanceof AwsInstance<?>) ? ((AwsInstance<?>) host).getInstanceType().name() : null,

+ host.getPrivateAddress().getHostAddress(),

+ host.getPublicAddress() == null ? null : host.getPublicAddress().getHostAddress(),

+ host.getRegion().getId(), host.getLaunchTimePoint(), host.isSharedHost(),

+ new AvailabilityZoneDTO(host.getAvailabilityZone().getName(), host.getRegion().getId(),

+ host.getAvailabilityZone().getId()));

+ @Override

+ public void createArchiveReplicaSet(String regionId, SailingApplicationReplicaSetDTO<String> archiveReplicaSetToUpgrade,

+ String instanceType, String releaseNameOrNullForLatestMaster, String optionalKeyName,

+ byte[] privateKeyEncryptionPassphrase, String securityReplicationBearerToken,

+ String replicaReplicationBearerToken, Integer optionalMemoryInMegabytesOrNull, Integer optionalMemoryTotalSizeFactorOrNull) throws Exception {

+ checkLandscapeManageAwsPermission();

+ final String userSetOrArchiveServerSecurityReplicationBearerToken;

+ final AwsRegion region = new AwsRegion(regionId, getLandscape());

+ final AwsApplicationReplicaSet<String, SailingAnalyticsMetrics, SailingAnalyticsProcess<String>> awsReplicaSet =

+ convertFromApplicationReplicaSetDTO(region, archiveReplicaSetToUpgrade, optionalKeyName, privateKeyEncryptionPassphrase);

+ final SailingAnalyticsProcess<String> master = awsReplicaSet.getMaster();

+ if (Util.hasLength(securityReplicationBearerToken)) {

+ userSetOrArchiveServerSecurityReplicationBearerToken = securityReplicationBearerToken;

+ } else {

+ userSetOrArchiveServerSecurityReplicationBearerToken = master.getEnvShValueFor(

+ DefaultProcessConfigurationVariables.REPLICATE_MASTER_BEARER_TOKEN,

+ Landscape.WAIT_FOR_PROCESS_TIMEOUT, Optional.of(optionalKeyName), privateKeyEncryptionPassphrase);

+ }

+ final String replicaSetName = SharedLandscapeConstants.ARCHIVE_SERVER_APPLICATION_REPLICA_SET_NAME;

+ final String domainName = AwsLandscape.getHostedZoneName(archiveReplicaSetToUpgrade.getHostname());

+ final Database databaseConfiguration = master.getDatabaseConfiguration(region,

+ Landscape.WAIT_FOR_PROCESS_TIMEOUT, Optional.ofNullable(optionalKeyName),

+ privateKeyEncryptionPassphrase);

+ final URL requestURL = new URL(getThreadLocalRequest().getRequestURL().toString());

+ final URL continuationBaseURL = new URL(requestURL.getProtocol(), requestURL.getHost(), requestURL.getPort(), "/");

+ getLandscapeService()

+ .createArchiveReplicaSet(regionId, replicaSetName, instanceType, releaseNameOrNullForLatestMaster,

+ databaseConfiguration, optionalKeyName, privateKeyEncryptionPassphrase,

+ replicaReplicationBearerToken, domainName, optionalMemoryInMegabytesOrNull,

+ userSetOrArchiveServerSecurityReplicationBearerToken, optionalMemoryTotalSizeFactorOrNull,

+ /* optionalIgtimiRiotPort */ null, continuationBaseURL);

+ }

+

+ @Override

+ public void makeCandidateArchiveServerGoLive(String regionId, SailingApplicationReplicaSetDTO<String> archiveReplicaSetToUpgrade,

+ String optionalKeyName, byte[] privateKeyEncryptionPassphrase) throws Exception {

+ final String domainName = AwsLandscape.getHostedZoneName(archiveReplicaSetToUpgrade.getHostname());

+ getLandscapeService().makeCandidateArchiveServerGoLive(regionId, optionalKeyName, privateKeyEncryptionPassphrase, domainName);

+ }

+

+ private String instanceType;

+ public AwsInstanceDTO(String instanceId, String instanceType, String privateIpAddress, String publicIpAddress, String region, TimePoint launchTimePoint, boolean shared, AvailabilityZoneDTO azDTO) {

+ this.instanceType = instanceType;

+ public String getInstanceType() {

+ return instanceType;

+ }

+ public ReverseProxyDTO(String instanceId, String instanceType, String privateIpAddress,

+ String publicIpAddress, String region, TimePoint launchTimePoint, boolean shared, String name, String imageId,

+ String healthInTargetGroup, boolean isDisposable, AvailabilityZoneDTO availabilityZoneDTO) {

+ super(instanceId, instanceType, privateIpAddress, publicIpAddress, region, launchTimePoint, shared, availabilityZoneDTO);

+ /**

+ * Originates from load balancer rule and therefore it can be null of not managed by load balancer rule

+ */

+ /**

+ * @return may be null if not managed by load balancer rule

+ */

+MasterUnavailableMailBody=The primary server of replica set {0} is temporarily unavailable.\nModifying access will be suspended.\nModifications incurred by a replica will be queued and will be applied when the primary is available again.\n\nYou are receiving this mail because you have administrative permissions for {0}.\nRemove those permissions at <https://sapsailing.com/gwt/AdminConsole.html#UserManagementPlace:> if you do not like to receive these messages anymore.

+StartingNewArchiveCandidateSubject=Starting new {0} candidate

+StartingNewArchiveCandidateBody=Starting new {0} candidate.\nFirst, archived content is loaded from the MongoDB; afterwards wind estimations and mark passings are calculated.\nThe whole process can take up to two days.\nYou will receive another e-mail when this phase has finished.\nAlso check the status of the candidate at https://archive-canidate.sapsailing.com/gwt/status

+NewArchiveServerLiveSubject=New {0} server is live

+NewArchiveServerLiveBody=New {0} server is live.\nYou can now archive content to {0}.\n\nYou are receiving this mail because you have administrative permissions for {0}.\nRemove those permissions at <https://sapsailing.com/gwt/AdminConsole.html#UserManagementPlace:> if you do not like to receive these messages anymore.

+StartingToArchiveReplicaSetIntoBody=Starting to archive a replica set to {0}.\nWhile this is going on, refrain from archiving another replica set into the same archive {0}.\nAfter the content has been imported it will be compared to the original.\nYou should receive another e-mail when this has completed.\n\nYou are receiving this mail because you have administrative permissions for {0}.\nRemove those permissions at <https://sapsailing.com/gwt/AdminConsole.html#UserManagementPlace:> if you do not like to receive these messages anymore.

+StartingToArchiveReplicaSetBody=Starting to archive a replica set {0}.\nWhile this is ongoing please do not make any modifications to {0}.\nYou will receive another e-mail when this process has finished.\n\nYou are receiving this mail because you have administrative permissions for {0}.\nRemove those permissions at <https://sapsailing.com/gwt/AdminConsole.html#UserManagementPlace:> if you do not like to receive these messages anymore.

+FinishedToArchiveReplicaSetIntoBody=Archiving a replica set to {0} has finished.\nYou can now archive other content to {0} if you want.\n\nYou are receiving this mail because you have administrative permissions for {0}.\nRemove those permissions at <https://sapsailing.com/gwt/AdminConsole.html#UserManagementPlace:> if you do not like to receive these messages anymore.

+FinishedToArchiveReplicaSetBody=Archiving replica set {0} has finished.\nIf you requested so, the original replica set has been removed.\n\nYou are receiving this mail because you have administrative permissions for {0}.\nRemove those permissions at <https://sapsailing.com/gwt/AdminConsole.html#UserManagementPlace:> if you do not like to receive these messages anymore.

+NewArchiveCandidateReadyForSpotChecksAndRotationSubject=The new {0} candidate is ready for spot checks

+NewArchiveCandidateReadyForSpotChecksAndRotationBody=We''ve run the following checks:\n{3}.\nThe new {0} candidate is ready for spot checks and, if OK, rotation to become the new production {0}.\nRun your spot checks at <https://{1}/gwt/Home.html#EventsPlace:> and compare to <https://{2}/gwt/Home.html#EventsPlace:>.\nStart the rotation to the new production server at <{4}/gwt/AdminConsole.html#LandscapeManagementPlace:> after successful checks.

+NewArchiveCandidateFailedSubject=Check {1} failed during {0} startup

+NewArchiveCandidateFailedBody=The check "{1}" failed with message "{2}" while starting up {0}. Please check the landscape and fix manually.

+MasterUnavailableMailBody=Der Primär-Server des Anwendungs-Clusters {0} ist vorübergehend nicht verfügbar.\nVerändernde Zugriffe sind derzeit nicht möglich.\nModifikationen, die durch eine Replika ausgeüfhrt werden, werden gepuffert und werden angewandt, wenn der primäre Server wieder verfügbar ist.\n\nDiese Nachricht wurde versandt, weil Du über administrative Rechte für {0} verfügst.\nUm das zu ändern, besuche <https://sapsailing.com/gwt/AdminConsole.html#UserManagementPlace:>, um diese Rechte für Dein Benutzerkonto zu entfernen.

+MasterAvailableMailBody=Der Primär-Server des Anwendungs-Clusters {0} ist wieder verfügbar.\nVerändernde Zugriffe sind jetzt wieder möglich.\nGepufferte Modifikationen werden jetzt abgearbeitet.\n\nDiese Nachricht wurde versandt, weil Du über administrative Rechte für {0} verfügst.\nUm das zu ändern, besuche <https://sapsailing.com/gwt/AdminConsole.html#UserManagementPlace:>, um diese Rechte für Dein Benutzerkonto zu entfernen.

+StartingNewArchiveCandidateSubject=Neuer {0}-Kandidat wird gestartet

+StartingNewArchiveCandidateBody=Neuer {0}-Kandidat wird gestartet.\nZuerst werden dabei die archivierten Veranstaltungen von der Datenbank geladen. Danach werden Manöver, Windschätzungen und Zwischenzeiten berechnet.\nDieser Prozess kann bis zu zwei vollen Tagen dauern.\nEine weitere e-Mail benachrichtigt über den Abschluss dieser Phase.\nUnter https://archive-canidate.sapsailing.com/gwt/status kann der Status des Kandidaten verfolgt werden.

+NewArchiveServerLiveSubject=Neuer {0}-Server ist live

+NewArchiveServerLiveBody=Neuer {0}-Server ist live.\nAb jetzt dürfen wieder Anwendungs-Cluster nach {0} archiviert werden.\n\nDiese Nachricht wurde versandt, weil Du über administrative Rechte für {0} verfügst.\nUm das zu ändern, besuche https://sapsailing.com/gwt/AdminConsole.html#UserManagementPlace:, um diese Rechte für Dein Benutzerkonto zu entfernen.

+StartingToArchiveReplicaSetIntoBody=Ein Anwendungs-Cluster wird nach {0} archiviert.\nWährend dieser Vorgang läuft, dürfen keine weitere Anwendungs-Cluster nach {0} archiviert werden.\nNach der Archivierung werden die Inhalte verglichen.\nEine e-Mail folgt, wenn der Vorgang abgeschlossen ist.\n\nDiese Nachricht wurde versandt, weil Du über administrative Rechte für {0} verfügst.\nUm das zu ändern, besuche <https://sapsailing.com/gwt/AdminConsole.html#UserManagementPlace:>, um diese Rechte für Dein Benutzerkonto zu entfernen.

+StartingToArchiveReplicaSetBody=Das Anwendungs-Cluster {0} wird jetzt archiviert.\nWährenddessen dürfen keine Veränderungen an {0} vorgenommen werden.\nEine e-Mail folgt, wenn der Vorgang abgeschlossen ist.\n\nDiese Nachricht wurde versandt, weil Du über administrative Rechte für {0} verfügst.\nUm das zu ändern, besuche <https://sapsailing.com/gwt/AdminConsole.html#UserManagementPlace:>, um diese Rechte für Dein Benutzerkonto zu entfernen.

+FinishedToArchiveReplicaSetIntoBody=Die Archivierung des Anwendungs-Clusters nach {0} ist beendet.\nAb jetzt sind bei Bedarf weitere Archivierungen nach {0} möglich.\n\nDiese Nachricht wurde versandt, weil Du über administrative Rechte für {0} verfügst.\nUm das zu ändern, besuche <https://sapsailing.com/gwt/AdminConsole.html#UserManagementPlace:>, um diese Rechte für Dein Benutzerkonto zu entfernen.

+FinishedToArchiveReplicaSetBody=Die Archivierung des Anwendungs-Clusters {0} ist beendet.\nFalls angefragt, wurde das Original Anwendungs-Cluster entfernt.\n\nDiese Nachricht wurde versandt, weil Du über administrative Rechte für {0} verfügst.\nUm das zu ändern, besuche <https://sapsailing.com/gwt/AdminConsole.html#UserManagementPlace:>, um diese Rechte für Dein Benutzerkonto zu entfernen.

+NewArchiveCandidateReadyForSpotChecksAndRotationSubject=Der neue {0} Kandidat ist bereit für einen stichprobenartigen Vergleich

+NewArchiveCandidateReadyForSpotChecksAndRotationBody=Es wurden die folgenden Prüfungen durchgeführt:\n{3}.\nDer neue {0} Kandidat ist bereit für einen stichprobenartigen Vergleich\nund, falls OK, Rotation zum neuen Produktiv-Server für {0}.\nStichprobenartiger Vergleich unter https://{1}/gwt/Home.html#EventsPlace: und https://{2}/gwt/Home.html#EventsPlace:.\nRotation nach erfolgreichen Prüfungen unter <{4}/gwt/AdminConsole.html#LandscapeManagementPlace:> starten.

+NewArchiveCandidateFailedSubject=Überprüfung {1} beim Start von {0} fehlgeschlagen

+NewArchiveCandidateFailedBody=Die Überprüfung "{1}" zum Start von {0} ist mit der Meldung "{2}" fehlgeschlagen. Bitte die Landschaft inspizieren und manuell korrigieren.

+import java.net.URL;

+import com.sap.sailing.server.gateway.interfaces.SailingServerFactory;

+import com.sap.sse.common.mail.MailException;

+import com.sap.sse.landscape.mongodb.Database;

+import com.sap.sse.security.shared.HasPermissions.Action;

+import com.sap.sse.security.shared.impl.User;

+

+ /**

+ * Runs phase 1 of an ARCHIVE server upgrade. This includes launching the new instance in a favorable availability

+ * zone where ideally we have a reverse proxy and that ideally is different from the AZ in which the current

+ * production ARCHIVE server runs. It then installs a {@link ArchiveCandidateMonitoringBackgroundTask background

+ * task} that keeps applying a sequence of checks. When any of the checks keeps failing beyond a timeout, the

+ * activity is aborted, and the user who triggered it receives an e-mail about this. If all checks pass, the user

+ * receives an e-mail that asks for manual spot checks and a confirmation about the rotation. A link embedded in the

+ * e-mail grants the user easy access to the

+ * {@link #makeCandidateArchiveServerGoLive(String, String, byte[], String)} method which then performs phase 2.

+ *

+ * @param continuationBaseURL

+ * the base URL to which to direct the user for continuation of the ARCHIVE upgrade process (phase 2)

+ * after this first phase has completed successfully

+ */

+ void createArchiveReplicaSet(

+ String regionId, String name, String instanceType, String releaseNameOrNullForLatestMaster, Database databaseConfiguration,

+ String optionalKeyName, byte[] privateKeyEncryptionPassphrase, String replicaReplicationBearerToken,

+ String optionalDomainName, Integer optionalMemoryInMegabytesOrNull, String securityServiceReplicationBearerToken,

+ Integer optionalMemoryTotalSizeFactorOrNull, Integer optionalIgtimiRiotPort, URL continuationBaseURL) throws Exception;

+

+ /**

+ * Phase 2 of an ARCHIVE server upgrade. This is to be triggered ideally after a "human in the loop" step

+ * where a user makes some spot checks and then confirms that the archive candidate can be installed as the

+ * new production server, with the previous production server then becoming the failover, and the old failover

+ * instance being terminated.

+ */

+ void makeCandidateArchiveServerGoLive(String regionId, String optionalKeyName,

+ byte[] privateKeyEncryptionPassphrase, String optionalDomainName) throws Exception;

+

+ /**

+ * @param subjectMessageKey

+ * must have a single placeholder argument representing the name of the replica set

+ * @param bodyMessageKey

+ * must have a single placeholder argument representing the name of the replica set

+ * @param alsoSendToAllUsersWithThisPermissionOnReplicaSet

+ * when not empty, all users that have permission to this {@link SecuredSecurityTypes#SERVER SERVER}

+ * action on the {@code replicaSet} will receive the e-mail in addition to the server owner. No user

+ * will receive the e-mail twice.

+ */

+ void sendMailToReplicaSetOwner(

+ AwsApplicationReplicaSet<String, SailingAnalyticsMetrics, SailingAnalyticsProcess<String>> replicaSet,

+ String subjectMessageKey, String bodyMessageKey,

+ Optional<Action> alsoSendToAllUsersWithThisPermissionOnReplicaSet) throws MailException;

+

+ void sendMailToCurrentUser(String messageSubjectKey, String messageBodyKey, String... messageParameters)

+ throws MailException;

+

+ void sendMailToUser(User user, String messageSubjectKey, String messageBodyKey, String... messageParameters)

+ throws MailException;

+

+ SailingServerFactory getSailingServerFactory();

+import java.util.concurrent.TimeoutException;

+import com.sap.sse.util.ThreadPoolUtil;

+

+ double getLastMinuteSystemLoadAverage(Optional<Duration> optionalTimeout) throws TimeoutException, Exception;

+

+ /**

+ * The count of <em>all</em> tasks in the default background thread pool executor's queue, including those scheduled

+ * with a delay, such as rate limiter and cache clean-up tasks or periodic fetching of remote server content.

+ *

+ * @see ThreadPoolUtil#getDefaultBackgroundTaskThreadPoolExecutor()

+ */

+ int getDefaultBackgroundThreadPoolExecutorQueueSize(Optional<Duration> optionalTimeout) throws TimeoutException, Exception;

+

+ /**

+ * The count of <em>all</em> tasks in the default foreground thread pool executor's queue, including those scheduled

+ * with a delay, such as rate limiter and cache clean-up tasks or periodic fetching of remote server content.

+ *

+ * @see ThreadPoolUtil#getDefaultForegroundTaskThreadPoolExecutor()

+ */

+ int getDefaultForegroundThreadPoolExecutorQueueSize(Optional<Duration> optionalTimeout) throws TimeoutException, Exception;

+

+ /**

+ * The count of only those tasks in the default background thread pool executor's queue that have no scheduling

+ * delay or a delay below {@link Duration#ONE_SECOND one second}. This helps exclude from the count those rate

+ * limiter and cache clean-up tasks or periodic fetching of remote server content. It is as such as good approximation

+ * of the "immediate" tasks that will keep the server busy in the immediate future.

+ *

+ * @see ThreadPoolUtil#getDefaultBackgroundTaskThreadPoolExecutor()

+ */

+ int getDefaultBackgroundThreadPoolExecutorQueueSizeNondelayed(Optional<Duration> optionalTimeout) throws TimeoutException, Exception;

+

+ /**

+ * The count of only those tasks in the default foreground thread pool executor's queue that have no scheduling

+ * delay or a delay below {@link Duration#ONE_SECOND one second}. This helps exclude from the count those rate

+ * limiter and cache clean-up tasks or periodic fetching of remote server content. It is as such as good approximation

+ * of the "immediate" tasks that will keep the server busy in the immediate future.

+ *

+ * @see ThreadPoolUtil#getDefaultForegroundTaskThreadPoolExecutor()

+ */

+ int getDefaultForegroundThreadPoolExecutorQueueSizeNondelayed(Optional<Duration> optionalTimeout) throws TimeoutException, Exception;

+package com.sap.sailing.landscape.impl;

+

+import java.net.URL;

+import java.util.Arrays;

+import java.util.Iterator;

+import java.util.Optional;

+import java.util.concurrent.ExecutionException;

+import java.util.concurrent.ScheduledExecutorService;

+import java.util.concurrent.TimeUnit;

+import java.util.logging.Logger;

+

+import com.sap.sailing.landscape.LandscapeService;

+import com.sap.sailing.landscape.SailingAnalyticsMetrics;

+import com.sap.sailing.landscape.SailingAnalyticsProcess;

+import com.sap.sailing.server.gateway.interfaces.CompareServersResult;

+import com.sap.sailing.server.gateway.interfaces.SailingServer;

+import com.sap.sse.common.Duration;

+import com.sap.sse.common.Named;

+import com.sap.sse.common.TimePoint;

+import com.sap.sse.common.Util;

+import com.sap.sse.common.impl.NamedImpl;

+import com.sap.sse.common.mail.MailException;

+import com.sap.sse.landscape.Landscape;

+import com.sap.sse.landscape.aws.AwsApplicationReplicaSet;

+import com.sap.sse.security.shared.impl.User;

+

+/**

+ * A stateful monitoring task that can be {@link #run run} to observe an {@code ARCHIVE} candidate process and wait for

+ * it to be ready for comparing its contents with a production {@code ARCHIVE} instance. When run for the first time,

+ * the task check the {@code /gwt/status} end point on {@code candidateHostname} to see whether it is already serving

+ * requests. If not, it will re-schedule itself after some delay to check again until either the candidate becomes

+ * healthy or a timeout is reached.

+ * <p>

+ *

+ * If the candidate was seen serving a {@code /gwt/status} request, this task changes state and now looks at the

+ * contents of the status response. Four conditions must be fulfilled for the candidate to be considered ready for

+ * comparison:

+ *

+ * <ol>

+ * <li>the overall status must be {@code available: true}.</li>

+ * <li>the one-minute system load average must be below 2 (per cent)</li>

+ * <li>the default foreground thread pool queue must contain less than 10 tasks</li>

+ * <li>the default background thread pool queue must contain less than 10 tasks</li>

+ * <li>the old and new ARCHIVE must compare equal with the {@link SailingServer#compareServers(Optional, SailingServer, Optional)} method</li>

+ * </ol>

+ *

+ * When any of these conditions is not fulfilled, the task will re-schedule itself after some delay to check again until

+ * either the candidate fulfills all conditions or a timeout is reached.

+ * <p>

+ *

+ * @author Axel Uhl (d043530)

+ *

+ */

+public class ArchiveCandidateMonitoringBackgroundTask implements Runnable {

+ private interface Check extends Named {

+ boolean runCheck() throws Exception;

+ void setLastFailureMessage(String lastFailureMessage);

+ boolean hasTimedOut();

+ Duration getDelayAfterFailure();

+ String getLastFailureMessage();

+ }

+

+ private abstract class AbstractCheck extends NamedImpl implements Check {

+ private static final long serialVersionUID = -8809199091635882129L;

+ private final TimePoint creationTime;

+ private final Duration timeout;

+ private final Duration delayAfterFailure;

+ private String lastFailureMessage;

+

+ public AbstractCheck(String name, Duration timeout, Duration delayAfterFailure) {

+ super(name);

+ this.creationTime = TimePoint.now();

+ this.timeout = timeout;

+ this.delayAfterFailure = delayAfterFailure;

+ }

+

+ @Override

+ public boolean hasTimedOut() {

+ return creationTime.until(TimePoint.now()).compareTo(timeout) > 0;

+ }

+

+ @Override

+ public Duration getDelayAfterFailure() {

+ return delayAfterFailure;

+ }

+

+ @Override

+ public String getLastFailureMessage() {

+ return lastFailureMessage;

+ }

+

+ @Override

+ public void setLastFailureMessage(String lastFailureMessage) {

+ this.lastFailureMessage = lastFailureMessage;

+ }

+ }

+

+ private static final Logger logger = Logger.getLogger(ArchiveCandidateMonitoringBackgroundTask.class.getName());

+

+ private final static Duration DELAY_BETWEEN_CHECKS = Duration.ONE_MINUTE.times(5);

+ private final static Duration LONG_TIMEOUT = Duration.ONE_DAY.times(3);

+ private final static double MAXIMUM_ONE_MINUTE_SYSTEM_LOAD_AVERAGE = 2.0;

+ private final static int MAXIMUM_THREAD_POOL_QUEUE_SIZE = 10;

+ private final static Optional<Duration> TIMEOUT_FIRST_CONTACT = Optional.of(Landscape.WAIT_FOR_PROCESS_TIMEOUT.get().plus(Landscape.WAIT_FOR_HOST_TIMEOUT.get()));

+ private final static Duration SERVER_COMPARISON_TIMEOUT = Duration.ONE_MINUTE.times(10); // good for two or three attempts, usually

+ private final static Duration DELAY_BETWEEN_COMPARISON_CHECKS = Duration.ONE_MINUTE;

+

+ /**

+ * The user on whose behalf the monitoring is performed; this is used for sending notifications about the monitoring

+ * result to the user and for performing the monitoring with the same permissions as the user (e.g. when accessing

+ * the candidate's REST API)

+ */

+ private final User currentUser;

+ private final String candidateHostname;

+ private final LandscapeService landscapeService;

+ private final AwsApplicationReplicaSet<String, SailingAnalyticsMetrics, SailingAnalyticsProcess<String>> replicaSet;

+ private final URL continuationBaseURL;

+ private final ScheduledExecutorService executor;

+

+ /**

+ * A bearer token expected to authenticate the {@link #currentUser} against the candidate and production ARCHIVE

+ * servers

+ */

+ private final String effectiveBearerToken;

+

+ private Iterable<Check> checks;

+ private Iterator<Check> checksIterator;

+ private Check currentCheck;

+

+ public ArchiveCandidateMonitoringBackgroundTask(User currentUser, LandscapeService landscapeService,

+ AwsApplicationReplicaSet<String, SailingAnalyticsMetrics, SailingAnalyticsProcess<String>> replicaSet,

+ String candidateHostname,

+ ScheduledExecutorService executor,

+ String effectiveBearerToken, URL continuationBaseURL) {

+ this.currentUser = currentUser;

+ this.landscapeService = landscapeService;

+ this.continuationBaseURL = continuationBaseURL;

+ this.replicaSet = replicaSet;

+ this.candidateHostname = candidateHostname;

+ this.executor = executor;

+ this.effectiveBearerToken = effectiveBearerToken;

+ this.checks = Arrays.asList(

+ new IsAlive(),

+ new IsReady(),

+ new HasLowEnoughSystemLoad(),

+ new HasShortEnoughDefaultBackgroundThreadPoolExecutorQueue(),

+ new HasShortEnoughDefaultForegroundThreadPoolExecutorQueue(),

+ new CompareServersWithRestAPI());

+ this.checksIterator = this.checks.iterator();

+ this.currentCheck = checksIterator.next();

+ }

+

+ @Override

+ public void run() {

+ try {

+ if (currentCheck.runCheck()) {

+ logger.info("Check \""+currentCheck+"\" passed.");

+ // the check passed; proceed to next check, if any

+ currentCheck = checksIterator.hasNext() ? checksIterator.next() : null;

+ if (currentCheck != null) {

+ logger.info("More checks to do; re-scheduling to run next check \""+currentCheck+"\"");

+ // re-schedule this task to run next check immediately

+ executor.submit(this);

+ } else {

+ // all checks passed; candidate is ready for production; nothing more to do here

+ logger.info("Done with all checks; candidate is ready for production.");

+ notifyProcessOwnerCandidateIsReadyForSpotChecksAndRotation(); // this ends the re-scheduling loop

+ }

+ } else {

+ rescheduleCurrentCheckAfterFailureOrTimeout();

+ }

+ } catch (Exception e) {

+ logger.warning("Exception while running check \"" + currentCheck + "\" for candidate " + replicaSet.getMaster().getHost().getHostname() + ": " + e.getMessage());

+ currentCheck.setLastFailureMessage(e.getMessage());

+ try {

+ rescheduleCurrentCheckAfterFailureOrTimeout();

+ } catch (MailException e1) {

+ logger.severe("Issue while trying to send mail: "+e.getMessage()+"; user may not know what to do next!");

+ }

+ }

+ }