diff options
Diffstat (limited to 'src/fs/gnunet-service-fs_cp.h')
-rw-r--r-- | src/fs/gnunet-service-fs_cp.h | 77 |
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 | */ |
63 | struct GSF_PeerPerformanceData { | 63 | struct 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 | */ |
204 | void * | 205 | void * |
205 | GSF_peer_connect_handler(void *cls, | 206 | GSF_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 | */ |
216 | struct GSF_ConnectedPeer * | 217 | struct GSF_ConnectedPeer * |
217 | GSF_peer_get_(const struct GNUNET_PeerIdentity *peer); | 218 | GSF_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 | */ |
226 | void | 227 | void |
227 | GSF_update_peer_latency_(const struct GNUNET_PeerIdentity *id, | 228 | GSF_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 | */ |
241 | void | 242 | void |
242 | GSF_peer_transmit_(struct GSF_ConnectedPeer *cp, | 243 | GSF_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 | */ |
255 | void | 256 | void |
256 | GSF_peer_update_performance_(struct GSF_ConnectedPeer *cp, | 257 | GSF_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 | */ |
268 | void | 269 | void |
269 | GSF_peer_update_responder_client_(struct GSF_ConnectedPeer *cp, | 270 | GSF_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 | */ |
280 | void | 281 | void |
281 | GSF_peer_update_responder_peer_(struct GSF_ConnectedPeer *cp, | 282 | GSF_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 | */ |
292 | void | 293 | void |
293 | handle_p2p_migration_stop(void *cls, | 294 | handle_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 | */ |
303 | void | 304 | void |
304 | handle_p2p_get(void *cls, | 305 | handle_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 | */ |
314 | struct GSF_PeerPerformanceData * | 315 | struct GSF_PeerPerformanceData * |
315 | GSF_get_peer_performance_data_(struct GSF_ConnectedPeer *cp); | 316 | GSF_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 | */ |
325 | void | 326 | void |
326 | GSF_block_peer_migration_(struct GSF_ConnectedPeer *cp, | 327 | GSF_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 | */ |
338 | void | 339 | void |
339 | GSF_peer_disconnect_handler(void *cls, | 340 | GSF_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 | */ |
350 | void | 351 | void |
351 | GSF_handle_local_client_disconnect_(const struct GSF_LocalClient *lc); | 352 | GSF_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 | */ |
363 | void | 364 | void |
364 | GSF_connected_peer_change_preference_(struct GSF_ConnectedPeer *cp, | 365 | GSF_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 | */ |
374 | void | 375 | void |
375 | GSF_connected_peer_get_identity_(const struct GSF_ConnectedPeer *cp, | 376 | GSF_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 | */ |
385 | const struct GNUNET_PeerIdentity * | 386 | const struct GNUNET_PeerIdentity * |
386 | GSF_connected_peer_get_identity2_(const struct GSF_ConnectedPeer *cp); | 387 | GSF_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 | */ |
396 | void | 397 | void |
397 | GSF_iterate_connected_peers_(GSF_ConnectedPeerIterator it, void *it_cls); | 398 | GSF_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 | */ |
403 | void | 404 | void |
404 | GSF_connected_peer_init_(void); | 405 | GSF_connected_peer_init_ (void); |
405 | 406 | ||
406 | 407 | ||
407 | /** | 408 | /** |
408 | * Shutdown peer management subsystem. | 409 | * Shutdown peer management subsystem. |
409 | */ | 410 | */ |
410 | void | 411 | void |
411 | GSF_connected_peer_done_(void); | 412 | GSF_connected_peer_done_ (void); |
412 | 413 | ||
413 | 414 | ||
414 | #endif | 415 | #endif |