mirror of
https://gitlab.com/suyu-emu/suyu.git
synced 2024-03-15 23:15:44 +00:00
Merge pull request #917 from lioncash/crash
kernel/thread: Fix potential crashes introduced in 26de4bb5
This commit is contained in:
commit
d43dad001e
|
@ -28,20 +28,32 @@ SharedPtr<SharedMemory> SharedMemory::Create(SharedPtr<Process> owner_process, u
|
||||||
shared_memory->permissions = permissions;
|
shared_memory->permissions = permissions;
|
||||||
shared_memory->other_permissions = other_permissions;
|
shared_memory->other_permissions = other_permissions;
|
||||||
|
|
||||||
auto& vm_manager = shared_memory->owner_process->vm_manager;
|
if (address == 0) {
|
||||||
|
shared_memory->backing_block = std::make_shared<std::vector<u8>>(size);
|
||||||
|
shared_memory->backing_block_offset = 0;
|
||||||
|
|
||||||
// The memory is already available and mapped in the owner process.
|
// Refresh the address mappings for the current process.
|
||||||
auto vma = vm_manager.FindVMA(address);
|
if (Core::CurrentProcess() != nullptr) {
|
||||||
ASSERT_MSG(vma != vm_manager.vma_map.end(), "Invalid memory address");
|
Core::CurrentProcess()->vm_manager.RefreshMemoryBlockMappings(
|
||||||
ASSERT_MSG(vma->second.backing_block, "Backing block doesn't exist for address");
|
shared_memory->backing_block.get());
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
auto& vm_manager = shared_memory->owner_process->vm_manager;
|
||||||
|
|
||||||
// The returned VMA might be a bigger one encompassing the desired address.
|
// The memory is already available and mapped in the owner process.
|
||||||
auto vma_offset = address - vma->first;
|
auto vma = vm_manager.FindVMA(address);
|
||||||
ASSERT_MSG(vma_offset + size <= vma->second.size,
|
ASSERT_MSG(vma != vm_manager.vma_map.end(), "Invalid memory address");
|
||||||
"Shared memory exceeds bounds of mapped block");
|
ASSERT_MSG(vma->second.backing_block, "Backing block doesn't exist for address");
|
||||||
|
|
||||||
|
// The returned VMA might be a bigger one encompassing the desired address.
|
||||||
|
auto vma_offset = address - vma->first;
|
||||||
|
ASSERT_MSG(vma_offset + size <= vma->second.size,
|
||||||
|
"Shared memory exceeds bounds of mapped block");
|
||||||
|
|
||||||
|
shared_memory->backing_block = vma->second.backing_block;
|
||||||
|
shared_memory->backing_block_offset = vma->second.offset + vma_offset;
|
||||||
|
}
|
||||||
|
|
||||||
shared_memory->backing_block = vma->second.backing_block;
|
|
||||||
shared_memory->backing_block_offset = vma->second.offset + vma_offset;
|
|
||||||
shared_memory->base_address = address;
|
shared_memory->base_address = address;
|
||||||
|
|
||||||
return shared_memory;
|
return shared_memory;
|
||||||
|
|
|
@ -339,6 +339,17 @@ ResultVal<SharedPtr<Thread>> Thread::Create(std::string name, VAddr entry_point,
|
||||||
tls_slots.emplace_back(0); // The page is completely available at the start
|
tls_slots.emplace_back(0); // The page is completely available at the start
|
||||||
available_page = tls_slots.size() - 1;
|
available_page = tls_slots.size() - 1;
|
||||||
available_slot = 0; // Use the first slot in the new page
|
available_slot = 0; // Use the first slot in the new page
|
||||||
|
|
||||||
|
// Allocate some memory from the end of the linear heap for this region.
|
||||||
|
const size_t offset = thread->tls_memory->size();
|
||||||
|
thread->tls_memory->insert(thread->tls_memory->end(), Memory::PAGE_SIZE, 0);
|
||||||
|
|
||||||
|
auto& vm_manager = owner_process->vm_manager;
|
||||||
|
vm_manager.RefreshMemoryBlockMappings(thread->tls_memory.get());
|
||||||
|
|
||||||
|
vm_manager.MapMemoryBlock(Memory::TLS_AREA_VADDR + available_page * Memory::PAGE_SIZE,
|
||||||
|
thread->tls_memory, 0, Memory::PAGE_SIZE,
|
||||||
|
MemoryState::ThreadLocal);
|
||||||
}
|
}
|
||||||
|
|
||||||
// Mark the slot as used
|
// Mark the slot as used
|
||||||
|
|
|
@ -265,6 +265,8 @@ public:
|
||||||
private:
|
private:
|
||||||
Thread();
|
Thread();
|
||||||
~Thread() override;
|
~Thread() override;
|
||||||
|
|
||||||
|
std::shared_ptr<std::vector<u8>> tls_memory = std::make_shared<std::vector<u8>>();
|
||||||
};
|
};
|
||||||
|
|
||||||
/**
|
/**
|
||||||
|
|
Loading…
Reference in a new issue