/*
* %CopyrightBegin%
*
* Copyright Ericsson AB 2003-2013. All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*
* %CopyrightEnd%
*/
#ifdef HAVE_CONFIG_H
# include "config.h"
#endif
#include "sys.h"
#include "erl_vm.h"
#include "global.h"
#include "erl_process.h"
#include "error.h"
#include "bif.h"
#include "erl_db.h"
#include "dist.h"
#include "beam_catches.h"
#include "erl_binary.h"
#define ERTS_WANT_EXTERNAL_TAGS
#include "external.h"
#define PTR_FMT "%bpX"
#define ETERM_FMT "%beX"
#define OUR_NIL _make_header(0,_TAG_HEADER_FLOAT)
static void dump_process_info(int to, void *to_arg, Process *p);
static void dump_element(int to, void *to_arg, Eterm x);
static void dump_dist_ext(int to, void *to_arg, ErtsDistExternal *edep);
static void dump_element_nl(int to, void *to_arg, Eterm x);
static int stack_element_dump(int to, void *to_arg, Eterm* sp,
int yreg);
static void stack_trace_dump(int to, void *to_arg, Eterm* sp);
static void print_function_from_pc(int to, void *to_arg, BeamInstr* x);
static void heap_dump(int to, void *to_arg, Eterm x);
static void dump_binaries(int to, void *to_arg, Binary* root);
static void dump_externally(int to, void *to_arg, Eterm term);
static Binary* all_binaries;
extern BeamInstr beam_apply[];
extern BeamInstr beam_exit[];
extern BeamInstr beam_continue_exit[];
void
erts_deep_process_dump(int to, void *to_arg)
{
int i, max = erts_ptab_max(&erts_proc);
all_binaries = NULL;
for (i = 0; i < max; i++) {
Process *p = erts_pix2proc(i);
if (p && p->i != ENULL) {
erts_aint32_t state = erts_smp_atomic32_read_acqb(&p->state);
if (!(state & (ERTS_PSFLG_EXITING|ERTS_PSFLG_GC)))
dump_process_info(to, to_arg, p);
}
}
dump_binaries(to, to_arg, all_binaries);
}
Uint erts_process_memory(Process *p) {
ErlMessage *mp;
Uint size = 0;
struct saved_calls *scb;
size += sizeof(Process);
ERTS_SMP_MSGQ_MV_INQ2PRIVQ(p);
erts_doforall_links(ERTS_P_LINKS(p), &erts_one_link_size, &size);
erts_doforall_monitors(ERTS_P_MONITORS(p), &erts_one_mon_size, &size);
size += (p->heap_sz + p->mbuf_sz) * sizeof(Eterm);
if (p->old_hend && p->old_heap)
size += (p->old_hend - p->old_heap) * sizeof(Eterm);
size += p->msg.len * sizeof(ErlMessage);
for (mp = p->msg.first; mp; mp = mp->next)
if (mp->data.attached)
size += erts_msg_attached_data_size(mp)*sizeof(Eterm);
if (p->arg_reg != p->def_arg_reg) {
size += p->arity * sizeof(p->arg_reg[0]);
}
if (p->psd)
size += sizeof(ErtsPSD);
scb = ERTS_PROC_GET_SAVED_CALLS_BUF(p);
if (scb) {
size += (sizeof(struct saved_calls)
+ (scb->len-1) * sizeof(scb->ct[0]));
}
size += erts_dicts_mem_size(p);
return size;
}
static void
dump_process_info(int to, void *to_arg, Process *p)
{
Eterm* sp;
ErlMessage* mp;
int yreg = -1;
ERTS_SMP_MSGQ_MV_INQ2PRIVQ(p);
if ((ERTS_TRACE_FLAGS(p) & F_SENSITIVE) == 0 && p->msg.first) {
erts_print(to, to_arg, "=proc_messages:%T\n", p->common.id);
for (mp = p->msg.first; mp != NULL; mp = mp->next) {
Eterm mesg = ERL_MESSAGE_TERM(mp);
if (is_value(mesg))
dump_element(to, to_arg, mesg);
else
dump_dist_ext(to, to_arg, mp->data.dist_ext);
mesg = ERL_MESSAGE_TOKEN(mp);
erts_print(to, to_arg, ":");
dump_element(to, to_arg, mesg);
erts_print(to, to_arg, "\n");
}
}
if ((ERTS_TRACE_FLAGS(p) & F_SENSITIVE) == 0) {
if (p->dictionary) {
erts_print(to, to_arg, "=proc_dictionary:%T\n", p->common.id);
erts_deep_dictionary_dump(to, to_arg,
p->dictionary, dump_element_nl);
}
}
if ((ERTS_TRACE_FLAGS(p) & F_SENSITIVE) == 0) {
erts_print(to, to_arg, "=proc_stack:%T\n", p->common.id);
for (sp = p->stop; sp < STACK_START(p); sp++) {
yreg = stack_element_dump(to, to_arg, sp, yreg);
}
erts_print(to, to_arg, "=proc_heap:%T\n", p->common.id);
for (sp = p->stop; sp < STACK_START(p); sp++) {
Eterm term = *sp;
if (!is_catch(term) && !is_CP(term)) {
heap_dump(to, to_arg, term);
}
}
for (mp = p->msg.first; mp != NULL; mp = mp->next) {
Eterm mesg = ERL_MESSAGE_TERM(mp);
if (is_value(mesg))
heap_dump(to, to_arg, mesg);
mesg = ERL_MESSAGE_TOKEN(mp);
heap_dump(to, to_arg, mesg);
}
if (p->dictionary) {
erts_deep_dictionary_dump(to, to_arg, p->dictionary, heap_dump);
}
}
}
static void
dump_dist_ext(int to, void *to_arg, ErtsDistExternal *edep)
{
if (!edep)
erts_print(to, to_arg, "D0:E0:");
else {
byte *e;
size_t sz;
if (!(edep->flags & ERTS_DIST_EXT_ATOM_TRANS_TAB))
erts_print(to, to_arg, "D0:");
else {
int i;
erts_print(to, to_arg, "D%X:", edep->attab.size);
for (i = 0; i < edep->attab.size; i++)
dump_element(to, to_arg, edep->attab.atom[i]);
}
sz = edep->ext_endp - edep->extp;
e = edep->extp;
if (edep->flags & ERTS_DIST_EXT_DFLAG_HDR) {
ASSERT(*e != VERSION_MAGIC);
sz++;
}
else {
ASSERT(*e == VERSION_MAGIC);
}
erts_print(to, to_arg, "E%X:", sz);
if (edep->flags & ERTS_DIST_EXT_DFLAG_HDR)
erts_print(to, to_arg, "%02X", VERSION_MAGIC);
while (e < edep->ext_endp)
erts_print(to, to_arg, "%02X", *e++);
}
}
static void
dump_element(int to, void *to_arg, Eterm x)
{
if (is_list(x)) {
erts_print(to, to_arg, "H" PTR_FMT, list_val(x));
} else if (is_boxed(x)) {
erts_print(to, to_arg, "H" PTR_FMT, boxed_val(x));
} else if (is_immed(x)) {
if (is_atom(x)) {
unsigned char* s = atom_tab(atom_val(x))->name;
int len = atom_tab(atom_val(x))->len;
int i;
erts_print(to, to_arg, "A%X:", atom_tab(atom_val(x))->len);
for (i = 0; i < len; i++) {
erts_putc(to, to_arg, *s++);
}
} else if (is_small(x)) {
erts_print(to, to_arg, "I%T", x);
} else if (is_pid(x)) {
erts_print(to, to_arg, "P%T", x);
} else if (is_port(x)) {
erts_print(to, to_arg, "p<%beu.%beu>",
port_channel_no(x), port_number(x));
} else if (is_nil(x)) {
erts_putc(to, to_arg, 'N');
}
}
}
static void
dump_element_nl(int to, void *to_arg, Eterm x)
{
dump_element(to, to_arg, x);
erts_putc(to, to_arg, '\n');
}
static void
stack_trace_dump(int to, void *to_arg, Eterm *sp) {
Eterm x = *sp;
if (is_CP(x)) {
erts_print(to, to_arg, "%p:", sp);
erts_print(to, to_arg, "SReturn addr 0x%X (", cp_val(x));
print_function_from_pc(to, to_arg, cp_val(x));
erts_print(to, to_arg, ")\n");
}
}
void
erts_limited_stack_trace(int to, void *to_arg, Process *p)
{
Eterm* sp;
if (ERTS_TRACE_FLAGS(p) & F_SENSITIVE) {
return;
}
if (STACK_START(p) < STACK_TOP(p)) {
return;
}
if ((STACK_START(p) - STACK_TOP(p)) < 512) {
if (erts_sys_is_area_readable((char*)STACK_TOP(p),
(char*)STACK_START(p)))
for (sp = STACK_TOP(p); sp < STACK_START(p); sp++)
stack_trace_dump(to, to_arg, sp);
else
erts_print(to, to_arg, "Could not read from stack memory: %p - %p\n",
STACK_TOP(p), STACK_START(p));
} else {
sp = STACK_TOP(p);
if (erts_sys_is_area_readable((char*)STACK_TOP(p),
(char*)(STACK_TOP(p) + 25)))
for (; sp < (STACK_TOP(p) + 256); sp++)
stack_trace_dump(to, to_arg, sp);
else
erts_print(to, to_arg, "Could not read from stack memory: %p - %p\n",
STACK_TOP(p), STACK_TOP(p) + 256);
erts_print(to, to_arg, "%p: skipping %d frames\n",
sp, STACK_START(p) - STACK_TOP(p) - 512);
if (erts_sys_is_area_readable((char*)(STACK_START(p) - 256),
(char*)STACK_START(p)))
for (sp = STACK_START(p) - 256; sp < STACK_START(p); sp++)
stack_trace_dump(to, to_arg, sp);
else
erts_print(to, to_arg, "Could not read from stack memory: %p - %p\n",
STACK_START(p) - 256, STACK_START(p));
}
}
static int
stack_element_dump(int to, void *to_arg, Eterm* sp, int yreg)
{
Eterm x = *sp;
if (yreg < 0 || is_CP(x)) {
erts_print(to, to_arg, "%p:", sp);
} else {
erts_print(to, to_arg, "y%d:", yreg);
yreg++;
}
if (is_CP(x)) {
erts_print(to, to_arg, "SReturn addr 0x%X (", cp_val(x));
print_function_from_pc(to, to_arg, cp_val(x));
erts_print(to, to_arg, ")\n");
yreg = 0;
} else if is_catch(x) {
erts_print(to, to_arg, "SCatch 0x%X (", catch_pc(x));
print_function_from_pc(to, to_arg, catch_pc(x));
erts_print(to, to_arg, ")\n");
} else {
dump_element(to, to_arg, x);
erts_putc(to, to_arg, '\n');
}
return yreg;
}
static void
print_function_from_pc(int to, void *to_arg, BeamInstr* x)
{
BeamInstr* addr = find_function_from_pc(x);
if (addr == NULL) {
if (x == beam_exit) {
erts_print(to, to_arg, "<terminate process>");
} else if (x == beam_continue_exit) {
erts_print(to, to_arg, "<continue terminate process>");
} else if (x == beam_apply+1) {
erts_print(to, to_arg, "<terminate process normally>");
} else {
erts_print(to, to_arg, "unknown function");
}
} else {
erts_print(to, to_arg, "%T:%T/%bpu + %bpu",
addr[0], addr[1], addr[2], ((x-addr)-2) * sizeof(Eterm));
}
}
static void
heap_dump(int to, void *to_arg, Eterm x)
{
DeclareTmpHeapNoproc(last,1);
Eterm* next = last;
Eterm* ptr;
if (is_immed(x) || is_CP(x)) {
return;
}
UseTmpHeapNoproc(1);
*last = OUR_NIL;
while (x != OUR_NIL) {
if (is_CP(x)) {
next = (Eterm *) EXPAND_POINTER(x);
} else if (is_list(x)) {
ptr = list_val(x);
if (ptr[0] != OUR_NIL) {
erts_print(to, to_arg, PTR_FMT ":l", ptr);
dump_element(to, to_arg, ptr[0]);
erts_putc(to, to_arg, '|');
dump_element(to, to_arg, ptr[1]);
erts_putc(to, to_arg, '\n');
if (is_immed(ptr[1])) {
ptr[1] = make_small(0);
}
x = ptr[0];
ptr[0] = (Eterm) COMPRESS_POINTER(next);
next = ptr + 1;
continue;
}
} else if (is_boxed(x)) {
Eterm hdr;
ptr = boxed_val(x);
hdr = *ptr;
if (hdr != OUR_NIL) { /* If not visited */
erts_print(to, to_arg, PTR_FMT ":", ptr);
if (is_arity_value(hdr)) {
Uint i;
Uint arity = arityval(hdr);
erts_print(to, to_arg, "t" ETERM_FMT ":", arity);
for (i = 1; i <= arity; i++) {
dump_element(to, to_arg, ptr[i]);
if (is_immed(ptr[i])) {
ptr[i] = make_small(0);
}
if (i < arity) {
erts_putc(to, to_arg, ',');
}
}
erts_putc(to, to_arg, '\n');
if (arity == 0) {
ptr[0] = OUR_NIL;
} else {
x = ptr[arity];
ptr[0] = (Eterm) COMPRESS_POINTER(next);
next = ptr + arity - 1;
continue;
}
} else if (hdr == HEADER_FLONUM) {
FloatDef f;
char sbuf[31];
int i;
GET_DOUBLE_DATA((ptr+1), f);
i = sys_double_to_chars(f.fd, (char*) sbuf, sizeof(sbuf));
sys_memset(sbuf+i, 0, 31-i);
erts_print(to, to_arg, "F%X:%s\n", i, sbuf);
*ptr = OUR_NIL;
} else if (_is_bignum_header(hdr)) {
erts_print(to, to_arg, "B%T\n", x);
*ptr = OUR_NIL;
} else if (is_binary_header(hdr)) {
Uint tag = thing_subtag(hdr);
Uint size = binary_size(x);
Uint i;
if (tag == HEAP_BINARY_SUBTAG) {
byte* p;
erts_print(to, to_arg, "Yh%X:", size);
p = binary_bytes(x);
for (i = 0; i < size; i++) {
erts_print(to, to_arg, "%02X", p[i]);
}
} else if (tag == REFC_BINARY_SUBTAG) {
ProcBin* pb = (ProcBin *) binary_val(x);
Binary* val = pb->val;
if (erts_smp_atomic_xchg_nob(&val->refc, 0) != 0) {
val->flags = (UWord) all_binaries;
all_binaries = val;
}
erts_print(to, to_arg,
"Yc" PTR_FMT ":" PTR_FMT ":" PTR_FMT,
val,
pb->bytes - (byte *)val->orig_bytes,
size);
} else if (tag == SUB_BINARY_SUBTAG) {
ErlSubBin* Sb = (ErlSubBin *) binary_val(x);
Eterm* real_bin;
void* val;
/*
* Must use boxed_val() here, because the original
* binary may have been visited and have had its
* header word changed to OUR_NIL (in which case
* binary_val() will cause an assertion failure in
* the DEBUG emulator).
*/
real_bin = boxed_val(Sb->orig);
if (thing_subtag(*real_bin) == REFC_BINARY_SUBTAG) {
/*
* Unvisited REFC_BINARY: Point directly to
* the binary.
*/
ProcBin* pb = (ProcBin *) real_bin;
val = pb->val;
} else {
/*
* Heap binary or visited REFC binary: Point
* to heap binary or ProcBin on the heap.
*/
val = real_bin;
}
erts_print(to, to_arg,
"Ys" PTR_FMT ":" PTR_FMT ":" PTR_FMT,
val, Sb->offs, size);
}
erts_putc(to, to_arg, '\n');
*ptr = OUR_NIL;
} else if (is_external_pid_header(hdr)) {
erts_print(to, to_arg, "P%T\n", x);
*ptr = OUR_NIL;
} else if (is_external_port_header(hdr)) {
erts_print(to, to_arg, "p<%beu.%beu>\n",
port_channel_no(x), port_number(x));
*ptr = OUR_NIL;
} else {
/*
* All other we dump in the external term format.
*/
dump_externally(to, to_arg, x);
erts_putc(to, to_arg, '\n');
*ptr = OUR_NIL;
}
}
}
x = *next;
*next = OUR_NIL;
next--;
}
UnUseTmpHeapNoproc(1);
}
static void
dump_binaries(int to, void *to_arg, Binary* current)
{
while (current) {
long i;
long size = current->orig_size;
byte* bytes = (byte*) current->orig_bytes;
erts_print(to, to_arg, "=binary:" PTR_FMT "\n", current);
erts_print(to, to_arg, "%X:", size);
for (i = 0; i < size; i++) {
erts_print(to, to_arg, "%02X", bytes[i]);
}
erts_putc(to, to_arg, '\n');
current = (Binary *) current->flags;
}
}
static void
dump_externally(int to, void *to_arg, Eterm term)
{
byte sbuf[1024]; /* encode and hope for the best ... */
byte* s;
byte* p;
if (is_fun(term)) {
/*
* The fun's environment used to cause trouble. There were
* two kind of problems:
*
* 1. A term used in the environment could already have been
* dumped and thus destroyed (since dumping is destructive).
*
* 2. A term in the environment could be too big, so that
* the buffer for external format overflowed (allocating
* memory is not really a solution, as it could be exhausted).
*
* Simple solution: Set all variables in the environment to NIL.
* The crashdump_viewer does not allow inspection of them anyway.
*/
ErlFunThing* funp = (ErlFunThing *) fun_val(term);
Uint num_free = funp->num_free;
Uint i;
for (i = 0; i < num_free; i++) {
funp->env[i] = NIL;
}
}
s = p = sbuf;
erts_encode_ext(term, &p);
erts_print(to, to_arg, "E%X:", p-s);
while (s < p) {
erts_print(to, to_arg, "%02X", *s++);
}
}
void erts_dump_process_state(int to, void *to_arg, erts_aint32_t psflg) {
if (psflg & ERTS_PSFLG_FREE)
erts_print(to, to_arg, "Non Existing\n"); /* Should never happen */
else if (psflg & ERTS_PSFLG_EXITING)
erts_print(to, to_arg, "Exiting\n");
else if (psflg & ERTS_PSFLG_GC) {
erts_print(to, to_arg, "Garbing\n");
}
else if (psflg & ERTS_PSFLG_SUSPENDED)
erts_print(to, to_arg, "Suspended\n");
else if (psflg & ERTS_PSFLG_RUNNING) {
erts_print(to, to_arg, "Running\n");
}
else if (psflg & ERTS_PSFLG_ACTIVE)
erts_print(to, to_arg, "Scheduled\n");
else
erts_print(to, to_arg, "Waiting\n");
}
void
erts_dump_extended_process_state(int to, void *to_arg, erts_aint32_t psflg) {
int i;
switch (ERTS_PSFLGS_GET_ACT_PRIO(psflg)) {
case PRIORITY_MAX: erts_print(to, to_arg, "ACT_PRIO_MAX | "); break;
case PRIORITY_HIGH: erts_print(to, to_arg, "ACT_PRIO_HIGH | "); break;
case PRIORITY_NORMAL: erts_print(to, to_arg, "ACT_PRIO_NORMAL | "); break;
case PRIORITY_LOW: erts_print(to, to_arg, "ACT_PRIO_LOW | "); break;
}
switch (ERTS_PSFLGS_GET_USR_PRIO(psflg)) {
case PRIORITY_MAX: erts_print(to, to_arg, "USR_PRIO_MAX | "); break;
case PRIORITY_HIGH: erts_print(to, to_arg, "USR_PRIO_HIGH | "); break;
case PRIORITY_NORMAL: erts_print(to, to_arg, "USR_PRIO_NORMAL | "); break;
case PRIORITY_LOW: erts_print(to, to_arg, "USR_PRIO_LOW | "); break;
}
switch (ERTS_PSFLGS_GET_PRQ_PRIO(psflg)) {
case PRIORITY_MAX: erts_print(to, to_arg, "PRQ_PRIO_MAX"); break;
case PRIORITY_HIGH: erts_print(to, to_arg, "PRQ_PRIO_HIGH"); break;
case PRIORITY_NORMAL: erts_print(to, to_arg, "PRQ_PRIO_NORMAL"); break;
case PRIORITY_LOW: erts_print(to, to_arg, "PRQ_PRIO_LOW"); break;
}
psflg &= ~(ERTS_PSFLGS_ACT_PRIO_MASK |
ERTS_PSFLGS_USR_PRIO_MASK |
ERTS_PSFLGS_PRQ_PRIO_MASK);
if (psflg)
erts_print(to, to_arg, " | ");
for (i = 0; i < ERTS_PSFLG_MAX && psflg; i++) {
erts_aint32_t chk = (1 << i);
if (psflg & chk) {
switch (chk) {
case ERTS_PSFLG_IN_PRQ_MAX:
erts_print(to, to_arg, "IN_PRQ_MAX"); break;
case ERTS_PSFLG_IN_PRQ_HIGH:
erts_print(to, to_arg, "IN_PRQ_HIGH"); break;
case ERTS_PSFLG_IN_PRQ_NORMAL:
erts_print(to, to_arg, "IN_PRQ_NORMAL"); break;
case ERTS_PSFLG_IN_PRQ_LOW:
erts_print(to, to_arg, "IN_PRQ_LOW"); break;
case ERTS_PSFLG_FREE:
erts_print(to, to_arg, "FREE"); break;
case ERTS_PSFLG_EXITING:
erts_print(to, to_arg, "EXITING"); break;
case ERTS_PSFLG_PENDING_EXIT:
erts_print(to, to_arg, "PENDING_EXIT"); break;
case ERTS_PSFLG_ACTIVE:
erts_print(to, to_arg, "ACTIVE"); break;
case ERTS_PSFLG_IN_RUNQ:
erts_print(to, to_arg, "IN_RUNQ"); break;
case ERTS_PSFLG_RUNNING:
erts_print(to, to_arg, "RUNNING"); break;
case ERTS_PSFLG_SUSPENDED:
erts_print(to, to_arg, "SUSPENDED"); break;
case ERTS_PSFLG_GC:
erts_print(to, to_arg, "GC"); break;
case ERTS_PSFLG_BOUND:
erts_print(to, to_arg, "BOUND"); break;
case ERTS_PSFLG_TRAP_EXIT:
erts_print(to, to_arg, "TRAP_EXIT"); break;
case ERTS_PSFLG_ACTIVE_SYS:
erts_print(to, to_arg, "ACTIVE_SYS"); break;
case ERTS_PSFLG_RUNNING_SYS:
erts_print(to, to_arg, "RUNNING_SYS"); break;
case ERTS_PSFLG_PROXY:
erts_print(to, to_arg, "PROXY"); break;
case ERTS_PSFLG_DELAYED_SYS:
erts_print(to, to_arg, "DELAYED_SYS"); break;
#ifdef ERTS_DIRTY_SCHEDULERS
case ERTS_PSFLG_DIRTY_CPU_PROC:
erts_print(to, to_arg, "DIRTY_CPU_PROC"); break;
case ERTS_PSFLG_DIRTY_IO_PROC:
erts_print(to, to_arg, "DIRTY_IO_PROC"); break;
case ERTS_PSFLG_DIRTY_CPU_PROC_IN_Q:
erts_print(to, to_arg, "DIRTY_CPU_PROC_IN_Q"); break;
case ERTS_PSFLG_DIRTY_IO_PROC_IN_Q:
erts_print(to, to_arg, "DIRTY_IO_PROC_IN_Q"); break;
#endif
default:
erts_print(to, to_arg, "UNKNOWN(%d)", chk); break;
}
if (psflg > chk)
erts_print(to, to_arg, " | ");
psflg -= chk;
}
}
erts_print(to, to_arg, "\n");
}