src-java/flowmonitoring-topology/flowmonitoring-storm-topology/src/main/java/org/openkilda/wfm/topology/flowmonitoring/service/IslCacheService.java
/**
     * Update ISL cache according to Isl changed info.
     */
Update ISL cache according to Isl changed info.
Update ISL cache according to Isl changed info .
public void handleIslChangedData(IslChangedInfoData data) {
        cleanUpLinkStatesByEndpoint(data.getSource().getDatapath(), data.getSource().getPortNumber());
        if (data.getDestination() != null) {
            cleanUpLinkStatesByEndpoint(data.getDestination().getDatapath(), data.getDestination().getPortNumber());
            linkStates.put(Link.builder()
                            .srcSwitchId(data.getSource().getDatapath())
                            .srcPort(data.getSource().getPortNumber())
                            .destSwitchId(data.getDestination().getDatapath())
                            .destPort(data.getDestination().getPortNumber())
                            .build(),
                    LinkState.builder().build());
        }
    }
public void handleIslChangedData ( IslChangedInfoData data ) { cleanUpLinkStatesByEndpoint ( data . getSource ( ) . getDatapath ( ) , data . getSource ( ) . getPortNumber ( ) ) ; if ( data . getDestination ( ) != null ) { cleanUpLinkStatesByEndpoint ( data . getDestination ( ) . getDatapath ( ) , data . getDestination ( ) . getPortNumber ( ) ) ; linkStates . put ( Link . builder ( ) . srcSwitchId ( data . getSource ( ) . getDatapath ( ) ) . srcPort ( data . getSource ( ) . getPortNumber ( ) ) . destSwitchId ( data . getDestination ( ) . getDatapath ( ) ) . destPort ( data . getDestination ( ) . getPortNumber ( ) ) . build ( ) , LinkState . builder ( ) . build ( ) ) ; } }
Update ISL cache according to Isl changed info.
Update ISL cache according to Isl changed info .
// Handle moved ISL