X-Git-Url: https://codewiz.org/gitweb?a=blobdiff_plain;f=kern%2Fsem.c;h=0f31fa067b9fff651945b60076adaf3e855e05f4;hb=faf2f6bfd5933ff75e6cc01e3d48f9277f731d8f;hp=05488e4c2fab64d3b057a6d9a5b5c2d526451514;hpb=00e009957d70dab15575ab310ed83f0b78cc8656;p=bertos.git diff --git a/kern/sem.c b/kern/sem.c old mode 100755 new mode 100644 index 05488e4c..0f31fa06 --- a/kern/sem.c +++ b/kern/sem.c @@ -1,9 +1,34 @@ -/*! +/** * \file * * * \brief Semaphore based synchronization services. @@ -13,38 +38,23 @@ * \author Bernardo Innocenti */ -/*#* - *#* $Log$ - *#* Revision 1.7 2004/11/28 23:20:25 bernie - *#* Remove obsolete INITLIST macro. - *#* - *#* Revision 1.6 2004/10/21 10:57:21 bernie - *#* Use proc_forbid()/proc_permit(). - *#* - *#* Revision 1.5 2004/10/21 10:48:57 bernie - *#* sem_release(): Simplify (made by rasky on scfirm). - *#* - *#* Revision 1.4 2004/08/25 14:12:09 rasky - *#* Aggiornato il comment block dei log RCS - *#* - *#* Revision 1.3 2004/08/08 05:53:23 bernie - *#* Use DISABLE_IRQSAVE/ENABLE_IRQRESTORE; Cleanup documentation. - *#* - *#* Revision 1.2 2004/06/03 11:27:09 bernie - *#* Add dual-license information. - *#* - *#* Revision 1.1 2004/05/23 17:27:00 bernie - *#* Import kern/ subdirectory. - *#*/ - #include "sem.h" -#include "proc.h" -#include "proc_p.h" -#include "signal.h" -#include "hw.h" +#include +#include +#include +#include + +INLINE void sem_verify(struct Semaphore *s) +{ + (void)s; + ASSERT(s); + LIST_ASSERT_VALID(&s->wait_queue); + ASSERT(s->nest_count >= 0); + ASSERT(s->nest_count < 128); // heuristic max +} -/*! +/** * \brief Initialize a Semaphore structure. */ void sem_init(struct Semaphore *s) @@ -55,7 +65,7 @@ void sem_init(struct Semaphore *s) } -/*! +/** * \brief Attempt to lock a semaphore without waiting. * * \return true in case of success, false if the semaphore @@ -71,6 +81,7 @@ bool sem_attempt(struct Semaphore *s) bool result = false; proc_forbid(); + sem_verify(s); if ((!s->owner) || (s->owner == CurrentProcess)) { s->owner = CurrentProcess; @@ -83,7 +94,7 @@ bool sem_attempt(struct Semaphore *s) } -/*! +/** * \brief Lock a semaphore. * * If the semaphore is already owned by another process, the caller @@ -103,6 +114,7 @@ bool sem_attempt(struct Semaphore *s) void sem_obtain(struct Semaphore *s) { proc_forbid(); + sem_verify(s); /* Is the semaphore already locked by another process? */ if (UNLIKELY(s->owner && (s->owner != CurrentProcess))) @@ -120,6 +132,8 @@ void sem_obtain(struct Semaphore *s) } else { + ASSERT(LIST_EMPTY(&s->wait_queue)); + /* The semaphore was free: lock it */ s->owner = CurrentProcess; s->nest_count++; @@ -128,7 +142,7 @@ void sem_obtain(struct Semaphore *s) } -/*! +/** * \brief Release a lock on a previously locked semaphore. * * If the nesting count of the semaphore reaches zero, @@ -144,6 +158,9 @@ void sem_obtain(struct Semaphore *s) void sem_release(struct Semaphore *s) { proc_forbid(); + sem_verify(s); + + ASSERT(s->owner == CurrentProcess); /* * Decrement nesting count and check if the semaphore @@ -157,7 +174,7 @@ void sem_release(struct Semaphore *s) s->owner = NULL; /* Give semaphore to the first applicant, if any */ - if (UNLIKELY((proc = (Process *)REMHEAD(&s->wait_queue)))) + if (UNLIKELY((proc = (Process *)list_remHead(&s->wait_queue)))) { s->nest_count = 1; s->owner = proc;