| 48 | } |
| 49 | |
| 50 | void readDataAsync(ReadFile* readFile, bool checkFileSize = true) { |
| 51 | if (checkFileSize) { |
| 52 | ASSERT_EQ(readFile->size(), 15 + kOneMB); |
| 53 | } |
| 54 | if (readFile->uringEnabled()) { |
| 55 | char buffer1[5]; |
| 56 | readFile->submitRead(reinterpret_cast<char*>(&buffer1), 10 + kOneMB, 5); |
| 57 | readFile->waitForComplete(); |
| 58 | ASSERT_EQ(std::string_view(buffer1, 5), "ddddd"); |
| 59 | char buffer2[10]; |
| 60 | readFile->submitRead(reinterpret_cast<char*>(&buffer2), 0, 10); |
| 61 | readFile->waitForComplete(); |
| 62 | ASSERT_EQ(std::string_view(buffer2, 10), "aaaaabbbbb"); |
| 63 | char buffer3[kOneMB]; |
| 64 | readFile->submitRead(reinterpret_cast<char*>(&buffer3), 10, kOneMB); |
| 65 | readFile->waitForComplete(); |
| 66 | ASSERT_EQ(std::string_view(buffer3, kOneMB), std::string(kOneMB, 'c')); |
| 67 | } else { |
| 68 | char buffer1[5]; |
| 69 | ASSERT_EQ(readFile->pread(10 + kOneMB, 5, &buffer1), "ddddd"); |
| 70 | char buffer2[10]; |
| 71 | ASSERT_EQ(readFile->pread(0, 10, &buffer2), "aaaaabbbbb"); |
| 72 | char buffer3[kOneMB]; |
| 73 | ASSERT_EQ(readFile->pread(10, kOneMB, &buffer3), std::string(kOneMB, 'c')); |
| 74 | } |
| 75 | if (checkFileSize) { |
| 76 | ASSERT_EQ(readFile->size(), 15 + kOneMB); |
| 77 | } |
| 78 | } |
| 79 | |
| 80 | void readDataAsyncForWirteBuffers( |
| 81 | ReadFile* readFile, |
no test coverage detected