77 lines
1.8 KiB
C++
77 lines
1.8 KiB
C++
#include "scheduler/process.h"
|
|
|
|
#include "debug/debug.h"
|
|
#include "include/zcall.h"
|
|
#include "memory/paging_util.h"
|
|
#include "memory/physical_memory.h"
|
|
#include "scheduler/scheduler.h"
|
|
#include "scheduler/thread.h"
|
|
|
|
namespace {
|
|
|
|
static uint64_t gNextId = 1;
|
|
|
|
}
|
|
|
|
RefPtr<Process> Process::RootProcess() {
|
|
RefPtr<Process> proc = MakeRefCounted<Process>(0);
|
|
proc->threads_.PushBack(Thread::RootThread(*proc));
|
|
proc->next_thread_id_ = 1;
|
|
|
|
return proc;
|
|
}
|
|
RefPtr<Process> Process::Create() { return MakeRefCounted<Process>(); }
|
|
|
|
Process::Process() : id_(gNextId++), state_(RUNNING) {
|
|
caps_.PushBack(new Capability(this, Capability::PROCESS, Z_INIT_PROC_SELF,
|
|
ZC_PROC_SPAWN_PROC | ZC_PROC_SPAWN_THREAD));
|
|
}
|
|
|
|
RefPtr<Thread> Process::CreateThread() {
|
|
RefPtr<Thread> thread = MakeRefCounted<Thread>(*this, next_thread_id_++);
|
|
threads_.PushBack(thread);
|
|
return thread;
|
|
}
|
|
|
|
RefPtr<Thread> Process::GetThread(uint64_t tid) {
|
|
auto iter = threads_.begin();
|
|
while (iter != threads_.end()) {
|
|
if (iter->tid() == tid) {
|
|
return *iter;
|
|
}
|
|
++iter;
|
|
}
|
|
panic("Bad thread access.");
|
|
return nullptr;
|
|
}
|
|
|
|
void Process::CheckState() {
|
|
auto iter = threads_.begin();
|
|
while (iter != threads_.end()) {
|
|
if (iter->GetState() != Thread::FINISHED) {
|
|
return;
|
|
}
|
|
++iter;
|
|
}
|
|
state_ = FINISHED;
|
|
}
|
|
|
|
SharedPtr<Capability> Process::GetCapability(uint64_t cid) {
|
|
auto iter = caps_.begin();
|
|
while (iter != caps_.end()) {
|
|
if (iter->id() == cid) {
|
|
return *iter;
|
|
}
|
|
++iter;
|
|
}
|
|
dbgln("Bad cap access");
|
|
return {};
|
|
}
|
|
|
|
uint64_t Process::AddCapability(RefPtr<Thread>& thread) {
|
|
uint64_t cap_id = next_cap_id_++;
|
|
caps_.PushBack(
|
|
new Capability(thread.get(), Capability::THREAD, cap_id, ZC_WRITE));
|
|
return cap_id;
|
|
}
|