--- /dev/null
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP : ccsdk features
+ * ================================================================================
+ * Copyright (C) 2023 highstreet technologies GmbH Intellectual Property.
+ * All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ *
+ */
+package org.onap.ccsdk.features.sdnr.wt.devicemanager.ne.factory;
+
+public class DevicemanagerNature implements Comparable<DevicemanagerNature> {
+
+ /** Specific devicemanager */
+ public static final DevicemanagerNature SPECIFIC = new DevicemanagerNature(10);
+ /** Priority of mid specfic types */
+ public static final DevicemanagerNature NORMAL = new DevicemanagerNature(100);
+ /** Common devicemanager with basic functionality for standard */
+ public static final DevicemanagerNature COMMON = new DevicemanagerNature(250);
+ /** Priority of "NetworkElementFactory" types */
+ public static final DevicemanagerNature NETWORKELEMENT_FACTORY_DEFAULT = new DevicemanagerNature(Integer.MAX_VALUE);
+
+ //Low numbers have the highest priority for devicemanager selection
+ private final int nature;
+
+ private DevicemanagerNature(int nature) {
+ super();
+ this.nature = nature;
+ }
+
+ @Override
+ public int compareTo(DevicemanagerNature o) {
+ return Integer.compare(nature, o.nature);
+ }
+
+ public static DevicemanagerNature getDefaultDevicemanagerNature(NetworkElementFactory a) {
+ return (a instanceof NetworkElementFactory2) ? ((NetworkElementFactory2) a).getDevicemanagerNature()
+ : NETWORKELEMENT_FACTORY_DEFAULT;
+ }
+
+ public static int compareTo(NetworkElementFactory a, NetworkElementFactory b) {
+ return getDefaultDevicemanagerNature(a).compareTo(getDefaultDevicemanagerNature(b));
+ }
+
+}
--- /dev/null
+/*
+ * ============LICENSE_START========================================================================
+ * ONAP : ccsdk feature sdnr wt
+ * =================================================================================================
+ * Copyright (C) 2023 highstreet technologies GmbH Intellectual Property. All rights reserved.
+ * =================================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ * ============LICENSE_END==========================================================================
+ */
+
+package org.onap.ccsdk.features.sdnr.wt.devicemanager.ne.factory;
+
+public interface NetworkElementFactory2 extends NetworkElementFactory {
+
+ /**
+ * Provide the nature of the devicemanager for list ordering
+ * @return nature definition of devicemanager
+ */
+ DevicemanagerNature getDevicemanagerNature();
+
+}
*/
package org.onap.ccsdk.features.sdnr.wt.devicemanager.impl;
+import java.util.Collections;
import java.util.List;
import java.util.concurrent.CopyOnWriteArrayList;
import org.eclipse.jdt.annotation.NonNull;
import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.xml.WebSocketServiceClientImpl;
import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.xml.WebSocketServiceClientInternal;
import org.onap.ccsdk.features.sdnr.wt.devicemanager.maintenance.impl.MaintenanceServiceImpl;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.ne.factory.DevicemanagerNature;
import org.onap.ccsdk.features.sdnr.wt.devicemanager.ne.factory.FactoryRegistration;
import org.onap.ccsdk.features.sdnr.wt.devicemanager.ne.factory.NetworkElementFactory;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.ne.factory.NetworkElementFactory2;
import org.onap.ccsdk.features.sdnr.wt.devicemanager.ne.service.NetworkElement;
import org.onap.ccsdk.features.sdnr.wt.devicemanager.performancemanager.impl.PerformanceManagerImpl;
import org.onap.ccsdk.features.sdnr.wt.devicemanager.service.AaiService;
}
@Override
- public @NonNull <L extends NetworkElementFactory> FactoryRegistration<L> registerBindingNetworkElementFactory(
+ synchronized public @NonNull <L extends NetworkElementFactory> FactoryRegistration<L> registerBindingNetworkElementFactory(
@NonNull final L factory) {
LOG.debug("Factory registration {}", factory.getClass().getName());
factoryList.add(factory);
+ Collections.sort(factoryList, (a,b) -> DevicemanagerNature.compareTo(a, b) );
factory.init(getServiceProvider());
return new FactoryRegistration<L>() {
};
}
- @SuppressWarnings("null")
+ private DevicemanagerNature getNature(NetworkElementFactory a) {
+ return (a instanceof NetworkElementFactory2) ? ((NetworkElementFactory2)a).getDevicemanagerNature()
+ : DevicemanagerNature.NETWORKELEMENT_FACTORY_DEFAULT;
+ }
+
@Override
public @NonNull DataProvider getDataProvider() {
return this.dataProvider;
// update db with connect status
NetconfNode netconfNode = acessor.getNetconfNode();
sendUpdateNotification(acessor.getNodeId(), netconfNode.getConnectionStatus(), netconfNode);
-
- for (NetworkElementFactory f : getFactoryList()) {
- Optional<NetworkElement> optionalNe = f.create(acessor, getServiceProvider());
- if (optionalNe.isPresent()) {
- // sendUpdateNotification(mountPointNodeName, nNode.getConnectionStatus(), nNode);
- handleNeStartup(acessor.getNodeId(), optionalNe.get());
- break; // Use the first provided
- }
+ // Start devicemanager if possible
+ Optional<NetworkElement> optionalNe = createNetworkElement(acessor);
+ // Startup device
+ if (optionalNe.isPresent()) {
+ handleNeStartup(acessor.getNodeId(), optionalNe.get());
}
}
* Private functions
*/
+ /**
+ * Get the NetworkElement from list
+ *
+ * @param accessor
+ * @return Optional<NetowrkElement>
+ */
+ private Optional<NetworkElement> createNetworkElement(NetconfAccessor accessor) {
+ Optional<NetworkElement> optionalNe = Optional.empty();
+ for (NetworkElementFactory f : getFactoryList()) {
+ optionalNe = f.create(accessor, getServiceProvider());
+ if (optionalNe.isPresent()) {
+ return optionalNe; // Use the first provided
+ }
+ }
+ return Optional.empty();
+ }
+
/**
* Do all tasks necessary to move from mountpoint state connected -> connecting
*
Code Review / ccsdk / features.git / commitdiff