diff options
author | Rickard Green <[email protected]> | 2018-09-06 14:20:22 +0200 |
---|---|---|
committer | Rickard Green <[email protected]> | 2018-09-06 14:20:22 +0200 |
commit | eb538b5bff24ba3144f0646e1a24174e62218479 (patch) | |
tree | f7a18e02fd1cc4f8f5abb04a032afd0cd8095e76 /erts/emulator/beam/erl_node_tables.c | |
parent | 6f44c787bd543dbf0f0d7a02baae175e822d5802 (diff) | |
parent | 30e5321740b96b3a8984611b6f821692716d0555 (diff) | |
download | otp-eb538b5bff24ba3144f0646e1a24174e62218479.tar.gz otp-eb538b5bff24ba3144f0646e1a24174e62218479.tar.bz2 otp-eb538b5bff24ba3144f0646e1a24174e62218479.zip |
Merge branch 'maint-21' into maint
* maint-21:
Updated OTP version
Update release notes
Update version numbers
kernel: Fix missing abort_connection in net_kernel
Prevent inconsistent node lists
Fix an endless rescheduling loop when a process is executing process_info(self(), ...)
Diffstat (limited to 'erts/emulator/beam/erl_node_tables.c')
-rw-r--r-- | erts/emulator/beam/erl_node_tables.c | 38 |
1 files changed, 38 insertions, 0 deletions
diff --git a/erts/emulator/beam/erl_node_tables.c b/erts/emulator/beam/erl_node_tables.c index 1f147011a8..9b34af1480 100644 --- a/erts/emulator/beam/erl_node_tables.c +++ b/erts/emulator/beam/erl_node_tables.c @@ -412,6 +412,44 @@ static void schedule_delete_dist_entry(DistEntry* dep) static void start_timer_delete_dist_entry(void *vdep) { + DistEntry *dep = vdep; + Eterm sysname; + enum dist_entry_state state; + Uint32 connection_id; + + erts_de_rlock(dep); + state = dep->state; + connection_id = dep->connection_id; + sysname = dep->sysname; + erts_de_runlock(dep); + + if (state != ERTS_DE_STATE_IDLE) { + char *state_str; + erts_dsprintf_buf_t *dsbuf = erts_create_logger_dsbuf(); + switch (state) { + case ERTS_DE_STATE_CONNECTED: + state_str = "connected"; + break; + case ERTS_DE_STATE_PENDING: + state_str = "pending connect"; + break; + case ERTS_DE_STATE_EXITING: + state_str = "exiting"; + break; + case ERTS_DE_STATE_IDLE: + state_str = "idle"; + break; + default: + state_str = "unknown"; + break; + } + erts_dsprintf(dsbuf, "Garbage collecting distribution " + "entry for node %T in state: %s", + sysname, state_str); + erts_send_error_to_logger_nogl(dsbuf); + erts_abort_connection(dep, connection_id); + } + if (node_tab_delete_delay == 0) { prepare_try_delete_dist_entry(vdep); } |