diff options
| author | Rickard Green <[email protected]> | 2016-10-21 14:05:11 +0200 |
|---|---|---|
| committer | Rickard Green <[email protected]> | 2016-11-22 16:21:09 +0100 |
| commit | dd2e99bdd726d4322c8e07c81731ad66ae05176e (patch) | |
| tree | 8ed35c084215aaf1a30d774f2126ab0b3646b7ec | |
| parent | a532df810da29fcb28d142d244b6b3c812fa33ca (diff) | |
| download | otp-dd2e99bdd726d4322c8e07c81731ad66ae05176e.tar.gz otp-dd2e99bdd726d4322c8e07c81731ad66ae05176e.tar.bz2 otp-dd2e99bdd726d4322c8e07c81731ad66ae05176e.zip | |
Fix send of exit signal to process executing dirty
| -rw-r--r-- | erts/emulator/beam/erl_process.c | 34 |
1 files changed, 28 insertions, 6 deletions
diff --git a/erts/emulator/beam/erl_process.c b/erts/emulator/beam/erl_process.c index 59ee84d115..86a997de65 100644 --- a/erts/emulator/beam/erl_process.c +++ b/erts/emulator/beam/erl_process.c @@ -12405,6 +12405,8 @@ send_exit_signal(Process *c_p, /* current process if and only else if (!(state & (ERTS_PSFLG_RUNNING|ERTS_PSFLG_RUNNING_SYS))) { /* Process not running ... */ ErtsProcLocks need_locks = ~(*rp_locks) & ERTS_PROC_LOCKS_ALL; + ErlHeapFragment *bp = NULL; + Eterm rsn_cpy; if (need_locks && erts_smp_proc_trylock(rp, need_locks) == EBUSY) { /* ... but we havn't got all locks on it ... */ @@ -12417,12 +12419,32 @@ send_exit_signal(Process *c_p, /* current process if and only } /* ...and we have all locks on it... */ *rp_locks = ERTS_PROC_LOCKS_ALL; - set_proc_exiting(rp, - state, - (is_immed(rsn) - ? rsn - : copy_object(rsn, rp)), - NULL); + + state = erts_smp_atomic32_read_nob(&rp->state); + + if (is_immed(rsn)) + rsn_cpy = rsn; + else { + Eterm *hp; + ErlOffHeap *ohp; + Uint rsn_sz = size_object(rsn); +#ifdef ERTS_DIRTY_SCHEDULERS + if (state & (ERTS_PSFLG_DIRTY_RUNNING + | ERTS_PSFLG_DIRTY_RUNNING_SYS)) { + bp = new_message_buffer(rsn_sz); + ohp = &bp->off_heap; + hp = &bp->mem[0]; + } + else +#endif + { + hp = HAlloc(rp, rsn_sz); + ohp = &rp->off_heap; + } + rsn_cpy = copy_struct(rsn, rsn_sz, &hp, ohp); + } + + set_proc_exiting(rp, state, rsn_cpy, bp); } else { /* Process running... */ |