Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit aef9cb05 authored by Thomas Gleixner's avatar Thomas Gleixner
Browse files

debugobjects: Convert to raw_spinlocks



Convert locks which cannot be sleeping locks in preempt-rt to
raw_spinlocks.

Signed-off-by: default avatarThomas Gleixner <tglx@linutronix.de>
Acked-by: default avatarPeter Zijlstra <peterz@infradead.org>
Acked-by: default avatarIngo Molnar <mingo@elte.hu>
parent e625cce1
Loading
Loading
Loading
Loading
+37 −37
Original line number Original line Diff line number Diff line
@@ -26,14 +26,14 @@


struct debug_bucket {
struct debug_bucket {
	struct hlist_head	list;
	struct hlist_head	list;
	spinlock_t		lock;
	raw_spinlock_t		lock;
};
};


static struct debug_bucket	obj_hash[ODEBUG_HASH_SIZE];
static struct debug_bucket	obj_hash[ODEBUG_HASH_SIZE];


static struct debug_obj		obj_static_pool[ODEBUG_POOL_SIZE] __initdata;
static struct debug_obj		obj_static_pool[ODEBUG_POOL_SIZE] __initdata;


static DEFINE_SPINLOCK(pool_lock);
static DEFINE_RAW_SPINLOCK(pool_lock);


static HLIST_HEAD(obj_pool);
static HLIST_HEAD(obj_pool);


@@ -96,10 +96,10 @@ static int fill_pool(void)
		if (!new)
		if (!new)
			return obj_pool_free;
			return obj_pool_free;


		spin_lock_irqsave(&pool_lock, flags);
		raw_spin_lock_irqsave(&pool_lock, flags);
		hlist_add_head(&new->node, &obj_pool);
		hlist_add_head(&new->node, &obj_pool);
		obj_pool_free++;
		obj_pool_free++;
		spin_unlock_irqrestore(&pool_lock, flags);
		raw_spin_unlock_irqrestore(&pool_lock, flags);
	}
	}
	return obj_pool_free;
	return obj_pool_free;
}
}
@@ -133,7 +133,7 @@ alloc_object(void *addr, struct debug_bucket *b, struct debug_obj_descr *descr)
{
{
	struct debug_obj *obj = NULL;
	struct debug_obj *obj = NULL;


	spin_lock(&pool_lock);
	raw_spin_lock(&pool_lock);
	if (obj_pool.first) {
	if (obj_pool.first) {
		obj	    = hlist_entry(obj_pool.first, typeof(*obj), node);
		obj	    = hlist_entry(obj_pool.first, typeof(*obj), node);


@@ -152,7 +152,7 @@ alloc_object(void *addr, struct debug_bucket *b, struct debug_obj_descr *descr)
		if (obj_pool_free < obj_pool_min_free)
		if (obj_pool_free < obj_pool_min_free)
			obj_pool_min_free = obj_pool_free;
			obj_pool_min_free = obj_pool_free;
	}
	}
	spin_unlock(&pool_lock);
	raw_spin_unlock(&pool_lock);


	return obj;
	return obj;
}
}
@@ -165,7 +165,7 @@ static void free_obj_work(struct work_struct *work)
	struct debug_obj *obj;
	struct debug_obj *obj;
	unsigned long flags;
	unsigned long flags;


	spin_lock_irqsave(&pool_lock, flags);
	raw_spin_lock_irqsave(&pool_lock, flags);
	while (obj_pool_free > ODEBUG_POOL_SIZE) {
	while (obj_pool_free > ODEBUG_POOL_SIZE) {
		obj = hlist_entry(obj_pool.first, typeof(*obj), node);
		obj = hlist_entry(obj_pool.first, typeof(*obj), node);
		hlist_del(&obj->node);
		hlist_del(&obj->node);
@@ -174,11 +174,11 @@ static void free_obj_work(struct work_struct *work)
		 * We release pool_lock across kmem_cache_free() to
		 * We release pool_lock across kmem_cache_free() to
		 * avoid contention on pool_lock.
		 * avoid contention on pool_lock.
		 */
		 */
		spin_unlock_irqrestore(&pool_lock, flags);
		raw_spin_unlock_irqrestore(&pool_lock, flags);
		kmem_cache_free(obj_cache, obj);
		kmem_cache_free(obj_cache, obj);
		spin_lock_irqsave(&pool_lock, flags);
		raw_spin_lock_irqsave(&pool_lock, flags);
	}
	}
	spin_unlock_irqrestore(&pool_lock, flags);
	raw_spin_unlock_irqrestore(&pool_lock, flags);
}
}


