mono/native/pal-icalls.c

   1 /**
   2  * \file
   3  * System.Native PAL internal calls
   4  * Adapter code between the Mono runtime and the CoreFX Platform Abstraction Layer (PAL)
   5  * Copyright 2018 Microsoft
   6  * Licensed under the MIT license. See LICENSE file in the project root for full license information.
   7 */
   8
   9 #if !defined (HOST_WATCHOS) && !defined (HOST_TVOS) /* These platforms don't support async suspend and do not need this code for now */
  10
  11 #include <config.h>
  12 #include <glib.h>
  13 #include "mono/utils/mono-threads-api.h"
  14 #include "mono/utils/atomic.h"
  15 #include "mono/metadata/icall-internals.h"
  16 #include "pal-icalls.h"
  17
  18
  19 /*
  20  * mono_pal_init:
  21  *
  22  *      Initializes Mono's usage of the PAL (probably just by registering the necessary internal calls).
  23  *      This is called only from managed code, by any Interop.* classes that need to use the code here.
  24  *      The function may be called multiple times.
  25  *
  26  */
  27 void
  28 mono_pal_init (void)
  29 {
  30         volatile static gboolean module_initialized = FALSE;
  31         if (mono_atomic_cas_i32 (&module_initialized, TRUE, FALSE) == FALSE) {
  32                 mono_add_internal_call_with_flags ("Interop/Sys::Read", ves_icall_Interop_Sys_Read, TRUE);
  33
  34 #if defined(__APPLE__)
  35                 mono_add_internal_call_with_flags ("Interop/RunLoop::CFRunLoopRun", ves_icall_Interop_RunLoop_CFRunLoopRun, TRUE);
  36 #endif
  37         }
  38
  39 }
  40
  41 gint32
  42 ves_icall_Interop_Sys_Read (intptr_t fd, gchar* buffer, gint32 count)
  43 {
  44         gint32 result;
  45         MONO_ENTER_GC_SAFE;
  46         result = SystemNative_Read (fd, buffer, count);
  47         mono_marshal_set_last_error ();
  48         MONO_EXIT_GC_SAFE;
  49         return result;
  50 }
  51
  52 #if defined(__APPLE__)
  53
  54 #include <CoreFoundation/CFRunLoop.h>
  55
  56 static void
  57 interrupt_CFRunLoop (gpointer data)
  58 {
  59         g_assert (data);
  60         CFRunLoopStop ((CFRunLoopRef)data);
  61 }
  62
  63 void
  64 ves_icall_Interop_RunLoop_CFRunLoopRun (void)
  65 {
  66         gpointer runloop_ref = CFRunLoopGetCurrent ();
  67         gboolean interrupted;
  68         mono_thread_info_install_interrupt (interrupt_CFRunLoop, runloop_ref, &interrupted);
  69
  70         if (interrupted)
  71                 return;
  72
  73         MONO_ENTER_GC_SAFE;
  74         CFRunLoopRun ();
  75         MONO_EXIT_GC_SAFE;
  76
  77         mono_thread_info_uninstall_interrupt (&interrupted);
  78 }
  79
  80 #endif
  81
  82 #endif /* !defined (HOST_WATCHOS) && !defined (HOST_TVOS) */