Mon Apr 29 12:47:36 CEST 2002 Paolo Molaro <lupus@ximian.com>
[mono.git] / mono / metadata / object.c
index 6794e020615d30798fbef063ff81a633802d3a7d..a7f45a0a635b177922699ee6fb9432cb2cd5abde 100644 (file)
 #include <config.h>
 #include <stdlib.h>
 #include <stdio.h>
+#include <signal.h>
 #include <string.h>
+#include <mono/metadata/mono-endian.h>
 #include <mono/metadata/tabledefs.h>
+#include <mono/metadata/tokentype.h>
 #include <mono/metadata/loader.h>
 #include <mono/metadata/object.h>
-#if G_BYTE_ORDER != G_LITTLE_ENDIAN
-#include <sys/mman.h>
-#include <limits.h>    /* for PAGESIZE */
-#ifndef PAGESIZE
-#define PAGESIZE 4096
-#endif
+#include <mono/metadata/gc.h>
+#include <mono/metadata/appdomain.h>
+#if HAVE_BOEHM_GC
+#include <gc/gc.h>
 #endif
 
+MonoStats mono_stats;
+
+/* next object id for object hashcode */
+static guint32 uoid = 0;
+
+void
+mono_runtime_object_init (MonoObject *this)
+{
+       int i;
+       MonoMethod *method = NULL;
+       MonoClass *klass = this->vtable->klass;
+
+       for (i = 0; i < klass->method.count; ++i) {
+               if (!strcmp (".ctor", klass->methods [i]->name) &&
+                   klass->methods [i]->signature->param_count == 0) {
+                       method = klass->methods [i];
+                       break;
+               }
+       }
+
+       g_assert (method);
+
+       mono_runtime_invoke (method, this, NULL);
+}
+
+/*
+ * runtime_class_init:
+ * @klass: klass that needs to be initialized
+ *
+ * This routine calls the class constructor for @class.
+ */
+void
+mono_runtime_class_init (MonoClass *klass)
+{
+       int i;
+
+       for (i = 0; i < klass->method.count; ++i) {
+               MonoMethod *method = klass->methods [i];
+               if ((method->flags & METHOD_ATTRIBUTE_SPECIAL_NAME) && 
+                   (strcmp (".cctor", method->name) == 0)) {
+                       mono_runtime_invoke (method, NULL, NULL);
+                       return;
+               }
+       }
+       /* No class constructor found */
+}
+
+static gpointer
+default_trampoline (MonoMethod *method)
+{
+       return method;
+}
+
+static gpointer
+default_remoting_trampoline (MonoMethod *method)
+{
+       g_error ("remoting not installed");
+       return NULL;
+}
+
+static MonoTrampoline arch_create_jit_trampoline = default_trampoline;
+static MonoTrampoline arch_create_remoting_trampoline = default_remoting_trampoline;
+
+void
+mono_install_trampoline (MonoTrampoline func) 
+{
+       arch_create_jit_trampoline = func? func: default_trampoline;
+}
+
+void
+mono_install_remoting_trampoline (MonoTrampoline func) 
+{
+       arch_create_remoting_trampoline = func? func: default_remoting_trampoline;
+}
+
+#if 0 && HAVE_BOEHM_GC
 static void
