X-Git-Url: http://git.megacz.com/?p=ghc-hetmet.git;a=blobdiff_plain;f=rts%2FRtsStartup.c;h=951b07fab2ced78a87622f8d0d8b2de1ddbb9edb;hp=f0b39d6a0a912370bfa314c32a894253b62a5cd5;hb=596cacfe4e9463d1fd66c3292bef7432cfb1b17a;hpb=897bcbf84da1b217503e86910ac27255106fc026 diff --git a/rts/RtsStartup.c b/rts/RtsStartup.c index f0b39d6..951b07f 100644 --- a/rts/RtsStartup.c +++ b/rts/RtsStartup.c @@ -199,6 +199,7 @@ hs_init(int *argc, char **argv[]) /* Parse the flags, separating the RTS flags from the programs args */ if (argc != NULL && argv != NULL) { + setFullProgArgv(*argc,*argv); setupRtsFlags(argc, *argv, &rts_argc, rts_argv); setProgArgv(*argc,*argv); } @@ -213,9 +214,6 @@ hs_init(int *argc, char **argv[]) synchroniseSystem(); // calls initParallelSystem etc #endif /* PAR */ - /* Perform initialisation of adjustor thunk layer. */ - initAdjustor(); - /* initialise scheduler data structures (needs to be done before * initStorage()). */ @@ -357,12 +355,25 @@ hs_add_root(void (*init_root)(void)) initProfiling2(); } -/* ----------------------------------------------------------------------------- - Shutting down the RTS - -------------------------------------------------------------------------- */ +/* ---------------------------------------------------------------------------- + * Shutting down the RTS + * + * The wait_foreign parameter means: + * True ==> wait for any threads doing foreign calls now. + * False ==> threads doing foreign calls may return in the + * future, but will immediately block on a mutex. + * (capability->lock). + * + * If this RTS is a DLL that we're about to unload, then you want + * safe=True, otherwise the thread might return to code that has been + * unloaded. If this is a standalone program that is about to exit, + * then you can get away with safe=False, which is better because we + * won't hang on exit if there is a blocked foreign call outstanding. + * + ------------------------------------------------------------------------- */ -void -hs_exit(void) +static void +hs_exit_(rtsBool wait_foreign) { if (hs_init_count <= 0) { errorBelch("warning: too many hs_exit()s"); @@ -388,7 +399,7 @@ hs_exit(void) #endif /* stop all running tasks */ - exitScheduler(); + exitScheduler(wait_foreign); #if defined(GRAN) /* end_gr_simulation prints global stats if requested -- HWL */ @@ -452,8 +463,6 @@ hs_exit(void) /* free the stable pointer table */ exitStablePtrTable(); - freeProfiling1(); - #if defined(DEBUG) /* free the thread label table */ freeThreadLabelTable(); @@ -469,6 +478,8 @@ hs_exit(void) reportCCSProfiling(); #endif + freeProfiling1(); + endProfiling(); #ifdef PROFILING @@ -483,7 +494,7 @@ hs_exit(void) #endif #if defined(mingw32_HOST_OS) && !defined(THREADED_RTS) - shutdownAsyncIO(); + shutdownAsyncIO(wait_foreign); #endif /* free hash table storage */ @@ -499,6 +510,14 @@ hs_exit(void) } +// The real hs_exit(): +void +hs_exit(void) +{ + hs_exit_(rtsTrue); + // be safe; this might be a DLL +} + // Compatibility interfaces void shutdownHaskell(void) @@ -511,7 +530,8 @@ shutdownHaskellAndExit(int n) { if (hs_init_count == 1) { OnExitHook(); - hs_exit(); + hs_exit_(rtsFalse); + // we're about to exit(), no need to wait for foreign calls to return. #if defined(PAR) /* really exit (stg_exit() would call shutdownParallelSystem() again) */ exit(n);