1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
/* demultiplex incoming IKE messages
* Copyright (C) 1997 Angelos D. Keromytis.
* Copyright (C) 1998-2002 D. Hugh Redelmeier.
* Copyright (C) 2019 Andrew Cagney <cagney@gnu.org>
*
* This program is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License as published by the
* Free Software Foundation; either version 2 of the License, or (at your
* option) any later version. See <https://www.gnu.org/licenses/gpl2.txt>.
*
* This program is distributed in the hope that it will be useful, but
* WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
* or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
* for more details.
*
*/
#include "defs.h"
#include "log.h"
#include "demux.h" /* needs packet.h */
#include "iface.h"
struct msg_digest *alloc_md(struct iface_endpoint *ifp,
const ip_endpoint *sender,
const uint8_t *packet, size_t packet_len,
where_t where)
{
struct msg_digest *md = refcnt_overalloc(struct msg_digest, packet_len, where);
md->iface = iface_endpoint_addref_where(ifp, where);
md->sender = *sender;
md->logger = alloc_logger(md, &logger_message_vec,
/*debugging*/LEMPTY, where);
void *buffer = md + 1;
md->packet_pbs = pbs_in_from_shunk(shunk2(buffer, packet_len), "packet");
if (packet != NULL) {
memcpy(buffer, packet, packet_len);
}
return md;
}
struct msg_digest *clone_raw_md(struct msg_digest *md, where_t where)
{
shunk_t packet = pbs_in_all(&md->packet_pbs);
struct msg_digest *clone = alloc_md(md->iface, &md->sender,
packet.ptr, packet.len,
where);
clone->fake_clone = true;
clone->md_inception = threadtime_start();
return clone;
}
struct msg_digest *md_addref_where(struct msg_digest *md, where_t where)
{
return addref_where(md, where);
}
void md_delref_where(struct msg_digest **mdp, where_t where)
{
/* need non-NULL so .logger is available */
const struct logger *logger = (*mdp != NULL ? (*mdp)->logger : &global_logger);
struct msg_digest *md = delref_where(mdp, logger, where);
if (md != NULL) {
free_chunk_content(&md->raw_packet);
free_logger(&md->logger, where);
iface_endpoint_delref_where(&md->iface, where);
pfree(md);
}
}
|
