corda/src/builtin.cpp

#include "builtin.h"
#include "machine.h"
#include "constants.h"
#include "run.h"

using namespace vm;

namespace {

inline void
replace(char a, char b, char* c)
{
  for (; *c; ++c) if (*c == a) *c = b;
}

jstring JNICALL
Object_toString(Thread* t, jobject this_)
{
  unsigned hash = objectHash(t, *this_);
  object s = makeString
    (t, "%s@0x%x",
     &byteArrayBody(t, className(t, objectClass(t, *this_)), 0),
     hash);

  return pushReference(t, s);
}

jclass JNICALL
Object_getClass(Thread* t, jobject this_)
{
  return pushReference(t, objectClass(t, *this_));
}

void JNICALL
Object_wait(Thread* t, jobject this_, jlong milliseconds)
{
  vm::wait(t, *this_, milliseconds);
}

void JNICALL
Object_notify(Thread* t, jobject this_)
{
  notify(t, *this_);
}

void JNICALL
Object_notifyAll(Thread* t, jobject this_)
{
  notifyAll(t, *this_);
}

jint JNICALL
Object_hashCode(Thread* t, jobject this_)
{
  return objectHash(t, *this_);
}

jobject JNICALL
Object_clone(Thread* t, jclass, jobject o)
{
  object clone = make(t, objectClass(t, *o));
  memcpy(reinterpret_cast<void**>(clone) + 1,
         reinterpret_cast<void**>(*o) + 1,
         (baseSize(t, *o, objectClass(t, *o)) - 1) * BytesPerWord);
  return pushReference(t, clone);
}

jclass JNICALL
ClassLoader_defineClass(Thread* t, jclass, jbyteArray b, jint offset,
                        jint length)
{
  uint8_t* buffer = static_cast<uint8_t*>(t->vm->system->allocate(length));
  memcpy(buffer, &byteArrayBody(t, *b, offset), length);
  object c = parseClass(t, buffer, length);
  t->vm->system->free(buffer);
  return pushReference(t, c);
}

jclass
search(Thread* t, jstring name, object (*op)(Thread*, object),
       bool replaceDots)
{
  if (LIKELY(name)) {
    object n = makeByteArray(t, stringLength(t, *name) + 1, false);
    char* s = reinterpret_cast<char*>(&byteArrayBody(t, n, 0));
    stringChars(t, *name, s);
    
    if (replaceDots) {
      replace('.', '/', s);
    }

    object r = op(t, n);
    if (t->exception) {
      return 0;
    }

    return pushReference(t, r);
  } else {
    t->exception = makeNullPointerException(t);
    return 0;
  }
}

jclass JNICALL
SystemClassLoader_findLoadedClass(Thread* t, jclass, jstring name)
{
  return search(t, name, findLoadedClass, true);
}

jclass JNICALL
SystemClassLoader_findClass(Thread* t, jclass, jstring name)
{
  return search(t, name, resolveClass, true);
}

jboolean JNICALL
SystemClassLoader_resourceExists(Thread* t, jclass, jstring name)
{
  if (LIKELY(name)) {
    char n[stringLength(t, *name) + 1];
    stringChars(t, *name, n);
    return t->vm->finder->exists(n);
  } else {
    t->exception = makeNullPointerException(t);
    return 0;
  }
}

jobject JNICALL
ObjectInputStream_makeInstance(Thread* t, jclass, jclass c)
{
  return pushReference(t, make(t, *c));
}

jclass JNICALL
Class_primitiveClass(Thread* t, jclass, jchar name)
{
  switch (name) {
  case 'B':
    return pushReference(t, arrayBody(t, t->vm->types, Machine::JbyteType));
  case 'C':
    return pushReference(t, arrayBody(t, t->vm->types, Machine::JcharType));
  case 'D':
    return pushReference(t, arrayBody(t, t->vm->types, Machine::JdoubleType));
  case 'F':
    return pushReference(t, arrayBody(t, t->vm->types, Machine::JfloatType));
  case 'I':
    return pushReference(t, arrayBody(t, t->vm->types, Machine::JintType));
  case 'J':
    return pushReference(t, arrayBody(t, t->vm->types, Machine::JlongType));
  case 'S':
    return pushReference(t, arrayBody(t, t->vm->types, Machine::JshortType));
  case 'V':
    return pushReference(t, arrayBody(t, t->vm->types, Machine::JvoidType));
  case 'Z':
    return pushReference(t, arrayBody(t, t->vm->types, Machine::JbooleanType));
  default:
    t->exception = makeIllegalArgumentException(t);
    return 0;
  }
}

void JNICALL
Class_initialize(Thread* t, jobject this_)
{
  initClass(t, *this_);
}

jboolean JNICALL
Class_isAssignableFrom(Thread* t, jobject this_, jclass that)
{
  if (LIKELY(that)) {
    return vm::isAssignableFrom(t, *this_, *that);
  } else {
    t->exception = makeNullPointerException(t);
    return 0;
  }
}

jlong JNICALL
Field_getPrimitive(Thread* t, jclass, jobject instance, jint code, jint offset)
{
  switch (code) {
  case ByteField: 
    return cast<int8_t>(*instance, offset);
  case BooleanField: 
    return cast<uint8_t>(*instance, offset);
  case CharField: 
    return cast<uint16_t>(*instance, offset);
  case ShortField: 
    return cast<int16_t>(*instance, offset);
  case IntField: 
    return cast<int32_t>(*instance, offset);
  case LongField: 
    return cast<int64_t>(*instance, offset);
  case FloatField: 
    return cast<uint32_t>(*instance, offset);
  case DoubleField: 
    return cast<uint64_t>(*instance, offset);
  default:
    abort(t);
  }
}

jobject JNICALL
Field_getObject(Thread* t, jclass, jobject instance, jint offset)
{
  return pushReference(t, cast<object>(*instance, offset));
}

void JNICALL
Field_setPrimitive(Thread* t, jclass, jobject instance, jint code, jint offset,
                   jlong value)
{
  switch (code) {
  case ByteField:
    cast<int8_t>(*instance, offset) = static_cast<int8_t>(value);
    break;
  case BooleanField:
    cast<uint8_t>(*instance, offset) = static_cast<uint8_t>(value);
    break;
  case CharField:
    cast<uint16_t>(*instance, offset) = static_cast<uint16_t>(value);
    break;
  case ShortField:
    cast<int16_t>(*instance, offset) = static_cast<int16_t>(value);
    break;
  case IntField: 
    cast<int32_t>(*instance, offset) = static_cast<int32_t>(value);
    break;
  case LongField: 
    cast<int64_t>(*instance, offset) = static_cast<int64_t>(value);
    break;
  case FloatField: 
    cast<uint32_t>(*instance, offset) = static_cast<uint32_t>(value);
    break;
  case DoubleField: 
    cast<uint64_t>(*instance, offset) = static_cast<uint64_t>(value);
    break;
  default:
    abort(t);
  }
}

void JNICALL
Field_setObject(Thread* t, jclass, jobject instance, jint offset,
                jobject value)
{
  set(t, cast<object>(*instance, offset), (value ? *value : 0));
}

jobject JNICALL
Constructor_make(Thread* t, jclass, jclass c)
{
  return pushReference(t, make(t, *c));
}

jobject JNICALL
Method_getCaller(Thread* t, jclass)
{
  return pushReference
    (t, frameMethod(t, frameNext(t, frameNext(t, t->frame))));
}

jobject JNICALL
Method_invoke(Thread* t, jclass, jobject method, jobject instance,
              jobjectArray arguments)
{
  object v = run2(t, *method, (instance ? *instance : 0), *arguments);
  if (t->exception) {
    t->exception = makeInvocationTargetException(t, t->exception);
  }
  return pushReference(t, v);
}

jint JNICALL
Array_getLength(Thread* t, jclass, jobject array)
{
  if (LIKELY(array)) {
    object a = *array;
    unsigned elementSize = classArrayElementSize(t, objectClass(t, a));

    if (LIKELY(elementSize)) {
      return cast<uintptr_t>(a, BytesPerWord);
    } else {
      t->exception = makeIllegalArgumentException(t);
    }
  } else {
    t->exception = makeNullPointerException(t);
  }
  return 0;
}

jobject JNICALL
Array_makeObjectArray(Thread* t, jclass, jclass elementType, jint length)
{
  return pushReference(t, makeObjectArray(t, *elementType, length, true));
}

jint JNICALL
Float_floatToRawIntBits(Thread*, jclass, jfloat v)
{
  int32_t r; memcpy(&r, &v, 4);
  return r;
}

jfloat JNICALL
Float_intBitsToFloat(Thread*, jclass, jint v)
{
  jfloat r; memcpy(&r, &v, 4);
  return r;
}

jlong JNICALL
Double_doubleToRawLongBits(Thread*, jclass, jdouble v)
{
  int64_t r; memcpy(&r, &v, 8);
  return r;
}

jdouble JNICALL
Double_longBitsToDouble(Thread*, jclass, jlong v)
{
  jdouble r; memcpy(&r, &v, 8);
  return r;
}

jobject JNICALL
String_intern(Thread* t, jobject this_)
{
  return pushReference(t, intern(t, *this_));
}

jstring JNICALL
System_getVMProperty(Thread* t, jclass, jint code)
{
  enum {
    JavaClassPath = 1
  };

  switch (code) {
  case JavaClassPath:
    return pushReference(t, makeString(t, "%s", t->vm->finder->path()));

  default:
    t->exception = makeRuntimeException(t, 0);
    return 0;
  }
}

void JNICALL
System_arraycopy(Thread* t, jclass, jobject src, jint srcOffset, jobject dst,
                 jint dstOffset, jint length)
{
  if (LIKELY(src and dst)) {
    object s = *src;
    object d = *dst;

    if (LIKELY(objectClass(t, s) == objectClass(t, d))) {
      unsigned elementSize = classArrayElementSize(t, objectClass(t, s));

      if (LIKELY(elementSize)) {
        intptr_t sl = cast<uintptr_t>(s, BytesPerWord);
        intptr_t dl = cast<uintptr_t>(d, BytesPerWord);
        if (LIKELY(srcOffset >= 0 and srcOffset + length <= sl and
                   dstOffset >= 0 and dstOffset + length <= dl))
        {
          uint8_t* sbody = &cast<uint8_t>(s, 2 * BytesPerWord);
          uint8_t* dbody = &cast<uint8_t>(d, 2 * BytesPerWord);
          if (src == dst) {
            memmove(dbody + (dstOffset * elementSize),
                    sbody + (srcOffset * elementSize),
                    length * elementSize);
          } else {
            memcpy(dbody + (dstOffset * elementSize),
                   sbody + (srcOffset * elementSize),
                   length * elementSize);
          }
          return;
        }
      }
    }
  } else {
    t->exception = makeNullPointerException(t);
    return;
  }

  t->exception = makeArrayStoreException(t);
}

jint JNICALL
System_identityHashCode(Thread* t, jclass, jobject o)
{
  if (LIKELY(o)) {
    return objectHash(t, *o);
  } else {
    t->exception = makeNullPointerException(t);
    return 0;
  }
}

void JNICALL
Runtime_load(Thread* t, jclass, jstring name, jboolean mapName)
{
  char n[stringLength(t, *name) + 1];
  stringChars(t, *name, n);

  for (System::Library* lib = t->vm->libraries; lib; lib = lib->next()) {
    if (lib->matches(n, mapName)) {
      // already loaded
      return;
    }
  }

  System::Library* lib;
  if (LIKELY(t->vm->system->success
             (t->vm->system->load(&lib, n, mapName, t->vm->libraries))))
  {
    t->vm->libraries = lib;
  } else {
    object message = makeString(t, "library not found: %s", n);
    t->exception = makeUnsatisfiedLinkError(t, message);
  }
}

void JNICALL
Runtime_gc(Thread* t, jobject)
{
  ENTER(t, Thread::ExclusiveState);

  collect(t, Heap::MajorCollection);
}

void JNICALL
Runtime_exit(Thread* t, jobject, jint code)
{
  t->vm->system->exit(code);
}

jlong JNICALL
Runtime_freeMemory(Thread*, jobject)
{
  // todo
  return 0;
}

jobject JNICALL
Throwable_trace(Thread* t, jclass, jint skipCount)
{
  int frame = t->frame;
  while (skipCount-- and frame >= 0) {
    frame = frameNext(t, frame);
  }
  
  // skip Throwable constructors
  while (frame >= 0
         and isAssignableFrom
         (t, arrayBody(t, t->vm->types, Machine::ThrowableType),
          methodClass(t, frameMethod(t, frame)))
         and strcmp(reinterpret_cast<const int8_t*>("<init>"),
                    &byteArrayBody(t, methodName(t, frameMethod(t, frame)), 0))
         == 0)
  {
    frame = frameNext(t, frame);
  }

  return pushReference(t, makeTrace(t, frame));
}

jarray JNICALL
Throwable_resolveTrace(Thread* t, jclass, jobject trace)
{
  unsigned length = arrayLength(t, *trace);
  object array = makeObjectArray
    (t, arrayBody(t, t->vm->types, Machine::StackTraceElementType),
     length, true);
  PROTECT(t, array);

  object e = 0;
  PROTECT(t, e);

  object class_ = 0;
  PROTECT(t, class_);

  for (unsigned i = 0; i < length; ++i) {
    e = arrayBody(t, *trace, i);

    class_ = className(t, methodClass(t, traceElementMethod(t, e)));
    class_ = makeString(t, class_, 0, byteArrayLength(t, class_) - 1, 0);

    object method = methodName(t, traceElementMethod(t, e));
    method = makeString(t, method, 0, byteArrayLength(t, method) - 1, 0);

    unsigned line = lineNumber
      (t, traceElementMethod(t, e), traceElementIp(t, e));

    object ste = makeStackTraceElement(t, class_, method, 0, line);
    set(t, objectArrayBody(t, array, i), ste);
  }

  return pushReference(t, array);
}

jobject JNICALL
Thread_currentThread(Thread* t, jclass)
{
  return pushReference(t, t->javaThread);
}

jlong JNICALL
Thread_doStart(Thread* t, jobject this_)
{
  Thread* p = new (t->vm->system->allocate(sizeof(Thread)))
    Thread(t->vm, *this_, t);

  enter(p, Thread::ActiveState);

  if (t->vm->system->success(t->vm->system->start(&(p->runnable)))) {
    return reinterpret_cast<jlong>(p);
  } else {
    p->exit();
    return 0;
  }
}

void JNICALL
Thread_interrupt(Thread* t, jclass, jlong peer)
{
  interrupt(t, reinterpret_cast<Thread*>(peer));
}

jlong JNICALL
ResourceInputStream_open(Thread* t, jclass, jstring path)
{
  if (LIKELY(path)) {
    char p[stringLength(t, *path) + 1];
    stringChars(t, *path, p);

    return reinterpret_cast<jlong>(t->vm->finder->find(p));
  } else {
    t->exception = makeNullPointerException(t);
    return 0;
  }
}

jint JNICALL
ResourceInputStream_read(Thread*, jclass, jlong peer, jint position)
{
  Finder::Data* d = reinterpret_cast<Finder::Data*>(peer);
  if (position >= static_cast<jint>(d->length())) {
    return -1;
  } else {
    return d->start()[position];
  }
}

jint JNICALL
ResourceInputStream_read2(Thread* t, jclass, jlong peer, jint position,
                          jbyteArray b, jint offset, jint length)
{
  if (length == 0) return 0;
  
  Finder::Data* d = reinterpret_cast<Finder::Data*>(peer);
  if (length > static_cast<jint>(d->length()) - position) {
    length = static_cast<jint>(d->length()) - position;
  }
  if (length <= 0) {
    return -1;
  } else {
    memcpy(&byteArrayBody(t, *b, offset), d->start() + position, length);
    return length;
  }
}

void JNICALL
ResourceInputStream_close(Thread*, jclass, jlong peer)
{
  reinterpret_cast<Finder::Data*>(peer)->dispose();
}

} // namespace

