| 28 | constexpr int kOneMB = 1 << 20; |
| 29 | |
| 30 | void writeDataAsync(WriteFile* writeFile) { |
| 31 | if (writeFile->uringEnabled()) { |
| 32 | std::vector<std::unique_ptr<folly::IOBuf>> buffers; |
| 33 | buffers.push_back(folly::IOBuf::copyBuffer("aaaaa")); |
| 34 | buffers.push_back(folly::IOBuf::copyBuffer("bbbbb")); |
| 35 | buffers.push_back(folly::IOBuf::copyBuffer(std::string(kOneMB, 'c'))); |
| 36 | buffers.push_back(folly::IOBuf::copyBuffer("ddddd")); |
| 37 | for (int i = 0; i < buffers.size(); i++) |
| 38 | writeFile->submitWrite(buffers[i].get(), i); |
| 39 | writeFile->waitForCompleteAll(); |
| 40 | } else { |
| 41 | std::unique_ptr<folly::IOBuf> buf = folly::IOBuf::copyBuffer("aaaaa"); |
| 42 | buf->appendToChain(folly::IOBuf::copyBuffer("bbbbb")); |
| 43 | buf->appendToChain(folly::IOBuf::copyBuffer(std::string(kOneMB, 'c'))); |
| 44 | buf->appendToChain(folly::IOBuf::copyBuffer("ddddd")); |
| 45 | writeFile->append(std::move(buf)); |
| 46 | } |
| 47 | ASSERT_EQ(writeFile->size(), 15 + kOneMB); |
| 48 | } |
| 49 | |
| 50 | void readDataAsync(ReadFile* readFile, bool checkFileSize = true) { |
| 51 | if (checkFileSize) { |
no test coverage detected