commit e66466ad33ebf69e4498b8adadb8c60e24019901
author Andrea Campanella <andrea@opennetworking.org> Mon Feb 03 14:05:45 2020 +0000
committer Andrea Campanella <andrea@opennetworking.org> Mon Feb 10 10:38:03 2020 +0100
tree ea967ca7cc35340a34bdb0b3753117a346c012ea
parent 064084cc34d80a9513d4eb321fe08a25e6f78a3c

[SEBA-935] Including session timeout scenario of authentication session level statistics

Change-Id: Ibed87f4d028104f79ab5337ff369277a5882b266

app/src/main/java/org/opencord/aaa/impl/AaaManager.java

diff --git a/app/src/main/java/org/opencord/aaa/impl/AaaManager.java b/app/src/main/java/org/opencord/aaa/impl/AaaManager.java
index 2ba48ae..ee339e4 100644
--- a/app/src/main/java/org/opencord/aaa/impl/AaaManager.java
+++ b/app/src/main/java/org/opencord/aaa/impl/AaaManager.java
@@ -951,6 +951,14 @@
     private void handleStateMachineTimeout(ConnectPoint supplicantConnectPoint) {
         StateMachine stateMachine = stateMachines.remove(sessionId(supplicantConnectPoint));
 
+        //pushing captured machine stats to kafka
+        stateMachine.setSessionTerminateReason("Time out");
+        AaaSupplicantMachineStats obj = aaaSupplicantStatsManager
+                .getSupplicantStats(stateMachine);
+        aaaSupplicantStatsManager.getMachineStatsDelegate()
+                .notify(new AaaMachineStatisticsEvent(
+                        AaaMachineStatisticsEvent.Type.STATS_UPDATE, obj));
+
         if (stateMachine.state() == StateMachine.STATE_PENDING && stateMachine.isWaitingForRadiusResponse()) {
             aaaStatisticsManager.getAaaStats().increaseTimedOutPackets();
         }