#include <mono/metadata/threads.h>
#include <mono/metadata/tabledefs.h>
#include <mono/metadata/exception.h>
+#include <mono/metadata/domain-internals.h>
+#include <mono/metadata/class-internals.h>
+#include <mono/utils/mono-logger.h>
#define GC_I_HIDE_POINTERS
#include <mono/os/gc_wrapper.h>
#define GC_finalize_on_demand __imp_GC_finalize_on_demand
#endif
+#ifdef HAVE_VALGRIND_MEMCHECK_H
+#include <valgrind/memcheck.h>
+#endif
+
static int finalize_slot = -1;
static gboolean gc_disabled = FALSE;
if (finalize_slot < 0) {
int i;
- for (i = 0; i < mono_defaults.object_class->vtable_size; ++i) {
- MonoMethod *cm = mono_defaults.object_class->vtable [i];
+ MonoClass* obj_class = mono_get_object_class ();
+ for (i = 0; i < obj_class->vtable_size; ++i) {
+ MonoMethod *cm = obj_class->vtable [i];
- if (!strcmp (cm->name, "Finalize")) {
+ if (!strcmp (mono_method_get_name (cm), "Finalize")) {
finalize_slot = i;
break;
}
/* make sure the finalizer is not called again if the object is resurrected */
object_register_finalizer (obj, NULL);
+
+ if (o->vtable->klass == mono_get_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); */
}
}
+gpointer
+mono_gc_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);
+
+ return NULL;
+}
+
/*
* Some of our objects may point to a different address than the address returned by GC_malloc()
* (because of the GetHashCode hack), but we need to pass the real address to register_finalizer.
/* Tell the finalizer thread to finalize this appdomain */
finalize_notify ();
- res = WaitForSingleObject (done_event, timeout);
+ res = WaitForSingleObjectEx (done_event, timeout, TRUE);
- //printf ("WAIT RES: %d.\n", res);
- if (res == WAIT_TIMEOUT)
+ /* printf ("WAIT RES: %d.\n", res); */
+ if (res == WAIT_TIMEOUT) {
+ /* We leak the handle here */
return FALSE;
- else
- return TRUE;
+ }
+
+ CloseHandle (done_event);
+ return TRUE;
#else
/* We don't support domain finalization without a GC */
return FALSE;
ResetEvent (pending_done_event);
finalize_notify ();
/* g_print ("Waiting for pending finalizers....\n"); */
- WaitForSingleObject (pending_done_event, INFINITE);
+ WaitForSingleObjectEx (pending_done_event, INFINITE, TRUE);
/* g_print ("Done pending....\n"); */
#else
#endif
/* 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;
guint8 *new_type_array;
if (!array_size)
array_size = 16;
+#if HAVE_BOEHM_GC
new_array = GC_MALLOC (sizeof (gpointer) * (array_size * 2));
new_type_array = GC_MALLOC (sizeof (guint8) * (array_size * 2));
+#else
+ new_array = g_malloc0 (sizeof (gpointer) * (array_size * 2));
+ new_type_array = g_malloc0 (sizeof (guint8) * (array_size * 2));
+#endif
if (gc_handles) {
int i;
memcpy (new_array, gc_handles, sizeof (gpointer) * array_size);
#else
if (((gulong)new_array [i]) & 0x1) {
#endif
+#if HAVE_BOEHM_GC
if (gc_handles [i] != (gpointer)-1)
GC_unregister_disappearing_link (&(gc_handles [i]));
if (new_array [i] != (gpointer)-1)
GC_GENERAL_REGISTER_DISAPPEARING_LINK (&(new_array [i]), REVEAL_POINTER (new_array [i]));
+#endif
}
}
}
array_size *= 2;
+#ifndef HAVE_BOEHM_GC
+ g_free (gc_handles);
+ g_free (gc_handle_types);
+#endif
gc_handles = new_array;
gc_handle_types = new_type_array;
-#else
- mono_raise_exception (mono_get_exception_execution_engine ("No GCHandle support built-in"));
-#endif
}
/* resuse the type from the old target */
#if HAVE_BOEHM_GC
if (gc_handles [idx] != (gpointer)-1)
GC_GENERAL_REGISTER_DISAPPEARING_LINK (&(gc_handles [idx]), obj);
-#else
- mono_raise_exception (mono_get_exception_execution_engine ("No weakref support"));
#endif
break;
default:
if (gc_handles [idx] != (gpointer)-1)
GC_unregister_disappearing_link (&(gc_handles [idx]));
}
-#else
- LeaveCriticalSection (&handle_section);
- mono_raise_exception (mono_get_exception_execution_engine ("No GCHandle support"));
#endif
gc_handles [idx] = (gpointer)-1;
if (obj == (MonoObject *) -1)
return NULL;
}
- return obj;
+ if (obj) {
+ MonoClass *klass = mono_object_class (obj);
+ if (klass == mono_defaults.string_class) {
+ return mono_string_chars ((MonoString*)obj);
+ } else if (klass->rank) {
+ return mono_array_addr ((MonoArray*)obj, char, 0);
+ } else {
+ /* the C# code will check and throw the exception */
+ /* FIXME: missing !klass->blittable test, see bug #61134 */
+ if ((klass->flags & TYPE_ATTRIBUTE_LAYOUT_MASK) == TYPE_ATTRIBUTE_AUTO_LAYOUT)
+ return (gpointer)-1;
+ return (char*)obj + sizeof (MonoObject);
+ }
+ }
}
return NULL;
}
+guint32
+mono_gchandle_new (MonoObject *obj, gboolean pinned)
+{
+ return ves_icall_System_GCHandle_GetTargetHandle (obj, 0, pinned? HANDLE_PINNED: HANDLE_NORMAL);
+}
+
+guint32
+mono_gchandle_new_weakref (MonoObject *obj, gboolean track_resurrection)
+{
+ return ves_icall_System_GCHandle_GetTargetHandle (obj, 0, track_resurrection? HANDLE_WEAK_TRACK: HANDLE_WEAK);
+}
+
+/* This will return NULL for a collected object if using a weakref handle */
+MonoObject*
+mono_gchandle_get_target (guint32 gchandle)
+{
+ return ves_icall_System_GCHandle_GetTarget (gchandle);
+}
+
+void
+mono_gchandle_free (guint32 gchandle)
+{
+ ves_icall_System_GCHandle_FreeHandle (gchandle);
+}
+
#if HAVE_BOEHM_GC
static HANDLE finalizer_event;
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
objs = g_ptr_array_new ();
g_hash_table_foreach (domain->finalizable_objects_hash,
collect_objects, objs);
- //printf ("FINALIZING %d OBJECTS.\n", objs->len);
+ /* printf ("FINALIZING %d OBJECTS.\n", objs->len); */
for (i = 0; i < objs->len; ++i) {
MonoObject *o = (MonoObject*)g_ptr_array_index (objs, i);
g_ptr_array_free (objs, TRUE);
}
- //printf ("DONE.\n");
+ /* Process finalizers which are already in the queue */
+ GC_invoke_finalizers ();
+
+ /* printf ("DONE.\n"); */
SetEvent (req->done_event);
- /* FIXME: How to delete the 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;
-
gc_thread = mono_thread_current ();
SetEvent (thread_started_event);
/* Wait to be notified that there's at least one
* finaliser to run
*/
- WaitForSingleObject (finalizer_event, INFINITE);
+ WaitForSingleObjectEx (finalizer_event, INFINITE, TRUE);
if (domains_to_finalize) {
EnterCriticalSection (&finalizer_mutex);
}
SetEvent (shutdown_event);
-
return(0);
}
};
#endif /* WITH_INCLUDED_LIBGC */
+static void
+mono_gc_warning (char *msg, GC_word arg)
+{
+ mono_trace (G_LOG_LEVEL_WARNING, MONO_TRACE_GC, msg, (unsigned long)arg);
+}
+
+static gboolean
+mono_running_on_valgrind (void)
+{
+#ifdef HAVE_VALGRIND_MEMCHECK_H
+ if (RUNNING_ON_VALGRIND)
+ return TRUE;
+ else
+ return FALSE;
+#else
+ return FALSE;
+#endif
+}
+
+
void mono_gc_init (void)
{
InitializeCriticalSection (&handle_section);
#ifdef WITH_INCLUDED_LIBGC
gc_thread_vtable = &mono_gc_thread_vtable;
#endif
+
+ MONO_GC_REGISTER_ROOT (gc_handles);
+ MONO_GC_REGISTER_ROOT (gc_handle_types);
+ GC_no_dls = TRUE;
+
+ GC_oom_fn = mono_gc_out_of_memory;
+
+ GC_set_warn_proc (mono_gc_warning);
#ifdef ENABLE_FINALIZER_THREAD
- if (getenv ("GC_DONT_GC")) {
+ if (g_getenv ("GC_DONT_GC")) {
+ gc_disabled = TRUE;
+ return;
+ }
+
+ /* valgrind does not play nicely with the GC,
+ * so, turn it off when we are under vg.
+ */
+ if (mono_running_on_valgrind ()) {
+ /* valgrind doesnt like g_warning for some reason... */
+ printf ("You are running under valgrind. Currently, valgrind does "
+ "not support the GC. This program will run with the GC "
+ "turned off. Your program may take up a fair amount of "
+ "memory. Also, finalizers will not be run.");
+
gc_disabled = TRUE;
return;
}
* Wait until the finalizer thread sets gc_thread since its value is needed
* by mono_thread_attach ()
*/
- WaitForSingleObject (thread_started_event, INFINITE);
+ WaitForSingleObjectEx (thread_started_event, INFINITE, FALSE);
#endif
}
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);
+ if (WaitForSingleObjectEx (shutdown_event, 2000, FALSE) == WAIT_TIMEOUT) {
+ mono_thread_stop (gc_thread);
+ }
}
#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
+}
+
#else
/* no Boehm GC support. */
{
}
+void
+mono_gc_disable (void)
+{
+}
+
+void
+mono_gc_enable (void)
+{
+}
+
#endif
gboolean
projects / mono.git / blobdiff