Parcourir la source

qcacmn: Use qdf_tracker for nbuf mapping

qdf_tracker generically implements all of the logic necessary to
implement the qdf_nbuf map tracking. Rather than using the current
custom tracking solution for qdf_nbuf map tracking, use qdf_tracker
instead.

Change-Id: Id33138a9035653b45c66b712bd11e54873266a17
CRs-Fixed: 2425623
Rajeev Kumar il y a 6 ans
Parent
commit
ad8457136c
2 fichiers modifiés avec 33 ajouts et 126 suppressions
  1. 32 125
      qdf/linux/src/qdf_nbuf.c
  2. 1 1
      qdf/src/qdf_tracker.c

+ 32 - 125
qdf/linux/src/qdf_nbuf.c

@@ -28,20 +28,18 @@
 #include <linux/module.h>
 #include <linux/proc_fs.h>
 #include <qdf_atomic.h>
-#include <qdf_types.h>
-#include <qdf_nbuf.h>
-#include "qdf_flex_mem.h"
+#include <qdf_debugfs.h>
+#include <qdf_lock.h>
 #include <qdf_mem.h>
+#include <qdf_module.h>
+#include <qdf_nbuf.h>
 #include <qdf_status.h>
-#include <qdf_lock.h>
+#include "qdf_str.h"
 #include <qdf_trace.h>
-#include <qdf_debugfs.h>
+#include "qdf_tracker.h"
+#include <qdf_types.h>
 #include <net/ieee80211_radiotap.h>
-#include <qdf_module.h>
-#include <qdf_atomic.h>
 #include <pld_common.h>
-#include <qdf_module.h>
-#include "qdf_str.h"
 
 #if defined(FEATURE_TSO)
 #include <net/ipv6.h>
