sergiotarxz/nuttx
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

include/nuttx:add linux-like notifier

Browse Source 
Signed-off-by: 田昕 <tianxin7@xiaomi.com>
This commit is contained in:
田昕 2022-12-01 22:03:46 +08:00 committed by Xiang Xiao
parent 22390df92d
commit cb0418676f
1 changed files with 201 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

201
include/nuttx/notifier.h Normal file
View File

@ -0,0 +1,201 @@
/****************************************************************************
* include/nuttx/notifier.h
*
* 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 __INCLUDE_NUTTX_NOTIFIER_H
#define __INCLUDE_NUTTX_NOTIFIER_H
/****************************************************************************
* Included Files
****************************************************************************/
#include <nuttx/config.h>
#include <nuttx/irq.h>
#include <debug.h>
#include <errno.h>
#include <sys/types.h>
/****************************************************************************
* Pre-processor Definitions
****************************************************************************/
#define ATOMIC_NOTIFIER_INIT(name) {NULL}
#define ATOMIC_NOTIFIER_HEAD(name) \
struct atomic_notifier_head name = ATOMIC_NOTIFIER_INIT(name)
/****************************************************************************
* Public Type Definitions
****************************************************************************/
struct notifier_block;
typedef CODE int (*notifier_fn_t)(FAR struct notifier_block *nb,
unsigned long action, FAR void *data);
struct notifier_block
{
notifier_fn_t notifier_call;
FAR struct notifier_block *next;
int priority;
};
struct atomic_notifier_head
{
FAR struct notifier_block *head;
};
/****************************************************************************
* Public Function Prototypes
****************************************************************************/
#ifndef __ASSEMBLY__
#undef EXTERN
#if defined(__cplusplus)
#define EXTERN extern "C"
extern "C"
{
#else
#define EXTERN extern
#endif
#define notifier_chain_register(nhead, node, unique_priority) \
do \
{ \
FAR struct notifier_block **nl = &(nhead); \
FAR struct notifier_block *n = (node); \
int flag = 0; \
while (*nl != NULL) \
{ \
if (*nl == n) \
{ \
flag = -EEXIST; \
break; \
} \
if (n->priority > (*nl)->priority) \
{ \
break; \
} \
if (n->priority == (*nl)->priority && (unique_priority)) \
{ \
flag = -EBUSY; \
break; \
} \
nl = &((*nl)->next); \
} \
if (flag == 0) \
{ \
n->next = *nl; \
*nl = n; \
} \
} \
while (0)
#define notifier_chain_unregister(nhead, node) \
do \
{ \
FAR struct notifier_block **nl = &(nhead); \
FAR struct notifier_block *n = (node); \
while (*nl != NULL) \
{ \
if (*nl == n) \
{ \
*nl = n->next; \
break; \
} \
nl = &((*nl)->next); \
} \
} \
while(0)
#define notifier_call_chain(nhead, val, v, num_to_call, num_calls) \
do \
{ \
FAR struct notifier_block *nb; \
FAR struct notifier_block *next_nb; \
int nr_to_call = (num_to_call); \
FAR int *nr_calls = (num_calls); \
nb = (nhead); \
while (nb && nr_to_call) \
{ \
next_nb = nb->next; \
nb->notifier_call(nb, (val), (v)); \
if (nr_calls) \
{ \
(*nr_calls)++; \
} \
nb = next_nb; \
nr_to_call--; \
} \
} \
while(0)
#define atomic_notifier_chain_register(nhead, nb) \
do \
{ \
FAR struct atomic_notifier_head *nh = (nhead); \
irqstate_t flags; \
flags = enter_critical_section(); \
notifier_chain_register(nh->head, (nb), false); \
leave_critical_section(flags); \
} \
while(0)
#define atomic_notifier_chain_register_uniqueprio(nhead, nb) \
do \
{ \
FAR struct atomic_notifier_head *nh = (nhead); \
irqstate_t flags; \
flags = enter_critical_section(); \
notifier_chain_register(nh->head, (nb), true); \
leave_critical_section(flags); \
} \
while(0)
#define atomic_notifier_chain_unregister(nhead, nb) \
do \
{ \
FAR struct atomic_notifier_head *nh = (nhead); \
irqstate_t flags; \
flags = enter_critical_section(); \
notifier_chain_unregister(nh->head, (nb); \
leave_critical_section(flags); \
} \
while(0)
#define atomic_notifier_call_chain(nhead, val, v) \
do \
{ \
FAR struct atomic_notifier_head *nh = (nhead); \
irqstate_t flags; \
flags = enter_critical_section(); \
notifier_call_chain(nh->head, (val), (v), -1, NULL); \
leave_critical_section(flags); \
} \
while(0)
#undef EXTERN
#if defined(__cplusplus)
}
#endif
#endif /* __ASSEMBLY__ */
#endif /* __INCLUDE_NUTTX_NOTIFIER_H */