src-java/flowmonitoring-topology/flowmonitoring-storm-topology/src/main/java/org/openkilda/wfm/topology/flowmonitoring/service/ActionService.java
/**
     * Check flow SLA is violated.
     */
Check flow SLA is violated.
Check flow SLA is violated .
public void checkFlowSla(String flowId, FlowDirection direction, long latency,
                             Long maxLatency, Long maxLatencyTier2) {
        if (maxLatency != null && maxLatency > 0 && latency > maxLatency) {
            long latencyMs = TimeUnit.NANOSECONDS.toMillis(latency);
            long maxLatencyMs = TimeUnit.NANOSECONDS.toMillis(maxLatency);
            log.warn("{} path for flow '{}' violates latency SLA {}/{} ms",
                    direction.name(), flowId, latencyMs, maxLatencyMs);
        }
    }
public void checkFlowSla ( String flowId , FlowDirection direction , long latency , Long maxLatency , Long maxLatencyTier2 ) { if ( maxLatency != null && maxLatency > 0 && latency > maxLatency ) { long latencyMs = TimeUnit . NANOSECONDS . toMillis ( latency ) ; long maxLatencyMs = TimeUnit . NANOSECONDS . toMillis ( maxLatency ) ; log . warn ( "{} path for flow '{}' violates latency SLA {}/{} ms" , direction . name ( ) , flowId , latencyMs , maxLatencyMs ) ; } }
Check flow SLA is violated.
Check flow SLA is violated .
//TODO add flow SLA violation reactions