commit 51207a361cd0939cac5e8c9a0ef054ab81e84ea6
author Shubham Sharma <shubham.sharma45@infosys.com> Fri Aug 09 06:54:22 2019 +0000
committer Jonathan Hart <jonomhart@gmail.com> Tue Jan 28 14:02:05 2020 -0800
tree e4961991fcaf36d4ab330236de8048e8934e9a78
parent 4cf3760497ca696d9d6baa97cf531658f12bd251

[SEBA-35] Adding Stats for 802.1x Authentication

cherry-picked from kafka-onos-1.2

Change-Id: I493f8683c6af9f802d631e7f8a2c93e06026380a

src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java

diff --git a/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java b/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java
index 693e731..425e634 100644
--- a/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java
+++ b/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java
@@ -92,6 +92,13 @@
     private static final String REQUEST_RTT_MILLIS = "requestRttMillis";
     private static final String REQUEST_RE_TX = "requestReTx";
     private static final String TIMED_OUT_PACKETS = "timedOutPackets";
+    private static final String EAPOL_LOGOFF_RX = "eapolLogoffRx";
+    private static final String EAPOL_RES_IDENTITY_MSG_TRANS = "eapolResIdentityMsgTrans";
+    private static final String EAPOL_AUTH_SUCCESS_TRANS = "eapolAuthSuccessTrans";
+    private static final String EAPOL_AUTH_FAILURE_TRANS = "eapolAuthFailureTrans";
+    private static final String EAPOL_START_REQ_TRANS = "eapolStartReqTrans";
+    private static final String EAP_PKT_TX_AUTH_CHOOSE_EAP = "eapPktTxauthChooseEap";
+    private static final String EAPOL_TRANS_RESP_NOT_NAK = "eapolTransRespNotNak";
 
     protected void bindAuthenticationService(AuthenticationService incomingService) {
         bindAndAddListener(incomingService, authServiceRef, listener);
@@ -161,6 +168,13 @@
         authMetricsEvent.put(REQUEST_RTT_MILLIS, event.subject().getRequestRttMilis());
         authMetricsEvent.put(REQUEST_RE_TX, event.subject().getRequestReTx());
         authMetricsEvent.put(TIMED_OUT_PACKETS, event.subject().getTimedOutPackets());
+        authMetricsEvent.put(EAPOL_LOGOFF_RX, event.subject().getEapolLogoffRx());
+        authMetricsEvent.put(EAPOL_RES_IDENTITY_MSG_TRANS, event.subject().getEapolResIdentityMsgTrans());
+        authMetricsEvent.put(EAPOL_AUTH_SUCCESS_TRANS, event.subject().getEapolAuthSuccessTrans());
+        authMetricsEvent.put(EAPOL_AUTH_FAILURE_TRANS, event.subject().getEapolAuthFailureTrans());
+        authMetricsEvent.put(EAPOL_START_REQ_TRANS, event.subject().getEapolStartReqTrans());
+        authMetricsEvent.put(EAP_PKT_TX_AUTH_CHOOSE_EAP, event.subject().getEapPktTxauthChooseEap());
+        authMetricsEvent.put(EAPOL_TRANS_RESP_NOT_NAK, event.subject().getEapolTransRespNotNak());
         return authMetricsEvent;
     }