commit 22a3e4f7718e94799d6933e9e5f53d183709ad8b
author Shubham Sharma <shubham.sharma45@infosys.com> Mon Sep 16 10:07:02 2019 +0000
committer Jonathan Hart <jonomhart@gmail.com> Tue Jan 28 14:16:48 2020 -0800
tree 49e9f6f46acff8b47e530a6074c79a705a4257d6
parent 51207a361cd0939cac5e8c9a0ef054ab81e84ea6

[SEBA-34] Operational Status 802.1x Authenticator

cherry-picked from kafka-onos-1.2

Change-Id: I987c174b5e2f6e16c1fdf8040292efd9ed307fdb

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 425e634..e903a98 100644
--- a/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java
+++ b/src/main/java/org/opencord/kafka/integrations/AaaKafkaIntegration.java
@@ -99,6 +99,15 @@
     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";
+    private static final String EAPOL_FRAMES_TX = "eapolFramesTx";
+    private static final String AUTH_STATE_IDLE = "authStateIdle";
+    private static final String REQUEST_ID_FRAMES_TX = "requestIdFramesTx";
+    private static final String REQUEST_EAP_FRAMES_TX = "requestEapFramesTx";
+    private static final String INVALID_PKT_TYPE = "invalidPktType";
+    private static final String INVALID_BODY_LENGTH = "invalidBodyLength";
+    private static final String VALID_EAPOL_FRAMES_RX = "validEapolFramesRx";
+    private static final String PENDING_RES_SUPPLICANT = "pendingResSupplicant";
+    private static final String RES_ID_EAP_FRAMES_RX = "resIdEapFramesRx";
 
     protected void bindAuthenticationService(AuthenticationService incomingService) {
         bindAndAddListener(incomingService, authServiceRef, listener);
@@ -175,6 +184,15 @@
         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());
+        authMetricsEvent.put(EAPOL_FRAMES_TX, event.subject().getEapolFramesTx());
+        authMetricsEvent.put(AUTH_STATE_IDLE, event.subject().getAuthStateIdle());
+        authMetricsEvent.put(REQUEST_ID_FRAMES_TX, event.subject().getRequestIdFramesTx());
+        authMetricsEvent.put(REQUEST_EAP_FRAMES_TX, event.subject().getReqEapFramesTx());
+        authMetricsEvent.put(INVALID_PKT_TYPE, event.subject().getInvalidPktType());
+        authMetricsEvent.put(INVALID_BODY_LENGTH, event.subject().getInvalidBodyLength());
+        authMetricsEvent.put(VALID_EAPOL_FRAMES_RX, event.subject().getValidEapolFramesRx());
+        authMetricsEvent.put(PENDING_RES_SUPPLICANT, event.subject().getPendingResSupp());
+        authMetricsEvent.put(RES_ID_EAP_FRAMES_RX, event.subject().getEapolattrIdentity());
         return authMetricsEvent;
     }
 
@@ -193,4 +211,4 @@
             handleStat(authenticationStatisticsEvent);
         }
     }
-}
\ No newline at end of file
+}