We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 61adc84 commit f64f76bCopy full SHA for f64f76b
1 file changed
src/ioq.c
@@ -850,6 +850,7 @@ static int ioq_ring_init(struct ioq *ioq, struct ioq_thread *thread) {
850
851
if (prev) {
852
// Initial setup already complete
853
+ thread->ring_ops = prev->ring_ops;
854
return 0;
855
}
856
@@ -916,12 +917,14 @@ static void ioq_thread_join(struct ioq_thread *thread) {
916
917
918
919
struct ioq *ioq_create(size_t depth, size_t nthreads) {
- struct ioq *ioq = ZALLOC_FLEX(struct ioq, threads, nthreads);
920
+ struct ioq *ioq = ALLOC_FLEX(struct ioq, threads, nthreads);
921
if (!ioq) {
922
goto fail;
923
924
925
ioq->depth = depth;
926
+ ioq->size = 0;
927
+ ioq->cancel = false;
928
929
ARENA_INIT(&ioq->ents, struct ioq_ent);
930
0 commit comments