/*
/*
@@ -190,7 +190,7 @@ static void free_object(struct debug_obj *obj)
	unsigned long flags;
	unsigned long flags;
	int sched = 0;
	int sched = 0;


	spin_lock_irqsave(&pool_lock, flags);
	raw_spin_lock_irqsave(&pool_lock, flags);
	/*
	/*
	 * schedule work when the pool is filled and the cache is
	 * schedule work when the pool is filled and the cache is
	 * initialized:
	 * initialized:
@@ -200,7 +200,7 @@ static void free_object(struct debug_obj *obj)
	hlist_add_head(&obj->node, &obj_pool);
	hlist_add_head(&obj->node, &obj_pool);
	obj_pool_free++;
	obj_pool_free++;
	obj_pool_used--;
	obj_pool_used--;
	spin_unlock_irqrestore(&pool_lock, flags);
	raw_spin_unlock_irqrestore(&pool_lock, flags);
	if (sched)
	if (sched)
		schedule_work(&debug_obj_work);
		schedule_work(&debug_obj_work);
}
}
@@ -221,9 +221,9 @@ static void debug_objects_oom(void)
	printk(KERN_WARNING "ODEBUG: Out of memory. ODEBUG disabled\n");
	printk(KERN_WARNING "ODEBUG: Out of memory. ODEBUG disabled\n");


	for (i = 0; i < ODEBUG_HASH_SIZE; i++, db++) {
	for (i = 0; i < ODEBUG_HASH_SIZE; i++, db++) {
		spin_lock_irqsave(&db->lock, flags);
		raw_spin_lock_irqsave(&db->lock, flags);
		hlist_move_list(&db->list, &freelist);
		hlist_move_list(&db->list, &freelist);
		spin_unlock_irqrestore(&db->lock, flags);
		raw_spin_unlock_irqrestore(&db->lock, flags);


		/* Now free them */
		/* Now free them */
		hlist_for_each_entry_safe(obj, node, tmp, &freelist, node) {
		hlist_for_each_entry_safe(obj, node, tmp, &freelist, node) {
@@ -303,14 +303,14 @@ __debug_object_init(void *addr, struct debug_obj_descr *descr, int onstack)


	db = get_bucket((unsigned long) addr);
	db = get_bucket((unsigned long) addr);


	spin_lock_irqsave(&db->lock, flags);
	raw_spin_lock_irqsave(&db->lock, flags);


	obj = lookup_object(addr, db);
	obj = lookup_object(addr, db);
	if (!obj) {
	if (!obj) {
		obj = alloc_object(addr, db, descr);
		obj = alloc_object(addr, db, descr);
		if (!obj) {
		if (!obj) {
			debug_objects_enabled = 0;
			debug_objects_enabled = 0;
			spin_unlock_irqrestore(&db->lock, flags);
			raw_spin_unlock_irqrestore(&db->lock, flags);
			debug_objects_oom();
			debug_objects_oom();
			return;
			return;
		}
		}
@@ -327,7 +327,7 @@ __debug_object_init(void *addr, struct debug_obj_descr *descr, int onstack)
	case ODEBUG_STATE_ACTIVE:
	case ODEBUG_STATE_ACTIVE:
		debug_print_object(obj, "init");
		debug_print_object(obj, "init");
		state = obj->state;
		state = obj->state;
		spin_unlock_irqrestore(&db->lock, flags);
		raw_spin_unlock_irqrestore(&db->lock, flags);
		debug_object_fixup(descr->fixup_init, addr, state);
		debug_object_fixup(descr->fixup_init, addr, state);
		return;
		return;


@@ -338,7 +338,7 @@ __debug_object_init(void *addr, struct debug_obj_descr *descr, int onstack)
		break;
		break;
	}
	}


	spin_unlock_irqrestore(&db->lock, flags);
	raw_spin_unlock_irqrestore(&db->lock, flags);
}
}


/**
/**
@@ -385,7 +385,7 @@ void debug_object_activate(void *addr, struct debug_obj_descr *descr)


	db = get_bucket((unsigned long) addr);
	db = get_bucket((unsigned long) addr);


	spin_lock_irqsave(&db->lock, flags);
	raw_spin_lock_irqsave(&db->lock, flags);


	obj = lookup_object(addr, db);
	obj = lookup_object(addr, db);
	if (obj) {
	if (obj) {
@@ -398,7 +398,7 @@ void debug_object_activate(void *addr, struct debug_obj_descr *descr)
		case ODEBUG_STATE_ACTIVE:
		case ODEBUG_STATE_ACTIVE:
			debug_print_object(obj, "activate");
			debug_print_object(obj, "activate");
			state = obj->state;
			state = obj->state;
			spin_unlock_irqrestore(&db->lock, flags);
			raw_spin_unlock_irqrestore(&db->lock, flags);
			debug_object_fixup(descr->fixup_activate, addr, state);
			debug_object_fixup(descr->fixup_activate, addr, state);
			return;
			return;


@@ -408,11 +408,11 @@ void debug_object_activate(void *addr, struct debug_obj_descr *descr)
		default:
		default:
			break;
			break;
		}
		}
		spin_unlock_irqrestore(&db->lock, flags);
		raw_spin_unlock_irqrestore(&db->lock, flags);
		return;
		return;
	}
	}


	spin_unlock_irqrestore(&db->lock, flags);
	raw_spin_unlock_irqrestore(&db->lock, flags);
	/*
	/*
	 * This happens when a static object is activated. We
	 * This happens when a static object is activated. We
	 * let the type specific code decide whether this is
	 * let the type specific code decide whether this is
@@ -438,7 +438,7 @@ void debug_object_deactivate(void *addr, struct debug_obj_descr *descr)


	db = get_bucket((unsigned long) addr);
	db = get_bucket((unsigned long) addr);


	spin_lock_irqsave(&db->lock, flags);
	raw_spin_lock_irqsave(&db->lock, flags);


	obj = lookup_object(addr, db);
	obj = lookup_object(addr, db);
	if (obj) {
	if (obj) {
@@ -463,7 +463,7 @@ void debug_object_deactivate(void *addr, struct debug_obj_descr *descr)
		debug_print_object(&o, "deactivate");
		debug_print_object(&o, "deactivate");
	}
	}


	spin_unlock_irqrestore(&db->lock, flags);
	raw_spin_unlock_irqrestore(&db->lock, flags);
}
}


/**
/**
@@ -483,7 +483,7 @@ void debug_object_destroy(void *addr, struct debug_obj_descr *descr)


	db = get_bucket((unsigned long) addr);
	db = get_bucket((unsigned long) addr);


	spin_lock_irqsave(&db->lock, flags);
	raw_spin_lock_irqsave(&db->lock, flags);


	obj = lookup_object(addr, db);
	obj = lookup_object(addr, db);
	if (!obj)
	if (!obj)
@@ -498,7 +498,7 @@ void debug_object_destroy(void *addr, struct debug_obj_descr *descr)
	case ODEBUG_STATE_ACTIVE:
	case ODEBUG_STATE_ACTIVE:
		debug_print_object(obj, "destroy");
		debug_print_object(obj, "destroy");
		state = obj->state;
		state = obj->state;
		spin_unlock_irqrestore(&db->lock, flags);
		raw_spin_unlock_irqrestore(&db->lock, flags);
		debug_object_fixup(descr->fixup_destroy, addr, state);
		debug_object_fixup(descr->fixup_destroy, addr, state);
		return;
		return;


@@ -509,7 +509,7 @@ void debug_object_destroy(void *addr, struct debug_obj_descr *descr)
		break;
		break;
	}
	}
out_unlock:
out_unlock:
	spin_unlock_irqrestore(&db->lock, flags);
	raw_spin_unlock_irqrestore(&db->lock, flags);
}
}


/**
/**
@@ -529,7 +529,7 @@ void debug_object_free(void *addr, struct debug_obj_descr *descr)


	db = get_bucket((unsigned long) addr);
	db = get_bucket((unsigned long) addr);


	spin_lock_irqsave(&db->lock, flags);
	raw_spin_lock_irqsave(&db->lock, flags);


	obj = lookup_object(addr, db);
	obj = lookup_object(addr, db);
	if (!obj)
	if (!obj)
@@ -539,17 +539,17 @@ void debug_object_free(void *addr, struct debug_obj_descr *descr)
	case ODEBUG_STATE_ACTIVE:
	case ODEBUG_STATE_ACTIVE:
		debug_print_object(obj, "free");
		debug_print_object(obj, "free");
		state = obj->state;
		state = obj->state;
		spin_unlock_irqrestore(&db->lock, flags);
		raw_spin_unlock_irqrestore(&db->lock, flags);
		debug_object_fixup(descr->fixup_free, addr, state);
		debug_object_fixup(descr->fixup_free, addr, state);
		return;
		return;
	default:
	default:
		hlist_del(&obj->node);
		hlist_del(&obj->node);
		spin_unlock_irqrestore(&db->lock, flags);
		raw_spin_unlock_irqrestore(&db->lock, flags);
		free_object(obj);
		free_object(obj);
		return;
		return;
	}
	}
out_unlock:
out_unlock:
	spin_unlock_irqrestore(&db->lock, flags);
	raw_spin_unlock_irqrestore(&db->lock, flags);
}
}


#ifdef CONFIG_DEBUG_OBJECTS_FREE
#ifdef CONFIG_DEBUG_OBJECTS_FREE
@@ -575,7 +575,7 @@ static void __debug_check_no_obj_freed(const void *address, unsigned long size)


repeat:
repeat:
		cnt = 0;
		cnt = 0;
		spin_lock_irqsave(&db->lock, flags);
		raw_spin_lock_irqsave(&db->lock, flags);
		hlist_for_each_entry_safe(obj, node, tmp, &db->list, node) {
		hlist_for_each_entry_safe(obj, node, tmp, &db->list, node) {
			cnt++;
			cnt++;
			oaddr = (unsigned long) obj->object;
			oaddr = (unsigned long) obj->object;
@@ -587,7 +587,7 @@ static void __debug_check_no_obj_freed(const void *address, unsigned long size)
				debug_print_object(obj, "free");
				debug_print_object(obj, "free");
				descr = obj->descr;
				descr = obj->descr;
				state = obj->state;
				state = obj->state;
				spin_unlock_irqrestore(&db->lock, flags);
				raw_spin_unlock_irqrestore(&db->lock, flags);
				debug_object_fixup(descr->fixup_free,
				debug_object_fixup(descr->fixup_free,
						   (void *) oaddr, state);
						   (void *) oaddr, state);
				goto repeat;
				goto repeat;
@@ -597,7 +597,7 @@ static void __debug_check_no_obj_freed(const void *address, unsigned long size)
				break;
				break;
			}
			}
		}
		}
		spin_unlock_irqrestore(&db->lock, flags);
		raw_spin_unlock_irqrestore(&db->lock, flags);


		/* Now free them */
		/* Now free them */
		hlist_for_each_entry_safe(obj, node, tmp, &freelist, node) {
		hlist_for_each_entry_safe(obj, node, tmp, &freelist, node) {
@@ -783,7 +783,7 @@ check_results(void *addr, enum debug_obj_state state, int fixups, int warnings)


	db = get_bucket((unsigned long) addr);
	db = get_bucket((unsigned long) addr);


	spin_lock_irqsave(&db->lock, flags);
	raw_spin_lock_irqsave(&db->lock, flags);


	obj = lookup_object(addr, db);
	obj = lookup_object(addr, db);
	if (!obj && state != ODEBUG_STATE_NONE) {
	if (!obj && state != ODEBUG_STATE_NONE) {
@@ -807,7 +807,7 @@ check_results(void *addr, enum debug_obj_state state, int fixups, int warnings)
	}
	}
	res = 0;
	res = 0;
out:
out:
	spin_unlock_irqrestore(&db->lock, flags);
	raw_spin_unlock_irqrestore(&db->lock, flags);
	if (res)
	if (res)
		debug_objects_enabled = 0;
		debug_objects_enabled = 0;
	return res;
	return res;
@@ -907,7 +907,7 @@ void __init debug_objects_early_init(void)
	int i;
	int i;


	for (i = 0; i < ODEBUG_HASH_SIZE; i++)
	for (i = 0; i < ODEBUG_HASH_SIZE; i++)
		spin_lock_init(&obj_hash[i].lock);
		raw_spin_lock_init(&obj_hash[i].lock);


	for (i = 0; i < ODEBUG_POOL_SIZE; i++)
	for (i = 0; i < ODEBUG_POOL_SIZE; i++)
		hlist_add_head(&obj_static_pool[i].node, &obj_pool);
		hlist_add_head(&obj_static_pool[i].node, &obj_pool);