aboutsummaryrefslogtreecommitdiff
path: root/src/fs/gnunet-service-fs_pe.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-03-15 14:02:06 +0000
committerChristian Grothoff <christian@grothoff.org>2011-03-15 14:02:06 +0000
commit88d047a2472a83a4552507ff99ad23af27852dcc (patch)
treea9e74179c0ce221de07966d952a7d6ee544058a4 /src/fs/gnunet-service-fs_pe.c
parentc387d97879b2a78125a58e86d5bae07593389e69 (diff)
downloadgnunet-88d047a2472a83a4552507ff99ad23af27852dcc.tar.gz
gnunet-88d047a2472a83a4552507ff99ad23af27852dcc.zip
fix
Diffstat (limited to 'src/fs/gnunet-service-fs_pe.c')
-rw-r--r--src/fs/gnunet-service-fs_pe.c6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/fs/gnunet-service-fs_pe.c b/src/fs/gnunet-service-fs_pe.c
index 7b0f874ff..816328392 100644
--- a/src/fs/gnunet-service-fs_pe.c
+++ b/src/fs/gnunet-service-fs_pe.c
@@ -174,6 +174,7 @@ transmit_message_callback (void *cls,
174 struct GSF_RequestPlan *rp; 174 struct GSF_RequestPlan *rp;
175 size_t msize; 175 size_t msize;
176 176
177 pp->pth = NULL;
177 if (NULL == buf) 178 if (NULL == buf)
178 { 179 {
179 /* failed, try again... */ 180 /* failed, try again... */
@@ -181,6 +182,11 @@ transmit_message_callback (void *cls,
181 return 0; 182 return 0;
182 } 183 }
183 rp = GNUNET_CONTAINER_heap_peek (pp->priority_heap); 184 rp = GNUNET_CONTAINER_heap_peek (pp->priority_heap);
185 if (NULL == rp)
186 {
187 pp->task = GNUNET_SCHEDULER_add_now (&schedule_peer_transmission, pp);
188 return 0;
189 }
184 msize = GSF_pending_request_get_message_ (rp->pr, buf_size, buf); 190 msize = GSF_pending_request_get_message_ (rp->pr, buf_size, buf);
185 if (msize > buf_size) 191 if (msize > buf_size)
186 { 192 {