1
0
mirror of https://github.com/ilyakooo0/urbit.git synced 2024-12-27 00:44:27 +03:00
urbit/noun/manage.c

1522 lines
30 KiB
C
Raw Normal View History

2015-07-03 01:29:28 +03:00
/* n/m.c
2014-09-05 23:55:16 +04:00
**
*/
2014-09-11 04:01:32 +04:00
#include <errno.h>
#include <fcntl.h>
#include <sys/stat.h>
2014-09-12 04:41:26 +04:00
#include <ctype.h>
2014-10-05 01:57:40 +04:00
#include <sigsegv.h>
2014-09-05 23:55:16 +04:00
#include "all.h"
2014-11-16 04:10:15 +03:00
/* (u3_noun)setjmp(u3R->esc.buf): setjmp within road.
*/
#if 0
c3_o
u3m_trap(void);
#else
2015-01-15 22:10:29 +03:00
# define u3m_trap() (u3_noun)(_setjmp(u3R->esc.buf))
2014-11-16 04:10:15 +03:00
#endif
/* u3m_signal(): treat a nock-level exception as a signal interrupt.
*/
void
u3m_signal(u3_noun sig_l);
/* u3m_dump(): dump the current road to stderr.
*/
void
u3m_dump(void);
/* u3m_fall(): return to parent road.
*/
void
u3m_fall(void);
/* u3m_leap(): in u3R, create a new road within the existing one.
*/
void
u3m_leap(c3_w pad_w);
/* u3m_golf(): record cap length for u3_flog().
*/
c3_w
u3m_golf(void);
/* u3m_flog(): pop the cap.
**
** A common sequence for inner allocation is:
**
** c3_w gof_w = u3m_golf();
** u3m_leap();
** // allocate some inner stuff...
** u3m_fall();
** // inner stuff is still valid, but on cap
** u3m_flog(gof_w);
**
** u3m_flog(0) simply clears the cap.
*/
void
u3m_flog(c3_w gof_w);
/* u3m_soft_top(): top-level safety wrapper.
*/
u3_noun
u3m_soft_top(c3_w sec_w, // timer seconds
c3_w pad_w, // base memory pad
u3_funk fun_f,
u3_noun arg);
static sigjmp_buf u3_Signal;
2014-10-05 01:57:40 +04:00
#ifndef SIGSTKSZ
# define SIGSTKSZ 16384
#endif
static uint8_t Sigstk[SIGSTKSZ];
void u3_unix_ef_hold(void); // suspend system signal regime
void u3_unix_ef_move(void); // restore system signal regime
extern void
u3_lo_sway(c3_l tab_l, u3_noun tax);
2014-10-06 21:17:33 +04:00
#if 0
2014-10-05 01:57:40 +04:00
/* _cm_punt(): crudely print trace.
*/
static void
_cm_punt(u3_noun tax)
{
u3_noun xat;
for ( xat = tax; xat; xat = u3t(xat) ) {
2014-11-06 03:20:01 +03:00
u3m_p("&", u3h(xat));
2014-10-05 01:57:40 +04:00
}
}
#endif
/* _cm_emergency(): write emergency text to stderr, never failing.
*/
static void
_cm_emergency(c3_c* cap_c, c3_l sig_l)
{
write(2, "\r\n", 2);
write(2, cap_c, strlen(cap_c));
if ( sig_l ) {
write(2, ": ", 2);
write(2, &sig_l, 4);
}
write(2, "\r\n", 2);
}
2014-10-06 21:17:33 +04:00
static void _cm_overflow(void *arg1, void *arg2, void *arg3)
2014-10-05 01:57:40 +04:00
{
(void)(arg1);
(void)(arg2);
(void)(arg3);
2014-10-06 21:17:33 +04:00
siglongjmp(u3_Signal, c3__over);
2014-10-05 01:57:40 +04:00
}
/* _cm_signal_handle(): handle a signal in general.
*/
static void
_cm_signal_handle(c3_l sig_l)
{
2014-10-06 21:17:33 +04:00
if ( c3__over == sig_l ) {
sigsegv_leave_handler(_cm_overflow, NULL, NULL, NULL);
2014-10-05 01:57:40 +04:00
}
else {
2014-10-06 21:17:33 +04:00
siglongjmp(u3_Signal, sig_l);
2014-10-05 01:57:40 +04:00
}
}
static void
_cm_signal_handle_over(int emergency, stackoverflow_context_t scp)
{
_cm_signal_handle(c3__over);
}
static void
_cm_signal_handle_term(int x)
{
2014-10-24 04:35:26 +04:00
// Ignore if we are using base memory from work memory, very rare.
//
if ( (0 != u3H->rod_u.kid_p) && (&(u3H->rod_u) == u3R) ) {
2014-10-24 04:35:26 +04:00
_cm_emergency("ignored", c3__term);
}
else {
_cm_signal_handle(c3__term);
}
2014-10-05 01:57:40 +04:00
}
static void
_cm_signal_handle_intr(int x)
{
2014-10-24 04:35:26 +04:00
// Interrupt: stop work. Ignore if not working, or (rarely) using base.
//
if ( &(u3H->rod_u) == u3R ) {
_cm_emergency("ignored", c3__intr);
}
else {
_cm_signal_handle(c3__intr);
}
2014-10-05 01:57:40 +04:00
}
static void
_cm_signal_handle_alrm(int x)
{
_cm_signal_handle(c3__alrm);
}
/* _cm_signal_reset(): reset top road after signal longjmp.
*/
static void
_cm_signal_reset(void)
{
u3R = &u3H->rod_u;
u3R->cap_p = u3R->mat_p;
u3R->ear_p = 0;
u3R->kid_p = 0;
2014-10-05 01:57:40 +04:00
}
2015-02-02 22:03:14 +03:00
/* _cm_stack_recover(): recover stack trace, with lacunae.
*/
static u3_noun
_cm_stack_recover(u3a_road* rod_u)
{
c3_w len_w;
len_w = 0;
{
u3_noun tax = rod_u->bug.tax;
while ( tax ) {
len_w++;
tax = u3t(tax);
}
if ( len_w < 4096 ) {
return u3a_take(rod_u->bug.tax);
}
else {
u3_noun beg, fin;
c3_w i_w;
tax = rod_u->bug.tax;
beg = u3_nul;
for ( i_w = 0; i_w < 2048; i_w++ ) {
beg = u3nc(u3a_take(u3h(tax)), beg);
tax = u3t(tax);
}
beg = u3kb_flop(beg);
for ( i_w = 0; i_w < (len_w - 4096); i_w++ ) {
tax = u3t(tax);
}
fin = u3nc(u3nc(c3__lose, c3__over), u3a_take(tax));
return u3kb_weld(beg, fin);
}
}
}
/* _cm_signal_recover(): recover from a deep signal, after longjmp. Free arg.
2014-10-05 01:57:40 +04:00
*/
static u3_noun
_cm_signal_recover(c3_l sig_l, u3_noun arg)
2014-10-05 01:57:40 +04:00
{
2014-10-06 21:17:33 +04:00
u3_noun tax;
2014-10-05 01:57:40 +04:00
2014-10-06 21:17:33 +04:00
// Unlikely to be set, but it can be made to happen.
//
tax = u3H->rod_u.bug.tax;
u3H->rod_u.bug.tax = 0;
2014-10-06 21:17:33 +04:00
if ( &(u3H->rod_u) == u3R ) {
// A top-level crash - rather odd. We should GC.
2014-10-06 21:17:33 +04:00
//
_cm_emergency("recover: top", sig_l);
2014-11-29 05:19:11 +03:00
u3C.wag_w |= u3o_check_corrupt;
2014-10-06 21:17:33 +04:00
// Reset the top road - the problem could be a fat cap.
//
2014-10-05 01:57:40 +04:00
_cm_signal_reset();
2014-10-06 21:17:33 +04:00
2014-11-06 03:20:01 +03:00
if ( (c3__meme == sig_l) && (u3a_open(u3R) <= 256) ) {
2014-10-06 21:17:33 +04:00
// Out of memory at the top level. Error becomes c3__full,
// and we release the emergency buffer. To continue work,
// we need to readjust the image, eg, migrate to 64 bit.
//
u3z(u3R->bug.mer);
2014-10-15 06:02:37 +04:00
u3R->bug.mer = 0;
2014-10-06 21:17:33 +04:00
sig_l = c3__full;
}
return u3nt(3, sig_l, tax);
2014-10-05 01:57:40 +04:00
}
else {
u3_noun pro;
2014-10-06 21:17:33 +04:00
// A signal was generated while we were within Nock.
//
_cm_emergency("recover: dig", sig_l);
// Descend to the innermost trace, collecting stack.
2014-10-05 01:57:40 +04:00
//
{
2014-11-06 03:20:01 +03:00
u3a_road* rod_u;
2014-10-05 01:57:40 +04:00
u3R = &(u3H->rod_u);
rod_u = u3R;
2015-02-02 22:03:14 +03:00
while ( rod_u->kid_p ) {
2015-02-02 22:03:14 +03:00
#if 0
fprintf(stderr, "collecting %d frames\r\n",
u3kb_lent((u3to(u3_road, rod_u->kid_p)->bug.tax));
2015-02-02 22:03:14 +03:00
#endif
tax = u3kb_weld(_cm_stack_recover(u3to(u3_road, rod_u->kid_p)), tax);
rod_u = u3to(u3_road, rod_u->kid_p);
2014-10-05 01:57:40 +04:00
}
}
2014-10-06 21:17:33 +04:00
pro = u3nt(3, sig_l, tax);
_cm_signal_reset();
2014-10-05 01:57:40 +04:00
u3z(arg);
2014-10-05 01:57:40 +04:00
return pro;
}
}
/* _cm_signal_deep(): start deep processing; set timer for sec_w or 0.
*/
static void
_cm_signal_deep(c3_w sec_w)
{
u3_unix_ef_hold();
stackoverflow_install_handler(_cm_signal_handle_over, Sigstk, SIGSTKSZ);
signal(SIGINT, _cm_signal_handle_intr);
signal(SIGTERM, _cm_signal_handle_term);
2014-10-15 06:02:37 +04:00
// Provide a little emergency memory, for use in case things
// go utterly haywire.
//
if ( 0 == u3H->rod_u.bug.mer ) {
2014-11-06 03:20:01 +03:00
u3H->rod_u.bug.mer = u3i_string("emergency buffer");
2014-10-15 06:02:37 +04:00
}
2014-10-05 01:57:40 +04:00
if ( sec_w ) {
struct itimerval itm_u;
timerclear(&itm_u.it_interval);
itm_u.it_value.tv_sec = sec_w;
itm_u.it_value.tv_usec = 0;
setitimer(ITIMER_VIRTUAL, &itm_u, 0);
signal(SIGVTALRM, _cm_signal_handle_alrm);
}
2014-12-01 03:06:08 +03:00
u3t_boot();
2014-10-05 01:57:40 +04:00
}
/* _cm_signal_done():
*/
static void
_cm_signal_done()
{
// signal(SIGINT, SIG_IGN);
signal(SIGTERM, SIG_IGN);
signal(SIGVTALRM, SIG_IGN);
stackoverflow_deinstall_handler();
{
struct itimerval itm_u;
timerclear(&itm_u.it_interval);
timerclear(&itm_u.it_value);
setitimer(ITIMER_VIRTUAL, &itm_u, 0);
}
u3_unix_ef_move();
2014-12-01 03:06:08 +03:00
u3t_boff();
2014-10-05 01:57:40 +04:00
}
2014-11-06 03:20:01 +03:00
/* u3m_signal(): treat a nock-level exception as a signal interrupt.
2014-10-06 21:17:33 +04:00
*/
void
2014-11-06 03:20:01 +03:00
u3m_signal(u3_noun sig_l)
2014-10-06 21:17:33 +04:00
{
siglongjmp(u3_Signal, sig_l);
}
2014-11-06 03:20:01 +03:00
/* u3m_file(): load file, as atom, or bail.
*/
2014-09-11 04:01:32 +04:00
u3_noun
2014-11-06 03:20:01 +03:00
u3m_file(c3_c* pas_c)
{
struct stat buf_b;
c3_i fid_i = open(pas_c, O_RDONLY, 0644);
c3_w fln_w, red_w;
c3_y* pad_y;
if ( (fid_i < 0) || (fstat(fid_i, &buf_b) < 0) ) {
fprintf(stderr, "%s: %s\r\n", pas_c, strerror(errno));
2014-11-06 03:20:01 +03:00
return u3m_bail(c3__fail);
}
fln_w = buf_b.st_size;
pad_y = c3_malloc(buf_b.st_size);
red_w = read(fid_i, pad_y, fln_w);
close(fid_i);
if ( fln_w != red_w ) {
free(pad_y);
2014-11-06 03:20:01 +03:00
return u3m_bail(c3__fail);
}
else {
2014-11-06 03:20:01 +03:00
u3_noun pad = u3i_bytes(fln_w, (c3_y *)pad_y);
free(pad_y);
return pad;
}
}
2014-09-29 01:56:17 +04:00
/* _find_north(): in restored image, point to a north home.
2014-09-05 23:55:16 +04:00
*/
2014-09-22 20:10:57 +04:00
static u3_road*
_find_north(c3_w* mem_w, c3_w siz_w, c3_w len_w)
{
2014-09-23 21:11:59 +04:00
return (void *) ((mem_w + len_w) - siz_w);
2014-09-22 20:10:57 +04:00
}
2014-10-01 10:34:30 +04:00
#if 0
2014-09-29 01:56:17 +04:00
/* _find_south(): in restored image, point to a south home.
2014-09-22 20:10:57 +04:00
*/
static u3_road*
_find_south(c3_w* mem_w, c3_w siz_w, c3_w len_w)
{
2014-10-03 21:44:08 +04:00
return (void *)mem_w;
2014-09-22 20:10:57 +04:00
}
2014-10-01 10:34:30 +04:00
#endif
2014-09-22 20:10:57 +04:00
2014-09-06 00:13:24 +04:00
static u3_road*
2014-11-16 04:10:15 +03:00
_pave_north(c3_w* mem_w, c3_w siz_w, c3_w len_w)
2014-09-05 23:55:16 +04:00
{
c3_w* rut_w = mem_w;
c3_w* hat_w = rut_w;
2014-09-10 20:45:39 +04:00
c3_w* mat_w = ((mem_w + len_w) - siz_w);
2014-09-05 23:55:16 +04:00
c3_w* cap_w = mat_w;
2014-09-06 00:13:24 +04:00
u3_road* rod_u = (void*) mat_w;
2014-09-05 23:55:16 +04:00
2014-10-03 21:44:08 +04:00
// memset(mem_w, 0, 4 * len_w); // enable in case of corruption
2014-09-10 20:45:39 +04:00
memset(rod_u, 0, 4 * siz_w);
2014-09-05 23:55:16 +04:00
rod_u->rut_p = u3of(c3_w, rut_w);
rod_u->hat_p = u3of(c3_w, hat_w);
2014-09-05 23:55:16 +04:00
rod_u->mat_p = u3of(c3_w, mat_w);
rod_u->cap_p = u3of(c3_w, cap_w);
2014-09-05 23:55:16 +04:00
return rod_u;
}
2014-11-16 04:10:15 +03:00
/* _pave_south(): install a south road.
2014-09-05 23:55:16 +04:00
*/
2014-09-06 00:13:24 +04:00
static u3_road*
2014-11-16 04:10:15 +03:00
_pave_south(c3_w* mem_w, c3_w siz_w, c3_w len_w)
2014-09-05 23:55:16 +04:00
{
2014-09-29 01:56:17 +04:00
c3_w* rut_w = (mem_w + len_w);
2014-09-05 23:55:16 +04:00
c3_w* hat_w = rut_w;
2014-10-03 21:44:08 +04:00
c3_w* mat_w = mem_w;
c3_w* cap_w = mat_w + siz_w;
2014-09-06 00:13:24 +04:00
u3_road* rod_u = (void*) mat_w;
2014-09-05 23:55:16 +04:00
2014-10-03 21:44:08 +04:00
// memset(mem_w, 0, 4 * len_w); // enable in case of corruption
2014-09-10 20:45:39 +04:00
memset(rod_u, 0, 4 * siz_w);
2014-09-05 23:55:16 +04:00
rod_u->rut_p = u3of(c3_w, rut_w);
rod_u->hat_p = u3of(c3_w, hat_w);
rod_u->mat_p = u3of(c3_w, mat_w);
rod_u->cap_p = u3of(c3_w, cap_w);
2014-09-05 23:55:16 +04:00
return rod_u;
}
2014-11-16 04:10:15 +03:00
/* _pave_parts(): build internal tables.
2014-09-12 22:32:11 +04:00
*/
static void
2014-11-16 04:10:15 +03:00
_pave_parts(void)
2014-09-12 22:32:11 +04:00
{
2014-11-06 03:20:01 +03:00
u3R->cax.har_p = u3h_new();
u3R->jed.har_p = u3h_new();
2014-11-20 22:58:55 +03:00
u3R->jed.das = u3_nul;
2014-09-12 22:32:11 +04:00
}
2014-11-06 03:20:01 +03:00
/* u3m_mark(): mark all nouns in the road.
2014-10-09 07:24:31 +04:00
*/
2015-05-08 02:16:54 +03:00
c3_w
2014-11-06 03:20:01 +03:00
u3m_mark(void)
2014-10-09 07:24:31 +04:00
{
2015-05-08 02:16:54 +03:00
c3_w tot_w = 0;
tot_w += u3h_mark(u3R->jed.har_p);
tot_w += u3a_mark_noun(u3R->jed.das);
tot_w += u3a_mark_noun(u3R->ski.flu);
tot_w += u3a_mark_noun(u3R->bug.tax);
tot_w += u3a_mark_noun(u3R->bug.mer);
tot_w += u3a_mark_noun(u3R->pro.don);
tot_w += u3a_mark_noun(u3R->pro.day);
tot_w += u3h_mark(u3R->cax.har_p);
return tot_w;
2014-10-09 07:24:31 +04:00
}
2014-11-16 04:10:15 +03:00
/* _cm_pave(): instantiate or activate image.
2014-09-22 20:10:57 +04:00
*/
2014-11-16 04:10:15 +03:00
static void
_cm_pave(c3_o nuu_o, c3_o bug_o)
2014-09-22 20:10:57 +04:00
{
2014-11-05 04:18:47 +03:00
if ( c3y == nuu_o ) {
2014-11-16 04:10:15 +03:00
u3H = (void *)_pave_north(u3_Loom + 1,
2014-11-06 03:20:01 +03:00
c3_wiseof(u3v_home),
u3a_words - 1);
2014-09-24 11:38:37 +04:00
u3R = &u3H->rod_u;
2014-09-22 20:10:57 +04:00
2014-11-16 04:10:15 +03:00
_pave_parts();
2014-09-24 11:38:37 +04:00
}
else {
2014-11-04 02:07:46 +03:00
u3H = (void *)_find_north(u3_Loom + 1,
2014-11-06 03:20:01 +03:00
c3_wiseof(u3v_home),
u3a_words - 1);
2014-09-24 11:38:37 +04:00
u3R = &u3H->rod_u;
}
2014-09-05 23:55:16 +04:00
}
2014-11-16 04:10:15 +03:00
#if 0
2014-11-06 03:20:01 +03:00
/* u3m_clear(): clear all allocated data in road.
2014-09-07 04:09:29 +04:00
*/
void
2014-11-06 03:20:01 +03:00
u3m_clear(void)
2014-09-07 04:09:29 +04:00
{
2014-11-06 03:20:01 +03:00
u3h_free(u3R->cax.har_p);
u3h_free(u3R->jed.har_p);
u3a_lose(u3R->jed.das);
2014-09-07 04:09:29 +04:00
}
2014-09-05 23:55:16 +04:00
void
2014-11-06 03:20:01 +03:00
u3m_dump(void)
2014-09-05 23:55:16 +04:00
{
c3_w hat_w;
c3_w fre_w = 0;
c3_w i_w;
2014-11-06 03:20:01 +03:00
hat_w = _(u3a_is_north(u3R)) ? u3R->hat_w - u3R->rut_w
2014-09-29 01:56:17 +04:00
: u3R->rut_w - u3R->hat_w;
2014-09-05 23:55:16 +04:00
2014-09-06 00:13:24 +04:00
for ( i_w = 0; i_w < u3_cc_fbox_no; i_w++ ) {
2014-11-06 03:20:01 +03:00
u3a_fbox* fre_u = u3R->all.fre_u[i_w];
2014-09-05 23:55:16 +04:00
while ( fre_u ) {
fre_w += fre_u->box_u.siz_w;
fre_u = fre_u->nex_u;
}
}
2014-10-03 21:44:08 +04:00
fprintf(stderr, "dump: hat_w %x, fre_w %x, allocated %x\n",
2014-09-05 23:55:16 +04:00
hat_w, fre_w, (hat_w - fre_w));
if ( 0 != (hat_w - fre_w) ) {
2014-11-06 03:20:01 +03:00
c3_w* box_w = _(u3a_is_north(u3R)) ? u3R->rut_w : u3R->hat_w;
2014-09-05 23:55:16 +04:00
c3_w mem_w = 0;
2014-11-06 03:20:01 +03:00
while ( box_w < (_(u3a_is_north(u3R)) ? u3R->hat_w : u3R->rut_w) ) {
u3a_box* box_u = (void *)box_w;
2014-09-05 23:55:16 +04:00
if ( 0 != box_u->use_w ) {
2014-09-07 02:39:28 +04:00
#ifdef U3_MEMORY_DEBUG
2014-09-29 01:56:17 +04:00
// printf("live %d words, code %x\n", box_u->siz_w, box_u->cod_w);
2014-09-07 02:39:28 +04:00
#endif
2014-09-05 23:55:16 +04:00
mem_w += box_u->siz_w;
}
box_w += box_u->siz_w;
}
2014-10-03 21:44:08 +04:00
fprintf(stderr, "second count: %x\n", mem_w);
2014-09-05 23:55:16 +04:00
}
}
2014-11-04 02:07:46 +03:00
#endif
2014-09-05 23:55:16 +04:00
2014-10-09 02:16:24 +04:00
c3_w Exit;
2014-11-06 03:20:01 +03:00
/* u3m_bail(): bail out. Does not return.
2014-09-05 23:55:16 +04:00
**
** Bail motes:
**
** %evil :: erroneous cryptography
** %exit :: semantic failure
** %oops :: assertion failure
** %intr :: interrupt
** %fail :: computability failure
2014-10-05 01:57:40 +04:00
** %over :: stack overflow (a kind of %fail)
2014-09-05 23:55:16 +04:00
** %need :: namespace block
** %meme :: out of memory
2014-09-30 20:45:51 +04:00
**
** These are equivalents of the full exception noun, the error ball:
**
** $% [%0 success]
** [%1 paths]
** [%2 trace]
** [%3 code trace]
** ==
2015-02-23 03:11:46 +03:00
*/
2014-09-05 23:55:16 +04:00
c3_i
2014-11-06 03:20:01 +03:00
u3m_bail(u3_noun how)
2014-09-05 23:55:16 +04:00
{
2014-10-25 07:49:27 +04:00
if ( (c3__exit == how) && (u3R == &u3H->rod_u) ) {
abort();
}
2014-12-02 01:05:09 +03:00
2015-07-15 22:14:11 +03:00
#ifdef U3_PRINT_WATERMARK
2015-07-03 01:29:28 +03:00
if ( c3__meme == how ) {
2015-07-03 03:17:14 +03:00
fprintf(stderr, "u3R %p, parent %x\n", u3R, u3R->par_p);
2015-07-15 22:14:11 +03:00
fprintf(stderr, "max %dMB\r\n", u3R->all.max_w / 256000);
2015-07-03 01:29:28 +03:00
abort();
}
2015-07-15 22:14:11 +03:00
#endif
2015-07-03 01:29:28 +03:00
2014-09-30 20:45:51 +04:00
/* Printf some metadata.
*/
2014-12-10 01:59:31 +03:00
if ( c3__exit != how && (_(u3ud(how)) || 1 != u3h(how)) ) {
2014-11-05 04:18:47 +03:00
if ( _(u3ud(how)) ) {
2014-09-30 20:45:51 +04:00
c3_c str_c[5];
2014-10-01 10:34:30 +04:00
str_c[0] = ((how >> 0) & 0xff);
str_c[1] = ((how >> 8) & 0xff);
str_c[2] = ((how >> 16) & 0xff);
str_c[3] = ((how >> 24) & 0xff);
2014-09-30 20:45:51 +04:00
str_c[4] = 0;
2015-09-10 02:52:53 +03:00
fprintf(stderr, "\r\nbail: %s\r\n", str_c);
2014-09-30 20:45:51 +04:00
}
else {
2014-11-05 04:18:47 +03:00
c3_assert(_(u3ud(u3h(how))));
2014-09-13 03:06:33 +04:00
2015-09-10 02:52:53 +03:00
fprintf(stderr, "\r\nbail: %d\r\n", u3h(how));
2014-11-06 03:20:01 +03:00
u3m_p("bail", u3t(how));
2014-09-30 20:45:51 +04:00
}
2014-09-05 23:55:16 +04:00
}
2014-10-06 21:17:33 +04:00
2014-12-07 00:10:53 +03:00
switch ( how ) {
2015-07-14 21:57:02 +03:00
#if 0
2014-12-07 00:10:53 +03:00
case c3__fail:
case c3__meme:
2015-07-14 21:57:02 +03:00
#endif
case c3__foul:
2014-12-07 00:10:53 +03:00
case c3__oops:
abort();
}
2014-10-06 21:17:33 +04:00
if ( &(u3H->rod_u) == u3R ) {
// For top-level errors, which shouln't happen often, we have no
// choice but to use the signal process; and we require the flat
// form of how.
//
2014-11-06 03:20:01 +03:00
c3_assert(_(u3a_is_cat(how)));
u3m_signal(how);
2014-10-06 21:17:33 +04:00
}
2014-09-05 23:55:16 +04:00
2014-09-30 20:45:51 +04:00
/* Reconstruct a correct error ball.
*/
{
2014-11-05 04:18:47 +03:00
if ( _(u3ud(how)) ) {
2014-09-30 20:45:51 +04:00
switch ( how ) {
case c3__exit: {
how = u3nc(2, u3R->bug.tax);
break;
}
case c3__need: {
c3_assert(0);
}
default: {
how = u3nt(3, how, u3R->bug.tax);
break;
}
}
}
}
2015-02-23 03:11:46 +03:00
2014-09-30 20:45:51 +04:00
/* Longjmp, with an underscore.
*/
2014-10-01 10:34:30 +04:00
_longjmp(u3R->esc.buf, how);
2014-09-05 23:55:16 +04:00
}
2014-09-30 20:45:51 +04:00
2014-11-06 03:20:01 +03:00
int c3_cooked() { return u3m_bail(c3__oops); }
2014-09-05 23:55:16 +04:00
2014-11-06 03:20:01 +03:00
/* u3m_error(): bail out with %exit, ct_pushing error.
2014-09-05 23:55:16 +04:00
*/
c3_i
2014-11-06 03:20:01 +03:00
u3m_error(c3_c* str_c)
2014-09-05 23:55:16 +04:00
{
2015-06-11 06:59:08 +03:00
u3t_mean(u3i_string(str_c));
2014-11-06 03:20:01 +03:00
return u3m_bail(c3__exit);
2014-09-05 23:55:16 +04:00
}
2014-11-06 03:20:01 +03:00
/* u3m_leap(): in u3R, create a new road within the existing one.
2014-09-05 23:55:16 +04:00
*/
void
2014-11-06 03:20:01 +03:00
u3m_leap(c3_w pad_w)
2014-09-05 23:55:16 +04:00
{
2014-10-01 10:34:30 +04:00
c3_w len_w;
2014-09-06 00:13:24 +04:00
u3_road* rod_u;
2014-09-05 23:55:16 +04:00
2014-10-01 10:34:30 +04:00
/* Measure the pad - we'll need it.
*/
{
2014-12-01 03:06:08 +03:00
#if 0
2014-10-01 10:34:30 +04:00
if ( pad_w < u3R->all.fre_w ) {
pad_w = 0;
}
else {
pad_w -= u3R->all.fre_w;
}
2014-12-01 03:06:08 +03:00
#endif
2014-11-06 03:20:01 +03:00
if ( (pad_w + c3_wiseof(u3a_road)) >= u3a_open(u3R) ) {
u3m_bail(c3__meme);
2014-10-01 10:34:30 +04:00
}
2014-11-06 03:20:01 +03:00
len_w = u3a_open(u3R) - (pad_w + c3_wiseof(u3a_road));
2014-09-05 23:55:16 +04:00
}
2014-10-01 10:34:30 +04:00
/* Allocate a region on the cap.
*/
{
u3p(c3_w) bot_p;
2014-10-01 10:34:30 +04:00
2014-11-06 03:20:01 +03:00
if ( c3y == u3a_is_north(u3R) ) {
bot_p = (u3R->cap_p - len_w);
u3R->cap_p -= len_w;
2014-09-12 22:32:11 +04:00
2014-11-16 04:10:15 +03:00
rod_u = _pave_south(u3a_into(bot_p), c3_wiseof(u3a_road), len_w);
2014-10-03 21:44:08 +04:00
#if 0
fprintf(stderr, "leap: from north %p (cap %x), to south %p\r\n",
2014-10-01 10:34:30 +04:00
u3R,
u3R->cap_p + len_p,
2014-10-01 10:34:30 +04:00
rod_u);
2014-10-03 21:44:08 +04:00
#endif
2014-10-01 10:34:30 +04:00
}
else {
bot_p = u3R->cap_p;
u3R->cap_p += len_w;
2014-10-01 10:34:30 +04:00
2014-11-16 04:10:15 +03:00
rod_u = _pave_north(u3a_into(bot_p), c3_wiseof(u3a_road), len_w);
2014-10-03 21:44:08 +04:00
#if 0
fprintf(stderr, "leap: from north %p (cap %p), to south %p\r\n",
2014-10-01 10:34:30 +04:00
u3R,
u3R->cap_p - len_p,
2014-10-01 10:34:30 +04:00
rod_u);
2014-10-03 21:44:08 +04:00
#endif
2014-10-01 10:34:30 +04:00
}
}
/* Attach the new road to its parents.
*/
{
c3_assert(0 == u3R->kid_p);
rod_u->par_p = u3of(u3_road, u3R);
u3R->kid_p = u3of(u3_road, rod_u);
2014-10-01 10:34:30 +04:00
}
/* Set up the new road.
*/
{
u3R = rod_u;
2014-11-16 04:10:15 +03:00
_pave_parts();
2014-10-01 10:34:30 +04:00
}
2015-07-15 22:14:11 +03:00
#ifdef U3_MEMORY_DEBUG
2015-07-03 01:29:28 +03:00
rod_u->all.fre_w = 0;
2015-07-15 22:14:11 +03:00
#endif
2014-09-05 23:55:16 +04:00
}
2014-11-06 03:20:01 +03:00
/* u3m_fall(): in u3R, return an inner road to its parent.
2014-09-05 23:55:16 +04:00
*/
void
2014-11-06 03:20:01 +03:00
u3m_fall()
2014-09-05 23:55:16 +04:00
{
c3_assert(0 != u3R->par_p);
2014-09-05 23:55:16 +04:00
2014-10-03 21:44:08 +04:00
#if 0
fprintf(stderr, "fall: from %s %p, to %s %p (cap %p, was %p)\r\n",
2014-11-06 03:20:01 +03:00
_(u3a_is_north(u3R)) ? "north" : "south",
2014-10-01 10:34:30 +04:00
u3R,
2014-11-06 03:20:01 +03:00
_(u3a_is_north(u3R)) ? "north" : "south",
u3to(u3_road, u3R->par_p),
2014-10-01 10:34:30 +04:00
u3R->hat_w,
u3R->rut_w);
2014-10-03 21:44:08 +04:00
#endif
2014-10-01 10:34:30 +04:00
/* The new cap is the old hat - it's as simple as that.
*/
u3to(u3_road, u3R->par_p)->cap_p = u3R->hat_p;
2014-10-01 10:34:30 +04:00
/* And, we're back home.
*/
u3R = u3to(u3_road, u3R->par_p);
u3R->kid_p = 0;
2014-09-05 23:55:16 +04:00
}
2014-11-06 03:20:01 +03:00
/* u3m_hate(): new, integrated leap mechanism (enter).
2014-10-31 00:40:05 +03:00
*/
void
2014-11-06 03:20:01 +03:00
u3m_hate(c3_w pad_w)
2014-10-31 00:40:05 +03:00
{
c3_assert(0 == u3R->ear_p);
2014-10-31 00:40:05 +03:00
u3R->ear_p = u3R->cap_p;
2014-11-06 03:20:01 +03:00
u3m_leap(pad_w);
2014-10-31 00:40:05 +03:00
}
2014-11-06 03:20:01 +03:00
/* u3m_love(): return product from leap.
2014-10-31 00:40:05 +03:00
*/
u3_noun
2014-11-06 03:20:01 +03:00
u3m_love(u3_noun pro)
2014-10-31 00:40:05 +03:00
{
2015-01-15 22:10:29 +03:00
{
u3_noun das = u3R->jed.das;
u3p(u3h_root) har_p = u3R->jed.har_p;
2014-10-31 00:40:05 +03:00
2015-01-15 22:10:29 +03:00
u3m_fall();
2014-10-31 00:40:05 +03:00
2015-01-15 22:10:29 +03:00
pro = u3a_take(pro);
2014-10-31 00:40:05 +03:00
2015-01-15 22:10:29 +03:00
u3j_reap(das, har_p);
2014-10-31 00:40:05 +03:00
2015-01-15 22:10:29 +03:00
u3R->cap_p = u3R->ear_p;
u3R->ear_p = 0;
}
2014-10-31 00:40:05 +03:00
return pro;
}
2014-11-06 03:20:01 +03:00
/* u3m_golf(): record cap_p length for u3_flog().
2014-09-05 23:55:16 +04:00
*/
c3_w
2014-11-06 03:20:01 +03:00
u3m_golf(void)
2014-09-05 23:55:16 +04:00
{
2014-11-06 03:20:01 +03:00
if ( c3y == u3a_is_north(u3R) ) {
return u3R->mat_p - u3R->cap_p;
2014-09-05 23:55:16 +04:00
}
else {
return u3R->cap_p - u3R->mat_p;
2014-09-05 23:55:16 +04:00
}
}
2014-11-06 03:20:01 +03:00
/* u3m_flog(): reset cap_p.
2014-09-05 23:55:16 +04:00
*/
void
2014-11-06 03:20:01 +03:00
u3m_flog(c3_w gof_w)
2014-09-05 23:55:16 +04:00
{
2014-10-03 21:44:08 +04:00
// Enable memsets in case of memory corruption.
//
2014-11-06 03:20:01 +03:00
if ( c3y == u3a_is_north(u3R) ) {
u3_post bot_p = (u3R->mat_p - gof_w);
2014-10-03 21:44:08 +04:00
// c3_w len_w = (bot_w - u3R->cap_w);
// memset(u3R->cap_w, 0, 4 * len_w);
u3R->cap_p = bot_p;
2014-10-03 21:44:08 +04:00
}
else {
u3_post bot_p = u3R->mat_p + gof_w;
2014-10-03 21:44:08 +04:00
// c3_w len_w = (u3R->cap_w - bot_w);
// memset(bot_w, 0, 4 * len_w); //
u3R->cap_p = bot_p;
2014-09-05 23:55:16 +04:00
}
}
2014-11-06 03:20:01 +03:00
/* u3m_water(): produce watermarks.
2014-09-05 23:55:16 +04:00
*/
void
2014-11-06 03:20:01 +03:00
u3m_water(c3_w* low_w, c3_w* hig_w)
2014-09-05 23:55:16 +04:00
{
2014-09-11 04:01:32 +04:00
c3_assert(u3R == &u3H->rod_u);
2014-09-05 23:55:16 +04:00
*low_w = (u3H->rod_u.hat_p - u3H->rod_u.rut_p);
2014-11-06 03:20:01 +03:00
*hig_w = (u3H->rod_u.mat_p - u3H->rod_u.cap_p) + c3_wiseof(u3v_home);
2014-09-05 23:55:16 +04:00
}
2014-11-06 03:20:01 +03:00
/* u3m_soft_top(): top-level safety wrapper.
2014-09-29 22:28:20 +04:00
*/
u3_noun
2014-11-06 03:20:01 +03:00
u3m_soft_top(c3_w sec_w, // timer seconds
2014-12-01 03:06:08 +03:00
c3_w pad_w, // base memory pad
u3_funk fun_f,
u3_noun arg)
2014-09-29 22:28:20 +04:00
{
2014-10-05 01:57:40 +04:00
u3_noun why, pro;
2014-10-06 21:17:33 +04:00
c3_l sig_l;
2014-11-02 01:13:18 +03:00
2014-10-05 01:57:40 +04:00
/* Enter internal signal regime.
2014-09-30 20:45:51 +04:00
*/
2014-10-05 01:57:40 +04:00
_cm_signal_deep(0);
2014-09-30 20:45:51 +04:00
2014-10-06 21:17:33 +04:00
if ( 0 != (sig_l = sigsetjmp(u3_Signal, 1)) ) {
2014-12-03 03:26:30 +03:00
// reinitialize trace state
//
u3t_init();
2014-10-05 01:57:40 +04:00
// return to blank state
//
_cm_signal_done();
2014-10-06 21:17:33 +04:00
// recover memory state from the top down
//
return _cm_signal_recover(sig_l, arg);
2014-09-30 20:45:51 +04:00
}
2014-09-29 22:28:20 +04:00
2014-09-30 20:45:51 +04:00
/* Record the cap, and leap.
*/
2014-11-06 03:20:01 +03:00
u3m_hate(pad_w);
2014-10-05 01:57:40 +04:00
/* Trap for ordinary nock exceptions.
2014-09-30 20:45:51 +04:00
*/
2015-01-15 22:10:29 +03:00
if ( 0 == (why = (u3_noun)_setjmp(u3R->esc.buf)) ) {
2014-10-31 00:40:05 +03:00
pro = fun_f(arg);
/* Make sure the inner routine did not create garbage.
*/
2014-11-29 05:19:11 +03:00
if ( u3C.wag_w & u3o_debug_ram ) {
2015-07-15 22:14:11 +03:00
#ifdef U3_PRINT_WATERMARK
2015-07-03 01:29:28 +03:00
if ( u3R->all.max_w > 1000000 ) {
2015-07-03 03:17:14 +03:00
fprintf(stderr, "soft_top: max %dMB\r\n", u3R->all.max_w / 256000);
2015-07-03 01:29:28 +03:00
}
2015-07-15 22:14:11 +03:00
#endif
2014-11-26 02:31:35 +03:00
u3m_grab(pro, u3_none);
2014-10-12 10:40:31 +04:00
}
2014-10-31 00:40:05 +03:00
2014-10-05 01:57:40 +04:00
/* Revert to external signal regime.
2014-09-30 20:45:51 +04:00
*/
2014-10-05 01:57:40 +04:00
_cm_signal_done();
2014-09-29 22:28:20 +04:00
2014-09-30 20:45:51 +04:00
/* Produce success, on the old road.
*/
2014-11-06 03:20:01 +03:00
pro = u3nc(0, u3m_love(pro));
2014-09-30 20:45:51 +04:00
}
else {
2014-10-05 01:57:40 +04:00
/* Overload the error result.
2014-09-30 20:45:51 +04:00
*/
2014-11-06 03:20:01 +03:00
pro = u3m_love(why);
2014-09-29 22:28:20 +04:00
}
2014-10-11 09:32:58 +04:00
2014-10-05 01:57:40 +04:00
/* Revert to external signal regime.
*/
_cm_signal_done();
2014-10-11 09:32:58 +04:00
/* Free the argument.
*/
u3z(arg);
2014-09-30 20:45:51 +04:00
/* Return the product.
*/
return pro;
2014-09-29 22:28:20 +04:00
}
2014-11-06 03:20:01 +03:00
/* u3m_soft_sure(): top-level call assumed correct.
2014-11-02 01:13:18 +03:00
*/
u3_noun
2014-11-06 03:20:01 +03:00
u3m_soft_sure(u3_funk fun_f, u3_noun arg)
2014-11-02 01:13:18 +03:00
{
2014-12-02 01:05:09 +03:00
u3_noun pro, pru = u3m_soft_top(0, (1 << 18), fun_f, arg);
2014-11-02 01:13:18 +03:00
2014-11-05 04:18:47 +03:00
c3_assert(_(u3du(pru)));
2014-11-02 01:13:18 +03:00
pro = u3k(u3t(pru));
u3z(pru);
return pro;
}
2014-11-06 03:20:01 +03:00
/* u3m_soft_slam: top-level call.
2014-11-02 01:13:18 +03:00
*/
2014-11-06 03:20:01 +03:00
u3_noun _cm_slam(u3_noun arg) { return u3n_slam_on(u3h(arg), u3t(arg)); }
2014-11-02 01:13:18 +03:00
u3_noun
2014-11-06 03:20:01 +03:00
u3m_soft_slam(u3_noun gat, u3_noun sam)
2014-11-02 01:13:18 +03:00
{
2014-11-06 03:20:01 +03:00
return u3m_soft_sure(_cm_slam, u3nc(gat, sam));
2014-11-02 01:13:18 +03:00
}
2014-11-16 04:10:15 +03:00
/* u3m_soft_nock: top-level nock.
*/
u3_noun _cm_nock(u3_noun arg) { return u3n_nock_on(u3h(arg), u3t(arg)); }
u3_noun
u3m_soft_nock(u3_noun bus, u3_noun fol)
{
return u3m_soft_sure(_cm_nock, u3nc(bus, fol));
}
2014-11-06 03:20:01 +03:00
/* u3m_soft_run(): descend into virtualization context.
2014-09-29 22:28:20 +04:00
*/
u3_noun
2014-11-06 03:20:01 +03:00
u3m_soft_run(u3_noun fly,
2015-01-15 22:10:29 +03:00
u3_funq fun_f,
u3_noun aga,
u3_noun agb)
2014-09-29 22:28:20 +04:00
{
2015-01-15 22:10:29 +03:00
u3_noun why = 0, pro;
2014-10-03 21:44:08 +04:00
2014-09-30 20:45:51 +04:00
/* Record the cap, and leap.
*/
2014-12-02 01:05:09 +03:00
u3m_hate(1 << 18);
2014-09-30 20:45:51 +04:00
2014-10-01 10:34:30 +04:00
/* Configure the new road.
*/
{
u3R->ski.flu = u3nc(fly, u3to(u3_road, u3R->par_p)->ski.flu);
u3R->pro.don = u3to(u3_road, u3R->par_p)->pro.don;
2014-10-01 10:34:30 +04:00
u3R->bug.tax = 0;
}
2015-01-15 22:10:29 +03:00
u3t_on(coy_o);
2014-10-01 10:34:30 +04:00
2014-09-30 20:45:51 +04:00
/* Trap for exceptions.
*/
2015-01-15 22:10:29 +03:00
if ( 0 == (why = (u3_noun)_setjmp(u3R->esc.buf)) ) {
u3t_off(coy_o);
2014-10-03 21:44:08 +04:00
pro = fun_f(aga, agb);
2014-09-29 22:28:20 +04:00
2015-07-15 22:14:11 +03:00
#ifdef U3_PRINT_WATERMARK
2015-07-03 03:17:14 +03:00
if ( u3R->all.max_w > 1000000 ) {
fprintf(stderr, "soft_run: max %dMB\r\n", u3R->all.max_w / 256000);
}
2015-07-15 22:14:11 +03:00
#endif
2014-09-30 20:45:51 +04:00
/* Produce success, on the old road.
*/
2014-11-06 03:20:01 +03:00
pro = u3nc(0, u3m_love(pro));
2014-09-29 22:28:20 +04:00
}
else {
2014-12-03 03:26:30 +03:00
u3t_init();
2014-09-30 20:45:51 +04:00
/* Produce - or fall again.
*/
{
2014-11-05 04:18:47 +03:00
c3_assert(_(u3du(why)));
2014-09-30 20:45:51 +04:00
switch ( u3h(why) ) {
default: c3_assert(0); return 0;
case 0: { // unusual: bail with success.
2014-11-06 03:20:01 +03:00
pro = u3m_love(why);
2014-09-30 20:45:51 +04:00
} break;
case 1: { // blocking request
2014-11-06 03:20:01 +03:00
pro = u3m_love(why);
2014-09-30 20:45:51 +04:00
} break;
case 2: { // true exit
2014-11-06 03:20:01 +03:00
pro = u3m_love(why);
2014-09-30 20:45:51 +04:00
} break;
2014-10-01 10:34:30 +04:00
case 3: { // failure; rebail w/trace
2014-11-06 03:20:01 +03:00
u3_noun yod = u3m_love(u3t(why));
2014-10-31 00:40:05 +03:00
2014-11-06 03:20:01 +03:00
u3m_bail
2014-09-30 20:45:51 +04:00
(u3nt(3,
2014-11-06 03:20:01 +03:00
u3a_take(u3h(yod)),
2014-11-06 22:13:57 +03:00
u3kb_weld(u3t(yod), u3k(u3R->bug.tax))));
2014-09-30 20:45:51 +04:00
} break;
case 4: { // meta-bail
2014-11-06 03:20:01 +03:00
u3m_bail(u3m_love(u3t(why)));
2014-09-30 20:45:51 +04:00
} break;
2014-09-29 22:28:20 +04:00
}
}
}
2014-10-01 10:34:30 +04:00
/* Release the arguments.
*/
{
u3z(fly);
u3z(aga);
u3z(agb);
}
2014-09-29 22:28:20 +04:00
2014-09-30 20:45:51 +04:00
/* Return the product.
*/
return pro;
2014-09-29 22:28:20 +04:00
}
2014-11-06 03:20:01 +03:00
/* u3m_soft_esc(): namespace lookup. Produces direct result.
2014-09-29 22:28:20 +04:00
*/
u3_noun
2014-11-06 03:20:01 +03:00
u3m_soft_esc(u3_noun sam)
2014-09-29 22:28:20 +04:00
{
2014-10-01 10:34:30 +04:00
u3_noun why, fly, pro;
2014-09-30 20:45:51 +04:00
2014-10-01 10:34:30 +04:00
/* Assert preconditions.
2014-09-30 20:45:51 +04:00
*/
{
2014-10-01 10:34:30 +04:00
c3_assert(0 != u3R->ski.flu);
fly = u3h(u3R->ski.flu);
2014-09-30 20:45:51 +04:00
}
2014-09-29 22:28:20 +04:00
2014-09-30 20:45:51 +04:00
/* Record the cap, and leap.
*/
2014-12-02 01:05:09 +03:00
u3m_hate(1 << 18);
2014-09-30 20:45:51 +04:00
2014-10-01 10:34:30 +04:00
/* Configure the new road.
*/
{
u3R->ski.flu = u3t(u3to(u3_road, u3R->par_p)->ski.flu);
u3R->pro.don = u3to(u3_road, u3R->par_p)->pro.don;
2014-10-01 10:34:30 +04:00
u3R->bug.tax = 0;
}
2014-09-30 20:45:51 +04:00
/* Trap for exceptions.
*/
2015-01-15 22:10:29 +03:00
if ( 0 == (why = (u3_noun)_setjmp(u3R->esc.buf)) ) {
2014-11-06 03:20:01 +03:00
pro = u3n_slam_on(fly, sam);
2014-09-30 20:45:51 +04:00
/* Fall back to the old road, leaving temporary memory intact.
*/
2014-11-06 03:20:01 +03:00
pro = u3m_love(pro);
}
else {
2014-12-03 03:26:30 +03:00
u3t_init();
2014-09-30 20:45:51 +04:00
/* Push the error back up to the calling context - not the run we
2014-10-01 10:34:30 +04:00
** are in, but the caller of the run, matching pure nock semantics.
2014-09-30 20:45:51 +04:00
*/
2014-11-06 03:20:01 +03:00
u3m_bail(u3nc(4, u3m_love(why)));
}
2014-09-30 20:45:51 +04:00
2014-10-01 10:34:30 +04:00
/* Release the sample.
*/
u3z(sam);
2014-09-30 20:45:51 +04:00
/* Return the product.
*/
return pro;
}
2014-09-12 04:41:26 +04:00
2014-11-26 02:31:35 +03:00
/* u3m_grab(): garbage-collect the world, plus extra roots.
*/
void
u3m_grab(u3_noun som, ...) // terminate with u3_none
{
// u3h_free(u3R->cax.har_p);
// u3R->cax.har_p = u3h_new();
u3v_mark();
u3m_mark();
{
va_list vap;
u3_noun tur;
va_start(vap, som);
if ( som != u3_none ) {
u3a_mark_noun(som);
while ( u3_none != (tur = va_arg(vap, u3_noun)) ) {
u3a_mark_noun(tur);
}
}
va_end(vap);
}
u3a_sweep();
}
2014-11-06 03:20:01 +03:00
/* u3m_soft(): top-level wrapper.
**
** Produces [0 product] or [%error (list tank)], top last.
2014-10-01 10:34:30 +04:00
*/
u3_noun
2014-11-06 03:20:01 +03:00
u3m_soft(c3_w sec_w,
2014-10-01 10:34:30 +04:00
u3_funk fun_f,
u3_noun arg)
{
2014-10-28 20:36:22 +03:00
u3_noun why;
2014-10-31 00:40:05 +03:00
2014-12-02 01:05:09 +03:00
why = u3m_soft_top(sec_w, (1 << 18), fun_f, arg); // 512K pad
2014-10-01 10:34:30 +04:00
if ( 0 == u3h(why) ) {
return why;
} else {
u3_noun tax, cod, pro, mok;
c3_assert(1 != u3h(why)); // don't use .^ at the top level!
if ( 2 == u3h(why) ) {
cod = c3__exit;
tax = u3k(u3t(why));
}
else {
c3_assert(3 == u3h(why));
cod = u3k(u3h(u3t(why)));
tax = u3k(u3t(u3t(why)));
}
2014-11-06 06:10:22 +03:00
mok = u3dc("mook", 2, tax);
pro = u3nc(cod, u3k(u3t(mok)));
u3z(mok);
u3z(why);
return pro;
2014-10-01 10:34:30 +04:00
}
}
2014-09-12 04:41:26 +04:00
/* _cm_is_tas(): yes iff som (RETAIN) is @tas.
*/
static c3_o
_cm_is_tas(u3_atom som, c3_w len_w)
{
c3_w i_w;
for ( i_w = 0; i_w < len_w; i_w++ ) {
2014-11-06 03:20:01 +03:00
c3_c c_c = u3r_byte(i_w, som);
2014-09-12 04:41:26 +04:00
if ( islower(c_c) ||
(isdigit(c_c) && (0 != i_w) && ((len_w - 1) != i_w))
|| '-' == c_c )
{
continue;
}
2014-11-05 04:18:47 +03:00
return c3n;
2014-09-12 04:41:26 +04:00
}
2014-11-05 04:18:47 +03:00
return c3y;
2014-09-12 04:41:26 +04:00
}
/* _cm_is_ta(): yes iff som (RETAIN) is @ta.
*/
static c3_o
_cm_is_ta(u3_noun som, c3_w len_w)
{
c3_w i_w;
for ( i_w = 0; i_w < len_w; i_w++ ) {
2014-11-06 03:20:01 +03:00
c3_c c_c = u3r_byte(i_w, som);
2014-09-12 04:41:26 +04:00
if ( (c_c < 32) || (c_c > 127) ) {
2014-11-05 04:18:47 +03:00
return c3n;
2014-09-12 04:41:26 +04:00
}
}
2014-11-05 04:18:47 +03:00
return c3y;
2014-09-12 04:41:26 +04:00
}
2014-09-15 07:09:40 +04:00
/* _cm_hex(): hex byte.
*/
c3_y _cm_hex(c3_y c_y)
{
if ( c_y < 10 )
return '0' + c_y;
else return 'a' + (c_y - 10);
}
2014-09-12 04:41:26 +04:00
/* _cm_in_pretty: measure/cut prettyprint.
*/
static c3_w
_cm_in_pretty(u3_noun som, c3_o sel_o, c3_c* str_c)
{
2014-11-05 04:18:47 +03:00
if ( _(u3du(som)) ) {
2014-09-12 04:41:26 +04:00
c3_w sel_w, one_w, two_w;
sel_w = 0;
2014-11-05 04:18:47 +03:00
if ( _(sel_o) ) {
2014-09-12 04:41:26 +04:00
if ( str_c ) { *(str_c++) = '['; }
sel_w += 1;
}
2014-11-05 04:18:47 +03:00
one_w = _cm_in_pretty(u3h(som), c3y, str_c);
2014-09-12 04:41:26 +04:00
if ( str_c ) {
str_c += one_w;
*(str_c++) = ' ';
}
2014-11-05 04:18:47 +03:00
two_w = _cm_in_pretty(u3t(som), c3n, str_c);
2014-09-12 22:32:11 +04:00
if ( str_c ) { str_c += two_w; }
2014-09-12 04:41:26 +04:00
2014-11-05 04:18:47 +03:00
if ( _(sel_o) ) {
2014-09-12 04:41:26 +04:00
if ( str_c ) { *(str_c++) = ']'; }
sel_w += 1;
}
2014-09-12 22:32:11 +04:00
return one_w + two_w + 1 + sel_w;
2014-09-12 04:41:26 +04:00
}
else {
2014-09-13 00:18:03 +04:00
if ( som < 65536 ) {
c3_c buf_c[6];
2014-09-12 04:41:26 +04:00
c3_w len_w;
2014-09-13 00:18:03 +04:00
snprintf(buf_c, 6, "%d", som);
2014-09-12 04:41:26 +04:00
len_w = strlen(buf_c);
if ( str_c ) { strcpy(str_c, buf_c); str_c += len_w; }
return len_w;
}
else {
2014-11-06 03:20:01 +03:00
c3_w len_w = u3r_met(3, som);
2014-09-12 04:41:26 +04:00
2014-11-05 04:18:47 +03:00
if ( _(_cm_is_tas(som, len_w)) ) {
2014-11-06 03:20:01 +03:00
c3_w len_w = u3r_met(3, som);
2014-09-12 04:41:26 +04:00
if ( str_c ) {
*(str_c++) = '%';
2014-11-06 03:20:01 +03:00
u3r_bytes(0, len_w, (c3_y *)str_c, som);
2014-09-12 04:41:26 +04:00
str_c += len_w;
}
return len_w + 1;
}
2014-11-05 04:18:47 +03:00
else if ( _(_cm_is_ta(som, len_w)) ) {
2014-09-12 04:41:26 +04:00
if ( str_c ) {
*(str_c++) = '\'';
2014-11-06 03:20:01 +03:00
u3r_bytes(0, len_w, (c3_y *)str_c, som);
2014-09-12 04:41:26 +04:00
str_c += len_w;
*(str_c++) = '\'';
}
return len_w + 2;
}
else {
2014-11-06 03:20:01 +03:00
c3_w len_w = u3r_met(3, som);
2014-09-15 07:09:40 +04:00
c3_c *buf_c = malloc(2 + (2 * len_w) + 1);
c3_w i_w = 0;
c3_w a_w = 0;
buf_c[a_w++] = '0';
2014-09-15 07:27:48 +04:00
buf_c[a_w++] = 'x';
2014-09-15 07:09:40 +04:00
for ( i_w = 0; i_w < len_w; i_w++ ) {
2014-11-06 03:20:01 +03:00
c3_y c_y = u3r_byte(len_w - (i_w + 1), som);
2014-09-15 07:09:40 +04:00
if ( (i_w == 0) && (c_y <= 0xf) ) {
buf_c[a_w++] = _cm_hex(c_y);
} else {
buf_c[a_w++] = _cm_hex(c_y >> 4);
buf_c[a_w++] = _cm_hex(c_y & 0xf);
}
}
buf_c[a_w] = 0;
len_w = a_w;
2014-09-12 04:41:26 +04:00
if ( str_c ) { strcpy(str_c, buf_c); str_c += len_w; }
free(buf_c);
return len_w;
}
}
}
}
2014-11-06 03:20:01 +03:00
/* u3m_pretty(): dumb prettyprint to string.
2014-09-12 04:41:26 +04:00
*/
c3_c*
2014-11-06 03:20:01 +03:00
u3m_pretty(u3_noun som)
2014-09-12 04:41:26 +04:00
{
2014-11-05 04:18:47 +03:00
c3_w len_w = _cm_in_pretty(som, c3y, 0);
2014-09-12 04:41:26 +04:00
c3_c* pre_c = malloc(len_w + 1);
2014-11-05 04:18:47 +03:00
_cm_in_pretty(som, c3y, pre_c);
2014-09-12 22:32:11 +04:00
pre_c[len_w] = 0;
2014-09-12 04:41:26 +04:00
return pre_c;
}
2014-11-06 03:20:01 +03:00
/* u3m_p(): dumb print with caption.
2014-09-12 04:41:26 +04:00
*/
void
2014-11-06 03:20:01 +03:00
u3m_p(const c3_c* cap_c, u3_noun som)
2014-09-12 04:41:26 +04:00
{
2014-11-06 03:20:01 +03:00
c3_c* pre_c = u3m_pretty(som);
2014-09-12 04:41:26 +04:00
2014-10-03 21:44:08 +04:00
fprintf(stderr, "%s: %s\r\n", cap_c, pre_c);
2014-09-12 04:41:26 +04:00
free(pre_c);
}
2014-09-27 04:27:35 +04:00
2014-11-06 03:20:01 +03:00
/* u3m_tape(): dump a tape to stdout.
2014-09-27 04:27:35 +04:00
*/
void
2014-11-06 03:20:01 +03:00
u3m_tape(u3_noun tep)
2014-09-27 04:27:35 +04:00
{
u3_noun tap = tep;
while ( u3_nul != tap ) {
c3_c car_c;
if ( u3h(tap) >= 127 ) {
car_c = '?';
} else car_c = u3h(tap);
putc(car_c, stdout);
tap = u3t(tap);
}
u3z(tep);
}
2014-11-06 03:20:01 +03:00
/* u3m_wall(): dump a wall to stdout.
2014-09-27 04:27:35 +04:00
*/
void
2014-11-06 03:20:01 +03:00
u3m_wall(u3_noun wol)
2014-09-27 04:27:35 +04:00
{
u3_noun wal = wol;
while ( u3_nul != wal ) {
2014-11-06 03:20:01 +03:00
u3m_tape(u3k(u3h(wal)));
2014-09-27 04:27:35 +04:00
putc(13, stdout);
putc(10, stdout);
wal = u3t(wal);
}
u3z(wol);
}
2014-11-16 04:10:15 +03:00
/* _cm_limits(): set up global modes and limits.
*/
static void
_cm_limits(void)
{
struct rlimit rlm;
c3_i ret_i;
/* Moar stack.
*/
{
ret_i = getrlimit(RLIMIT_STACK, &rlm);
c3_assert(0 == ret_i);
rlm.rlim_cur = (rlm.rlim_max > (65536 << 10))
? (65536 << 10)
: rlm.rlim_max;
if ( 0 != setrlimit(RLIMIT_STACK, &rlm) ) {
perror("stack");
exit(1);
}
}
/* Moar filez.
*/
{
ret_i = getrlimit(RLIMIT_NOFILE, &rlm);
c3_assert(0 == ret_i);
2015-06-01 16:34:06 +03:00
rlm.rlim_cur = 10240; // default OSX max, not in rlim_max irritatingly
2014-11-16 04:10:15 +03:00
if ( 0 != setrlimit(RLIMIT_NOFILE, &rlm) ) {
2015-06-10 02:12:36 +03:00
// perror("file limit");
2014-11-16 04:10:15 +03:00
// no exit, not a critical limit
}
}
/* Moar core.
*/
{
getrlimit(RLIMIT_CORE, &rlm);
rlm.rlim_cur = RLIM_INFINITY;
if ( 0 != setrlimit(RLIMIT_CORE, &rlm) ) {
perror("core limit");
// no exit, not a critical limit
}
}
}
/* _cm_signals(): set up interrupts, etc.
*/
static void
_cm_signals(void)
{
if ( 0 != sigsegv_install_handler(u3e_fault) ) {
fprintf(stderr, "sigsegv install failed\n");
exit(1);
}
// signal(SIGINT, _loom_stop);
2014-11-30 13:06:41 +03:00
// Block SIGPROF, so that if/when we reactivate it on the
2014-12-01 03:06:08 +03:00
// main thread for profiling, we won't get hits in parallel
2014-11-30 13:06:41 +03:00
// on other threads.
{
sigset_t set;
sigemptyset(&set);
sigaddset(&set, SIGPROF);
if ( 0 != pthread_sigmask(SIG_BLOCK, &set, NULL) ) {
perror("pthread_sigmask");
exit(1);
}
}
2014-11-16 04:10:15 +03:00
}
/* _cm_init(): start the environment, with/without checkpointing.
*/
void
_cm_init(c3_o chk_o)
{
_cm_limits();
_cm_signals();
/* Make sure GMP uses our malloc.
*/
mp_set_memory_functions(u3a_malloc, u3a_realloc2, u3a_free2);
/* Map at fixed address.
*/
{
c3_w len_w = u3a_bytes;
void* map_v;
map_v = mmap((void *)u3_Loom,
len_w,
_(chk_o) ? PROT_READ : (PROT_READ | PROT_WRITE),
(MAP_ANON | MAP_FIXED | MAP_PRIVATE),
-1, 0);
if ( -1 == (c3_ps)map_v ) {
map_v = mmap((void *)0,
len_w,
PROT_READ,
MAP_ANON | MAP_PRIVATE,
-1, 0);
if ( -1 == (c3_ps)map_v ) {
fprintf(stderr, "boot: map failed twice\r\n");
} else {
fprintf(stderr, "boot: map failed - try U3_OS_LoomBase %p\r\n", map_v);
}
exit(1);
}
printf("loom: mapped %dMB\r\n", len_w >> 20);
}
}
/* u3m_boot(): start the u3 system.
*/
void
u3m_boot(c3_o nuu_o, c3_o bug_o, c3_c* dir_c)
{
/* Activate the loom.
*/
_cm_init(nuu_o);
/* Activate the storage system.
*/
2014-11-20 03:46:16 +03:00
nuu_o = u3e_live(nuu_o, dir_c);
2014-11-16 04:10:15 +03:00
2014-12-03 03:26:30 +03:00
/* Activate tracing.
*/
u3t_init();
2014-11-16 04:10:15 +03:00
/* Construct or activate the allocator.
*/
_cm_pave(nuu_o, bug_o);
/* Initialize the jet system.
*/
u3j_boot();
/* Install or reactivate the kernel.
*/
if ( _(nuu_o) ) {
c3_c pas_c[2049];
struct stat buf_u;
snprintf(pas_c, 2048, "%s/.urb/urbit.pill", dir_c);
if ( -1 == stat(pas_c, &buf_u) ) {
snprintf(pas_c, 2048, "%s/urbit.pill", U3_LIB);
}
printf("boot: loading %s\r\n", pas_c);
u3v_make(pas_c);
u3v_jack();
}
else {
u3v_hose();
u3j_ream();
}
}