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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
|
/**
* coopgammad -- Cooperative gamma server
* Copyright (C) 2016 Mattias Andrée (maandree@kth.se)
*
* 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 3 of the License, or
* (at your option) any later version.
*
* 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.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#include "filter.h"
#include "util.h"
#include <stdlib.h>
#include <string.h>
/**
* Free all resources allocated to a filter.
* The allocation of `filter` itself is not freed.
*
* @param this The filter
*/
void filter_destroy(struct filter* this)
{
free(this->class);
free(this->ramps);
}
/**
* Marshal a filter
*
* @param this The filter
* @param buf Output buffer for the marshalled filter,
* `NULL` just measure how large the buffers
* needs to be
* @param ramps_size The byte-size of `this->ramps`
* @return The number of marshalled byte
*/
size_t filter_marshal(const struct filter* this, void* buf, size_t ramps_size)
{
size_t off = 0, n;
char nonnulls = 0;
char* bs = buf;
if (bs != NULL)
{
if (this->class != NULL) nonnulls |= 1;
if (this->ramps != NULL) nonnulls |= 2;
*(bs + off) = nonnulls;
}
off += 1;
if (bs != NULL)
*(int64_t*)(bs + off) = this->priority;
off += sizeof(int64_t);
if (bs != NULL)
*(enum lifespan*)(bs + off) = this->lifespan;
off += sizeof(enum lifespan);
if (this->class != NULL)
{
n = strlen(this->class) + 1;
if (bs != NULL)
memcpy(bs + off, this->class, n);
off += n;
}
if (this->ramps != NULL)
{
if (bs != NULL)
memcpy(bs + off, this->ramps, ramps_size);
off += ramps_size;
}
return off;
}
/**
* Unmarshal a filter
*
* @param this Output for the filter
* @param buf Buffer with the marshalled filter
* @param ramps_size The byte-size of `this->ramps`
* @return The number of unmarshalled bytes, 0 on error
*/
size_t filter_unmarshal(struct filter* this, const void* buf, size_t ramps_size)
{
size_t off = 0, n;
char nonnulls = 0;
const char* bs = buf;
nonnulls = *(bs + off);
off += 1;
this->class = NULL;
this->ramps = NULL;
this->priority = *(const int64_t*)(bs + off);
off += sizeof(int64_t);
this->lifespan = *(const enum lifespan*)(bs + off);
off += sizeof(enum lifespan);
if (nonnulls & 1)
{
n = strlen(bs + off) + 1;
if (!(this->class = memdup(bs + off, n)))
goto fail;
off += n;
}
if (nonnulls & 2)
{
if (!(this->ramps = memdup(bs + off, ramps_size)))
goto fail;
off += ramps_size;
}
return off;
fail:
free(this->class);
free(this->ramps);
return 0;
}
|
