libnl  3.2.11
log_msg_obj.c
1 /*
2  * lib/netfilter/log_msg_obj.c Netfilter Log Object
3  *
4  * This library is free software; you can redistribute it and/or
5  * modify it under the terms of the GNU Lesser General Public
6  * License as published by the Free Software Foundation version 2.1
7  * of the License.
8  *
9  * Copyright (c) 2003-2008 Thomas Graf <tgraf@suug.ch>
10  * Copyright (c) 2007 Philip Craig <philipc@snapgear.com>
11  * Copyright (c) 2007 Secure Computing Corporation
12  */
13 
14 #include <netlink-local.h>
15 #include <netlink/netfilter/nfnl.h>
16 #include <netlink/netfilter/netfilter.h>
17 #include <netlink/netfilter/log_msg.h>
18 
19 /** @cond SKIP */
20 #define LOG_MSG_ATTR_FAMILY (1UL << 0)
21 #define LOG_MSG_ATTR_HWPROTO (1UL << 1)
22 #define LOG_MSG_ATTR_HOOK (1UL << 2)
23 #define LOG_MSG_ATTR_MARK (1UL << 3)
24 #define LOG_MSG_ATTR_TIMESTAMP (1UL << 4)
25 #define LOG_MSG_ATTR_INDEV (1UL << 5)
26 #define LOG_MSG_ATTR_OUTDEV (1UL << 6)
27 #define LOG_MSG_ATTR_PHYSINDEV (1UL << 7)
28 #define LOG_MSG_ATTR_PHYSOUTDEV (1UL << 8)
29 #define LOG_MSG_ATTR_HWADDR (1UL << 9)
30 #define LOG_MSG_ATTR_PAYLOAD (1UL << 10)
31 #define LOG_MSG_ATTR_PREFIX (1UL << 11)
32 #define LOG_MSG_ATTR_UID (1UL << 12)
33 #define LOG_MSG_ATTR_GID (1UL << 13)
34 #define LOG_MSG_ATTR_SEQ (1UL << 14)
35 #define LOG_MSG_ATTR_SEQ_GLOBAL (1UL << 15)
36 /** @endcond */
37 
38 static void log_msg_free_data(struct nl_object *c)
39 {
40  struct nfnl_log_msg *msg = (struct nfnl_log_msg *) c;
41 
42  if (msg == NULL)
43  return;
44 
45  free(msg->log_msg_payload);
46  free(msg->log_msg_prefix);
47 }
48 
49 static int log_msg_clone(struct nl_object *_dst, struct nl_object *_src)
50 {
51  struct nfnl_log_msg *dst = (struct nfnl_log_msg *) _dst;
52  struct nfnl_log_msg *src = (struct nfnl_log_msg *) _src;
53  int err;
54 
55  if (src->log_msg_payload) {
56  err = nfnl_log_msg_set_payload(dst, src->log_msg_payload,
57  src->log_msg_payload_len);
58  if (err < 0)
59  goto errout;
60  }
61 
62  if (src->log_msg_prefix) {
63  err = nfnl_log_msg_set_prefix(dst, src->log_msg_prefix);
64  if (err < 0)
65  goto errout;
66  }
67 
68  return 0;
69 errout:
70  return err;
71 }
72 
73 static void log_msg_dump(struct nl_object *a, struct nl_dump_params *p)
74 {
75  struct nfnl_log_msg *msg = (struct nfnl_log_msg *) a;
76  struct nl_cache *link_cache;
77  char buf[64];
78 
79  link_cache = nl_cache_mngt_require("route/link");
80 
81  nl_new_line(p);
82 
83  if (msg->ce_mask & LOG_MSG_ATTR_PREFIX)
84  nl_dump(p, "%s", msg->log_msg_prefix);
85 
86  if (msg->ce_mask & LOG_MSG_ATTR_INDEV) {
87  if (link_cache)
88  nl_dump(p, "IN=%s ",
89  rtnl_link_i2name(link_cache,
90  msg->log_msg_indev,
91  buf, sizeof(buf)));
92  else
93  nl_dump(p, "IN=%d ", msg->log_msg_indev);
94  }
95 
96  if (msg->ce_mask & LOG_MSG_ATTR_PHYSINDEV) {
97  if (link_cache)
98  nl_dump(p, "PHYSIN=%s ",
99  rtnl_link_i2name(link_cache,
100  msg->log_msg_physindev,
101  buf, sizeof(buf)));
102  else
103  nl_dump(p, "IN=%d ", msg->log_msg_physindev);
104  }
105 
106  if (msg->ce_mask & LOG_MSG_ATTR_OUTDEV) {
107  if (link_cache)
108  nl_dump(p, "OUT=%s ",
109  rtnl_link_i2name(link_cache,
110  msg->log_msg_outdev,
111  buf, sizeof(buf)));
112  else
113  nl_dump(p, "OUT=%d ", msg->log_msg_outdev);
114  }
115 
116  if (msg->ce_mask & LOG_MSG_ATTR_PHYSOUTDEV) {
117  if (link_cache)
118  nl_dump(p, "PHYSOUT=%s ",
119  rtnl_link_i2name(link_cache,
120  msg->log_msg_physoutdev,
121  buf, sizeof(buf)));
122  else
123  nl_dump(p, "PHYSOUT=%d ", msg->log_msg_physoutdev);
124  }
125 
126  if (msg->ce_mask & LOG_MSG_ATTR_HWADDR) {
127  int i;
128 
129  nl_dump(p, "MAC");
130  for (i = 0; i < msg->log_msg_hwaddr_len; i++)
131  nl_dump(p, "%c%02x", i?':':'=', msg->log_msg_hwaddr[i]);
132  nl_dump(p, " ");
133  }
134 
135  /* FIXME: parse the payload to get iptables LOG compatible format */
136 
137  if (msg->ce_mask & LOG_MSG_ATTR_FAMILY)
138  nl_dump(p, "FAMILY=%s ",
139  nl_af2str(msg->log_msg_family, buf, sizeof(buf)));
140 
141  if (msg->ce_mask & LOG_MSG_ATTR_HWPROTO)
142  nl_dump(p, "HWPROTO=%s ",
143  nl_ether_proto2str(ntohs(msg->log_msg_hwproto),
144  buf, sizeof(buf)));
145 
146  if (msg->ce_mask & LOG_MSG_ATTR_HOOK)
147  nl_dump(p, "HOOK=%s ",
148  nfnl_inet_hook2str(msg->log_msg_hook,
149  buf, sizeof(buf)));
150 
151  if (msg->ce_mask & LOG_MSG_ATTR_MARK)
152  nl_dump(p, "MARK=%u ", msg->log_msg_mark);
153 
154  if (msg->ce_mask & LOG_MSG_ATTR_PAYLOAD)
155  nl_dump(p, "PAYLOADLEN=%d ", msg->log_msg_payload_len);
156 
157  if (msg->ce_mask & LOG_MSG_ATTR_UID)
158  nl_dump(p, "UID=%u ", msg->log_msg_uid);
159 
160  if (msg->ce_mask & LOG_MSG_ATTR_GID)
161  nl_dump(p, "GID=%u ", msg->log_msg_gid);
162 
163  if (msg->ce_mask & LOG_MSG_ATTR_SEQ)
164  nl_dump(p, "SEQ=%d ", msg->log_msg_seq);
165 
166  if (msg->ce_mask & LOG_MSG_ATTR_SEQ_GLOBAL)
167  nl_dump(p, "SEQGLOBAL=%d ", msg->log_msg_seq_global);
168 
169  nl_dump(p, "\n");
170 }
171 
172 /**
173  * @name Allocation/Freeing
174  * @{
175  */
176 
177 struct nfnl_log_msg *nfnl_log_msg_alloc(void)
178 {
179  return (struct nfnl_log_msg *) nl_object_alloc(&log_msg_obj_ops);
180 }
181 
182 void nfnl_log_msg_get(struct nfnl_log_msg *msg)
183 {
184  nl_object_get((struct nl_object *) msg);
185 }
186 
187 void nfnl_log_msg_put(struct nfnl_log_msg *msg)
188 {
189  nl_object_put((struct nl_object *) msg);
190 }
191 
192 /** @} */
193 
194 /**
195  * @name Attributes
196  * @{
197  */
198 
199 void nfnl_log_msg_set_family(struct nfnl_log_msg *msg, uint8_t family)
200 {
201  msg->log_msg_family = family;
202  msg->ce_mask |= LOG_MSG_ATTR_FAMILY;
203 }
204 
205 uint8_t nfnl_log_msg_get_family(const struct nfnl_log_msg *msg)
206 {
207  if (msg->ce_mask & LOG_MSG_ATTR_FAMILY)
208  return msg->log_msg_family;
209  else
210  return AF_UNSPEC;
211 }
212 
213 void nfnl_log_msg_set_hwproto(struct nfnl_log_msg *msg, uint16_t hwproto)
214 {
215  msg->log_msg_hwproto = hwproto;
216  msg->ce_mask |= LOG_MSG_ATTR_HWPROTO;
217 }
218 
219 int nfnl_log_msg_test_hwproto(const struct nfnl_log_msg *msg)
220 {
221  return !!(msg->ce_mask & LOG_MSG_ATTR_HWPROTO);
222 }
223 
224 uint16_t nfnl_log_msg_get_hwproto(const struct nfnl_log_msg *msg)
225 {
226  return msg->log_msg_hwproto;
227 }
228 
229 void nfnl_log_msg_set_hook(struct nfnl_log_msg *msg, uint8_t hook)
230 {
231  msg->log_msg_hook = hook;
232  msg->ce_mask |= LOG_MSG_ATTR_HOOK;
233 }
234 
235 int nfnl_log_msg_test_hook(const struct nfnl_log_msg *msg)
236 {
237  return !!(msg->ce_mask & LOG_MSG_ATTR_HOOK);
238 }
239 
240 uint8_t nfnl_log_msg_get_hook(const struct nfnl_log_msg *msg)
241 {
242  return msg->log_msg_hook;
243 }
244 
245 void nfnl_log_msg_set_mark(struct nfnl_log_msg *msg, uint32_t mark)
246 {
247  msg->log_msg_mark = mark;
248  msg->ce_mask |= LOG_MSG_ATTR_MARK;
249 }
250 
251 int nfnl_log_msg_test_mark(const struct nfnl_log_msg *msg)
252 {
253  return !!(msg->ce_mask & LOG_MSG_ATTR_MARK);
254 }
255 
256 uint32_t nfnl_log_msg_get_mark(const struct nfnl_log_msg *msg)
257 {
258  return msg->log_msg_mark;
259 }
260 
261 void nfnl_log_msg_set_timestamp(struct nfnl_log_msg *msg, struct timeval *tv)
262 {
263  msg->log_msg_timestamp.tv_sec = tv->tv_sec;
264  msg->log_msg_timestamp.tv_usec = tv->tv_usec;
265  msg->ce_mask |= LOG_MSG_ATTR_TIMESTAMP;
266 }
267 
268 const struct timeval *nfnl_log_msg_get_timestamp(const struct nfnl_log_msg *msg)
269 {
270  if (!(msg->ce_mask & LOG_MSG_ATTR_TIMESTAMP))
271  return NULL;
272  return &msg->log_msg_timestamp;
273 }
274 
275 void nfnl_log_msg_set_indev(struct nfnl_log_msg *msg, uint32_t indev)
276 {
277  msg->log_msg_indev = indev;
278  msg->ce_mask |= LOG_MSG_ATTR_INDEV;
279 }
280 
281 uint32_t nfnl_log_msg_get_indev(const struct nfnl_log_msg *msg)
282 {
283  return msg->log_msg_indev;
284 }
285 
286 void nfnl_log_msg_set_outdev(struct nfnl_log_msg *msg, uint32_t outdev)
287 {
288  msg->log_msg_outdev = outdev;
289  msg->ce_mask |= LOG_MSG_ATTR_OUTDEV;
290 }
291 
292 uint32_t nfnl_log_msg_get_outdev(const struct nfnl_log_msg *msg)
293 {
294  return msg->log_msg_outdev;
295 }
296 
297 void nfnl_log_msg_set_physindev(struct nfnl_log_msg *msg, uint32_t physindev)
298 {
299  msg->log_msg_physindev = physindev;
300  msg->ce_mask |= LOG_MSG_ATTR_PHYSINDEV;
301 }
302 
303 uint32_t nfnl_log_msg_get_physindev(const struct nfnl_log_msg *msg)
304 {
305  return msg->log_msg_physindev;
306 }
307 
308 void nfnl_log_msg_set_physoutdev(struct nfnl_log_msg *msg, uint32_t physoutdev)
309 {
310  msg->log_msg_physoutdev = physoutdev;
311  msg->ce_mask |= LOG_MSG_ATTR_PHYSOUTDEV;
312 }
313 
314 uint32_t nfnl_log_msg_get_physoutdev(const struct nfnl_log_msg *msg)
315 {
316  return msg->log_msg_physoutdev;
317 }
318 
319 void nfnl_log_msg_set_hwaddr(struct nfnl_log_msg *msg, uint8_t *hwaddr, int len)
320 {
321  if (len > sizeof(msg->log_msg_hwaddr))
322  len = sizeof(msg->log_msg_hwaddr);
323  msg->log_msg_hwaddr_len = len;
324  memcpy(msg->log_msg_hwaddr, hwaddr, len);
325  msg->ce_mask |= LOG_MSG_ATTR_HWADDR;
326 }
327 
328 const uint8_t *nfnl_log_msg_get_hwaddr(const struct nfnl_log_msg *msg, int *len)
329 {
330  if (!(msg->ce_mask & LOG_MSG_ATTR_HWADDR)) {
331  *len = 0;
332  return NULL;
333  }
334 
335  *len = msg->log_msg_hwaddr_len;
336  return msg->log_msg_hwaddr;
337 }
338 
339 int nfnl_log_msg_set_payload(struct nfnl_log_msg *msg, uint8_t *payload, int len)
340 {
341  free(msg->log_msg_payload);
342  msg->log_msg_payload = malloc(len);
343  if (!msg->log_msg_payload)
344  return -NLE_NOMEM;
345 
346  memcpy(msg->log_msg_payload, payload, len);
347  msg->log_msg_payload_len = len;
348  msg->ce_mask |= LOG_MSG_ATTR_PAYLOAD;
349  return 0;
350 }
351 
352 const void *nfnl_log_msg_get_payload(const struct nfnl_log_msg *msg, int *len)
353 {
354  if (!(msg->ce_mask & LOG_MSG_ATTR_PAYLOAD)) {
355  *len = 0;
356  return NULL;
357  }
358 
359  *len = msg->log_msg_payload_len;
360  return msg->log_msg_payload;
361 }
362 
363 int nfnl_log_msg_set_prefix(struct nfnl_log_msg *msg, void *prefix)
364 {
365  free(msg->log_msg_prefix);
366  msg->log_msg_prefix = strdup(prefix);
367  if (!msg->log_msg_prefix)
368  return -NLE_NOMEM;
369 
370  msg->ce_mask |= LOG_MSG_ATTR_PREFIX;
371  return 0;
372 }
373 
374 const char *nfnl_log_msg_get_prefix(const struct nfnl_log_msg *msg)
375 {
376  return msg->log_msg_prefix;
377 }
378 
379 void nfnl_log_msg_set_uid(struct nfnl_log_msg *msg, uint32_t uid)
380 {
381  msg->log_msg_uid = uid;
382  msg->ce_mask |= LOG_MSG_ATTR_UID;
383 }
384 
385 int nfnl_log_msg_test_uid(const struct nfnl_log_msg *msg)
386 {
387  return !!(msg->ce_mask & LOG_MSG_ATTR_UID);
388 }
389 
390 uint32_t nfnl_log_msg_get_uid(const struct nfnl_log_msg *msg)
391 {
392  return msg->log_msg_uid;
393 }
394 
395 void nfnl_log_msg_set_gid(struct nfnl_log_msg *msg, uint32_t gid)
396 {
397  msg->log_msg_gid = gid;
398  msg->ce_mask |= LOG_MSG_ATTR_GID;
399 }
400 
401 int nfnl_log_msg_test_gid(const struct nfnl_log_msg *msg)
402 {
403  return !!(msg->ce_mask & LOG_MSG_ATTR_GID);
404 }
405 
406 uint32_t nfnl_log_msg_get_gid(const struct nfnl_log_msg *msg)
407 {
408  return msg->log_msg_gid;
409 }
410 
411 
412 void nfnl_log_msg_set_seq(struct nfnl_log_msg *msg, uint32_t seq)
413 {
414  msg->log_msg_seq = seq;
415  msg->ce_mask |= LOG_MSG_ATTR_SEQ;
416 }
417 
418 int nfnl_log_msg_test_seq(const struct nfnl_log_msg *msg)
419 {
420  return !!(msg->ce_mask & LOG_MSG_ATTR_SEQ);
421 }
422 
423 uint32_t nfnl_log_msg_get_seq(const struct nfnl_log_msg *msg)
424 {
425  return msg->log_msg_seq;
426 }
427 
428 void nfnl_log_msg_set_seq_global(struct nfnl_log_msg *msg, uint32_t seq_global)
429 {
430  msg->log_msg_seq_global = seq_global;
431  msg->ce_mask |= LOG_MSG_ATTR_SEQ_GLOBAL;
432 }
433 
434 int nfnl_log_msg_test_seq_global(const struct nfnl_log_msg *msg)
435 {
436  return !!(msg->ce_mask & LOG_MSG_ATTR_SEQ_GLOBAL);
437 }
438 
439 uint32_t nfnl_log_msg_get_seq_global(const struct nfnl_log_msg *msg)
440 {
441  return msg->log_msg_seq_global;
442 }
443 
444 /** @} */
445 
446 struct nl_object_ops log_msg_obj_ops = {
447  .oo_name = "netfilter/log_msg",
448  .oo_size = sizeof(struct nfnl_log_msg),
449  .oo_free_data = log_msg_free_data,
450  .oo_clone = log_msg_clone,
451  .oo_dump = {
452  [NL_DUMP_LINE] = log_msg_dump,
453  [NL_DUMP_DETAILS] = log_msg_dump,
454  [NL_DUMP_STATS] = log_msg_dump,
455  },
456 };
457 
458 /** @} */