| /branches/dd/kernel/generic/include/synch/spinlock.h |
|---|
| 0,0 → 1,142 |
| /* |
| * Copyright (c) 2001-2004 Jakub Jermar |
| * All rights reserved. |
| * |
| * Redistribution and use in source and binary forms, with or without |
| * modification, are permitted provided that the following conditions |
| * are met: |
| * |
| * - Redistributions of source code must retain the above copyright |
| * notice, this list of conditions and the following disclaimer. |
| * - Redistributions in binary form must reproduce the above copyright |
| * notice, this list of conditions and the following disclaimer in the |
| * documentation and/or other materials provided with the distribution. |
| * - The name of the author may not be used to endorse or promote products |
| * derived from this software without specific prior written permission. |
| * |
| * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR |
| * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |
| * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
| * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, |
| * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT |
| * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF |
| * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| */ |
| /** @addtogroup sync |
| * @{ |
| */ |
| /** @file |
| */ |
| #ifndef KERN_SPINLOCK_H_ |
| #define KERN_SPINLOCK_H_ |
| #include <arch/types.h> |
| #include <preemption.h> |
| #include <atomic.h> |
| #include <debug.h> |
| #ifdef CONFIG_SMP |
| typedef struct { |
| #ifdef CONFIG_DEBUG_SPINLOCK |
| char *name; |
| #endif |
| atomic_t val; |
| } spinlock_t; |
| /* |
| * SPINLOCK_DECLARE is to be used for dynamically allocated spinlocks, |
| * where the lock gets initialized in run time. |
| */ |
| #define SPINLOCK_DECLARE(slname) spinlock_t slname |
| #define SPINLOCK_EXTERN(slname) extern spinlock_t slname |
| /* |
| * SPINLOCK_INITIALIZE is to be used for statically allocated spinlocks. |
| * It declares and initializes the lock. |
| */ |
| #ifdef CONFIG_DEBUG_SPINLOCK |
| #define SPINLOCK_INITIALIZE(slname) \ |
| spinlock_t slname = { \ |
| .name = #slname, \ |
| .val = { 0 } \ |
| } |
| #else |
| #define SPINLOCK_INITIALIZE(slname) \ |
| spinlock_t slname = { \ |
| .val = { 0 } \ |
| } |
| #endif |
| extern void spinlock_initialize(spinlock_t *sl, char *name); |
| extern int spinlock_trylock(spinlock_t *sl); |
| extern void spinlock_lock_debug(spinlock_t *sl); |
| #ifdef CONFIG_DEBUG_SPINLOCK |
| # define spinlock_lock(x) spinlock_lock_debug(x) |
| #else |
| # define spinlock_lock(x) atomic_lock_arch(&(x)->val) |
| #endif |
| /** Unlock spinlock |
| * |
| * Unlock spinlock. |
| * |
| * @param sl Pointer to spinlock_t structure. |
| */ |
| static inline void spinlock_unlock(spinlock_t *sl) |
| { |
| ASSERT(atomic_get(&sl->val) != 0); |
| /* |
| * Prevent critical section code from bleeding out this way down. |
| */ |
| CS_LEAVE_BARRIER(); |
| atomic_set(&sl->val, 0); |
| preemption_enable(); |
| } |
| #ifdef CONFIG_DEBUG_SPINLOCK |
| extern int printf(const char *, ...); |
| #define DEADLOCK_THRESHOLD 100000000 |
| #define DEADLOCK_PROBE_INIT(pname) count_t pname = 0 |
| #define DEADLOCK_PROBE(pname, value) \ |
| if ((pname)++ > (value)) { \ |
| (pname) = 0; \ |
| printf("Deadlock probe %s: exceeded threshold %d\n", \ |
| "cpu%d: function=%s, line=%d\n", \ |
| #pname, (value), CPU->id, __func__, __LINE__); \ |
| } |
| #else |
| #define DEADLOCK_PROBE_INIT(pname) |
| #define DEADLOCK_PROBE(pname, value) |
| #endif |
| #else |
| /* On UP systems, spinlocks are effectively left out. */ |
| #define SPINLOCK_DECLARE(name) |
| #define SPINLOCK_EXTERN(name) |
| #define SPINLOCK_INITIALIZE(name) |
| #define spinlock_initialize(x, name) |
| #define spinlock_lock(x) preemption_disable() |
| #define spinlock_trylock(x) (preemption_disable(), 1) |
| #define spinlock_unlock(x) preemption_enable() |
| #define DEADLOCK_PROBE_INIT(pname) |
| #define DEADLOCK_PROBE(pname, value) |
| #endif |
| #endif |
| /** @} |
| */ |
| /branches/dd/kernel/generic/include/synch/waitq.h |
|---|
| 0,0 → 1,82 |
| /* |
| * Copyright (c) 2001-2004 Jakub Jermar |
| * All rights reserved. |
| * |
| * Redistribution and use in source and binary forms, with or without |
| * modification, are permitted provided that the following conditions |
| * are met: |
| * |
| * - Redistributions of source code must retain the above copyright |
| * notice, this list of conditions and the following disclaimer. |
| * - Redistributions in binary form must reproduce the above copyright |
| * notice, this list of conditions and the following disclaimer in the |
| * documentation and/or other materials provided with the distribution. |
| * - The name of the author may not be used to endorse or promote products |
| * derived from this software without specific prior written permission. |
| * |
| * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR |
| * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |
| * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
| * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, |
| * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT |
| * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF |
| * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| */ |
| /** @addtogroup sync |
| * @{ |
| */ |
| /** @file |
| */ |
| #ifndef KERN_WAITQ_H_ |
| #define KERN_WAITQ_H_ |
| #include <arch/types.h> |
| #include <synch/spinlock.h> |
| #include <synch/synch.h> |
| #include <adt/list.h> |
| typedef enum { |
| WAKEUP_FIRST = 0, |
| WAKEUP_ALL |
| } wakeup_mode_t; |
| /** Wait queue structure. */ |
| typedef struct { |
| /** Lock protecting wait queue structure. |
| * |
| * Must be acquired before T.lock for each T of type thread_t. |
| */ |
| SPINLOCK_DECLARE(lock); |
| /** |
| * Number of waitq_wakeup() calls that didn't find a thread to wake up. |
| */ |
| int missed_wakeups; |
| /** List of sleeping threads for wich there was no missed_wakeup. */ |
| link_t head; |
| } waitq_t; |
| #define waitq_sleep(wq) \ |
| waitq_sleep_timeout((wq), SYNCH_NO_TIMEOUT, SYNCH_FLAGS_NONE) |
| struct thread; |
| extern void waitq_initialize(waitq_t *wq); |
| extern int waitq_sleep_timeout(waitq_t *wq, uint32_t usec, int flags); |
| extern ipl_t waitq_sleep_prepare(waitq_t *wq); |
| extern int waitq_sleep_timeout_unsafe(waitq_t *wq, uint32_t usec, int flags); |
| extern void waitq_sleep_finish(waitq_t *wq, int rc, ipl_t ipl); |
| extern void waitq_wakeup(waitq_t *wq, wakeup_mode_t mode); |
| extern void _waitq_wakeup_unsafe(waitq_t *wq, wakeup_mode_t mode); |
| extern void waitq_interrupt_sleep(struct thread *t); |
| #endif |
| /** @} |
| */ |
| /branches/dd/kernel/generic/include/synch/mutex.h |
|---|
| 0,0 → 1,60 |
| /* |
| * Copyright (c) 2001-2004 Jakub Jermar |
| * All rights reserved. |
| * |
| * Redistribution and use in source and binary forms, with or without |
| * modification, are permitted provided that the following conditions |
| * are met: |
| * |
| * - Redistributions of source code must retain the above copyright |
| * notice, this list of conditions and the following disclaimer. |
| * - Redistributions in binary form must reproduce the above copyright |
| * notice, this list of conditions and the following disclaimer in the |
| * documentation and/or other materials provided with the distribution. |
| * - The name of the author may not be used to endorse or promote products |
| * derived from this software without specific prior written permission. |
| * |
| * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR |
| * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |
| * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
| * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, |
| * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT |
| * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF |
| * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| */ |
| /** @addtogroup sync |
| * @{ |
| */ |
| /** @file |
| */ |
| #ifndef KERN_MUTEX_H_ |
| #define KERN_MUTEX_H_ |
| #include <arch/types.h> |
| #include <synch/semaphore.h> |
| #include <synch/synch.h> |
| typedef struct { |
| semaphore_t sem; |
| } mutex_t; |
| #define mutex_lock(mtx) \ |
| _mutex_lock_timeout((mtx), SYNCH_NO_TIMEOUT, SYNCH_FLAGS_NONE) |
| #define mutex_trylock(mtx) \ |
| _mutex_lock_timeout((mtx), SYNCH_NO_TIMEOUT, SYNCH_FLAGS_NON_BLOCKING) |
| #define mutex_lock_timeout(mtx, usec) \ |
| _mutex_lock_timeout((mtx), (usec), SYNCH_FLAGS_NON_BLOCKING) |
| extern void mutex_initialize(mutex_t *mtx); |
| extern int _mutex_lock_timeout(mutex_t *mtx, uint32_t usec, int flags); |
| extern void mutex_unlock(mutex_t *mtx); |
| #endif |
| /** @} |
| */ |
| /branches/dd/kernel/generic/include/synch/futex.h |
|---|
| 0,0 → 1,65 |
| /* |
| * Copyright (c) 2006 Jakub Jermar |
| * All rights reserved. |
| * |
| * Redistribution and use in source and binary forms, with or without |
| * modification, are permitted provided that the following conditions |
| * are met: |
| * |
| * - Redistributions of source code must retain the above copyright |
| * notice, this list of conditions and the following disclaimer. |
| * - Redistributions in binary form must reproduce the above copyright |
| * notice, this list of conditions and the following disclaimer in the |
| * documentation and/or other materials provided with the distribution. |
| * - The name of the author may not be used to endorse or promote products |
| * derived from this software without specific prior written permission. |
| * |
| * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR |
| * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |
| * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
| * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, |
| * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT |
| * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF |
| * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| */ |
| /** @addtogroup sync |
| * @{ |
| */ |
| /** @file |
| */ |
| #ifndef KERN_FUTEX_H_ |
| #define KERN_FUTEX_H_ |
| #include <arch/types.h> |
| #include <synch/waitq.h> |
| #include <genarch/mm/page_ht.h> |
| #include <genarch/mm/page_pt.h> |
| /** Kernel-side futex structure. */ |
| typedef struct { |
| /** Physical address of the status variable. */ |
| uintptr_t paddr; |
| /** Wait queue for threads waiting for futex availability. */ |
| waitq_t wq; |
| /** Futex hash table link. */ |
| link_t ht_link; |
| /** Number of tasks that reference this futex. */ |
| count_t refcount; |
| } futex_t; |
| extern void futex_init(void); |
| extern unative_t sys_futex_sleep_timeout(uintptr_t uaddr, uint32_t usec, |
| int flags); |
| extern unative_t sys_futex_wakeup(uintptr_t uaddr); |
| extern void futex_cleanup(void); |
| #endif |
| /** @} |
| */ |
| /branches/dd/kernel/generic/include/synch/condvar.h |
|---|
| 0,0 → 1,61 |
| /* |
| * Copyright (c) 2001-2004 Jakub Jermar |
| * All rights reserved. |
| * |
| * Redistribution and use in source and binary forms, with or without |
| * modification, are permitted provided that the following conditions |
| * are met: |
| * |
| * - Redistributions of source code must retain the above copyright |
| * notice, this list of conditions and the following disclaimer. |
| * - Redistributions in binary form must reproduce the above copyright |
| * notice, this list of conditions and the following disclaimer in the |
| * documentation and/or other materials provided with the distribution. |
| * - The name of the author may not be used to endorse or promote products |
| * derived from this software without specific prior written permission. |
| * |
| * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR |
| * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |
| * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
| * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, |
| * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT |
| * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF |
| * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| */ |
| /** @addtogroup sync |
| * @{ |
| */ |
| /** @file |
| */ |
| #ifndef KERN_CONDVAR_H_ |
| #define KERN_CONDVAR_H_ |
| #include <arch/types.h> |
| #include <synch/waitq.h> |
| #include <synch/mutex.h> |
| #include <synch/synch.h> |
| typedef struct { |
| waitq_t wq; |
| } condvar_t; |
| #define condvar_wait(cv, mtx) \ |
| _condvar_wait_timeout((cv), (mtx), SYNCH_NO_TIMEOUT, SYNCH_FLAGS_NONE) |
| #define condvar_wait_timeout(cv, mtx, usec) \ |
| _condvar_wait_timeout((cv), (mtx), (usec), SYNCH_FLAGS_NONE) |
| extern void condvar_initialize(condvar_t *cv); |
| extern void condvar_signal(condvar_t *cv); |
| extern void condvar_broadcast(condvar_t *cv); |
| extern int _condvar_wait_timeout(condvar_t *cv, mutex_t *mtx, uint32_t usec, |
| int flags); |
| #endif |
| /** @} |
| */ |
| /branches/dd/kernel/generic/include/synch/rwlock.h |
|---|
| 0,0 → 1,83 |
| /* |
| * Copyright (c) 2001-2004 Jakub Jermar |
| * All rights reserved. |
| * |
| * Redistribution and use in source and binary forms, with or without |
| * modification, are permitted provided that the following conditions |
| * are met: |
| * |
| * - Redistributions of source code must retain the above copyright |
| * notice, this list of conditions and the following disclaimer. |
| * - Redistributions in binary form must reproduce the above copyright |
| * notice, this list of conditions and the following disclaimer in the |
| * documentation and/or other materials provided with the distribution. |
| * - The name of the author may not be used to endorse or promote products |
| * derived from this software without specific prior written permission. |
| * |
| * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR |
| * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |
| * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
| * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, |
| * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT |
| * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF |
| * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| */ |
| /** @addtogroup sync |
| * @{ |
| */ |
| /** @file |
| */ |
| #ifndef KERN_RWLOCK_H_ |
| #define KERN_RWLOCK_H_ |
| #include <arch/types.h> |
| #include <synch/mutex.h> |
| #include <synch/synch.h> |
| #include <synch/spinlock.h> |
| typedef enum { |
| RWLOCK_NONE, |
| RWLOCK_READER, |
| RWLOCK_WRITER |
| } rwlock_type_t; |
| typedef struct { |
| SPINLOCK_DECLARE(lock); |
| /** |
| * Mutex for writers, readers can bypass it if readers_in is positive. |
| */ |
| mutex_t exclusive; |
| /** Number of readers in critical section. */ |
| count_t readers_in; |
| } rwlock_t; |
| #define rwlock_write_lock(rwl) \ |
| _rwlock_write_lock_timeout((rwl), SYNCH_NO_TIMEOUT, SYNCH_FLAGS_NONE) |
| #define rwlock_read_lock(rwl) \ |
| _rwlock_read_lock_timeout((rwl), SYNCH_NO_TIMEOUT, SYNCH_FLAGS_NONE) |
| #define rwlock_write_trylock(rwl) \ |
| _rwlock_write_lock_timeout((rwl), SYNCH_NO_TIMEOUT, \ |
| SYNCH_FLAGS_NON_BLOCKING) |
| #define rwlock_read_trylock(rwl) \ |
| _rwlock_read_lock_timeout((rwl), SYNCH_NO_TIMEOUT, \ |
| SYNCH_FLAGS_NON_BLOCKING) |
| #define rwlock_write_lock_timeout(rwl, usec) \ |
| _rwlock_write_lock_timeout((rwl), (usec), SYNCH_FLAGS_NONE) |
| #define rwlock_read_lock_timeout(rwl, usec) \ |
| _rwlock_read_lock_timeout((rwl), (usec), SYNCH_FLAGS_NONE) |
| extern void rwlock_initialize(rwlock_t *rwl); |
| extern void rwlock_read_unlock(rwlock_t *rwl); |
| extern void rwlock_write_unlock(rwlock_t *rwl); |
| extern int _rwlock_read_lock_timeout(rwlock_t *rwl, uint32_t usec, int flags); |
| extern int _rwlock_write_lock_timeout(rwlock_t *rwl, uint32_t usec, int flags); |
| #endif |
| /** @} |
| */ |
| /branches/dd/kernel/generic/include/synch/semaphore.h |
|---|
| 0,0 → 1,60 |
| /* |
| * Copyright (c) 2001-2004 Jakub Jermar |
| * All rights reserved. |
| * |
| * Redistribution and use in source and binary forms, with or without |
| * modification, are permitted provided that the following conditions |
| * are met: |
| * |
| * - Redistributions of source code must retain the above copyright |
| * notice, this list of conditions and the following disclaimer. |
| * - Redistributions in binary form must reproduce the above copyright |
| * notice, this list of conditions and the following disclaimer in the |
| * documentation and/or other materials provided with the distribution. |
| * - The name of the author may not be used to endorse or promote products |
| * derived from this software without specific prior written permission. |
| * |
| * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR |
| * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |
| * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
| * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, |
| * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT |
| * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF |
| * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| */ |
| /** @addtogroup sync |
| * @{ |
| */ |
| /** @file |
| */ |
| #ifndef KERN_SEMAPHORE_H_ |
| #define KERN_SEMAPHORE_H_ |
| #include <arch/types.h> |
| #include <synch/waitq.h> |
| #include <synch/synch.h> |
| typedef struct { |
| waitq_t wq; |
| } semaphore_t; |
| #define semaphore_down(s) \ |
| _semaphore_down_timeout((s), SYNCH_NO_TIMEOUT, SYNCH_FLAGS_NONE) |
| #define semaphore_trydown(s) \ |
| _semaphore_down_timeout((s), SYNCH_NO_TIMEOUT, SYNCH_FLAGS_NON_BLOCKING) |
| #define semaphore_down_timeout(s, usec) \ |
| _semaphore_down_timeout((s), (usec), SYNCH_FLAGS_NONE) |
| extern void semaphore_initialize(semaphore_t *s, int val); |
| extern int _semaphore_down_timeout(semaphore_t *s, uint32_t usec, int flags); |
| extern void semaphore_up(semaphore_t *s); |
| #endif |
| /** @} |
| */ |
| /branches/dd/kernel/generic/include/synch/synch.h |
|---|
| 0,0 → 1,67 |
| /* |
| * Copyright (c) 2001-2004 Jakub Jermar |
| * All rights reserved. |
| * |
| * Redistribution and use in source and binary forms, with or without |
| * modification, are permitted provided that the following conditions |
| * are met: |
| * |
| * - Redistributions of source code must retain the above copyright |
| * notice, this list of conditions and the following disclaimer. |
| * - Redistributions in binary form must reproduce the above copyright |
| * notice, this list of conditions and the following disclaimer in the |
| * documentation and/or other materials provided with the distribution. |
| * - The name of the author may not be used to endorse or promote products |
| * derived from this software without specific prior written permission. |
| * |
| * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR |
| * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES |
| * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. |
| * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, |
| * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT |
| * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF |
| * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| */ |
| /** @addtogroup sync |
| * @{ |
| */ |
| /** @file |
| */ |
| #ifndef KERN_SYNCH_H_ |
| #define KERN_SYNCH_H_ |
| /** Request with no timeout. */ |
| #define SYNCH_NO_TIMEOUT 0 |
| /** No flags specified. */ |
| #define SYNCH_FLAGS_NONE 0 |
| /** Non-blocking operation request. */ |
| #define SYNCH_FLAGS_NON_BLOCKING (1 << 0) |
| /** Interruptible operation. */ |
| #define SYNCH_FLAGS_INTERRUPTIBLE (1 << 1) |
| /** Could not satisfy the request without going to sleep. */ |
| #define ESYNCH_WOULD_BLOCK 1 |
| /** Timeout occurred. */ |
| #define ESYNCH_TIMEOUT 2 |
| /** Sleep was interrupted. */ |
| #define ESYNCH_INTERRUPTED 4 |
| /** Operation succeeded without sleeping. */ |
| #define ESYNCH_OK_ATOMIC 8 |
| /** Operation succeeded and did sleep. */ |
| #define ESYNCH_OK_BLOCKED 16 |
| #define SYNCH_FAILED(rc) \ |
| ((rc) & (ESYNCH_WOULD_BLOCK | ESYNCH_TIMEOUT | ESYNCH_INTERRUPTED)) |
| #define SYNCH_OK(rc) \ |
| ((rc) & (ESYNCH_OK_ATOMIC | ESYNCH_OK_BLOCKED)) |
| #endif |
| /** @} |
| */ |