i2p/haiku-beta6
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

VMAnonymousCache.cpp: changed page_index type to page_num_t

Browse Source 
* consistently use page_num_t for page numbers and off_t for offsets and sizes.
This commit is contained in:
Jérôme Duval
2013-04-26 21:17:39 +02:00
parent cc3fb1f518
commit f7176b0ee5
2 changed files with 27 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/system/kernel/vm/VMAnonymousCache.cpp
+22 -22
View File
@@ -96,7 +96,7 @@ struct swap_file : DoublyLinkedListLinkImpl<swap_file> {
struct swap_hash_key { struct swap_hash_key {
VMAnonymousCache *cache; VMAnonymousCache *cache;
off_t page_index; // page index in the cache page_num_t page_index; // page index in the cache
}; };
// Each swap block contains swap address information for // Each swap block contains swap address information for
@@ -128,8 +128,8 @@ struct SwapHashTableDefinition {
bool Compare(const swap_hash_key& key, const swap_block* value) const bool Compare(const swap_hash_key& key, const swap_block* value) const
{ {
return (key.page_index & ~(off_t)SWAP_BLOCK_MASK) return (key.page_index & ~(page_num_t)SWAP_BLOCK_MASK)
== (value->key.page_index & ~(off_t)SWAP_BLOCK_MASK) == (value->key.page_index & ~(page_num_t)SWAP_BLOCK_MASK)
&& key.cache == value->key.cache; && key.cache == value->key.cache;
} }
@@ -557,7 +557,7 @@ VMAnonymousCache::Commit(off_t size, int priority)
// pre-commit some pages to make a later failure less probable // pre-commit some pages to make a later failure less probable
fHasPrecommitted = true; fHasPrecommitted = true;
uint32 precommitted = fPrecommittedPages * B_PAGE_SIZE; off_t precommitted = (off_t)fPrecommittedPages * B_PAGE_SIZE;
if (size > precommitted) if (size > precommitted)
size = precommitted; size = precommitted;
} }
@@ -593,7 +593,7 @@ status_t
VMAnonymousCache::Read(off_t offset, const generic_io_vec* vecs, size_t count, VMAnonymousCache::Read(off_t offset, const generic_io_vec* vecs, size_t count,
uint32 flags, generic_size_t* _numBytes) uint32 flags, generic_size_t* _numBytes)
{ {
off_t pageIndex = offset >> PAGE_SHIFT; page_num_t pageIndex = offset >> PAGE_SHIFT;
for (uint32 i = 0, j = 0; i < count; i = j) { for (uint32 i = 0, j = 0; i < count; i = j) {
swap_addr_t startSlotIndex = _SwapBlockGetAddress(pageIndex + i); swap_addr_t startSlotIndex = _SwapBlockGetAddress(pageIndex + i);
@@ -625,7 +625,7 @@ status_t
VMAnonymousCache::Write(off_t offset, const generic_io_vec* vecs, size_t count, VMAnonymousCache::Write(off_t offset, const generic_io_vec* vecs, size_t count,
uint32 flags, generic_size_t* _numBytes) uint32 flags, generic_size_t* _numBytes)
{ {
off_t pageIndex = offset >> PAGE_SHIFT; page_num_t pageIndex = offset >> PAGE_SHIFT;
AutoLocker<VMCache> locker(this); AutoLocker<VMCache> locker(this);
@@ -636,13 +636,13 @@ VMAnonymousCache::Write(off_t offset, const generic_io_vec* vecs, size_t count,
if (slotIndex != SWAP_SLOT_NONE) { if (slotIndex != SWAP_SLOT_NONE) {
swap_slot_dealloc(slotIndex, pageCount); swap_slot_dealloc(slotIndex, pageCount);
_SwapBlockFree(pageIndex + totalPages, pageCount); _SwapBlockFree(pageIndex + totalPages, pageCount);
fAllocatedSwapSize -= pageCount * B_PAGE_SIZE; fAllocatedSwapSize -= (off_t)pageCount * B_PAGE_SIZE;
} }
totalPages += pageCount; totalPages += pageCount;
} }
off_t totalSize = totalPages * B_PAGE_SIZE; off_t totalSize = (off_t)totalPages * B_PAGE_SIZE;
if (fAllocatedSwapSize + totalSize > fCommittedSwapSize) if (fAllocatedSwapSize + totalSize > fCommittedSwapSize)
return B_ERROR; return B_ERROR;
@@ -695,8 +695,8 @@ VMAnonymousCache::Write(off_t offset, const generic_io_vec* vecs, size_t count,
pagesLeft -= n; pagesLeft -= n;
if (n != pageCount) { if (n != pageCount) {
vectorBase = vectorBase + n * B_PAGE_SIZE; vectorBase = vectorBase + (off_t)n * B_PAGE_SIZE;
vectorLength -= n * B_PAGE_SIZE; vectorLength -= (off_t)n * B_PAGE_SIZE;
} }
} }
@@ -818,7 +818,7 @@ VMAnonymousCache::Fault(struct VMAddressSpace* aspace, off_t offset)
? VM_PRIORITY_SYSTEM : VM_PRIORITY_USER; ? VM_PRIORITY_SYSTEM : VM_PRIORITY_USER;
if (vm_try_reserve_memory(B_PAGE_SIZE, priority, 0) != B_OK) { if (vm_try_reserve_memory(B_PAGE_SIZE, priority, 0) != B_OK) {
dprintf("%p->VMAnonymousCache::Fault(): Failed to reserve " dprintf("%p->VMAnonymousCache::Fault(): Failed to reserve "
"%d bytes of RAM.\n", this, (int)B_PAGE_SIZE); "%d bytes of RAM.\n", this, B_PAGE_SIZE);
return B_NO_MEMORY; return B_NO_MEMORY;
} }
} }
@@ -873,14 +873,14 @@ VMAnonymousCache::DeleteObject()
void void
VMAnonymousCache::_SwapBlockBuild(off_t startPageIndex, VMAnonymousCache::_SwapBlockBuild(page_num_t startPageIndex,
swap_addr_t startSlotIndex, uint32 count) swap_addr_t startSlotIndex, uint32 count)
{ {
WriteLocker locker(sSwapHashLock); WriteLocker locker(sSwapHashLock);
uint32 left = count; uint32 left = count;
for (uint32 i = 0, j = 0; i < count; i += j) { for (uint32 i = 0, j = 0; i < count; i += j) {
off_t pageIndex = startPageIndex + i; page_num_t pageIndex = startPageIndex + i;
swap_addr_t slotIndex = startSlotIndex + i; swap_addr_t slotIndex = startSlotIndex + i;
swap_hash_key key = { this, pageIndex }; swap_hash_key key = { this, pageIndex };
@@ -899,7 +899,7 @@ VMAnonymousCache::_SwapBlockBuild(off_t startPageIndex,
} }
swap->key.cache = this; swap->key.cache = this;
swap->key.page_index = pageIndex & ~(off_t)SWAP_BLOCK_MASK; swap->key.page_index = pageIndex & ~(page_num_t)SWAP_BLOCK_MASK;
swap->used = 0; swap->used = 0;
for (uint32 i = 0; i < SWAP_BLOCK_PAGES; i++) for (uint32 i = 0; i < SWAP_BLOCK_PAGES; i++)
swap->swap_slots[i] = SWAP_SLOT_NONE; swap->swap_slots[i] = SWAP_SLOT_NONE;
@@ -919,13 +919,13 @@ VMAnonymousCache::_SwapBlockBuild(off_t startPageIndex,
void void
VMAnonymousCache::_SwapBlockFree(off_t startPageIndex, uint32 count) VMAnonymousCache::_SwapBlockFree(page_num_t startPageIndex, uint32 count)
{ {
WriteLocker locker(sSwapHashLock); WriteLocker locker(sSwapHashLock);
uint32 left = count; uint32 left = count;
for (uint32 i = 0, j = 0; i < count; i += j) { for (uint32 i = 0, j = 0; i < count; i += j) {
off_t pageIndex = startPageIndex + i; page_num_t pageIndex = startPageIndex + i;
swap_hash_key key = { this, pageIndex }; swap_hash_key key = { this, pageIndex };
swap_block* swap = sSwapHashTable.Lookup(key); swap_block* swap = sSwapHashTable.Lookup(key);
@@ -948,7 +948,7 @@ VMAnonymousCache::_SwapBlockFree(off_t startPageIndex, uint32 count)
swap_addr_t swap_addr_t
VMAnonymousCache::_SwapBlockGetAddress(off_t pageIndex) VMAnonymousCache::_SwapBlockGetAddress(page_num_t pageIndex)
{ {
ReadLocker locker(sSwapHashLock); ReadLocker locker(sSwapHashLock);
@@ -1127,7 +1127,7 @@ VMAnonymousCache::_MergeSwapPages(VMAnonymousCache* source)
continue; continue;
for (uint32 i = 0; i < SWAP_BLOCK_PAGES; i++) { for (uint32 i = 0; i < SWAP_BLOCK_PAGES; i++) {
off_t pageIndex = swapBlockPageIndex + i; page_num_t pageIndex = swapBlockPageIndex + i;
swap_addr_t sourceSlotIndex = sourceSwapBlock->swap_slots[i]; swap_addr_t sourceSlotIndex = sourceSwapBlock->swap_slots[i];
if (sourceSlotIndex == SWAP_SLOT_NONE) if (sourceSlotIndex == SWAP_SLOT_NONE)
@@ -1318,7 +1318,7 @@ swap_file_add(const char* path)
swap->vnode = node; swap->vnode = node;
swap->cookie = descriptor->cookie; swap->cookie = descriptor->cookie;
uint32 pageCount = st.st_size >> PAGE_SHIFT; page_num_t pageCount = st.st_size >> PAGE_SHIFT;
swap->bmp = radix_bitmap_create(pageCount); swap->bmp = radix_bitmap_create(pageCount);
if (swap->bmp == NULL) { if (swap->bmp == NULL) {
free(swap); free(swap);
@@ -1635,18 +1635,18 @@ swap_free_page_swap_space(vm_page* page)
} }
uint32 page_num_t
swap_available_pages() swap_available_pages()
{ {
mutex_lock(&sAvailSwapSpaceLock); mutex_lock(&sAvailSwapSpaceLock);
uint32 avail = sAvailSwapSpace >> PAGE_SHIFT; page_num_t avail = sAvailSwapSpace >> PAGE_SHIFT;
mutex_unlock(&sAvailSwapSpaceLock); mutex_unlock(&sAvailSwapSpaceLock);
return avail; return avail;
} }
uint32 page_num_t
swap_total_swap_pages() swap_total_swap_pages()
{ {
mutex_lock(&sSwapFileListLock); mutex_lock(&sSwapFileListLock);
src/system/kernel/vm/VMAnonymousCache.h
+5 -5
View File
@@ -25,8 +25,8 @@ extern "C" {
void swap_init(void); void swap_init(void);
void swap_init_post_modules(void); void swap_init_post_modules(void);
bool swap_free_page_swap_space(vm_page* page); bool swap_free_page_swap_space(vm_page* page);
uint32 swap_available_pages(void); page_num_t swap_available_pages(void);
uint32 swap_total_swap_pages(void); page_num_t swap_total_swap_pages(void);
} }
@@ -73,10 +73,10 @@ private:
class WriteCallback; class WriteCallback;
friend class WriteCallback; friend class WriteCallback;
void _SwapBlockBuild(off_t pageIndex, void _SwapBlockBuild(page_num_t pageIndex,
swap_addr_t slotIndex, uint32 count); swap_addr_t slotIndex, uint32 count);
void _SwapBlockFree(off_t pageIndex, uint32 count); void _SwapBlockFree(page_num_t pageIndex, uint32 count);
swap_addr_t _SwapBlockGetAddress(off_t pageIndex); swap_addr_t _SwapBlockGetAddress(page_num_t pageIndex);
status_t _Commit(off_t size, int priority); status_t _Commit(off_t size, int priority);
void _MergePagesSmallerSource( void _MergePagesSmallerSource(