//===------------ VMThread.cpp - VM thread description --------------------===//
//
//                                N3
//
// This file is distributed under the University of Illinois Open Source
// License. See LICENSE.TXT for details.
//
//===----------------------------------------------------------------------===//

#include "llvm/Target/TargetData.h"

#include "mvm/JIT.h"
#include "mvm/PrintBuffer.h"
#include "mvm/Threads/Locks.h"
#include "mvm/Threads/Thread.h"

#include "Assembly.h"
#include "CLIJit.h"
#include "N3ModuleProvider.h"
#include "VMClass.h"
#include "VMObject.h"
#include "VMThread.h"
#include "N3.h"

using namespace n3;

const unsigned int VMThread::StateRunning = 0;
const unsigned int VMThread::StateWaiting = 1;
const unsigned int VMThread::StateInterrupted = 2;

void VMThread::print(mvm::PrintBuffer* buf) const {
  buf->write("Thread<>");
	declare_gcroot(VMObject *, appThread) = ooo_appThread;
  appThread->print(buf);
}

extern void AddStandardCompilePasses(llvm::FunctionPassManager*);

VMThread::~VMThread() {
  delete perFunctionPasses;
}

VMThread::VMThread(VMObject* appThread, N3* vm) {
	llvm_gcroot(appThread, 0);
  this->perFunctionPasses = 0;
  this->ooo_appThread = appThread;
  this->MyVM = vm;
  this->lock = new mvm::LockNormal();
  this->varcond = new mvm::Cond();
  this->interruptFlag = 0;
  this->state = StateRunning;
  this->ooo_pendingException = 0;
  this->perFunctionPasses = new llvm::FunctionPassManager(vm->getLLVMModule());
  this->perFunctionPasses->add(new llvm::TargetData(vm->getLLVMModule()));
  AddStandardCompilePasses(this->perFunctionPasses);
}

VMObject* VMThread::currentThread() {
  VMThread* result = get();
  if (result != 0) {
		declare_gcroot(VMObject *, appThread) = result->ooo_appThread;
    return appThread;
  } else
    return 0;
}

void* VMThread::getCppException() {
  return (void*)((char*)VMThread::get()->internalPendingException - 8 * sizeof(void*));
}

VMObject* VMThread::getCLIException() {
  VMThread* th = VMThread::get();
	declare_gcroot(VMObject *, pendingException) = th->ooo_pendingException;
  return pendingException;
}

extern "C" void* __cxa_allocate_exception(unsigned);
extern "C" void __cxa_throw(void*, void*, void*);


void VMThread::throwException(VMObject* obj) {
	llvm_gcroot(obj, 0);
  VMThread* th = VMThread::get();
  assert(th->ooo_pendingException == 0 && "pending exception already there?");
  th->ooo_pendingException = obj;
  void* exc = __cxa_allocate_exception(0);
  th->internalPendingException = exc;
  __cxa_throw(exc, 0, 0); 
}

void VMThread::internalClearException() {
  ooo_pendingException = 0;
  internalPendingException = 0;
}

bool VMThread::compareException(VMClass* cl) {
  declare_gcroot(VMObject*, pe) = VMThread::get()->ooo_pendingException;
  assert(pe && "no pending exception?");
  return pe->classOf->subclassOf(cl);
}