aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_cp.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/fs/gnunet-service-fs_cp.h')
-rw-r--r--src/fs/gnunet-service-fs_cp.h77
1 files changed, 39 insertions, 38 deletions
diff --git a/src/fs/gnunet-service-fs_cp.h b/src/fs/gnunet-service-fs_cp.h
index 9eab3d9de..c17b6a0a8 100644
--- a/src/fs/gnunet-service-fs_cp.h
+++ b/src/fs/gnunet-service-fs_cp.h
@@ -60,7 +60,8 @@
60/** 60/**
61 * Performance data kept for a peer. 61 * Performance data kept for a peer.
62 */ 62 */
63struct GSF_PeerPerformanceData { 63struct GSF_PeerPerformanceData
64{
64 /** 65 /**
65 * List of the last clients for which this peer successfully 66 * List of the last clients for which this peer successfully
66 * answered a query. 67 * answered a query.
@@ -202,9 +203,9 @@ struct GSF_PeerTransmitHandle;
202 * @return internal handle for the peer 203 * @return internal handle for the peer
203 */ 204 */
204void * 205void *
205GSF_peer_connect_handler(void *cls, 206GSF_peer_connect_handler (void *cls,
206 const struct GNUNET_PeerIdentity *peer, 207 const struct GNUNET_PeerIdentity *peer,
207 struct GNUNET_MQ_Handle *mq); 208 struct GNUNET_MQ_Handle *mq);
208 209
209 210
210/** 211/**
@@ -214,7 +215,7 @@ GSF_peer_connect_handler(void *cls,
214 * @return NULL if this peer is not currently connected 215 * @return NULL if this peer is not currently connected
215 */ 216 */
216struct GSF_ConnectedPeer * 217struct GSF_ConnectedPeer *
217GSF_peer_get_(const struct GNUNET_PeerIdentity *peer); 218GSF_peer_get_ (const struct GNUNET_PeerIdentity *peer);
218 219
219 220
220/** 221/**
@@ -224,8 +225,8 @@ GSF_peer_get_(const struct GNUNET_PeerIdentity *peer);
224 * @param latency current latency value 225 * @param latency current latency value
225 */ 226 */
226void 227void
227GSF_update_peer_latency_(const struct GNUNET_PeerIdentity *id, 228GSF_update_peer_latency_ (const struct GNUNET_PeerIdentity *id,
228 struct GNUNET_TIME_Relative latency); 229 struct GNUNET_TIME_Relative latency);
229 230
230 231
231/** 232/**
@@ -239,10 +240,10 @@ GSF_update_peer_latency_(const struct GNUNET_PeerIdentity *id,
239 * @param env envelope of message to send 240 * @param env envelope of message to send
240 */ 241 */
241void 242void
242GSF_peer_transmit_(struct GSF_ConnectedPeer *cp, 243GSF_peer_transmit_ (struct GSF_ConnectedPeer *cp,
243 int is_query, 244 int is_query,
244 uint32_t priority, 245 uint32_t priority,
245 struct GNUNET_MQ_Envelope *env); 246 struct GNUNET_MQ_Envelope *env);
246 247
247 248
248/** 249/**
@@ -253,9 +254,9 @@ GSF_peer_transmit_(struct GSF_ConnectedPeer *cp,
253 * @param request_priority priority of the original request 254 * @param request_priority priority of the original request
254 */ 255 */
255void 256void
256GSF_peer_update_performance_(struct GSF_ConnectedPeer *cp, 257GSF_peer_update_performance_ (struct GSF_ConnectedPeer *cp,
257 struct GNUNET_TIME_Absolute request_time, 258 struct GNUNET_TIME_Absolute request_time,
258 uint32_t request_priority); 259 uint32_t request_priority);
259 260
260 261
261/** 262/**
@@ -266,8 +267,8 @@ GSF_peer_update_performance_(struct GSF_ConnectedPeer *cp,
266 * @param initiator_client local client on responsible for query 267 * @param initiator_client local client on responsible for query
267 */ 268 */
268void 269void
269GSF_peer_update_responder_client_(struct GSF_ConnectedPeer *cp, 270GSF_peer_update_responder_client_ (struct GSF_ConnectedPeer *cp,
270 struct GSF_LocalClient *initiator_client); 271 struct GSF_LocalClient *initiator_client);
271 272
272 273
273/** 274/**
@@ -278,9 +279,9 @@ GSF_peer_update_responder_client_(struct GSF_ConnectedPeer *cp,
278 * @param initiator_peer other peer responsible for query 279 * @param initiator_peer other peer responsible for query
279 */ 280 */
280void 281void
281GSF_peer_update_responder_peer_(struct GSF_ConnectedPeer *cp, 282GSF_peer_update_responder_peer_ (struct GSF_ConnectedPeer *cp,
282 const struct GSF_ConnectedPeer 283 const struct GSF_ConnectedPeer
283 *initiator_peer); 284 *initiator_peer);
284 285
285 286
286/** 287/**
@@ -290,8 +291,8 @@ GSF_peer_update_responder_peer_(struct GSF_ConnectedPeer *cp,
290 * @param msm the actual message 291 * @param msm the actual message
291 */ 292 */
292void 293void
293handle_p2p_migration_stop(void *cls, 294handle_p2p_migration_stop (void *cls,
294 const struct MigrationStopMessage *message); 295 const struct MigrationStopMessage *message);
295 296
296 297
297/** 298/**
@@ -301,8 +302,8 @@ handle_p2p_migration_stop(void *cls,
301 * @param gm the actual message 302 * @param gm the actual message
302 */ 303 */
303void 304void
304handle_p2p_get(void *cls, 305handle_p2p_get (void *cls,
305 const struct GetMessage *gm); 306 const struct GetMessage *gm);
306 307
307 308
308/** 309/**
@@ -312,7 +313,7 @@ handle_p2p_get(void *cls,
312 * @return performance data record for the peer 313 * @return performance data record for the peer
313 */ 314 */
314struct GSF_PeerPerformanceData * 315struct GSF_PeerPerformanceData *
315GSF_get_peer_performance_data_(struct GSF_ConnectedPeer *cp); 316GSF_get_peer_performance_data_ (struct GSF_ConnectedPeer *cp);
316 317
317 318
318/** 319/**
@@ -323,8 +324,8 @@ GSF_get_peer_performance_data_(struct GSF_ConnectedPeer *cp);
323 * @param block_time until when to block 324 * @param block_time until when to block
324 */ 325 */
325void 326void
326GSF_block_peer_migration_(struct GSF_ConnectedPeer *cp, 327GSF_block_peer_migration_ (struct GSF_ConnectedPeer *cp,
327 struct GNUNET_TIME_Absolute block_time); 328 struct GNUNET_TIME_Absolute block_time);
328 329
329 330
330/** 331/**
@@ -336,9 +337,9 @@ GSF_block_peer_migration_(struct GSF_ConnectedPeer *cp,
336 * @param internal_cls our `struct GSF_ConnectedPeer` for @a peer 337 * @param internal_cls our `struct GSF_ConnectedPeer` for @a peer
337 */ 338 */
338void 339void
339GSF_peer_disconnect_handler(void *cls, 340GSF_peer_disconnect_handler (void *cls,
340 const struct GNUNET_PeerIdentity *peer, 341 const struct GNUNET_PeerIdentity *peer,
341 void *internal_cls); 342 void *internal_cls);
342 343
343 344
344/** 345/**
@@ -348,7 +349,7 @@ GSF_peer_disconnect_handler(void *cls,
348 * @param lc handle to the local client (henceforth invalid) 349 * @param lc handle to the local client (henceforth invalid)
349 */ 350 */
350void 351void
351GSF_handle_local_client_disconnect_(const struct GSF_LocalClient *lc); 352GSF_handle_local_client_disconnect_ (const struct GSF_LocalClient *lc);
352 353
353 354
354/** 355/**
@@ -361,8 +362,8 @@ GSF_handle_local_client_disconnect_(const struct GSF_LocalClient *lc);
361 * @param pref preference change 362 * @param pref preference change
362 */ 363 */
363void 364void
364GSF_connected_peer_change_preference_(struct GSF_ConnectedPeer *cp, 365GSF_connected_peer_change_preference_ (struct GSF_ConnectedPeer *cp,
365 uint64_t pref); 366 uint64_t pref);
366 367
367 368
368/** 369/**
@@ -372,8 +373,8 @@ GSF_connected_peer_change_preference_(struct GSF_ConnectedPeer *cp,
372 * @param id identity to set (written to) 373 * @param id identity to set (written to)
373 */ 374 */
374void 375void
375GSF_connected_peer_get_identity_(const struct GSF_ConnectedPeer *cp, 376GSF_connected_peer_get_identity_ (const struct GSF_ConnectedPeer *cp,
376 struct GNUNET_PeerIdentity *id); 377 struct GNUNET_PeerIdentity *id);
377 378
378 379
379/** 380/**
@@ -383,7 +384,7 @@ GSF_connected_peer_get_identity_(const struct GSF_ConnectedPeer *cp,
383 * @return reference to peer identity, valid until peer disconnects (!) 384 * @return reference to peer identity, valid until peer disconnects (!)
384 */ 385 */
385const struct GNUNET_PeerIdentity * 386const struct GNUNET_PeerIdentity *
386GSF_connected_peer_get_identity2_(const struct GSF_ConnectedPeer *cp); 387GSF_connected_peer_get_identity2_ (const struct GSF_ConnectedPeer *cp);
387 388
388 389
389 390
@@ -394,21 +395,21 @@ GSF_connected_peer_get_identity2_(const struct GSF_ConnectedPeer *cp);
394 * @param it_cls closure for it 395 * @param it_cls closure for it
395 */ 396 */
396void 397void
397GSF_iterate_connected_peers_(GSF_ConnectedPeerIterator it, void *it_cls); 398GSF_iterate_connected_peers_ (GSF_ConnectedPeerIterator it, void *it_cls);
398 399
399 400
400/** 401/**
401 * Initialize peer management subsystem. 402 * Initialize peer management subsystem.
402 */ 403 */
403void 404void
404GSF_connected_peer_init_(void); 405GSF_connected_peer_init_ (void);
405 406
406 407
407/** 408/**
408 * Shutdown peer management subsystem. 409 * Shutdown peer management subsystem.
409 */ 410 */
410void 411void
411GSF_connected_peer_done_(void); 412GSF_connected_peer_done_ (void);
412 413
413 414
414#endif 415#endif