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
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
|
/*
This file is part of GNUnet
Copyright (C) 2013-2017 GNUnet e.V.
GNUnet 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.
GNUnet 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
Affero General Public License for more details.
*/
/**
* @file set/gnunet-service-set_union.h
* @brief two-peer set operations
* @author Florian Dold
* @author Christian Grothoff
*/
#ifndef GNUNET_SERVICE_SET_UNION_H
#define GNUNET_SERVICE_SET_UNION_H
#include "gnunet-service-set.h"
#include "gnunet-service-set_protocol.h"
/**
* Handle a strata estimator from a remote peer
*
* @param cls the union operation
* @param msg the message
*/
int
check_union_p2p_strata_estimator (void *cls,
const struct StrataEstimatorMessage *msg);
/**
* Handle a strata estimator from a remote peer
*
* @param cls the union operation
* @param msg the message
*/
void
handle_union_p2p_strata_estimator (void *cls,
const struct StrataEstimatorMessage *msg);
/**
* Check an IBF message from a remote peer.
*
* Reassemble the IBF from multiple pieces, and
* process the whole IBF once possible.
*
* @param cls the union operation
* @param msg the header of the message
* @return #GNUNET_OK if @a msg is well-formed
*/
int
check_union_p2p_ibf (void *cls,
const struct IBFMessage *msg);
/**
* Handle an IBF message from a remote peer.
*
* Reassemble the IBF from multiple pieces, and
* process the whole IBF once possible.
*
* @param cls the union operation
* @param msg the header of the message
*/
void
handle_union_p2p_ibf (void *cls,
const struct IBFMessage *msg);
/**
* Check an element message from a remote peer.
*
* @param cls the union operation
* @param emsg the message
*/
int
check_union_p2p_elements (void *cls,
const struct GNUNET_SET_ElementMessage *emsg);
/**
* Handle an element message from a remote peer.
* Sent by the other peer either because we decoded an IBF and placed a demand,
* or because the other peer switched to full set transmission.
*
* @param cls the union operation
* @param emsg the message
*/
void
handle_union_p2p_elements (void *cls,
const struct GNUNET_SET_ElementMessage *emsg);
/**
* Check a full element message from a remote peer.
*
* @param cls the union operation
* @param emsg the message
*/
int
check_union_p2p_full_element (void *cls,
const struct GNUNET_SET_ElementMessage *emsg);
/**
* Handle an element message from a remote peer.
*
* @param cls the union operation
* @param emsg the message
*/
void
handle_union_p2p_full_element (void *cls,
const struct GNUNET_SET_ElementMessage *emsg);
/**
* Send offers (for GNUNET_Hash-es) in response
* to inquiries (for IBF_Key-s).
*
* @param cls the union operation
* @param msg the message
*/
int
check_union_p2p_inquiry (void *cls,
const struct InquiryMessage *msg);
/**
* Send offers (for GNUNET_Hash-es) in response
* to inquiries (for IBF_Key-s).
*
* @param cls the union operation
* @param msg the message
*/
void
handle_union_p2p_inquiry (void *cls,
const struct InquiryMessage *msg);
/**
* Handle a request for full set transmission.
*
* @parem cls closure, a set union operation
* @param mh the demand message
*/
void
handle_union_p2p_request_full (void *cls,
const struct GNUNET_MessageHeader *mh);
/**
* Handle a "full done" message.
*
* @parem cls closure, a set union operation
* @param mh the demand message
*/
void
handle_union_p2p_full_done (void *cls,
const struct GNUNET_MessageHeader *mh);
/**
* Check a demand by the other peer for elements based on a list
* of `struct GNUNET_HashCode`s.
*
* @parem cls closure, a set union operation
* @param mh the demand message
* @return #GNUNET_OK if @a mh is well-formed
*/
int
check_union_p2p_demand (void *cls,
const struct GNUNET_MessageHeader *mh);
/**
* Handle a demand by the other peer for elements based on a list
* of `struct GNUNET_HashCode`s.
*
* @parem cls closure, a set union operation
* @param mh the demand message
*/
void
handle_union_p2p_demand (void *cls,
const struct GNUNET_MessageHeader *mh);
/**
* Check offer (of `struct GNUNET_HashCode`s).
*
* @param cls the union operation
* @param mh the message
* @return #GNUNET_OK if @a mh is well-formed
*/
int
check_union_p2p_offer (void *cls,
const struct GNUNET_MessageHeader *mh);
/**
* Handle offers (of `struct GNUNET_HashCode`s) and
* respond with demands (of `struct GNUNET_HashCode`s).
*
* @param cls the union operation
* @param mh the message
*/
void
handle_union_p2p_offer (void *cls,
const struct GNUNET_MessageHeader *mh);
/**
* Handle a done message from a remote peer
*
* @param cls the union operation
* @param mh the message
*/
void
handle_union_p2p_done (void *cls,
const struct GNUNET_MessageHeader *mh);
/**
* Handle an over message from a remote peer
*
* @param cls the union operation
* @param mh the message
*/
void
handle_union_p2p_over (void *cls,
const struct GNUNET_MessageHeader *mh);
#endif
|
