diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-03-15 14:02:06 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-03-15 14:02:06 +0000 |
commit | 88d047a2472a83a4552507ff99ad23af27852dcc (patch) | |
tree | a9e74179c0ce221de07966d952a7d6ee544058a4 /src/fs/gnunet-service-fs_pe.c | |
parent | c387d97879b2a78125a58e86d5bae07593389e69 (diff) | |
download | gnunet-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.c | 6 |
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 | { |