bb85ad849e
The load/compare and RMW to wait_count need protection. Using atomic operations should resolve both issues. NOTE: The assumption that the user will call pthread_cond_signal / pthread_cond_broadcast with the mutex given to pthread_cond_wait held is simply not true. It MAY hold it, but it is not forced. Thus, using the user space lock for protecting the wait counter as well is not valid! The pthread_cond_signal() or pthread_cond_broadcast() functions may be called by a thread whether or not it currently owns the mutex that threads calling pthread_cond_wait() or pthread_cond_timedwait() have associated with the condition variable during their waits; however, if predictable scheduling behaviour is required, then that mutex is locked by the thread calling pthread_cond_signal() or pthread_cond_broadcast(). [1] https://pubs.opengroup.org/onlinepubs/7908799/xsh/pthread_cond_signal.html
140 lines
5.8 KiB
C
140 lines
5.8 KiB
C
/****************************************************************************
|
|
* sched/pthread/pthread.h
|
|
*
|
|
* SPDX-License-Identifier: Apache-2.0
|
|
*
|
|
* Licensed to the Apache Software Foundation (ASF) under one or more
|
|
* contributor license agreements. See the NOTICE file distributed with
|
|
* this work for additional information regarding copyright ownership. The
|
|
* ASF licenses this file to you under the Apache License, Version 2.0 (the
|
|
* "License"); you may not use this file except in compliance with the
|
|
* License. You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
|
|
* WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
|
|
* License for the specific language governing permissions and limitations
|
|
* under the License.
|
|
*
|
|
****************************************************************************/
|
|
|
|
#ifndef __SCHED_PTHREAD_PTHREAD_H
|
|
#define __SCHED_PTHREAD_PTHREAD_H
|
|
|
|
/****************************************************************************
|
|
* Included Files
|
|
****************************************************************************/
|
|
|
|
#include <nuttx/config.h>
|
|
|
|
#include <sys/types.h>
|
|
#include <stdint.h>
|
|
#include <stdbool.h>
|
|
#include <pthread.h>
|
|
|
|
#include <nuttx/compiler.h>
|
|
#include <nuttx/semaphore.h>
|
|
#include <nuttx/sched.h>
|
|
|
|
/****************************************************************************
|
|
* Pre-processor Definitions
|
|
****************************************************************************/
|
|
|
|
#ifdef CONFIG_PTHREAD_MUTEX_TYPES
|
|
# define mutex_init(m) nxrmutex_init(m)
|
|
# define mutex_destroy(m) nxrmutex_destroy(m)
|
|
# define mutex_is_hold(m) nxrmutex_is_hold(m)
|
|
# define mutex_is_locked(m) nxrmutex_is_locked(m)
|
|
# define mutex_is_recursive(m) nxrmutex_is_recursive(m)
|
|
# define mutex_get_holder(m) nxrmutex_get_holder(m)
|
|
# define mutex_reset(m) nxrmutex_reset(m)
|
|
# define mutex_unlock(m) nxrmutex_unlock(m)
|
|
# define mutex_lock(m) nxrmutex_lock(m)
|
|
# define mutex_trylock(m) nxrmutex_trylock(m)
|
|
# define mutex_breaklock(m,v) nxrmutex_breaklock(m,v)
|
|
# define mutex_restorelock(m,v) nxrmutex_restorelock(m,v)
|
|
# define mutex_clocklock(m,t) nxrmutex_clocklock(m,CLOCK_REALTIME,t)
|
|
# define mutex_set_protocol(m,p) nxrmutex_set_protocol(m,p)
|
|
# define mutex_getprioceiling(m,p) nxrmutex_getprioceiling(m,p)
|
|
# define mutex_setprioceiling(m,p,o) nxrmutex_setprioceiling(m,p,o)
|
|
#else
|
|
# define mutex_init(m) nxmutex_init(m)
|
|
# define mutex_destroy(m) nxmutex_destroy(m)
|
|
# define mutex_is_hold(m) nxmutex_is_hold(m)
|
|
# define mutex_is_recursive(m) (false)
|
|
# define mutex_is_locked(m) nxmutex_is_locked(m)
|
|
# define mutex_get_holder(m) nxmutex_get_holder(m)
|
|
# define mutex_reset(m) nxmutex_reset(m)
|
|
# define mutex_unlock(m) nxmutex_unlock(m)
|
|
# define mutex_lock(m) nxmutex_lock(m)
|
|
# define mutex_trylock(m) nxmutex_trylock(m)
|
|
# define mutex_breaklock(m,v) nxmutex_breaklock(m, v)
|
|
# define mutex_restorelock(m,v) nxmutex_restorelock(m, v)
|
|
# define mutex_clocklock(m,t) nxmutex_clocklock(m,CLOCK_REALTIME,t)
|
|
# define mutex_set_protocol(m,p) nxmutex_set_protocol(m,p)
|
|
# define mutex_getprioceiling(m,p) nxmutex_getprioceiling(m,p)
|
|
# define mutex_setprioceiling(m,p,o) nxmutex_setprioceiling(m,p,o)
|
|
#endif
|
|
|
|
#define COND_WAIT_COUNT(cond) ((FAR atomic_t *)&(cond)->wait_count)
|
|
|
|
/****************************************************************************
|
|
* Public Data
|
|
****************************************************************************/
|
|
|
|
#ifdef __cplusplus
|
|
#define EXTERN extern "C"
|
|
extern "C"
|
|
{
|
|
#else
|
|
#define EXTERN extern
|
|
#endif
|
|
|
|
/****************************************************************************
|
|
* Public Function Prototypes
|
|
****************************************************************************/
|
|
|
|
struct pthread_tcb_s; /* Forward reference */
|
|
struct task_group_s; /* Forward reference */
|
|
|
|
int pthread_setup_scheduler(FAR struct pthread_tcb_s *tcb, int priority,
|
|
start_t start, pthread_startroutine_t entry);
|
|
|
|
int pthread_completejoin(pid_t pid, FAR void *exit_value);
|
|
void pthread_destroyjoin(FAR struct task_group_s *group,
|
|
FAR struct task_join_s *pjoin);
|
|
int pthread_findjoininfo(FAR struct task_group_s *group, pid_t pid,
|
|
FAR struct task_join_s **join, bool create);
|
|
void pthread_release(FAR struct task_group_s *group);
|
|
|
|
#ifndef CONFIG_PTHREAD_MUTEX_UNSAFE
|
|
int pthread_mutex_take(FAR struct pthread_mutex_s *mutex,
|
|
FAR const struct timespec *abs_timeout);
|
|
int pthread_mutex_trytake(FAR struct pthread_mutex_s *mutex);
|
|
int pthread_mutex_give(FAR struct pthread_mutex_s *mutex);
|
|
int pthread_mutex_breaklock(FAR struct pthread_mutex_s *mutex,
|
|
FAR unsigned int *breakval);
|
|
int pthread_mutex_restorelock(FAR struct pthread_mutex_s *mutex,
|
|
unsigned int breakval);
|
|
void pthread_mutex_inconsistent(FAR struct tcb_s *tcb);
|
|
#else
|
|
# define pthread_mutex_take(m,abs_timeout) -mutex_clocklock(&(m)->mutex, \
|
|
abs_timeout)
|
|
# define pthread_mutex_trytake(m) -mutex_trylock(&(m)->mutex)
|
|
# define pthread_mutex_give(m) -mutex_unlock(&(m)->mutex)
|
|
# define pthread_mutex_breaklock(m,v) -mutex_breaklock(&(m)->mutex,v)
|
|
# define pthread_mutex_restorelock(m,v) -mutex_restorelock(&(m)->mutex,v)
|
|
#endif
|
|
|
|
#ifdef CONFIG_PTHREAD_MUTEX_TYPES
|
|
int pthread_mutexattr_verifytype(int type);
|
|
#endif
|
|
|
|
#undef EXTERN
|
|
#ifdef __cplusplus
|
|
}
|
|
#endif
|
|
|
|
#endif /* __SCHED_PTHREAD_PTHREAD_H */
|