#ifndef _NETGRAPH_NETGRAPH_H_
#define _NETGRAPH_NETGRAPH_H_
#ifndef _SYS_QUEUE_H_
#include <sys/queue.h>
#endif
#ifndef _SYS_MODULE_H_
#include <sys/module.h>
#endif
#ifndef _SYS_MBUF_H_
#include <sys/mbuf.h>
#endif
#ifndef _NETGRAPH_NG_MESSAGE_H_
#include <netgraph/ng_message.h>
#endif
#ifndef _KERNEL
#error "This file should not be included in user level programs"
#endif
#define NG_ABI_VERSION NG_VERSION
struct ng_hook {
char *name;
void *private;
int flags;
int refs;
struct ng_hook *peer;
struct ng_node *node;
LIST_ENTRY(ng_hook) hooks;
};
typedef struct ng_hook *hook_p;
#define HK_INVALID 0x0001
void ng_unref_hook(hook_p hook);
#define NG_HOOK_REF(hook) atomic_add_int(&(hook)->refs, 1)
#define NG_HOOK_NAME(hook) ((hook)->name)
#define NG_HOOK_UNREF(hook) ng_unref_hook(hook)
#define NG_HOOK_SET_PRIVATE(hook, val) do {(hook)->private = val;} while (0)
#define NG_HOOK_SET_RCVMSG(hook, val) do {(hook)->rcvmsg = val;} while (0)
#define NG_HOOK_SET_RCVDATA(hook, val) do {(hook)->rcvdata = val;} while (0)
#define NG_HOOK_PRIVATE(hook) ((hook)->private)
#define NG_HOOK_NOT_VALID(hook) ((hook)->flags & HK_INVALID)
#define NG_HOOK_IS_VALID(hook) (!((hook)->flags & HK_INVALID))
#define NG_HOOK_NODE(hook) ((hook)->node)
#define NG_HOOK_PEER(hook) ((hook)->peer)
#define NG_PEER_NODE(hook) NG_HOOK_NODE(NG_HOOK_PEER(hook))
#define NG_PEER_HOOK_NAME(hook) NG_HOOK_NAME(NG_HOOK_PEER(hook))
#define NG_PEER_NODE_NAME(hook) NG_NODE_NAME(NG_PEER_NODE(hook))
struct ng_node {
char *name;
struct ng_type *type;
int flags;
int sleepers;
int refs;
int numhooks;
int colour;
void *private;
ng_ID_t ID;
LIST_HEAD(hooks, ng_hook) hooks;
LIST_ENTRY(ng_node) nodes;
LIST_ENTRY(ng_node) idnodes;
};
typedef struct ng_node *node_p;
#define NG_INVALID 0x001
#define NG_BUSY 0x002
#define NG_TOUCHED 0x004
#define NGF_TYPE1 0x10000000
#define NGF_TYPE2 0x20000000
#define NGF_TYPE3 0x40000000
#define NGF_TYPE4 0x80000000
void ng_unref_node(node_p node);
#define NG_NODE_NAME(node) ((node)->name + 0)
#define NG_NODE_HAS_NAME(node) ((node)->name[0] + 0)
#define NG_NODE_ID(node) ((node)->ID + 0)
#define NG_NODE_REF(node) atomic_add_int(&(node)->refs, 1)
#define NG_NODE_UNREF(node) ng_unref(node)
#define NG_NODE_SET_PRIVATE(node, val) do {(node)->private = val;} while (0)
#define NG_NODE_PRIVATE(node) ((node)->private)
#define NG_NODE_IS_VALID(node) (!((node)->flags & NG_INVALID))
#define NG_NODE_NOT_VALID(node) ((node)->flags & NG_INVALID)
#define NG_NODE_NUMHOOKS(node) ((node)->numhooks + 0)
struct meta_field_header {
u_long cookie;
u_short type;
u_short len;
char data[0];
};
#define NGM_INVALID_COOKIE 865455152
struct ng_meta {
char priority;
char discardability;
u_short allocated_len;
u_short used_len;
u_short flags;
struct meta_field_header options[0];
};
typedef struct ng_meta *meta_p;
#define NGMF_TEST 0x01
#define NGMF_TRACE 0x02
typedef int ng_constructor_t(node_p *node);
typedef int ng_rcvmsg_t(node_p node, struct ng_mesg *msg,
const char *retaddr, struct ng_mesg **resp);
typedef int ng_shutdown_t(node_p node);
typedef int ng_newhook_t(node_p node, hook_p hook, const char *name);
typedef hook_p ng_findhook_t(node_p node, const char *name);
typedef int ng_connect_t(hook_p hook);
typedef int ng_rcvdata_t(hook_p hook, struct mbuf *m, meta_p meta);
typedef int ng_disconnect_t(hook_p hook);
struct ng_cmdlist {
u_int32_t cookie;
int cmd;
const char *name;
const struct ng_parse_type *mesgType;
const struct ng_parse_type *respType;
};
struct ng_type {
u_int32_t version;
const char *name;
modeventhand_t mod_event;
ng_constructor_t *constructor;
ng_rcvmsg_t *rcvmsg;
ng_shutdown_t *shutdown;
ng_newhook_t *newhook;
ng_findhook_t *findhook;
ng_connect_t *connect;
ng_rcvdata_t *rcvdata;
ng_rcvdata_t *rcvdataq;
ng_disconnect_t *disconnect;
const struct ng_cmdlist *cmdlist;
LIST_ENTRY(ng_type) types;
int refs;
};
#define NG_SEND_DATA(error, hook, m, a) \
do { \
(error) = ng_send_data((hook), (m), (a)); \
(m) = NULL; \
(a) = NULL; \
} while (0)
#define NG_SEND_DATA_ONLY(error, hook, m) \
do { \
(error) = ng_send_data((hook), (m), NULL); \
(m) = NULL; \
} while (0)
#define NG_SEND_DATAQ(error, hook, m, a) \
do { \
(error) = ng_send_dataq((hook), (m), (a)); \
(m) = NULL; \
(a) = NULL; \
} while (0)
#define NG_RESPOND_MSG(error, here, retaddr, resp, rptr) \
do { \
if (rptr) { \
*rptr = resp; \
} else if (resp) { \
if (retaddr) { \
error = ng_queue_msg(here, resp, retaddr); \
} else { \
kfree(resp, M_NETGRAPH); \
} \
} \
} while (0)
#define NG_FREE_MSG(msg) \
do { \
if ((msg)) { \
kfree((msg), M_NETGRAPH); \
(msg) = NULL; \
} \
} while (0)
#define NG_FREE_META(a) \
do { \
if ((a)) { \
kfree((a), M_NETGRAPH); \
(a) = NULL; \
} \
} while (0)
#define NG_FREE_M(m) \
do { \
if ((m)) { \
m_freem((m)); \
(m) = NULL; \
} \
} while (0)
#define NG_FREE_DATA(m, a) \
do { \
NG_FREE_M((m)); \
NG_FREE_META((a)); \
} while (0)
#define NETGRAPH_INIT_ORDERED(typename, typestructp, sub, order) \
static moduledata_t ng_##typename##_mod = { \
"ng_" #typename, \
ng_mod_event, \
(typestructp) \
}; \
DECLARE_MODULE(ng_##typename, ng_##typename##_mod, sub, order); \
MODULE_VERSION(ng_##typename, NG_ABI_VERSION); \
MODULE_DEPEND(ng_##typename, netgraph, NG_ABI_VERSION, \
NG_ABI_VERSION, \
NG_ABI_VERSION)
#define NETGRAPH_INIT(tn, tp) \
NETGRAPH_INIT_ORDERED(tn, tp, SI_SUB_PSEUDO, SI_ORDER_ANY)
#ifdef MALLOC_DECLARE
MALLOC_DECLARE(M_NETGRAPH);
#endif
#ifdef SYSCTL_DECL
SYSCTL_DECL(_net_graph);
#endif
int ng_bypass(hook_p hook1, hook_p hook2);
void ng_cutlinks(node_p node);
int ng_con_nodes(node_p node,
const char *name, node_p node2, const char *name2);
meta_p ng_copy_meta(meta_p meta);
void ng_destroy_hook(hook_p hook);
hook_p ng_findhook(node_p node, const char *name);
node_p ng_findname(node_p node, const char *name);
struct ng_type *ng_findtype(const char *type);
int ng_make_node(const char *type, node_p *nodepp);
int ng_make_node_common(struct ng_type *typep, node_p *nodep);
int ng_mkpeer(node_p node, const char *name, const char *name2, char *type);
int ng_mod_event(module_t mod, int what, void *arg);
int ng_name_node(node_p node, const char *name);
int ng_newtype(struct ng_type *tp);
ng_ID_t ng_node2ID(node_p node);
int ng_path2node(node_p here, const char *path, node_p *dest, char **rtnp);
int ng_path_parse(char *addr, char **node, char **path, char **hook);
int ng_queue_data(hook_p hook, struct mbuf *m, meta_p meta);
int ng_queue_msg(node_p here, struct ng_mesg *msg, const char *address);
void ng_release_node(node_p node);
void ng_rmnode(node_p node);
int ng_send_data(hook_p hook, struct mbuf *m, meta_p meta);
int ng_send_dataq(hook_p hook, struct mbuf *m, meta_p meta);
int ng_send_msg(node_p here, struct ng_mesg *msg,
const char *address, struct ng_mesg **resp);
void ng_unname(node_p node);
void ng_unref(node_p node);
int ng_wait_node(node_p node, char *msg);
#endif