aboutsummaryrefslogtreecommitdiff
path: root/src/fs/fs_download.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2014-12-12 00:03:49 +0000
committerChristian Grothoff <christian@grothoff.org>2014-12-12 00:03:49 +0000
commit1224b6d62b7214a4afca27695ff7d789fb6f93d3 (patch)
tree66fb08633714e7e0eab91df29ca12e7a7d95f8b9 /src/fs/fs_download.c
parent9a112a7aa7c1703a9489da7306293ee1b9df7331 (diff)
downloadgnunet-1224b6d62b7214a4afca27695ff7d789fb6f93d3.tar.gz
gnunet-1224b6d62b7214a4afca27695ff7d789fb6f93d3.zip
start fewer FS probes concurrently, run them all in the same task to avoid undue pressure on the scheduler
Diffstat (limited to 'src/fs/fs_download.c')
-rw-r--r--src/fs/fs_download.c10
1 files changed, 3 insertions, 7 deletions
diff --git a/src/fs/fs_download.c b/src/fs/fs_download.c
index b3726e9bb..348a0bc17 100644
--- a/src/fs/fs_download.c
+++ b/src/fs/fs_download.c
@@ -2257,11 +2257,7 @@ GNUNET_FS_download_start_from_search (struct GNUNET_FS_Handle *h,
2257 { 2257 {
2258 GNUNET_FS_download_stop (sr->probe_ctx, GNUNET_YES); 2258 GNUNET_FS_download_stop (sr->probe_ctx, GNUNET_YES);
2259 sr->probe_ctx = NULL; 2259 sr->probe_ctx = NULL;
2260 } 2260 GNUNET_FS_stop_probe_ping_task_ (sr);
2261 if (GNUNET_SCHEDULER_NO_TASK != sr->probe_ping_task)
2262 {
2263 GNUNET_SCHEDULER_cancel (sr->probe_ping_task);
2264 sr->probe_ping_task = GNUNET_SCHEDULER_NO_TASK;
2265 } 2261 }
2266 return dc; 2262 return dc;
2267} 2263}
@@ -2314,14 +2310,14 @@ GNUNET_FS_download_resume (struct GNUNET_FS_DownloadContext *dc)
2314 2310
2315 pi.status = GNUNET_FS_STATUS_DOWNLOAD_ACTIVE; 2311 pi.status = GNUNET_FS_STATUS_DOWNLOAD_ACTIVE;
2316 GNUNET_FS_download_make_status_ (&pi, dc); 2312 GNUNET_FS_download_make_status_ (&pi, dc);
2317 2313
2318 dc->job_queue = 2314 dc->job_queue =
2319 GNUNET_FS_queue_ (dc->h, &activate_fs_download, &deactivate_fs_download, 2315 GNUNET_FS_queue_ (dc->h, &activate_fs_download, &deactivate_fs_download,
2320 dc, (dc->length + DBLOCK_SIZE - 1) / DBLOCK_SIZE, 2316 dc, (dc->length + DBLOCK_SIZE - 1) / DBLOCK_SIZE,
2321 (0 == (dc->options & GNUNET_FS_DOWNLOAD_IS_PROBE)) 2317 (0 == (dc->options & GNUNET_FS_DOWNLOAD_IS_PROBE))
2322 ? GNUNET_FS_QUEUE_PRIORITY_NORMAL 2318 ? GNUNET_FS_QUEUE_PRIORITY_NORMAL
2323 : GNUNET_FS_QUEUE_PRIORITY_PROBE); 2319 : GNUNET_FS_QUEUE_PRIORITY_PROBE);
2324 2320
2325} 2321}
2326 2322
2327 2323