1
0
mirror of https://github.com/golang/go synced 2024-11-26 01:37:58 -07:00
go/usr/austin/ogle/rvalue.go
Austin Clements ffe83e582e Switch ogle over to the in-tree debug/proc package. Fix
debug/proc to install to the right place.  Delete the old
ptrace package.  The diff looks huge, but it's mostly
s/ptrace/proc/.

R=rsc
APPROVED=rsc
DELTA=1940  (10 added, 1835 deleted, 95 changed)
OCL=34966
CL=34968
2009-09-24 09:07:47 -07:00

580 lines
12 KiB
Go

// Copyright 2009 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 ogle
import (
"debug/proc";
"eval";
"fmt";
)
// A RemoteMismatchError occurs when an operation that requires two
// identical remote processes is given different process. For
// example, this occurs when trying to set a pointer in one process to
// point to something in another process.
type RemoteMismatchError string
func (e RemoteMismatchError) String() string {
return string(e);
}
// A ReadOnlyError occurs when attempting to set or assign to a
// read-only value.
type ReadOnlyError string
func (e ReadOnlyError) String() string {
return string(e);
}
// A maker is a function that converts a remote address into an
// interpreter Value.
type maker func(remote) eval.Value
type remoteValue interface {
addr() remote;
}
// remote represents an address in a remote process.
type remote struct {
base proc.Word;
p *Process;
}
func (v remote) Get(a aborter, size int) uint64 {
// TODO(austin) This variable might temporarily be in a
// register. We could trace the assembly back from the
// current PC, looking for the beginning of the function or a
// call (both of which guarantee that the variable is in
// memory), or an instruction that loads the variable into a
// register.
//
// TODO(austin) If this is a local variable, it might not be
// live at this PC. In fact, because the compiler reuses
// slots, there might even be a different local variable at
// this location right now. A simple solution to both
// problems is to include the range of PC's over which a local
// variable is live in the symbol table.
//
// TODO(austin) We need to prevent the remote garbage
// collector from collecting objects out from under us.
var arr [8]byte;
buf := arr[0:size];
_, err := v.p.Peek(v.base, buf);
if err != nil {
a.Abort(err);
}
return uint64(v.p.ToWord(buf));
}
func (v remote) Set(a aborter, size int, x uint64) {
var arr [8]byte;
buf := arr[0:size];
v.p.FromWord(proc.Word(x), buf);
_, err := v.p.Poke(v.base, buf);
if err != nil {
a.Abort(err);
}
}
func (v remote) plus(x proc.Word) remote {
return remote{v.base + x, v.p};
}
func tryRVString(f func(a aborter) string) string {
var s string;
err := try(func(a aborter) { s = f(a) });
if err != nil {
return fmt.Sprintf("<error: %v>", err);
}
return s;
}
/*
* Bool
*/
type remoteBool struct {
r remote;
}
func (v remoteBool) String() string {
return tryRVString(func(a aborter) string { return fmt.Sprintf("%v", v.aGet(a)) });
}
func (v remoteBool) Assign(t *eval.Thread, o eval.Value) {
v.Set(t, o.(eval.BoolValue).Get(t));
}
func (v remoteBool) Get(t *eval.Thread) bool {
return v.aGet(t);
}
func (v remoteBool) aGet(a aborter) bool {
return v.r.Get(a, 1) != 0;
}
func (v remoteBool) Set(t *eval.Thread, x bool) {
v.aSet(t, x);
}
func (v remoteBool) aSet(a aborter, x bool) {
if x {
v.r.Set(a, 1, 1);
} else {
v.r.Set(a, 1, 0);
}
}
func (v remoteBool) addr() remote {
return v.r;
}
func mkBool(r remote) eval.Value {
return remoteBool{r};
}
/*
* Uint
*/
type remoteUint struct {
r remote;
size int;
}
func (v remoteUint) String() string {
return tryRVString(func(a aborter) string { return fmt.Sprintf("%v", v.aGet(a)) });
}
func (v remoteUint) Assign(t *eval.Thread, o eval.Value) {
v.Set(t, o.(eval.UintValue).Get(t));
}
func (v remoteUint) Get(t *eval.Thread) uint64 {
return v.aGet(t);
}
func (v remoteUint) aGet(a aborter) uint64 {
return v.r.Get(a, v.size);
}
func (v remoteUint) Set(t *eval.Thread, x uint64) {
v.aSet(t, x);
}
func (v remoteUint) aSet(a aborter, x uint64) {
v.r.Set(a, v.size, x);
}
func (v remoteUint) addr() remote {
return v.r;
}
func mkUint8(r remote) eval.Value {
return remoteUint{r, 1};
}
func mkUint16(r remote) eval.Value {
return remoteUint{r, 2};
}
func mkUint32(r remote) eval.Value {
return remoteUint{r, 4};
}
func mkUint64(r remote) eval.Value {
return remoteUint{r, 8};
}
func mkUint(r remote) eval.Value {
return remoteUint{r, r.p.IntSize()};
}
func mkUintptr(r remote) eval.Value {
return remoteUint{r, r.p.PtrSize()};
}
/*
* Int
*/
type remoteInt struct {
r remote;
size int;
}
func (v remoteInt) String() string {
return tryRVString(func(a aborter) string { return fmt.Sprintf("%v", v.aGet(a)) });
}
func (v remoteInt) Assign(t *eval.Thread, o eval.Value) {
v.Set(t, o.(eval.IntValue).Get(t));
}
func (v remoteInt) Get(t *eval.Thread) int64 {
return v.aGet(t);
}
func (v remoteInt) aGet(a aborter) int64 {
return int64(v.r.Get(a, v.size));
}
func (v remoteInt) Set(t *eval.Thread, x int64) {
v.aSet(t, x);
}
func (v remoteInt) aSet(a aborter, x int64) {
v.r.Set(a, v.size, uint64(x));
}
func (v remoteInt) addr() remote {
return v.r;
}
func mkInt8(r remote) eval.Value {
return remoteInt{r, 1};
}
func mkInt16(r remote) eval.Value {
return remoteInt{r, 2};
}
func mkInt32(r remote) eval.Value {
return remoteInt{r, 4};
}
func mkInt64(r remote) eval.Value {
return remoteInt{r, 8};
}
func mkInt(r remote) eval.Value {
return remoteInt{r, r.p.IntSize()};
}
/*
* Float
*/
type remoteFloat struct {
r remote;
size int;
}
func (v remoteFloat) String() string {
return tryRVString(func(a aborter) string { return fmt.Sprintf("%v", v.aGet(a)) });
}
func (v remoteFloat) Assign(t *eval.Thread, o eval.Value) {
v.Set(t, o.(eval.FloatValue).Get(t));
}
func (v remoteFloat) Get(t *eval.Thread) float64 {
return v.aGet(t);
}
func (v remoteFloat) aGet(a aborter) float64 {
bits := v.r.Get(a, v.size);
switch v.size {
case 4:
return float64(v.r.p.ToFloat32(uint32(bits)));
case 8:
return v.r.p.ToFloat64(bits);
}
panic("Unexpected float size ", v.size);
}
func (v remoteFloat) Set(t *eval.Thread, x float64) {
v.aSet(t, x);
}
func (v remoteFloat) aSet(a aborter, x float64) {
var bits uint64;
switch v.size{
case 4:
bits = uint64(v.r.p.FromFloat32(float32(x)));
case 8:
bits = v.r.p.FromFloat64(x);
default:
panic("Unexpected float size ", v.size);
}
v.r.Set(a, v.size, bits);
}
func (v remoteFloat) addr() remote {
return v.r;
}
func mkFloat32(r remote) eval.Value {
return remoteFloat{r, 4};
}
func mkFloat64(r remote) eval.Value {
return remoteFloat{r, 8};
}
func mkFloat(r remote) eval.Value {
return remoteFloat{r, r.p.FloatSize()};
}
/*
* String
*/
type remoteString struct {
r remote;
}
func (v remoteString) String() string {
return tryRVString(func(a aborter) string { return v.aGet(a) });
}
func (v remoteString) Assign(t *eval.Thread, o eval.Value) {
v.Set(t, o.(eval.StringValue).Get(t));
}
func (v remoteString) Get(t *eval.Thread) string {
return v.aGet(t);
}
func (v remoteString) aGet(a aborter) string {
rs := v.r.p.runtime.String.mk(v.r).(remoteStruct);
str := proc.Word(rs.field(v.r.p.f.String.Str).(remoteUint).aGet(a));
len := rs.field(v.r.p.f.String.Len).(remoteInt).aGet(a);
bytes := make([]uint8, len);
_, err := v.r.p.Peek(str, bytes);
if err != nil {
a.Abort(err);
}
return string(bytes);
}
func (v remoteString) Set(t *eval.Thread, x string) {
v.aSet(t, x);
}
func (v remoteString) aSet(a aborter, x string) {
// TODO(austin) This isn't generally possible without the
// ability to allocate remote memory.
a.Abort(ReadOnlyError("remote strings cannot be assigned to"));
}
func mkString(r remote) eval.Value {
return remoteString{r};
}
/*
* Array
*/
type remoteArray struct {
r remote;
len int64;
elemType *remoteType;
}
func (v remoteArray) String() string {
res := "{";
for i := int64(0); i < v.len; i++ {
if i > 0 {
res += ", ";
}
res += v.elem(i).String();
}
return res + "}";
}
func (v remoteArray) Assign(t *eval.Thread, o eval.Value) {
// TODO(austin) Could do a bigger memcpy if o is a
// remoteArray in the same Process.
oa := o.(eval.ArrayValue);
for i := int64(0); i < v.len; i++ {
v.Elem(t, i).Assign(t, oa.Elem(t, i));
}
}
func (v remoteArray) Get(t *eval.Thread) eval.ArrayValue {
return v;
}
func (v remoteArray) Elem(t *eval.Thread, i int64) eval.Value {
return v.elem(i);
}
func (v remoteArray) elem(i int64) eval.Value {
return v.elemType.mk(v.r.plus(proc.Word(int64(v.elemType.size) * i)));
}
func (v remoteArray) Sub(i int64, len int64) eval.ArrayValue {
return remoteArray{v.r.plus(proc.Word(int64(v.elemType.size) * i)), len, v.elemType};
}
/*
* Struct
*/
type remoteStruct struct {
r remote;
layout []remoteStructField;
}
type remoteStructField struct {
offset int;
fieldType *remoteType;
}
func (v remoteStruct) String() string {
res := "{";
for i := range v.layout {
if i > 0 {
res += ", ";
}
res += v.field(i).String();
}
return res + "}";
}
func (v remoteStruct) Assign(t *eval.Thread, o eval.Value) {
// TODO(austin) Could do a bigger memcpy.
oa := o.(eval.StructValue);
l := len(v.layout);
for i := 0; i < l; i++ {
v.Field(t, i).Assign(t, oa.Field(t, i));
}
}
func (v remoteStruct) Get(t *eval.Thread) eval.StructValue {
return v;
}
func (v remoteStruct) Field(t *eval.Thread, i int) eval.Value {
return v.field(i);
}
func (v remoteStruct) field(i int) eval.Value {
f := &v.layout[i];
return f.fieldType.mk(v.r.plus(proc.Word(f.offset)));
}
func (v remoteStruct) addr() remote {
return v.r;
}
/*
* Pointer
*/
// TODO(austin) Comparing two remote pointers for equality in the
// interpreter will crash it because the Value's returned from
// remotePtr.Get() will be structs.
type remotePtr struct {
r remote;
elemType *remoteType;
}
func (v remotePtr) String() string {
return tryRVString(func(a aborter) string {
e := v.aGet(a);
if e == nil {
return "<nil>";
}
return "&" + e.String();
});
}
func (v remotePtr) Assign(t *eval.Thread, o eval.Value) {
v.Set(t, o.(eval.PtrValue).Get(t));
}
func (v remotePtr) Get(t *eval.Thread) eval.Value {
return v.aGet(t);
}
func (v remotePtr) aGet(a aborter) eval.Value {
addr := proc.Word(v.r.Get(a, v.r.p.PtrSize()));
if addr == 0 {
return nil;
}
return v.elemType.mk(remote{addr, v.r.p});
}
func (v remotePtr) Set(t *eval.Thread, x eval.Value) {
v.aSet(t, x);
}
func (v remotePtr) aSet(a aborter, x eval.Value) {
if x == nil {
v.r.Set(a, v.r.p.PtrSize(), 0);
return;
}
xr, ok := x.(remoteValue);
if !ok || v.r.p != xr.addr().p {
a.Abort(RemoteMismatchError("remote pointer must point within the same process"));
}
v.r.Set(a, v.r.p.PtrSize(), uint64(xr.addr().base));
}
func (v remotePtr) addr() remote {
return v.r;
}
/*
* Slice
*/
type remoteSlice struct {
r remote;
elemType *remoteType;
}
func (v remoteSlice) String() string {
return tryRVString(func(a aborter) string {
b := v.aGet(a).Base;
if b == nil {
return "<nil>";
}
return b.String();
});
}
func (v remoteSlice) Assign(t *eval.Thread, o eval.Value) {
v.Set(t, o.(eval.SliceValue).Get(t));
}
func (v remoteSlice) Get(t *eval.Thread) eval.Slice {
return v.aGet(t);
}
func (v remoteSlice) aGet(a aborter) eval.Slice {
rs := v.r.p.runtime.Slice.mk(v.r).(remoteStruct);
base := proc.Word(rs.field(v.r.p.f.Slice.Array).(remoteUint).aGet(a));
nel := rs.field(v.r.p.f.Slice.Len).(remoteInt).aGet(a);
cap := rs.field(v.r.p.f.Slice.Cap).(remoteInt).aGet(a);
if base == 0 {
return eval.Slice{nil, nel, cap};
}
return eval.Slice{remoteArray{remote{base, v.r.p}, nel, v.elemType}, nel, cap};
}
func (v remoteSlice) Set(t *eval.Thread, x eval.Slice) {
v.aSet(t, x);
}
func (v remoteSlice) aSet(a aborter, x eval.Slice) {
rs := v.r.p.runtime.Slice.mk(v.r).(remoteStruct);
if x.Base == nil {
rs.field(v.r.p.f.Slice.Array).(remoteUint).aSet(a, 0);
} else {
ar, ok := x.Base.(remoteArray);
if !ok || v.r.p != ar.r.p {
a.Abort(RemoteMismatchError("remote slice must point within the same process"));
}
rs.field(v.r.p.f.Slice.Array).(remoteUint).aSet(a, uint64(ar.r.base));
}
rs.field(v.r.p.f.Slice.Len).(remoteInt).aSet(a, x.Len);
rs.field(v.r.p.f.Slice.Cap).(remoteInt).aSet(a, x.Cap);
}