Added missing try/catch

ntop · Oct 4, 2024 · 58cabdd · 58cabdd
1 parent ee60c6e
commit 58cabdd
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/src/NetworkInterface.cpp b/src/NetworkInterface.cpp
@@ -9538,6 +9538,7 @@ bool NetworkInterface::initFlowDump(u_int8_t num_dump_interfaces) {
     return (true);
 
   if (db == NULL) {
+    try {
     if (ntop->getPrefs()->do_dump_flows_on_clickhouse()) {
 #if defined(NTOPNG_PRO) && defined(HAVE_CLICKHOUSE) && defined(HAVE_MYSQL)
       db = new (std::nothrow) ClickHouseFlowDB(this);
@@ -9561,18 +9562,21 @@ bool NetworkInterface::initFlowDump(u_int8_t num_dump_interfaces) {
     }
 #if defined(HAVE_KAFKA) && defined(NTOPNG_PRO)
     else if ((ntop->getPrefs()->getKakfaBrokersList() != NULL)) {
-      kafka = new KafkaProducer(this, ntop->getPrefs()->getKakfaBrokersList(),
-                                ntop->getPrefs()->getKafkaTopic(),
-                                ntop->getPrefs()->getKafkaOptions());
-      db = kafka;
-    }
+	kafka = new (std::nothrow) KafkaProducer(this, ntop->getPrefs()->getKakfaBrokersList(),
+						 ntop->getPrefs()->getKafkaTopic(),
+						 ntop->getPrefs()->getKafkaOptions());
+	db = kafka;
+      }
 #endif
 #if !defined(WIN32) && !defined(__APPLE__)
     else if (ntop->getPrefs()->do_dump_flows_on_syslog()) {
       db = new (std::nothrow) SyslogDump(this);
     }
 #endif
 #endif
+    } catch (...) {
+      ;
+    }
   }
 
   return (db != NULL);