aboutsummaryrefslogtreecommitdiff
path: root/src/fs/fs_download.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/fs/fs_download.c')
-rw-r--r--src/fs/fs_download.c25
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,
1707void 1709void
1708GNUNET_FS_download_start_downloading_ (struct GNUNET_FS_DownloadContext *dc) 1710GNUNET_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,