scottk/wlan-cloud-opensync-controller
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-opensync-controller.git synced 2025-11-06 21:47:56 +00:00
Code Issues Packages Projects Releases 1 Wiki Activity

Client Session update handling, only for client entries without null values

Browse Source
This commit is contained in:
Mike Hansen
2020-06-30 14:32:30 -04:00
parent d81b636632
commit b893590b0e
1 changed files with 9 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
opensync-ext-cloud/src/main/java/com/telecominfraproject/wlan/opensync/external/integration/OpensyncExternalIntegrationCloud.java vendored
View File

@@ -1244,8 +1244,7 @@ public class OpensyncExternalIntegrationCloud implements OpensyncExternalIntegra
try try
{ {
LOG.info("handleClientSessionUpdate for {} on BSSID {}", client, LOG.info("handleClientSessionUpdate for {} on BSSID {}", client, bssidAddress);
bssidAddress);
com.telecominfraproject.wlan.client.models.Client clientInstance = clientServiceInterface com.telecominfraproject.wlan.client.models.Client clientInstance = clientServiceInterface
.getOrNull(customerId, new MacAddress(client.getMacAddress())); .getOrNull(customerId, new MacAddress(client.getMacAddress()));
@@ -1274,7 +1273,7 @@ public class OpensyncExternalIntegrationCloud implements OpensyncExternalIntegra
} }
ClientSession clientSession = clientServiceInterface.getSessionOrNull(customerId, equipmentId, ClientSession clientSession = clientServiceInterface.getSessionOrNull(customerId, equipmentId,
bssidAddress); clientInstance.getMacAddress());
// For this session if we have a disconnected client, remove, else // For this session if we have a disconnected client, remove, else
// update // update
if (!client.getConnected()) { if (!client.getConnected()) {
@@ -1481,9 +1480,12 @@ public class OpensyncExternalIntegrationCloud implements OpensyncExternalIntegra
} }
try { try {
handleClientSessionUpdate(customerId, equipmentId, apId, locationId, clientReport.getChannel(), if (ssidStatistics.getBssid() != null && ssidStatistics.getSsid() != null
clientReport.getBand(), clientReport.getTimestampMs(), client, report.getNodeID(), && client.getMacAddress() != null) {
ssidStatistics.getBssid(), ssidStatistics.getSsid()); handleClientSessionUpdate(customerId, equipmentId, apId, locationId,
clientReport.getChannel(), clientReport.getBand(), clientReport.getTimestampMs(),
client, report.getNodeID(), ssidStatistics.getBssid(), ssidStatistics.getSsid());
}
} catch (Exception e) { } catch (Exception e) {
LOG.debug("Unabled to update client {} session {}", client, e); LOG.debug("Unabled to update client {} session {}", client, e);
} }
@@ -1992,7 +1994,7 @@ public class OpensyncExternalIntegrationCloud implements OpensyncExternalIntegra
@Override @Override
public void wifiInetStateDbTableUpdate(List<OpensyncAPInetState> inetStateTables, String apId) { public void wifiInetStateDbTableUpdate(List<OpensyncAPInetState> inetStateTables, String apId) {
LOG.debug("Received Wifi_Inet_State table update for AP {}", apId); LOG.debug("Received Wifi_Inet_State table update for AP {}", apId);
OvsdbSession ovsdbSession = ovsdbSessionMapInterface.getSession(apId); OvsdbSession ovsdbSession = ovsdbSessionMapInterface.getSession(apId);