#include "object/process.h"

#include "debug/debug.h"
#include "include/zcall.h"
#include "memory/paging_util.h"
#include "memory/physical_memory.h"
#include "object/thread.h"
#include "scheduler/scheduler.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() {
  auto proc = MakeRefCounted<Process>();
  proc->caps_.PushBack(
      MakeRefCounted<Capability>(proc, Capability::PROCESS, Z_INIT_PROC_SELF,
                                 ZC_PROC_SPAWN_PROC | ZC_PROC_SPAWN_THREAD));
  proc->caps_.PushBack(MakeRefCounted<Capability>(
      proc->vmas(), Capability::ADDRESS_SPACE, Z_INIT_VMAS_SELF, ZC_WRITE));
  return proc;
}

Process::Process()
    : id_(gNextId++), vmas_(MakeRefCounted<AddressSpace>()), state_(RUNNING) {}

RefPtr<Thread> Process::CreateThread() {
  MutexHolder lock(mutex_);
  RefPtr<Thread> thread = MakeRefCounted<Thread>(*this, next_thread_id_++);
  threads_.PushBack(thread);
  return thread;
}

RefPtr<Thread> Process::GetThread(uint64_t tid) {
  MutexHolder lock(mutex_);
  auto iter = threads_.begin();
  while (iter != threads_.end()) {
    if (iter->tid() == tid) {
      return *iter;
    }
    ++iter;
  }
  panic("Bad thread access.");
  return nullptr;
}

void Process::CheckState() {
  MutexHolder lock(mutex_);
  auto iter = threads_.begin();
  while (iter != threads_.end()) {
    if (iter->GetState() != Thread::FINISHED) {
      return;
    }
    ++iter;
  }
  state_ = FINISHED;
}

RefPtr<Capability> Process::ReleaseCapability(uint64_t cid) {
  MutexHolder lock(mutex_);
  auto iter = caps_.begin();
  while (iter != caps_.end()) {
    if (*iter && iter->id() == cid) {
      auto cap = *iter;
      *iter = {nullptr};
      return cap;
    }
    ++iter;
  }
  dbgln("Bad cap release: %u", cid);
  dbgln("Num caps: %u", caps_.size());
  return {};
}

RefPtr<Capability> Process::GetCapability(uint64_t cid) {
  MutexHolder lock(mutex_);
  auto iter = caps_.begin();
  while (iter != caps_.end()) {
    if (*iter && iter->id() == cid) {
      return *iter;
    }
    ++iter;
  }
  dbgln("Bad cap access %u", cid);
  dbgln("Num caps: %u", caps_.size());
  return {};
}

uint64_t Process::AddCapability(const RefPtr<Capability>& cap) {
  MutexHolder lock(mutex_);
  cap->set_id(next_cap_id_++);
  caps_.PushBack(cap);
  return cap->id();
}
uint64_t Process::AddCapability(const RefPtr<Thread>& thread) {
  MutexHolder lock(mutex_);
  uint64_t cap_id = next_cap_id_++;
  caps_.PushBack(
      MakeRefCounted<Capability>(thread, Capability::THREAD, cap_id, ZC_WRITE));
  return cap_id;
}

uint64_t Process::AddCapability(const RefPtr<Process>& p) {
  MutexHolder lock(mutex_);
  uint64_t cap_id = next_cap_id_++;
  caps_.PushBack(MakeRefCounted<Capability>(p, Capability::PROCESS, cap_id,
                                            ZC_WRITE | ZC_PROC_SPAWN_THREAD));
  return cap_id;
}
uint64_t Process::AddCapability(const RefPtr<AddressSpace>& vmas) {
  MutexHolder lock(mutex_);
  uint64_t cap_id = next_cap_id_++;
  caps_.PushBack(MakeRefCounted<Capability>(vmas, Capability::ADDRESS_SPACE,
                                            cap_id, ZC_WRITE));
  return cap_id;
}
uint64_t Process::AddCapability(const RefPtr<MemoryObject>& vmmo) {
  MutexHolder lock(mutex_);
  uint64_t cap_id = next_cap_id_++;
  caps_.PushBack(MakeRefCounted<Capability>(vmmo, Capability::MEMORY_OBJECT,
                                            cap_id, ZC_WRITE));
  return cap_id;
}
uint64_t Process::AddCapability(const RefPtr<Channel>& chan) {
  MutexHolder lock(mutex_);
  uint64_t cap_id = next_cap_id_++;
  caps_.PushBack(MakeRefCounted<Capability>(chan, Capability::CHANNEL, cap_id,
                                            ZC_WRITE | ZC_READ));
  return cap_id;
}

uint64_t Process::AddCapability(const RefPtr<Port>& port) {
  MutexHolder lock(mutex_);
  uint64_t cap_id = next_cap_id_++;
  caps_.PushBack(MakeRefCounted<Capability>(port, Capability::PORT, cap_id,
                                            ZC_WRITE | ZC_READ));
  return cap_id;
}

void Process::AddCapability(uint64_t cap_id, const RefPtr<MemoryObject>& vmmo) {
  MutexHolder lock(mutex_);
  caps_.PushBack(MakeRefCounted<Capability>(vmmo, Capability::MEMORY_OBJECT,
                                            cap_id, ZC_WRITE));
}