-default_runtime_object_init (MonoObject *o)
+vtable_finalizer (void *obj, void *data) {
+       g_print ("%s finalized (%p)\n", (char*)data, obj);
+}
+#endif
+
+/**
+ * mono_class_vtable:
+ * @domain: the application domain
+ * @class: the class to initialize
+ *
+ * VTables are domain specific because we create domain specific code, and 
+ * they contain the domain specific static class data.
+ */
+MonoVTable *
+mono_class_vtable (MonoDomain *domain, MonoClass *class)
 {
-       return;
+       MonoClass *k;
+       MonoVTable *vt;
+       MonoClassField *field;
+       guint32 cindex;
+       guint32 cols [MONO_CONSTANT_SIZE];
+       const char *p;
+       char *t;
+       int i, len;
+
+       g_assert (class);
+
+       /* can interfaces have static fields? */
+       if (class->flags & TYPE_ATTRIBUTE_INTERFACE)
+               g_assert_not_reached ();
+
+       mono_domain_lock (domain);
+       if ((vt = mono_g_hash_table_lookup (domain->class_vtable_hash, class))) {
+               mono_domain_unlock (domain);
+               return vt;
+       }
+       
+       if (!class->inited)
+               mono_class_init (class);
+
+//     mono_stats.used_class_count++;
+//     mono_stats.class_vtable_size += sizeof (MonoVTable) + class->vtable_size * sizeof (gpointer);
+
+       vt = mono_mempool_alloc0 (domain->mp,  sizeof (MonoVTable) + 
+                                 class->vtable_size * sizeof (gpointer));
+       vt->klass = class;
+       vt->domain = domain;
+
+       if (class->class_size) {
+#if HAVE_BOEHM_GC
+               vt->data = GC_malloc (class->class_size + 8);
+               /*vt->data = GC_debug_malloc (class->class_size + 8, class->name, 2);*/
+               /*GC_register_finalizer (vt->data, vtable_finalizer, class->name, NULL, NULL);*/
+               mono_g_hash_table_insert (domain->static_data_hash, class, vt->data);
+#else
+               vt->data = mono_mempool_alloc0 (domain->mp, class->class_size + 8);
+               
+#endif
+//             mono_stats.class_static_data_size += class->class_size + 8;
+       }
+
+       for (i = class->field.first; i < class->field.last; ++i) {
+               field = &class->fields [i - class->field.first];
+               if (!(field->type->attrs & FIELD_ATTRIBUTE_STATIC))
+                       continue;
+               if (!(field->type->attrs & FIELD_ATTRIBUTE_HAS_DEFAULT))
+                       continue;
+               cindex = mono_metadata_get_constant_index (class->image, MONO_TOKEN_FIELD_DEF | (i + 1));
+               if (!cindex) {
+                       g_warning ("constant for field %s not found", field->name);
+                       continue;
+               }
+               mono_metadata_decode_row (&class->image->tables [MONO_TABLE_CONSTANT], cindex - 1, cols, MONO_CONSTANT_SIZE);
+               p = mono_metadata_blob_heap (class->image, cols [MONO_CONSTANT_VALUE]);
+               len = mono_metadata_decode_blob_size (p, &p);
+               t = (char*)vt->data + field->offset;
+               /* should we check that the type matches? */
+               switch (cols [MONO_CONSTANT_TYPE]) {
+               case MONO_TYPE_BOOLEAN:
+               case MONO_TYPE_U1:
+               case MONO_TYPE_I1:
+                       *t = *p;
+                       break;
+               case MONO_TYPE_CHAR:
+               case MONO_TYPE_U2:
+               case MONO_TYPE_I2: {
+                       guint16 *val = (guint16*)t;
+                       *val = read16 (p);
+                       break;
+               }
+               case MONO_TYPE_U4:
+               case MONO_TYPE_I4: {
+                       guint32 *val = (guint32*)t;
+                       *val = read32 (p);
+                       break;
+               }
+               case MONO_TYPE_U8:
+               case MONO_TYPE_I8: {
+                       guint64 *val = (guint64*)t;
+                       *val = read64 (p);
+                       break;
+               }
+               case MONO_TYPE_R4: {
+                       float *val = (float*)t;
+                       readr4 (p, val);
+                       break;
+               }
+               case MONO_TYPE_R8: {
+                       double *val = (double*)t;
+                       readr8 (p, val);
+                       break;
+               }
+               case MONO_TYPE_STRING: {
+                       //gpointer *val = (gpointer*)t;
+                       //*val = mono_string_new_utf16 (domain, (const guint16*)p, len/2);
+                       break;
+               }
+               case MONO_TYPE_CLASS:
+                       /* nothing to do, we malloc0 the data and the value can be 0 only */
+                       break;
+               default:
+                       g_warning ("type 0x%02x should not be in constant table", cols [MONO_CONSTANT_TYPE]);
+               }
+       }
+
+       vt->max_interface_id = class->max_interface_id;
+       
+       vt->interface_offsets = mono_mempool_alloc0 (domain->mp, 
+               sizeof (gpointer) * (class->max_interface_id + 1));
+
+       /* initialize interface offsets */
+       for (k = class; k ; k = k->parent) {
+               for (i = 0; i < k->interface_count; i++) {
+                       int slot;
+                       MonoClass *ic = k->interfaces [i];
+                       slot = class->interface_offsets [ic->interface_id];
+                       vt->interface_offsets [ic->interface_id] = &vt->vtable [slot];
+               }
+       }
+
+       /* initialize vtable */
+       for (i = 0; i < class->vtable_size; ++i) {
+               MonoMethod *cm;
+              
+               if ((cm = class->vtable [i]))
+                       vt->vtable [i] = arch_create_jit_trampoline (cm);
+       }
+
+       mono_g_hash_table_insert (domain->class_vtable_hash, class, vt);
+       mono_domain_unlock (domain);
+
+       mono_runtime_class_init (class);
+
+       return vt;
 }
 
-MonoRuntimeObjectInit mono_runtime_object_init = default_runtime_object_init;
+/**
+ * mono_class_proxy_vtable:
+ * @domain: the application domain
+ * @class: the class to proxy
+ *
+ * Creates a vtable for transparent proxies. It is basically
+ * a copy of the real vtable of @class, but all function pointers invoke
+ * the remoting functions, and vtable->klass points to the 
+ * transparent proxy class, and not to @class.
+ */
+MonoVTable *
+mono_class_proxy_vtable (MonoDomain *domain, MonoClass *class)
+{
+       MonoVTable *vt, *pvt;
+       int i, vtsize;
+
+       if ((pvt = mono_g_hash_table_lookup (domain->proxy_vtable_hash, class)))
+               return pvt;
+
+       vt = mono_class_vtable (domain, class);
+       vtsize = sizeof (MonoVTable) + class->vtable_size * sizeof (gpointer);
+
+//     mono_stats.class_vtable_size += vtsize;
+
+       pvt = mono_mempool_alloc (domain->mp, vtsize);
+       memcpy (pvt, vt, vtsize);
+
+       pvt->klass = mono_defaults.transparent_proxy_class;
+
+       /* initialize vtable */
+       for (i = 0; i < class->vtable_size; ++i) {
+               MonoMethod *cm;
+              
+               if ((cm = class->vtable [i]))
+                       pvt->vtable [i] = arch_create_remoting_trampoline (cm);
+       }
+
+       mono_g_hash_table_insert (domain->proxy_vtable_hash, class, pvt);
+
+       return pvt;
+}
+
+static MonoInvokeFunc default_mono_runtime_invoke = NULL;
+
+MonoObject*
+mono_runtime_invoke (MonoMethod *method, void *obj, void **params)
+{
+       if (!default_mono_runtime_invoke) {
+               g_error ("runtime invoke called on uninitialized runtime");
+               return NULL;
+       }
+       return default_mono_runtime_invoke (method, obj, params);
+}
+
+int
+mono_runtime_exec_main (MonoMethod *method, MonoArray *args)
+{
+       gpointer pa [1];
+
+       pa [0] = args;
+
+       if (method->signature->ret->type == MONO_TYPE_I4) {
+               MonoObject *res;
+               res = mono_runtime_invoke (method, NULL, pa);
+               return *(guint32 *)((char *)res + sizeof (MonoObject));
+       } else {
+               mono_runtime_invoke (method, NULL, pa);
+               return 0;
+       }
+}
 
 void
