LOG.debug("Sending notification for id {} - state {}", monitorId, state);
EventData data = new EventDataBuilder().setMonitorId(monitorId)
.setMonitorState(state).build();
- MonitorEvent event = new MonitorEventBuilder().setEventData(data).build();;
- final ListenableFuture<? extends Object> eventFuture = notificationPublishService.offerNotification(event);
+ MonitorEvent event = new MonitorEventBuilder().setEventData(data).build();
+ final ListenableFuture<?> eventFuture = notificationPublishService.offerNotification(event);
Futures.addCallback(eventFuture, new FutureCallback<Object>() {
@Override
public void onFailure(Throwable error) {
import java.util.Map;
public interface PortNameMappingMBean {
- public Map<String,String> getPortIdtoPortNameMap();
- public String getPortName(String portId);
+ Map<String,String> getPortIdtoPortNameMap();
+ String getPortName(String portId);
}
\ No newline at end of file
import java.util.ArrayList;
public interface ControlPathFailureAlarmMBean {
- public void setRaiseAlarmObject(ArrayList<String> raiseAlarmObject);
- public ArrayList<String> getRaiseAlarmObject();
- public void setClearAlarmObject(ArrayList<String> clearAlarmObject);
- public ArrayList<String> getClearAlarmObject();
- public void raiseAlarm(String alarmName, String additionalText, String source);
- public void clearAlarm(String alarmName, String additionalText, String source);
+ void setRaiseAlarmObject(ArrayList<String> raiseAlarmObject);
+ ArrayList<String> getRaiseAlarmObject();
+ void setClearAlarmObject(ArrayList<String> clearAlarmObject);
+ ArrayList<String> getClearAlarmObject();
+ void raiseAlarm(String alarmName, String additionalText, String source);
+ void clearAlarm(String alarmName, String additionalText, String source);
}
//-----------
// operations
//-----------
- public void updateCounter(Map<String, String> map);
- public Map<String, String> retrieveCounterMap();
+ void updateCounter(Map<String, String> map);
+ Map<String, String> retrieveCounterMap();
}
//-----------
// operations
//-----------
- public void updateCounter(Map<String, String> map);
- public Map<String, String> retrieveCounterMap();
+ void updateCounter(Map<String, String> map);
+ Map<String, String> retrieveCounterMap();
}
//-----------
// operations
//-----------
- public void updateCounter(Map<String, String> map);
- public Map<String, String> retrieveCounterMap();
+ void updateCounter(Map<String, String> map);
+ Map<String, String> retrieveCounterMap();
}
* Source of the alarm ex: dpnId=openflow:1
* the source node that caused this alarm
*/
- public void raiseAlarm(String alarmName, String additionalText, String source);
+ void raiseAlarm(String alarmName, String additionalText, String source);
/**
* Clears the given alarm in platform environment
* Source of the alarm ex: dpnId=openflow:1
* the source node that caused this alarm
*/
- public void clearAlarm(String alarmName, String additionalText, String source);
+ void clearAlarm(String alarmName, String additionalText, String source);
}
\ No newline at end of file
import java.util.Map;
public interface PMServiceFacade {
- public void connectToPMFactory(Map map);
+ void connectToPMFactory(Map map);
}
public interface IdHolder {
Optional<Long> allocateId();
- public void addId(long id);
- public boolean isIdAvailable();
- public long getAvailableIdCount();
- public void refreshDataStore(IdPoolBuilder idPoolBuilder);
+ void addId(long id);
+ boolean isIdAvailable();
+ long getAvailableIdCount();
+ void refreshDataStore(IdPoolBuilder idPoolBuilder);
}
\ No newline at end of file
MPLS_OVER_GRE,
MPLS_OVER_UDP,
LOGICAL_GROUP_INTERFACE,
- UNKNOWN_INTERFACE;
+ UNKNOWN_INTERFACE
}
public enum InterfaceAdminState {
public interface IInterfaceManager {
@Deprecated
- public Long getPortForInterface(String ifName);
+ Long getPortForInterface(String ifName);
@Deprecated
- public BigInteger getDpnForInterface(String ifName);
+ BigInteger getDpnForInterface(String ifName);
@Deprecated
- public BigInteger getDpnForInterface(Interface intrf);
+ BigInteger getDpnForInterface(Interface intrf);
@Deprecated
- public String getEndpointIpForDpn(BigInteger dpnId);
+ String getEndpointIpForDpn(BigInteger dpnId);
@Deprecated
-
public List<ActionInfo> getInterfaceEgressActions(String ifName);
+ List<ActionInfo> getInterfaceEgressActions(String ifName);
@Deprecated
- public Long getPortForInterface(Interface intf);
+ Long getPortForInterface(Interface intf);
- public InterfaceInfo getInterfaceInfo(String intInfo);
+ InterfaceInfo getInterfaceInfo(String intInfo);
- public InterfaceInfo getInterfaceInfoFromOperationalDataStore(String interfaceName, InterfaceInfo.InterfaceType interfaceType);
- public InterfaceInfo getInterfaceInfoFromOperationalDataStore(String interfaceName);
+ InterfaceInfo getInterfaceInfoFromOperationalDataStore(String interfaceName,
+ InterfaceInfo.InterfaceType interfaceType);
+ InterfaceInfo getInterfaceInfoFromOperationalDataStore(String interfaceName);
- public Interface getInterfaceInfoFromConfigDataStore(String interfaceName);
+ Interface getInterfaceInfoFromConfigDataStore(String interfaceName);
- public void createVLANInterface(String interfaceName, String portName, BigInteger dpId, Integer vlanId,
- String description, IfL2vlan.L2vlanMode l2vlanMode) throws InterfaceAlreadyExistsException;
+ void createVLANInterface(String interfaceName, String portName, BigInteger dpId, Integer vlanId,
+ String description, IfL2vlan.L2vlanMode l2vlanMode) throws InterfaceAlreadyExistsException;
- public void createVLANInterface(String interfaceName, String portName, BigInteger dpId, Integer vlanId,
+ void createVLANInterface(String interfaceName, String portName, BigInteger dpId, Integer vlanId,
String description, IfL2vlan.L2vlanMode l2vlanMode, boolean isExternal) throws InterfaceAlreadyExistsException;
- public void bindService(String interfaceName, Class<? extends ServiceModeBase> serviceMode, BoundServices serviceInfo);
- public void unbindService(String interfaceName, Class<? extends ServiceModeBase> serviceMode, BoundServices serviceInfo);
+ void bindService(String interfaceName, Class<? extends ServiceModeBase> serviceMode, BoundServices serviceInfo);
+ void unbindService(String interfaceName, Class<? extends ServiceModeBase> serviceMode, BoundServices serviceInfo);
List<Interface> getVlanInterfaces();
List<Interface> getVxlanInterfaces();
- public boolean isExternalInterface(String interfaceName);
+ boolean isExternalInterface(String interfaceName);
}
\ No newline at end of file
profileBuilder.setProtocolType(protocolType);
buildGetProfile.setProfile(profileBuilder.build());
return (buildGetProfile.build());
- };
+ }
public static long allocateProfile(AlivenessMonitorService alivenessMonitor, long FAILURE_THRESHOLD, long MONITORING_INTERVAL,
long MONITORING_WINDOW, EtherTypes etherTypes) {
//-----------
// operations
//-----------
- public void setCounterDetails(Map<String, Integer> map);
- public Map<String, Integer> getCounterDetails();
+ void setCounterDetails(Map<String, Integer> map);
+ Map<String, Integer> getCounterDetails();
//-----------
// attributes
//-----------
- public void invokePMManagedObjects(Map<String, Integer> map);
- public Map<String, String> retrieveCounterMap();
+ void invokePMManagedObjects(Map<String, Integer> map);
+ Map<String, String> retrieveCounterMap();
}
//-----------
// operations
//-----------
- public void setCounterDetails(Map<String, Integer> map);
- public Map<String, Integer> getCounterDetails();
+ void setCounterDetails(Map<String, Integer> map);
+ Map<String, Integer> getCounterDetails();
//-----------
// attributes
//-----------
- public void invokePMManagedObjects(Map<String, Integer> map);
- public Map<String, String> retrieveCounterMap();
+ void invokePMManagedObjects(Map<String, Integer> map);
+ Map<String, String> retrieveCounterMap();
}
//-----------
// operations
//-----------
- public void setCounterDetails(Map<String, Integer> map);
- public Map<String, Integer> getCounterDetails();
+ void setCounterDetails(Map<String, Integer> map);
+ Map<String, Integer> getCounterDetails();
//-----------
// attributes
//-----------
- public void invokePMManagedObjects(Map<String, Integer> map);
- public Map<String, String> retrieveCounterMap();
+ void invokePMManagedObjects(Map<String, Integer> map);
+ Map<String, String> retrieveCounterMap();
}
//-----------
// operations
//-----------
- public void setCounterDetails(Map<String, Integer> map);
- public Map<String, Integer> getCounterDetails();
+ void setCounterDetails(Map<String, Integer> map);
+ Map<String, Integer> getCounterDetails();
//-----------
// attributes
//-----------
- public void invokePMManagedObjects(Map<String, Integer> map);
- public Map<String, String> retrieveCounterMap();
+ void invokePMManagedObjects(Map<String, Integer> map);
+ Map<String, String> retrieveCounterMap();
}
//-----------
// operations
//-----------
- public void setCounterDetails(Map<String, Integer> map);
- public Map<String, Integer> getCounterDetails();
+ void setCounterDetails(Map<String, Integer> map);
+ Map<String, Integer> getCounterDetails();
//-----------
// attributes
//-----------
- public void invokePMManagedObjects(Map<String, Integer> map);
- public Map<String, String> retrieveCounterMap();
+ void invokePMManagedObjects(Map<String, Integer> map);
+ Map<String, String> retrieveCounterMap();
}
//-----------
// operations
//-----------
- public void setCounterDetails(Map<String, Integer> map);
- public Map<String, Integer> getCounterDetails();
+ void setCounterDetails(Map<String, Integer> map);
+ Map<String, Integer> getCounterDetails();
//-----------
// attributes
//-----------
- public void invokePMManagedObjects(Map<String, Integer> map);
- public Map<String, String> retrieveCounterMap();
+ void invokePMManagedObjects(Map<String, Integer> map);
+ Map<String, String> retrieveCounterMap();
}
\ No newline at end of file
//-----------
// operations
//-----------
- public void setCounterDetails(Map<String, Integer> map);
- public Map<String, Integer> getCounterDetails();
+ void setCounterDetails(Map<String, Integer> map);
+ Map<String, Integer> getCounterDetails();
//-----------
// attributes
//-----------
- public void invokePMManagedObjects(Map<String, Integer> map);
- public Map<String, String> retrieveCounterMap();
+ void invokePMManagedObjects(Map<String, Integer> map);
+ Map<String, String> retrieveCounterMap();
}
//-----------
// operations
//-----------
- public void setCounterDetails(Map<String, Integer> map);
- public Map<String, Integer> getCounterDetails();
+ void setCounterDetails(Map<String, Integer> map);
+ Map<String, Integer> getCounterDetails();
//-----------
// attributes
//-----------
- public void invokePMManagedObjects(Map<String, Integer> map);
- public Map<String, String> retrieveCounterMap();
+ void invokePMManagedObjects(Map<String, Integer> map);
+ Map<String, String> retrieveCounterMap();
}
public static List<ListenableFuture<Void>> removePortFromBridge(InstanceIdentifier<OvsdbBridgeAugmentation> bridgeIid,
OvsdbBridgeAugmentation bridgeOld, DataBroker dataBroker) {
List<ListenableFuture<Void>> futures = new ArrayList<>();
- WriteTransaction transaction = dataBroker.newWriteOnlyTransaction();;
+ WriteTransaction transaction = dataBroker.newWriteOnlyTransaction();
BigInteger dpnId = IfmUtil.getDpnId(bridgeOld.getDatapathId());
if (dpnId == null) {
import java.util.List;
public interface FlowBasedServicesConfigAddable {
- public List<ListenableFuture<Void>> bindService(InstanceIdentifier<BoundServices> instanceIdentifier,
- BoundServices boundServiceNew);
+ List<ListenableFuture<Void>> bindService(InstanceIdentifier<BoundServices> instanceIdentifier,
+ BoundServices boundServiceNew);
}
import java.util.List;
public interface FlowBasedServicesConfigRemovable {
- public List<ListenableFuture<Void>> unbindService(InstanceIdentifier<BoundServices> instanceIdentifier,
- BoundServices boundServiceNew);
+ List<ListenableFuture<Void>> unbindService(InstanceIdentifier<BoundServices> instanceIdentifier,
+ BoundServices boundServiceNew);
}
import java.util.List;
public interface FlowBasedServicesStateAddable {
- public List<ListenableFuture<Void>> bindServicesOnInterface(Interface ifaceState);
+ List<ListenableFuture<Void>> bindServicesOnInterface(Interface ifaceState);
}
import java.util.List;
public interface FlowBasedServicesStateRemovable {
- public List<ListenableFuture<Void>> unbindServicesFromInterface(Interface ifaceState);
+ List<ListenableFuture<Void>> unbindServicesFromInterface(Interface ifaceState);
}
public enum ServiceMode {
INGRESS,
- EGRESS;
+ EGRESS
}
public static final ImmutableBiMap SERVICE_MODE_MAP =
public interface InterfaceStatusMonitorMBean {
- public String acquireServiceStatus();
+ String acquireServiceStatus();
}
public interface IITMProvider {
// APIs used by i
- public void createLocalCache(BigInteger dpnId, String portName, Integer vlanId, String ipAddress, String subnetMask, String gatewayIp, String transportZone, CommandSession session);
+ void createLocalCache(BigInteger dpnId, String portName, Integer vlanId, String ipAddress, String subnetMask,
+ String gatewayIp, String transportZone, CommandSession session);
- public void commitTeps();
+ void commitTeps();
- public DataBroker getDataBroker();
+ DataBroker getDataBroker();
- public void showTeps(CommandSession session);
+ void showTeps(CommandSession session);
- public void showState(List<StateTunnelList> tunnels, CommandSession session);
+ void showState(List<StateTunnelList> tunnels, CommandSession session);
- public void showCache(String cacheName);
+ void showCache(String cacheName);
- public void deleteVtep(BigInteger dpnId, String portName, Integer vlanId, String ipAddress, String subnetMask,
- String gatewayIp, String transportZone, CommandSession session);
+ void deleteVtep(BigInteger dpnId, String portName, Integer vlanId, String ipAddress, String subnetMask,
+ String gatewayIp, String transportZone, CommandSession session);
// public void showState(TunnelsState tunnelsState);
- public void configureTunnelType(String transportZone, String tunnelType);
+ void configureTunnelType(String transportZone, String tunnelType);
/**
* @param vtepConfigSchema
* the vtep config schema
*/
- public void addVtepConfigSchema(VtepConfigSchema vtepConfigSchema);
+ void addVtepConfigSchema(VtepConfigSchema vtepConfigSchema);
/**
* Gets the vtep config schema.
* the schema name
* @return the vtep config schema
*/
- public VtepConfigSchema getVtepConfigSchema(String schemaName);
+ VtepConfigSchema getVtepConfigSchema(String schemaName);
/**
* Gets the all vtep config schemas.
*
* @return the all vtep config schemas
*/
- public List<VtepConfigSchema> getAllVtepConfigSchemas();
+ List<VtepConfigSchema> getAllVtepConfigSchemas();
/**
* Update VTEP schema.
* @param lstDpnsForDelete
* the lst dpns for delete
*/
- public void updateVtepSchema(String schemaName, List<BigInteger> lstDpnsForAdd, List<BigInteger> lstDpnsForDelete);
+ void updateVtepSchema(String schemaName, List<BigInteger> lstDpnsForAdd, List<BigInteger> lstDpnsForDelete);
/**
* Delete all vtep schemas.
*/
- public void deleteAllVtepSchemas();
+ void deleteAllVtepSchemas();
- public void configureTunnelMonitorParams(boolean monitorEnabled, String monitorProtocol);
+ void configureTunnelMonitorParams(boolean monitorEnabled, String monitorProtocol);
- public void configureTunnelMonitorInterval(int interval);
+ void configureTunnelMonitorInterval(int interval);
- public void addExternalEndpoint(java.lang.Class<? extends TunnelTypeBase> tunType, IpAddress dcgwIP);
+ void addExternalEndpoint(java.lang.Class<? extends TunnelTypeBase> tunType, IpAddress dcgwIP);
- public void remExternalEndpoint(java.lang.Class<? extends TunnelTypeBase> tunType, IpAddress dcgwIP);
+ void remExternalEndpoint(java.lang.Class<? extends TunnelTypeBase> tunType, IpAddress dcgwIP);
- public boolean validateIP (final String ip);
+ boolean validateIP(final String ip);
}
logger.error("Error in Datastore operation", error);
}
- ;
};
public static List<ListenableFuture<Void>> buildTunnelsToExternalEndPoint(DataBroker dataBroker, IdManagerService idManagerService,
public void onFailure(Throwable error) {
logger.error("Error in Datastore operation", error);
- };
- };
+ }
+ };
public static List<ListenableFuture<Void>> build_all_tunnels(DataBroker dataBroker, IdManagerService idManagerService,IMdsalApiManager mdsalManager,
import java.util.ArrayList;
public interface DataPathAlarmMBean {
- public void setRaiseAlarmObject(ArrayList<String> raiseAlarmObject);
- public ArrayList<String> getRaiseAlarmObject();
- public void setClearAlarmObject(ArrayList<String> clearAlarmObject);
- public ArrayList<String> getClearAlarmObject();
- public void raiseAlarm(String alarmName, String additionalText, String source);
- public void clearAlarm(String alarmName, String additionalText, String source);
+ void setRaiseAlarmObject(ArrayList<String> raiseAlarmObject);
+ ArrayList<String> getRaiseAlarmObject();
+ void setClearAlarmObject(ArrayList<String> clearAlarmObject);
+ ArrayList<String> getClearAlarmObject();
+ void raiseAlarm(String alarmName, String additionalText, String source);
+ void clearAlarm(String alarmName, String additionalText, String source);
}
public interface ITMStatusMonitorMBean {
- public String acquireServiceStatus();
+ String acquireServiceStatus();
}
import org.opendaylight.yang.gen.v1.urn.opendaylight.genius.itm.rev160406.transport.zones.TransportZone;
public interface TransportZoneValidator {
- public ValidatorErrorCode validate(TransportZone zone);
+ ValidatorErrorCode validate(TransportZone zone);
}
return message;
}
- private ValidatorErrorCode(int val, String msg) {
+ ValidatorErrorCode(int val, String msg) {
this.value = val;
this.message = msg;
}
public class MDSALUtil {
- public enum MdsalOp { CREATION_OP, UPDATE_OP, REMOVAL_OP };
+ public enum MdsalOp { CREATION_OP, UPDATE_OP, REMOVAL_OP }
public static final String NODE_PREFIX = "openflow";
public static final int GROUP_WEIGHT = 0;
*
* @param mapMatchBuilder the map which holds the matches.
*/
- public void createInnerMatchBuilder(Map<Class<?>, Object> mapMatchBuilder);
+ void createInnerMatchBuilder(Map<Class<?>, Object> mapMatchBuilder);
/**
* Set the match to the match builder.
* @param matchBuilder the matchbuilder to set the match
* @param mapMatchBuilder the map containing the matches
*/
- public void setMatch(MatchBuilder matchBuilder, Map<Class<?>, Object> mapMatchBuilder);
+ void setMatch(MatchBuilder matchBuilder, Map<Class<?>, Object> mapMatchBuilder);
}
}
public enum LearnFlowModsType {
- MATCH_FROM_FIELD, MATCH_FROM_VALUE, COPY_FROM_FIELD, COPY_FROM_VALUE, OUTPUT_TO_PORT;
+ MATCH_FROM_FIELD, MATCH_FROM_VALUE, COPY_FROM_FIELD, COPY_FROM_VALUE, OUTPUT_TO_PORT
}
}
public interface IMdsalApiManager {
- public void installFlow(FlowEntity flowEntity);
+ void installFlow(FlowEntity flowEntity);
/**
* Add a Flow to batched transaction.
* @param tx
* batched transaction
*/
- public void addFlowToTx(FlowEntity flowEntity, WriteTransaction tx);
+ void addFlowToTx(FlowEntity flowEntity, WriteTransaction tx);
- public CheckedFuture<Void,TransactionCommitFailedException> installFlow(BigInteger dpId, Flow flowEntity);
+ CheckedFuture<Void,TransactionCommitFailedException> installFlow(BigInteger dpId, Flow flowEntity);
/**
* Add a Flow to batched transaction
* @param tx
* batched transaction
*/
- public void addFlowToTx(BigInteger dpId, Flow flow, WriteTransaction tx);
+ void addFlowToTx(BigInteger dpId, Flow flow, WriteTransaction tx);
- public CheckedFuture<Void,TransactionCommitFailedException> removeFlow(BigInteger dpId, Flow flowEntity);
+ CheckedFuture<Void,TransactionCommitFailedException> removeFlow(BigInteger dpId, Flow flowEntity);
- public CheckedFuture<Void,TransactionCommitFailedException> removeFlow(BigInteger dpId, FlowEntity flowEntity);
+ CheckedFuture<Void,TransactionCommitFailedException> removeFlow(BigInteger dpId, FlowEntity flowEntity);
/**
* Remove a Flow using batched transaction.
* @param tx
* batched transaction
*/
- public void removeFlowToTx(BigInteger dpId, Flow flow, WriteTransaction tx);
+ void removeFlowToTx(BigInteger dpId, Flow flow, WriteTransaction tx);
- public CheckedFuture<Void,TransactionCommitFailedException> installFlow(BigInteger dpId, FlowEntity flowEntity);
+ CheckedFuture<Void,TransactionCommitFailedException> installFlow(BigInteger dpId, FlowEntity flowEntity);
- public void removeFlow(FlowEntity flowEntity);
+ void removeFlow(FlowEntity flowEntity);
/**
* Remove a Flow using batched transaction.
* @param tx
* batched transaction
*/
- public void removeFlowToTx(FlowEntity flowEntity, WriteTransaction tx);
+ void removeFlowToTx(FlowEntity flowEntity, WriteTransaction tx);
- public void installGroup(GroupEntity groupEntity);
+ void installGroup(GroupEntity groupEntity);
/**
* Add a Group using batched transaction
* @param tx
* batched transaction
*/
- public void addGroupToTx(GroupEntity groupEntity, WriteTransaction tx);
+ void addGroupToTx(GroupEntity groupEntity, WriteTransaction tx);
/**
* Add a Group using batched transaction
* @param tx
* batched transaction
*/
- public void addGroupToTx(BigInteger dpId, Group group, WriteTransaction tx);
+ void addGroupToTx(BigInteger dpId, Group group, WriteTransaction tx);
- public void modifyGroup(GroupEntity groupEntity);
+ void modifyGroup(GroupEntity groupEntity);
- public void removeGroup(GroupEntity groupEntity);
+ void removeGroup(GroupEntity groupEntity);
/**
* Remove a Group using batched transaction
* @param tx
* batched transaction
*/
- public void removeGroupToTx(GroupEntity groupEntity, WriteTransaction tx);
+ void removeGroupToTx(GroupEntity groupEntity, WriteTransaction tx);
/**
* Remove a Group using batched transaction
* @param tx
* batched transaction
*/
- public void removeGroupToTx(BigInteger dpId, Group group, WriteTransaction tx);
+ void removeGroupToTx(BigInteger dpId, Group group, WriteTransaction tx);
- public void sendPacketOut(BigInteger dpnId, int groupId, byte[] payload);
+ void sendPacketOut(BigInteger dpnId, int groupId, byte[] payload);
-
public void sendPacketOutWithActions(BigInteger dpnId, long groupId, byte[] payload, List<ActionInfo> actionInfos);
+ void sendPacketOutWithActions(BigInteger dpnId, long groupId, byte[] payload, List<ActionInfo> actionInfos);
-
public void sendARPPacketOutWithActions(BigInteger dpnId, byte[] payload, List<ActionInfo> action_info);
+ void sendARPPacketOutWithActions(BigInteger dpnId, byte[] payload, List<ActionInfo> action_info);
/**
* API to remove the flow on Data Plane Node synchronously. It internally waits for
* @param flowEntity
* @param delayTime
*/
- public void syncRemoveFlow(FlowEntity flowEntity, long delayTime);
- public void syncInstallFlow(FlowEntity flowEntity, long delayTime);
+ void syncRemoveFlow(FlowEntity flowEntity, long delayTime);
+ void syncInstallFlow(FlowEntity flowEntity, long delayTime);
/**
* API to install the Group on Data Plane Node synchronously. It internally waits for
* @param groupEntity
* @param delayTime
*/
- public void syncInstallGroup(GroupEntity groupEntity, long delayTime);
+ void syncInstallGroup(GroupEntity groupEntity, long delayTime);
- public void syncInstallGroup(BigInteger dpId, Group group, long delayTime);
+ void syncInstallGroup(BigInteger dpId, Group group, long delayTime);
/**
* API to remove the Group on Data Plane Node synchronously. It internally waits for
*
* @param groupEntity
*/
- public void syncRemoveGroup(GroupEntity groupEntity);
+ void syncRemoveGroup(GroupEntity groupEntity);
- public void syncRemoveGroup(BigInteger dpId, Group groupEntity);
+ void syncRemoveGroup(BigInteger dpId, Group groupEntity);
}
private String protocolName;
private int protocolNumber;
- private IPProtocols(String name, int number) {
+ IPProtocols(String name, int number) {
protocolName = name;
protocolNumber = number;
}
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
public interface ActionableResource {
- static final short CREATE = 1;
- static final short UPDATE = 2;
- static final short DELETE = 3;
+ short CREATE = 1;
+ short UPDATE = 2;
+ short DELETE = 3;
InstanceIdentifier getInstanceIdentifier();
void setInstanceIdentifier(InstanceIdentifier identifier);
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
public interface SubTransaction {
- static final short CREATE = 1;
- static final short UPDATE = 2;
- static final short DELETE = 3;
+ short CREATE = 1;
+ short UPDATE = 2;
+ short DELETE = 3;
InstanceIdentifier getInstanceIdentifier();
void setInstanceIdentifier(InstanceIdentifier identifier);
return nodeId != null ? nodeId.hashCode() : 0;
}
- static enum NodeStatus {
- Connected,Disconnected;
+ enum NodeStatus {
+ Connected,Disconnected
}
public static class NodeConnectedEvent extends NodeEvent {
@Override
public void addGroupToTx(BigInteger dpId, Group group, WriteTransaction tx) {
- mdSalMgr.writeGroup(dpId, group, tx);;
+ mdSalMgr.writeGroup(dpId, group, tx);
}
@Override
Code Review / genius.git / commitdiff