2014-08-06 01:00:10 +00:00
|
|
|
/***************************************************************************
|
|
|
|
* __________ __ ___.
|
|
|
|
* Open \______ \ ____ ____ | | _\_ |__ _______ ___
|
|
|
|
* Source | _// _ \_/ ___\| |/ /| __ \ / _ \ \/ /
|
|
|
|
* Jukebox | | ( <_> ) \___| < | \_\ ( <_> > < <
|
|
|
|
* Firmware |____|_ /\____/ \___ >__|_ \|___ /\____/__/\_ \
|
|
|
|
* \/ \/ \/ \/ \/
|
|
|
|
* $Id$
|
|
|
|
*
|
|
|
|
* Copyright (C) 2014 by Michael Sevakis
|
|
|
|
*
|
|
|
|
* This program 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.
|
|
|
|
*
|
|
|
|
* This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
|
|
|
|
* KIND, either express or implied.
|
|
|
|
*
|
|
|
|
****************************************************************************/
|
|
|
|
#ifndef MRSW_LOCK_H
|
|
|
|
#define MRSW_LOCK_H
|
|
|
|
|
2014-08-08 05:39:29 +00:00
|
|
|
#include "thread.h"
|
|
|
|
|
2014-08-06 01:00:10 +00:00
|
|
|
/* Multi-reader, single-writer object that allows mutltiple readers or a
|
|
|
|
* single writer thread access to a critical section.
|
|
|
|
*
|
|
|
|
* Readers and writers, as with a mutex, may claim the lock recursively for
|
|
|
|
* the same type of access they were already granted.
|
|
|
|
*
|
|
|
|
* Writers are trivially granted read access by ignoring the request; the
|
|
|
|
* object is not changed.
|
|
|
|
*
|
|
|
|
* Reader promotion to writer is NOT supported and a reader attempting write
|
|
|
|
* access will result in a deadlock. That could change but for now, be warned.
|
|
|
|
*
|
|
|
|
* Full priority inheritance is implemented.
|
|
|
|
*/
|
|
|
|
struct mrsw_lock
|
|
|
|
{
|
2014-08-08 10:33:51 +00:00
|
|
|
int volatile count; /* counter; >0 = reader(s), <0 = writer */
|
|
|
|
struct __wait_queue queue; /* waiter list */
|
|
|
|
struct blocker_splay splay; /* priority inheritance/owner info */
|
2014-08-06 01:00:10 +00:00
|
|
|
uint8_t rdrecursion[MAXTHREADS]; /* per-thread reader recursion counts */
|
|
|
|
IF_COP( struct corelock cl; )
|
|
|
|
};
|
|
|
|
|
|
|
|
void mrsw_init(struct mrsw_lock *mrsw);
|
|
|
|
void mrsw_read_acquire(struct mrsw_lock *mrsw);
|
|
|
|
void mrsw_read_release(struct mrsw_lock *mrsw);
|
|
|
|
void mrsw_write_acquire(struct mrsw_lock *mrsw);
|
|
|
|
void mrsw_write_release(struct mrsw_lock *mrsw);
|
|
|
|
|
|
|
|
#endif /* MRSW_LOCK_H */
|