| 689 | } |
| 690 | |
| 691 | void enqueue(IOBlock* io, const char* op, AsyncFileKAIO* owner) { |
| 692 | ASSERT(int64_t(io->buf) % 4096 == 0 && io->offset % 4096 == 0 && io->nbytes % 4096 == 0); |
| 693 | |
| 694 | KAIOLogBlockEvent(owner->logFile, io, OpLogEntry::START); |
| 695 | |
| 696 | io->flags |= 1; |
| 697 | io->eventfd = ctx.evfd; |
| 698 | io->prio = (int64_t(g_network->getCurrentTask()) << 32) - (++ctx.opsIssued); |
| 699 | // io->prio = - (++ctx.opsIssued); |
| 700 | io->owner = Reference<AsyncFileKAIO>::addRef(owner); |
| 701 | |
| 702 | ctx.queue.push(io); |
| 703 | } |
| 704 | |
| 705 | static int openFlags(int flags) { |
| 706 | int oflags = O_DIRECT | O_CLOEXEC; |
nothing calls this directly
no test coverage detected