diff options
| author | Christian Grothoff <christian@grothoff.org> | 2012-01-14 23:18:23 +0000 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2012-01-14 23:18:23 +0000 |
| commit | 70ebf5bc2f2f8b0980d5a00a92fa3ed987b2c1a4 (patch) | |
| tree | 9872247361c3e9d0ed6ffe9a6b84e4fcdb8433e6 /src | |
| parent | 91ab799c42b2496e65afd0c866811999d88119ed (diff) | |
| download | gnunet-70ebf5bc2f2f8b0980d5a00a92fa3ed987b2c1a4.tar.gz gnunet-70ebf5bc2f2f8b0980d5a00a92fa3ed987b2c1a4.zip | |
-LRN: use blocking writes for scanner
Diffstat (limited to 'src')
| -rw-r--r-- | src/fs/fs_dirmetascan.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/fs/fs_dirmetascan.c b/src/fs/fs_dirmetascan.c index ce76b0387..6af186347 100644 --- a/src/fs/fs_dirmetascan.c +++ b/src/fs/fs_dirmetascan.c | |||
| @@ -355,7 +355,7 @@ write_progress (struct AddDirContext *adc, const char *filename, | |||
| 355 | wr = 1; | 355 | wr = 1; |
| 356 | while ((wr > 0 || errno == EAGAIN) && total_write < sizeof (reason)) | 356 | while ((wr > 0 || errno == EAGAIN) && total_write < sizeof (reason)) |
| 357 | { | 357 | { |
| 358 | wr = GNUNET_DISK_file_write (adc->progress_write, | 358 | wr = GNUNET_DISK_file_write_blocking (adc->progress_write, |
| 359 | &((char *)&reason)[total_write], sizeof (reason) - total_write); | 359 | &((char *)&reason)[total_write], sizeof (reason) - total_write); |
| 360 | if (wr > 0) | 360 | if (wr > 0) |
| 361 | total_write += wr; | 361 | total_write += wr; |
| @@ -370,7 +370,7 @@ write_progress (struct AddDirContext *adc, const char *filename, | |||
| 370 | wr = 1; | 370 | wr = 1; |
| 371 | while ((wr > 0 || errno == EAGAIN) && total_write < sizeof (size_t)) | 371 | while ((wr > 0 || errno == EAGAIN) && total_write < sizeof (size_t)) |
| 372 | { | 372 | { |
| 373 | wr = GNUNET_DISK_file_write (adc->progress_write, | 373 | wr = GNUNET_DISK_file_write_blocking (adc->progress_write, |
| 374 | &((char *)&filename_len)[total_write], sizeof (size_t) - total_write); | 374 | &((char *)&filename_len)[total_write], sizeof (size_t) - total_write); |
| 375 | if (wr > 0) | 375 | if (wr > 0) |
| 376 | total_write += wr; | 376 | total_write += wr; |
| @@ -383,7 +383,7 @@ write_progress (struct AddDirContext *adc, const char *filename, | |||
| 383 | wr = 1; | 383 | wr = 1; |
| 384 | while ((wr > 0 || errno == EAGAIN) && total_write < filename_len) | 384 | while ((wr > 0 || errno == EAGAIN) && total_write < filename_len) |
| 385 | { | 385 | { |
| 386 | wr = GNUNET_DISK_file_write (adc->progress_write, | 386 | wr = GNUNET_DISK_file_write_blocking (adc->progress_write, |
| 387 | &((char *)filename)[total_write], filename_len - total_write); | 387 | &((char *)filename)[total_write], filename_len - total_write); |
| 388 | if (wr > 0) | 388 | if (wr > 0) |
| 389 | total_write += wr; | 389 | total_write += wr; |
| @@ -394,7 +394,7 @@ write_progress (struct AddDirContext *adc, const char *filename, | |||
| 394 | wr = 1; | 394 | wr = 1; |
| 395 | while ((wr > 0 || errno == EAGAIN) && total_write < sizeof (char)) | 395 | while ((wr > 0 || errno == EAGAIN) && total_write < sizeof (char)) |
| 396 | { | 396 | { |
| 397 | wr = GNUNET_DISK_file_write (adc->progress_write, | 397 | wr = GNUNET_DISK_file_write_blocking (adc->progress_write, |
| 398 | &((char *)&is_directory)[total_write], sizeof (char) - total_write); | 398 | &((char *)&is_directory)[total_write], sizeof (char) - total_write); |
| 399 | if (wr > 0) | 399 | if (wr > 0) |
| 400 | total_write += wr; | 400 | total_write += wr; |