diff options
author | Christian Grothoff <christian@grothoff.org> | 2014-12-12 00:03:49 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2014-12-12 00:03:49 +0000 |
commit | 1224b6d62b7214a4afca27695ff7d789fb6f93d3 (patch) | |
tree | 66fb08633714e7e0eab91df29ca12e7a7d95f8b9 /src/fs/fs_download.c | |
parent | 9a112a7aa7c1703a9489da7306293ee1b9df7331 (diff) | |
download | gnunet-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.c | 10 |
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 | ||