upstream/opnsense-src
1
0
Fork 0
mirror of https://github.com/opnsense/src.git synced 2026-05-28 04:12:45 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add the ability to reinitialize a mutex (internally, not a userland

Browse source 
API).

Reviewed by:	davidxu
This commit is contained in:
Daniel Eischen 2003-11-04 19:53:32 +00:00
parent 358702366c
commit ee574ccc3e
2 changed files with 40 additions and 14 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
lib/libkse/thread/thr_mutex.c
View file

@ -65,6 +65,11 @@
#endif
#define THR_IN_MUTEXQ(thr) (((thr)->sflags & THR_FLAGS_IN_SYNCQ) != 0)
#define MUTEX_DESTROY(m) do { \
_lock_destroy(&(m)->m_lock); \
free(m); \
} while (0)
/*
* Prototypes
@ -192,8 +197,7 @@ _pthread_mutex_init(pthread_mutex_t *mutex,
*mutex = pmutex;
} else {
/* Free the mutex lock structure: */
_lock_destroy(&pmutex->m_lock);
free(pmutex);
MUTEX_DESTROY(pmutex);
*mutex = NULL;
}
}
@ -202,6 +206,19 @@ _pthread_mutex_init(pthread_mutex_t *mutex,
return (ret);
}
void
_thr_mutex_reinit(pthread_mutex_t *mutex)
{
_lock_reinit(&(*mutex)->m_lock, LCK_ADAPTIVE,
_thr_lock_wait, _thr_lock_wakeup);
TAILQ_INIT(&(*mutex)->m_queue);
(*mutex)->m_owner = NULL;
(*mutex)->m_count = 0;
(*mutex)->m_refcount = 0;
(*mutex)->m_prio = 0;
(*mutex)->m_saved_prio = 0;
}
int
_pthread_mutex_destroy(pthread_mutex_t *mutex)
{
@ -241,11 +258,7 @@ _pthread_mutex_destroy(pthread_mutex_t *mutex)
* structure:
*/
MUTEX_ASSERT_NOT_OWNED(m);
/* Free the mutex lock structure: */
_lock_destroy(&m->m_lock);
free(m);
MUTEX_DESTROY(m);
}
}

27
lib/libpthread/thread/thr_mutex.c
View file

@ -65,6 +65,11 @@
#endif
#define THR_IN_MUTEXQ(thr) (((thr)->sflags & THR_FLAGS_IN_SYNCQ) != 0)
#define MUTEX_DESTROY(m) do { \
_lock_destroy(&(m)->m_lock); \
free(m); \
} while (0)
/*
* Prototypes
@ -192,8 +197,7 @@ _pthread_mutex_init(pthread_mutex_t *mutex,
*mutex = pmutex;
} else {
/* Free the mutex lock structure: */
_lock_destroy(&pmutex->m_lock);
free(pmutex);
MUTEX_DESTROY(pmutex);
*mutex = NULL;
}
}
@ -202,6 +206,19 @@ _pthread_mutex_init(pthread_mutex_t *mutex,
return (ret);
}
void
_thr_mutex_reinit(pthread_mutex_t *mutex)
{
_lock_reinit(&(*mutex)->m_lock, LCK_ADAPTIVE,
_thr_lock_wait, _thr_lock_wakeup);
TAILQ_INIT(&(*mutex)->m_queue);
(*mutex)->m_owner = NULL;
(*mutex)->m_count = 0;
(*mutex)->m_refcount = 0;
(*mutex)->m_prio = 0;
(*mutex)->m_saved_prio = 0;
}
int
_pthread_mutex_destroy(pthread_mutex_t *mutex)
{
@ -241,11 +258,7 @@ _pthread_mutex_destroy(pthread_mutex_t *mutex)
* structure:
*/
MUTEX_ASSERT_NOT_OWNED(m);
/* Free the mutex lock structure: */
_lock_destroy(&m->m_lock);
free(m);
MUTEX_DESTROY(m);
}
}