diff --git a/kernel/include/kernel/Storage/NVMe/Queue.h b/kernel/include/kernel/Storage/NVMe/Queue.h index f174ed15..8cbe97d0 100644 --- a/kernel/include/kernel/Storage/NVMe/Queue.h +++ b/kernel/include/kernel/Storage/NVMe/Queue.h @@ -31,11 +31,13 @@ namespace Kernel uint32_t m_cq_head { 0 }; uint16_t m_cq_valid_phase { 1 }; - Semaphore m_semaphore; - SpinLock m_lock; - BAN::Atomic m_used_mask { 0 }; - BAN::Atomic m_done_mask { 0 }; - volatile uint16_t m_status_codes[64] { }; + Semaphore m_semaphore; + SpinLock m_lock; + BAN::Atomic m_used_mask { 0 }; + BAN::Atomic m_done_mask { 0 }; + volatile uint16_t m_status_codes[64] { }; + + static constexpr size_t m_mask_bits = sizeof(size_t) * 8; }; } diff --git a/kernel/kernel/Storage/NVMe/Queue.cpp b/kernel/kernel/Storage/NVMe/Queue.cpp index 68b72b7a..63b48d01 100644 --- a/kernel/kernel/Storage/NVMe/Queue.cpp +++ b/kernel/kernel/Storage/NVMe/Queue.cpp @@ -15,8 +15,8 @@ namespace Kernel , m_doorbell(db) , m_qdepth(qdepth) { - for (uint32_t i = qdepth; i < 64; i++) - m_used_mask |= (uint64_t)1 << i; + for (uint32_t i = qdepth; i < m_mask_bits; i++) + m_used_mask |= (size_t)1 << i; set_irq(irq); enable_interrupt(); } @@ -29,8 +29,8 @@ namespace Kernel { uint16_t sts = cq_ptr[m_cq_head].sts >> 1; uint16_t cid = cq_ptr[m_cq_head].cid; - uint64_t cid_mask = (uint64_t)1 << cid; - ASSERT(cid < 64); + size_t cid_mask = (size_t)1 << cid; + ASSERT(cid < m_mask_bits); ASSERT((m_done_mask & cid_mask) == 0); @@ -50,7 +50,7 @@ namespace Kernel uint16_t NVMeQueue::submit_command(NVMe::SubmissionQueueEntry& sqe) { uint16_t cid = reserve_cid(); - uint64_t cid_mask = (uint64_t)1 << cid; + size_t cid_mask = (size_t)1 << cid; { SpinLockGuard _(m_lock); @@ -98,13 +98,13 @@ namespace Kernel } uint16_t cid = 0; - for (; cid < 64; cid++) - if ((m_used_mask & ((uint64_t)1 << cid)) == 0) + for (; cid < m_mask_bits; cid++) + if ((m_used_mask & ((size_t)1 << cid)) == 0) break; - ASSERT(cid < 64); + ASSERT(cid < m_mask_bits); ASSERT(cid < m_qdepth); - m_used_mask |= (uint64_t)1 << cid; + m_used_mask |= (size_t)1 << cid; m_lock.unlock(state); return cid;