mirrors/rpcs3
1
0
Fork 0
mirror of https://github.com/RPCS3/rpcs3.git synced 2025-04-20 19:45:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

sys_mempool implemented

Browse source
This commit is contained in:
KaOs1 2015-08-13 18:39:35 +02:00 • committed by Nekotekina
parent 850416d530
commit bc13128afe
1 changed files with 99 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

109
rpcs3/Emu/SysCalls/Modules/sys_mempool.cpp
View file

@ -1,40 +1,129 @@
#include "stdafx.h"
#include "Emu/Memory/Memory.h"
#include "Emu/System.h"
#include "Emu/IdManager.h"
#include "Emu/SysCalls/Modules.h"
#include "sysPrxForUser.h"
extern Module sysPrxForUser;
using sys_mempool_t = u32;
struct memory_pool_t
{
vm::ptr<void> chunk;
u64 chunk_size;
u64 block_size;
u64 ralignment;
std::vector<vm::ptr<void>> free_blocks;
};
s32 sys_mempool_allocate_block()
{
throw EXCEPTION("");
}
s32 sys_mempool_create()
s32 sys_mempool_create(vm::ptr<sys_mempool_t> mempool, vm::ptr<void> chunk, const u64 chunk_size, const u64 block_size, const u64 ralignment)
{
throw EXCEPTION("");
sysPrxForUser.Warning("sys_mempool_create(mempool=*0x%x, chunk=*0x%x, chunk_size=%d, block_size=%d, ralignment=%d)", mempool, chunk, chunk_size, block_size, ralignment);
if (block_size > chunk_size)
{
return EINVAL;
}
u64 alignment = ralignment;
if (ralignment == 0 || ralignment == 2)
{
alignment = 4;
}
// Check if alignment is power of two
if ((alignment & (alignment - 1)) != 0)
{
return EINVAL;
}
// Test chunk address aligment
vm::ptr<u8> test_align = vm::ptr<u8>::make(chunk.addr());
if (!test_align.aligned())
{
return EINVAL;
}
auto id = Emu.GetIdManager().make<memory_pool_t>();
auto memory_pool = Emu.GetIdManager().get<memory_pool_t>(id);
memory_pool->chunk = chunk;
memory_pool->chunk_size = chunk_size;
memory_pool->block_size = block_size;
memory_pool->ralignment = alignment;
// TODO: check blocks alignment wrt ralignment
u64 num_blocks = chunk_size / block_size;
for (int i = 0; i < num_blocks; ++i)
{
memory_pool->free_blocks.push_back(vm::ptr<void>::make(chunk.addr() + i * block_size));
}
*mempool = id;
return CELL_OK;
}
s32 sys_mempool_destroy()
void sys_mempool_destroy(sys_mempool_t mempool)
{
throw EXCEPTION("");
sysPrxForUser.Warning("sys_mempool_destroy(mempool=%d)", mempool);
Emu.GetIdManager().remove<memory_pool_t>(mempool);
}
s32 sys_mempool_free_block()
s32 sys_mempool_free_block(sys_mempool_t mempool, vm::ptr<void> block)
{
throw EXCEPTION("");
sysPrxForUser.Warning("sys_mempool_free_block(mempool=%d, block=*0x%x)", mempool, block);
auto memory_pool = Emu.GetIdManager().get<memory_pool_t>(mempool);
if (!memory_pool)
{
return EINVAL;
}
// Cannot free a block not belonging to this memory pool
if (block.addr() > memory_pool->chunk.addr() + memory_pool->chunk_size)
{
return EINVAL;
}
memory_pool->free_blocks.push_back(block);
return CELL_OK;
}
s32 sys_mempool_get_count()
s32 sys_mempool_get_count(sys_mempool_t mempool)
{
throw EXCEPTION("");
sysPrxForUser.Warning("sys_mempool_get_count(mempool=%d)", mempool);
auto memory_pool = Emu.GetIdManager().get<memory_pool_t>(mempool);
if (!memory_pool)
{
return EINVAL;
}
return memory_pool->free_blocks.size();
}
s32 sys_mempool_try_allocate_block()
vm::ptr<void> sys_mempool_try_allocate_block(sys_mempool_t mempool)
{
throw EXCEPTION("");
sysPrxForUser.Warning("sys_mempool_try_allocate_block(mempool=%d)", mempool);
auto memory_pool = Emu.GetIdManager().get<memory_pool_t>(mempool);
if (!memory_pool || memory_pool->free_blocks.size() == 0)
{
return vm::null;
}
auto block_ptr = memory_pool->free_blocks.back();
memory_pool->free_blocks.pop_back();
return block_ptr;
}