task_thread_api.h

Go to the documentation of this file.

/*
 * Copyright (c) 2017 Juniper Networks, Inc. All rights reserved.
 */

#ifndef vnsw_agent_task_thread_api_h
#define vnsw_agent_task_thread_api_h

#include "mcast_common.h"

typedef struct thread_ {
    struct thread_ *next;
    struct thread_ *prev;
} task_thread;

#define THREAD_TO_STRUCT(function, structure, member)                   \
    static inline structure * (function)(task_thread *address) {             \
        if (address) {                                                  \
            return (structure *)((char*)address - offsetof(structure, member));\
        }                                                               \
        return NULL;                                                    \
    }

extern void thread_new_circular_thread(task_thread *head);
extern boolean thread_circular_thread_empty(task_thread *head);
extern boolean thread_circular_thread_head(task_thread *head, task_thread *node);
extern boolean thread_node_on_thread(const task_thread *node);
extern task_thread *thread_circular_top(task_thread *head);
extern void thread_circular_add_top(task_thread *head, task_thread *node);
extern void thread_circular_add_bottom(task_thread *head, task_thread *node);
extern task_thread *thread_next_node(task_thread *node);
extern task_thread *thread_circular_thread_next(task_thread *head, task_thread *node);
extern task_thread *thread_circular_dequeue_top(task_thread *head);
extern void thread_remove(task_thread *node);

#define FOR_ALL_CIRCULAR_THREAD_ENTRIES(head, current)                  \
    for ((current) = thread_next_node(head);                            \
            !thread_circular_thread_head(head, (current));              \
            (current) = thread_next_node(current))

#endif /* vnsw_agent_task_thread_api_h */