* are done by the ComponentActivatorAbstractBase.
*
*/
+ @Override
public void init() {
}
* ComponentActivatorAbstractBase
*
*/
+ @Override
public void destroy() {
}
* instantiated in order to get an fully working implementation
* Object
*/
+ @Override
public Object[] getImplementations() {
Object[] res = { TopologyServices.class, DataPacketServices.class,
InventoryService.class, ReadService.class,
* per-container different behavior if needed, usually should not
* be the case though.
*/
+ @Override
public void configureInstance(Component c, Object imp, String containerName) {
if (imp.equals(TopologyServices.class)) {
// export the service to be used by SAL
.setService(IPluginOutConnectionService.class)
.setCallbacks("setIPluginOutConnectionService",
"unsetIPluginOutConnectionService")
- .setRequired(false));
+ .setRequired(true));
}
if (imp.equals(ReadService.class)) {
.setService(IPluginOutConnectionService.class)
.setCallbacks("setIPluginOutConnectionService",
"unsetIPluginOutConnectionService")
- .setRequired(false));
+ .setRequired(true));
}
if (imp.equals(FlowProgrammerNotifier.class)) {
.setService(IPluginOutConnectionService.class)
.setCallbacks("setIPluginOutConnectionService",
"unsetIPluginOutConnectionService")
- .setRequired(false));
+ .setRequired(true));
}
}
* instantiated in order to get an fully working implementation
* Object
*/
+ @Override
public Object[] getGlobalImplementations() {
Object[] res = { Controller.class, OFStatisticsManager.class,
FlowProgrammerService.class, ReadServiceFilter.class,
* Implementation class that is being configured, needed as long
* as the same routine can configure multiple implementations
*/
+ @Override
public void configureGlobalInstance(Component c, Object imp) {
if (imp.equals(Controller.class)) {
.setService(IPluginOutConnectionService.class)
.setCallbacks("setIPluginOutConnectionService",
"unsetIPluginOutConnectionService")
- .setRequired(false));
+ .setRequired(true));
}
if (imp.equals(ReadServiceFilter.class)) {
.setService(IPluginOutConnectionService.class)
.setCallbacks("setIPluginOutConnectionService",
"unsetIPluginOutConnectionService")
- .setRequired(false));
+ .setRequired(true));
}
// DataPacket mux/demux services, which is teh actual engine
.setService(IPluginOutConnectionService.class)
.setCallbacks("setIPluginOutConnectionService",
"unsetIPluginOutConnectionService")
- .setRequired(false));
+ .setRequired(true));
}
if (imp.equals(InventoryService.class)) {
.setService(IPluginOutInventoryService.class, "(scope=Global)")
.setCallbacks("setPluginOutInventoryServices",
"unsetPluginOutInventoryServices")
- .setRequired(false));
+ .setRequired(true));
}
if (imp.equals(InventoryServiceShim.class)) {
.setService(IPluginOutConnectionService.class)
.setCallbacks("setIPluginOutConnectionService",
"unsetIPluginOutConnectionService")
- .setRequired(false));
+ .setRequired(true));
}
if (imp.equals(TopologyServiceShim.class)) {
import org.opendaylight.controller.sal.action.Action;
import org.opendaylight.controller.sal.action.ActionType;
import org.opendaylight.controller.sal.action.Output;
-import org.opendaylight.controller.sal.connection.IPluginOutConnectionService;
import org.opendaylight.controller.sal.core.ContainerFlow;
import org.opendaylight.controller.sal.core.IContainerListener;
import org.opendaylight.controller.sal.core.Node;
this.statsMgr = null;
}
- IPluginOutConnectionService connectionPluginOutService;
- void setIPluginOutConnectionService(IPluginOutConnectionService s) {
- connectionPluginOutService = s;
- }
-
- void unsetIPluginOutConnectionService(IPluginOutConnectionService s) {
- if (connectionPluginOutService == s) {
- connectionPluginOutService = null;
- }
- }
-
@Override
public FlowOnNode readFlow(String container, Node node, Flow flow, boolean cached) {
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.opendaylight.controller.sal.connection.IPluginOutConnectionService;
import org.opendaylight.controller.sal.core.Bandwidth;
import org.opendaylight.controller.sal.core.Config;
import org.opendaylight.controller.sal.core.ContainerFlow;
this.notifyQ = notifyQ;
}
+ @Override
public void run() {
while (true) {
try {
this.notifyQ = notifyQ;
}
+ @Override
public void run() {
while (true) {
try {
}
}
- IPluginOutConnectionService connectionPluginOutService;
- void setIPluginOutConnectionService(IPluginOutConnectionService s) {
- connectionPluginOutService = s;
- }
-
- void unsetIPluginOutConnectionService(IPluginOutConnectionService s) {
- if (connectionPluginOutService == s) {
- connectionPluginOutService = null;
- }
- }
-
private void removeNodeConnector(String container,
NodeConnector nodeConnector) {
List<TopoEdgeUpdate> teuList = new ArrayList<TopoEdgeUpdate>();
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.opendaylight.controller.sal.connection.IPluginOutConnectionService;
import org.opendaylight.controller.sal.core.Edge;
import org.opendaylight.controller.sal.topology.IPluginInTopologyService;
import org.opendaylight.controller.sal.topology.IPluginOutTopologyService;
.getLogger(TopologyServices.class);
private IPluginOutTopologyService salTopoService = null;
private IRefreshInternalProvider topoRefreshService = null;
- private IPluginOutConnectionService connectionOutService;
private String containerName;
/**
this.salTopoService.edgeUtilBackToNormal(edge);
}
}
-
- void setIPluginOutConnectionService(IPluginOutConnectionService s) {
- connectionOutService = s;
- }
-
- void unsetIPluginOutConnectionService(IPluginOutConnectionService s) {
- if (connectionOutService == s) {
- connectionOutService = null;
- }
- }
}