mirror of
https://github.com/golang/go
synced 2024-10-05 12:31:23 -06:00
b71883e9b0
Previously, a timeout (in int64 nanoseconds) applied to a granularity even smaller than one operation: a 100 byte read with a 1 second timeout could take 100 seconds, if the bytes all arrived on the network 1 second apart. This was confusing. Rather than making the timeout granularity be per-Read/Write, this CL makes callers set an absolute deadline (in time.Time) after which operations will fail. This makes it possible to set deadlines at higher levels, without knowing exactly how many read/write operations will happen in e.g. reading an HTTP request. Fixes #2723 R=r, rsc, dave CC=golang-dev https://golang.org/cl/5555048
68 lines
1.3 KiB
Go
68 lines
1.3 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 errors.New("net.Pipe does not support deadlines")
|
|
}
|
|
|
|
func (p *pipe) SetReadDeadline(t time.Time) error {
|
|
return errors.New("net.Pipe does not support deadlines")
|
|
}
|
|
|
|
func (p *pipe) SetWriteDeadline(t time.Time) error {
|
|
return errors.New("net.Pipe does not support deadlines")
|
|
}
|