aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_mesh_client.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/fs/gnunet-service-fs_mesh_client.c')
-rw-r--r--src/fs/gnunet-service-fs_mesh_client.c30
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 */
50struct MeshHandle; 50struct 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 */
105struct MeshHandle 105struct 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 */
646static void 646static void
647cleaner_cb (void *cls, 647cleaner_cb (void *cls,