import java.util.concurrent.atomic.AtomicLong;
import javax.annotation.Nonnull;
import javax.annotation.Nullable;
-
import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService;
import org.opendaylight.openflowplugin.api.openflow.OFPManager;
import org.opendaylight.openflowplugin.api.openflow.connection.ConnectionContext;
notificationPublishService,
new AtomicLong());
}
+
+ // Fill flow registry with flows found in operational and config datastore
+ deviceContext.getDeviceFlowRegistry().fill(deviceInfo.getNodeInstanceIdentifier());
} else {
logText = "Stopp";
statisticsManager.stopScheduling(deviceInfo);
@Override
public void onFailure(final Throwable throwable) {
- LOG.warn("ing services for node {} was NOT successful, closing connection", logText, deviceInfo);
+ LOG.warn("{}ing services for node {} was NOT successful, closing connection", logText, deviceInfo);
closeConnection(deviceInfo);
}
});