diff options
author | Lukas Larsson <[email protected]> | 2016-06-13 10:08:47 +0200 |
---|---|---|
committer | Lukas Larsson <[email protected]> | 2016-06-13 10:10:56 +0200 |
commit | 4e87bebe004039465548ed432d363f2d7e42fee6 (patch) | |
tree | eeaa1d1fa4a91f5e90538a70448d54eaf20fda7e /erts/emulator/beam | |
parent | 7979f72ce15ec5eeb8e0e9cfc1c291f10c4f0432 (diff) | |
download | otp-4e87bebe004039465548ed432d363f2d7e42fee6.tar.gz otp-4e87bebe004039465548ed432d363f2d7e42fee6.tar.bz2 otp-4e87bebe004039465548ed432d363f2d7e42fee6.zip |
erts: Allow enif_port_command in non-sched thread
It has to be possible to send trace messages to a port
from non-schedulers threads (specifically from the
sys_msg_dispatcher).
Diffstat (limited to 'erts/emulator/beam')
-rw-r--r-- | erts/emulator/beam/erl_nif.c | 25 |
1 files changed, 9 insertions, 16 deletions
diff --git a/erts/emulator/beam/erl_nif.c b/erts/emulator/beam/erl_nif.c index 039f97ef43..23931f0e54 100644 --- a/erts/emulator/beam/erl_nif.c +++ b/erts/emulator/beam/erl_nif.c @@ -769,32 +769,25 @@ enif_port_command(ErlNifEnv *env, const ErlNifPort* to_port, if (scheduler > 0) prt = erts_port_lookup(to_port->port_id, iflags); -#ifdef ERTS_DIRTY_SCHEDULERS - else if (scheduler < 0) { + else { +#ifdef ERTS_SMP if (ERTS_PROC_IS_EXITING(c_p)) return 0; prt = erts_thr_port_lookup(to_port->port_id, iflags); - } +#else + erts_exit(ERTS_ABORT_EXIT, + "enif_port_command: called from non-scheduler " + "thread on non-SMP VM"); #endif - else { - erts_exit(ERTS_ABORT_EXIT, "enif_port_command: " - "called from non-scheduler thread"); } if (!prt) res = 0; - else { - - if (IS_TRACED_FL(prt, F_TRACE_RECEIVE)) - trace_port_receive(prt, c_p->common.id, am_command, msg); - - res = erts_port_output_async(prt, c_p->common.id, msg); - } + else + res = erts_port_output_async(prt, c_p->common.id, msg); -#ifdef ERTS_DIRTY_SCHEDULERS - if (scheduler < 0) + if (scheduler <= 0) erts_port_dec_refc(prt); -#endif return res; } |