synch.h

/*
 * Copyright (C) 2001,2002,2003 Philippe Gerum <rpm@xenomai.org>.
 *
 * Xenomai is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published
 * by the Free Software Foundation; either version 2 of the License,
 * or (at your option) any later version.
 *
 * Xenomai is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with Xenomai; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
 * 02111-1307, USA.
 */
#ifndef _COBALT_KERNEL_SYNCH_H
#define _COBALT_KERNEL_SYNCH_H
 
#include <cobalt/kernel/list.h>
#include <cobalt/kernel/assert.h>
#include <cobalt/kernel/timer.h>
#include <cobalt/uapi/kernel/synch.h>
#include <cobalt/uapi/kernel/thread.h>
 
#define XNSYNCH_CLAIMED  0x100  /* Claimed by other thread(s) (PI) */
#define XNSYNCH_CEILING  0x200  /* Actively boosting (PP) */
 
/* Spare flags usable by upper interfaces */
#define XNSYNCH_SPARE0  0x01000000
#define XNSYNCH_SPARE1  0x02000000
#define XNSYNCH_SPARE2  0x04000000
#define XNSYNCH_SPARE3  0x08000000
#define XNSYNCH_SPARE4  0x10000000
#define XNSYNCH_SPARE5  0x20000000
#define XNSYNCH_SPARE6  0x40000000
#define XNSYNCH_SPARE7  0x80000000
 
/* Statuses */
#define XNSYNCH_DONE    0       /* Resource available / operation complete */
#define XNSYNCH_WAIT    1       /* Calling thread blocked -- start rescheduling */
#define XNSYNCH_RESCHED 2       /* Force rescheduling */
 
struct xnthread;
struct xnsynch;
 
struct xnsynch {
        int wprio;
        struct list_head next;
        u32 *ceiling_ref;
        unsigned long status;
        struct list_head pendq;
        struct xnthread *owner;
        atomic_t *fastlock;
        /* Cleanup handler */
        void (*cleanup)(struct xnsynch *synch);
};
 
#define XNSYNCH_WAITQUEUE_INITIALIZER(__name) {         \
                .status = XNSYNCH_PRIO,                 \
                .wprio = -1,                            \
                .pendq = LIST_HEAD_INIT((__name).pendq),        \
                .owner = NULL,                          \
                .cleanup = NULL,                        \
                .fastlock = NULL,                       \
        }
 
#define DEFINE_XNWAITQ(__name)  \
        struct xnsynch __name = XNSYNCH_WAITQUEUE_INITIALIZER(__name)
 
static inline void xnsynch_set_status(struct xnsynch *synch, int bits)
{
        synch->status |= bits;
}
 
static inline void xnsynch_clear_status(struct xnsynch *synch, int bits)
{
        synch->status &= ~bits;
}
 
#define xnsynch_for_each_sleeper(__pos, __synch)                \
        list_for_each_entry(__pos, &(__synch)->pendq, plink)
 
#define xnsynch_for_each_sleeper_safe(__pos, __tmp, __synch)    \
        list_for_each_entry_safe(__pos, __tmp, &(__synch)->pendq, plink)
 
static inline int xnsynch_pended_p(struct xnsynch *synch)
{
        return !list_empty(&synch->pendq);
}
 
static inline struct xnthread *xnsynch_owner(struct xnsynch *synch)
{
        return synch->owner;
}
 
#define xnsynch_fastlock(synch)         ((synch)->fastlock)
#define xnsynch_fastlock_p(synch)       ((synch)->fastlock != NULL)
#define xnsynch_owner_check(synch, thread) \
        xnsynch_fast_owner_check((synch)->fastlock, thread->handle)
 
#ifdef CONFIG_XENO_OPT_DEBUG_MUTEX_RELAXED
 
void xnsynch_detect_relaxed_owner(struct xnsynch *synch,
                                  struct xnthread *sleeper);
 
void xnsynch_detect_boosted_relax(struct xnthread *owner);
 
#else /* !CONFIG_XENO_OPT_DEBUG_MUTEX_RELAXED */
 
static inline void xnsynch_detect_relaxed_owner(struct xnsynch *synch,
                                  struct xnthread *sleeper) { }
 
static inline void xnsynch_detect_boosted_relax(struct xnthread *owner) { }
 
#endif /* !CONFIG_XENO_OPT_DEBUG_MUTEX_RELAXED */
 
void xnsynch_init(struct xnsynch *synch, int flags,
                  atomic_t *fastlock);
 
void xnsynch_init_protect(struct xnsynch *synch, int flags,
                          atomic_t *fastlock, u32 *ceiling_ref);
 
int xnsynch_destroy(struct xnsynch *synch);
 
void xnsynch_commit_ceiling(struct xnthread *curr);
 
static inline void xnsynch_register_cleanup(struct xnsynch *synch,
                                            void (*handler)(struct xnsynch *))
{
        synch->cleanup = handler;
}
 
int __must_check xnsynch_sleep_on(struct xnsynch *synch,
                                  xnticks_t timeout,
                                  xntmode_t timeout_mode);
 
struct xnthread *xnsynch_wakeup_one_sleeper(struct xnsynch *synch);
 
int xnsynch_wakeup_many_sleepers(struct xnsynch *synch, int nr);
 
void xnsynch_wakeup_this_sleeper(struct xnsynch *synch,
                                 struct xnthread *sleeper);
 
int __must_check xnsynch_acquire(struct xnsynch *synch,
                                 xnticks_t timeout,
                                 xntmode_t timeout_mode);
 
int __must_check xnsynch_try_acquire(struct xnsynch *synch);
 
bool xnsynch_release(struct xnsynch *synch, struct xnthread *thread);
 
struct xnthread *xnsynch_peek_pendq(struct xnsynch *synch);
 
int xnsynch_flush(struct xnsynch *synch, int reason);
 
void xnsynch_requeue_sleeper(struct xnthread *thread);
 
void xnsynch_forget_sleeper(struct xnthread *thread);
 
struct xnsynch *__cobalt_mutex_lookup_lazy_pp(xnhandle_t handle);
 
#endif /* !_COBALT_KERNEL_SYNCH_H_ */