Commit c81a0ed3 authored by Russ Cox's avatar Russ Cox

liblink, runtime: diagnose and fix C code running on Go stack

This CL contains compiler+runtime changes that detect C code
running on Go (not g0, not gsignal) stacks, and it contains
corrections for what it detected.

The detection works by changing the C prologue to use a different
stack guard word in the G than Go prologue does. On the g0 and
gsignal stacks, that stack guard word is set to the usual
stack guard value. But on ordinary Go stacks, that stack
guard word is set to ^0, which will make any stack split
check fail. The C prologue then calls morestackc instead
of morestack, and morestackc aborts the program with
a message about running C code on a Go stack.

This check catches all C code running on the Go stack
except NOSPLIT code. The NOSPLIT code is allowed,
so the check is complete. Since it is a dynamic check,
the code must execute to be caught. But unlike the static
checks we've been using in cmd/ld, the dynamic check
works with function pointers and other indirect calls.
For example it caught sigpanic being pushed onto Go
stacks in the signal handlers.

Fixes #8667.

LGTM=khr, iant
R=golang-codereviews, khr, iant
CC=golang-codereviews, r
https://golang.org/cl/133700043
parent 52631983
...@@ -769,6 +769,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int noctxt) ...@@ -769,6 +769,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int noctxt)
p->as = AMOVW; p->as = AMOVW;
p->from.type = D_OREG; p->from.type = D_OREG;
p->from.reg = REGG; p->from.reg = REGG;
if(ctxt->cursym->cfunc)
p->from.offset = 3*ctxt->arch->ptrsize;
p->to.type = D_REG; p->to.type = D_REG;
p->to.reg = 1; p->to.reg = 1;
...@@ -884,6 +886,9 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int noctxt) ...@@ -884,6 +886,9 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int noctxt)
p->as = ABL; p->as = ABL;
p->scond = C_SCOND_LS; p->scond = C_SCOND_LS;
p->to.type = D_BRANCH; p->to.type = D_BRANCH;
if(ctxt->cursym->cfunc)
p->to.sym = linklookup(ctxt, "runtime.morestackc", 0);
else
p->to.sym = ctxt->symmorestack[noctxt]; p->to.sym = ctxt->symmorestack[noctxt];
// BLS start // BLS start
......
...@@ -783,6 +783,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int32 textarg, int noctxt, Prog ...@@ -783,6 +783,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int32 textarg, int noctxt, Prog
p->as = cmp; p->as = cmp;
p->from.type = D_SP; p->from.type = D_SP;
indir_cx(ctxt, &p->to); indir_cx(ctxt, &p->to);
if(ctxt->cursym->cfunc)
p->to.offset = 3*ctxt->arch->ptrsize;
} else if(framesize <= StackBig) { } else if(framesize <= StackBig) {
// large stack: SP-framesize <= stackguard-StackSmall // large stack: SP-framesize <= stackguard-StackSmall
// LEAQ -xxx(SP), AX // LEAQ -xxx(SP), AX
...@@ -797,6 +799,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int32 textarg, int noctxt, Prog ...@@ -797,6 +799,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int32 textarg, int noctxt, Prog
p->as = cmp; p->as = cmp;
p->from.type = D_AX; p->from.type = D_AX;
indir_cx(ctxt, &p->to); indir_cx(ctxt, &p->to);
if(ctxt->cursym->cfunc)
p->to.offset = 3*ctxt->arch->ptrsize;
} else { } else {
// Such a large stack we need to protect against wraparound. // Such a large stack we need to protect against wraparound.
// If SP is close to zero: // If SP is close to zero:
...@@ -817,6 +821,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int32 textarg, int noctxt, Prog ...@@ -817,6 +821,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int32 textarg, int noctxt, Prog
p->as = mov; p->as = mov;
indir_cx(ctxt, &p->from); indir_cx(ctxt, &p->from);
p->from.offset = 0; p->from.offset = 0;
if(ctxt->cursym->cfunc)
p->from.offset = 3*ctxt->arch->ptrsize;
p->to.type = D_SI; p->to.type = D_SI;
p = appendp(ctxt, p); p = appendp(ctxt, p);
...@@ -873,6 +879,11 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int32 textarg, int noctxt, Prog ...@@ -873,6 +879,11 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int32 textarg, int noctxt, Prog
// 4 varieties varieties (const1==0 cross const2==0) // 4 varieties varieties (const1==0 cross const2==0)
// and 6 subvarieties of (const1==0 and const2!=0) // and 6 subvarieties of (const1==0 and const2!=0)
p = appendp(ctxt, p); p = appendp(ctxt, p);
if(ctxt->cursym->cfunc) {
p->as = ACALL;
p->to.type = D_BRANCH;
p->to.sym = linklookup(ctxt, "runtime.morestackc", 0);
} else
if(moreconst1 == 0 && moreconst2 == 0) { if(moreconst1 == 0 && moreconst2 == 0) {
p->as = ACALL; p->as = ACALL;
p->to.type = D_BRANCH; p->to.type = D_BRANCH;
......
...@@ -539,6 +539,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int noctxt, Prog **jmpok) ...@@ -539,6 +539,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int noctxt, Prog **jmpok)
p->as = ACMPL; p->as = ACMPL;
p->from.type = D_SP; p->from.type = D_SP;
p->to.type = D_INDIR+D_CX; p->to.type = D_INDIR+D_CX;
if(ctxt->cursym->cfunc)
p->to.offset = 3*ctxt->arch->ptrsize;
} else if(framesize <= StackBig) { } else if(framesize <= StackBig) {
// large stack: SP-framesize <= stackguard-StackSmall // large stack: SP-framesize <= stackguard-StackSmall
// LEAL -(framesize-StackSmall)(SP), AX // LEAL -(framesize-StackSmall)(SP), AX
...@@ -553,6 +555,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int noctxt, Prog **jmpok) ...@@ -553,6 +555,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int noctxt, Prog **jmpok)
p->as = ACMPL; p->as = ACMPL;
p->from.type = D_AX; p->from.type = D_AX;
p->to.type = D_INDIR+D_CX; p->to.type = D_INDIR+D_CX;
if(ctxt->cursym->cfunc)
p->to.offset = 3*ctxt->arch->ptrsize;
} else { } else {
// Such a large stack we need to protect against wraparound // Such a large stack we need to protect against wraparound
// if SP is close to zero. // if SP is close to zero.
...@@ -572,6 +576,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int noctxt, Prog **jmpok) ...@@ -572,6 +576,8 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int noctxt, Prog **jmpok)
p->as = AMOVL; p->as = AMOVL;
p->from.type = D_INDIR+D_CX; p->from.type = D_INDIR+D_CX;
p->from.offset = 0; p->from.offset = 0;
if(ctxt->cursym->cfunc)
p->from.offset = 3*ctxt->arch->ptrsize;
p->to.type = D_SI; p->to.type = D_SI;
p = appendp(ctxt, p); p = appendp(ctxt, p);
...@@ -641,6 +647,9 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int noctxt, Prog **jmpok) ...@@ -641,6 +647,9 @@ stacksplit(Link *ctxt, Prog *p, int32 framesize, int noctxt, Prog **jmpok)
p = appendp(ctxt, p); p = appendp(ctxt, p);
p->as = ACALL; p->as = ACALL;
p->to.type = D_BRANCH; p->to.type = D_BRANCH;
if(ctxt->cursym->cfunc)
p->to.sym = linklookup(ctxt, "runtime.morestackc", 0);
else
p->to.sym = ctxt->symmorestack[noctxt]; p->to.sym = ctxt->symmorestack[noctxt];
p = appendp(ctxt, p); p = appendp(ctxt, p);
......
...@@ -33,18 +33,7 @@ ...@@ -33,18 +33,7 @@
// crosscall2(_cgo_allocate, &a, sizeof a); // crosscall2(_cgo_allocate, &a, sizeof a);
// /* Here a.ret is a pointer to the allocated memory. */ // /* Here a.ret is a pointer to the allocated memory. */
static void void runtime·_cgo_allocate_internal(void);
_cgo_allocate_internal(uintptr len, byte *ret)
{
CgoMal *c;
ret = runtime·mallocgc(len, nil, 0);
c = runtime·mallocgc(sizeof(*c), nil, 0);
c->next = g->m->cgomal;
c->alloc = ret;
g->m->cgomal = c;
FLUSH(&ret);
}
#pragma cgo_export_static _cgo_allocate #pragma cgo_export_static _cgo_allocate
#pragma cgo_export_dynamic _cgo_allocate #pragma cgo_export_dynamic _cgo_allocate
...@@ -52,7 +41,7 @@ _cgo_allocate_internal(uintptr len, byte *ret) ...@@ -52,7 +41,7 @@ _cgo_allocate_internal(uintptr len, byte *ret)
void void
_cgo_allocate(void *a, int32 n) _cgo_allocate(void *a, int32 n)
{ {
runtime·cgocallback((void(*)(void))_cgo_allocate_internal, a, n); runtime·cgocallback((void(*)(void))runtime·_cgo_allocate_internal, a, n);
} }
// Panic. The argument is converted into a Go string. // Panic. The argument is converted into a Go string.
...@@ -63,18 +52,7 @@ _cgo_allocate(void *a, int32 n) ...@@ -63,18 +52,7 @@ _cgo_allocate(void *a, int32 n)
// crosscall2(_cgo_panic, &a, sizeof a); // crosscall2(_cgo_panic, &a, sizeof a);
// /* The function call will not return. */ // /* The function call will not return. */
extern void ·cgoStringToEface(String, Eface*); void runtime·_cgo_panic_internal(void);
static void
_cgo_panic_internal(byte *p)
{
String s;
Eface err;
s = runtime·gostring(p);
·cgoStringToEface(s, &err);
runtime·gopanic(err);
}
#pragma cgo_export_static _cgo_panic #pragma cgo_export_static _cgo_panic
#pragma cgo_export_dynamic _cgo_panic #pragma cgo_export_dynamic _cgo_panic
...@@ -82,7 +60,7 @@ _cgo_panic_internal(byte *p) ...@@ -82,7 +60,7 @@ _cgo_panic_internal(byte *p)
void void
_cgo_panic(void *a, int32 n) _cgo_panic(void *a, int32 n)
{ {
runtime·cgocallback((void(*)(void))_cgo_panic_internal, a, n); runtime·cgocallback((void(*)(void))runtime·_cgo_panic_internal, a, n);
} }
#pragma cgo_import_static x_cgo_init #pragma cgo_import_static x_cgo_init
......
...@@ -24,10 +24,3 @@ package cgo ...@@ -24,10 +24,3 @@ package cgo
*/ */
import "C" import "C"
// Supports _cgo_panic by converting a string constant to an empty
// interface.
func cgoStringToEface(s string, ret *interface{}) {
*ret = s
}
// Copyright 2011 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
package runtime
import "unsafe"
// These functions are called from C code via cgo/callbacks.c.
// Allocate memory. This allocates the requested number of bytes in
// memory controlled by the Go runtime. The allocated memory will be
// zeroed. You are responsible for ensuring that the Go garbage
// collector can see a pointer to the allocated memory for as long as
// it is valid, e.g., by storing a pointer in a local variable in your
// C function, or in memory allocated by the Go runtime. If the only
// pointers are in a C global variable or in memory allocated via
// malloc, then the Go garbage collector may collect the memory.
//
// TODO(rsc,iant): This memory is untyped.
// Either we need to add types or we need to stop using it.
func _cgo_allocate_internal(len uintptr) unsafe.Pointer {
ret := gomallocgc(len, nil, 0)
c := new(cgomal)
c.alloc = ret
gp := getg()
c.next = gp.m.cgomal
gp.m.cgomal = c
return ret
}
// Panic.
func _cgo_panic_internal(p *byte) {
panic(gostringnocopy(p))
}
...@@ -711,7 +711,7 @@ dumpmemprof(void) ...@@ -711,7 +711,7 @@ dumpmemprof(void)
} }
static void static void
mdump(G *gp) mdump(void)
{ {
byte *hdr; byte *hdr;
uintptr i; uintptr i;
...@@ -737,18 +737,32 @@ mdump(G *gp) ...@@ -737,18 +737,32 @@ mdump(G *gp)
dumpmemprof(); dumpmemprof();
dumpint(TagEOF); dumpint(TagEOF);
flush(); flush();
gp->param = nil;
runtime·casgstatus(gp, Gwaiting, Grunning);
runtime·gogo(&gp->sched);
} }
static void writeheapdump_m(void);
#pragma textflag NOSPLIT
void void
runtimedebug·WriteHeapDump(uintptr fd) runtimedebug·WriteHeapDump(uintptr fd)
{ {
void (*fn)(G*); void (*fn)(void);
g->m->scalararg[0] = fd;
fn = writeheapdump_m;
runtime·onM(&fn);
}
static void
writeheapdump_m(void)
{
uintptr fd;
fd = g->m->scalararg[0];
g->m->scalararg[0] = 0;
// Stop the world. // Stop the world.
runtime·casgstatus(g->m->curg, Grunning, Gwaiting);
g->waitreason = runtime·gostringnocopy((byte*)"dumping heap");
runtime·semacquire(&runtime·worldsema, false); runtime·semacquire(&runtime·worldsema, false);
g->m->gcing = 1; g->m->gcing = 1;
runtime·stoptheworld(); runtime·stoptheworld();
...@@ -761,11 +775,8 @@ runtime∕debug·WriteHeapDump(uintptr fd) ...@@ -761,11 +775,8 @@ runtime∕debug·WriteHeapDump(uintptr fd)
// Set dump file. // Set dump file.
dumpfd = fd; dumpfd = fd;
// Call dump routine on M stack. // Call dump routine.
runtime·casgstatus(g, Grunning, Gwaiting); mdump();
g->waitreason = runtime·gostringnocopy((byte*)"dumping heap");
fn = mdump;
runtime·mcall(&fn);
// Reset dump file. // Reset dump file.
dumpfd = 0; dumpfd = 0;
...@@ -780,6 +791,7 @@ runtime∕debug·WriteHeapDump(uintptr fd) ...@@ -780,6 +791,7 @@ runtime∕debug·WriteHeapDump(uintptr fd)
g->m->locks++; g->m->locks++;
runtime·semrelease(&runtime·worldsema); runtime·semrelease(&runtime·worldsema);
runtime·starttheworld(); runtime·starttheworld();
runtime·casgstatus(g->m->curg, Gwaiting, Grunning);
g->m->locks--; g->m->locks--;
} }
......
...@@ -124,9 +124,8 @@ static FinBlock *allfin; // list of all blocks ...@@ -124,9 +124,8 @@ static FinBlock *allfin; // list of all blocks
BitVector runtime·gcdatamask; BitVector runtime·gcdatamask;
BitVector runtime·gcbssmask; BitVector runtime·gcbssmask;
static Mutex gclock; extern Mutex runtime·gclock;
static void bgsweep(void);
static Workbuf* getempty(Workbuf*); static Workbuf* getempty(Workbuf*);
static Workbuf* getfull(Workbuf*); static Workbuf* getfull(Workbuf*);
static void putempty(Workbuf*); static void putempty(Workbuf*);
...@@ -137,7 +136,8 @@ static bool scanframe(Stkframe *frame, void *unused); ...@@ -137,7 +136,8 @@ static bool scanframe(Stkframe *frame, void *unused);
static void scanstack(G *gp); static void scanstack(G *gp);
static BitVector unrollglobgcprog(byte *prog, uintptr size); static BitVector unrollglobgcprog(byte *prog, uintptr size);
static FuncVal bgsweepv = {bgsweep}; void runtime·bgsweep(void);
static FuncVal bgsweepv = {runtime·bgsweep};
static struct { static struct {
uint64 full; // lock-free list of full blocks uint64 full; // lock-free list of full blocks
...@@ -1041,9 +1041,10 @@ runtime·MSpan_Sweep(MSpan *s, bool preserve) ...@@ -1041,9 +1041,10 @@ runtime·MSpan_Sweep(MSpan *s, bool preserve)
return res; return res;
} }
// State of background sweep. // State of background runtime·sweep.
// Pretected by gclock. // Pretected by runtime·gclock.
static struct // Must match mgc0.go.
struct
{ {
G* g; G* g;
bool parked; bool parked;
...@@ -1052,29 +1053,7 @@ static struct ...@@ -1052,29 +1053,7 @@ static struct
uint32 nbgsweep; uint32 nbgsweep;
uint32 npausesweep; uint32 npausesweep;
} sweep; } runtime·sweep;
// background sweeping goroutine
static void
bgsweep(void)
{
g->issystem = true;
for(;;) {
while(runtime·sweepone() != -1) {
sweep.nbgsweep++;
runtime·gosched();
}
runtime·lock(&gclock);
if(!runtime·mheap.sweepdone) {
// It's possible if GC has happened between sweepone has
// returned -1 and gclock lock.
runtime·unlock(&gclock);
continue;
}
sweep.parked = true;
runtime·parkunlock(&gclock, runtime·gostringnocopy((byte*)"GC sweep wait"));
}
}
// sweeps one span // sweeps one span
// returns number of pages returned to heap, or -1 if there is nothing to sweep // returns number of pages returned to heap, or -1 if there is nothing to sweep
...@@ -1090,7 +1069,7 @@ runtime·sweepone(void) ...@@ -1090,7 +1069,7 @@ runtime·sweepone(void)
g->m->locks++; g->m->locks++;
sg = runtime·mheap.sweepgen; sg = runtime·mheap.sweepgen;
for(;;) { for(;;) {
idx = runtime·xadd(&sweep.spanidx, 1) - 1; idx = runtime·xadd(&runtime·sweep.spanidx, 1) - 1;
if(idx >= work.nspan) { if(idx >= work.nspan) {
runtime·mheap.sweepdone = true; runtime·mheap.sweepdone = true;
g->m->locks--; g->m->locks--;
...@@ -1111,6 +1090,30 @@ runtime·sweepone(void) ...@@ -1111,6 +1090,30 @@ runtime·sweepone(void)
} }
} }
static void
sweepone_m(void)
{
g->m->scalararg[0] = runtime·sweepone();
}
#pragma textflag NOSPLIT
uintptr
runtime·gosweepone(void)
{
void (*fn)(void);
fn = sweepone_m;
runtime·onM(&fn);
return g->m->scalararg[0];
}
#pragma textflag NOSPLIT
bool
runtime·gosweepdone(void)
{
return runtime·mheap.sweepdone;
}
void void
runtime·gchelper(void) runtime·gchelper(void)
{ {
...@@ -1328,7 +1331,7 @@ gc(struct gc_args *args) ...@@ -1328,7 +1331,7 @@ gc(struct gc_args *args)
// Sweep what is not sweeped by bgsweep. // Sweep what is not sweeped by bgsweep.
while(runtime·sweepone() != -1) while(runtime·sweepone() != -1)
sweep.npausesweep++; runtime·sweep.npausesweep++;
// Cache runtime.mheap.allspans in work.spans to avoid conflicts with // Cache runtime.mheap.allspans in work.spans to avoid conflicts with
// resizing/freeing allspans. // resizing/freeing allspans.
...@@ -1407,11 +1410,11 @@ gc(struct gc_args *args) ...@@ -1407,11 +1410,11 @@ gc(struct gc_args *args)
mstats.numgc, work.nproc, (t1-t0)/1000, (t2-t1)/1000, (t3-t2)/1000, (t4-t3)/1000, mstats.numgc, work.nproc, (t1-t0)/1000, (t2-t1)/1000, (t3-t2)/1000, (t4-t3)/1000,
heap0>>20, heap1>>20, obj, heap0>>20, heap1>>20, obj,
mstats.nmalloc, mstats.nfree, mstats.nmalloc, mstats.nfree,
work.nspan, sweep.nbgsweep, sweep.npausesweep, work.nspan, runtime·sweep.nbgsweep, runtime·sweep.npausesweep,
stats.nhandoff, stats.nhandoffcnt, stats.nhandoff, stats.nhandoffcnt,
work.markfor->nsteal, work.markfor->nstealcnt, work.markfor->nsteal, work.markfor->nstealcnt,
stats.nprocyield, stats.nosyield, stats.nsleep); stats.nprocyield, stats.nosyield, stats.nsleep);
sweep.nbgsweep = sweep.npausesweep = 0; runtime·sweep.nbgsweep = runtime·sweep.npausesweep = 0;
} }
// See the comment in the beginning of this function as to why we need the following. // See the comment in the beginning of this function as to why we need the following.
...@@ -1426,23 +1429,23 @@ gc(struct gc_args *args) ...@@ -1426,23 +1429,23 @@ gc(struct gc_args *args)
runtime·mheap.sweepdone = false; runtime·mheap.sweepdone = false;
work.spans = runtime·mheap.allspans; work.spans = runtime·mheap.allspans;
work.nspan = runtime·mheap.nspan; work.nspan = runtime·mheap.nspan;
sweep.spanidx = 0; runtime·sweep.spanidx = 0;
runtime·unlock(&runtime·mheap.lock); runtime·unlock(&runtime·mheap.lock);
// Temporary disable concurrent sweep, because we see failures on builders. // Temporary disable concurrent sweep, because we see failures on builders.
if(ConcurrentSweep && !args->eagersweep) { if(ConcurrentSweep && !args->eagersweep) {
runtime·lock(&gclock); runtime·lock(&runtime·gclock);
if(sweep.g == nil) if(runtime·sweep.g == nil)
sweep.g = runtime·newproc1(&bgsweepv, nil, 0, 0, gc); runtime·sweep.g = runtime·newproc1(&bgsweepv, nil, 0, 0, gc);
else if(sweep.parked) { else if(runtime·sweep.parked) {
sweep.parked = false; runtime·sweep.parked = false;
runtime·ready(sweep.g); runtime·ready(runtime·sweep.g);
} }
runtime·unlock(&gclock); runtime·unlock(&runtime·gclock);
} else { } else {
// Sweep all spans eagerly. // Sweep all spans eagerly.
while(runtime·sweepone() != -1) while(runtime·sweepone() != -1)
sweep.npausesweep++; runtime·sweep.npausesweep++;
} }
runtime·mProf_GC(); runtime·mProf_GC();
...@@ -1451,9 +1454,27 @@ gc(struct gc_args *args) ...@@ -1451,9 +1454,27 @@ gc(struct gc_args *args)
extern uintptr runtime·sizeof_C_MStats; extern uintptr runtime·sizeof_C_MStats;
static void readmemstats_m(void);
#pragma textflag NOSPLIT
void void
runtime·ReadMemStats(MStats *stats) runtime·ReadMemStats(MStats *stats)
{ {
void (*fn)(void);
g->m->ptrarg[0] = stats;
fn = readmemstats_m;
runtime·onM(&fn);
}
static void
readmemstats_m(void)
{
MStats *stats;
stats = g->m->ptrarg[0];
g->m->ptrarg[0] = nil;
// Have to acquire worldsema to stop the world, // Have to acquire worldsema to stop the world,
// because stoptheworld can only be used by // because stoptheworld can only be used by
// one goroutine at a time, and there might be // one goroutine at a time, and there might be
...@@ -1478,12 +1499,29 @@ runtime·ReadMemStats(MStats *stats) ...@@ -1478,12 +1499,29 @@ runtime·ReadMemStats(MStats *stats)
g->m->locks--; g->m->locks--;
} }
static void readgcstats_m(void);
#pragma textflag NOSPLIT
void void
runtimedebug·readGCStats(Slice *pauses) runtimedebug·readGCStats(Slice *pauses)
{ {
void (*fn)(void);
g->m->ptrarg[0] = pauses;
fn = readgcstats_m;
runtime·onM(&fn);
}
static void
readgcstats_m(void)
{
Slice *pauses;
uint64 *p; uint64 *p;
uint32 i, n; uint32 i, n;
pauses = g->m->ptrarg[0];
g->m->ptrarg[0] = nil;
// Calling code in runtime/debug should make the slice large enough. // Calling code in runtime/debug should make the slice large enough.
if(pauses->cap < nelem(mstats.pause_ns)+3) if(pauses->cap < nelem(mstats.pause_ns)+3)
runtime·throw("runtime: short slice passed to readGCStats"); runtime·throw("runtime: short slice passed to readGCStats");
...@@ -1510,7 +1548,8 @@ runtime∕debug·readGCStats(Slice *pauses) ...@@ -1510,7 +1548,8 @@ runtime∕debug·readGCStats(Slice *pauses)
} }
void void
runtime·setgcpercent_m(void) { runtime·setgcpercent_m(void)
{
int32 in; int32 in;
int32 out; int32 out;
...@@ -1901,7 +1940,8 @@ runtime·getgcmask(byte *p, Type *t, byte **mask, uintptr *len) ...@@ -1901,7 +1940,8 @@ runtime·getgcmask(byte *p, Type *t, byte **mask, uintptr *len)
void runtime·gc_unixnanotime(int64 *now); void runtime·gc_unixnanotime(int64 *now);
int64 runtime·unixnanotime(void) int64
runtime·unixnanotime(void)
{ {
int64 now; int64 now;
......
...@@ -68,3 +68,38 @@ func clearpools() { ...@@ -68,3 +68,38 @@ func clearpools() {
} }
} }
} }
// State of background sweep.
// Protected by gclock.
// Must match mgc0.c.
var sweep struct {
g *g
parked bool
spanidx uint32 // background sweeper position
nbgsweep uint32
npausesweep uint32
}
var gclock mutex // also in mgc0.c
func gosweepone() uintptr
func gosweepdone() bool
func bgsweep() {
getg().issystem = true
for {
for gosweepone() != ^uintptr(0) {
sweep.nbgsweep++
gosched()
}
lock(&gclock)
if !gosweepdone() {
// This can happen if a GC runs between
// gosweepone returning ^0 above
// and the lock being acquired.
unlock(&gclock)
continue
}
sweep.parked = true
goparkunlock(&gclock, "GC sweep wait")
}
}
...@@ -498,41 +498,6 @@ runtime·mach_semrelease(uint32 sem) ...@@ -498,41 +498,6 @@ runtime·mach_semrelease(uint32 sem)
} }
} }
void
runtime·sigpanic(void)
{
if(!runtime·canpanic(g))
runtime·throw("unexpected signal during runtime execution");
switch(g->sig) {
case SIGBUS:
if(g->sigcode0 == BUS_ADRERR && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGSEGV:
if((g->sigcode0 == 0 || g->sigcode0 == SEGV_MAPERR || g->sigcode0 == SEGV_ACCERR) && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGFPE:
switch(g->sigcode0) {
case FPE_INTDIV:
runtime·panicstring("integer divide by zero");
case FPE_INTOVF:
runtime·panicstring("integer overflow");
}
runtime·panicstring("floating point error");
}
runtime·panicstring(runtime·sigtab[g->sig].name);
}
#pragma textflag NOSPLIT #pragma textflag NOSPLIT
void void
runtime·osyield(void) runtime·osyield(void)
...@@ -593,3 +558,10 @@ runtime·unblocksignals(void) ...@@ -593,3 +558,10 @@ runtime·unblocksignals(void)
{ {
runtime·sigprocmask(SIG_SETMASK, &sigset_none, nil); runtime·sigprocmask(SIG_SETMASK, &sigset_none, nil);
} }
#pragma textflag NOSPLIT
int8*
runtime·signame(int32 sig)
{
return runtime·sigtab[sig].name;
}
...@@ -215,41 +215,6 @@ runtime·unminit(void) ...@@ -215,41 +215,6 @@ runtime·unminit(void)
runtime·signalstack(nil, 0); runtime·signalstack(nil, 0);
} }
void
runtime·sigpanic(void)
{
if(!runtime·canpanic(g))
runtime·throw("unexpected signal during runtime execution");
switch(g->sig) {
case SIGBUS:
if(g->sigcode0 == BUS_ADRERR && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGSEGV:
if((g->sigcode0 == 0 || g->sigcode0 == SEGV_MAPERR || g->sigcode0 == SEGV_ACCERR) && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGFPE:
switch(g->sigcode0) {
case FPE_INTDIV:
runtime·panicstring("integer divide by zero");
case FPE_INTOVF:
runtime·panicstring("integer overflow");
}
runtime·panicstring("floating point error");
}
runtime·panicstring(runtime·sigtab[g->sig].name);
}
uintptr uintptr
runtime·memlimit(void) runtime·memlimit(void)
{ {
...@@ -338,3 +303,10 @@ runtime·unblocksignals(void) ...@@ -338,3 +303,10 @@ runtime·unblocksignals(void)
{ {
runtime·sigprocmask(&sigset_none, nil); runtime·sigprocmask(&sigset_none, nil);
} }
#pragma textflag NOSPLIT
int8*
runtime·signame(int32 sig)
{
return runtime·sigtab[sig].name;
}
...@@ -223,41 +223,6 @@ runtime·unminit(void) ...@@ -223,41 +223,6 @@ runtime·unminit(void)
runtime·signalstack(nil, 0); runtime·signalstack(nil, 0);
} }
void
runtime·sigpanic(void)
{
if(!runtime·canpanic(g))
runtime·throw("unexpected signal during runtime execution");
switch(g->sig) {
case SIGBUS:
if(g->sigcode0 == BUS_ADRERR && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGSEGV:
if((g->sigcode0 == 0 || g->sigcode0 == SEGV_MAPERR || g->sigcode0 == SEGV_ACCERR) && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGFPE:
switch(g->sigcode0) {
case FPE_INTDIV:
runtime·panicstring("integer divide by zero");
case FPE_INTOVF:
runtime·panicstring("integer overflow");
}
runtime·panicstring("floating point error");
}
runtime·panicstring(runtime·sigtab[g->sig].name);
}
uintptr uintptr
runtime·memlimit(void) runtime·memlimit(void)
{ {
...@@ -346,3 +311,10 @@ runtime·unblocksignals(void) ...@@ -346,3 +311,10 @@ runtime·unblocksignals(void)
{ {
runtime·sigprocmask(&sigset_none, nil); runtime·sigprocmask(&sigset_none, nil);
} }
#pragma textflag NOSPLIT
int8*
runtime·signame(int32 sig)
{
return runtime·sigtab[sig].name;
}
...@@ -237,41 +237,6 @@ runtime·unminit(void) ...@@ -237,41 +237,6 @@ runtime·unminit(void)
runtime·signalstack(nil, 0); runtime·signalstack(nil, 0);
} }
void
runtime·sigpanic(void)
{
if(!runtime·canpanic(g))
runtime·throw("unexpected signal during runtime execution");
switch(g->sig) {
case SIGBUS:
if(g->sigcode0 == BUS_ADRERR && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGSEGV:
if((g->sigcode0 == 0 || g->sigcode0 == SEGV_MAPERR || g->sigcode0 == SEGV_ACCERR) && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGFPE:
switch(g->sigcode0) {
case FPE_INTDIV:
runtime·panicstring("integer divide by zero");
case FPE_INTOVF:
runtime·panicstring("integer overflow");
}
runtime·panicstring("floating point error");
}
runtime·panicstring(runtime·sigtab[g->sig].name);
}
uintptr uintptr
runtime·memlimit(void) runtime·memlimit(void)
{ {
...@@ -368,3 +333,10 @@ runtime·unblocksignals(void) ...@@ -368,3 +333,10 @@ runtime·unblocksignals(void)
{ {
runtime·rtsigprocmask(SIG_SETMASK, &sigset_none, nil, sizeof sigset_none); runtime·rtsigprocmask(SIG_SETMASK, &sigset_none, nil, sizeof sigset_none);
} }
#pragma textflag NOSPLIT
int8*
runtime·signame(int32 sig)
{
return runtime·sigtab[sig].name;
}
...@@ -291,19 +291,6 @@ runtime·closeonexec(int32) ...@@ -291,19 +291,6 @@ runtime·closeonexec(int32)
{ {
} }
void
runtime·sigpanic(void)
{
if(!runtime·canpanic(g))
runtime·throw("unexpected signal during runtime execution");
// Native Client only invokes the exception handler for memory faults.
g->sig = SIGSEGV;
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
uint32 runtime·writelock; // test-and-set spin lock for runtime.write uint32 runtime·writelock; // test-and-set spin lock for runtime.write
/* /*
......
...@@ -28,3 +28,14 @@ const stackSystem = 0 ...@@ -28,3 +28,14 @@ const stackSystem = 0
func os_sigpipe() { func os_sigpipe() {
gothrow("too many writes on closed pipe") gothrow("too many writes on closed pipe")
} }
func sigpanic() {
g := getg()
if !canpanic(g) {
gothrow("unexpected signal during runtime execution")
}
// Native Client only invokes the exception handler for memory faults.
g.sig = _SIGSEGV
panicmem()
}
...@@ -293,41 +293,6 @@ runtime·unminit(void) ...@@ -293,41 +293,6 @@ runtime·unminit(void)
runtime·signalstack(nil, 0); runtime·signalstack(nil, 0);
} }
void
runtime·sigpanic(void)
{
if(!runtime·canpanic(g))
runtime·throw("unexpected signal during runtime execution");
switch(g->sig) {
case SIGBUS:
if(g->sigcode0 == BUS_ADRERR && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGSEGV:
if((g->sigcode0 == 0 || g->sigcode0 == SEGV_MAPERR || g->sigcode0 == SEGV_ACCERR) && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGFPE:
switch(g->sigcode0) {
case FPE_INTDIV:
runtime·panicstring("integer divide by zero");
case FPE_INTOVF:
runtime·panicstring("integer overflow");
}
runtime·panicstring("floating point error");
}
runtime·panicstring(runtime·sigtab[g->sig].name);
}
uintptr uintptr
runtime·memlimit(void) runtime·memlimit(void)
{ {
...@@ -394,3 +359,10 @@ runtime·unblocksignals(void) ...@@ -394,3 +359,10 @@ runtime·unblocksignals(void)
{ {
runtime·sigprocmask(SIG_SETMASK, &sigset_none, nil); runtime·sigprocmask(SIG_SETMASK, &sigset_none, nil);
} }
#pragma textflag NOSPLIT
int8*
runtime·signame(int32 sig)
{
return runtime·sigtab[sig].name;
}
...@@ -248,41 +248,6 @@ runtime·unminit(void) ...@@ -248,41 +248,6 @@ runtime·unminit(void)
runtime·signalstack(nil, 0); runtime·signalstack(nil, 0);
} }
void
runtime·sigpanic(void)
{
if(!runtime·canpanic(g))
runtime·throw("unexpected signal during runtime execution");
switch(g->sig) {
case SIGBUS:
if(g->sigcode0 == BUS_ADRERR && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGSEGV:
if((g->sigcode0 == 0 || g->sigcode0 == SEGV_MAPERR || g->sigcode0 == SEGV_ACCERR) && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGFPE:
switch(g->sigcode0) {
case FPE_INTDIV:
runtime·panicstring("integer divide by zero");
case FPE_INTOVF:
runtime·panicstring("integer overflow");
}
runtime·panicstring("floating point error");
}
runtime·panicstring(runtime·sigtab[g->sig].name);
}
uintptr uintptr
runtime·memlimit(void) runtime·memlimit(void)
{ {
...@@ -346,3 +311,10 @@ runtime·unblocksignals(void) ...@@ -346,3 +311,10 @@ runtime·unblocksignals(void)
{ {
runtime·sigprocmask(SIG_SETMASK, sigset_none); runtime·sigprocmask(SIG_SETMASK, sigset_none);
} }
#pragma textflag NOSPLIT
int8*
runtime·signame(int32 sig)
{
return runtime·sigtab[sig].name;
}
...@@ -326,84 +326,6 @@ runtime·semawakeup(M *mp) ...@@ -326,84 +326,6 @@ runtime·semawakeup(M *mp)
runtime·plan9_semrelease(&mp->waitsemacount, 1); runtime·plan9_semrelease(&mp->waitsemacount, 1);
} }
static int64
atolwhex(byte *p)
{
int64 n;
int32 f;
n = 0;
f = 0;
while(*p == ' ' || *p == '\t')
p++;
if(*p == '-' || *p == '+') {
if(*p++ == '-')
f = 1;
while(*p == ' ' || *p == '\t')
p++;
}
if(p[0] == '0' && p[1]) {
if(p[1] == 'x' || p[1] == 'X') {
p += 2;
for(;;) {
if('0' <= *p && *p <= '9')
n = n*16 + *p++ - '0';
else if('a' <= *p && *p <= 'f')
n = n*16 + *p++ - 'a' + 10;
else if('A' <= *p && *p <= 'F')
n = n*16 + *p++ - 'A' + 10;
else
break;
}
} else
while('0' <= *p && *p <= '7')
n = n*8 + *p++ - '0';
} else
while('0' <= *p && *p <= '9')
n = n*10 + *p++ - '0';
if(f)
n = -n;
return n;
}
void
runtime·sigpanic(void)
{
byte *p;
if(!runtime·canpanic(g))
runtime·throw("unexpected signal during runtime execution");
switch(g->sig) {
case SIGRFAULT:
case SIGWFAULT:
p = runtime·strstr((byte*)g->m->notesig, (byte*)"addr=")+5;
g->sigcode1 = atolwhex(p);
if(g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
break;
case SIGTRAP:
if(g->paniconfault)
runtime·panicstring("invalid memory address or nil pointer dereference");
runtime·throw(g->m->notesig);
break;
case SIGINTDIV:
runtime·panicstring("integer divide by zero");
break;
case SIGFLOAT:
runtime·panicstring("floating point error");
break;
default:
runtime·panicstring(g->m->notesig);
break;
}
}
#pragma textflag NOSPLIT #pragma textflag NOSPLIT
int32 int32
runtime·read(int32 fd, void *buf, int32 nbytes) runtime·read(int32 fd, void *buf, int32 nbytes)
......
...@@ -32,3 +32,75 @@ type _Plink uintptr ...@@ -32,3 +32,75 @@ type _Plink uintptr
func os_sigpipe() { func os_sigpipe() {
gothrow("too many writes on closed pipe") gothrow("too many writes on closed pipe")
} }
func sigpanic() {
g := getg()
if !canpanic(g) {
gothrow("unexpected signal during runtime execution")
}
note := gostringnocopy((*byte)(unsafe.Pointer(g.m.notesig)))
switch g.sig {
case _SIGRFAULT, _SIGWFAULT:
addr := note[index(note, "addr=")+5:]
g.sigcode1 = uintptr(atolwhex(addr))
if g.sigcode1 < 0x1000 || g.paniconfault {
panicmem()
}
print("unexpected fault address ", hex(g.sigcode1), "\n")
gothrow("fault")
case _SIGTRAP:
if g.paniconfault {
panicmem()
}
gothrow(note)
case _SIGINTDIV:
panicdivide()
case _SIGFLOAT:
panicfloat()
default:
panic(errorString(note))
}
}
func atolwhex(p string) int64 {
for hasprefix(p, " ") || hasprefix(p, "\t") {
p = p[1:]
}
neg := false
if hasprefix(p, "-") || hasprefix(p, "+") {
neg = p[0] == '-'
p = p[1:]
for hasprefix(p, " ") || hasprefix(p, "\t") {
p = p[1:]
}
}
var n int64
switch {
case hasprefix(p, "0x"), hasprefix(p, "0X"):
p = p[2:]
for ; len(p) > 0; p = p[1:] {
if '0' <= p[0] && p[0] <= '9' {
n = n*16 + int64(p[0]-'0')
} else if 'a' <= p[0] && p[0] <= 'f' {
n = n*16 + int64(p[0]-'a'+10)
} else if 'A' <= p[0] && p[0] <= 'F' {
n = n*16 + int64(p[0]-'A'+10)
} else {
break
}
}
case hasprefix(p, "0"):
for ; len(p) > 0 && '0' <= p[0] && p[0] <= '7'; p = p[1:] {
n = n*8 + int64(p[0]-'0')
}
default:
for ; len(p) > 0 && '0' <= p[0] && p[0] <= '9'; p = p[1:] {
n = n*10 + int64(p[0]-'0')
}
}
if neg {
n = -n
}
return n
}
...@@ -194,41 +194,6 @@ runtime·unminit(void) ...@@ -194,41 +194,6 @@ runtime·unminit(void)
runtime·signalstack(nil, 0); runtime·signalstack(nil, 0);
} }
void
runtime·sigpanic(void)
{
if(!runtime·canpanic(g))
runtime·throw("unexpected signal during runtime execution");
switch(g->sig) {
case SIGBUS:
if(g->sigcode0 == BUS_ADRERR && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGSEGV:
if((g->sigcode0 == 0 || g->sigcode0 == SEGV_MAPERR || g->sigcode0 == SEGV_ACCERR) && g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case SIGFPE:
switch(g->sigcode0) {
case FPE_INTDIV:
runtime·panicstring("integer divide by zero");
case FPE_INTOVF:
runtime·panicstring("integer overflow");
}
runtime·panicstring("floating point error");
}
runtime·panicstring(runtime·sigtab[g->sig].name);
}
uintptr uintptr
runtime·memlimit(void) runtime·memlimit(void)
{ {
...@@ -580,3 +545,10 @@ runtime·osyield(void) ...@@ -580,3 +545,10 @@ runtime·osyield(void)
} }
runtime·osyield1(); runtime·osyield1();
} }
#pragma textflag NOSPLIT
int8*
runtime·signame(int32 sig)
{
return runtime·sigtab[sig].name;
}
...@@ -453,35 +453,6 @@ runtime·issigpanic(uint32 code) ...@@ -453,35 +453,6 @@ runtime·issigpanic(uint32 code)
return 0; return 0;
} }
void
runtime·sigpanic(void)
{
if(!runtime·canpanic(g))
runtime·throw("unexpected signal during runtime execution");
switch(g->sig) {
case EXCEPTION_ACCESS_VIOLATION:
if(g->sigcode1 < 0x1000 || g->paniconfault) {
if(g->sigpc == 0)
runtime·panicstring("call of nil func value");
runtime·panicstring("invalid memory address or nil pointer dereference");
}
runtime·printf("unexpected fault address %p\n", g->sigcode1);
runtime·throw("fault");
case EXCEPTION_INT_DIVIDE_BY_ZERO:
runtime·panicstring("integer divide by zero");
case EXCEPTION_INT_OVERFLOW:
runtime·panicstring("integer overflow");
case EXCEPTION_FLT_DENORMAL_OPERAND:
case EXCEPTION_FLT_DIVIDE_BY_ZERO:
case EXCEPTION_FLT_INEXACT_RESULT:
case EXCEPTION_FLT_OVERFLOW:
case EXCEPTION_FLT_UNDERFLOW:
runtime·panicstring("floating point error");
}
runtime·throw("fault");
}
void void
runtime·initsig(void) runtime·initsig(void)
{ {
......
...@@ -31,3 +31,30 @@ const stackSystem = 512 * ptrSize ...@@ -31,3 +31,30 @@ const stackSystem = 512 * ptrSize
func os_sigpipe() { func os_sigpipe() {
gothrow("too many writes on closed pipe") gothrow("too many writes on closed pipe")
} }
func sigpanic() {
g := getg()
if !canpanic(g) {
gothrow("unexpected signal during runtime execution")
}
switch uint32(g.sig) {
case _EXCEPTION_ACCESS_VIOLATION:
if g.sigcode1 < 0x1000 || g.paniconfault {
panicmem()
}
print("unexpected fault address ", hex(g.sigcode1), "\n")
gothrow("fault")
case _EXCEPTION_INT_DIVIDE_BY_ZERO:
panicdivide()
case _EXCEPTION_INT_OVERFLOW:
panicoverflow()
case _EXCEPTION_FLT_DENORMAL_OPERAND,
_EXCEPTION_FLT_DIVIDE_BY_ZERO,
_EXCEPTION_FLT_INEXACT_RESULT,
_EXCEPTION_FLT_OVERFLOW,
_EXCEPTION_FLT_UNDERFLOW:
panicfloat()
}
gothrow("fault")
}
...@@ -190,6 +190,7 @@ runtime·dopanic_m(void) ...@@ -190,6 +190,7 @@ runtime·dopanic_m(void)
runtime·exit(2); runtime·exit(2);
} }
#pragma textflag NOSPLIT
bool bool
runtime·canpanic(G *gp) runtime·canpanic(G *gp)
{ {
......
...@@ -24,6 +24,24 @@ func panicdivide() { ...@@ -24,6 +24,24 @@ func panicdivide() {
panic(divideError) panic(divideError)
} }
var overflowError = error(errorString("integer overflow"))
func panicoverflow() {
panic(overflowError)
}
var floatError = error(errorString("floating point error"))
func panicfloat() {
panic(floatError)
}
var memoryError = error(errorString("invalid memory address or nil pointer dereference"))
func panicmem() {
panic(memoryError)
}
func throwreturn() { func throwreturn() {
gothrow("no return at end of a typed function - compiler is broken") gothrow("no return at end of a typed function - compiler is broken")
} }
...@@ -214,3 +232,5 @@ func Goexit() { ...@@ -214,3 +232,5 @@ func Goexit() {
} }
goexit() goexit()
} }
func canpanic(*g) bool
...@@ -10,9 +10,6 @@ import "unsafe" ...@@ -10,9 +10,6 @@ import "unsafe"
// should use printhex instead of printuint (decimal). // should use printhex instead of printuint (decimal).
type hex uint64 type hex uint64
//go:noescape
func gostring(*byte) string
func bytes(s string) (ret []byte) { func bytes(s string) (ret []byte) {
rp := (*slice)(unsafe.Pointer(&ret)) rp := (*slice)(unsafe.Pointer(&ret))
sp := (*_string)(noescape(unsafe.Pointer(&s))) sp := (*_string)(noescape(unsafe.Pointer(&s)))
......
...@@ -212,84 +212,10 @@ runtime·schedinit(void) ...@@ -212,84 +212,10 @@ runtime·schedinit(void)
runtime·cgoFree = _cgo_free; runtime·cgoFree = _cgo_free;
} }
extern void main·init(void);
extern void runtime·init(void);
extern void main·main(void);
static FuncVal initDone = { runtime·unlockOSThread };
// The main goroutine.
// Note: C frames in general are not copyable during stack growth, for two reasons:
// 1) We don't know where in a frame to find pointers to other stack locations.
// 2) There's no guarantee that globals or heap values do not point into the frame.
//
// The C frame for runtime.main is copyable, because:
// 1) There are no pointers to other stack locations in the frame
// (d.fn points at a global, d.link is nil, d.argp is -1).
// 2) The only pointer into this frame is from the defer chain,
// which is explicitly handled during stack copying.
void void
runtime·main(void) runtime·newsysmon(void)
{ {
Defer d;
// Racectx of m0->g0 is used only as the parent of the main goroutine.
// It must not be used for anything else.
g->m->g0->racectx = 0;
// Max stack size is 1 GB on 64-bit, 250 MB on 32-bit.
// Using decimal instead of binary GB and MB because
// they look nicer in the stack overflow failure message.
if(sizeof(void*) == 8)
runtime·maxstacksize = 1000000000;
else
runtime·maxstacksize = 250000000;
newm(sysmon, nil); newm(sysmon, nil);
// Lock the main goroutine onto this, the main OS thread,
// during initialization. Most programs won't care, but a few
// do require certain calls to be made by the main thread.
// Those can arrange for main.main to run in the main thread
// by calling runtime.LockOSThread during initialization
// to preserve the lock.
runtime·lockOSThread();
// Defer unlock so that runtime.Goexit during init does the unlock too.
d.fn = &initDone;
d.siz = 0;
d.link = g->defer;
d.argp = NoArgs;
d.special = true;
g->defer = &d;
if(g->m != &runtime·m0)
runtime·throw("runtime·main not on m0");
runtime·init();
mstats.enablegc = 1; // now that runtime is initialized, GC is okay
main·init();
if(g->defer != &d || d.fn != &initDone)
runtime·throw("runtime: bad defer entry after init");
g->defer = d.link;
runtime·unlockOSThread();
main·main();
if(raceenabled)
runtime·racefini();
// Make racy client program work: if panicking on
// another goroutine at the same time as main returns,
// let the other goroutine finish printing the panic trace.
// Once it does, it will exit. See issue 3934.
if(runtime·panicking)
runtime·park(nil, nil, runtime·gostringnocopy((byte*)"panicwait"));
runtime·exit(0);
for(;;)
*(int32*)runtime·main = 0;
} }
static void static void
...@@ -322,6 +248,8 @@ mcommoninit(M *mp) ...@@ -322,6 +248,8 @@ mcommoninit(M *mp)
mp->id = runtime·sched.mcount++; mp->id = runtime·sched.mcount++;
checkmcount(); checkmcount();
runtime·mpreinit(mp); runtime·mpreinit(mp);
if(mp->gsignal)
mp->gsignal->stackguard1 = mp->gsignal->stackguard;
// Add to runtime·allm so garbage collector doesn't free g->m // Add to runtime·allm so garbage collector doesn't free g->m
// when it is just in a register or thread-local storage. // when it is just in a register or thread-local storage.
...@@ -977,6 +905,7 @@ runtime·allocm(P *p) ...@@ -977,6 +905,7 @@ runtime·allocm(P *p)
else else
mp->g0 = runtime·malg(8192); mp->g0 = runtime·malg(8192);
mp->g0->m = mp; mp->g0->m = mp;
mp->g0->stackguard1 = mp->g0->stackguard;
if(p == g->m->p) if(p == g->m->p)
releasep(); releasep();
...@@ -1733,6 +1662,7 @@ runtime·park_m(G *gp) ...@@ -1733,6 +1662,7 @@ runtime·park_m(G *gp)
} }
// Scheduler yield. // Scheduler yield.
#pragma textflag NOSPLIT
void void
runtime·gosched(void) runtime·gosched(void)
{ {
...@@ -2210,6 +2140,7 @@ runtime·malg(int32 stacksize) ...@@ -2210,6 +2140,7 @@ runtime·malg(int32 stacksize)
newg->stack0 = (uintptr)stk; newg->stack0 = (uintptr)stk;
newg->stackguard = (uintptr)stk + StackGuard; newg->stackguard = (uintptr)stk + StackGuard;
newg->stackguard0 = newg->stackguard; newg->stackguard0 = newg->stackguard;
newg->stackguard1 = ~(uintptr)0;
newg->stackbase = (uintptr)stk + stacksize - sizeof(Stktop); newg->stackbase = (uintptr)stk + stacksize - sizeof(Stktop);
} }
return newg; return newg;
...@@ -2261,6 +2192,8 @@ runtime·newproc(int32 siz, FuncVal* fn, ...) ...@@ -2261,6 +2192,8 @@ runtime·newproc(int32 siz, FuncVal* fn, ...)
g->m->locks--; g->m->locks--;
} }
void runtime·main(void);
// Create a new g running fn with narg bytes of arguments starting // Create a new g running fn with narg bytes of arguments starting
// at argp and returning nret bytes of results. callerpc is the // at argp and returning nret bytes of results. callerpc is the
// address of the go statement that created this. The new g is put // address of the go statement that created this. The new g is put
......
...@@ -6,6 +6,79 @@ package runtime ...@@ -6,6 +6,79 @@ package runtime
import "unsafe" import "unsafe"
func newsysmon()
func runtime_init()
func main_init()
func main_main()
// The main goroutine.
func main() {
g := getg()
// Racectx of m0->g0 is used only as the parent of the main goroutine.
// It must not be used for anything else.
g.m.g0.racectx = 0
// Max stack size is 1 GB on 64-bit, 250 MB on 32-bit.
// Using decimal instead of binary GB and MB because
// they look nicer in the stack overflow failure message.
if ptrSize == 8 {
maxstacksize = 1000000000
} else {
maxstacksize = 250000000
}
onM(newsysmon)
// Lock the main goroutine onto this, the main OS thread,
// during initialization. Most programs won't care, but a few
// do require certain calls to be made by the main thread.
// Those can arrange for main.main to run in the main thread
// by calling runtime.LockOSThread during initialization
// to preserve the lock.
lockOSThread()
// Defer unlock so that runtime.Goexit during init does the unlock too.
needUnlock := true
defer func() {
if needUnlock {
unlockOSThread()
}
}()
if g.m != &m0 {
gothrow("runtime.main not on m0")
}
runtime_init()
memstats.enablegc = true // now that runtime is initialized, GC is okay
main_init()
needUnlock = false
unlockOSThread()
main_main()
if raceenabled {
racefini()
}
// Make racy client program work: if panicking on
// another goroutine at the same time as main returns,
// let the other goroutine finish printing the panic trace.
// Once it does, it will exit. See issue 3934.
if panicking != 0 {
gopark(nil, nil, "panicwait")
}
exit(0)
for {
var x *int32
*x = 0
}
}
var parkunlock_c byte var parkunlock_c byte
// start forcegc helper goroutine // start forcegc helper goroutine
......
...@@ -12,6 +12,8 @@ import ( ...@@ -12,6 +12,8 @@ import (
"unsafe" "unsafe"
) )
func racefini()
// RaceDisable disables handling of race events in the current goroutine. // RaceDisable disables handling of race events in the current goroutine.
func RaceDisable() func RaceDisable()
......
...@@ -271,6 +271,8 @@ struct G ...@@ -271,6 +271,8 @@ struct G
uintptr stackguard0; // cannot move - also known to liblink, libmach, runtime/cgo uintptr stackguard0; // cannot move - also known to liblink, libmach, runtime/cgo
uintptr stackbase; // cannot move - also known to libmach, runtime/cgo uintptr stackbase; // cannot move - also known to libmach, runtime/cgo
Panic* panic; // cannot move - also known to liblink Panic* panic; // cannot move - also known to liblink
// stackguard1 is checked by C code; it is set to ~0 in ordinary (non-g0, non-gsignal) goroutines
uintptr stackguard1; // cannot move - also known to liblink
Defer* defer; Defer* defer;
Gobuf sched; Gobuf sched;
uintptr syscallstack; // if status==Gsyscall, syscallstack = stackbase to use during gc uintptr syscallstack; // if status==Gsyscall, syscallstack = stackbase to use during gc
......
// Copyright 2014 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
// +build darwin dragonfly freebsd linux netbsd openbsd solaris
package runtime
func signame(int32) *byte
func sigpanic() {
g := getg()
if !canpanic(g) {
gothrow("unexpected signal during runtime execution")
}
switch g.sig {
case _SIGBUS:
if g.sigcode0 == _BUS_ADRERR && g.sigcode1 < 0x1000 || g.paniconfault {
panicmem()
}
print("unexpected fault address ", hex(g.sigcode1), "\n")
gothrow("fault")
case _SIGSEGV:
if (g.sigcode0 == 0 || g.sigcode0 == _SEGV_MAPERR || g.sigcode0 == _SEGV_ACCERR) && g.sigcode1 < 0x1000 || g.paniconfault {
panicmem()
}
print("unexpected fault address ", hex(g.sigcode1), "\n")
gothrow("fault")
case _SIGFPE:
switch g.sigcode0 {
case _FPE_INTDIV:
panicdivide()
case _FPE_INTOVF:
panicoverflow()
}
panicfloat()
}
panic(errorString(gostringnocopy(signame(g.sig))))
}
...@@ -428,13 +428,6 @@ checkframecopy(Stkframe *frame, void *arg) ...@@ -428,13 +428,6 @@ checkframecopy(Stkframe *frame, void *arg)
runtime·printf(" <next segment>\n"); runtime·printf(" <next segment>\n");
return false; // stop traceback return false; // stop traceback
} }
if(f->entry == (uintptr)runtime·main) {
// A special routine at the TOS of the main routine.
// We will allow it to be copied even though we don't
// have full GC info for it (because it is written in C).
cinfo->frames++;
return false; // stop traceback
}
if(f->entry == (uintptr)runtime·switchtoM) { if(f->entry == (uintptr)runtime·switchtoM) {
// A special routine at the bottom of stack of a goroutine that does onM call. // A special routine at the bottom of stack of a goroutine that does onM call.
// We will allow it to be copied even though we don't // We will allow it to be copied even though we don't
...@@ -657,8 +650,7 @@ adjustframe(Stkframe *frame, void *arg) ...@@ -657,8 +650,7 @@ adjustframe(Stkframe *frame, void *arg)
f = frame->fn; f = frame->fn;
if(StackDebug >= 2) if(StackDebug >= 2)
runtime·printf(" adjusting %s frame=[%p,%p] pc=%p continpc=%p\n", runtime·funcname(f), frame->sp, frame->fp, frame->pc, frame->continpc); runtime·printf(" adjusting %s frame=[%p,%p] pc=%p continpc=%p\n", runtime·funcname(f), frame->sp, frame->fp, frame->pc, frame->continpc);
if(f->entry == (uintptr)runtime·main || if(f->entry == (uintptr)runtime·switchtoM)
f->entry == (uintptr)runtime·switchtoM)
return true; return true;
targetpc = frame->continpc; targetpc = frame->continpc;
if(targetpc == 0) { if(targetpc == 0) {
...@@ -1126,3 +1118,21 @@ runtime·shrinkstack(G *gp) ...@@ -1126,3 +1118,21 @@ runtime·shrinkstack(G *gp)
return; return;
copystack(gp, nframes, newsize); copystack(gp, nframes, newsize);
} }
static void badc(void);
#pragma textflag NOSPLIT
void
runtime·morestackc(void)
{
void (*fn)(void);
fn = badc;
runtime·onM(&fn);
}
static void
badc(void)
{
runtime·throw("attempt to execute C code on Go stack");
}
...@@ -37,59 +37,6 @@ runtime·findnullw(uint16 *s) ...@@ -37,59 +37,6 @@ runtime·findnullw(uint16 *s)
uintptr runtime·maxstring = 256; // a hint for print uintptr runtime·maxstring = 256; // a hint for print
static String
gostringsize(intgo l)
{
String s;
uintptr ms;
if(l == 0)
return runtime·emptystring;
s.str = runtime·mallocgc(l, 0, FlagNoScan|FlagNoZero);
s.len = l;
for(;;) {
ms = runtime·maxstring;
if((uintptr)l <= ms || runtime·casp((void**)&runtime·maxstring, (void*)ms, (void*)l))
break;
}
return s;
}
String
runtime·gostring(byte *str)
{
intgo l;
String s;
l = runtime·findnull(str);
s = gostringsize(l);
runtime·memmove(s.str, str, l);
return s;
}
String
runtime·gostringn(byte *str, intgo l)
{
String s;
s = gostringsize(l);
runtime·memmove(s.str, str, l);
return s;
}
// used by cmd/cgo
Slice
runtime·gobytes(byte *p, intgo n)
{
Slice sl;
sl.array = runtime·mallocgc(n, 0, FlagNoScan|FlagNoZero);
sl.len = n;
sl.cap = n;
runtime·memmove(sl.array, p, n);
return sl;
}
#pragma textflag NOSPLIT #pragma textflag NOSPLIT
String String
runtime·gostringnocopy(byte *str) runtime·gostringnocopy(byte *str)
...@@ -189,6 +136,8 @@ runetochar(byte *str, int32 rune) /* note: in original, arg2 was pointer */ ...@@ -189,6 +136,8 @@ runetochar(byte *str, int32 rune) /* note: in original, arg2 was pointer */
return 4; return 4;
} }
String runtime·gostringsize(intgo);
String String
runtime·gostringw(uint16 *str) runtime·gostringw(uint16 *str)
{ {
...@@ -199,7 +148,7 @@ runtime·gostringw(uint16 *str) ...@@ -199,7 +148,7 @@ runtime·gostringw(uint16 *str)
n1 = 0; n1 = 0;
for(i=0; str[i]; i++) for(i=0; str[i]; i++)
n1 += runetochar(buf, str[i]); n1 += runetochar(buf, str[i]);
s = gostringsize(n1+4); s = runtime·gostringsize(n1+4);
n2 = 0; n2 = 0;
for(i=0; str[i]; i++) { for(i=0; str[i]; i++) {
// check for race // check for race
...@@ -212,22 +161,6 @@ runtime·gostringw(uint16 *str) ...@@ -212,22 +161,6 @@ runtime·gostringw(uint16 *str)
return s; return s;
} }
String
runtime·catstring(String s1, String s2)
{
String s3;
if(s1.len == 0)
return s2;
if(s2.len == 0)
return s1;
s3 = gostringsize(s1.len + s2.len);
runtime·memmove(s3.str, s1.str, s1.len);
runtime·memmove(s3.str+s1.len, s2.str, s2.len);
return s3;
}
int32 int32
runtime·strcmp(byte *s1, byte *s2) runtime·strcmp(byte *s1, byte *s2)
{ {
......
...@@ -239,3 +239,60 @@ func rawruneslice(size int) (b []rune) { ...@@ -239,3 +239,60 @@ func rawruneslice(size int) (b []rune) {
(*slice)(unsafe.Pointer(&b)).cap = uint(mem / 4) (*slice)(unsafe.Pointer(&b)).cap = uint(mem / 4)
return return
} }
// used by cmd/cgo
func gobytes(p *byte, n int) []byte {
if n == 0 {
return make([]byte, 0)
}
x := make([]byte, n)
memmove(unsafe.Pointer(&x[0]), unsafe.Pointer(p), uintptr(n))
return x
}
func gostringsize(n int) string {
s, _ := rawstring(n)
return s
}
//go:noescape
func findnull(*byte) int
func gostring(p *byte) string {
l := findnull(p)
if l == 0 {
return ""
}
s, b := rawstring(l)
memmove(unsafe.Pointer(&b[0]), unsafe.Pointer(p), uintptr(l))
return s
}
func gostringn(p *byte, l int) string {
if l == 0 {
return ""
}
s, b := rawstring(l)
memmove(unsafe.Pointer(&b[0]), unsafe.Pointer(p), uintptr(l))
return s
}
func index(s, t string) int {
if len(t) == 0 {
return 0
}
for i := 0; i < len(s); i++ {
if s[i] == t[0] && hasprefix(s[i:], t) {
return i
}
}
return -1
}
func contains(s, t string) bool {
return index(s, t) >= 0
}
func hasprefix(s, t string) bool {
return len(s) >= len(t) && s[:len(t)] == t
}
...@@ -223,7 +223,6 @@ func lessstack() ...@@ -223,7 +223,6 @@ func lessstack()
func morestack() func morestack()
func mstart() func mstart()
func rt0_go() func rt0_go()
func sigpanic()
// return0 is a stub used to return 0 from deferproc. // return0 is a stub used to return 0 from deferproc.
// It is called at the very end of deferproc to signal // It is called at the very end of deferproc to signal
......
...@@ -143,8 +143,17 @@ TEXT reflect·unsafe_NewArray(SB),NOSPLIT,$0-0 ...@@ -143,8 +143,17 @@ TEXT reflect·unsafe_NewArray(SB),NOSPLIT,$0-0
TEXT reflect·makechan(SB),NOSPLIT,$0-0 TEXT reflect·makechan(SB),NOSPLIT,$0-0
JMP runtime·makechan(SB) JMP runtime·makechan(SB)
TEXT reflect·rselect(SB), NOSPLIT, $0-0 TEXT reflect·rselect(SB),NOSPLIT,$0-0
JMP runtime·reflect_rselect(SB) JMP runtime·reflect_rselect(SB)
TEXT os·sigpipe(SB), NOSPLIT, $0-0 TEXT os·sigpipe(SB),NOSPLIT,$0-0
JMP runtime·os_sigpipe(SB) JMP runtime·os_sigpipe(SB)
TEXT runtime·runtime_init(SB),NOSPLIT,$0-0
JMP runtime·init(SB)
TEXT runtime·main_init(SB),NOSPLIT,$0-0
JMP main·init(SB)
TEXT runtime·main_main(SB),NOSPLIT,$0-0
JMP main·main(SB)
...@@ -526,22 +526,6 @@ func showframe(f *_func, gp *g) bool { ...@@ -526,22 +526,6 @@ func showframe(f *_func, gp *g) bool {
return traceback > 1 || f != nil && contains(name, ".") && !hasprefix(name, "runtime.") return traceback > 1 || f != nil && contains(name, ".") && !hasprefix(name, "runtime.")
} }
func contains(s, t string) bool {
if len(t) == 0 {
return true
}
for i := 0; i < len(s); i++ {
if s[i] == t[0] && hasprefix(s[i:], t) {
return true
}
}
return false
}
func hasprefix(s, t string) bool {
return len(s) >= len(t) && s[:len(t)] == t
}
var gStatusStrings = [...]string{ var gStatusStrings = [...]string{
_Gidle: "idle", _Gidle: "idle",
_Grunnable: "runnable", _Grunnable: "runnable",
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment