diff options
author | SrikanthN <sn00469487@techmahindra.com> | 2019-03-13 14:55:59 +0530 |
---|---|---|
committer | SrikanthN <sn00469487@techmahindra.com> | 2019-03-13 15:51:24 +0530 |
commit | 0d08c0ad086d7cbe8a1efcef9164a0cca08e2864 (patch) | |
tree | aaffd3f4dc943a06b0b4968a07ddfe7a1bcd08e4 /veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/HeartBeatData.java | |
parent | 03ff3e042bb3070148f06e7cf819150150e5e6af (diff) |
JAVA Test code coveragedublin
JAVA Test code coverage Issue-ID: VNFSDK-381
Change-Id: I460967cde23f51c208e0b92d1a4cbdb1a1968118
Signed-off-by: SrikanthN <sn00469487@techmahindra.com>
Diffstat (limited to 'veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/HeartBeatData.java')
-rw-r--r-- | veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/HeartBeatData.java | 67 |
1 files changed, 35 insertions, 32 deletions
diff --git a/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/HeartBeatData.java b/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/HeartBeatData.java index 52ddaea..77c1823 100644 --- a/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/HeartBeatData.java +++ b/veslibrary/ves_javalibrary/evel_javalib2/src/main/java/evel_javalibrary/att/com/loadbalance/HeartBeatData.java @@ -38,6 +38,7 @@ import evel_javalibrary.att.com.AgentMain; import evel_javalibrary.att.com.EvelHeartbeatField; import org.apache.log4j.Level; +import org.apache.log4j.Logger; import org.json.simple.JSONObject; import org.json.simple.parser.JSONParser; import org.json.simple.parser.ParseException; @@ -45,26 +46,28 @@ import org.json.simple.parser.ParseException; public class HeartBeatData extends Thread{ static HashMap<String, String> hbConfig = new HashMap(); - static int gm_event_id = 1; - static String event_id1 = "heartbeatvfs"; - static String event_id = "00000000"; - static String event_id2=null; + static int gmEventid = 1; + static String eventId1 = "heartbeatvfs"; + static String eventId = "00000000"; + static String eventId2=null; + private static final Logger logger = Logger.getLogger(AgentMain.class); - public void run() { - - Long start_epoch_microsec = 0L; - Long last_epoch_microsec = 0L; + @Override + public void run() { + Long startEpochMicrosec = 0L; + Long lastEpochMicrosec = 0L; String hostName = hostName(); try { readHeartbeatConfig(); - }catch(Exception e) { + }catch(Exception e) { + logger.error(e); } while(true) { String heatBeatInterval=""; long milliseconds = 60000; - event_id2 = event_id1+ event_id+(gm_event_id++); + eventId2 = eventId1+ eventId+(gmEventid++); if(hbConfig.get("heartbeatInterval") == null) { heatBeatInterval = Long.toString(milliseconds); }else { @@ -72,46 +75,46 @@ public class HeartBeatData extends Thread{ } EvelHeartbeatField evelHb = new EvelHeartbeatField(Integer.parseInt(heatBeatInterval) , hbConfig.get("eventName"), - event_id2); + eventId2); if( hbConfig.get("eventType")!=null) { - start_epoch_microsec = last_epoch_microsec; - last_epoch_microsec = System.nanoTime()/1000; + startEpochMicrosec = lastEpochMicrosec; + lastEpochMicrosec = System.nanoTime()/1000; - evelHb.evel_last_epoch_set(start_epoch_microsec); - evelHb.evel_start_epoch_set(last_epoch_microsec); + evelHb.evel_last_epoch_set(startEpochMicrosec); + evelHb.evel_start_epoch_set(lastEpochMicrosec); - evelHb.evel_header_type_set(hbConfig.get("eventType").toString()); - evelHb.evel_nfcnamingcode_set(hbConfig.get("nfcNamingCode").toString()); - evelHb.evel_nfnamingcode_set(hbConfig.get("nfNamingCode").toString()); + evelHb.evel_header_type_set(hbConfig.get("eventType")); + evelHb.evel_nfcnamingcode_set(hbConfig.get("nfcNamingCode")); + evelHb.evel_nfnamingcode_set(hbConfig.get("nfNamingCode")); if(hbConfig.get("reportingEntityName") == null) { evelHb.evel_reporting_entity_name_set(hostName); }else { - evelHb.evel_reporting_entity_name_set(hbConfig.get("reportingEntityName").toString()); + evelHb.evel_reporting_entity_name_set(hbConfig.get("reportingEntityName")); } - evelHb.evel_reporting_entity_id_set(hbConfig.get("reportingEntityId").toString()); - evelHb.evel_nfVendorName_set(hbConfig.get("nfVendorName").toString()); - evelHb.evel_header_set_sourceid(true,hbConfig.get("sourceId").toString()); + evelHb.evel_reporting_entity_id_set(hbConfig.get("reportingEntityId")); + evelHb.evel_nfVendorName_set(hbConfig.get("nfVendorName")); + evelHb.evel_header_set_sourceid(true,hbConfig.get("sourceId")); if(hbConfig.get("sourceName") == null) { evelHb.evel_header_set_source_name(hostName); }else { - evelHb.evel_header_set_source_name(hbConfig.get("sourceName").toString()); + evelHb.evel_header_set_source_name(hbConfig.get("sourceName")); } - evelHb.evel_timeZoneOffset_set(hbConfig.get("timeZoneOffset").toString()); + evelHb.evel_timeZoneOffset_set(hbConfig.get("timeZoneOffset")); } try { Thread.sleep(Integer.parseInt(heatBeatInterval)); }catch(Exception e) { - + logger.error(e); } AgentMain.evel_post_event(evelHb); } } - public static HashMap<String, String> readHeartbeatConfig() throws IOException, ParseException { + private static HashMap<String, String> readHeartbeatConfig() throws IOException, ParseException { JSONParser jsonParser = new JSONParser(); try { @@ -130,7 +133,7 @@ public class HeartBeatData extends Thread{ } } catch (ClassCastException ex) { - ex.printStackTrace(); + logger.error(ex); } return hbConfig; } @@ -148,7 +151,7 @@ private static String bytesToHex(byte[] bytes) { public static String hostName() { String hostname = "Unknown"; - String uuid = "Unknown"; + try { InetAddress addr; @@ -157,6 +160,7 @@ public static String hostName() { } catch (UnknownHostException ex) { + logger.error(ex); } try{ Enumeration<NetworkInterface> networks = @@ -177,19 +181,18 @@ public static String hostName() { } } if (mac != null) { - uuid = bytesToHex(mac); + bytesToHex(mac); } } } catch (SocketException e) { - // TODO Auto-generated catch block - + logger.error(e); } return hostname; } public static void main(String[] args) { - // TODO Auto-generated method stub + try { AgentMain.evel_initialize("http://127.0.0.1",30000, |