diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-04-19 21:01:44 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-04-19 21:01:44 +0000 |
commit | ff74c423c7528e4920a7591e0e64b0b282a81bec (patch) | |
tree | a5124fdd98ceb0cf2df4e19de256575daad5b197 /src/fs/gnunet-service-fs_pe.c | |
parent | 3121108ec2fd4f5c7a481955c8a02dc8ad65b40e (diff) | |
download | gnunet-ff74c423c7528e4920a7591e0e64b0b282a81bec.tar.gz gnunet-ff74c423c7528e4920a7591e0e64b0b282a81bec.zip |
stuff
Diffstat (limited to 'src/fs/gnunet-service-fs_pe.c')
-rw-r--r-- | src/fs/gnunet-service-fs_pe.c | 20 |
1 files changed, 19 insertions, 1 deletions
diff --git a/src/fs/gnunet-service-fs_pe.c b/src/fs/gnunet-service-fs_pe.c index e09a8567b..d0e30f025 100644 --- a/src/fs/gnunet-service-fs_pe.c +++ b/src/fs/gnunet-service-fs_pe.c | |||
@@ -200,6 +200,12 @@ transmit_message_callback (void *cls, | |||
200 | rp->hn = NULL; | 200 | rp->hn = NULL; |
201 | rp->last_transmission = GNUNET_TIME_absolute_get (); | 201 | rp->last_transmission = GNUNET_TIME_absolute_get (); |
202 | rp->transmission_counter++; | 202 | rp->transmission_counter++; |
203 | #if DEBUG_FS | ||
204 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
205 | "Executing plan %p executed %u times, planning retransmission\n", | ||
206 | rp, | ||
207 | rp->transmission_counter); | ||
208 | #endif | ||
203 | plan (pp, rp); | 209 | plan (pp, rp); |
204 | return msize; | 210 | return msize; |
205 | } | 211 | } |
@@ -243,6 +249,11 @@ schedule_peer_transmission (void *cls, | |||
243 | } | 249 | } |
244 | /* process from priority heap */ | 250 | /* process from priority heap */ |
245 | rp = GNUNET_CONTAINER_heap_peek (pp->priority_heap); | 251 | rp = GNUNET_CONTAINER_heap_peek (pp->priority_heap); |
252 | #if DEBUG_FS | ||
253 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
254 | "Executing query plan %p\n", | ||
255 | rp); | ||
256 | #endif | ||
246 | GNUNET_assert (NULL != rp); | 257 | GNUNET_assert (NULL != rp); |
247 | msize = GSF_pending_request_get_message_ (rp->pr, 0, NULL); | 258 | msize = GSF_pending_request_get_message_ (rp->pr, 0, NULL); |
248 | pp->pth = GSF_peer_transmit_ (pp->cp, | 259 | pp->pth = GSF_peer_transmit_ (pp->cp, |
@@ -270,7 +281,7 @@ GSF_plan_add_ (struct GSF_ConnectedPeer *cp, | |||
270 | struct PeerPlan *pp; | 281 | struct PeerPlan *pp; |
271 | struct GSF_PendingRequestData *prd; | 282 | struct GSF_PendingRequestData *prd; |
272 | struct GSF_RequestPlan *rp; | 283 | struct GSF_RequestPlan *rp; |
273 | 284 | ||
274 | GSF_connected_peer_get_identity_ (cp, &id); | 285 | GSF_connected_peer_get_identity_ (cp, &id); |
275 | pp = GNUNET_CONTAINER_multihashmap_get (plans, | 286 | pp = GNUNET_CONTAINER_multihashmap_get (plans, |
276 | &id.hashPubKey); | 287 | &id.hashPubKey); |
@@ -287,6 +298,13 @@ GSF_plan_add_ (struct GSF_ConnectedPeer *cp, | |||
287 | } | 298 | } |
288 | prd = GSF_pending_request_get_data_ (pr); | 299 | prd = GSF_pending_request_get_data_ (pr); |
289 | rp = GNUNET_malloc (sizeof (struct GSF_RequestPlan)); | 300 | rp = GNUNET_malloc (sizeof (struct GSF_RequestPlan)); |
301 | #if DEBUG_FS | ||
302 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
303 | "Planning transmission of query `%s' to peer `%s' (%p)\n", | ||
304 | GNUNET_h2s (&prd->query), | ||
305 | GNUNET_i2s (&id), | ||
306 | rp); | ||
307 | #endif | ||
290 | rp->pr = pr; | 308 | rp->pr = pr; |
291 | GNUNET_CONTAINER_DLL_insert (prd->rp_head, | 309 | GNUNET_CONTAINER_DLL_insert (prd->rp_head, |
292 | prd->rp_tail, | 310 | prd->rp_tail, |