8#include <linux/netfilter.h>
10#include <netlink/netfilter/nfnl.h>
11#include <netlink/netfilter/netfilter.h>
12#include <netlink/netfilter/queue_msg.h>
13#include <netlink/route/link.h>
15#include "nl-netfilter.h"
16#include "nl-priv-dynamic-core/nl-core.h"
19#define QUEUE_MSG_ATTR_GROUP (1UL << 0)
20#define QUEUE_MSG_ATTR_FAMILY (1UL << 1)
21#define QUEUE_MSG_ATTR_PACKETID (1UL << 2)
22#define QUEUE_MSG_ATTR_HWPROTO (1UL << 3)
23#define QUEUE_MSG_ATTR_HOOK (1UL << 4)
24#define QUEUE_MSG_ATTR_MARK (1UL << 5)
25#define QUEUE_MSG_ATTR_TIMESTAMP (1UL << 6)
26#define QUEUE_MSG_ATTR_INDEV (1UL << 7)
27#define QUEUE_MSG_ATTR_OUTDEV (1UL << 8)
28#define QUEUE_MSG_ATTR_PHYSINDEV (1UL << 9)
29#define QUEUE_MSG_ATTR_PHYSOUTDEV (1UL << 10)
30#define QUEUE_MSG_ATTR_HWADDR (1UL << 11)
31#define QUEUE_MSG_ATTR_PAYLOAD (1UL << 12)
32#define QUEUE_MSG_ATTR_VERDICT (1UL << 13)
35static void nfnl_queue_msg_free_data(
struct nl_object *c)
42 free(msg->queue_msg_payload);
45static int nfnl_queue_msg_clone(
struct nl_object *_dst,
struct nl_object *_src)
51 dst->queue_msg_payload = NULL;
52 dst->queue_msg_payload_len = 0;
54 if (src->queue_msg_payload) {
55 err = nfnl_queue_msg_set_payload(dst, src->queue_msg_payload,
56 src->queue_msg_payload_len);
64static void nfnl_queue_msg_dump(
struct nl_object *a,
struct nl_dump_params *p)
67 struct nl_cache *link_cache;
74 if (msg->ce_mask & QUEUE_MSG_ATTR_GROUP)
75 nl_dump(p,
"GROUP=%u ", msg->queue_msg_group);
77 if (msg->ce_mask & QUEUE_MSG_ATTR_INDEV) {
84 nl_dump(p,
"IN=%d ", msg->queue_msg_indev);
87 if (msg->ce_mask & QUEUE_MSG_ATTR_PHYSINDEV) {
91 msg->queue_msg_physindev,
94 nl_dump(p,
"IN=%d ", msg->queue_msg_physindev);
97 if (msg->ce_mask & QUEUE_MSG_ATTR_OUTDEV) {
101 msg->queue_msg_outdev,
104 nl_dump(p,
"OUT=%d ", msg->queue_msg_outdev);
107 if (msg->ce_mask & QUEUE_MSG_ATTR_PHYSOUTDEV) {
111 msg->queue_msg_physoutdev,
114 nl_dump(p,
"PHYSOUT=%d ", msg->queue_msg_physoutdev);
117 if (msg->ce_mask & QUEUE_MSG_ATTR_HWADDR) {
121 for (i = 0; i < msg->queue_msg_hwaddr_len; i++)
122 nl_dump(p,
"%c%02x", i?
':':
'=',
123 msg->queue_msg_hwaddr[i]);
127 if (msg->ce_mask & QUEUE_MSG_ATTR_FAMILY)
129 nl_af2str(msg->queue_msg_family, buf,
sizeof(buf)));
131 if (msg->ce_mask & QUEUE_MSG_ATTR_HWPROTO)
133 nl_ether_proto2str(ntohs(msg->queue_msg_hwproto),
136 if (msg->ce_mask & QUEUE_MSG_ATTR_HOOK)
138 nfnl_inet_hook2str(msg->queue_msg_hook,
141 if (msg->ce_mask & QUEUE_MSG_ATTR_MARK)
142 nl_dump(p,
"MARK=%d ", msg->queue_msg_mark);
144 if (msg->ce_mask & QUEUE_MSG_ATTR_PAYLOAD)
145 nl_dump(p,
"PAYLOADLEN=%d ", msg->queue_msg_payload_len);
147 if (msg->ce_mask & QUEUE_MSG_ATTR_PACKETID)
148 nl_dump(p,
"PACKETID=%u ", msg->queue_msg_packetid);
150 if (msg->ce_mask & QUEUE_MSG_ATTR_VERDICT)
152 nfnl_verdict2str(msg->queue_msg_verdict,
158 nl_cache_put(link_cache);
188void nfnl_queue_msg_set_group(
struct nfnl_queue_msg *msg, uint16_t group)
190 msg->queue_msg_group = group;
191 msg->ce_mask |= QUEUE_MSG_ATTR_GROUP;
196 return !!(msg->ce_mask & QUEUE_MSG_ATTR_GROUP);
199uint16_t nfnl_queue_msg_get_group(
const struct nfnl_queue_msg *msg)
201 return msg->queue_msg_group;
209void nfnl_queue_msg_set_family(
struct nfnl_queue_msg *msg, uint8_t family)
211 msg->queue_msg_family = family;
212 msg->ce_mask |= QUEUE_MSG_ATTR_FAMILY;
217 return !!(msg->ce_mask & QUEUE_MSG_ATTR_FAMILY);
220uint8_t nfnl_queue_msg_get_family(
const struct nfnl_queue_msg *msg)
222 if (msg->ce_mask & QUEUE_MSG_ATTR_FAMILY)
223 return msg->queue_msg_family;
228void nfnl_queue_msg_set_packetid(
struct nfnl_queue_msg *msg, uint32_t packetid)
230 msg->queue_msg_packetid = packetid;
231 msg->ce_mask |= QUEUE_MSG_ATTR_PACKETID;
236 return !!(msg->ce_mask & QUEUE_MSG_ATTR_PACKETID);
239uint32_t nfnl_queue_msg_get_packetid(
const struct nfnl_queue_msg *msg)
241 return msg->queue_msg_packetid;
244void nfnl_queue_msg_set_hwproto(
struct nfnl_queue_msg *msg, uint16_t hwproto)
246 msg->queue_msg_hwproto = hwproto;
247 msg->ce_mask |= QUEUE_MSG_ATTR_HWPROTO;
252 return !!(msg->ce_mask & QUEUE_MSG_ATTR_HWPROTO);
255uint16_t nfnl_queue_msg_get_hwproto(
const struct nfnl_queue_msg *msg)
257 return msg->queue_msg_hwproto;
260void nfnl_queue_msg_set_hook(
struct nfnl_queue_msg *msg, uint8_t hook)
262 msg->queue_msg_hook = hook;
263 msg->ce_mask |= QUEUE_MSG_ATTR_HOOK;
268 return !!(msg->ce_mask & QUEUE_MSG_ATTR_HOOK);
273 return msg->queue_msg_hook;
276void nfnl_queue_msg_set_mark(
struct nfnl_queue_msg *msg, uint32_t mark)
278 msg->queue_msg_mark = mark;
279 msg->ce_mask |= QUEUE_MSG_ATTR_MARK;
284 return !!(msg->ce_mask & QUEUE_MSG_ATTR_MARK);
289 return msg->queue_msg_mark;
295 msg->queue_msg_timestamp.tv_sec = tv->tv_sec;
296 msg->queue_msg_timestamp.tv_usec = tv->tv_usec;
297 msg->ce_mask |= QUEUE_MSG_ATTR_TIMESTAMP;
300int nfnl_queue_msg_test_timestamp(
const struct nfnl_queue_msg *msg)
302 return !!(msg->ce_mask & QUEUE_MSG_ATTR_TIMESTAMP);
305const struct timeval *nfnl_queue_msg_get_timestamp(
const struct nfnl_queue_msg *msg)
307 if (!(msg->ce_mask & QUEUE_MSG_ATTR_TIMESTAMP))
309 return &msg->queue_msg_timestamp;
312void nfnl_queue_msg_set_indev(
struct nfnl_queue_msg *msg, uint32_t indev)
314 msg->queue_msg_indev = indev;
315 msg->ce_mask |= QUEUE_MSG_ATTR_INDEV;
320 return !!(msg->ce_mask & QUEUE_MSG_ATTR_INDEV);
323uint32_t nfnl_queue_msg_get_indev(
const struct nfnl_queue_msg *msg)
325 return msg->queue_msg_indev;
328void nfnl_queue_msg_set_outdev(
struct nfnl_queue_msg *msg, uint32_t outdev)
330 msg->queue_msg_outdev = outdev;
331 msg->ce_mask |= QUEUE_MSG_ATTR_OUTDEV;
336 return !!(msg->ce_mask & QUEUE_MSG_ATTR_OUTDEV);
339uint32_t nfnl_queue_msg_get_outdev(
const struct nfnl_queue_msg *msg)
341 return msg->queue_msg_outdev;
347 msg->queue_msg_physindev = physindev;
348 msg->ce_mask |= QUEUE_MSG_ATTR_PHYSINDEV;
351int nfnl_queue_msg_test_physindev(
const struct nfnl_queue_msg *msg)
353 return !!(msg->ce_mask & QUEUE_MSG_ATTR_PHYSINDEV);
356uint32_t nfnl_queue_msg_get_physindev(
const struct nfnl_queue_msg *msg)
358 return msg->queue_msg_physindev;
364 msg->queue_msg_physoutdev = physoutdev;
365 msg->ce_mask |= QUEUE_MSG_ATTR_PHYSOUTDEV;
368int nfnl_queue_msg_test_physoutdev(
const struct nfnl_queue_msg *msg)
370 return !!(msg->ce_mask & QUEUE_MSG_ATTR_PHYSOUTDEV);
373uint32_t nfnl_queue_msg_get_physoutdev(
const struct nfnl_queue_msg *msg)
375 return msg->queue_msg_physoutdev;
378void nfnl_queue_msg_set_hwaddr(
struct nfnl_queue_msg *msg, uint8_t *hwaddr,
381 if (len >
sizeof(msg->queue_msg_hwaddr))
382 len =
sizeof(msg->queue_msg_hwaddr);
384 msg->queue_msg_hwaddr_len = len;
385 memcpy(msg->queue_msg_hwaddr, hwaddr, len);
386 msg->ce_mask |= QUEUE_MSG_ATTR_HWADDR;
391 return !!(msg->ce_mask & QUEUE_MSG_ATTR_HWADDR);
394const uint8_t *nfnl_queue_msg_get_hwaddr(
const struct nfnl_queue_msg *msg,
397 if (!(msg->ce_mask & QUEUE_MSG_ATTR_HWADDR)) {
402 *len = msg->queue_msg_hwaddr_len;
403 return msg->queue_msg_hwaddr;
406int nfnl_queue_msg_set_payload(
struct nfnl_queue_msg *msg, uint8_t *payload,
414 p = _nl_memdup(payload, len);
418 free(msg->queue_msg_payload);
419 msg->queue_msg_payload = p;
420 msg->queue_msg_payload_len = len;
422 msg->ce_mask |= QUEUE_MSG_ATTR_PAYLOAD;
424 msg->ce_mask &= ~QUEUE_MSG_ATTR_PAYLOAD;
430 return !!(msg->ce_mask & QUEUE_MSG_ATTR_PAYLOAD);
433const void *nfnl_queue_msg_get_payload(
const struct nfnl_queue_msg *msg,
int *len)
435 if (!(msg->ce_mask & QUEUE_MSG_ATTR_PAYLOAD)) {
440 *len = msg->queue_msg_payload_len;
441 return msg->queue_msg_payload;
450 unsigned int verdict)
452 msg->queue_msg_verdict = verdict;
453 msg->ce_mask |= QUEUE_MSG_ATTR_VERDICT;
458 return !!(msg->ce_mask & QUEUE_MSG_ATTR_VERDICT);
461unsigned int nfnl_queue_msg_get_verdict(
const struct nfnl_queue_msg *msg)
463 return msg->queue_msg_verdict;
466static const struct trans_tbl nfnl_queue_msg_attrs[] = {
467 __ADD(QUEUE_MSG_ATTR_GROUP, group),
468 __ADD(QUEUE_MSG_ATTR_FAMILY, family),
469 __ADD(QUEUE_MSG_ATTR_PACKETID, packetid),
470 __ADD(QUEUE_MSG_ATTR_HWPROTO, hwproto),
471 __ADD(QUEUE_MSG_ATTR_HOOK, hook),
472 __ADD(QUEUE_MSG_ATTR_MARK, mark),
473 __ADD(QUEUE_MSG_ATTR_TIMESTAMP, timestamp),
474 __ADD(QUEUE_MSG_ATTR_INDEV, indev),
475 __ADD(QUEUE_MSG_ATTR_OUTDEV, outdev),
476 __ADD(QUEUE_MSG_ATTR_PHYSINDEV, physindev),
477 __ADD(QUEUE_MSG_ATTR_PHYSOUTDEV, physoutdev),
478 __ADD(QUEUE_MSG_ATTR_HWADDR, hwaddr),
479 __ADD(QUEUE_MSG_ATTR_PAYLOAD, payload),
480 __ADD(QUEUE_MSG_ATTR_VERDICT, verdict),
483static char *nfnl_queue_msg_attrs2str(
int attrs,
char *buf,
size_t len)
485 return __flags2str(attrs, buf, len, nfnl_queue_msg_attrs,
486 ARRAY_SIZE(nfnl_queue_msg_attrs));
491struct nl_object_ops queue_msg_obj_ops = {
492 .oo_name =
"netfilter/queuemsg",
494 .oo_free_data = nfnl_queue_msg_free_data,
495 .oo_clone = nfnl_queue_msg_clone,
501 .oo_attrs2str = nfnl_queue_msg_attrs2str,
struct nl_cache * nl_cache_mngt_require_safe(const char *name)
Return cache previously provided via nl_cache_mngt_provide()
char * rtnl_link_i2name(struct nl_cache *cache, int ifindex, char *dst, size_t len)
Translate interface index to corresponding link name.
void nl_object_put(struct nl_object *obj)
Release a reference from an object.
void nl_object_get(struct nl_object *obj)
Acquire a reference on a object.
struct nl_object * nl_object_alloc(struct nl_object_ops *ops)
Allocate a new object of kind specified by the operations handle.
void nl_dump(struct nl_dump_params *params, const char *fmt,...)
Dump a formatted character string.
void nl_new_line(struct nl_dump_params *params)
Handle a new line while dumping.
@ NL_DUMP_STATS
Dump all attributes including statistics.
@ NL_DUMP_LINE
Dump object briefly on one line.
@ NL_DUMP_DETAILS
Dump all attributes but no statistics.