com.ibm.tivoli.nm.collectors.impl.ecilightsoft.data

Class DataProcessor

java.lang.Object

com.ibm.tivoli.nm.collectors.impl.ecilightsoft.data.DataProcessor

public class DataProcessor
extends java.lang.Object

Processes Collector data to be added into the DataStore

Author:

Yeo Eng Seng

Constructor Summary

Constructors

Constructor and Description
DataProcessor() Constructor Always pass in the DataTracker instance individually for each method in order to use the instance with the most up-to-date data.

Method Summary

Modifier and Type	Method and Description
java.lang.String	getTopolinkEndPointDevice(DataTracker data, NameAndStringValue_T[] name) Returns the name of the device containing the topological link
NetworkDevice	processChassisData(int dataSourceId, DataTracker data, ManagedElement_T me) Processes chassis data
java.util.Map<java.util.Map<java.lang.String,java.lang.Object>,java.util.Map<java.lang.String,java.lang.Object>>	processConnectionTPData(int dataSourceId, NetworkDevice device, DataTracker data, TerminationPoint_T ctp) Processes ConnectionTP data
java.util.Map<java.lang.String,java.lang.Object>	processModuleData(DataTracker data, EquipmentHolder_T eqh) Process module data using the EquipmentHolder_T object
java.util.Map<java.lang.String,java.lang.Object>	processModuleData(Equipment_T eq, java.util.Map<java.lang.String,java.lang.Object> hashedData) Process module data using the Equipment_T object
java.util.Map<java.util.Map<java.lang.String,java.lang.Object>,java.util.Map<java.lang.String,java.lang.Object>>	processPhysicalTPData(int dataSourceId, NetworkDevice device, DataTracker data, TerminationPoint_T ptp, java.util.Set<Equipment_T> eqtSubslotSet) Processes PhysicalTP data
java.util.Map<java.lang.String,java.lang.Object>	processRackData(int dataSourceId, NetworkDevice device, DataTracker data) Process virtual Rack data
java.util.Map<java.lang.String,java.lang.Object>	processRackData(int dataSourceId, NetworkDevice device, DataTracker data, EquipmentHolder_T eq) Process rack data
java.util.Map<java.lang.String,java.lang.Object>	processSlotData(int dataSourceId, NetworkDevice device, DataTracker data, EquipmentHolder_T eq) Processed slot data
java.util.Map<java.lang.String,java.lang.Object>	processTopologicalLinkData(int dataSourceId, DataTracker data, TopologicalLink_T tl) Processes Topological Link data

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DataProcessor

public DataProcessor()

Constructor Always pass in the DataTracker instance individually for each method in order to use the instance with the most up-to-date data.

Method Detail

processChassisData

public NetworkDevice processChassisData(int dataSourceId,
                                        DataTracker data,
                                        ManagedElement_T me)

Processes chassis data

Parameters:

dataSourceId - Data source identifier

data - DataTracker data

me - ManagedElement_T instance

Returns:

new NetworkDevice instance containing processed chassis data

processRackData

public java.util.Map<java.lang.String,java.lang.Object> processRackData(int dataSourceId,
                                                                        NetworkDevice device,
                                                                        DataTracker data,
                                                                        EquipmentHolder_T eq)

Process rack data

Parameters:

dataSourceId - Data source identifier

device - NetworkDevice instance

data - DataTracker instance

eq - EquipmentHolder_T instance

Returns:

new Map containing processed rack data

processRackData

public java.util.Map<java.lang.String,java.lang.Object> processRackData(int dataSourceId,
                                                                        NetworkDevice device,
                                                                        DataTracker data)

Process virtual Rack data

Parameters:

dataSourceId - Data source identifier

device - NetworkDevice instance

data - DataTracker instance

Returns:

new Map containing processed rack data

processSlotData

public java.util.Map<java.lang.String,java.lang.Object> processSlotData(int dataSourceId,
                                                                        NetworkDevice device,
                                                                        DataTracker data,
                                                                        EquipmentHolder_T eq)

Processed slot data

Parameters:

dataSourceId - Data source identifier

device - NetworkDevice instance

data - DataTracker instance

eq - EquipmentHolder_T instance

Returns:

new Map containing processed slot data

processModuleData

public java.util.Map<java.lang.String,java.lang.Object> processModuleData(DataTracker data,
                                                                          EquipmentHolder_T eqh)

Process module data using the EquipmentHolder_T object

This method works with the following assumptions:

• An EquipmentHolder_T object represents a slot in the device.
• When a card is installed in the slot, the expectedOrInstalledEquipment attribute will not be null or empty.

When a card is installed in the slot, there should also be a corresponding Equipment_T object. EquipmentHolder_T objects are always processed first, followed by Equipment_T objects.

Parameters:

data - DataTracker instance

eqh - EquipmentHolder_T instance

Returns:

new map containing processed module data

processModuleData

public java.util.Map<java.lang.String,java.lang.Object> processModuleData(Equipment_T eq,
                                                                          java.util.Map<java.lang.String,java.lang.Object> hashedData)

Process module data using the Equipment_T object

Parameters:

eq - Equipment_T instance

hashedData - Map of processed module data

Returns:

Map of processed module data updated with data from Equipment_T object

processPhysicalTPData

public java.util.Map<java.util.Map<java.lang.String,java.lang.Object>,java.util.Map<java.lang.String,java.lang.Object>> processPhysicalTPData(int dataSourceId,
                                                                                                                                              NetworkDevice device,
                                                                                                                                              DataTracker data,
                                                                                                                                              TerminationPoint_T ptp,
                                                                                                                                              java.util.Set<Equipment_T> eqtSubslotSet)

Processes PhysicalTP data

Parameters:

dataSourceId - Data source identifier

device - NetworkDevice instance

data - DataTracker instance

ptp - TerminationPoint_T instance

eqtSubslotSet - Set of Equipment_T objects containing sub-slot data

Returns:

new map containing processed module data

processConnectionTPData

public java.util.Map<java.util.Map<java.lang.String,java.lang.Object>,java.util.Map<java.lang.String,java.lang.Object>> processConnectionTPData(int dataSourceId,
                                                                                                                                                NetworkDevice device,
                                                                                                                                                DataTracker data,
                                                                                                                                                TerminationPoint_T ctp)

Processes ConnectionTP data

Parameters:

dataSourceId - Data source identifier

device - NetworkDevice instance

data - DataTracker instance

ctp - TerminationPoint_T instance

extraInfoMapping - Set containing Extra Info mapping details from the Collector properties file

Returns:

new map containing processed ConnectionTP data

processTopologicalLinkData

public java.util.Map<java.lang.String,java.lang.Object> processTopologicalLinkData(int dataSourceId,
                                                                                   DataTracker data,
                                                                                   TopologicalLink_T tl)
                                                                            throws CorbaCollectorException

Processes Topological Link data

Parameters:

dataSourceId - Data source identifier

data - DataTracker instance

tl - TopologicalLink_T instance

Returns:

new map containing processed topology data

Throws:

CorbaCollectorException

getTopolinkEndPointDevice

public java.lang.String getTopolinkEndPointDevice(DataTracker data,
                                                  NameAndStringValue_T[] name)

Returns the name of the device containing the topological link

Parameters:

data - DataTracker instance

name - NameAndStringValue_T[] instance of the topological link

Returns:

the name of the device containing the topological link