*
* Author:
* Miguel de Icaza (miguel@ximian.com)
+ * Paolo Molaro (lupus@ximian.com)
*
- * (C) 2001 Ximian, Inc.
+ * (C) 2001-2004 Ximian, Inc.
*/
#include <config.h>
#include <stdlib.h>
#include <mono/metadata/environment.h>
#include "mono/metadata/profiler-private.h"
#include <mono/os/gc_wrapper.h>
+#include <mono/utils/strenc.h>
-/*
- * enable to get a good speedup: we still need to figure out
- * how the sync structure is freed.
+/*
+ * Enable experimental typed allocation using the GC_gcj_malloc function.
*/
-#define CREATION_SPEEDUP 0
+#ifdef HAVE_GC_GCJ_MALLOC
+#define CREATION_SPEEDUP 1
+#endif
void
mono_runtime_object_init (MonoObject *this)
mono_runtime_invoke (method, this, NULL, NULL);
}
+/* The pseudo algorithm for type initialization from the spec
+Note it doesn't say anything about domains - only threads.
+
+2. If the type is initialized you are done.
+2.1. If the type is not yet initialized, try to take an
+ initialization lock.
+2.2. If successful, record this thread as responsible for
+ initializing the type and proceed to step 2.3.
+2.2.1. If not, see whether this thread or any thread
+ waiting for this thread to complete already holds the lock.
+2.2.2. If so, return since blocking would create a deadlock. This thread
+ will now see an incompletely initialized state for the type,
+ but no deadlock will arise.
+2.2.3 If not, block until the type is initialized then return.
+2.3 Initialize the parent type and then all interfaces implemented
+ by this type.
+2.4 Execute the type initialization code for this type.
+2.5 Mark the type as initialized, release the initialization lock,
+ awaken any threads waiting for this type to be initialized,
+ and return.
+
+*/
+
+typedef struct
+{
+ guint32 initializing_tid;
+ guint32 waiting_count;
+ CRITICAL_SECTION initialization_section;
+} TypeInitializationLock;
+
+/* for locking access to type_initialization_hash and blocked_thread_hash */
+static CRITICAL_SECTION type_initialization_section;
+
+/* from vtable to lock */
+static GHashTable *type_initialization_hash;
+
+/* from thread id to thread id being waited on */
+static GHashTable *blocked_thread_hash;
+
+/* Main thread */
+static MonoThread *main_thread;
+
+void
+mono_type_initialization_init (void)
+{
+ InitializeCriticalSection (&type_initialization_section);
+ type_initialization_hash = g_hash_table_new (NULL, NULL);
+ blocked_thread_hash = g_hash_table_new (NULL, NULL);
+}
+
/*
* mono_runtime_class_init:
- * @klass: klass that needs to be initialized
+ * @vtable: vtable that needs to be initialized
*
- * This routine calls the class constructor for @class.
+ * This routine calls the class constructor for @vtable.
*/
void
-mono_runtime_class_init (MonoClass *klass)
+mono_runtime_class_init (MonoVTable *vtable)
{
int i;
- MonoException *exc = NULL;
+ MonoException *exc;
MonoException *exc_to_throw;
- MonoMethod *method;
+ MonoMethod *method = NULL;
+ MonoClass *klass;
gchar *full_name;
+ gboolean found;
+
+ MONO_ARCH_SAVE_REGS;
+
+ if (vtable->initialized)
+ return;
+
+ exc = NULL;
+ found = FALSE;
+ klass = vtable->klass;
for (i = 0; i < klass->method.count; ++i) {
method = klass->methods [i];
if ((method->flags & METHOD_ATTRIBUTE_SPECIAL_NAME) &&
(strcmp (".cctor", method->name) == 0)) {
- mono_runtime_invoke (method, NULL, NULL, (MonoObject **) &exc);
- if (exc != NULL)
- break;
+ found = TRUE;
+ break;
+ }
+ }
+
+ if (found) {
+ MonoDomain *domain = vtable->domain;
+ TypeInitializationLock *lock;
+ guint32 tid = GetCurrentThreadId();
+ int do_initialization = 0;
+ MonoDomain *last_domain = NULL;
+
+ EnterCriticalSection (&type_initialization_section);
+ /* double check... */
+ if (vtable->initialized) {
+ LeaveCriticalSection (&type_initialization_section);
return;
}
+ lock = g_hash_table_lookup (type_initialization_hash, vtable);
+ if (lock == NULL) {
+ /* This thread will get to do the initialization */
+ if (mono_domain_get () != domain) {
+ /* Transfer into the target domain */
+ last_domain = mono_domain_get ();
+ if (!mono_domain_set (domain, FALSE)) {
+ vtable->initialized = 1;
+ LeaveCriticalSection (&type_initialization_section);
+ mono_raise_exception (mono_get_exception_appdomain_unloaded ());
+ }
+ }
+ lock = g_malloc (sizeof(TypeInitializationLock));
+ InitializeCriticalSection (&lock->initialization_section);
+ lock->initializing_tid = tid;
+ lock->waiting_count = 1;
+ /* grab the vtable lock while this thread still owns type_initialization_section */
+ EnterCriticalSection (&lock->initialization_section);
+ g_hash_table_insert (type_initialization_hash, vtable, lock);
+ do_initialization = 1;
+ } else {
+ gpointer blocked;
+
+ if (lock->initializing_tid == tid) {
+ LeaveCriticalSection (&type_initialization_section);
+ return;
+ }
+ /* see if the thread doing the initialization is already blocked on this thread */
+ blocked = GUINT_TO_POINTER (lock->initializing_tid);
+ while ((blocked = g_hash_table_lookup (blocked_thread_hash, blocked))) {
+ if (blocked == GUINT_TO_POINTER (tid)) {
+ LeaveCriticalSection (&type_initialization_section);
+ return;
+ }
+ }
+ ++lock->waiting_count;
+ /* record the fact that we are waiting on the initializing thread */
+ g_hash_table_insert (blocked_thread_hash, GUINT_TO_POINTER (tid), GUINT_TO_POINTER (lock->initializing_tid));
+ }
+ LeaveCriticalSection (&type_initialization_section);
+
+ if (do_initialization) {
+ mono_runtime_invoke (method, NULL, NULL, (MonoObject **) &exc);
+ if (last_domain)
+ mono_domain_set (last_domain, TRUE);
+ LeaveCriticalSection (&lock->initialization_section);
+ } else {
+ /* this just blocks until the initializing thread is done */
+ EnterCriticalSection (&lock->initialization_section);
+ LeaveCriticalSection (&lock->initialization_section);
+ }
+
+ EnterCriticalSection (&type_initialization_section);
+ if (lock->initializing_tid != tid)
+ g_hash_table_remove (blocked_thread_hash, GUINT_TO_POINTER (tid));
+ --lock->waiting_count;
+ if (lock->waiting_count == 0) {
+ DeleteCriticalSection (&lock->initialization_section);
+ g_hash_table_remove (type_initialization_hash, vtable);
+ g_free (lock);
+ }
+ vtable->initialized = 1;
+ /* FIXME: if the cctor fails, the type must be marked as unusable */
+ LeaveCriticalSection (&type_initialization_section);
+ } else {
+ vtable->initialized = 1;
+ return;
}
if (exc == NULL ||
}
#endif
+#if CREATION_SPEEDUP
+
+#define GC_NO_DESCRIPTOR ((gpointer)(0 | GC_DS_LENGTH))
+
+/*
+ * The vtables in the root appdomain are assumed to be reachable by other
+ * roots, and we don't use typed allocation in the other domains.
+ */
+
+#define GC_HEADER_BITMAP (1 << (G_STRUCT_OFFSET (MonoObject,synchronisation) / sizeof(gpointer)))
+
+static void
+mono_class_compute_gc_descriptor (MonoClass *class)
+{
+ MonoClassField *field;
+ guint64 bitmap;
+ guint32 bm [2];
+ int i;
+ static gboolean gcj_inited = FALSE;
+
+ if (!gcj_inited) {
+ gcj_inited = TRUE;
+
+ GC_init_gcj_malloc (5, NULL);
+ }
+
+ if (!class->inited)
+ mono_class_init (class);
+
+ if (class->gc_descr_inited)
+ return;
+
+ class->gc_descr_inited = TRUE;
+ class->gc_descr = GC_NO_DESCRIPTOR;
+
+ if (class == mono_defaults.string_class) {
+ bitmap = GC_HEADER_BITMAP;
+ class->gc_descr = (gpointer)GC_make_descriptor ((GC_bitmap)&bitmap, 2);
+ }
+ else if (class->rank) {
+ mono_class_compute_gc_descriptor (class->element_class);
+
+ if (class->element_class->valuetype && (class->element_class->gc_descr != GC_NO_DESCRIPTOR) && (class->element_class->gc_bitmap == GC_HEADER_BITMAP)) {
+ bitmap = GC_HEADER_BITMAP;
+ if (class->rank > 1)
+ bitmap += 1 << (G_STRUCT_OFFSET (MonoArray,bounds) / sizeof(gpointer));
+ class->gc_descr = (gpointer)GC_make_descriptor ((GC_bitmap)&bitmap, 3);
+ }
+ }
+ else {
+ static int count = 0;
+ MonoClass *p;
+ guint32 pos;
+
+ /* GC 6.1 has trouble handling 64 bit descriptors... */
+ if ((class->instance_size / sizeof (gpointer)) > 30) {
+// printf ("TOO LARGE: %s %d.\n", class->name, class->instance_size / sizeof (gpointer));
+ return;
+ }
+
+ bitmap = GC_HEADER_BITMAP;
+
+ count ++;
+
+// if (count > 442)
+// return;
+
+// printf("KLASS: %s.\n", class->name);
+
+ for (p = class; p != NULL; p = p->parent) {
+ for (i = 0; i < p->field.count; ++i) {
+ field = &p->fields [i];
+ if (field->type->attrs & FIELD_ATTRIBUTE_STATIC)
+ continue;
+ if (field->type->attrs & FIELD_ATTRIBUTE_HAS_FIELD_RVA)
+ return;
+
+ pos = field->offset / sizeof (gpointer);
+
+ if (field->type->byref)
+ return;
+
+ switch (field->type->type) {
+ case MONO_TYPE_BOOLEAN:
+ case MONO_TYPE_I1:
+ case MONO_TYPE_U1:
+ case MONO_TYPE_I2:
+ case MONO_TYPE_U2:
+ case MONO_TYPE_CHAR:
+ case MONO_TYPE_I4:
+ case MONO_TYPE_U4:
+ case MONO_TYPE_I8:
+ case MONO_TYPE_U8:
+ case MONO_TYPE_R4:
+ case MONO_TYPE_R8:
+// printf ("F: %s %s %d %lld %llx.\n", class->name, field->name, field->offset, ((guint64)1) << pos, bitmap);
+ break;
+ case MONO_TYPE_I:
+ case MONO_TYPE_STRING:
+ case MONO_TYPE_SZARRAY:
+ case MONO_TYPE_CLASS:
+ case MONO_TYPE_OBJECT:
+ case MONO_TYPE_ARRAY:
+ case MONO_TYPE_PTR:
+ g_assert ((field->offset % sizeof(gpointer)) == 0);
+
+ bitmap |= ((guint64)1) << pos;
+// printf ("F: %s %s %d %d %lld %llx.\n", class->name, field->name, field->offset, pos, ((guint64)(1)) << pos, bitmap);
+ break;
+ case MONO_TYPE_VALUETYPE: {
+ MonoClass *fclass = field->type->data.klass;
+ if (!fclass->enumtype) {
+ mono_class_compute_gc_descriptor (fclass);
+ bitmap |= (fclass->gc_bitmap >> (sizeof (MonoObject) / sizeof (gpointer))) << pos;
+ }
+ break;
+ }
+ default:
+ return;
+ }
+ }
+ }
+
+// printf("CLASS: %s.%s -> %d %llx.\n", class->name_space, class->name, class->instance_size / sizeof (gpointer), bitmap);
+ class->gc_bitmap = bitmap;
+ /* Convert to the format expected by GC_make_descriptor */
+ bm [0] = (guint32)bitmap;
+ bm [1] = (guint32)(bitmap >> 32);
+ class->gc_descr = (gpointer)GC_make_descriptor ((GC_bitmap)&bm, class->instance_size / sizeof (gpointer));
+ }
+}
+#endif /* CREATION_SPEEDUP */
+
+/**
+ * field_is_special_static:
+ *
+ * Returns SPECIAL_STATIC_THREAD if the field is thread static, SPECIAL_STATIC_CONTEXT if it is context static,
+ * SPECIAL_STATIC_NONE otherwise.
+ */
+static gint32
+field_is_special_static (MonoClass *fklass, MonoClassField *field)
+{
+ MonoCustomAttrInfo *ainfo;
+ int i;
+ ainfo = mono_custom_attrs_from_field (fklass, field);
+ if (!ainfo)
+ return FALSE;
+ for (i = 0; i < ainfo->num_attrs; ++i) {
+ MonoClass *klass = ainfo->attrs [i].ctor->klass;
+ if (klass->image == mono_defaults.corlib) {
+ if (strcmp (klass->name, "ThreadStaticAttribute") == 0) {
+ mono_custom_attrs_free (ainfo);
+ return SPECIAL_STATIC_THREAD;
+ }
+ else if (strcmp (klass->name, "ContextStaticAttribute") == 0) {
+ mono_custom_attrs_free (ainfo);
+ return SPECIAL_STATIC_CONTEXT;
+ }
+ }
+ }
+ mono_custom_attrs_free (ainfo);
+ return SPECIAL_STATIC_NONE;
+}
+
/**
* mono_class_vtable:
* @domain: the application domain
MonoVTable *
mono_class_vtable (MonoDomain *domain, MonoClass *class)
{
- MonoClass *k;
- MonoVTable *vt;
+ MonoVTable *vt = NULL;
MonoClassField *field;
- guint32 cindex;
- guint32 cols [MONO_CONSTANT_SIZE];
const char *p;
char *t;
int i, len;
+ guint32 vtable_size;
+ guint32 cindex;
+ guint32 constant_cols [MONO_CONSTANT_SIZE];
g_assert (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));
+ vtable_size = sizeof (MonoVTable) + class->vtable_size * sizeof (gpointer);
+
+ vt = mono_mempool_alloc0 (domain->mp, vtable_size);
+
vt->klass = class;
vt->domain = domain;
+#if CREATION_SPEEDUP
+ mono_class_compute_gc_descriptor (class);
+ if (domain != mono_root_domain)
+ /*
+ * We can't use typed allocation in the non-root domains, since the
+ * collector needs the GC descriptor stored in the vtable even after
+ * the mempool containing the vtable is destroyed when the domain is
+ * unloaded. An alternative might be to allocate vtables in the GC
+ * heap, but this does not seem to work (it leads to crashes inside
+ * libgc). If that approach is tried, two gc descriptors need to be
+ * allocated for each class: one for the root domain, and one for all
+ * other domains. The second descriptor should contain a bit for the
+ * vtable field in MonoObject, since we can no longer assume the
+ * vtable is reachable by other roots after the appdomain is unloaded.
+ */
+ vt->gc_descr = GC_NO_DESCRIPTOR;
+ else
+ vt->gc_descr = class->gc_descr;
+#endif
+
if (class->class_size) {
#if HAVE_BOEHM_GC
vt->data = GC_MALLOC (class->class_size + 8);
mono_stats.class_static_data_size += class->class_size + 8;
}
+ cindex = -1;
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 (mono_field_is_deleted (field))
+ continue;
+ if (!(field->type->attrs & FIELD_ATTRIBUTE_LITERAL)) {
+ gint32 special_static = field_is_special_static (class, field);
+ if (special_static != SPECIAL_STATIC_NONE) {
+ guint32 size, align, offset;
+ size = mono_type_size (field->type, &align);
+ offset = mono_alloc_special_static_data (special_static, size, align);
+ if (!domain->special_static_fields)
+ domain->special_static_fields = g_hash_table_new (NULL, NULL);
+ g_hash_table_insert (domain->special_static_fields, field, GUINT_TO_POINTER (offset));
+ continue;
+ }
+ }
if ((field->type->attrs & FIELD_ATTRIBUTE_HAS_FIELD_RVA)) {
MonoClass *fklass = mono_class_from_mono_type (field->type);
t = (char*)vt->data + field->offset;
} else {
/* it's a pointer type: add check */
g_assert (fklass->byval_arg.type == MONO_TYPE_PTR);
- *t = *(gpointer*)field->data;
+ *t = *(char *)field->data;
}
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;
+
+ if (!field->def_value) {
+ cindex = mono_metadata_get_constant_index (class->image, MONO_TOKEN_FIELD_DEF | (i + 1), cindex + 1);
+ g_assert (cindex);
+
+ mono_metadata_decode_row (&class->image->tables [MONO_TABLE_CONSTANT], cindex - 1, constant_cols, MONO_CONSTANT_SIZE);
+ field->def_value = g_new0 (MonoConstant, 1);
+ field->def_value->type = constant_cols [MONO_CONSTANT_TYPE];
+ field->def_value->value = (gpointer)mono_metadata_blob_heap (class->image, constant_cols [MONO_CONSTANT_VALUE]);
}
- 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]);
+
+ p = field->def_value->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]) {
+ switch (field->def_value->type) {
case MONO_TYPE_BOOLEAN:
case MONO_TYPE_U1:
case MONO_TYPE_I1:
/* 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]);
+ g_warning ("type 0x%02x should not be in constant table", field->def_value->type);
}
}
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];
- }
+ for (i = 0; i <= class->max_interface_id; ++i) {
+ int slot = class->interface_offsets [i];
+ if (slot >= 0)
+ vt->interface_offsets [i] = &(vt->vtable [slot]);
}
/*
if (class->parent)
mono_class_vtable (domain, class->parent);
- mono_runtime_class_init (class);
-
+ vt->type = mono_type_get_object (domain, &class->byval_arg);
+ if (class->contextbound)
+ vt->remote = 1;
+ else
+ vt->remote = 0;
+
return vt;
}
/**
* mono_class_proxy_vtable:
* @domain: the application domain
- * @class: the class to proxy
+ * @remove_class: the remote class
*
* 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.
+ * a copy of the real vtable of the class wrapped in @remote_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)
+static MonoVTable *
+mono_class_proxy_vtable (MonoDomain *domain, MonoRemoteClass *remote_class)
{
MonoVTable *vt, *pvt;
- int i, vtsize;
-
- if ((pvt = mono_g_hash_table_lookup (domain->proxy_vtable_hash, class)))
- return pvt;
+ int i, j, vtsize, max_interface_id, extra_interface_vtsize = 0;
+ MonoClass *k;
+ MonoClass *class = remote_class->proxy_class;
vt = mono_class_vtable (domain, class);
+ max_interface_id = vt->max_interface_id;
+
+ /* Calculate vtable space for extra interfaces */
+ for (j = 0; j < remote_class->interface_count; j++) {
+ MonoClass* iclass = remote_class->interfaces[j];
+ int method_count = iclass->method.count;
+
+ if (iclass->interface_id <= class->max_interface_id && class->interface_offsets[iclass->interface_id] != 0)
+ continue; /* interface implemented by the class */
+
+ for (i = 0; i < iclass->interface_count; i++)
+ method_count += iclass->interfaces[i]->method.count;
+
+ extra_interface_vtsize += method_count * sizeof (gpointer);
+ if (iclass->max_interface_id > max_interface_id) max_interface_id = iclass->max_interface_id;
+ }
+
vtsize = sizeof (MonoVTable) + class->vtable_size * sizeof (gpointer);
- mono_stats.class_vtable_size += vtsize;
+ mono_stats.class_vtable_size += vtsize + extra_interface_vtsize;
- pvt = mono_mempool_alloc (domain->mp, vtsize);
+ pvt = mono_mempool_alloc (domain->mp, vtsize + extra_interface_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);
+ if (class->flags & TYPE_ATTRIBUTE_ABSTRACT)
+ {
+ /* create trampolines for abstract methods */
+ for (k = class; k; k = k->parent) {
+ for (i = 0; i < k->method.count; i++) {
+ int slot = k->methods [i]->slot;
+ if (!pvt->vtable [slot])
+ pvt->vtable [slot] = arch_create_remoting_trampoline (k->methods[i]);
+ }
+ }
+ }
+
+ pvt->max_interface_id = max_interface_id;
+ pvt->interface_offsets = mono_mempool_alloc0 (domain->mp,
+ sizeof (gpointer) * (max_interface_id + 1));
+
+ /* initialize interface offsets */
+ for (i = 0; i <= class->max_interface_id; ++i) {
+ int slot = class->interface_offsets [i];
+ if (slot >= 0)
+ pvt->interface_offsets [i] = &(pvt->vtable [slot]);
+ }
+
+ if (remote_class->interface_count > 0)
+ {
+ int slot = class->vtable_size;
+ MonoClass* interf;
+ MonoClass* iclass;
+ int n;
+
+ /* Create trampolines for the methods of the interfaces */
+ for (n = 0; n < remote_class->interface_count; n++)
+ {
+ iclass = remote_class->interfaces[n];
+ if (iclass->interface_id <= class->max_interface_id && class->interface_offsets[iclass->interface_id] != 0)
+ continue; /* interface implemented by the class */
+
+ i = -1;
+ interf = iclass;
+ do {
+ pvt->interface_offsets [interf->interface_id] = &pvt->vtable [slot];
+
+ for (j = 0; j < interf->method.count; ++j) {
+ MonoMethod *cm = interf->methods [j];
+ pvt->vtable [slot + j] = arch_create_remoting_trampoline (cm);
+ }
+ slot += interf->method.count;
+ if (++i < iclass->interface_count) interf = iclass->interfaces[i];
+ else interf = NULL;
+
+ } while (interf);
+ }
+ }
return pvt;
}
+/**
+ * mono_remote_class:
+ * @domain: the application domain
+ * @class_name: name of the remote class
+ *
+ * Creates and initializes a MonoRemoteClass object for a remote type.
+ *
+ */
+MonoRemoteClass*
+mono_remote_class (MonoDomain *domain, MonoString *class_name, MonoClass *proxy_class)
+{
+ MonoRemoteClass *rc;
+
+ mono_domain_lock (domain);
+ rc = mono_g_hash_table_lookup (domain->proxy_vtable_hash, class_name);
+
+ if (rc) {
+ mono_domain_unlock (domain);
+ return rc;
+ }
+
+ rc = mono_mempool_alloc (domain->mp, sizeof(MonoRemoteClass));
+ rc->vtable = NULL;
+ rc->interface_count = 0;
+ rc->interfaces = NULL;
+ rc->proxy_class = mono_defaults.marshalbyrefobject_class;
+ rc->proxy_class_name = mono_string_to_utf8 (class_name);
+
+ mono_g_hash_table_insert (domain->proxy_vtable_hash, class_name, rc);
+ mono_upgrade_remote_class (domain, rc, proxy_class);
+
+ if (rc->vtable == NULL)
+ rc->vtable = mono_class_proxy_vtable (domain, rc);
+
+ mono_domain_unlock (domain);
+
+ return rc;
+}
+
+static void
+extend_interface_array (MonoDomain *domain, MonoRemoteClass *remote_class, int amount)
+{
+ /* Extends the array of interfaces. Memory is extended using blocks of 5 pointers */
+
+ int current_size = ((remote_class->interface_count / 5) + 1) * 5;
+ remote_class->interface_count += amount;
+
+ if (remote_class->interface_count > current_size || remote_class->interfaces == NULL)
+ {
+ int new_size = ((remote_class->interface_count / 5) + 1) * 5;
+ MonoClass **new_array = mono_mempool_alloc (domain->mp, new_size * sizeof (MonoClass*));
+
+ if (remote_class->interfaces != NULL)
+ memcpy (new_array, remote_class->interfaces, current_size * sizeof (MonoClass*));
+
+ remote_class->interfaces = new_array;
+ }
+}
+
+
+/**
+ * mono_upgrade_remote_class:
+ * @domain: the application domain
+ * @remote_class: the remote class
+ * @klass: class to which the remote class can be casted.
+ *
+ * Updates the vtable of the remote class by adding the necessary method slots
+ * and interface offsets so it can be safely casted to klass. klass can be a
+ * class or an interface.
+ */
+void mono_upgrade_remote_class (MonoDomain *domain, MonoRemoteClass *remote_class, MonoClass *klass)
+{
+ gboolean redo_vtable;
+
+ mono_domain_lock (domain);
+
+ if (klass->flags & TYPE_ATTRIBUTE_INTERFACE) {
+ int i;
+ redo_vtable = TRUE;
+ for (i = 0; i < remote_class->interface_count; i++)
+ if (remote_class->interfaces[i] == klass) redo_vtable = FALSE;
+
+ if (redo_vtable) {
+ extend_interface_array (domain, remote_class, 1);
+ remote_class->interfaces [remote_class->interface_count-1] = klass;
+ }
+ }
+ else {
+ redo_vtable = (remote_class->proxy_class != klass);
+ remote_class->proxy_class = klass;
+ }
+
+ if (redo_vtable)
+ remote_class->vtable = mono_class_proxy_vtable (domain, remote_class);
+/*
+ int n;
+ printf ("remote class upgrade - class:%s num-interfaces:%d\n", remote_class->proxy_class_name, remote_class->interface_count);
+
+ for (n=0; n<remote_class->interface_count; n++)
+ printf (" I:%s\n", remote_class->interfaces[n]->name);
+*/
+
+ mono_domain_unlock (domain);
+}
+
/*
* Retrieve the MonoMethod that would to be called on obj if obj is passed as
* the instance of a callvirt of method.
MonoClass *klass;
MonoMethod **vtable;
gboolean is_proxy;
- MonoMethod *res;
-
- if ((method->flags & METHOD_ATTRIBUTE_FINAL) || !(method->flags & METHOD_ATTRIBUTE_VIRTUAL))
- return method;
+ MonoMethod *res = NULL;
klass = mono_object_class (obj);
if (klass == mono_defaults.transparent_proxy_class) {
- klass = ((MonoTransparentProxy *)obj)->klass;
+ klass = ((MonoTransparentProxy *)obj)->remote_class->proxy_class;
is_proxy = TRUE;
} else {
is_proxy = FALSE;
}
+
+ if (!is_proxy && ((method->flags & METHOD_ATTRIBUTE_FINAL) || !(method->flags & METHOD_ATTRIBUTE_VIRTUAL)))
+ return method;
+
vtable = klass->vtable;
+ /* check method->slot is a valid index: perform isinstance? */
if (method->klass->flags & TYPE_ATTRIBUTE_INTERFACE) {
- res = vtable [method->klass->interface_id + method->slot];
+ if (!is_proxy)
+ res = vtable [klass->interface_offsets [method->klass->interface_id] + method->slot];
} else {
- res = vtable [method->slot];
+ if (method->slot != -1)
+ res = vtable [method->slot];
+ }
+
+ if (is_proxy) {
+ if (!res) res = method; /* It may be an interface or abstract class method */
+ res = mono_marshal_get_remoting_invoke (res);
}
- g_assert (res);
- if (is_proxy)
- return mono_marshal_get_remoting_invoke (res);
+ g_assert (res);
return res;
}
set_value (field->type, value, src, TRUE);
}
+MonoObject *
+mono_field_get_value_object (MonoDomain *domain, MonoClassField *field, MonoObject *obj)
+{
+ MonoObject *o;
+ MonoClass *klass;
+ MonoVTable *vtable = NULL;
+ gchar *v;
+ gboolean is_static = FALSE;
+ gboolean is_ref = FALSE;
+
+ switch (field->type->type) {
+ case MONO_TYPE_STRING:
+ case MONO_TYPE_OBJECT:
+ case MONO_TYPE_CLASS:
+ case MONO_TYPE_ARRAY:
+ case MONO_TYPE_SZARRAY:
+ is_ref = TRUE;
+ break;
+ 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_R4:
+ case MONO_TYPE_U8:
+ case MONO_TYPE_I8:
+ case MONO_TYPE_R8:
+ case MONO_TYPE_VALUETYPE:
+ is_ref = field->type->byref;
+ break;
+ default:
+ g_error ("type 0x%x not handled in "
+ "mono_field_get_value_object", field->type->type);
+ return NULL;
+ }
+
+ if (field->type->attrs & FIELD_ATTRIBUTE_STATIC) {
+ is_static = TRUE;
+ vtable = mono_class_vtable (domain, field->parent);
+ if (!vtable->initialized)
+ mono_runtime_class_init (vtable);
+ }
+
+ if (is_ref) {
+ if (is_static) {
+ mono_field_static_get_value (vtable, field, &o);
+ } else {
+ mono_field_get_value (obj, field, &o);
+ }
+ return o;
+ }
+
+ /* boxed value type */
+ klass = mono_class_from_mono_type (field->type);
+ o = mono_object_new (domain, klass);
+ v = ((gchar *) o) + sizeof (MonoObject);
+ if (is_static) {
+ mono_field_static_get_value (vtable, field, v);
+ } else {
+ mono_field_get_value (obj, field, v);
+ }
+
+ return o;
+}
+
+
void
mono_field_static_get_value (MonoVTable *vt, MonoClassField *field, void *value)
{
return main_args;
}
+static void
+fire_process_exit_event (void)
+{
+ MonoClassField *field;
+ MonoDomain *domain = mono_domain_get ();
+ gpointer pa [2];
+ MonoObject *delegate, *exc;
+
+ field = mono_class_get_field_from_name (mono_defaults.appdomain_class, "ProcessExit");
+ g_assert (field);
+
+ if (domain != mono_root_domain)
+ return;
+
+ delegate = *(MonoObject **)(((char *)domain->domain) + field->offset);
+ if (delegate == NULL)
+ return;
+
+ pa [0] = domain;
+ pa [1] = NULL;
+ mono_runtime_delegate_invoke (delegate, pa, &exc);
+}
+
/*
* Execute a standard Main() method (argc/argv contains the
* executable name). This method also sets the command line argument value
int i;
MonoArray *args = NULL;
MonoDomain *domain = mono_domain_get ();
+ gchar *utf8_fullpath;
+ int result;
+
+ main_thread = mono_thread_current ();
main_args = (MonoArray*)mono_array_new (domain, mono_defaults.string_class, argc);
- for (i = 0; i < argc; ++i) {
- MonoString *arg = mono_string_new (domain, argv [i]);
+
+ if (!g_path_is_absolute (argv [0])) {
+ gchar *basename = g_path_get_basename (argv [0]);
+ gchar *fullpath = g_build_filename (method->klass->image->assembly->basedir,
+ basename,
+ NULL);
+
+ utf8_fullpath = mono_utf8_from_external (fullpath);
+ if(utf8_fullpath == NULL) {
+ /* Printing the arg text will cause glib to
+ * whinge about "Invalid UTF-8", but at least
+ * its relevant, and shows the problem text
+ * string.
+ */
+ g_print ("\nCannot determine the text encoding for the assembly location: %s\n", fullpath);
+ g_print ("Please add the correct encoding to MONO_EXTERNAL_ENCODINGS and try again.\n");
+ exit (-1);
+ }
+
+ g_free (fullpath);
+ g_free (basename);
+ } else {
+ utf8_fullpath = mono_utf8_from_external (argv[0]);
+ if(utf8_fullpath == NULL) {
+ g_print ("\nCannot determine the text encoding for the assembly location: %s\n", argv[0]);
+ g_print ("Please add the correct encoding to MONO_EXTERNAL_ENCODINGS and try again.\n");
+ exit (-1);
+ }
+ }
+
+ mono_array_set (main_args, gpointer, 0, mono_string_new (domain, utf8_fullpath));
+ g_free (utf8_fullpath);
+
+ for (i = 1; i < argc; ++i) {
+ gchar *utf8_arg;
+ MonoString *arg;
+
+ utf8_arg=mono_utf8_from_external (argv[i]);
+ if(utf8_arg==NULL) {
+ /* Ditto the comment about Invalid UTF-8 here */
+ g_print ("\nCannot determine the text encoding for argument %d (%s).\n", i, argv[i]);
+ g_print ("Please add the correct encoding to MONO_EXTERNAL_ENCODINGS and try again.\n");
+ exit (-1);
+ }
+
+ arg = mono_string_new (domain, utf8_arg);
mono_array_set (main_args, gpointer, i, arg);
}
argc--;
if (method->signature->param_count) {
args = (MonoArray*)mono_array_new (domain, mono_defaults.string_class, argc);
for (i = 0; i < argc; ++i) {
- MonoString *arg = mono_string_new (domain, argv [i]);
+ /* The encodings should all work, given that
+ * we've checked all these args for the
+ * main_args array.
+ */
+ MonoString *arg = mono_string_new (domain, mono_utf8_from_external (argv [i]));
mono_array_set (args, gpointer, i, arg);
}
} else {
mono_assembly_set_main (method->klass->image->assembly);
- return mono_runtime_exec_main (method, args, exc);
+ result = mono_runtime_exec_main (method, args, exc);
+ fire_process_exit_event ();
+ return result;
+}
+
+/* Used in mono_unhandled_exception */
+static MonoObject *
+create_unhandled_exception_eventargs (MonoObject *exc)
+{
+ MonoClass *klass;
+ gpointer args [2];
+ MonoMethod *method = NULL;
+ MonoBoolean is_terminating = TRUE;
+ MonoObject *obj;
+ gint i;
+
+ klass = mono_class_from_name (mono_defaults.corlib, "System", "UnhandledExceptionEventArgs");
+ g_assert (klass);
+
+ mono_class_init (klass);
+
+ /* UnhandledExceptionEventArgs only has 1 public ctor with 2 args */
+ for (i = 0; i < klass->method.count; ++i) {
+ method = klass->methods [i];
+ if (!strcmp (".ctor", method->name) &&
+ method->signature->param_count == 2 &&
+ method->flags & METHOD_ATTRIBUTE_PUBLIC)
+ break;
+ method = NULL;
+ }
+
+ g_assert (method);
+
+ args [0] = exc;
+ args [1] = &is_terminating;
+
+ obj = mono_object_new (mono_domain_get (), klass);
+ mono_runtime_invoke (method, obj, args, NULL);
+
+ return obj;
}
/*
- * We call this function when we dectect an unhandled exception. It invokes the
- * UnhandledException event in AppDomain or print a warning to the console
+ * We call this function when we detect an unhandled exception
+ * in the default domain.
+ * It invokes the * UnhandledException event in AppDomain or prints
+ * a warning to the console
*/
void
mono_unhandled_exception (MonoObject *exc)
if (exc->vtable->klass != mono_defaults.threadabortexception_class) {
delegate = *(MonoObject **)(((char *)domain->domain) + field->offset);
- if (!delegate) {
+ /* set exitcode only in the main thread */
+ if (mono_thread_current () == main_thread)
+ mono_environment_exitcode_set (1);
+ if (domain != mono_root_domain || !delegate) {
mono_print_unhandled_exception (exc);
} else {
MonoObject *e = NULL;
gpointer pa [2];
- /* fixme: pass useful arguments */
- pa [0] = NULL;
- pa [1] = NULL;
+ pa [0] = domain->domain;
+ pa [1] = create_unhandled_exception_eventargs (exc);
mono_runtime_delegate_invoke (delegate, pa, &e);
- if (e)
- g_warning ("exception inside UnhandledException handler!");
+ if (e) {
+ gchar *msg = mono_string_to_utf8 (((MonoException *) e)->message);
+ g_warning ("exception inside UnhandledException handler: %s\n", msg);
+ g_free (msg);
+ }
}
}
}
{
MonoDomain *domain;
gpointer pa [1];
- MonoObject *res;
int rval;
g_assert (args);
domain = mono_object_domain (args);
if (!domain->entry_assembly) {
+ gchar *str;
+ gchar *config_suffix;
+
domain->entry_assembly = method->klass->image->assembly;
ves_icall_System_AppDomainSetup_InitAppDomainSetup (domain->setup);
+ config_suffix = g_strconcat (domain->entry_assembly->aname.name, ".exe.config", NULL);
+ str = g_build_filename (domain->entry_assembly->basedir, config_suffix, NULL);
+ g_free (config_suffix);
+ domain->setup->configuration_file = mono_string_new (domain, str);
+ g_free (str);
}
/* FIXME: check signature of method */
case MONO_TYPE_R4:
case MONO_TYPE_R8:
case MONO_TYPE_VALUETYPE:
+ g_assert (((gpointer*)params->vector) [i]);
pa [i] = (char *)(((gpointer *)params->vector)[i]) + sizeof (MonoObject);
break;
case MONO_TYPE_STRING:
case MONO_TYPE_CLASS:
case MONO_TYPE_ARRAY:
case MONO_TYPE_SZARRAY:
- pa [i] = (char *)(((gpointer *)params->vector)[i]);
+ if (sig->params [i]->byref)
+ pa [i] = &(((gpointer *)params->vector)[i]);
+ else
+ 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") && method->klass != mono_defaults.string_class) {
- if (!obj)
+ if (!obj) {
obj = mono_object_new (mono_domain_get (), method->klass);
+ if (mono_object_class(obj) == mono_defaults.transparent_proxy_class) {
+ method = mono_marshal_get_remoting_invoke (method->slot == -1 ? method : method->klass->vtable [method->slot]);
+ }
+ }
mono_runtime_invoke (method, obj, pa, exc);
return obj;
} else
return mono_runtime_invoke (method, obj, pa, exc);
}
+static void
+out_of_memory (size_t size)
+{
+ /*
+ * we could allocate at program startup some memory that we could release
+ * back to the system at this point if we're really low on memory (ie, size is
+ * lower than the memory we set apart)
+ */
+ mono_raise_exception (mono_domain_get ()->out_of_memory_ex);
+}
+
/**
* mono_object_allocate:
* @size: number of bytes to allocate
*
* Returns: an allocated object of size @size, or NULL on failure.
*/
-void *
+static inline void *
mono_object_allocate (size_t size)
{
#if HAVE_BOEHM_GC
#else
void *o = calloc (1, size);
#endif
+ mono_stats.new_object_count++;
+
+ if (!o)
+ out_of_memory (size);
+ return o;
+}
+#if CREATION_SPEEDUP
+static inline void *
+mono_object_allocate_spec (size_t size, void *gcdescr)
+{
+ /* if this is changed to GC_debug_malloc(), we need to change also metadata/gc.c */
+ void *o = GC_GCJ_MALLOC (size, gcdescr);
mono_stats.new_object_count++;
+ if (!o)
+ out_of_memory (size);
return o;
}
+#endif
/**
* mono_object_free:
MonoObject *
mono_object_new (MonoDomain *domain, MonoClass *klass)
{
+ MONO_ARCH_SAVE_REGS;
return mono_object_new_specific (mono_class_vtable (domain, klass));
}
{
MonoObject *o;
+ MONO_ARCH_SAVE_REGS;
+
+ if (vtable->remote)
+ {
+ gpointer pa [1];
+ MonoMethod *im = vtable->domain->create_proxy_for_type_method;
+
+ if (im == NULL) {
+ MonoClass *klass = mono_class_from_name (mono_defaults.corlib, "System.Runtime.Remoting.Activation", "ActivationServices");
+ int i;
+
+ if (!klass->inited)
+ mono_class_init (klass);
+
+ for (i = 0; i < klass->method.count; ++i) {
+ if (!strcmp ("CreateProxyForType", klass->methods [i]->name) &&
+ klass->methods [i]->signature->param_count == 1) {
+ im = klass->methods [i];
+ break;
+ }
+ }
+ g_assert (im);
+ vtable->domain->create_proxy_for_type_method = im;
+ }
+
+ pa [0] = mono_type_get_object (mono_domain_get (), &vtable->klass->byval_arg);
+
+ o = mono_runtime_invoke (im, NULL, pa, NULL);
+ if (o != NULL) return o;
+ }
+
+ return mono_object_new_alloc_specific (vtable);
+}
+
+MonoObject *
+mono_object_new_fast (MonoVTable *vtable)
+{
+ MonoObject *o;
+ MONO_ARCH_SAVE_REGS;
+
+#if CREATION_SPEEDUP
+ if (vtable->gc_descr != GC_NO_DESCRIPTOR) {
+ o = mono_object_allocate_spec (vtable->klass->instance_size, vtable);
+ } else {
+// printf("OBJECT: %s.%s.\n", vtable->klass->name_space, vtable->klass->name);
+ o = mono_object_allocate (vtable->klass->instance_size);
+ o->vtable = vtable;
+ }
+#else
+ o = mono_object_allocate (vtable->klass->instance_size);
+ o->vtable = vtable;
+#endif
+ return o;
+}
+
+MonoObject *
+mono_object_new_alloc_specific (MonoVTable *vtable)
+{
+ MonoObject *o;
+
+#if CREATION_SPEEDUP
+ if (vtable->gc_descr != GC_NO_DESCRIPTOR) {
+ o = mono_object_allocate_spec (vtable->klass->instance_size, vtable);
+ } else {
+// printf("OBJECT: %s.%s.\n", vtable->klass->name_space, vtable->klass->name);
+ o = mono_object_allocate (vtable->klass->instance_size);
+ o->vtable = vtable;
+ }
+#else
o = mono_object_allocate (vtable->klass->instance_size);
o->vtable = vtable;
+#endif
if (vtable->klass->has_finalize)
mono_object_register_finalizer (o);
return o;
}
+/* helper macros to check for overflow when calculating the size of arrays */
+#define MYGUINT32_MAX 4294967295U
+#define CHECK_ADD_OVERFLOW_UN(a,b) \
+ (guint32)(MYGUINT32_MAX) - (guint32)(b) < (guint32)(a) ? -1 : 0
+#define CHECK_MUL_OVERFLOW_UN(a,b) \
+ ((guint32)(a) == 0) || ((guint32)(b) == 0) ? 0 : \
+ (guint32)(b) > ((MYGUINT32_MAX) / (guint32)(a))
+
/*
* mono_array_new_full:
* @domain: domain where the object is created
MonoObject *o;
MonoArray *array;
MonoArrayBounds *bounds;
+ MonoVTable *vtable;
int i;
if (!array_class->inited)
#endif
for (i = 0; i < array_class->rank; ++i) {
bounds [i].length = lengths [i];
+ if (CHECK_MUL_OVERFLOW_UN (len, lengths [i]))
+ out_of_memory (MYGUINT32_MAX);
len *= lengths [i];
}
bounds [i].lower_bound = lower_bounds [i];
}
+ if (CHECK_MUL_OVERFLOW_UN (byte_len, len))
+ out_of_memory (MYGUINT32_MAX);
byte_len *= len;
+ if (CHECK_ADD_OVERFLOW_UN (byte_len, sizeof (MonoArray)))
+ out_of_memory (MYGUINT32_MAX);
+ byte_len += sizeof (MonoArray);
/*
* Following three lines almost taken from mono_object_new ():
* they need to be kept in sync.
*/
- o = mono_object_allocate (sizeof (MonoArray) + byte_len);
- if (!o)
- G_BREAKPOINT ();
- o->vtable = mono_class_vtable (domain, array_class);
+ vtable = mono_class_vtable (domain, array_class);
+#if CREATION_SPEEDUP
+ if (vtable->gc_descr != GC_NO_DESCRIPTOR)
+ o = mono_object_allocate_spec (byte_len, vtable);
+ else {
+ o = mono_object_allocate (byte_len);
+ o->vtable = vtable;
+ }
+#else
+ o = mono_object_allocate (byte_len);
+ o->vtable = vtable;
+#endif
array = (MonoArray*)o;
{
MonoClass *ac;
- ac = mono_array_class_get (&eclass->byval_arg, 1);
+ MONO_ARCH_SAVE_REGS;
+
+ ac = mono_array_class_get (eclass, 1);
g_assert (ac != NULL);
return mono_array_new_specific (mono_class_vtable (domain, ac), n);
{
MonoObject *o;
MonoArray *ao;
- gsize byte_len;
+ guint32 byte_len, elem_size;
+
+ MONO_ARCH_SAVE_REGS;
- byte_len = n * mono_array_element_size (vtable->klass);
+ elem_size = mono_array_element_size (vtable->klass);
+ if (CHECK_MUL_OVERFLOW_UN (n, elem_size))
+ out_of_memory (MYGUINT32_MAX);
+ byte_len = n * elem_size;
+ if (CHECK_ADD_OVERFLOW_UN (byte_len, sizeof (MonoArray)))
+ out_of_memory (MYGUINT32_MAX);
+ byte_len += sizeof (MonoArray);
#if CREATION_SPEEDUP
- if (vtable->klass->element_class->byval_arg.type >= MONO_TYPE_BOOLEAN && vtable->klass->element_class->byval_arg.type <= MONO_TYPE_R4) {
- o = GC_MALLOC_ATOMIC (sizeof (MonoArray) + byte_len);
- o->synchronisation = 0;
- memset (((MonoArray*)o)->vector, 0, byte_len);
+ if (vtable->gc_descr != GC_NO_DESCRIPTOR) {
+ o = mono_object_allocate_spec (byte_len, vtable);
} else {
- o = mono_object_allocate (sizeof (MonoArray) + byte_len);
+// printf("ARRAY: %s.%s.\n", vtable->klass->name_space, vtable->klass->name);
+ o = mono_object_allocate (byte_len);
+ o->vtable = vtable;
}
#else
- o = mono_object_allocate (sizeof (MonoArray) + byte_len);
-#endif
- if (!o)
- G_BREAKPOINT ();
+ o = mono_object_allocate (byte_len);
o->vtable = vtable;
+#endif
ao = (MonoArray *)o;
ao->bounds = NULL;
mono_string_new_size (MonoDomain *domain, gint32 len)
{
MonoString *s;
+ MonoVTable *vtable;
+
+ vtable = mono_class_vtable (domain, mono_defaults.string_class);
#if CREATION_SPEEDUP
- s = GC_MALLOC_ATOMIC (sizeof (MonoString) + ((len + 1) * 2));
- s->object.synchronisation = 0;
- mono_string_chars (s) [len] = 0;
+ if (vtable->gc_descr != GC_NO_DESCRIPTOR)
+ s = mono_object_allocate_spec (sizeof (MonoString) + ((len + 1) * 2), vtable);
+ else {
+ s = (MonoString*)mono_object_allocate (sizeof (MonoString) + ((len + 1) * 2));
+ s->object.vtable = vtable;
+ }
#else
s = (MonoString*)mono_object_allocate (sizeof (MonoString) + ((len + 1) * 2));
+ s->object.vtable = vtable;
#endif
- if (!s)
- G_BREAKPOINT ();
- s->object.vtable = mono_class_vtable (domain, mono_defaults.string_class);
s->length = len;
mono_profiler_allocation ((MonoObject*)s, mono_defaults.string_class);
guint16 *ut;
glong items_written;
-
ut = g_utf8_to_utf16 (text, length, NULL, &items_written, &error);
if (!error)
{
MonoDomain *domain = mono_domain_get ();
+ MONO_ARCH_SAVE_REGS;
+
if (text)
return mono_string_new (domain, text);
{
MonoObject *res;
int size;
+ MonoVTable *vtable;
g_assert (class->valuetype);
+ vtable = mono_class_vtable (domain, class);
size = mono_class_instance_size (class);
res = mono_object_allocate (size);
- res->vtable = mono_class_vtable (domain, class);
+ res->vtable = vtable;
mono_profiler_allocation (res, class);
size = size - sizeof (MonoObject);
return res;
}
+gpointer
+mono_object_unbox (MonoObject *obj)
+{
+ /* add assert for valuetypes? */
+ return ((char*)obj) + sizeof (MonoObject);
+}
+
/**
* mono_object_isinst:
* @obj: an object
MonoObject *
mono_object_isinst (MonoObject *obj, MonoClass *klass)
{
- MonoVTable *vt;
- MonoClass *oklass;
+ if (!klass->inited)
+ mono_class_init (klass);
+
+ if (klass->marshalbyref || klass->flags & TYPE_ATTRIBUTE_INTERFACE)
+ return mono_object_isinst_mbyref (obj, klass);
if (!obj)
return NULL;
- vt = obj->vtable;
- oklass = vt->klass;
+ return mono_class_is_assignable_from (klass, obj->vtable->klass) ? obj : NULL;
+}
- if (!klass->inited)
- mono_class_init (klass);
+MonoObject *
+mono_object_isinst_mbyref (MonoObject *obj, MonoClass *klass)
+{
+ MonoVTable *vt;
+
+ if (!obj)
+ return NULL;
+ vt = obj->vtable;
+
if (klass->flags & TYPE_ATTRIBUTE_INTERFACE) {
- if ((klass->interface_id <= oklass->max_interface_id) &&
- vt->interface_offsets [klass->interface_id])
+ if ((klass->interface_id <= vt->max_interface_id) &&
+ (vt->interface_offsets [klass->interface_id] != 0))
return obj;
- } else {
- if (oklass == mono_defaults.transparent_proxy_class) {
- /* fixme: add check for IRemotingTypeInfo */
- oklass = ((MonoTransparentProxy *)obj)->klass;
+ }
+ else {
+ MonoClass *oklass = vt->klass;
+ if ((oklass == mono_defaults.transparent_proxy_class))
+ oklass = ((MonoTransparentProxy *)obj)->remote_class->proxy_class;
+
+ if ((oklass->idepth >= klass->idepth) && (oklass->supertypes [klass->idepth - 1] == klass))
+ return obj;
+ }
+
+ if (vt->klass == mono_defaults.transparent_proxy_class && ((MonoTransparentProxy *)obj)->custom_type_info)
+ {
+ MonoDomain *domain = mono_domain_get ();
+ MonoObject *res;
+ MonoObject *rp = (MonoObject *)((MonoTransparentProxy *)obj)->rp;
+ MonoClass *rpklass = mono_defaults.iremotingtypeinfo_class;
+ MonoMethod *im = NULL;
+ gpointer pa [2];
+ int i;
+
+ for (i = 0; i < rpklass->method.count; ++i) {
+ if (!strcmp ("CanCastTo", rpklass->methods [i]->name)) {
+ im = rpklass->methods [i];
+ break;
+ }
}
- if (klass->rank) {
- if (oklass->rank == klass->rank &&
- (oklass->cast_class->baseval - klass->cast_class->baseval) <=
- klass->cast_class->diffval)
- return obj;
-
- } else if ((oklass->baseval - klass->baseval) <= klass->diffval)
+
+ im = mono_object_get_virtual_method (rp, im);
+ g_assert (im);
+
+ pa [0] = mono_type_get_object (domain, &klass->byval_arg);
+ pa [1] = obj;
+
+ res = mono_runtime_invoke (im, rp, pa, NULL);
+
+ if (*(MonoBoolean *) mono_object_unbox(res)) {
+ /* Update the vtable of the remote type, so it can safely cast to this new type */
+ mono_upgrade_remote_class (domain, ((MonoTransparentProxy *)obj)->remote_class, klass);
+ obj->vtable = ((MonoTransparentProxy *)obj)->remote_class->vtable;
return obj;
+ }
}
return NULL;
}
+/**
+ * mono_object_castclass_mbyref:
+ * @obj: an object
+ * @klass: a pointer to a class
+ *
+ * Returns: @obj if @obj is derived from @klass, throws an exception otherwise
+ */
+MonoObject *
+mono_object_castclass_mbyref (MonoObject *obj, MonoClass *klass)
+{
+ if (!obj) return NULL;
+ if (mono_object_isinst_mbyref (obj, klass)) return obj;
+
+ mono_raise_exception (mono_exception_from_name (mono_defaults.corlib,
+ "System",
+ "InvalidCastException"));
+ return NULL;
+}
+
+typedef struct {
+ MonoDomain *orig_domain;
+ char *ins;
+ MonoString *res;
+} LDStrInfo;
+
+static void
+str_lookup (MonoDomain *domain, gpointer user_data)
+{
+ LDStrInfo *info = user_data;
+ if (info->res || domain == info->orig_domain)
+ return;
+ mono_domain_lock (domain);
+ info->res = mono_g_hash_table_lookup (domain->ldstr_table, info->ins);
+ mono_domain_unlock (domain);
+}
+
static MonoString*
mono_string_is_interned_lookup (MonoString *str, int insert)
{
MonoDomain *domain;
char *ins = g_malloc (4 + str->length * 2);
char *p;
- int bloblen;
/* Encode the length */
+ /* Same code as in mono_image_insert_string () */
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;
+ mono_metadata_encode_value (1 | (2 * str->length), p, &p);
+
/*
* 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
#if G_BYTE_ORDER != G_LITTLE_ENDIAN
{
int i;
- char *p2 = mono_string_chars (str);
+ char *p2 = (char *)mono_string_chars (str);
for (i = 0; i < str->length; ++i) {
*p++ = p2 [1];
*p++ = p2 [0];
mono_g_hash_table_insert (ldstr_table, ins, str);
mono_domain_unlock (domain);
return str;
+ } else {
+ LDStrInfo ldstr_info;
+ ldstr_info.orig_domain = domain;
+ ldstr_info.ins = ins;
+ ldstr_info.res = NULL;
+
+ mono_domain_foreach (str_lookup, &ldstr_info);
+ if (ldstr_info.res) {
+ /*
+ * the string was already interned in some other domain:
+ * intern it in the current one as well.
+ */
+ mono_g_hash_table_insert (ldstr_table, ins, str);
+ mono_domain_unlock (domain);
+ return str;
+ }
}
mono_domain_unlock (domain);
g_free (ins);
MonoString *o;
size_t len2;
- if (image->assembly->dynamic)
+ MONO_ARCH_SAVE_REGS;
+
+ if (image->dynamic)
return mono_lookup_dynamic_token (image, MONO_TOKEN_STRING | idx);
else
sig = str = mono_metadata_user_string (image, idx);
return g_strdup ("");
as = g_utf16_to_utf8 (mono_string_chars (s), s->length, NULL, NULL, &error);
- if (error)
+ if (error) {
g_warning (error->message);
+ g_error_free (error);
+ }
return as;
}
{
MonoObject *o = (MonoObject*)ex;
g_error ("Exception %s.%s raised in C code", o->vtable->klass->name_space, o->vtable->klass->name);
+ exit (1);
}
static MonoExceptionFunc ex_handler = default_ex_handler;
void
mono_raise_exception (MonoException *ex)
{
+ /*
+ * NOTE: Do NOT annotate this function with G_GNUC_NORETURN, since
+ * that will cause gcc to omit the function epilog, causing problems when
+ * the JIT tries to walk the stack, since the return address on the stack
+ * will point into the next function in the executable, not this one.
+ */
+
ex_handler (ex);
}
res->data = data;
res->async_state = state;
- res->handle = (MonoObject *)mono_wait_handle_new (domain, handle);
+ if (handle != NULL)
+ res->handle = (MonoObject *) mono_wait_handle_new (domain, handle);
+
res->sync_completed = FALSE;
res->completed = FALSE;
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);
+ this->async_result = NULL;
+ this->call_type = CallType_Sync;
names = g_new (char *, sig->param_count);
mono_method_get_param_names (method->method, (const char **) names);
}
g_free (names);
-
for (i = 0, j = 0; i < sig->param_count; i++) {
if (sig->params [i]->byref) {
j++;
}
arg_type = 2;
- if (sig->params [i]->attrs & PARAM_ATTRIBUTE_IN)
+ if (!(sig->params [i]->attrs & PARAM_ATTRIBUTE_OUT))
arg_type |= 1;
} else {
arg_type = 1;
}
-
mono_array_set (this->arg_types, guint8, i, arg_type);
}
}
mono_remoting_invoke (MonoObject *real_proxy, MonoMethodMessage *msg,
MonoObject **exc, MonoArray **out_args)
{
- static MonoMethod *im = NULL;
+ MonoMethod *im = real_proxy->vtable->domain->private_invoke_method;
gpointer pa [4];
/*static MonoObject *(*invoke) (gpointer, gpointer, MonoObject **, MonoArray **) = NULL;*/
- /* FIXME: make this domain dependent */
if (!im) {
MonoClass *klass;
int i;
}
g_assert (im);
+ real_proxy->vtable->domain->private_invoke_method = im;
}
pa [0] = real_proxy;
mono_message_invoke (MonoObject *target, MonoMethodMessage *msg,
MonoObject **exc, MonoArray **out_args)
{
- if (target && target->vtable->klass == mono_defaults.transparent_proxy_class) {
+ MonoDomain *domain;
+ MonoMethod *method;
+ MonoMethodSignature *sig;
+ int i, j, outarg_count = 0;
- return mono_remoting_invoke ((MonoObject *)((MonoTransparentProxy *)target)->rp,
- msg, exc, out_args);
+ if (target && target->vtable->klass == mono_defaults.transparent_proxy_class) {
- } 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++;
+ MonoTransparentProxy* tp = (MonoTransparentProxy *)target;
+ if (tp->remote_class->proxy_class->contextbound && tp->rp->context == (MonoObject *) mono_context_get ()) {
+ target = tp->rp->unwrapped_server;
+ } else {
+ return mono_remoting_invoke ((MonoObject *)tp->rp, msg, exc, out_args);
}
+ }
- *out_args = mono_array_new (domain, mono_defaults.object_class, outarg_count);
- *exc = NULL;
+ domain = mono_domain_get ();
+ method = msg->method->method;
+ sig = method->signature;
- 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++;
- }
- }
+ 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;
- return mono_runtime_invoke_array (method, target, msg->args, exc);
+ 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, exc);
}
void
mono_array_set (msg->args, gpointer, i, arg);
}
- if (invoke) {
+ if (cb != NULL && state != NULL) {
*cb = *((MonoDelegate **)params [i]);
i++;
*state = *((MonoObject **)params [i]);
{
MonoMethodSignature *sig = method->signature;
int i, j, type, size;
-
for (i = 0, j = 0; i < sig->param_count; i++) {
MonoType *pt = sig->params [i];
- size = mono_type_stack_size (pt, NULL);
-
if (pt->byref) {
char *arg = mono_array_get (out_args, gpointer, j);
type = pt->type;
-
+
switch (type) {
case MONO_TYPE_VOID:
g_assert_not_reached ();
case MONO_TYPE_R4:
case MONO_TYPE_R8:
case MONO_TYPE_VALUETYPE: {
+ size = mono_class_value_size (((MonoObject*)arg)->vtable->klass, NULL);
memcpy (*((gpointer *)params [i]), arg + sizeof (MonoObject), size);
break;
}
case MONO_TYPE_CLASS:
case MONO_TYPE_ARRAY:
case MONO_TYPE_SZARRAY:
- *((MonoObject **)params [i]) = (MonoObject *)arg;
+ **((MonoObject ***)params [i]) = (MonoObject *)arg;
break;
default:
g_assert_not_reached ();
{
static MonoMethod *getter = NULL;
MonoDomain *domain = mono_domain_get ();
+ MonoTransparentProxy *tp = (MonoTransparentProxy *) this;
MonoClass *field_class;
MonoMethodMessage *msg;
MonoArray *out_args;
if (!res)
res = &tmp;
+ if (tp->remote_class->proxy_class->contextbound && tp->rp->context == (MonoObject *) mono_context_get ()) {
+ mono_field_get_value (tp->rp->unwrapped_server, field, res);
+ return res;
+ }
+
if (!getter) {
int i;
mono_array_set (msg->args, gpointer, 0, mono_string_new (domain, klass->name));
mono_array_set (msg->args, gpointer, 1, mono_string_new (domain, field->name));
- mono_remoting_invoke ((MonoObject *)((MonoTransparentProxy *)this)->rp, msg, &exc, &out_args);
+ mono_remoting_invoke ((MonoObject *)(tp->rp), msg, &exc, &out_args);
+
+ if (exc) mono_raise_exception ((MonoException *)exc);
*res = mono_array_get (out_args, MonoObject *, 0);
return res;
}
+MonoObject *
+mono_load_remote_field_new (MonoObject *this, MonoClass *klass, MonoClassField *field)
+{
+ static MonoMethod *getter = NULL;
+ MonoDomain *domain = mono_domain_get ();
+ MonoTransparentProxy *tp = (MonoTransparentProxy *) this;
+ MonoClass *field_class;
+ MonoMethodMessage *msg;
+ MonoArray *out_args;
+ MonoObject *exc, *res;
+
+ g_assert (this->vtable->klass == mono_defaults.transparent_proxy_class);
+
+ field_class = mono_class_from_mono_type (field->type);
+
+ if (tp->remote_class->proxy_class->contextbound && tp->rp->context == (MonoObject *) mono_context_get ()) {
+ gpointer val;
+ if (field_class->valuetype) {
+ res = mono_object_new (domain, field_class);
+ val = ((gchar *) res) + sizeof (MonoObject);
+ } else {
+ val = &res;
+ }
+ mono_field_get_value (tp->rp->unwrapped_server, field, val);
+ return res;
+ }
+
+ if (!getter) {
+ int i;
+
+ for (i = 0; i < mono_defaults.object_class->method.count; ++i) {
+ MonoMethod *cm = mono_defaults.object_class->methods [i];
+
+ if (!strcmp (cm->name, "FieldGetter")) {
+ getter = cm;
+ break;
+ }
+ }
+ g_assert (getter);
+ }
+
+ msg = (MonoMethodMessage *)mono_object_new (domain, mono_defaults.mono_method_message_class);
+ out_args = mono_array_new (domain, mono_defaults.object_class, 1);
+ mono_message_init (domain, msg, mono_method_get_object (domain, getter, NULL), out_args);
+
+ mono_array_set (msg->args, gpointer, 0, mono_string_new (domain, klass->name));
+ mono_array_set (msg->args, gpointer, 1, mono_string_new (domain, field->name));
+
+ mono_remoting_invoke ((MonoObject *)(tp->rp), msg, &exc, &out_args);
+
+ if (exc) mono_raise_exception ((MonoException *)exc);
+
+ res = mono_array_get (out_args, MonoObject *, 0);
+
+ return res;
+}
+
/**
* mono_store_remote_field:
* @this: pointer to an object
{
static MonoMethod *setter = NULL;
MonoDomain *domain = mono_domain_get ();
+ MonoTransparentProxy *tp = (MonoTransparentProxy *) this;
MonoClass *field_class;
MonoMethodMessage *msg;
MonoArray *out_args;
g_assert (this->vtable->klass == mono_defaults.transparent_proxy_class);
+ field_class = mono_class_from_mono_type (field->type);
+
+ if (tp->remote_class->proxy_class->contextbound && tp->rp->context == (MonoObject *) mono_context_get ()) {
+ if (field_class->valuetype) mono_field_set_value (tp->rp->unwrapped_server, field, val);
+ else mono_field_set_value (tp->rp->unwrapped_server, field, *((MonoObject **)val));
+ return;
+ }
+
if (!setter) {
int i;
g_assert (setter);
}
- field_class = mono_class_from_mono_type (field->type);
-
if (field_class->valuetype)
arg = mono_value_box (domain, field_class, val);
else
mono_array_set (msg->args, gpointer, 1, mono_string_new (domain, field->name));
mono_array_set (msg->args, gpointer, 2, arg);
- mono_remoting_invoke ((MonoObject *)((MonoTransparentProxy *)this)->rp, msg, &exc, &out_args);
+ mono_remoting_invoke ((MonoObject *)(tp->rp), msg, &exc, &out_args);
+
+ if (exc) mono_raise_exception ((MonoException *)exc);
+}
+
+void
+mono_store_remote_field_new (MonoObject *this, MonoClass *klass, MonoClassField *field, MonoObject *arg)
+{
+ static MonoMethod *setter = NULL;
+ MonoDomain *domain = mono_domain_get ();
+ MonoTransparentProxy *tp = (MonoTransparentProxy *) this;
+ MonoClass *field_class;
+ MonoMethodMessage *msg;
+ MonoArray *out_args;
+ MonoObject *exc;
+
+ g_assert (this->vtable->klass == mono_defaults.transparent_proxy_class);
+
+ field_class = mono_class_from_mono_type (field->type);
+
+ if (tp->remote_class->proxy_class->contextbound && tp->rp->context == (MonoObject *) mono_context_get ()) {
+ if (field_class->valuetype) mono_field_set_value (tp->rp->unwrapped_server, field, ((gchar *) arg) + sizeof (MonoObject));
+ else mono_field_set_value (tp->rp->unwrapped_server, field, arg);
+ return;
+ }
+
+ if (!setter) {
+ int i;
+
+ for (i = 0; i < mono_defaults.object_class->method.count; ++i) {
+ MonoMethod *cm = mono_defaults.object_class->methods [i];
+
+ if (!strcmp (cm->name, "FieldSetter")) {
+ setter = cm;
+ break;
+ }
+ }
+ g_assert (setter);
+ }
+
+ msg = (MonoMethodMessage *)mono_object_new (domain, mono_defaults.mono_method_message_class);
+ mono_message_init (domain, msg, mono_method_get_object (domain, setter, NULL), NULL);
+
+ mono_array_set (msg->args, gpointer, 0, mono_string_new (domain, klass->name));
+ mono_array_set (msg->args, gpointer, 1, mono_string_new (domain, field->name));
+ mono_array_set (msg->args, gpointer, 2, arg);
+
+ mono_remoting_invoke ((MonoObject *)(tp->rp), msg, &exc, &out_args);
+
+ if (exc) mono_raise_exception ((MonoException *)exc);
}
projects / mono.git / blobdiff