@@ -583,105 +581,28 @@ qdf_nbuf_history_add(qdf_nbuf_t nbuf, const char *func, uint32_t line,
 #endif /* NBUF_MEMORY_DEBUG */
 
 #ifdef NBUF_MAP_UNMAP_DEBUG
-struct qdf_nbuf_map_metadata {
-	struct hlist_node node;
-	qdf_nbuf_t nbuf;
-	char func[QDF_MEM_FUNC_NAME_SIZE];
-	uint32_t line;
-};
-
-DEFINE_QDF_FLEX_MEM_POOL(qdf_nbuf_map_pool,
-			 sizeof(struct qdf_nbuf_map_metadata), 0);
-#define QDF_NBUF_MAP_HT_BITS 10 /* 1024 buckets */
-static DECLARE_HASHTABLE(qdf_nbuf_map_ht, QDF_NBUF_MAP_HT_BITS);
-static qdf_spinlock_t qdf_nbuf_map_lock;
+#define qdf_nbuf_map_tracker_bits 11 /* 2048 buckets */
+qdf_tracker_declare(qdf_nbuf_map_tracker, qdf_nbuf_map_tracker_bits,
+		    "nbuf map-no-unmap events", "nbuf map", "nbuf unmap");
 
 static void qdf_nbuf_map_tracking_init(void)
 {
-	qdf_flex_mem_init(&qdf_nbuf_map_pool);
-	hash_init(qdf_nbuf_map_ht);
-	qdf_spinlock_create(&qdf_nbuf_map_lock);
-}
-
-static void qdf_nbuf_map_leaks_print(void)
-{
-	struct qdf_nbuf_map_metadata *meta;
-	int bucket;
-	uint32_t count = 0;
-
-	QDF_BUG(qdf_spin_is_locked(&qdf_nbuf_map_lock));
-
-	qdf_nofl_alert("Nbuf map-no-unmap events detected!");
-	qdf_nofl_alert("-----------------------------------------------------");
-
-	hash_for_each(qdf_nbuf_map_ht, bucket, meta, node) {
-		count++;
-		qdf_nofl_alert("0x%zx @ %s:%u",
-			       (uintptr_t)meta->nbuf, meta->func, meta->line);
-	}
-
-	QDF_DEBUG_PANIC("%u fatal nbuf map-no-unmap events detected!", count);
-}
-
-void qdf_nbuf_map_check_for_leaks(void)
-{
-	qdf_spin_lock_irqsave(&qdf_nbuf_map_lock);
-	if (!hash_empty(qdf_nbuf_map_ht))
-		qdf_nbuf_map_leaks_print();
-	qdf_spin_unlock_irqrestore(&qdf_nbuf_map_lock);
+	qdf_tracker_init(&qdf_nbuf_map_tracker);
 }
 
 static void qdf_nbuf_map_tracking_deinit(void)
 {
-	qdf_nbuf_map_check_for_leaks();
-	qdf_spinlock_destroy(&qdf_nbuf_map_lock);
-	qdf_flex_mem_deinit(&qdf_nbuf_map_pool);
-}
-
-static struct qdf_nbuf_map_metadata *qdf_nbuf_meta_get(qdf_nbuf_t nbuf)
-{
-	struct qdf_nbuf_map_metadata *meta;
-
-	hash_for_each_possible(qdf_nbuf_map_ht, meta, node, (size_t)nbuf) {
-		if (meta->nbuf == nbuf)
-			return meta;
-	}
-
-	return NULL;
+	qdf_tracker_deinit(&qdf_nbuf_map_tracker);
 }
 
 static QDF_STATUS
 qdf_nbuf_track_map(qdf_nbuf_t nbuf, const char *func, uint32_t line)
 {
-	struct qdf_nbuf_map_metadata *meta;
-
-	QDF_BUG(nbuf);
-	if (!nbuf) {
-		qdf_err("Cannot map null nbuf");
-		return QDF_STATUS_E_INVAL;
-	}
-
-	qdf_spin_lock_irqsave(&qdf_nbuf_map_lock);
-	meta = qdf_nbuf_meta_get(nbuf);
-	qdf_spin_unlock_irqrestore(&qdf_nbuf_map_lock);
-	if (meta)
-		QDF_DEBUG_PANIC(
-			"Double nbuf map detected @ %s:%u; last map from %s:%u",
-			func, line, meta->func, meta->line);
-
-	meta = qdf_flex_mem_alloc(&qdf_nbuf_map_pool);
-	if (!meta) {
-		qdf_err("Failed to allocate nbuf map tracking metadata");
-		return QDF_STATUS_E_NOMEM;
-	}
-
-	meta->nbuf = nbuf;
-	qdf_str_lcopy(meta->func, func, QDF_MEM_FUNC_NAME_SIZE);
-	meta->line = line;
+	QDF_STATUS status;
 
-	qdf_spin_lock_irqsave(&qdf_nbuf_map_lock);
-	hash_add(qdf_nbuf_map_ht, &meta->node, (size_t)nbuf);
-	qdf_spin_unlock_irqrestore(&qdf_nbuf_map_lock);
+	status = qdf_tracker_track(&qdf_nbuf_map_tracker, nbuf, func, line);
+	if (QDF_IS_STATUS_ERROR(status))
+		return status;
 
 	qdf_nbuf_history_add(nbuf, func, line, QDF_NBUF_MAP);
 
@@ -691,28 +612,13 @@ qdf_nbuf_track_map(qdf_nbuf_t nbuf, const char *func, uint32_t line)
 static void
 qdf_nbuf_untrack_map(qdf_nbuf_t nbuf, const char *func, uint32_t line)
 {
-	struct qdf_nbuf_map_metadata *meta;
-
-	QDF_BUG(nbuf);
-	if (!nbuf) {
-		qdf_err("Cannot unmap null nbuf");
-		return;
-	}
-
-	qdf_spin_lock_irqsave(&qdf_nbuf_map_lock);
-	meta = qdf_nbuf_meta_get(nbuf);
-
-	if (!meta)
-		QDF_DEBUG_PANIC(
-		      "Double nbuf unmap or unmap without map detected @ %s:%u",
-		      func, line);
-
-	hash_del(&meta->node);
-	qdf_spin_unlock_irqrestore(&qdf_nbuf_map_lock);
-
-	qdf_flex_mem_free(&qdf_nbuf_map_pool, meta);
-
 	qdf_nbuf_history_add(nbuf, func, line, QDF_NBUF_UNMAP);
+	qdf_tracker_untrack(&qdf_nbuf_map_tracker, nbuf, func, line);
+}
+
+void qdf_nbuf_map_check_for_leaks(void)
+{
+	qdf_tracker_check_for_leaks(&qdf_nbuf_map_tracker);
 }
 
 QDF_STATUS qdf_nbuf_map_debug(qdf_device_t osdev,
@@ -851,18 +757,19 @@ void qdf_nbuf_unmap_nbytes_single_debug(qdf_device_t osdev,
 
 qdf_export_symbol(qdf_nbuf_unmap_nbytes_single_debug);
 
-static void qdf_nbuf_panic_on_free_if_mapped(qdf_nbuf_t nbuf, const char *func,
+static void qdf_nbuf_panic_on_free_if_mapped(qdf_nbuf_t nbuf,
+					     const char *func,
 					     uint32_t line)
 {
-	struct qdf_nbuf_map_metadata *meta;
+	char map_func[QDF_TRACKER_FUNC_SIZE];
+	uint32_t map_line;
+
+	if (!qdf_tracker_lookup(&qdf_nbuf_map_tracker, nbuf,
+				&map_func, &map_line))
+		return;
 
-	qdf_spin_lock_irqsave(&qdf_nbuf_map_lock);
-	meta = qdf_nbuf_meta_get(nbuf);
-	if (meta)
-		QDF_DEBUG_PANIC(
-			"Nbuf freed @ %s:%u while mapped from %s:%u",
-			kbasename(func), line, meta->func, meta->line);
-	qdf_spin_unlock_irqrestore(&qdf_nbuf_map_lock);
+	QDF_DEBUG_PANIC("Nbuf freed @ %s:%u while mapped from %s:%u",
+			func, line, map_func, map_line);
 }
 #else
 static inline void qdf_nbuf_map_tracking_init(void)

+ 1 - 1
qdf/src/qdf_tracker.c

@@ -81,7 +81,7 @@ static uint32_t qdf_tracker_leaks_print(struct qdf_tracker *tracker,
 		}
 
 		count++;
-		qdf_nofl_alert("0x%zx @ %s:%u", node->entry.key,
+		qdf_nofl_alert("0x%lx @ %s:%u", node->entry.key,
 			       node->func, node->line);
 	}