t/aio-ring: updates/cleanups
authorJens Axboe <axboe@kernel.dk>
Mon, 10 Dec 2018 22:14:36 +0000 (15:14 -0700)
committerJens Axboe <axboe@kernel.dk>
Mon, 10 Dec 2018 22:14:36 +0000 (15:14 -0700)
Signed-off-by: Jens Axboe <axboe@kernel.dk>
t/aio-ring.c

index ec06f4d6927d2043d4ddb3c02a2dd6f3a9ff3483..c61063484be16e736e4d54a96f39625709460a3e 100644 (file)
@@ -63,10 +63,6 @@ struct aio_io_event_ring {
 #define IORING_FLAG_SUBMIT     (1 << 0)
 #define IORING_FLAG_GETEVENTS  (1 << 1)
 
 #define IORING_FLAG_SUBMIT     (1 << 0)
 #define IORING_FLAG_GETEVENTS  (1 << 1)
 
-#define container_of(ptr, type, member)  ({                            \
-       const __typeof__( ((type *)0)->member ) *__mptr = (ptr);        \
-       (type *)( (char *)__mptr - offsetof(type,member) );})
-
 #define DEPTH                  32
 #define RING_SIZE              (DEPTH + 1)
 
 #define DEPTH                  32
 #define RING_SIZE              (DEPTH + 1)
 
@@ -96,8 +92,8 @@ static volatile int finish;
 static int polled = 1;         /* use IO polling */
 static int fixedbufs = 1;      /* use fixed user buffers */
 static int buffered = 0;       /* use buffered IO, not O_DIRECT */
 static int polled = 1;         /* use IO polling */
 static int fixedbufs = 1;      /* use fixed user buffers */
 static int buffered = 0;       /* use buffered IO, not O_DIRECT */
-static int sq_thread = 0;
-static int sq_thread_cpu = 0;
+static int sq_thread = 0;      /* use kernel submission thread */
+static int sq_thread_cpu = 0;  /* pin above thread to this CPU */
 
 static int io_setup2(unsigned int nr_events, unsigned int flags,
                     struct iocb *iocbs, struct aio_iocb_ring *sq_ring,
 
 static int io_setup2(unsigned int nr_events, unsigned int flags,
                     struct iocb *iocbs, struct aio_iocb_ring *sq_ring,
@@ -297,8 +293,6 @@ submit:
                                        break;
                                if (this_reap)
                                        goto submit;
                                        break;
                                if (this_reap)
                                        goto submit;
-                               printf("EAGAIN reap=%d\n", reap_events(s));
-                               printf("%d/%d, %d/%d\n", s->sq_ring->head, s->sq_ring->tail, s->cq_ring->head, s->cq_ring->tail);
                                to_submit = 0;
                                goto submit;
                        }
                                to_submit = 0;
                                goto submit;
                        }