BNX2X: spatch signed typedefs
[akaros.git] / kern / src / atomic.c
index a413d24..cc73a71 100644 (file)
@@ -26,6 +26,34 @@ static void decrease_lock_depth(uint32_t coreid)
 }
 
 #ifdef CONFIG_SPINLOCK_DEBUG
+
+/* Put locks you want to ignore here. */
+static uintptr_t blacklist_locks[] = {
+       //0xffffffffc03bd000,
+};
+
+/* Could do this on the output side, though noisly locks will crowd us out */
+static bool can_trace(spinlock_t *lock)
+{
+       for (int i = 0; i < ARRAY_SIZE(blacklist_locks); i++) {
+               if (blacklist_locks[i] == (uintptr_t)lock)
+                       return FALSE;
+       }
+       return TRUE;
+}
+
+/* spinlock and trylock call this after locking */
+static void post_lock(spinlock_t *lock, uint32_t coreid)
+{
+       struct per_cpu_info *pcpui = &per_cpu_info[coreid];
+       if ((pcpui->__lock_checking_enabled == 1) && can_trace(lock))
+               pcpui_trace_locks(pcpui, lock);
+       lock->call_site = get_caller_pc();
+       lock->calling_core = coreid;
+       /* TODO consider merging this with __ctx_depth (unused field) */
+       increase_lock_depth(lock->calling_core);
+}
+
 void spin_lock(spinlock_t *lock)
 {
        uint32_t coreid = core_id_early();
@@ -52,17 +80,26 @@ void spin_lock(spinlock_t *lock)
        }
 lock:
        __spin_lock(lock);
-       lock->call_site = get_caller_pc();
-       lock->calling_core = coreid;
-       /* TODO consider merging this with __ctx_depth (unused field) */
-       increase_lock_depth(lock->calling_core);
        /* Memory barriers are handled by the particular arches */
+       post_lock(lock, coreid);
+}
+
+/* Trylock doesn't check for irq/noirq, in case we want to try and lock a
+ * non-irqsave lock from irq context. */
+bool spin_trylock(spinlock_t *lock)
+{
+       uint32_t coreid = core_id_early();
+       bool ret = __spin_trylock(lock);
+       if (ret)
+               post_lock(lock, coreid);
+       return ret;
 }
 
 void spin_unlock(spinlock_t *lock)
 {
        decrease_lock_depth(lock->calling_core);
        /* Memory barriers are handled by the particular arches */
+       assert(spin_locked(lock));
        __spin_unlock(lock);
 }
 
@@ -76,8 +113,9 @@ void spinlock_debug(spinlock_t *lock)
                return;
        }
        func_name = get_fn_name(pc);
-       printk("Lock %p: last locked at [<%p>] in %s on core %d\n", lock, pc,
-              func_name, lock->calling_core);
+       printk("Lock %p: currently %slocked.  Last locked at [<%p>] in %s on "
+              "core %d\n", lock, spin_locked(lock) ? "" : "un", pc, func_name,
+              lock->calling_core);
        kfree(func_name);
 }
 
@@ -263,6 +301,12 @@ int checklist_is_clear(checklist_t* list)
        return BITMASK_IS_CLEAR(list->mask.bits, list->mask.size);
 }
 
+// no synch guarantees - just looks at the list
+int checklist_is_full(checklist_t* list)
+{
+       return BITMASK_IS_FULL(list->mask.bits, list->mask.size);
+}
+
 // no synch guarantees - just resets the list to empty
 void reset_checklist(checklist_t* list)
 {