diff options
| author | Bernd Schubert <bernd.schubert@itwm.fraunhofer.de> | 2013-06-18 11:09:41 +0200 |
|---|---|---|
| committer | NeilBrown <neilb@suse.de> | 2013-06-19 10:05:38 +1000 |
| commit | 2161adce8f789cfb01123f6c6c1d7c986b27abb5 (patch) | |
| tree | 58095a91a711100967d36caf2608f288668c21bb /raid6check.c | |
| parent | 2c7b668df75ce355398a22e42b7a9ee860c10dbe (diff) | |
raid6check: Check return value of lseek64()
If lseek64() failed it was still writing to the disks, which would introduce
data corruption.
Signed-off-by: Bernd Schubert <bernd.schubert@fastmail.fm>
Signed-off-by: NeilBrown <neilb@suse.de>
Diffstat (limited to 'raid6check.c')
| -rw-r--r-- | raid6check.c | 32 |
1 files changed, 28 insertions, 4 deletions
diff --git a/raid6check.c b/raid6check.c index 45d808d4..aa6ce234 100644 --- a/raid6check.c +++ b/raid6check.c @@ -185,11 +185,19 @@ int check_stripes(struct mdinfo *info, int *source, unsigned long long *offsets, goto exitCheck; } for (i = 0 ; i < raid_disks ; i++) { - lseek64(source[i], offsets[i] + start * chunk_size, 0); + off64_t seek_res = lseek64(source[i], offsets[i] + start * chunk_size, + SEEK_SET); + if (seek_res < 0) { + fprintf(stderr, "lseek to source %d failed\n", i); + unlock_all_stripes(info, sig); + err = -1; + goto exitCheck; + } int read_res = read(source[i], stripes[i], chunk_size); if (read_res < chunk_size) { fprintf(stderr, "Failed to read complete chunk disk %d, aborting\n", i); unlock_all_stripes(info, sig); + err = -1; goto exitCheck; } } @@ -288,17 +296,33 @@ int check_stripes(struct mdinfo *info, int *source, unsigned long long *offsets, } int write_res1, write_res2; + off64_t seek_res; - lseek64(source[failed_disk1], offsets[failed_disk1] + start * chunk_size, 0); + seek_res = lseek64(source[failed_disk1], + offsets[failed_disk1] + start * chunk_size, SEEK_SET); + if (seek_res < 0) { + fprintf(stderr, "lseek failed for failed_disk1\n"); + unlock_all_stripes(info, sig); + err = -1; + goto exitCheck; + } write_res1 = write(source[failed_disk1], stripes[failed_disk1], chunk_size); - lseek64(source[failed_disk2], offsets[failed_disk2] + start * chunk_size, 0); + + + seek_res = lseek64(source[failed_disk2], + offsets[failed_disk2] + start * chunk_size, SEEK_SET); + if (seek_res < 0) { + fprintf(stderr, "lseek failed for failed_disk1\n"); + unlock_all_stripes(info, sig); + err = -1; + goto exitCheck; + } write_res2 = write(source[failed_disk2], stripes[failed_disk2], chunk_size); err = unlock_all_stripes(info, sig); if(err != 0) goto exitCheck; - if (write_res1 != chunk_size || write_res2 != chunk_size) { fprintf(stderr, "Failed to write a complete chunk.\n"); goto exitCheck; |