Revision 11aeae96
Added by david.sorber almost 3 years ago
| software/read_test/src/main.cc | ||
|---|---|---|
|
break;
|
||
|
}
|
||
|
std::cout << "Num threads: " << numThreads << "\n";
|
||
|
std::cout << "Chunk size: " << chunkSize << "\n";
|
||
|
std::cout << "Chunk size: " << chunkSize << " KB\n";
|
||
|
|
||
|
driver->start();
|
||
|
driver->waitUntilComplete();
|
||
| ... | ... | |
|
auto diff = end - start;
|
||
|
double duration = std::chrono::duration <double>(diff).count() ;
|
||
|
std::cout << "Duration: " << std::fixed << std::setprecision(3)
|
||
|
<< duration << " ms" << std::endl;
|
||
|
<< duration << " s" << std::endl;
|
||
|
|
||
|
double rawRate = fileSize / duration;
|
||
|
std::cout << "Raw rate: " << rawRate << " b/sec" << std::endl;
|
||
| software/read_test/src/write_test.cc | ||
|---|---|---|
|
#include <string>
|
||
|
#include <vector>
|
||
|
|
||
|
#include <unistd.h>
|
||
|
|
||
|
#include "liburing.h"
|
||
|
|
||
|
static const uint32_t QUEUE_DEPTH = 256;
|
||
| ... | ... | |
|
}
|
||
|
}
|
||
|
|
||
|
// Wait for any lingering IO completions
|
||
|
while (m_ioCounter > 0)
|
||
|
{
|
||
|
waitForCompletion(&m_ring, m_ioCounter);
|
||
|
}
|
||
|
|
||
|
|
||
|
// Release file descriptor
|
||
|
::close(fd);
|
||
|
|
||
Adding missing include to write_test. Also correcting read_test
units.