DiscoveryNode.java

Go to the documentation of this file.

package org.openkilda.messaging.model;

import com.fasterxml.jackson.annotation.JsonCreator;
import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
import com.fasterxml.jackson.annotation.JsonInclude;
import com.fasterxml.jackson.annotation.JsonProperty;
import com.fasterxml.jackson.databind.annotation.JsonSerialize;

import java.io.Serializable;
import java.util.Objects;

@JsonSerialize
@JsonIgnoreProperties(ignoreUnknown = true)
@JsonInclude(JsonInclude.Include.NON_NULL)
public class DiscoveryNode implements Serializable {

    public final static int FORLORN_NEVER = -1;

    @JsonProperty("switch_id")
    private final String switchId;

    @JsonProperty("port_id")
    private final String portId;

    @JsonProperty("attempts")
    private int attempts;

    @JsonProperty("time_counter")
    private int timeCounter;

    @JsonProperty("check_interval")
    private int checkInterval;

    @JsonProperty("consecutive_failure")
    private int consecutiveFailure;

    @JsonProperty("consecutive_success")
    private int consecutiveSuccess;

    @JsonProperty("forlorn_threshold")
    private int forlornThreshold;
    @JsonProperty("found_isl")
    private boolean foundIsl;

    public DiscoveryNode(String switchId, String portId, int checkInterval, int forlornThreshold) {
        this.switchId = switchId;
        this.portId = portId;
        this.timeCounter = 0;
        this.checkInterval = checkInterval;
        this.forlornThreshold = forlornThreshold;
        this.consecutiveFailure = 0;
        this.consecutiveSuccess = 0;
        this.foundIsl = false;
    }

    @JsonCreator
    public DiscoveryNode(@JsonProperty("switch_id") final String switchId,
            @JsonProperty("port_id") final String portId,
            @JsonProperty("attempts") final int attempts,
            @JsonProperty("time_counter") final int timeCounter,
            @JsonProperty("check_interval") final int checkInterval,
            @JsonProperty("consecutive_failure") final int consecutiveFailure,
            @JsonProperty("consecutive_success") final int consecutiveSuccess,
            @JsonProperty("forlorn_threshold") final int forlornThreshold,
            @JsonProperty("found_isl") final boolean foundIsl) {

        this.switchId = switchId;
        this.portId = portId;
        this.attempts = attempts;
        this.timeCounter = timeCounter;
        this.checkInterval = checkInterval;
        this.forlornThreshold = forlornThreshold;
        this.consecutiveFailure = consecutiveFailure;
        this.consecutiveSuccess = consecutiveSuccess;
        this.foundIsl = foundIsl;
    }


    public void setFoundIsl(boolean foundIsl){
        this.foundIsl = foundIsl;
    }

    public boolean isFoundIsl(){
        return this.foundIsl;
    }

    public void renew() {
        attempts = 0;
        timeCounter = 0;
    }

    public boolean forlorn() {
        if (forlornThreshold == FORLORN_NEVER) { // never gonna give a link up.
             return false;
        }
        return consecutiveFailure > forlornThreshold;
    }

    public void clearConsecutiveFailure() {
        consecutiveFailure = 0;
    }

    public void clearConsecutiveSuccess() {
        consecutiveSuccess = 0;
    }

    public int getConsecutiveFailure(){
        return this.consecutiveFailure;
    }

    public int getConsecutiveSuccess(){
        return this.consecutiveSuccess;
    }

    public void incConsecutiveFailure() {
        consecutiveFailure++;
    }

    public void incConsecutiveSuccess() {
        consecutiveSuccess++;
    }

    public int getTicks() {
        return timeCounter;
    }

    public void incTick() {
        timeCounter++;
    }

    public void resetTickCounter() {
        timeCounter = 0;
    }

    public boolean maxAttempts(Integer attemptLimit) {
        return (attemptLimit < attempts);
    }

    public void incAttempts() {
        attempts++;
    }

    public int getAttempts() {
        return attempts;
    }

    public boolean timeToCheck() {
        return timeCounter >= checkInterval;
    }

    public String getSwitchId() {
        return switchId;
    }

    public String getPortId() {
        return portId;
    }

    @Override
    public boolean equals(Object o) {
        if (this == o) {
            return true;
        }
        if (!(o instanceof DiscoveryNode)) {
            return false;
        }
        DiscoveryNode that = (DiscoveryNode) o;
        return Objects.equals(getSwitchId(), that.getSwitchId()) &&
                Objects.equals(getPortId(), that.getPortId());
    }

    @Override
    public int hashCode() {
        return Objects.hash(getSwitchId(), getPortId());
    }

    @Override
    public String toString() {
        return "DiscoveryNode{" +
                "switchId='" + switchId + '\'' +
                ", portId='" + portId + '\'' +
                ", attempts=" + attempts +
                ", consecutiveFailure=" + consecutiveFailure +
                ", consecutiveSuccess=" + consecutiveSuccess +
                '}';
    }
}