Revision 864b608c
Added by David Sorber about 4 years ago
| software/read_test/src/URingExecDriver.h | ||
|---|---|---|
|
#include <thread>
|
||
|
#include <vector>
|
||
|
|
||
|
#include "liburing.h"
|
||
|
|
||
|
#include "Chunk.h"
|
||
|
#include "ExecDriver.h"
|
||
|
#include "Utilities/ProtectedAndSynchronizedQueue.h"
|
||
| ... | ... | |
|
{
|
||
|
public:
|
||
|
|
||
|
static const uint32_t QUEUE_DEPTH = 256;
|
||
|
|
||
|
URingExecDriver(
|
||
|
const std::string& inputFile,
|
||
|
uint32_t numReaderThreads);
|
||
| ... | ... | |
|
chunk_queue_t* inQueue,
|
||
|
chunk_queue_t* outQueue) override;
|
||
|
|
||
|
|
||
|
void waitForCompletion(chunk_queue_t* outQueue);
|
||
|
|
||
|
struct io_uring m_ring;
|
||
|
|
||
|
uint32_t m_ioCounter;
|
||
|
|
||
|
};
|
||
|
|
||
|
}
|
||
read_test: add new uring read method to read_test. It uses (requires)
liburing and a kernel >= 5.6.