X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflowplugin-api%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fapi%2Fopenflow%2Fdevice%2FDeviceManager.java;h=64cfd864d1aca65c72602fcad1126714aea96e10;hb=f1cc4de7dee9e22c231a90cf517b03bc5071ad35;hp=55f68da8b7efe3689563127cd383cae4a10ff3a8;hpb=5225848e57f10d051355f649df8d1ae4ec0c068c;p=openflowplugin.git diff --git a/openflowplugin-api/src/main/java/org/opendaylight/openflowplugin/api/openflow/device/DeviceManager.java b/openflowplugin-api/src/main/java/org/opendaylight/openflowplugin/api/openflow/device/DeviceManager.java index 55f68da8b7..64cfd864d1 100644 --- a/openflowplugin-api/src/main/java/org/opendaylight/openflowplugin/api/openflow/device/DeviceManager.java +++ b/openflowplugin-api/src/main/java/org/opendaylight/openflowplugin/api/openflow/device/DeviceManager.java @@ -1,5 +1,5 @@ /* - * Copyright (c) 2015 Cisco Systems, Inc. and others. All rights reserved. + * Copyright (c) 2015, 2017 Cisco Systems, Inc. and others. All rights reserved. * * This program and the accompanying materials are made available under the * terms of the Eclipse Public License v1.0 which accompanies this distribution, @@ -8,69 +8,56 @@ package org.opendaylight.openflowplugin.api.openflow.device; -import com.google.common.util.concurrent.ListenableFuture; +import com.google.common.util.concurrent.CheckedFuture; +import javax.annotation.Nonnull; +import org.opendaylight.controller.md.sal.common.api.data.TransactionCommitFailedException; import org.opendaylight.openflowplugin.api.openflow.OFPManager; -import org.opendaylight.openflowplugin.api.openflow.device.handlers.DeviceConnectedHandler; -import org.opendaylight.openflowplugin.api.openflow.device.handlers.DeviceDisconnectedHandler; -import org.opendaylight.openflowplugin.api.openflow.device.handlers.DeviceInitializationPhaseHandler; -import org.opendaylight.openflowplugin.api.openflow.device.handlers.DeviceLifecycleSupervisor; -import org.opendaylight.openflowplugin.api.openflow.device.handlers.DeviceTerminationPhaseHandler; +import org.opendaylight.openflowplugin.api.openflow.connection.ConnectionContext; import org.opendaylight.openflowplugin.api.openflow.translator.TranslatorLibrarian; -import org.opendaylight.yang.gen.v1.urn.opendaylight.role.service.rev150727.OfpRole; +import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node; +import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey; +import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier; /** * This interface is responsible for instantiating DeviceContext and * registering transaction chain for each DeviceContext. Each device * has its own device context managed by this manager. */ -public interface DeviceManager extends DeviceConnectedHandler, DeviceDisconnectedHandler, DeviceLifecycleSupervisor, - DeviceInitializationPhaseHandler, DeviceTerminationPhaseHandler, TranslatorLibrarian, AutoCloseable, OFPManager { - +public interface DeviceManager extends + OFPManager, + TranslatorLibrarian { /** - * invoked after all services injected + * invoked after all services injected. */ void initialize(); - /** - * Method has to activate (MASTER) or deactivate (SLAVE) TransactionChainManager. - * TransactionChainManager represents possibility to write or delete Node subtree data - * for actual Controller Cluster Node. We are able to have an active TxManager only if - * newRole is {@link OfpRole#BECOMESLAVE}. - * Parameters are used as marker to be sure it is change to SLAVE from MASTER or from - * MASTER to SLAVE and the last parameter "cleanDataStore" is used for validation only. - * - * @param deviceInfo which device - * @param role - NewRole expect to be {@link OfpRole#BECOMESLAVE} or {@link OfpRole#BECOMEMASTER} - * @return RoleChangeTxChainManager future for activation/deactivation - */ - ListenableFuture onClusterRoleChange(final DeviceInfo deviceInfo, final OfpRole role); + void setFlowRemovedNotificationOn(boolean value); - /** - * Register device synchronize listeners - * @param deviceSynchronizeListener are notified if device is synchronized or not - */ - void addDeviceSynchronizeListener(final DeviceSynchronizeListener deviceSynchronizeListener); + boolean isFlowRemovedNotificationOn(); - /** - * Notify all registered listeners about synchronized status - * @param deviceInfo which device - * @param deviceSynchronized true if device is synchronized - */ - void notifyDeviceSynchronizeListeners(final DeviceInfo deviceInfo, final boolean deviceSynchronized); + void setGlobalNotificationQuota(long globalNotificationQuota); - /** - * Register device valid listeners - * @param deviceValidListener are notified if device is valid or not - */ - void addDeviceValidListener(final DeviceValidListener deviceValidListener); + void setSwitchFeaturesMandatory(boolean switchFeaturesMandatory); - /** - * Notify all registered listeners about valid status - * @param deviceInfo which device - * @param deviceValid true if device is valid - */ - void notifyDeviceValidListeners(final DeviceInfo deviceInfo, final boolean deviceValid); + void setSkipTableFeatures(boolean skipTableFeatures); + + void setBarrierCountLimit(int barrierCountLimit); + + void setBarrierInterval(long barrierTimeoutLimit); + + CheckedFuture removeDeviceFromOperationalDS(DeviceInfo deviceInfo); + + CheckedFuture removeDeviceFromOperationalDS(final KeyedInstanceIdentifier ii); + + void setUseSingleLayerSerialization(Boolean useSingleLayerSerialization); + + DeviceContext createContext(@Nonnull final ConnectionContext connectionContext); + + long getBarrierIntervalNanos(); + + int getBarrierCountLimit(); + void sendNodeAddedNotification(@Nonnull final DeviceInfo deviceInfo); }