diff options
author | Christian Grothoff <christian@grothoff.org> | 2010-07-03 13:58:02 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2010-07-03 13:58:02 +0000 |
commit | 171d70e706b9b355765041c855d5af6e2878cdb6 (patch) | |
tree | 9b774152c98427f1e873c6ab2cfce4b4db27283c /src/fs | |
parent | 0eb708afde86ce4e342bb19b7caac55e314c04c1 (diff) | |
download | gnunet-171d70e706b9b355765041c855d5af6e2878cdb6.tar.gz gnunet-171d70e706b9b355765041c855d5af6e2878cdb6.zip |
fixing off-by-one
Diffstat (limited to 'src/fs')
-rw-r--r-- | src/fs/fs_download.c | 28 | ||||
-rw-r--r-- | src/fs/test_fs_download_data.conf | 2 |
2 files changed, 27 insertions, 3 deletions
diff --git a/src/fs/fs_download.c b/src/fs/fs_download.c index 50d48b2cd..1ee4355ad 100644 --- a/src/fs/fs_download.c +++ b/src/fs/fs_download.c | |||
@@ -395,6 +395,17 @@ schedule_block_download (struct GNUNET_FS_DownloadContext *dc, | |||
395 | &transmit_download_request, | 395 | &transmit_download_request, |
396 | dc); | 396 | dc); |
397 | } | 397 | } |
398 | else | ||
399 | { | ||
400 | #if DEBUG_DOWNLOAD | ||
401 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
402 | "Transmission request not issued (%p %p)\n", | ||
403 | dc->th, | ||
404 | dc->client); | ||
405 | #endif | ||
406 | |||
407 | } | ||
408 | |||
398 | } | 409 | } |
399 | 410 | ||
400 | 411 | ||
@@ -1234,7 +1245,7 @@ transmit_download_request (void *cls, | |||
1234 | msize = 0; | 1245 | msize = 0; |
1235 | sm = buf; | 1246 | sm = buf; |
1236 | while ( (dc->pending != NULL) && | 1247 | while ( (dc->pending != NULL) && |
1237 | (size > msize + sizeof (struct SearchMessage)) ) | 1248 | (size >= msize + sizeof (struct SearchMessage)) ) |
1238 | { | 1249 | { |
1239 | #if DEBUG_DOWNLOAD | 1250 | #if DEBUG_DOWNLOAD |
1240 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | 1251 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, |
@@ -1391,6 +1402,10 @@ activate_fs_download (void *cls, | |||
1391 | struct GNUNET_FS_DownloadContext *dc = cls; | 1402 | struct GNUNET_FS_DownloadContext *dc = cls; |
1392 | struct GNUNET_FS_ProgressInfo pi; | 1403 | struct GNUNET_FS_ProgressInfo pi; |
1393 | 1404 | ||
1405 | #if DEBUG_DOWNLOAD | ||
1406 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
1407 | "Download activated\n"); | ||
1408 | #endif | ||
1394 | GNUNET_assert (NULL != client); | 1409 | GNUNET_assert (NULL != client); |
1395 | GNUNET_assert (dc->client == NULL); | 1410 | GNUNET_assert (dc->client == NULL); |
1396 | GNUNET_assert (dc->th == NULL); | 1411 | GNUNET_assert (dc->th == NULL); |
@@ -1404,12 +1419,17 @@ activate_fs_download (void *cls, | |||
1404 | GNUNET_CONTAINER_multihashmap_iterate (dc->active, | 1419 | GNUNET_CONTAINER_multihashmap_iterate (dc->active, |
1405 | &retry_entry, | 1420 | &retry_entry, |
1406 | dc); | 1421 | dc); |
1422 | #if DEBUG_DOWNLOAD | ||
1423 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
1424 | "Asking for transmission to FS service\n"); | ||
1425 | #endif | ||
1407 | dc->th = GNUNET_CLIENT_notify_transmit_ready (dc->client, | 1426 | dc->th = GNUNET_CLIENT_notify_transmit_ready (dc->client, |
1408 | sizeof (struct SearchMessage), | 1427 | sizeof (struct SearchMessage), |
1409 | GNUNET_CONSTANTS_SERVICE_TIMEOUT, | 1428 | GNUNET_CONSTANTS_SERVICE_TIMEOUT, |
1410 | GNUNET_NO, | 1429 | GNUNET_NO, |
1411 | &transmit_download_request, | 1430 | &transmit_download_request, |
1412 | dc); | 1431 | dc); |
1432 | GNUNET_assert (dc->th != NULL); | ||
1413 | } | 1433 | } |
1414 | 1434 | ||
1415 | 1435 | ||
@@ -1423,7 +1443,11 @@ deactivate_fs_download (void *cls) | |||
1423 | { | 1443 | { |
1424 | struct GNUNET_FS_DownloadContext *dc = cls; | 1444 | struct GNUNET_FS_DownloadContext *dc = cls; |
1425 | struct GNUNET_FS_ProgressInfo pi; | 1445 | struct GNUNET_FS_ProgressInfo pi; |
1426 | 1446 | ||
1447 | #if DEBUG_DOWNLOAD | ||
1448 | GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, | ||
1449 | "Download deactivated\n"); | ||
1450 | #endif | ||
1427 | if (NULL != dc->th) | 1451 | if (NULL != dc->th) |
1428 | { | 1452 | { |
1429 | GNUNET_CLIENT_notify_transmit_ready_cancel (dc->th); | 1453 | GNUNET_CLIENT_notify_transmit_ready_cancel (dc->th); |
diff --git a/src/fs/test_fs_download_data.conf b/src/fs/test_fs_download_data.conf index c154ba1b3..d647d448d 100644 --- a/src/fs/test_fs_download_data.conf +++ b/src/fs/test_fs_download_data.conf | |||
@@ -19,7 +19,7 @@ HOSTNAME = localhost | |||
19 | DEFAULTSERVICES = | 19 | DEFAULTSERVICES = |
20 | 20 | ||
21 | [datastore] | 21 | [datastore] |
22 | # DEBUG = YES | 22 | #DEBUG = YES |
23 | 23 | ||
24 | [statistics] | 24 | [statistics] |
25 | PORT = 42467 | 25 | PORT = 42467 |