#define REVEAL_POINTER(v) (v)
#endif
+typedef struct DomainFinalizationReq {
+ MonoDomain *domain;
+ HANDLE done_event;
+} DomainFinalizationReq;
+
+#ifdef PLATFORM_WINCE /* FIXME: add accessors to gc.dll API */
+extern void (*__imp_GC_finalizer_notifier)(void);
+#define GC_finalizer_notifier __imp_GC_finalizer_notifier
+extern int __imp_GC_finalize_on_demand;
+#define GC_finalize_on_demand __imp_GC_finalize_on_demand
+#endif
+
static int finalize_slot = -1;
+static gboolean gc_disabled = FALSE;
+
+static CRITICAL_SECTION finalizer_mutex;
+
+static GSList *domains_to_finalize= NULL;
+
+static MonoThread *gc_thread;
+
static void object_register_finalizer (MonoObject *obj, void (*callback)(void *, void*));
#if HAVE_BOEHM_GC
static void finalize_notify (void);
static HANDLE pending_done_event;
+static HANDLE shutdown_event;
+static HANDLE thread_started_event;
#endif
/*
run_finalize (void *obj, void *data)
{
MonoObject *exc = NULL;
- MonoObject *o;
+ MonoObject *o, *o2;
o = (MonoObject*)((char*)obj + GPOINTER_TO_UINT (data));
if (finalize_slot < 0) {
}
}
+ mono_domain_lock (o->vtable->domain);
+
+ o2 = g_hash_table_lookup (o->vtable->domain->finalizable_objects_hash, o);
+
+ mono_domain_unlock (o->vtable->domain);
+
+ if (!o2)
+ /* Already finalized somehow */
+ return;
+
/* make sure the finalizer is not called again if the object is resurrected */
object_register_finalizer (obj, NULL);
+
+ if (o->vtable->klass == mono_defaults.thread_class)
+ if (mono_gc_is_finalizer_thread ((MonoThread*)o))
+ /* Avoid finalizing ourselves */
+ return;
+
/* speedup later... and use a timeout */
- /*g_print ("Finalize run on %p %s.%s\n", o, mono_object_class (o)->name_space, mono_object_class (o)->name);*/
- mono_domain_set (mono_object_domain (o));
+ /* g_print ("Finalize run on %p %s.%s\n", o, mono_object_class (o)->name_space, mono_object_class (o)->name); */
+
+ /* Use _internal here, since this thread can enter a doomed appdomain */
+ mono_domain_set_internal (mono_object_domain (o));
mono_runtime_invoke (o->vtable->klass->vtable [finalize_slot], o, NULL, &exc);
#if HAVE_BOEHM_GC
guint offset = 0;
+#ifndef GC_DEBUG
+ /* This assertion is not valid when GC_DEBUG is defined */
g_assert (GC_base (obj) == (char*)obj - offset);
+#endif
+
+ if (mono_domain_is_unloading (obj->vtable->domain) && (callback != NULL))
+ /*
+ * Can't register finalizers in a dying appdomain, since they
+ * could be invoked after the appdomain has been unloaded.
+ */
+ return;
+
+ mono_domain_lock (obj->vtable->domain);
+
+ if (callback)
+ g_hash_table_insert (obj->vtable->domain->finalizable_objects_hash, obj,
+ obj);
+ else
+ g_hash_table_remove (obj->vtable->domain->finalizable_objects_hash, obj);
+
+ mono_domain_unlock (obj->vtable->domain);
+
GC_REGISTER_FINALIZER_NO_ORDER ((char*)obj - offset, callback, GUINT_TO_POINTER (offset), NULL, NULL);
#endif
}
void
mono_object_register_finalizer (MonoObject *obj)
{
- /*g_print ("Registered finalizer on %p %s.%s\n", obj, mono_object_class (obj)->name_space, mono_object_class (obj)->name);*/
+ /* g_print ("Registered finalizer on %p %s.%s\n", obj, mono_object_class (obj)->name_space, mono_object_class (obj)->name); */
object_register_finalizer (obj, run_finalize);
}
-/*
- * to speedup, at class init time, check if a class or struct
- * have fields that need to be finalized and set a flag.
+/*
+ * mono_domain_finalize:
+ *
+ * Request finalization of all finalizable objects inside @domain. Wait
+ * @timeout msecs for the finalization to complete.
+ * Returns: TRUE if succeeded, FALSE if there was a timeout
*/
-static void
-finalize_fields (MonoClass *class, char *data, gboolean instance, GHashTable *todo) {
- int i;
- MonoClassField *field;
- MonoObject *obj;
-
- /*if (!instance)
- g_print ("Finalize statics on on %s\n", class->name);*/
- if (instance && class->valuetype)
- data -= sizeof (MonoObject);
- do {
- for (i = 0; i < class->field.count; ++i) {
- field = &class->fields [i];
- if (instance) {
- if (field->type->attrs & FIELD_ATTRIBUTE_STATIC)
- continue;
- } else {
- if (!(field->type->attrs & FIELD_ATTRIBUTE_STATIC))
- continue;
- }
- switch (field->type->type) {
- case MONO_TYPE_OBJECT:
- case MONO_TYPE_CLASS:
- obj = *((MonoObject**)(data + field->offset));
- if (obj) {
- if (mono_object_class (obj)->has_finalize) {
- /* disable the registered finalizer */
- object_register_finalizer (obj, NULL);
- run_finalize (obj, NULL);
- } else {
- /*
- * if the type doesn't have a finalizer, we finalize
- * the fields ourselves just like we do for structs.
- * Disabled for now: how do we handle loops?
- */
- /*finalize_fields (mono_object_class (obj), obj, TRUE, todo);*/
- }
- }
- break;
- case MONO_TYPE_VALUETYPE: {
- MonoClass *fclass = mono_class_from_mono_type (field->type);
- if (fclass->enumtype)
- continue;
- /*finalize_fields (fclass, data + field->offset, TRUE, todo);*/
- break;
- }
- case MONO_TYPE_ARRAY:
- case MONO_TYPE_SZARRAY:
- /* FIXME: foreach item... */
- break;
- }
- }
- if (!instance)
- return;
- class = class->parent;
- } while (class);
-}
-static void
-finalize_static_data (MonoClass *class, MonoVTable *vtable, GHashTable *todo) {
-
- if (class->enumtype || !vtable->data)
- return;
- finalize_fields (class, vtable->data, FALSE, todo);
-}
-
-void
-mono_domain_finalize (MonoDomain *domain)
+gboolean
+mono_domain_finalize (MonoDomain *domain, guint32 timeout)
{
- GHashTable *todo = g_hash_table_new (NULL, NULL);
+ DomainFinalizationReq *req;
+ guint32 res;
+ HANDLE done_event;
/*
* No need to create another thread 'cause the finalizer thread
* is still working and will take care of running the finalizers
*/
- mono_thread_new_init (GetCurrentThreadId (), todo, NULL);
#if HAVE_BOEHM_GC
+ if (gc_disabled)
+ return TRUE;
+
GC_gcollect ();
-#endif
- mono_g_hash_table_foreach (domain->class_vtable_hash, (GHFunc)finalize_static_data, todo);
- /* FIXME: finalize objects in todo... */
- g_hash_table_destroy (todo);
- return;
+ done_event = CreateEvent (NULL, TRUE, FALSE, NULL);
+
+ req = g_new0 (DomainFinalizationReq, 1);
+ req->domain = domain;
+ req->done_event = done_event;
+
+ EnterCriticalSection (&finalizer_mutex);
+
+ domains_to_finalize = g_slist_append (domains_to_finalize, req);
+
+ LeaveCriticalSection (&finalizer_mutex);
+
+ /* Tell the finalizer thread to finalize this appdomain */
+ finalize_notify ();
+
+ res = WaitForSingleObject (done_event, timeout);
+
+ /* printf ("WAIT RES: %d.\n", res); */
+ if (res == WAIT_TIMEOUT) {
+ /* We leak the handle here */
+ return FALSE;
+ }
+
+ CloseHandle (done_event);
+ return TRUE;
+#else
+ /* We don't support domain finalization without a GC */
+ return FALSE;
+#endif
}
void
#if HAVE_BOEHM_GC
if (forceCollection)
GC_gcollect ();
- return GC_get_heap_size ();
+ return GC_get_heap_size () - GC_get_free_bytes ();
#else
return 0;
#endif
if (!GC_should_invoke_finalizers ())
return;
+ if (mono_thread_current () == gc_thread)
+ /* Avoid deadlocks */
+ return;
+
ResetEvent (pending_done_event);
finalize_notify ();
/* g_print ("Waiting for pending finalizers....\n"); */
MONO_ARCH_SAVE_REGS;
EnterCriticalSection (&handle_section);
- idx = next_handle++;
+ /* Indexes start from 1 since 0 means the handle is not allocated */
+ idx = ++next_handle;
if (idx >= array_size) {
#if HAVE_BOEHM_GC
gpointer *new_array;
GC_unregister_disappearing_link (&(gc_handles [idx]));
}
#else
+ LeaveCriticalSection (&handle_section);
mono_raise_exception (mono_get_exception_execution_engine ("No GCHandle support"));
#endif
static void finalize_notify (void)
{
- gboolean pending = GC_should_invoke_finalizers ();
#ifdef DEBUG
g_message (G_GNUC_PRETTY_FUNCTION ": prodding finalizer");
#endif
SetEvent (finalizer_event);
- if (finished && pending) {
- /* Finishing the finalizer thread, so wait a little bit... */
- /* MS seems to wait for about 2 seconds */
- ResetEvent (pending_done_event);
- WaitForSingleObject (pending_done_event, 2000);
+}
+
+static void
+collect_objects (gpointer key, gpointer value, gpointer user_data)
+{
+ GPtrArray *arr = (GPtrArray*)user_data;
+ g_ptr_array_add (arr, key);
+}
+
+/*
+ * finalize_domain_objects:
+ *
+ * Run the finalizers of all finalizable objects in req->domain.
+ */
+static void
+finalize_domain_objects (DomainFinalizationReq *req)
+{
+ int i;
+ GPtrArray *objs;
+ MonoDomain *domain = req->domain;
+
+ while (g_hash_table_size (domain->finalizable_objects_hash) > 0) {
+ /*
+ * Since the domain is unloading, nobody is allowed to put
+ * new entries into the hash table. But finalize_object might
+ * remove entries from the hash table, so we make a copy.
+ */
+ objs = g_ptr_array_new ();
+ g_hash_table_foreach (domain->finalizable_objects_hash,
+ collect_objects, objs);
+ //printf ("FINALIZING %d OBJECTS.\n", objs->len);
+
+ for (i = 0; i < objs->len; ++i) {
+ MonoObject *o = (MonoObject*)g_ptr_array_index (objs, i);
+ /* FIXME: Avoid finalizing threads, etc */
+ run_finalize (o, 0);
+ }
+
+ g_ptr_array_free (objs, TRUE);
}
+
+ /* printf ("DONE.\n"); */
+ SetEvent (req->done_event);
+
+ /* The event is closed in mono_domain_finalize if we get here */
+ g_free (req);
}
static guint32 finalizer_thread (gpointer unused)
{
- guint32 stack_start;
-
- mono_thread_new_init (GetCurrentThreadId (), &stack_start, NULL);
-
+ gc_thread = mono_thread_current ();
+
+ SetEvent (thread_started_event);
+
while(!finished) {
/* Wait to be notified that there's at least one
* finaliser to run
*/
WaitForSingleObject (finalizer_event, INFINITE);
+ if (domains_to_finalize) {
+ EnterCriticalSection (&finalizer_mutex);
+ if (domains_to_finalize) {
+ DomainFinalizationReq *req = domains_to_finalize->data;
+ domains_to_finalize = g_slist_remove (domains_to_finalize, req);
+ LeaveCriticalSection (&finalizer_mutex);
+
+ finalize_domain_objects (req);
+ }
+ else
+ LeaveCriticalSection (&finalizer_mutex);
+ }
+
#ifdef DEBUG
g_message (G_GNUC_PRETTY_FUNCTION ": invoking finalizers");
#endif
- /*
+ /* If finished == TRUE, mono_gc_cleanup has been called (from mono_runtime_cleanup),
+ * before the domain is unloaded.
+ *
* There is a bug in GC_invoke_finalizer () in versions <= 6.2alpha4:
* the 'mem_freed' variable is not initialized when there are no
* objects to finalize, which leads to strange behavior later on.
* The check is necessary to work around that bug.
*/
- if (GC_should_invoke_finalizers ())
+ if (GC_should_invoke_finalizers ()) {
GC_invoke_finalizers ();
+ }
+
SetEvent (pending_done_event);
}
+
+ SetEvent (shutdown_event);
return(0);
}
void mono_gc_init (void)
{
- HANDLE gc_thread;
-
InitializeCriticalSection (&handle_section);
InitializeCriticalSection (&allocator_section);
+ InitializeCriticalSection (&finalizer_mutex);
+
#ifdef WITH_INCLUDED_LIBGC
gc_thread_vtable = &mono_gc_thread_vtable;
#endif
#ifdef ENABLE_FINALIZER_THREAD
- if (getenv ("GC_DONT_GC"))
+ if (getenv ("GC_DONT_GC")) {
+ gc_disabled = TRUE;
return;
+ }
finalizer_event = CreateEvent (NULL, FALSE, FALSE, NULL);
pending_done_event = CreateEvent (NULL, TRUE, FALSE, NULL);
- if (finalizer_event == NULL || pending_done_event == NULL) {
+ shutdown_event = CreateEvent (NULL, TRUE, FALSE, NULL);
+ thread_started_event = CreateEvent (NULL, TRUE, FALSE, NULL);
+ if (finalizer_event == NULL || pending_done_event == NULL || shutdown_event == NULL || thread_started_event == NULL) {
g_assert_not_reached ();
}
GC_finalize_on_demand = 1;
GC_finalizer_notifier = finalize_notify;
-
- /* Don't use mono_thread_create here, because we don't want
- * the runtime to wait for this thread to exit when it's
- * cleaning up.
+
+ mono_thread_create (mono_domain_get (), finalizer_thread, NULL);
+ /*
+ * Wait until the finalizer thread sets gc_thread since its value is needed
+ * by mono_thread_attach ()
*/
- gc_thread = CreateThread (NULL, 0, finalizer_thread, NULL, 0, NULL);
- if (gc_thread == NULL) {
- g_assert_not_reached ();
- }
+ WaitForSingleObject (thread_started_event, INFINITE);
#endif
}
#endif
#ifdef ENABLE_FINALIZER_THREAD
- finished = TRUE;
- finalize_notify ();
+ if (!gc_disabled) {
+ ResetEvent (shutdown_event);
+ finished = TRUE;
+ finalize_notify ();
+ /* Finishing the finalizer thread, so wait a little bit... */
+ /* MS seems to wait for about 2 seconds */
+ /*
+ * FIXME: This is not thread safe. If the finalizer thread keeps
+ * running, and the runtime is shut down, it will lead to a crash.
+ */
+ WaitForSingleObject (shutdown_event, 2000);
+ }
+
+#endif
+}
+
+void
+mono_gc_disable (void)
+{
+#ifdef HAVE_GC_ENABLE
+ GC_disable ();
+#else
+ g_assert_not_reached ();
+#endif
+}
+
+void
+mono_gc_enable (void)
+{
+#ifdef HAVE_GC_ENABLE
+ GC_enable ();
+#else
+ g_assert_not_reached ();
#endif
}
{
}
+void
+mono_gc_disable (void)
+{
+}
+
+void
+mono_gc_enable (void)
+{
+}
+
#endif
+gboolean
+mono_gc_is_finalizer_thread (MonoThread *thread)
+{
+ return thread == gc_thread;
+}
+
+