diff options
Diffstat (limited to 'src/fs/fs_download.c')
-rw-r--r-- | src/fs/fs_download.c | 25 |
1 files changed, 14 insertions, 11 deletions
diff --git a/src/fs/fs_download.c b/src/fs/fs_download.c index 473260601..dca419fd3 100644 --- a/src/fs/fs_download.c +++ b/src/fs/fs_download.c | |||
@@ -1359,6 +1359,8 @@ activate_fs_download (void *cls, | |||
1359 | struct GNUNET_FS_ProgressInfo pi; | 1359 | struct GNUNET_FS_ProgressInfo pi; |
1360 | 1360 | ||
1361 | GNUNET_assert (NULL != client); | 1361 | GNUNET_assert (NULL != client); |
1362 | GNUNET_assert (dc->client == NULL); | ||
1363 | GNUNET_assert (dc->th == NULL); | ||
1362 | dc->client = client; | 1364 | dc->client = client; |
1363 | GNUNET_CLIENT_receive (client, | 1365 | GNUNET_CLIENT_receive (client, |
1364 | &receive_results, | 1366 | &receive_results, |
@@ -1369,14 +1371,12 @@ activate_fs_download (void *cls, | |||
1369 | GNUNET_CONTAINER_multihashmap_iterate (dc->active, | 1371 | GNUNET_CONTAINER_multihashmap_iterate (dc->active, |
1370 | &retry_entry, | 1372 | &retry_entry, |
1371 | dc); | 1373 | dc); |
1372 | if ( (dc->th == NULL) && | 1374 | dc->th = GNUNET_CLIENT_notify_transmit_ready (dc->client, |
1373 | (dc->client != NULL) ) | 1375 | sizeof (struct SearchMessage), |
1374 | dc->th = GNUNET_CLIENT_notify_transmit_ready (dc->client, | 1376 | GNUNET_CONSTANTS_SERVICE_TIMEOUT, |
1375 | sizeof (struct SearchMessage), | 1377 | GNUNET_NO, |
1376 | GNUNET_CONSTANTS_SERVICE_TIMEOUT, | 1378 | &transmit_download_request, |
1377 | GNUNET_NO, | 1379 | dc); |
1378 | &transmit_download_request, | ||
1379 | dc); | ||
1380 | } | 1380 | } |
1381 | 1381 | ||
1382 | 1382 | ||
@@ -1559,9 +1559,11 @@ GNUNET_FS_download_start (struct GNUNET_FS_Handle *h, | |||
1559 | dc->treedepth); | 1559 | dc->treedepth); |
1560 | #endif | 1560 | #endif |
1561 | if (parent == NULL) | 1561 | if (parent == NULL) |
1562 | dc->top = GNUNET_FS_make_top (dc->h, | 1562 | { |
1563 | &GNUNET_FS_download_signal_suspend_, | 1563 | dc->top = GNUNET_FS_make_top (dc->h, |
1564 | dc); | 1564 | &GNUNET_FS_download_signal_suspend_, |
1565 | dc); | ||
1566 | } | ||
1565 | pi.status = GNUNET_FS_STATUS_DOWNLOAD_START; | 1567 | pi.status = GNUNET_FS_STATUS_DOWNLOAD_START; |
1566 | pi.value.download.specifics.start.meta = meta; | 1568 | pi.value.download.specifics.start.meta = meta; |
1567 | GNUNET_FS_download_make_status_ (&pi, dc); | 1569 | GNUNET_FS_download_make_status_ (&pi, dc); |
@@ -1707,6 +1709,7 @@ GNUNET_FS_download_start_from_search (struct GNUNET_FS_Handle *h, | |||
1707 | void | 1709 | void |
1708 | GNUNET_FS_download_start_downloading_ (struct GNUNET_FS_DownloadContext *dc) | 1710 | GNUNET_FS_download_start_downloading_ (struct GNUNET_FS_DownloadContext *dc) |
1709 | { | 1711 | { |
1712 | GNUNET_assert (dc->job_queue == NULL); | ||
1710 | dc->job_queue = GNUNET_FS_queue_ (dc->h, | 1713 | dc->job_queue = GNUNET_FS_queue_ (dc->h, |
1711 | &activate_fs_download, | 1714 | &activate_fs_download, |
1712 | &deactivate_fs_download, | 1715 | &deactivate_fs_download, |