namespace vm {

void
populateBuiltinMap(Thread* t, object map)
{
  struct {
    const char* key;
    void* value;
  } builtins[] = {
    { "Java_java_lang_Class_isAssignableFrom",
      reinterpret_cast<void*>(::Class_isAssignableFrom) },
    { "Java_java_lang_Class_primitiveClass",
      reinterpret_cast<void*>(::Class_primitiveClass) },
    { "Java_java_lang_Class_initialize",
      reinterpret_cast<void*>(::Class_initialize) },

    { "Java_java_lang_ClassLoader_defineClass",
      reinterpret_cast<void*>(::ClassLoader_defineClass) },

    { "Java_java_lang_System_getVMProperty",
      reinterpret_cast<void*>(::System_getVMProperty) },
    { "Java_java_lang_System_arraycopy",
      reinterpret_cast<void*>(::System_arraycopy) },

    { "Java_java_lang_SystemClassLoader_findClass",
      reinterpret_cast<void*>(::SystemClassLoader_findClass) },
    { "Java_java_lang_SystemClassLoader_findLoadedClass",
      reinterpret_cast<void*>(::SystemClassLoader_findLoadedClass) },
    { "Java_java_lang_SystemClassLoader_resourceExists",
      reinterpret_cast<void*>(::SystemClassLoader_resourceExists) },

    { "Java_java_lang_Runtime_load",
      reinterpret_cast<void*>(::Runtime_load) },
    { "Java_java_lang_Runtime_gc",
      reinterpret_cast<void*>(::Runtime_gc) },
    { "Java_java_lang_Runtime_exit",
      reinterpret_cast<void*>(::Runtime_exit) },
    { "Java_java_lang_Runtime_freeMemory",
      reinterpret_cast<void*>(::Runtime_freeMemory) },

    { "Java_java_lang_String_intern",
      reinterpret_cast<void*>(::String_intern) },

    { "Java_java_lang_Thread_doStart",
      reinterpret_cast<void*>(::Thread_doStart) },
    { "Java_java_lang_Thread_interrupt",
      reinterpret_cast<void*>(::Thread_interrupt) },
    { "Java_java_lang_Thread_currentThread",
      reinterpret_cast<void*>(::Thread_currentThread) },

    { "Java_java_lang_Throwable_resolveTrace",
      reinterpret_cast<void*>(::Throwable_resolveTrace) },
    { "Java_java_lang_Throwable_trace",
      reinterpret_cast<void*>(::Throwable_trace) },

    { "Java_java_lang_Float_floatToRawIntBits",
      reinterpret_cast<void*>(::Float_floatToRawIntBits) },
    { "Java_java_lang_Float_intBitsToFloat",
      reinterpret_cast<void*>(::Float_intBitsToFloat) },

    { "Java_java_lang_Double_doubleToRawLongBits",
      reinterpret_cast<void*>(::Double_doubleToRawLongBits) },
    { "Java_java_lang_Double_longBitsToDouble",
      reinterpret_cast<void*>(::Double_longBitsToDouble) },

    { "Java_java_lang_Object_getClass",
      reinterpret_cast<void*>(::Object_getClass) },
    { "Java_java_lang_Object_notify",
      reinterpret_cast<void*>(::Object_notify) },
    { "Java_java_lang_Object_notifyAll",
      reinterpret_cast<void*>(::Object_notifyAll) },
    { "Java_java_lang_Object_toString",
      reinterpret_cast<void*>(::Object_toString) },
    { "Java_java_lang_Object_wait",
      reinterpret_cast<void*>(::Object_wait) },
    { "Java_java_lang_Object_hashCode",
      reinterpret_cast<void*>(::Object_hashCode) },
    { "Java_java_lang_Object_clone",
      reinterpret_cast<void*>(::Object_clone) },

    { "Java_java_lang_reflect_Array_getLength",
      reinterpret_cast<void*>(::Array_getLength) },
    { "Java_java_lang_reflect_Array_makeObjectArray",
      reinterpret_cast<void*>(::Array_makeObjectArray) },

    { "Java_java_lang_reflect_Constructor_make",
      reinterpret_cast<void*>(::Constructor_make) },

    { "Java_java_lang_reflect_Field_getPrimitive",
      reinterpret_cast<void*>(::Field_getPrimitive) },
    { "Java_java_lang_reflect_Field_getObject",
      reinterpret_cast<void*>(::Field_getObject) },
    { "Java_java_lang_reflect_Field_setPrimitive",
      reinterpret_cast<void*>(::Field_setPrimitive) },
    { "Java_java_lang_reflect_Field_setObject",
      reinterpret_cast<void*>(::Field_setObject) },

    { "Java_java_lang_reflect_Method_getCaller",
      reinterpret_cast<void*>(::Method_getCaller) },
    { "Java_java_lang_reflect_Method_invoke",
      reinterpret_cast<void*>(::Method_invoke) },

    { "Java_java_net_URL_00024ResourceInputStream_open",
      reinterpret_cast<void*>(::ResourceInputStream_open) },
    { "Java_java_net_URL_00024ResourceInputStream_read__JI",
      reinterpret_cast<void*>(::ResourceInputStream_read) },
    { "Java_java_net_URL_00024ResourceInputStream_read__JI_3BII",
      reinterpret_cast<void*>(::ResourceInputStream_read2) },
    { "Java_java_net_URL_00024ResourceInputStream_close",
      reinterpret_cast<void*>(::ResourceInputStream_close) },

    { "Java_java_io_ObjectInputStream_makeInstance",
      reinterpret_cast<void*>(::ObjectInputStream_makeInstance) },

    { 0, 0 }
  };

  for (unsigned i = 0; builtins[i].key; ++i) {
    object key = makeByteArray(t, builtins[i].key);
    PROTECT(t, key);
    object value = makePointer(t, builtins[i].value);

    hashMapInsert(t, map, key, value, byteArrayHash);
  }
}

} // namespace vm