#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>
-
-#ifndef HIDE_POINTER
-#define HIDE_POINTER(v) (v)
-#define REVEAL_POINTER(v) (v)
-#endif
+#include <mono/metadata/marshal.h> /* for mono_delegate_free_ftnptr () */
typedef struct DomainFinalizationReq {
MonoDomain *domain;
#define GC_finalize_on_demand __imp_GC_finalize_on_demand
#endif
-static int finalize_slot = -1;
-
static gboolean gc_disabled = FALSE;
+#define mono_finalizer_lock() EnterCriticalSection (&finalizer_mutex)
+#define mono_finalizer_unlock() LeaveCriticalSection (&finalizer_mutex)
static CRITICAL_SECTION finalizer_mutex;
static GSList *domains_to_finalize= NULL;
static void object_register_finalizer (MonoObject *obj, void (*callback)(void *, void*));
-#if HAVE_BOEHM_GC
-static void finalize_notify (void);
+#ifndef HAVE_NULL_GC
static HANDLE pending_done_event;
static HANDLE shutdown_event;
static HANDLE thread_started_event;
MonoObject *o, *o2;
o = (MonoObject*)((char*)obj + GPOINTER_TO_UINT (data));
- if (finalize_slot < 0) {
- int 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 (mono_method_get_name (cm), "Finalize")) {
- finalize_slot = i;
- break;
- }
- }
- }
-
+#ifndef HAVE_SGEN_GC
mono_domain_lock (o->vtable->domain);
o2 = g_hash_table_lookup (o->vtable->domain->finalizable_objects_hash, o);
if (!o2)
/* Already finalized somehow */
return;
+#endif
/* make sure the finalizer is not called again if the object is resurrected */
object_register_finalizer (obj, NULL);
/* 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);
+ /* delegates that have a native function pointer allocated are
+ * registered for finalization, but they don't have a Finalize
+ * method, because in most cases it's not needed and it's just a waste.
+ */
+ if (o->vtable->klass->delegate) {
+ MonoDelegate* del = (MonoDelegate*)o;
+ if (del->delegate_trampoline)
+ mono_delegate_free_ftnptr ((MonoDelegate*)o);
+ return;
+ }
+
+ mono_runtime_invoke (mono_class_get_finalizer (o->vtable->klass), o, NULL, &exc);
if (exc) {
/* fixme: do something useful */
mono_domain_unlock (obj->vtable->domain);
GC_REGISTER_FINALIZER_NO_ORDER ((char*)obj - offset, callback, GUINT_TO_POINTER (offset), NULL, NULL);
+#elif defined(HAVE_SGEN_GC)
+ mono_gc_register_for_finalization (obj, callback);
#endif
}
+/**
+ * mono_object_register_finalizer:
+ * @obj: object to register
+ *
+ * Records that object @obj has a finalizer, this will call the
+ * Finalize method when the garbage collector disposes the object.
+ *
+ */
void
mono_object_register_finalizer (MonoObject *obj)
{
object_register_finalizer (obj, run_finalize);
}
-/*
+/**
* mono_domain_finalize:
+ * @domain: the domain to finalize
+ * @timeout: msects to wait for the finalization to complete
*
* 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
*/
* is still working and will take care of running the finalizers
*/
-#if HAVE_BOEHM_GC
+#ifndef HAVE_NULL_GC
if (gc_disabled)
return TRUE;
- GC_gcollect ();
+ mono_gc_collect (mono_gc_max_generation ());
done_event = CreateEvent (NULL, TRUE, FALSE, NULL);
req->domain = domain;
req->done_event = done_event;
- EnterCriticalSection (&finalizer_mutex);
+ mono_finalizer_lock ();
domains_to_finalize = g_slist_append (domains_to_finalize, req);
- LeaveCriticalSection (&finalizer_mutex);
+ mono_finalizer_unlock ();
/* Tell the finalizer thread to finalize this appdomain */
- finalize_notify ();
+ mono_gc_finalize_notify ();
res = WaitForSingleObjectEx (done_event, timeout, TRUE);
void
ves_icall_System_GC_InternalCollect (int generation)
{
- MONO_ARCH_SAVE_REGS;
-
-#if HAVE_BOEHM_GC
- GC_gcollect ();
-#endif
+ mono_gc_collect (generation);
}
gint64
{
MONO_ARCH_SAVE_REGS;
-#if HAVE_BOEHM_GC
- if (!GC_should_invoke_finalizers ())
+#ifndef HAVE_NULL_GC
+ if (!mono_gc_pending_finalizers ())
return;
if (mono_thread_current () == gc_thread)
return;
ResetEvent (pending_done_event);
- finalize_notify ();
+ mono_gc_finalize_notify ();
/* g_print ("Waiting for pending finalizers....\n"); */
WaitForSingleObjectEx (pending_done_event, INFINITE, TRUE);
/* g_print ("Done pending....\n"); */
#else
#endif
}
-
+#define mono_allocator_lock() EnterCriticalSection (&allocator_section)
+#define mono_allocator_unlock() LeaveCriticalSection (&allocator_section)
static CRITICAL_SECTION allocator_section;
static CRITICAL_SECTION handle_section;
default:
g_assert_not_reached ();
}
- return -1;
+ return 0;
}
void
guint32 size;
guint8 type;
guint slot_hint : 24; /* starting slot for search */
+ /* 2^16 appdomains should be enough for everyone (though I know I'll regret this in 20 years) */
+ /* we alloc this only for weak refs, since we can get the domain directly in the other cases */
+ guint16 *domain_ids;
} HandleData;
/* weak and weak-track arrays will be allocated in malloc memory
- * (sadly libgc still requires REVEAL/HIDE_POINTER)
*/
static HandleData gc_handles [] = {
{NULL, NULL, 0, HANDLE_WEAK, 0},
if (!handles->size) {
handles->size = 32;
if (handles->type > HANDLE_WEAK_TRACK) {
-#ifdef HAVE_BOEHM_GC
- handles->entries = GC_MALLOC (sizeof (gpointer) * handles->size);
-#else
- handles->entries = g_malloc0 (sizeof (gpointer) * handles->size);
-#endif
+ handles->entries = mono_gc_alloc_fixed (sizeof (gpointer) * handles->size, NULL);
} else {
handles->entries = g_malloc0 (sizeof (gpointer) * handles->size);
+ handles->domain_ids = g_malloc0 (sizeof (guint16) * handles->size);
}
handles->bitmap = g_malloc0 (handles->size / 8);
}
/* resize and copy the entries */
if (handles->type > HANDLE_WEAK_TRACK) {
-#ifdef HAVE_BOEHM_GC
gpointer *entries;
- entries = GC_MALLOC (sizeof (gpointer) * new_size);
+ entries = mono_gc_alloc_fixed (sizeof (gpointer) * new_size, NULL);
memcpy (entries, handles->entries, sizeof (gpointer) * handles->size);
handles->entries = entries;
-#else
- handles->entries = g_realloc (handles->entries, sizeof (gpointer) * new_size);
- memset (handles->entries + handles->size, 0, sizeof (gpointer) * handles->size);
-#endif
} else {
-#ifdef HAVE_BOEHM_GC
gpointer *entries;
+ guint16 *domain_ids;
+ domain_ids = g_malloc0 (sizeof (guint16) * new_size);
entries = g_malloc (sizeof (gpointer) * new_size);
/* we disable GC because we could lose some disappearing link updates */
mono_gc_disable ();
memcpy (entries, handles->entries, sizeof (gpointer) * handles->size);
memset (entries + handles->size, 0, sizeof (gpointer) * handles->size);
+ memcpy (domain_ids, handles->domain_ids, sizeof (guint16) * handles->size);
for (i = 0; i < handles->size; ++i) {
- GC_unregister_disappearing_link (&(handles->entries [i]));
- /*g_print ("reg/unreg entry %d of type %d at %p to object %p (%p), was: %p\n", i, handles->type, &(entries [i]), REVEAL_POINTER (entries [i]), entries [i], handles->entries [i]);*/
- if (entries [i] && entries [i] != (gpointer)-1) {
- GC_GENERAL_REGISTER_DISAPPEARING_LINK (&(entries [i]), REVEAL_POINTER (entries [i]));
+ MonoObject *obj = mono_gc_weak_link_get (&(handles->entries [i]));
+ mono_gc_weak_link_remove (&(handles->entries [i]));
+ /*g_print ("reg/unreg entry %d of type %d at %p to object %p (%p), was: %p\n", i, handles->type, &(entries [i]), obj, entries [i], handles->entries [i]);*/
+ if (obj) {
+ mono_gc_weak_link_add (&(entries [i]), obj);
}
}
g_free (handles->entries);
+ g_free (handles->domain_ids);
handles->entries = entries;
+ handles->domain_ids = domain_ids;
mono_gc_enable ();
-#else
- handles->entries = g_realloc (handles->entries, sizeof (gpointer) * new_size);
- memset (handles->entries + handles->size, 0, sizeof (gpointer) * handles->size);
-#endif
}
/* set i and slot to the next free position */
handles->bitmap [slot] |= 1 << i;
slot = slot * 32 + i;
handles->entries [slot] = obj;
-#ifdef HAVE_BOEHM_GC
if (handles->type <= HANDLE_WEAK_TRACK) {
- handles->entries [slot] = (void*)HIDE_POINTER (obj);
- GC_GENERAL_REGISTER_DISAPPEARING_LINK (&(handles->entries [slot]), obj);
+ if (obj)
+ mono_gc_weak_link_add (&(handles->entries [slot]), obj);
}
-#endif
unlock_handles (handles);
/*g_print ("allocated entry %d of type %d to object %p (in slot: %p)\n", slot, handles->type, obj, handles->entries [slot]);*/
- return (slot << 2) | handles->type;
+ return (slot << 3) | (handles->type + 1);
}
+/**
+ * mono_gchandle_new:
+ * @obj: managed object to get a handle for
+ * @pinned: whether the object should be pinned
+ *
+ * This returns a handle that wraps the object, this is used to keep a
+ * reference to a managed object from the unmanaged world and preventing the
+ * object from being disposed.
+ *
+ * If @pinned is false the address of the object can not be obtained, if it is
+ * true the address of the object can be obtained. This will also pin the
+ * object so it will not be possible by a moving garbage collector to move the
+ * object.
+ *
+ * Returns: a handle that can be used to access the object from
+ * unmanaged code.
+ */
guint32
mono_gchandle_new (MonoObject *obj, gboolean pinned)
{
return alloc_handle (&gc_handles [pinned? HANDLE_PINNED: HANDLE_NORMAL], obj);
}
+/**
+ * mono_gchandle_new_weakref:
+ * @obj: managed object to get a handle for
+ * @pinned: whether the object should be pinned
+ *
+ * This returns a weak handle that wraps the object, this is used to
+ * keep a reference to a managed object from the unmanaged world.
+ * Unlike the mono_gchandle_new the object can be reclaimed by the
+ * garbage collector. In this case the value of the GCHandle will be
+ * set to zero.
+ *
+ * If @pinned is false the address of the object can not be obtained, if it is
+ * true the address of the object can be obtained. This will also pin the
+ * object so it will not be possible by a moving garbage collector to move the
+ * object.
+ *
+ * Returns: a handle that can be used to access the object from
+ * unmanaged code.
+ */
guint32
mono_gchandle_new_weakref (MonoObject *obj, gboolean track_resurrection)
{
return alloc_handle (&gc_handles [track_resurrection? HANDLE_WEAK_TRACK: HANDLE_WEAK], obj);
}
-/* This will return NULL for a collected object if using a weakref handle */
+/**
+ * mono_gchandle_get_target:
+ * @gchandle: a GCHandle's handle.
+ *
+ * The handle was previously created by calling mono_gchandle_new or
+ * mono_gchandle_new_weakref.
+ *
+ * Returns a pointer to the MonoObject represented by the handle or
+ * NULL for a collected object if using a weakref handle.
+ */
MonoObject*
mono_gchandle_get_target (guint32 gchandle)
{
- guint slot = gchandle >> 2;
- HandleData *handles = &gc_handles [gchandle & 3];
+ guint slot = gchandle >> 3;
+ guint type = (gchandle & 7) - 1;
+ HandleData *handles = &gc_handles [type];
MonoObject *obj = NULL;
+ if (type > 3)
+ return NULL;
lock_handles (handles);
- if (slot < handles->size) {
- obj = handles->entries [slot];
+ if (slot < handles->size && (handles->bitmap [slot / 32] & (1 << (slot % 32)))) {
if (handles->type <= HANDLE_WEAK_TRACK) {
- obj = REVEAL_POINTER (obj);
- if (obj == (MonoObject *) -1)
- obj = NULL;
+ obj = mono_gc_weak_link_get (&handles->entries [slot]);
+ } else {
+ obj = handles->entries [slot];
}
} else {
/* print a warning? */
static void
mono_gchandle_set_target (guint32 gchandle, MonoObject *obj)
{
- guint slot = gchandle >> 2;
- HandleData *handles = &gc_handles [gchandle & 3];
+ guint slot = gchandle >> 3;
+ guint type = (gchandle & 7) - 1;
+ HandleData *handles = &gc_handles [type];
+ if (type > 3)
+ return;
lock_handles (handles);
- if (slot < handles->size) {
-#ifdef HAVE_BOEHM_GC
+ if (slot < handles->size && (handles->bitmap [slot / 32] & (1 << (slot % 32)))) {
if (handles->type <= HANDLE_WEAK_TRACK) {
- GC_unregister_disappearing_link (&handles->entries [slot]);
- GC_GENERAL_REGISTER_DISAPPEARING_LINK (&(handles->entries [slot]), obj);
- handles->entries [slot] = (void*)HIDE_POINTER (obj);
+ mono_gc_weak_link_remove (&handles->entries [slot]);
+ if (obj)
+ mono_gc_weak_link_add (&handles->entries [slot], obj);
} else {
handles->entries [slot] = obj;
}
-#else
- handles->entries [slot] = obj;
-#endif
} else {
/* print a warning? */
}
- /*g_print ("changed entry %d of type %d to object %p (in slot: %p)\n", slot, gchandle & 3, obj, handles->entries [slot]);*/
+ /*g_print ("changed entry %d of type %d to object %p (in slot: %p)\n", slot, handles->type, obj, handles->entries [slot]);*/
unlock_handles (handles);
}
+/**
+ * mono_gchandle_is_in_domain:
+ * @gchandle: a GCHandle's handle.
+ * @domain: An application domain.
+ *
+ * Returns: true if the object wrapped by the @gchandle belongs to the specific @domain.
+ */
+gboolean
+mono_gchandle_is_in_domain (guint32 gchandle, MonoDomain *domain)
+{
+ guint slot = gchandle >> 3;
+ guint type = (gchandle & 7) - 1;
+ HandleData *handles = &gc_handles [type];
+ gboolean result = FALSE;
+ if (type > 3)
+ return FALSE;
+ lock_handles (handles);
+ if (slot < handles->size && (handles->bitmap [slot / 32] & (1 << (slot % 32)))) {
+ if (handles->type <= HANDLE_WEAK_TRACK) {
+ result = domain->domain_id == handles->domain_ids [slot];
+ } else {
+ MonoObject *obj;
+ obj = handles->entries [slot];
+ if (obj == NULL)
+ result = TRUE;
+ else
+ result = domain == mono_object_domain (obj);
+ }
+ } else {
+ /* print a warning? */
+ }
+ unlock_handles (handles);
+ return result;
+}
+
+/**
+ * mono_gchandle_free:
+ * @gchandle: a GCHandle's handle.
+ *
+ * Frees the @gchandle handle. If there are no outstanding
+ * references, the garbage collector can reclaim the memory of the
+ * object wrapped.
+ */
void
mono_gchandle_free (guint32 gchandle)
{
- guint slot = gchandle >> 2;
- HandleData *handles = &gc_handles [gchandle & 3];
+ guint slot = gchandle >> 3;
+ guint type = (gchandle & 7) - 1;
+ HandleData *handles = &gc_handles [type];
+ if (type > 3)
+ return;
lock_handles (handles);
- if (slot < handles->size) {
-#ifdef HAVE_BOEHM_GC
+ if (slot < handles->size && (handles->bitmap [slot / 32] & (1 << (slot % 32)))) {
if (handles->type <= HANDLE_WEAK_TRACK)
- GC_unregister_disappearing_link (&handles->entries [slot]);
-#endif
- handles->entries [slot] = NULL;
+ mono_gc_weak_link_remove (&handles->entries [slot]);
+ else
+ handles->entries [slot] = NULL;
handles->bitmap [slot / 32] &= ~(1 << (slot % 32));
} else {
/* print a warning? */
}
- /*g_print ("freed entry %d of type %d\n", slot, gchandle & 3);*/
+ /*g_print ("freed entry %d of type %d\n", slot, handles->type);*/
unlock_handles (handles);
}
-#if HAVE_BOEHM_GC
+#ifndef HAVE_NULL_GC
static HANDLE finalizer_event;
static volatile gboolean finished=FALSE;
-static void finalize_notify (void)
+void
+mono_gc_finalize_notify (void)
{
#ifdef DEBUG
g_message (G_GNUC_PRETTY_FUNCTION ": prodding finalizer");
}
/* Process finalizers which are already in the queue */
- GC_invoke_finalizers ();
+ mono_gc_invoke_finalizers ();
/* printf ("DONE.\n"); */
SetEvent (req->done_event);
WaitForSingleObjectEx (finalizer_event, INFINITE, TRUE);
if (domains_to_finalize) {
- EnterCriticalSection (&finalizer_mutex);
+ mono_finalizer_lock ();
if (domains_to_finalize) {
DomainFinalizationReq *req = domains_to_finalize->data;
domains_to_finalize = g_slist_remove (domains_to_finalize, req);
- LeaveCriticalSection (&finalizer_mutex);
+ mono_finalizer_unlock ();
finalize_domain_objects (req);
}
else
- LeaveCriticalSection (&finalizer_mutex);
+ mono_finalizer_unlock ();
}
#ifdef DEBUG
/* 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 ()) {
- GC_invoke_finalizers ();
- }
+ mono_gc_invoke_finalizers ();
SetEvent (pending_done_event);
}
*/
#define ENABLE_FINALIZER_THREAD
-#ifdef WITH_INCLUDED_LIBGC
-/* from threads.c */
-extern void mono_gc_stop_world (void);
-extern void mono_gc_start_world (void);
-extern void mono_gc_push_all_stacks (void);
-
-static void mono_gc_lock (void)
-{
- EnterCriticalSection (&allocator_section);
-}
-
-static void mono_gc_unlock (void)
-{
- LeaveCriticalSection (&allocator_section);
-}
-
-static GCThreadFunctions mono_gc_thread_vtable = {
- NULL,
-
- mono_gc_lock,
- mono_gc_unlock,
-
- mono_gc_stop_world,
- NULL,
- mono_gc_push_all_stacks,
- mono_gc_start_world
-};
-#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);
-}
-
-void mono_gc_init (void)
+void
+mono_gc_init (void)
{
InitializeCriticalSection (&handle_section);
InitializeCriticalSection (&allocator_section);
InitializeCriticalSection (&finalizer_mutex);
-#ifdef WITH_INCLUDED_LIBGC
- gc_thread_vtable = &mono_gc_thread_vtable;
-#endif
-
MONO_GC_REGISTER_ROOT (gc_handles [HANDLE_NORMAL].entries);
MONO_GC_REGISTER_ROOT (gc_handles [HANDLE_PINNED].entries);
- GC_no_dls = TRUE;
- GC_oom_fn = mono_gc_out_of_memory;
-
- GC_set_warn_proc (mono_gc_warning);
+ mono_gc_base_init ();
#ifdef ENABLE_FINALIZER_THREAD
g_assert_not_reached ();
}
- GC_finalize_on_demand = 1;
- GC_finalizer_notifier = finalize_notify;
-
mono_thread_create (mono_domain_get (), finalizer_thread, NULL);
/*
* Wait until the finalizer thread sets gc_thread since its value is needed
ResetEvent (shutdown_event);
finished = TRUE;
if (mono_thread_current () != gc_thread) {
- finalize_notify ();
+ mono_gc_finalize_notify ();
/* Finishing the finalizer thread, so wait a little bit... */
/* MS seems to wait for about 2 seconds */
- if (WaitForSingleObjectEx (shutdown_event, 2000000, FALSE) == WAIT_TIMEOUT) {
+ if (WaitForSingleObjectEx (shutdown_event, 2000, FALSE) == WAIT_TIMEOUT) {
mono_thread_stop (gc_thread);
}
}
gc_thread = NULL;
+#ifdef HAVE_BOEHM_GC
GC_finalizer_notifier = NULL;
+#endif
}
#endif
#endif
+/**
+ * mono_gc_is_finalizer_thread:
+ * @thread: the thread to test.
+ *
+ * In Mono objects are finalized asynchronously on a separate thread.
+ * This routine tests whether the @thread argument represents the
+ * finalization thread.
+ *
+ * Returns true if @thread is the finalization thread.
+ */
gboolean
mono_gc_is_finalizer_thread (MonoThread *thread)
{
projects / mono.git / blobdiff