public class Alcatel5620SamCollectorProcessor
extends java.lang.Object
| Constructor and Description |
|---|
Alcatel5620SamCollectorProcessor(CollectorDataStore dataStore,
int dataSourceId,
Alcatel5620SamCollectorProperties collProps)
Constructor
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
checkInterfaceExists(N5gFunction function,
java.lang.String interfacType,
java.lang.String ipAddress) |
void |
clearVprnIpMap() |
void |
createAmfDevices(java.lang.String ftpUrl,
java.lang.String moClassName)
Parses, processes, and saves the AMF device data to the datastore
|
void |
createAndInferRemotePcrfDevices(java.lang.String ftpUrl) |
void |
createENodeBDevice(java.lang.String ftpUrl)
Creates basic ENodeB data in the datastore
|
void |
createMmeDevice(java.lang.String ftpUrl,
java.lang.String moClassName)
Parses, processes, and saves the MME device data to the datastore
|
void |
createPcrfDevice(java.lang.String ftpUrl)
Create the PCRF device data in the datastore
|
void |
createPgwDevice(java.lang.String ftpUrl)
Create the PGW device data in the datastore
|
void |
createSgwDevice(java.lang.String ftpUrl)
Create the SGW device data in the datastore
|
void |
createSmfDevices(java.lang.String ftpUrl,
java.lang.String moClassName)
Parses, processes, and saves the AMF device data to the datastore
|
void |
createUpfDevices(java.lang.String ftpUrl,
java.lang.String moClassName)
Parses, processes, and saves the UPF device data to the datastore
|
void |
emptyLTEFunctionMap(java.lang.String deviceId)
Empties the Map containing LTE Functions based on given device Id
|
java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
fetchAllLagMembers(java.lang.String ftpUrl) |
void |
findAndCreateMMEDeviceTypes() |
void |
findAndCreateSAEFromS1uPaths(java.lang.String ftpUrl) |
void |
findAndCreateSgwFromS1uPaths(java.lang.String ftpUrl) |
N5gAMFFunction |
getAmfFunction(java.lang.String strDeviceId) |
LTEFunction |
getCloudMmeFunction(java.lang.String deviceId) |
LTEFunction |
getFunctionMap(java.lang.String strDeviceId,
LTEFunction.eFunctionType lteFunctionType)
Returns an LTE Function based on a given device Id and LTE Function type
|
java.util.List<java.lang.String> |
getLagConnectedPorts(java.util.Map<java.lang.String,java.util.List<java.lang.String>> lagDetails,
java.lang.String objectFullName) |
NetworkDevice |
getNetworkDevice(java.lang.String deviceId) |
boolean |
isS1UPathExists(java.lang.String deviceId) |
void |
loadS1UList() |
void |
populateAmfN26Interfaces(java.lang.String ftpUrl,
java.lang.String deviceId) |
void |
processBundleInterfaces(java.lang.String ftpUrl)
Parses, processes, and saves the Bundle interfaces to the datastore
|
java.util.Map<java.lang.String,java.lang.String> |
processCellHzBandwidthFDD(java.lang.String ftpUrl,
java.lang.String deviceSiteId)
Parses, processes, and saves the ENodeB Cell Frequency & bandwidth data to
the datastore
|
void |
processEmsDevices(java.lang.String ftpUrl)
Parses, processes, and saves the EMS devices data to the datastore
|
void |
processEnodeBCell(java.lang.String ftpUrl,
LTEENBFunction lteEnodeBFunction,
java.lang.String deviceSiteId)
Parses, processes, and saves the ENodeB Cell data to the datastore
|
void |
processEnodeBPlmn(java.lang.String ftpUrl,
LTEENBFunction lteEnodeBFunction,
java.lang.String deviceSiteId)
Parses, processes, and saves the ENodeB PLMN data to the datastore
|
void |
processEnodeBSector(java.lang.String ftpUrl,
LTEENBFunction lteEnodeBFunction,
java.lang.String deviceSiteId)
Parses, processes, and saves the ENodeB Sector data to the datastore
|
void |
processEntityList(java.lang.String ftpUrl)
Parses, processes, and saves the entities list to the datastore
|
void |
processIpInterfaces(java.lang.String ftpUrl)
Parses, processes, and saves the IP interfaces to the datastore
|
void |
processLagInterfaces(java.lang.String ftpUrl)
Parses, processes, and saves the LAG interfaces data to the datastore
|
void |
processLayer2ConnectionData(java.lang.String physicalLinkDataUrl,
java.lang.String lagInterface)
Parses, processes, and saves the layer 2 connections data to the datastore
|
void |
processLayer3AccessInterfaces(java.lang.String ftpUrl)
Parses, processes, and saves the layer 3 access interfaces data to the
datastore
|
void |
processLayer3ServiceSites(java.lang.String ftpUrl)
Parses, processes, and saves the layer 3 service sites data to the datastore
|
void |
processLteConnectivity(java.lang.String ftpUrl,
LTEFunction lteFunction,
java.lang.String deviceSiteId)
Parses, processes, and saves the LTE Connectivity data for ENnodeB, MME, PGW,
SGW, and PCRF to the datastore
|
void |
processLTEEntity(java.lang.String ftpUrl)
Parses, processes, and saves the LTE entities list to the datastore
|
void |
processLteInterfaces(java.lang.String ftpUrl,
LTEFunction lteFunction,
java.lang.String deviceSiteId)
Parses, processes, and saves the LTE Interfaces data for ENnodeB, MME, PGW,
SGW, and PCRF to the datastore
|
void |
processLtePcscfPeerEntry(java.lang.String ftpUrl,
java.lang.String deviceId,
LTEFunction ltePgwFunction) |
void |
processLtePeerConnectivity(java.lang.String ftpUrl,
LTEFunction lteFunction,
java.lang.String deviceSiteId)
Parses, processes, and saves the LTE Connectivity data for ENnodeB, MME, PGW,
SGW, and PCRF to the datastore
|
void |
processMmeGrpTAI(java.lang.String ftpUrl,
java.lang.String deviceSiteId) |
void |
processMplsInterfaceData(java.lang.String ftpUrl)
Parses, processes, and saves the MPLS interfaces data to the datastore
|
void |
processNetworkElementLayer2(java.lang.String ftpUrl)
Parses, processes, and saves the network layer 2 data to the datastore
|
void |
processPcscfPeerEntry(java.lang.String ftpUrl) |
void |
processPeerConnectivity(java.lang.String ftpUrl,
N5gFunction n5gFunction,
java.lang.String deviceSiteId) |
void |
processPhysicalInterfaces(java.lang.String ftpUrl)
Parses, processes, and saves the physical interfaces data to the datastore
|
void |
processPhysicalPortLayer2(java.lang.String ftpUrl)
Parses, processes, and saves the physical port layer 2 data to the datastore
|
void |
processRanBackhaulEthernetPortData(java.lang.String ftpUrl,
java.lang.String deviceSiteId)
Parses, processes, and saves the RanBackHaul's EthernetPort entity to the
datastore
|
void |
processRanBackhaulEthernetPortLTEIfData(java.lang.String ftpUrl,
LTEENBFunction lteEnodeBFunction,
java.lang.String deviceSiteId)
Parses, processes, and saves the RanBackHaul's EthernetPort LTE data to the
datastore
|
java.lang.String |
processRanBackhaulEthernetPortVlan(java.lang.String ftpUrl,
java.util.List<java.util.Map<java.lang.String,java.lang.String>> vlanTraffDescList,
java.lang.String deviceSiteId)
Processes, and saves the RanBackHaul's EthernetPort VLAN to the datastore
|
void |
processServiceIPInterfaces(java.lang.String ftpUrl,
LTEFunction lteFunction,
java.lang.String deviceSiteId,
java.lang.String interfaceType)
Parses, processes, and saves the LTE Interfaces data for ENnodeB, MME, PGW,
SGW, and PCRF to the datastore
|
void |
processServiceSitePolicy(java.lang.String ftpUrl)
Parses, processes, and saves the layer 3 service site policies data to the
datastore
|
void |
processSpecific5GConnectivity(N5gFunction n5gFunction,
java.util.Map<java.lang.String,java.lang.String> fields,
java.lang.String strSiteIdOnB,
java.lang.String strRemoteNbrIpAddr)
This method processes specific LTE connectivity depending on type of LTE
function and add the LTE connectivity data to dataStore
|
void |
processSpecificLteConnectivity(LTEFunction lteFunction,
java.util.Map<java.lang.String,java.lang.String> fields,
java.lang.String strSiteIdOnB,
java.lang.String strRemoteNbrIpAddr)
This method processes specific LTE connectivity depending on type of LTE
function and add the LTE connectivity data to dataStore
|
void |
processSpecificLteInterface(LTEFunction lteFunction,
java.util.Map<java.lang.String,java.lang.String> fields,
java.lang.String strFdnName,
java.lang.String ipAddr)
This method processes specific LTE interfaces depending on type of LTE
function and add the LTE interface's data to dataStore
|
void |
processSysDesc(java.lang.String ftpUrl)
Parses, processes, and saves the system descriptions to the datastore
|
void |
processVlanEntities(java.lang.String ftpUrl)
Parses, processes, and saves the vlans to the datastore
|
void |
processVllVpns(java.lang.String ftpUrl)
Parses, processes, and saves the VLL VPNs to the datastore
|
void |
processVplsVpns(java.lang.String ftpUrl)
Parses, processes, and saves the VPLS VPNs to the datastore
|
void |
setDataSourceId(int dataSourceId) |
void |
setDataStore(CollectorDataStore dataStore) |
public Alcatel5620SamCollectorProcessor(CollectorDataStore dataStore, int dataSourceId, Alcatel5620SamCollectorProperties collProps)
dataStore - dataSourceId - collProps - public void setDataStore(CollectorDataStore dataStore)
public void setDataSourceId(int dataSourceId)
public void clearVprnIpMap()
public void processEmsDevices(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the EMS devices datapublic void processSysDesc(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the system descriptions datapublic void processVlanEntities(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the vlan datapublic void processPhysicalPortLayer2(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the physical port layer 2 datapublic void processNetworkElementLayer2(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the network layer 2 datapublic void processPhysicalInterfaces(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the physical interfaces datapublic void processLagInterfaces(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the LAG interfaces datapublic void processIpInterfaces(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the IP interfaces datapublic void processBundleInterfaces(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the Bundle interfaces datapublic void processEntityList(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the entities list datapublic void processVplsVpns(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the VPLS VPNs datapublic void processVllVpns(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the VLL VPNs datapublic void processLayer3ServiceSites(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the layer 3 service sites datapublic void processLayer3AccessInterfaces(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the layer 3 access interfaces
datapublic void processServiceSitePolicy(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the layer 3 service site
policies datapublic void processMplsInterfaceData(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the MPLS interfaces datapublic void processLayer2ConnectionData(java.lang.String physicalLinkDataUrl,
java.lang.String lagInterface)
physicalLinkDataUrl - The location of the file containing the physical links dataphysicalPortsUrl - The location of the file containing the physical ports datanetworkElementsUrl - The location of the file containing the network elements datapublic java.util.List<java.lang.String> getLagConnectedPorts(java.util.Map<java.lang.String,java.util.List<java.lang.String>> lagDetails,
java.lang.String objectFullName)
public void createENodeBDevice(java.lang.String ftpUrl)
ftpUrl - URL of the downloaded XML filepublic void processEnodeBPlmn(java.lang.String ftpUrl,
LTEENBFunction lteEnodeBFunction,
java.lang.String deviceSiteId)
ftpUrl - URL of the downloaded XML filelteEnodeBFunction - ENodeB function object associated with this EnodeB sectordeviceSiteId - SiteId of the interface's devicepublic void processEnodeBCell(java.lang.String ftpUrl,
LTEENBFunction lteEnodeBFunction,
java.lang.String deviceSiteId)
ftpUrl - URL of the downloaded XML filelteEnodeBFunction - ENodeB function object associated with this EnodeB sectordeviceSiteId - SiteId of the interface's devicepublic java.util.Map<java.lang.String,java.lang.String> processCellHzBandwidthFDD(java.lang.String ftpUrl,
java.lang.String deviceSiteId)
ftpUrl - URL of the downloaded XML filelteEnodeBFunction - ENodeB function object associated with this EnodeB CelldeviceSiteId - SiteId of the interface's devicepublic void processEnodeBSector(java.lang.String ftpUrl,
LTEENBFunction lteEnodeBFunction,
java.lang.String deviceSiteId)
ftpUrl - URL of the downloaded XML filelteEnodeBFunction - ENodeB function object associated with this EnodeB sectordeviceSiteId - SiteId of the interface's devicepublic void createMmeDevice(java.lang.String ftpUrl,
java.lang.String moClassName)
ftpUrl - URL of the downloaded XML filepublic void createAmfDevices(java.lang.String ftpUrl,
java.lang.String moClassName)
ftpUrl - URL of the downloaded XML filepublic void createSmfDevices(java.lang.String ftpUrl,
java.lang.String moClassName)
ftpUrl - URL of the downloaded XML filepublic void createUpfDevices(java.lang.String ftpUrl,
java.lang.String moClassName)
ftpUrl - URL of the downloaded XML filepublic void createSgwDevice(java.lang.String ftpUrl)
ftpUrl - URL of the downloaded XML filepublic void createPgwDevice(java.lang.String ftpUrl)
ftpUrl - URL of the downloaded XML filepublic void createPcrfDevice(java.lang.String ftpUrl)
ftpUrl - URL of the downloaded XML filepublic void processLTEEntity(java.lang.String ftpUrl)
ftpUrl - The location of the file containing the LTE entities list datapublic void processLteInterfaces(java.lang.String ftpUrl,
LTEFunction lteFunction,
java.lang.String deviceSiteId)
ftpUrl - URL of the downloaded XML filelteFunction - The LTEFunction type of the interfacedeviceSiteId - SiteId of the interface's devicepublic void processServiceIPInterfaces(java.lang.String ftpUrl,
LTEFunction lteFunction,
java.lang.String deviceSiteId,
java.lang.String interfaceType)
ftpUrl - URL of the downloaded XML filelteFunction - The LTEFunction type of the interfacedeviceSiteId - SiteId of the interface's devicepublic void processMmeGrpTAI(java.lang.String ftpUrl,
java.lang.String deviceSiteId)
public void processSpecificLteInterface(LTEFunction lteFunction, java.util.Map<java.lang.String,java.lang.String> fields, java.lang.String strFdnName, java.lang.String ipAddr)
lteFunction - The LTEFunction type of the interfacefields - Parsed XML map data of interfacestrFdnName - Objectname of interfaceipAddr - Ip Address associated with the interfacepublic void processRanBackhaulEthernetPortData(java.lang.String ftpUrl,
java.lang.String deviceSiteId)
ftpUrl - The location of the file containing the RanBackHaul's EthernetPort
datadeviceSiteId - SiteId of the RanBackHaul's devicepublic void processRanBackhaulEthernetPortLTEIfData(java.lang.String ftpUrl,
LTEENBFunction lteEnodeBFunction,
java.lang.String deviceSiteId)
ftpUrl - The location of the file containing the RanBackHaul's EthernetPort
LTE datadeviceSiteId - SiteId of the RanBackHaul's devicepublic java.lang.String processRanBackhaulEthernetPortVlan(java.lang.String ftpUrl,
java.util.List<java.util.Map<java.lang.String,java.lang.String>> vlanTraffDescList,
java.lang.String deviceSiteId)
ftpUrl - The location of the file containing the RanBackHaul's EthernetPort
VLAN datadeviceSiteId - SiteId of the RanBackHaul's devicepublic void processLteConnectivity(java.lang.String ftpUrl,
LTEFunction lteFunction,
java.lang.String deviceSiteId)
ftpUrl - URL of the downloaded XML filelteFunction - The LTEFunction type of the interfacedeviceSiteId - SiteId of the connected devicepublic void processLtePeerConnectivity(java.lang.String ftpUrl,
LTEFunction lteFunction,
java.lang.String deviceSiteId)
ftpUrl - URL of the downloaded XML filelteFunction - The LTEFunction type of the interfacedeviceSiteId - SiteId of the connected devicepublic void processSpecificLteConnectivity(LTEFunction lteFunction, java.util.Map<java.lang.String,java.lang.String> fields, java.lang.String strSiteIdOnB, java.lang.String strRemoteNbrIpAddr)
lteFunction - The LTEFunction type of the interfacefields - Parsed XML map data of interfacestrSiteIdOnB - Name of the connected devicestrRemoteNbrIpAddr - Ip Address of the connected devicepublic LTEFunction getFunctionMap(java.lang.String strDeviceId, LTEFunction.eFunctionType lteFunctionType)
strDeviceId - The device id of a NElteFunctionType - Chassis type of LTE devicepublic N5gAMFFunction getAmfFunction(java.lang.String strDeviceId)
public LTEFunction getCloudMmeFunction(java.lang.String deviceId)
public void emptyLTEFunctionMap(java.lang.String deviceId)
deviceId - The device id of a NEpublic void findAndCreateSgwFromS1uPaths(java.lang.String ftpUrl)
ftpUrl - -- file path of the lte.ReferancePoint
if the device have S1U interface then
Create SAEGateway device and SAEGatewayFunction object and map SAEGatewayFunction to it devicepublic void findAndCreateSAEFromS1uPaths(java.lang.String ftpUrl)
ftpUrl - -- file path of the lte.ReferancePoint
if the device have S1U interface then
Create SAEGateway device object and map SGWFunction and PGWFunction to it devicepublic void findAndCreateMMEDeviceTypes()
public void loadS1UList()
public boolean isS1UPathExists(java.lang.String deviceId)
public java.util.Map<java.lang.String,java.util.List<java.lang.String>> fetchAllLagMembers(java.lang.String ftpUrl)
public void createAndInferRemotePcrfDevices(java.lang.String ftpUrl)
public void processPcscfPeerEntry(java.lang.String ftpUrl)
public void processLtePcscfPeerEntry(java.lang.String ftpUrl,
java.lang.String deviceId,
LTEFunction ltePgwFunction)
public NetworkDevice getNetworkDevice(java.lang.String deviceId)
public void populateAmfN26Interfaces(java.lang.String ftpUrl,
java.lang.String deviceId)
public boolean checkInterfaceExists(N5gFunction function, java.lang.String interfacType, java.lang.String ipAddress)
public void processSpecific5GConnectivity(N5gFunction n5gFunction, java.util.Map<java.lang.String,java.lang.String> fields, java.lang.String strSiteIdOnB, java.lang.String strRemoteNbrIpAddr)
lteFunction - The LTEFunction type of the interfacefields - Parsed XML map data of interfacestrSiteIdOnB - Name of the connected devicestrRemoteNbrIpAddr - Ip Address of the connected devicepublic void processPeerConnectivity(java.lang.String ftpUrl,
N5gFunction n5gFunction,
java.lang.String deviceSiteId)