-mono_install_runtime_object_init (MonoRuntimeObjectInit func)
+mono_install_runtime_invoke (MonoInvokeFunc func)
 {
-       mono_runtime_object_init = func? func: default_runtime_object_init;
+       default_mono_runtime_invoke = func;
+}
+
+MonoObject*
+mono_runtime_invoke_array (MonoMethod *method, void *obj, MonoArray *params)
+{
+       MonoMethodSignature *sig = method->signature;
+       gpointer *pa = NULL;
+       int i;
+               
+       if (NULL != params) {
+               pa = alloca (sizeof (gpointer) * mono_array_length (params));
+               for (i = 0; i < mono_array_length (params); i++) {
+                       if (sig->params [i]->byref) {
+                               /* nothing to do */
+                       }
+
+                       switch (sig->params [i]->type) {
+                       case MONO_TYPE_U1:
+                       case MONO_TYPE_I1:
+                       case MONO_TYPE_BOOLEAN:
+                       case MONO_TYPE_U2:
+                       case MONO_TYPE_I2:
+                       case MONO_TYPE_CHAR:
+                       case MONO_TYPE_U:
+                       case MONO_TYPE_I:
+                       case MONO_TYPE_U4:
+                       case MONO_TYPE_I4:
+                       case MONO_TYPE_U8:
+                       case MONO_TYPE_I8:
+                       case MONO_TYPE_VALUETYPE:
+                               pa [i] = (char *)(((gpointer *)params->vector)[i]) + sizeof (MonoObject);
+                               break;
+                       case MONO_TYPE_STRING:
+                       case MONO_TYPE_OBJECT:
+                       case MONO_TYPE_CLASS:
+                               pa [i] = (char *)(((gpointer *)params->vector)[i]);
+                               break;
+                       default:
+                               g_error ("type 0x%x not handled in ves_icall_InternalInvoke", sig->params [i]->type);
+                       }
+               }
+       }
+
+       if (!strcmp (method->name, ".ctor")) {
+               obj = mono_object_new (mono_domain_get (), method->klass);
+               mono_runtime_invoke (method, obj, pa);
+               return obj;
+       } else
+               return mono_runtime_invoke (method, obj, pa);
 }
 
 /**
@@ -47,7 +393,12 @@ mono_install_runtime_object_init (MonoRuntimeObjectInit func)
 void *
 mono_object_allocate (size_t size)
 {
+#if HAVE_BOEHM_GC
+       /* if this is changed to GC_debug_malloc(), we need to change also metadata/gc.c */
+       void *o = GC_malloc (size);
+#else
        void *o = calloc (1, size);
+#endif
 
        return o;
 }
@@ -61,10 +412,14 @@ mono_object_allocate (size_t size)
 void
 mono_object_free (MonoObject *o)
 {
-       MonoClass *c = o->klass;
+#if HAVE_BOEHM_GC
+       g_error ("mono_object_free called with boehm gc.");
+#else
+       MonoClass *c = o->vtable->klass;
        
        memset (o, 0, c->instance_size);
        free (o);
+#endif
 }
 
 /**
@@ -75,16 +430,40 @@ mono_object_free (MonoObject *o)
  * looked up using @klass
  */
 MonoObject *
-mono_object_new (MonoClass *klass)
+mono_object_new (MonoDomain *domain, MonoClass *klass)
 {
-       MonoObject *o;
+       return mono_object_new_specific (mono_class_vtable (domain, klass));
+}
 
-       if (!klass->inited)
-               mono_class_init (klass);
+/**
+ * mono_object_new_specific:
+ * @vtable: the vtable of the object that we want to create
+ *
+ * Returns: A newly created object with class and domain specified
+ * by @vtable
+ */
+MonoObject *
+mono_object_new_specific (MonoVTable *vtable)
+{
+       MonoObject *o;
 
-       o = mono_object_allocate (klass->instance_size);
-       o->klass = klass;
+       mono_stats.new_object_count++;          /* thread safe? */
 
+       /* if the returned pointer is not the same as the address returned by GC_malloc(), 
+        * we need to change also metadata/gc.c to take into account the new offset.
+        */
+       if (vtable->klass->ghcimpl)
+               o = mono_object_allocate (vtable->klass->instance_size);
+       else {
+               guint32 *t;
+               t = mono_object_allocate (vtable->klass->instance_size + 4);
+               *t = ++uoid;
+               o = (MonoObject *)(++t);
+       }
+       o->vtable = vtable;
+       if (vtable->klass->has_finalize)
+               mono_object_register_finalizer (o);
+       
        return o;
 }
 
@@ -97,13 +476,13 @@ mono_object_new (MonoClass *klass)
  * looked up using @token in the @image image
  */
 MonoObject *
