Implements Autonomous Systems hash table

2026-05-12 04:09:03 +00:00 · 2017-04-19 23:19:16 +02:00 · 2017-04-19 23:19:16 +02:00 · 5014669d12
commit 5014669d12
parent fa8b3f7f37
22 changed files with 768 additions and 61 deletions
--- a/src/AutonomousSystem.cpp
+++ b/src/AutonomousSystem.cpp
@ -0,0 +1,105 @@
+/*
+ *
+ * (C) 2013-17 - ntop.org
+ *
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
+ *
+ */
+
+#include "ntop_includes.h"
+
+/* *************************************** */
+
+AutonomousSystem::AutonomousSystem(NetworkInterface *_iface, IpAddress *ipa) : GenericHashEntry(_iface), GenericTrafficElement() {
+  asname = NULL;
+  ntop->getGeolocation()->getAS(ipa, &asn, &asname);
+
+  if(iface->getTimeLastPktRcvd() > 0)
+    first_seen = last_seen = iface->getTimeLastPktRcvd();
+  else
+    first_seen = last_seen = time(NULL);
+
+#ifdef AS_DEBUG
+  ntop->getTrace()->traceEvent(TRACE_NORMAL, "Created Autonomous System %u", asn);
+#endif
+}
+
+/* *************************************** */
+
+AutonomousSystem::~AutonomousSystem() {
+  if(asname) free(asname);
+  /* TODO: decide if it is useful to dump AS stats to redis */
+#ifdef AS_DEBUG
+  ntop->getTrace()->traceEvent(TRACE_NORMAL, "Deleted Autonomous System %u", asn);
+#endif
+}
+
+/* *************************************** */
+
+bool AutonomousSystem::idle() {
+  bool rc;
+  
+  if((num_uses > 0) || (!iface->is_purge_idle_interface()))
+    return(false);
+
+  rc = isIdle(MAX_LOCAL_HOST_IDLE);
+
+#ifdef AS_DEBUG
+  ntop->getTrace()->traceEvent(TRACE_NORMAL, " Autonomous System %u is idle [uses %u][%s][last: %u][diff: %d]",
+			       asn, num_uses,
+			       rc ? "Idle" : "Not Idle",
+			       last_seen, iface->getTimeLastPktRcvd() - (last_seen+MAX_LOCAL_HOST_IDLE));
+#endif
+
+  return(rc);
+}
+
+/* *************************************** */
+
+void AutonomousSystem::lua(lua_State* vm, DetailsLevel details_level, bool asListElement) {
+  lua_newtable(vm);
+
+  lua_push_int_table_entry(vm, "asn", asn);
+  lua_push_str_table_entry(vm, "asname", asname ? asname : (char*)"");
+
+  lua_push_int_table_entry(vm, "bytes.sent", sent.getNumBytes());
+  lua_push_int_table_entry(vm, "bytes.rcvd", rcvd.getNumBytes());
+
+  if(details_level >= details_high) {
+    ((GenericTrafficElement*)this)->lua(vm, true);
+
+    if(details_level >= details_higher)
+      if(ndpiStats) ndpiStats->lua(iface, vm);
+  }
+
+  lua_push_int_table_entry(vm, "seen.first", first_seen);
+  lua_push_int_table_entry(vm, "seen.last", last_seen);
+  lua_push_int_table_entry(vm, "duration", get_duration());
+
+  lua_push_int_table_entry(vm,   "num_hosts", getNumHosts());
+
+  if(asListElement) {
+    lua_pushnumber(vm, asn);
+    lua_insert(vm, -2);
+    lua_settable(vm, -3);
+  }
+}
+
+/* *************************************** */
+
+bool AutonomousSystem::equal(u_int32_t _asn) {
+  return(asn == _asn);
+}