mirror of
https://github.com/golang/go
synced 2024-10-01 09:38:36 -06:00
519474451a
This is a subset of https://golang.org/cl/20022 with only the copyright header lines, so the next CL will be smaller and more reviewable. Go policy has been single space after periods in comments for some time. The copyright header template at: https://golang.org/doc/contribute.html#copyright also uses a single space. Make them all consistent. Change-Id: Icc26c6b8495c3820da6b171ca96a74701b4a01b0 Reviewed-on: https://go-review.googlesource.com/20111 Run-TryBot: Brad Fitzpatrick <bradfitz@golang.org> Reviewed-by: Ian Lance Taylor <iant@golang.org> Reviewed-by: Matthew Dempsky <mdempsky@google.com> TryBot-Result: Gobot Gobot <gobot@golang.org>
68 lines
1.5 KiB
Go
68 lines
1.5 KiB
Go
// Copyright 2010 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 net
|
|
|
|
import (
|
|
"errors"
|
|
"io"
|
|
"time"
|
|
)
|
|
|
|
// Pipe creates a synchronous, in-memory, full duplex
|
|
// network connection; both ends implement the Conn interface.
|
|
// Reads on one end are matched with writes on the other,
|
|
// copying data directly between the two; there is no internal
|
|
// buffering.
|
|
func Pipe() (Conn, Conn) {
|
|
r1, w1 := io.Pipe()
|
|
r2, w2 := io.Pipe()
|
|
|
|
return &pipe{r1, w2}, &pipe{r2, w1}
|
|
}
|
|
|
|
type pipe struct {
|
|
*io.PipeReader
|
|
*io.PipeWriter
|
|
}
|
|
|
|
type pipeAddr int
|
|
|
|
func (pipeAddr) Network() string {
|
|
return "pipe"
|
|
}
|
|
|
|
func (pipeAddr) String() string {
|
|
return "pipe"
|
|
}
|
|
|
|
func (p *pipe) Close() error {
|
|
err := p.PipeReader.Close()
|
|
err1 := p.PipeWriter.Close()
|
|
if err == nil {
|
|
err = err1
|
|
}
|
|
return err
|
|
}
|
|
|
|
func (p *pipe) LocalAddr() Addr {
|
|
return pipeAddr(0)
|
|
}
|
|
|
|
func (p *pipe) RemoteAddr() Addr {
|
|
return pipeAddr(0)
|
|
}
|
|
|
|
func (p *pipe) SetDeadline(t time.Time) error {
|
|
return &OpError{Op: "set", Net: "pipe", Source: nil, Addr: nil, Err: errors.New("deadline not supported")}
|
|
}
|
|
|
|
func (p *pipe) SetReadDeadline(t time.Time) error {
|
|
return &OpError{Op: "set", Net: "pipe", Source: nil, Addr: nil, Err: errors.New("deadline not supported")}
|
|
}
|
|
|
|
func (p *pipe) SetWriteDeadline(t time.Time) error {
|
|
return &OpError{Op: "set", Net: "pipe", Source: nil, Addr: nil, Err: errors.New("deadline not supported")}
|
|
}
|