-mono_object_new_from_token  (MonoImage *image, guint32 token)
+mono_object_new_from_token  (MonoDomain *domain, MonoImage *image, guint32 token)
 {
        MonoClass *class;
 
        class = mono_class_get (image, token);
 
-       return mono_object_new (class);
+       return mono_object_new (domain, class);
 }
 
 
@@ -118,20 +497,71 @@ mono_object_clone (MonoObject *obj)
 {
        MonoObject *o;
        int size;
-       
-       size = obj->klass->instance_size;
+
+       size = obj->vtable->klass->instance_size;
        o = mono_object_allocate (size);
-       /* FIXME: handle arrays... */
-       
+
        memcpy (o, obj, size);
 
+       if (obj->vtable->klass->has_finalize)
+               mono_object_register_finalizer (o);
        return o;
 }
 
+/**
+ * mono_array_clone:
+ * @array: the array to clone
+ *
+ * Returns: A newly created array who is a shallow copy of @array
+ */
 MonoArray*
-mono_array_new_full (MonoClass *array_class, guint32 *lengths, guint32 *lower_bounds)
+mono_array_clone (MonoArray *array)
 {
-       guint32 byte_len;
+       MonoArray *o;
+       int size, i;
+       guint32 *sizes;
+       MonoClass *klass = array->obj.vtable->klass;
+
+       if (array->bounds == NULL) {
+               size = mono_array_length (array);
+               o = mono_array_new_full (((MonoObject *)array)->vtable->domain,
+                                        klass, &size, NULL);
+
+               size *= mono_array_element_size (klass);
+               memcpy (o, array, sizeof (MonoArray) + size);
+
+               return o;
+       }
+       
+       sizes = alloca (klass->rank * sizeof(guint32) * 2);
+       size = mono_array_element_size (klass);
+       for (i = 0; i < klass->rank; ++i) {
+               sizes [i] = array->bounds [i].length;
+               size *= array->bounds [i].length;
+               sizes [i + klass->rank] = array->bounds [i].lower_bound;
+       }
+       o = mono_array_new_full (((MonoObject *)array)->vtable->domain, 
+                                klass, sizes, sizes + klass->rank);
+       memcpy (o, array, sizeof(MonoArray) + size);
+
+       return o;
+}
+
+/*
+ * mono_array_new_full:
+ * @domain: domain where the object is created
+ * @array_class: array class
+ * @lengths: lengths for each dimension in the array
+ * @lower_bounds: lower bounds for each dimension in the array (may be NULL)
+ *
+ * This routine creates a new array objects with the given dimensions,
+ * lower bounds and type.
+ */
+MonoArray*
+mono_array_new_full (MonoDomain *domain, MonoClass *array_class, 
+                    guint32 *lengths, guint32 *lower_bounds)
+{
+       guint32 byte_len, len;
        MonoObject *o;
        MonoArray *array;
        MonoArrayBounds *bounds;
@@ -139,17 +569,31 @@ mono_array_new_full (MonoClass *array_class, guint32 *lengths, guint32 *lower_bo
 
        if (!array_class->inited)
                mono_class_init (array_class);
+
        byte_len = mono_array_element_size (array_class);
+       len = 1;
 
-       bounds = g_malloc0 (sizeof (MonoArrayBounds) * array_class->rank);
-       for (i = 0; i < array_class->rank; ++i) {
-               bounds [i].length = lengths [i];
-               byte_len *= lengths [i];
+       if (array_class->rank == 1 &&
+           (lower_bounds == NULL || lower_bounds [0] == 0)) {
+               bounds = NULL;
+               len = lengths [0];
+       } else {
+       #if HAVE_BOEHM_GC
+               bounds = GC_malloc (sizeof (MonoArrayBounds) * array_class->rank);
+       #else
+               bounds = g_malloc0 (sizeof (MonoArrayBounds) * array_class->rank);
+       #endif
+               for (i = 0; i < array_class->rank; ++i) {
+                       bounds [i].length = lengths [i];
+                       len *= lengths [i];
+               }
+
+               if (lower_bounds)
+                       for (i = 0; i < array_class->rank; ++i)
+                               bounds [i].lower_bound = lower_bounds [i];
        }
 
-       if (lower_bounds)
-               for (i = 0; i < array_class->rank; ++i)
-                       bounds [i].lower_bound = lower_bounds [i];
+       byte_len *= len;
        /* 
         * Following three lines almost taken from mono_object_new ():
         * they need to be kept in sync.
@@ -157,31 +601,61 @@ mono_array_new_full (MonoClass *array_class, guint32 *lengths, guint32 *lower_bo
        o = mono_object_allocate (sizeof (MonoArray) + byte_len);
        if (!o)
                G_BREAKPOINT ();
-       o->klass = array_class;
+       o->vtable = mono_class_vtable (domain, array_class);
 
        array = (MonoArray*)o;
 
        array->bounds = bounds;
+       array->max_length = len;
+
        return array;
 }
 
 /*
  * mono_array_new:
- * @image: image where the object is being referenced
+ * @domain: domain where the object is created
  * @eclass: element class
  * @n: number of array elements
  *
- * This routine creates a new szarray with @n elements of type @token
+ * This routine creates a new szarray with @n elements of type @eclass.
  */
 MonoArray *
-mono_array_new (MonoClass *eclass, guint32 n)
+mono_array_new (MonoDomain *domain, MonoClass *eclass, guint32 n)
 {
        MonoClass *ac;
 
-       ac = mono_array_class_get (eclass, 1);
+       ac = mono_array_class_get (&eclass->byval_arg, 1);
        g_assert (ac != NULL);
 
-       return mono_array_new_full (ac, &n, NULL);
+       return mono_array_new_specific (mono_class_vtable (domain, ac), n);
+}
+
+/*
+ * mono_array_new_specific:
+ * @vtable: a vtable in the appropriate domain for an initialized class
+ * @n: number of array elements
+ *
+ * This routine is a fast alternative to mono_array_new() for code which
+ * can be sure about the domain it operates in.
+ */
+MonoArray *
+mono_array_new_specific (MonoVTable *vtable, guint32 n)
+{
+       MonoObject *o;
+       MonoArray *ao;
+       gsize byte_len;
+
+       byte_len = n * mono_array_element_size (vtable->klass);
+       o = mono_object_allocate (sizeof (MonoArray) + byte_len);
+       if (!o)
+               G_BREAKPOINT ();
+       o->vtable = vtable;
+
+       ao = (MonoArray *)o;
+       ao->bounds = NULL;
+       ao->max_length = n;
+
+       return ao;
 }
 
 /**
@@ -192,25 +666,78 @@ mono_array_new (MonoClass *eclass, guint32 n)
  * Returns: A newly created string object which contains @text.
  */
 MonoString *
-mono_string_new_utf16 (const guint16 *text, gint32 len)
+mono_string_new_utf16 (MonoDomain *domain, const guint16 *text, gint32 len)
 {
        MonoString *s;
-       MonoArray *ca;
-
-       s = (MonoString*)mono_object_new (mono_defaults.string_class);
+       
+       s = mono_string_new_size (domain, len);
        g_assert (s != NULL);
 
-       ca = (MonoArray *)mono_array_new (mono_defaults.string_class, len);
-       g_assert (ca != NULL);
-       
-       s->c_str = ca;
-       s->length = len;
+       memcpy (mono_string_chars (s), text, len * 2);
 
-       memcpy (ca->vector, text, len * 2);
+       return s;
+}
+
+/**
+ * mono_string_new_size:
+ * @text: a pointer to an utf16 string
+ * @len: the length of the string
+ *
+ * Returns: A newly created string object of @len
+ */
+MonoString *
+mono_string_new_size (MonoDomain *domain, gint32 len)
+{
+       MonoString *s;
+
+       /* 
+        * enable to get a good speedup: we still need to figure out
+        * how the sync structure is freed.
+        */
+#ifdef 0 && HAVE_BOEHM_GC
+       s = GC_malloc_atomic (sizeof (MonoString) + ((len + 1) * 2));
+       s->object.synchronisation = 0;
+       mono_string_chars (s) [len] = 0;
+#else
+       s = (MonoString*)mono_object_allocate (sizeof (MonoString) + ((len + 1) * 2));
+#endif
+       if (!s)
+               G_BREAKPOINT ();
+
+       s->object.vtable = mono_class_vtable (domain, mono_defaults.string_class);
+       s->length = len;
 
        return s;
 }
 
+/*
+ * mono_string_new_len:
+ * @text: a pointer to an utf8 string
+ * @length: number of bytes in @text to consider
+ *
+ * Returns: A newly created string object which contains @text.
+ */
+MonoString*
+mono_string_new_len (MonoDomain *domain, const char *text, guint length)
+{
+       GError *error = NULL;
+       MonoString *o = NULL;
+       guint16 *ut;
+       glong items_written;
+
+       
+       ut = g_utf8_to_utf16 (text, length, NULL, &items_written, &error);
+
+       if (!error)
+               o = mono_string_new_utf16 (domain, ut, items_written);
+       else 
+               g_error_free (error);
+
+       g_free (ut);
+
+       return o;
+}
+
 /**
  * mono_string_new:
  * @text: a pointer to an utf8 string
@@ -218,7 +745,7 @@ mono_string_new_utf16 (const guint16 *text, gint32 len)
  * Returns: A newly created string object which contains @text.
  */
 MonoString*
-mono_string_new (const char *text)
+mono_string_new (MonoDomain *domain, const char *text)
 {
        GError *error = NULL;
        MonoString *o = NULL;
@@ -226,15 +753,12 @@ mono_string_new (const char *text)
        glong items_written;
        int l;
 
-       if (text == NULL)
-               return NULL;
-
        l = strlen (text);
        
        ut = g_utf8_to_utf16 (text, l, NULL, &items_written, &error);
 
        if (!error)
-               o = mono_string_new_utf16 (ut, items_written);
+               o = mono_string_new_utf16 (domain, ut, items_written);
        else 
                g_error_free (error);
 
@@ -243,6 +767,20 @@ mono_string_new (const char *text)
        return o;
 }
 
+/*
+ * mono_string_new_wrapper:
+ * @text: pointer to utf8 characters.
+ *
+ * Helper function to create a string object from @text in the current domain.
+ */
+MonoString*
+mono_string_new_wrapper (const char *text)
+{
+       MonoDomain *domain = mono_domain_get ();
+
+       return mono_string_new (domain, text);
+}
+
 /**
  * mono_value_box:
  * @class: the class of the value
@@ -251,7 +789,7 @@ mono_string_new (const char *text)
  * Returns: A newly created object which contains @value.
  */
 MonoObject *
-mono_value_box (MonoClass *class, gpointer value)
+mono_value_box (MonoDomain *domain, MonoClass *class, gpointer value)
 {
        MonoObject *res;
        int size;
@@ -260,12 +798,14 @@ mono_value_box (MonoClass *class, gpointer value)
 
        size = mono_class_instance_size (class);
        res = mono_object_allocate (size);
-       res->klass = class;
+       res->vtable = mono_class_vtable (domain, class);
 
        size = size - sizeof (MonoObject);
 
        memcpy ((char *)res + sizeof (MonoObject), value, size);
 
+       if (class->has_finalize)
+               mono_object_register_finalizer (res);
        return res;
 }
 
@@ -279,166 +819,183 @@ mono_value_box (MonoClass *class, gpointer value)
 MonoObject *
 mono_object_isinst (MonoObject *obj, MonoClass *klass)
 {
+       MonoVTable *vt;
        MonoClass *oklass;
 
        if (!obj)
                return NULL;
 
-       oklass = obj->klass;
+       vt = obj->vtable;
+       oklass = vt->klass;
 
        if (!klass->inited)
                mono_class_init (klass);
 
        if (klass->flags & TYPE_ATTRIBUTE_INTERFACE) {
                if ((klass->interface_id <= oklass->max_interface_id) &&
-                   oklass->interface_offsets [klass->interface_id])
+                   vt->interface_offsets [klass->interface_id])
                        return obj;
        } else {
-               if ((oklass->baseval - klass->baseval) <= klass->diffval)
+               if (oklass == mono_defaults.transparent_proxy_class) {
+                       /* fixme: add check for IRemotingTypeInfo */
+                       oklass = ((MonoTransparentProxy *)obj)->klass;
+               }
+               if (klass->rank) {
+                       if (oklass->rank == klass->rank && 
+                           (oklass->element_class->baseval - klass->element_class->baseval) <= 
+                           klass->element_class->diffval)
+                               return obj;
+                       
+               } else if ((oklass->baseval - klass->baseval) <= klass->diffval)
                        return obj;
        }
 
        return NULL;
 }
 
-static GHashTable *ldstr_table = NULL;
-
-static int
-ldstr_hash (const char* str)
+static MonoString*
+mono_string_is_interned_lookup (MonoString *str, int insert)
 {
-       guint len, h;
-       const char *end;
-       len = mono_metadata_decode_blob_size (str, &str);
-       end = str + len;
-       h = *str;
+       MonoGHashTable *ldstr_table;
+       MonoString *res;
+       MonoDomain *domain;
+       char *ins = g_malloc (4 + str->length * 2);
+       char *p;
+       int bloblen;
+       
+       /* Encode the length */
+       p = ins;
+       mono_metadata_encode_value (2 * str->length, p, &p);
+       bloblen = p - ins;
+       p = ins;
+       mono_metadata_encode_value (bloblen + 2 * str->length, p, &p);
+       bloblen = (p - ins) + 2 * str->length;
        /*
-        * FIXME: The distribution may not be so nice with lots of
-        * null chars in the string.
+        * ins is stored in the hash table as a key and needs to have the same
+        * representation as in the metadata: we swap the character bytes on big
+        * endian boxes.
         */
-       for (str += 1; str < end; str++)
-               h = (h << 5) - h + *str;
-       return h;
-}
-
-static gboolean
-ldstr_equal (const char *str1, const char *str2) {
-       int len;
-       if ((len=mono_metadata_decode_blob_size (str1, &str1)) !=
-                               mono_metadata_decode_blob_size (str2, &str2))
-               return 0;
-       return memcmp (str1, str2, len) == 0;
-}
-
-typedef struct {
-       MonoString *obj;
-       MonoString *found;
-} InternCheck;
-
-static void
-check_interned (gpointer key, MonoString *value, InternCheck *check)
-{
-       if (value == check->obj)
-               check->found = value;
+#if G_BYTE_ORDER != G_LITTLE_ENDIAN
+       {
+               int i;
+               char *p2 = mono_string_chars (str);
+               for (i = 0; i < str->length; ++i) {
+                       *p++ = p2 [1];
+                       *p++ = p2 [0];
+                       p2 += 2;
+               }
+       }
+#else
+       memcpy (p, mono_string_chars (str), str->length * 2);
+#endif
+       domain = ((MonoObject *)str)->vtable->domain;
+       ldstr_table = domain->ldstr_table;
+       mono_domain_lock (domain);
+       if ((res = mono_g_hash_table_lookup (ldstr_table, ins))) {
+               mono_domain_unlock (domain);
+               g_free (ins);
+               return res;
+       }
+       if (insert) {
+               mono_g_hash_table_insert (ldstr_table, ins, str);
+               mono_domain_unlock (domain);
+               return str;
+       }
+       mono_domain_unlock (domain);
+       g_free (ins);
+       return NULL;
 }
 
 MonoString*
 mono_string_is_interned (MonoString *o)
 {
-       InternCheck check;
-       check.obj = o;
-       check.found = NULL;
-       /*
-        * Yes, this is slow. Our System.String implementation needs to be redone.
-        * And GLib needs foreach() methods that can be stopped halfway.
-        */
-       g_hash_table_foreach (ldstr_table, (GHFunc)check_interned, &check);
-       return check.found;
+       return mono_string_is_interned_lookup (o, FALSE);
 }
 
 MonoString*
 mono_string_intern (MonoString *str)
 {
-       MonoString *res;
-       char *ins = g_malloc (4 + str->length * 2);
-       char *p;
-       
-       /* Encode the length */
-       p = ins;
-       mono_metadata_encode_value (str->length, p, &p);
-       memcpy (p, str->c_str->vector, str->length * 2);
-       
-       if ((res = g_hash_table_lookup (ldstr_table, str))) {
-               g_free (ins);
-               return res;
-       }
-       g_hash_table_insert (ldstr_table, ins, str);
-       return str;
+       return mono_string_is_interned_lookup (str, TRUE);
 }
 
+/*
+ * mono_ldstr:
+ * @domain: the domain where the string will be used.
+ * @image: a metadata context
+ * @idx: index into the user string table.
+ * 
+ * Implementation for the ldstr opcode.
+ */
 MonoString*
-mono_ldstr (MonoImage *image, guint32 index)
+mono_ldstr (MonoDomain *domain, MonoImage *image, guint32 idx)
 {
        const char *str, *sig;
        MonoString *o;
        size_t len2;
-       
-       if (!ldstr_table)
-               ldstr_table = g_hash_table_new ((GHashFunc)ldstr_hash, (GCompareFunc)ldstr_equal);
-       
-       sig = str = mono_metadata_user_string (image, index);
-       
-       if ((o = g_hash_table_lookup (ldstr_table, str)))
+               
+       sig = str = mono_metadata_user_string (image, idx);
+
+       mono_domain_lock (domain);
+       if ((o = mono_g_hash_table_lookup (domain->ldstr_table, sig))) {
+               mono_domain_unlock (domain);
                return o;
+       }
        
        len2 = mono_metadata_decode_blob_size (str, &str);
+       len2 >>= 1;
+
+       o = mono_string_new_utf16 (domain, (guint16*)str, len2);
 #if G_BYTE_ORDER != G_LITTLE_ENDIAN
-#define SWAP16(x) (x) = GUINT16_FROM_LE ((x))
        {
-               gint i;
-               guint16 *s;
-
-               /* FIXME: it will be better to just add WRITE and after get it to previous state */
-               mprotect ((void *) ((int) str & ~(PAGESIZE - 1)), len2 + ((int) str & (PAGESIZE - 1)),
-                                   PROT_READ | PROT_WRITE | PROT_EXEC);
-               len2 >>= 1;
-               for (i = 0, s = (guint16 *) str; i < len2; i++, s++) {
-                       *s = ((*s & 0xff) << 8) | (*s >> 8);
+               int i;
+               guint16 *p2 = (guint16*)mono_array_addr (o->c_str, guint16, 0);
+               for (i = 0; i < len2; ++i) {
+                       *p2 = GUINT16_FROM_LE (*p2);
+                       ++p2;
                }
        }
-#undef SWAP16
-#else
-               len2 >>= 1;
 #endif
-
-       o = mono_string_new_utf16 ((guint16*)str, len2);
-       g_hash_table_insert (ldstr_table, (gpointer)sig, o);
+       mono_g_hash_table_insert (domain->ldstr_table, (gpointer)sig, o);
+       mono_domain_unlock (domain);
 
        return o;
 }
 
+/*
+ * mono_string_to_utf8:
+ * @s: a System.String
+ *
+ * Return the UTF8 representation for @s.
+ * the resulting buffer nedds to be freed with g_free().
+ */
 char *
 mono_string_to_utf8 (MonoString *s)
 {
-       char *as, *vector;
+       char *as;
        GError *error = NULL;
 
        g_assert (s != NULL);
 
-       if (!s->length || !s->c_str)
+       if (!s->length)
                return g_strdup ("");
 
-       vector = (char*)s->c_str->vector;
-
-       g_assert (vector != NULL);
-
-       as = g_utf16_to_utf8 (vector, s->length, NULL, NULL, &error);
-
-       g_assert (!error);
+       as = g_utf16_to_utf8 (mono_string_chars (s), s->length, NULL, NULL, &error);
+       if (error)
+               g_warning (error->message);
 
        return as;
 }
 
-char *
+/*
+ * mono_string_to_utf16:
+ * @s: a MonoString
+ *
+ * Return an null-terminated array of the utf-16 chars
+ * contained in @s. The result must be freed with g_free().
+ * This is a temporary helper until our string implementation
+ * is reworked to always include the null terminating char.
+ */
+gunichar2 *
 mono_string_to_utf16 (MonoString *s)
 {
        char *as;
@@ -449,20 +1006,20 @@ mono_string_to_utf16 (MonoString *s)
        as [(s->length * 2)] = '\0';
        as [(s->length * 2) + 1] = '\0';
 
-       if (!s->length || !s->c_str) {
-               return (as);
+       if (!s->length) {
+               return (gunichar2 *)(as);
        }
        
        memcpy (as, mono_string_chars(s), s->length * 2);
        
-       return (as);
+       return (gunichar2 *)(as);
 }
 
 static void
 default_ex_handler (MonoException *ex)
 {
        MonoObject *o = (MonoObject*)ex;
-       g_error ("Exception %s.%s raised in C code", o->klass->name_space, o->klass->name);
+       g_error ("Exception %s.%s raised in C code", o->vtable->klass->name_space, o->vtable->klass->name);
 }
 
 static MonoExceptionFunc ex_handler = default_ex_handler;
@@ -473,9 +1030,177 @@ mono_install_handler        (MonoExceptionFunc func)
        ex_handler = func? func: default_ex_handler;
 }
 
+/*
+ * mono_raise_exception:
+ * @ex: exception object
+ *
+ * Signal the runtime that the exception @ex has been raised in unmanaged code.
+ */
 void
 mono_raise_exception (MonoException *ex) 
 {
        ex_handler (ex);
 }
 
+MonoWaitHandle *
+mono_wait_handle_new (MonoDomain *domain, HANDLE handle)
+{
+       MonoWaitHandle *res;
+
+       res = (MonoWaitHandle *)mono_object_new (domain, mono_defaults.waithandle_class);
+
+       res->handle = handle;
+
+       return res;
+}
+
+MonoAsyncResult *
+mono_async_result_new (MonoDomain *domain, HANDLE handle, MonoObject *state, gpointer data)
+{
+       MonoAsyncResult *res;
+
+       res = (MonoAsyncResult *)mono_object_new (domain, mono_defaults.asyncresult_class);
+
+       res->data = data;
+       res->async_state = state;
+       res->handle = (MonoObject *)mono_wait_handle_new (domain, handle);
+       res->sync_completed = FALSE;
+       res->completed = FALSE;
+
+       return res;
+}
+
+void
+mono_message_init (MonoDomain *domain,
+                  MonoMethodMessage *this, 
+                  MonoReflectionMethod *method,
+                  MonoArray *out_args)
+{
+       MonoMethodSignature *sig = method->method->signature;
+       MonoString *name;
+       int i, j;
+       char **names;
+       guint8 arg_type;
+
+       this->method = method;
+
+       this->args = mono_array_new (domain, mono_defaults.object_class, sig->param_count);
+       this->arg_types = mono_array_new (domain, mono_defaults.byte_class, sig->param_count);
+
+       names = g_new (char *, sig->param_count);
+       mono_method_get_param_names (method->method, (const char **) names);
+       this->names = mono_array_new (domain, mono_defaults.string_class, sig->param_count);
+       
+       for (i = 0; i < sig->param_count; i++) {
+                name = mono_string_new (domain, names [i]);
+                mono_array_set (this->names, gpointer, i, name);       
+       }
+
+       g_free (names);
+       
+       for (i = 0, j = 0; i < sig->param_count; i++) {
+
+               if (sig->params [i]->byref) {
+                       if (out_args) {
+                               gpointer arg = mono_array_get (out_args, gpointer, j);
+                               mono_array_set (this->args, gpointer, i, arg);
+                               j++;
+                       }
+                       arg_type = 2;
+                       if (sig->params [i]->attrs & PARAM_ATTRIBUTE_IN)
+                               arg_type |= 1;
+               } else {
+                       arg_type = 1;
+               }
+
+               mono_array_set (this->arg_types, guint8, i, arg_type);
+       }
+}
+
+/**
+ * mono_remoting_invoke:
+ * @real_proxy: pointer to a RealProxy object
+ * @msg: The MonoMethodMessage to execute
+ * @exc: used to store exceptions
+ * @out_args: used to store output arguments
+ *
+ * This is used to call RealProxy::Invoke(). RealProxy::Invoke() returns an
+ * IMessage interface and it is not trivial to extract results from there. So
+ * we call an helper method PrivateInvoke instead of calling
+ * RealProxy::Invoke() directly.
+ *
+ * Returns: the result object.
+ */
+MonoObject *
+mono_remoting_invoke (MonoObject *real_proxy, MonoMethodMessage *msg, 
+                     MonoObject **exc, MonoArray **out_args)
+{
+       static MonoMethod *im = NULL;
+       gpointer pa [4];
+
+       //static MonoObject *(*invoke) (gpointer, gpointer, MonoObject **, MonoArray **) = NULL;
+
+       /* fixme: make this domain dependent */
+       if (!im) {
+               MonoClass *klass;
+               int i;
+
+               klass = mono_defaults.real_proxy_class; 
+                      
+               for (i = 0; i < klass->method.count; ++i) {
+                       if (!strcmp ("PrivateInvoke", klass->methods [i]->name) &&
+                           klass->methods [i]->signature->param_count == 4) {
+                               im = klass->methods [i];
+                               break;
+                       }
+               }
+       
+               g_assert (im);
+       }
+
+       pa [0] = real_proxy;
+       pa [1] = msg;
+       pa [2] = exc;
+       pa [3] = out_args;
+
+       return mono_runtime_invoke (im, NULL, pa);
+}
+
+MonoObject *
+mono_message_invoke (MonoObject *target, MonoMethodMessage *msg, 
+                    MonoObject **exc, MonoArray **out_args) 
+{
+       if (target && target->vtable->klass == mono_defaults.transparent_proxy_class) {
+
+               return mono_remoting_invoke ((MonoObject *)((MonoTransparentProxy *)target)->rp, 
+                                            msg, exc, out_args);
+
+       } else {
+               MonoDomain *domain = mono_domain_get (); 
+               MonoMethod *method = msg->method->method;
+               MonoMethodSignature *sig = method->signature;
+               int i, j, outarg_count = 0;
+
+               for (i = 0; i < sig->param_count; i++) {
+                       if (sig->params [i]->byref) 
+                               outarg_count++;
+               }
+
+               *out_args = mono_array_new (domain, mono_defaults.object_class, outarg_count);
+               *exc = NULL;
+
+               for (i = 0, j = 0; i < sig->param_count; i++) {
+                       if (sig->params [i]->byref) {
+                               gpointer arg;
+                               arg = mono_array_get (msg->args, gpointer, i);
+                               mono_array_set (*out_args, gpointer, j, arg);
+                               j++;
+                       }
+               }
+
+               return mono_runtime_invoke_array (method, target, msg->args);
+       }
+}
+
+
+