NealSun96 commented on a change in pull request #1413:
URL: https://github.com/apache/helix/pull/1413#discussion_r499050485
##########
File path:
helix-core/src/main/java/org/apache/helix/controller/dataproviders/BaseControllerDataProvider.java
##########
@@ -728,6 +782,100 @@ private void updateDisabledInstances() {
}
}
+ /*
+ * Check if the instance is timed-out during maintenance mode. An instance
is timed-out if it has
+ * been offline for longer than the user defined timeout window.
+ * @param timeOutWindow - the timeout window; guaranteed to be non-negative
+ */
+ private boolean isInstanceTimedOutDuringMaintenance(HelixDataAccessor
accessor, String instance,
+ long timeOutWindow) {
+ ParticipantHistory history =
+
accessor.getProperty(accessor.keyBuilder().participantHistory(instance));
+ long currentTime = System.currentTimeMillis();
+
+ // Parse online timestamps from online list
+ List<Long> onlineTimestamps = new ArrayList<>();
+ List<String> historyOnlineList = history.getHistory();
+ if (historyOnlineList != null) {
+ long tailOnlineTime;
+ for (int i = historyOnlineList.size() - 1; i >= 0; i--) {
+ tailOnlineTime =
+
ParticipantHistory.extractTimeFromSessionHistoryString(historyOnlineList.get(i));
+ // Ignore bad format case
+ if (tailOnlineTime != -1) {
+ onlineTimestamps.add(0, tailOnlineTime);
+ // We only need one online timestamp before maintenance mode starts
+ if (tailOnlineTime <= _maintenanceSignal.getTimestamp()) {
+ break;
+ }
+ }
+ }
+ }
+ if (onlineTimestamps.isEmpty() || onlineTimestamps.get(0) >
_maintenanceSignal.getTimestamp()) {
+ // Node is a new node in this maintenance mode, no need to time out
since no partitions are
+ // assigned to it
+ return false;
+ }
+
+ // Parse offline timestamps from offline list
+ List<Long> offlineTimestamps = new ArrayList<>();
+ List<String> historyOfflineList = history.getOffline();
+ if (historyOfflineList != null) {
+ long tailOfflineTime;
+ for (int i = historyOfflineList.size() - 1; i >= 0; i--) {
+ tailOfflineTime =
+
ParticipantHistory.parseHistoryDateStringToLong(historyOfflineList.get(i));
+ // Ignore bad format case
+ if (tailOfflineTime != -1) {
+ if (tailOfflineTime <= onlineTimestamps.get(0)) {
+ break;
+ }
+ offlineTimestamps.add(0, tailOfflineTime);
+ }
+ }
+ }
+
+ // At this point, onlineTimestamps contains at least 1 timestamp that's
before maintenance mode;
+ // offlineTimestamps contains 0+ timestamp that's > the first online
timestamp.
+ if (!offlineTimestamps.isEmpty()
+ && offlineTimestamps.get(offlineTimestamps.size() - 1) >
onlineTimestamps
+ .get(onlineTimestamps.size() - 1)) {
+ // Make sure for each offline timestamp, 2 online timestamps creates a
range around it;
+ // this is usually true unless the timestamps are malformed (missing
online timestamps)
+ onlineTimestamps.add(currentTime);
+ }
+
+ // Hop between each pair of online timestamps and find the maximum offline
window
+ for (int onlineTimestampIndex = 1, offlineTimestampIndex = 0;
+ onlineTimestampIndex < onlineTimestamps.size() &&
offlineTimestampIndex < offlineTimestamps
+ .size(); onlineTimestampIndex++) {
+ long onlineTimestamp = onlineTimestamps.get(onlineTimestampIndex);
+ long offlineTimeStamp = offlineTimestamps.get(offlineTimestampIndex);
+
+ // If the offline timestamp isn't within this pair of online timestamp,
continue
+ if (offlineTimeStamp > onlineTimestamp) {
+ continue;
+ }
+
+ // Check the largest offline window against the timeout window
+ if (onlineTimestamp - offlineTimeStamp > timeOutWindow) {
Review comment:
The first offline time is always after the first online time based on my
parsing logic, see above.
Therefore we always start checking by the second online time, and do (second
online time - first offline time), for example.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
