aboutsummaryrefslogtreecommitdiff
path: root/src/lib
diff options
context:
space:
mode:
authorRuss Cox <rsc@golang.org>2009-05-22 22:43:57 -0700
committerRuss Cox <rsc@golang.org>2009-05-22 22:43:57 -0700
commitca2fe5d8bd77b1a159baddde66f8f6ca5e731be2 (patch)
treeb6132390c4156a7249f1ec0bb7a3b13d7f27e6b1 /src/lib
parent2a4dcfffc9d0618dd63b04db50816d82e4db5dc7 (diff)
downloadgo-ca2fe5d8bd77b1a159baddde66f8f6ca5e731be2.tar.xz
Automated g4 rollback of changelist 29302.
*** Reason for rollback *** too many files included *** Original change description *** simplifying grammar: delete LBASETYPE and LACONST R=ken OCL=29303 CL=29303
Diffstat (limited to 'src/lib')
-rw-r--r--src/lib/Make.deps4
-rw-r--r--src/lib/bufio/bufio.go8
-rw-r--r--src/lib/io/io.go14
-rw-r--r--src/lib/io/pipe.go86
-rw-r--r--src/lib/runtime/types.go121
-rw-r--r--src/lib/sync/mutex.go22
6 files changed, 43 insertions, 212 deletions
diff --git a/src/lib/Make.deps b/src/lib/Make.deps
index 4b0df407ce..30083f2631 100644
--- a/src/lib/Make.deps
+++ b/src/lib/Make.deps
@@ -10,7 +10,7 @@ exvar.install: fmt.install http.install io.install log.install strconv.install s
flag.install: fmt.install os.install strconv.install
fmt.install: io.install os.install reflect.install strconv.install utf8.install
go/ast.install: go/token.install unicode.install utf8.install
-go/doc.install: container/vector.install fmt.install go/ast.install go/token.install io.install once.install regexp.install sort.install strings.install template.install
+go/doc.install: container/vector.install fmt.install go/ast.install go/token.install io.install once.install regexp.install sort.install strings.install
go/parser.install: container/vector.install fmt.install go/ast.install go/scanner.install go/token.install io.install os.install
go/scanner.install: go/token.install strconv.install unicode.install utf8.install
go/token.install: strconv.install
@@ -39,7 +39,7 @@ syscall.install: sync.install
tabwriter.install: container/vector.install io.install os.install utf8.install
template.install: container/vector.install fmt.install io.install os.install reflect.install runtime.install strings.install
testing.install: flag.install fmt.install os.install runtime.install
-testing/iotest.install: io.install log.install os.install
+testing/iotest.install: io.install os.install
time.install: io.install once.install os.install syscall.install
unicode.install:
utf8.install:
diff --git a/src/lib/bufio/bufio.go b/src/lib/bufio/bufio.go
index d008b6d7b4..7bfbb089f7 100644
--- a/src/lib/bufio/bufio.go
+++ b/src/lib/bufio/bufio.go
@@ -109,11 +109,11 @@ func (b *Reader) fill() os.Error {
return nil
}
-// Read reads data into p, returning the number of bytes read.
-// Read reads as much data as possible into p.
-// If nn < len(p), Read also returns an error explaining
+// Read reads data into p.
+// It returns the number of bytes read into p.
+// If nn < len(p), also returns an error explaining
// why the read is short. At EOF, the count will be
-// zero and err will be io.ErrUnexpectedEOF.
+// zero and err will be io.ErrEOF.
func (b *Reader) Read(p []byte) (nn int, err os.Error) {
nn = 0;
for len(p) > 0 {
diff --git a/src/lib/io/io.go b/src/lib/io/io.go
index 68ef8c4803..c120d8d443 100644
--- a/src/lib/io/io.go
+++ b/src/lib/io/io.go
@@ -69,19 +69,7 @@ type ReadWriteCloser interface {
Closer;
}
-// ReadByter is the interface that wraps the basic ReadByte method.
-// Implementations of ReadByte typically use buffered I/O.
-type ReadByter interface {
- ReadByte() (byte, os.Error);
-}
-
-// WriteByter is the interface that wraps the basic WriteByte method.
-// Implementations of WriteByte typically use buffered I/O.
-type WriteByter interface {
- WriteByte(byte) os.Error;
-}
-
-// StringBytes converts a string to an array of bytes for easy marshaling.
+// Convert a string to an array of bytes for easy marshaling.
func StringBytes(s string) []byte {
b := make([]byte, len(s));
for i := 0; i < len(s); i++ {
diff --git a/src/lib/io/pipe.go b/src/lib/io/pipe.go
index f91bf34567..5f9e7a488c 100644
--- a/src/lib/io/pipe.go
+++ b/src/lib/io/pipe.go
@@ -21,9 +21,7 @@ type pipeReturn struct {
// Shared pipe structure.
type pipe struct {
rclosed bool; // Read end closed?
- rerr os.Error; // Error supplied to CloseReader
wclosed bool; // Write end closed?
- werr os.Error; // Error supplied to CloseWriter
wpend []byte; // Written data waiting to be read.
wtot int; // Bytes consumed so far in current write.
cr chan []byte; // Write sends data here...
@@ -41,7 +39,7 @@ func (p *pipe) Read(data []byte) (n int, err os.Error) {
p.wpend = <-p.cr;
}
if p.wpend == nil {
- return 0, p.werr;
+ return 0, nil;
}
p.wtot = 0;
}
@@ -72,7 +70,7 @@ func (p *pipe) Write(data []byte) (n int, err os.Error) {
return 0, os.EINVAL;
}
if p.rclosed {
- return 0, p.rerr;
+ return 0, os.EPIPE;
}
// Send data to reader.
@@ -83,34 +81,29 @@ func (p *pipe) Write(data []byte) (n int, err os.Error) {
return res.n, res.err;
}
-func (p *pipe) CloseReader(rerr os.Error) os.Error {
+func (p *pipe) CloseReader() os.Error {
if p == nil || p.rclosed {
return os.EINVAL;
}
// Stop any future writes.
p.rclosed = true;
- if rerr == nil {
- rerr = os.EPIPE;
- }
- p.rerr = rerr;
// Stop the current write.
if !p.wclosed {
- p.cw <- pipeReturn{p.wtot, rerr};
+ p.cw <- pipeReturn{p.wtot, os.EPIPE};
}
return nil;
}
-func (p *pipe) CloseWriter(werr os.Error) os.Error {
+func (p *pipe) CloseWriter() os.Error {
if p == nil || p.wclosed {
return os.EINVAL;
}
// Stop any future reads.
p.wclosed = true;
- p.werr = werr;
// Stop the current read.
if !p.rclosed {
@@ -128,97 +121,70 @@ func (p *pipe) CloseWriter(werr os.Error) os.Error {
// 2. Clients cannot use interface conversions on the
// read end to find the Write method, and vice versa.
-// A PipeReader is the read half of a pipe.
-type PipeReader struct {
+// Read half of pipe.
+type pipeRead struct {
lock sync.Mutex;
p *pipe;
}
-// Read implements the standard Read interface:
-// it reads data from the pipe, blocking until a writer
-// arrives or the write end is closed.
-// If the write end is closed with an error, that error is
-// returned as err; otherwise err is nil.
-func (r *PipeReader) Read(data []byte) (n int, err os.Error) {
+func (r *pipeRead) Read(data []byte) (n int, err os.Error) {
r.lock.Lock();
defer r.lock.Unlock();
return r.p.Read(data);
}
-// Close closes the reader; subsequent writes to the
-// write half of the pipe will return the error os.EPIPE.
-func (r *PipeReader) Close() os.Error {
- r.lock.Lock();
- defer r.lock.Unlock();
-
- return r.p.CloseReader(nil);
-}
-
-// CloseWithError closes the reader; subsequent writes
-// to the write half of the pipe will return the error rerr.
-func (r *PipeReader) CloseWithError(rerr os.Error) os.Error {
+func (r *pipeRead) Close() os.Error {
r.lock.Lock();
defer r.lock.Unlock();
- return r.p.CloseReader(rerr);
+ return r.p.CloseReader();
}
-func (r *PipeReader) finish() {
+func (r *pipeRead) finish() {
r.Close();
}
// Write half of pipe.
-type PipeWriter struct {
+type pipeWrite struct {
lock sync.Mutex;
p *pipe;
}
-// Write implements the standard Write interface:
-// it writes data to the pipe, blocking until readers
-// have consumed all the data or the read end is closed.
-// If the read end is closed with an error, that err is
-// returned as err; otherwise err is os.EPIPE.
-func (w *PipeWriter) Write(data []byte) (n int, err os.Error) {
+func (w *pipeWrite) Write(data []byte) (n int, err os.Error) {
w.lock.Lock();
defer w.lock.Unlock();
return w.p.Write(data);
}
-// Close closes the writer; subsequent reads from the
-// read half of the pipe will return no bytes and a nil error.
-func (w *PipeWriter) Close() os.Error {
- w.lock.Lock();
- defer w.lock.Unlock();
-
- return w.p.CloseWriter(nil);
-}
-
-// CloseWithError closes the writer; subsequent reads from the
-// read half of the pipe will return no bytes and the error werr.
-func (w *PipeWriter) CloseWithError(werr os.Error) os.Error {
+func (w *pipeWrite) Close() os.Error {
w.lock.Lock();
defer w.lock.Unlock();
- return w.p.CloseWriter(werr);
+ return w.p.CloseWriter();
}
-func (w *PipeWriter) finish() {
+func (w *pipeWrite) finish() {
w.Close();
}
// Pipe creates a synchronous in-memory pipe.
-// It can be used to connect code expecting an io.Reader
+// Used to connect code expecting an io.Reader
// with code expecting an io.Writer.
-// Reads on one end are matched with writes on the other.
-func Pipe() (*PipeReader, *PipeWriter) {
+//
+// Reads on one end are matched by writes on the other.
+// Writes don't complete until all the data has been
+// written or the read end is closed. Reads return
+// any available data or block until the next write
+// or the write end is closed.
+func Pipe() (io.ReadCloser, io.WriteCloser) {
p := new(pipe);
p.cr = make(chan []byte, 1);
p.cw = make(chan pipeReturn, 1);
- r := new(PipeReader);
+ r := new(pipeRead);
r.p = p;
- w := new(PipeWriter);
+ w := new(pipeWrite);
w.p = p;
return r, w;
}
diff --git a/src/lib/runtime/types.go b/src/lib/runtime/types.go
deleted file mode 100644
index 41c4b3a1e9..0000000000
--- a/src/lib/runtime/types.go
+++ /dev/null
@@ -1,121 +0,0 @@
-// 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.
-
-// TODO(rsc): Doc comments
-
-package runtime
-
-import "unsafe"
-
-// The Type interface stands for any of the run-time type structures
-// in this package.
-type Type interface { }
-
-// All types begin with a few common fields needed for
-// the interface runtime.
-type CommonType struct {
- Size uintptr;
- Hash uint32;
- Alg uint8;
- Align uint8;
- FieldAlign uint8;
-}
-
-// Basic types; should these be one struct with an enum kind?
-// The benefit of splitting them up into many types is that
-// one can use a single type switch instead of needing an
-// enum switch inside a type switch.
-type BoolType CommonType
-type Float32Type CommonType
-type Float64Type CommonType
-type FloatType CommonType
-type Int16Type CommonType
-type Int32Type CommonType
-type Int64Type CommonType
-type Int8Type CommonType
-type IntType CommonType
-type Uint16Type CommonType
-type Uint32Type CommonType
-type Uint64Type CommonType
-type Uint8Type CommonType
-type UintType CommonType
-type StringType CommonType
-type UintptrType CommonType
-type UnsafePointerType CommonType
-
-type ArrayType struct {
- CommonType;
- Elem *Type;
- Bound int32; // -1 means slice
-}
-
-type ChanDir int
-const (
- SendDir ChanDir = 1<<iota;
- RecvDir;
- BothDir = SendDir | RecvDir;
-)
-
-type ChanType struct {
- CommonType;
- Elem *Type;
- Dir ChanDir;
-}
-
-type FuncType struct {
- CommonType;
- In []*Type;
- Out []*Type;
-}
-
-type IMethod struct {
- Name *string;
- Package *string;
- Type *Type;
-}
-
-type InterfaceType struct {
- CommonType;
- Methods []*IMethod;
-}
-
-type MapType struct {
- CommonType;
- Key *Type;
- Elem *Type;
-}
-
-type Method struct {
- Name *string;
- Package *string;
- Type *Type;
- Func unsafe.Pointer;
-}
-
-type NamedType struct {
- CommonType;
- Name *string;
- Package *string;
- Type *Type;
- ValueMethods []*Method;
- PtrMethods []*Method;
-}
-
-type PtrType struct {
- CommonType;
- Sub *Type;
-}
-
-type StructField struct {
- Name *string;
- Type *Type;
- Tag *string;
- Offset uintptr;
-}
-
-type StructType struct {
- CommonType;
- Fields []*StructField;
-}
-
diff --git a/src/lib/sync/mutex.go b/src/lib/sync/mutex.go
index e485867802..5a6311a837 100644
--- a/src/lib/sync/mutex.go
+++ b/src/lib/sync/mutex.go
@@ -2,19 +2,19 @@
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
-/*
- The sync /* package * / provides basic sync primitives.
- // Such as mutual exclusion locks.
-*/
+// The sync package provides basic synchronization primitives
+// such as mutual exclusion locks. These are intended for use
+// by low-level library routines. Higher-level synchronization
+// is better done via channels and communication.
package sync
func cas(val *int32, old, new int32) bool
func semacquire(*int32)
func semrelease(*int32)
- // A Mutex is a mutual exclusion lock.
- // Mutexes can be created as part of other structures;
- // the zero value for a Mutex is an unlocked mutex.
+// A Mutex is a mutual exclusion lock.
+// Mutexes can be created as part of other structures;
+// the zero value for a Mutex is an unlocked mutex.
type Mutex struct {
key int32;
sema int32;
@@ -30,11 +30,9 @@ func xadd(val *int32, delta int32) (new int32) {
panic("unreached")
}
-/*
- * Lock locks m.
- * If the lock is already in use, the calling goroutine
- * blocks until the mutex is available.
- */
+// Lock locks m.
+// If the lock is already in use, the calling goroutine
+// blocks until the mutex is available.
func (m *Mutex) Lock() {
if xadd(&m.key, 1) == 1 {
// changed from 0 to 1; we hold lock