diff options
Diffstat (limited to 'src/fs/gnunet-service-fs_mesh_client.c')
-rw-r--r-- | src/fs/gnunet-service-fs_mesh_client.c | 30 |
1 files changed, 15 insertions, 15 deletions
diff --git a/src/fs/gnunet-service-fs_mesh_client.c b/src/fs/gnunet-service-fs_mesh_client.c index ffc3c6179..73ab6bb5d 100644 --- a/src/fs/gnunet-service-fs_mesh_client.c +++ b/src/fs/gnunet-service-fs_mesh_client.c | |||
@@ -44,7 +44,7 @@ | |||
44 | #define CLIENT_RETRY_TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 30) | 44 | #define CLIENT_RETRY_TIMEOUT GNUNET_TIME_relative_multiply (GNUNET_TIME_UNIT_SECONDS, 30) |
45 | 45 | ||
46 | 46 | ||
47 | /** | 47 | /** |
48 | * Handle for a mesh to another peer. | 48 | * Handle for a mesh to another peer. |
49 | */ | 49 | */ |
50 | struct MeshHandle; | 50 | struct MeshHandle; |
@@ -99,7 +99,7 @@ struct GSF_MeshRequest | |||
99 | }; | 99 | }; |
100 | 100 | ||
101 | 101 | ||
102 | /** | 102 | /** |
103 | * Handle for a mesh to another peer. | 103 | * Handle for a mesh to another peer. |
104 | */ | 104 | */ |
105 | struct MeshHandle | 105 | struct MeshHandle |
@@ -127,12 +127,12 @@ struct MeshHandle | |||
127 | 127 | ||
128 | /** | 128 | /** |
129 | * Handle for active write operation, or NULL. | 129 | * Handle for active write operation, or NULL. |
130 | */ | 130 | */ |
131 | struct GNUNET_MESH_TransmitHandle *wh; | 131 | struct GNUNET_MESH_TransmitHandle *wh; |
132 | 132 | ||
133 | /** | 133 | /** |
134 | * Which peer does this mesh go to? | 134 | * Which peer does this mesh go to? |
135 | */ | 135 | */ |
136 | struct GNUNET_PeerIdentity target; | 136 | struct GNUNET_PeerIdentity target; |
137 | 137 | ||
138 | /** | 138 | /** |
@@ -177,7 +177,7 @@ transmit_pending (struct MeshHandle *mh); | |||
177 | 177 | ||
178 | 178 | ||
179 | /** | 179 | /** |
180 | * Iterator called on each entry in a waiting map to | 180 | * Iterator called on each entry in a waiting map to |
181 | * move it back to the pending list. | 181 | * move it back to the pending list. |
182 | * | 182 | * |
183 | * @param cls the 'struct MeshHandle' | 183 | * @param cls the 'struct MeshHandle' |
@@ -192,7 +192,7 @@ move_to_pending (void *cls, | |||
192 | { | 192 | { |
193 | struct MeshHandle *mh = cls; | 193 | struct MeshHandle *mh = cls; |
194 | struct GSF_MeshRequest *sr = value; | 194 | struct GSF_MeshRequest *sr = value; |
195 | 195 | ||
196 | GNUNET_assert (GNUNET_YES == | 196 | GNUNET_assert (GNUNET_YES == |
197 | GNUNET_CONTAINER_multihashmap_remove (mh->waiting_map, | 197 | GNUNET_CONTAINER_multihashmap_remove (mh->waiting_map, |
198 | key, | 198 | key, |
@@ -342,7 +342,7 @@ transmit_sqm (void *cls, | |||
342 | transmit_pending (mh); | 342 | transmit_pending (mh); |
343 | return sizeof (sqm); | 343 | return sizeof (sqm); |
344 | } | 344 | } |
345 | 345 | ||
346 | 346 | ||
347 | /** | 347 | /** |
348 | * Transmit pending requests via the mesh. | 348 | * Transmit pending requests via the mesh. |
@@ -371,7 +371,7 @@ struct HandleReplyClosure | |||
371 | 371 | ||
372 | /** | 372 | /** |
373 | * Reply payload. | 373 | * Reply payload. |
374 | */ | 374 | */ |
375 | const void *data; | 375 | const void *data; |
376 | 376 | ||
377 | /** | 377 | /** |
@@ -384,11 +384,11 @@ struct HandleReplyClosure | |||
384 | */ | 384 | */ |
385 | size_t data_size; | 385 | size_t data_size; |
386 | 386 | ||
387 | /** | 387 | /** |
388 | * Type of the block. | 388 | * Type of the block. |
389 | */ | 389 | */ |
390 | enum GNUNET_BLOCK_Type type; | 390 | enum GNUNET_BLOCK_Type type; |
391 | 391 | ||
392 | /** | 392 | /** |
393 | * Did we have a matching query? | 393 | * Did we have a matching query? |
394 | */ | 394 | */ |
@@ -397,7 +397,7 @@ struct HandleReplyClosure | |||
397 | 397 | ||
398 | 398 | ||
399 | /** | 399 | /** |
400 | * Iterator called on each entry in a waiting map to | 400 | * Iterator called on each entry in a waiting map to |
401 | * process a result. | 401 | * process a result. |
402 | * | 402 | * |
403 | * @param cls the 'struct HandleReplyClosure' | 403 | * @param cls the 'struct HandleReplyClosure' |
@@ -412,7 +412,7 @@ handle_reply (void *cls, | |||
412 | { | 412 | { |
413 | struct HandleReplyClosure *hrc = cls; | 413 | struct HandleReplyClosure *hrc = cls; |
414 | struct GSF_MeshRequest *sr = value; | 414 | struct GSF_MeshRequest *sr = value; |
415 | 415 | ||
416 | sr->proc (sr->proc_cls, | 416 | sr->proc (sr->proc_cls, |
417 | hrc->type, | 417 | hrc->type, |
418 | hrc->expiration, | 418 | hrc->expiration, |
@@ -462,7 +462,7 @@ reply_cb (void *cls, | |||
462 | type, | 462 | type, |
463 | &srm[1], msize, &query)) | 463 | &srm[1], msize, &query)) |
464 | { | 464 | { |
465 | GNUNET_break_op (0); | 465 | GNUNET_break_op (0); |
466 | reset_mesh_async (mh); | 466 | reset_mesh_async (mh); |
467 | return GNUNET_SYSERR; | 467 | return GNUNET_SYSERR; |
468 | } | 468 | } |
@@ -611,7 +611,7 @@ GSF_mesh_query_cancel (struct GSF_MeshRequest *sr) | |||
611 | 611 | ||
612 | 612 | ||
613 | /** | 613 | /** |
614 | * Iterator called on each entry in a waiting map to | 614 | * Iterator called on each entry in a waiting map to |
615 | * call the 'proc' continuation and release associated | 615 | * call the 'proc' continuation and release associated |
616 | * resources. | 616 | * resources. |
617 | * | 617 | * |
@@ -641,7 +641,7 @@ free_waiting_entry (void *cls, | |||
641 | * | 641 | * |
642 | * @param cls NULL | 642 | * @param cls NULL |
643 | * @param tunnel tunnel of the disconnecting client | 643 | * @param tunnel tunnel of the disconnecting client |
644 | * @param tunnel_ctx our 'struct MeshClient' | 644 | * @param tunnel_ctx our 'struct MeshClient' |
645 | */ | 645 | */ |
646 | static void | 646 | static void |
647 | cleaner_cb (void *cls, | 647 | cleaner_cb (void *cls, |