Gecko [ 167.86.127.34 ]

Name	Size	Permission
http	[ DIR ]	drwxr-xr-x
internal	[ DIR ]	drwxr-xr-x
mail	[ DIR ]	drwxr-xr-x
rpc	[ DIR ]	drwxr-xr-x
smtp	[ DIR ]	drwxr-xr-x
testdata	[ DIR ]	drwxr-xr-x
textproto	[ DIR ]	drwxr-xr-x
url	[ DIR ]	drwxr-xr-x
addrselect.go	9.51 KB	-rw-r--r--
addrselect_test.go	6.2 KB	-rw-r--r--
cgo_aix.go	578 B	-rw-r--r--
cgo_android.go	268 B	-rw-r--r--
cgo_bsd.go	348 B	-rw-r--r--
cgo_linux.go	635 B	-rw-r--r--
cgo_netbsd.go	272 B	-rw-r--r--
cgo_openbsd.go	272 B	-rw-r--r--
cgo_resnew.go	577 B	-rw-r--r--
cgo_resold.go	571 B	-rw-r--r--
cgo_socknew.go	748 B	-rw-r--r--
cgo_sockold.go	838 B	-rw-r--r--
cgo_solaris.go	339 B	-rw-r--r--
cgo_stub.go	1.06 KB	-rw-r--r--
cgo_unix.go	9.53 KB	-rw-r--r--
cgo_unix_test.go	1.89 KB	-rw-r--r--
cgo_windows.go	398 B	-rw-r--r--
conf.go	8.88 KB	-rw-r--r--
conf_netcgo.go	369 B	-rw-r--r--
conf_test.go	9.59 KB	-rw-r--r--
conn_test.go	1.77 KB	-rw-r--r--
dial.go	22.44 KB	-rw-r--r--
dial_test.go	27 KB	-rw-r--r--
dial_unix_test.go	2.74 KB	-rw-r--r--
dnsclient.go	5.34 KB	-rw-r--r--
dnsclient_test.go	1.54 KB	-rw-r--r--
dnsclient_unix.go	21.86 KB	-rw-r--r--
dnsclient_unix_test.go	45.17 KB	-rw-r--r--
dnsconfig_unix.go	5.47 KB	-rw-r--r--
dnsconfig_unix_test.go	6.73 KB	-rw-r--r--
dnsname_test.go	1.98 KB	-rw-r--r--
error_plan9.go	224 B	-rw-r--r--
error_plan9_test.go	398 B	-rw-r--r--
error_posix.go	583 B	-rw-r--r--
error_posix_test.go	980 B	-rw-r--r--
error_test.go	19.39 KB	-rw-r--r--
error_unix.go	421 B	-rw-r--r--
error_unix_test.go	672 B	-rw-r--r--
error_windows.go	355 B	-rw-r--r--
error_windows_test.go	483 B	-rw-r--r--
example_test.go	3.16 KB	-rw-r--r--
external_test.go	4.07 KB	-rw-r--r--
fd_plan9.go	3.56 KB	-rw-r--r--
fd_unix.go	7.36 KB	-rw-r--r--
fd_windows.go	6.49 KB	-rw-r--r--
file.go	1.69 KB	-rw-r--r--
file_plan9.go	2.68 KB	-rw-r--r--
file_stub.go	485 B	-rw-r--r--
file_test.go	6.53 KB	-rw-r--r--
file_unix.go	2.51 KB	-rw-r--r--
file_windows.go	521 B	-rw-r--r--
hook.go	628 B	-rw-r--r--
hook_plan9.go	283 B	-rw-r--r--
hook_unix.go	734 B	-rw-r--r--
hook_windows.go	875 B	-rw-r--r--
hosts.go	3.1 KB	-rw-r--r--
hosts_test.go	4.65 KB	-rw-r--r--
interface.go	7.14 KB	-rw-r--r--
interface_aix.go	4.41 KB	-rw-r--r--
interface_bsd.go	2.74 KB	-rw-r--r--
interface_bsd_test.go	1.42 KB	-rw-r--r--
interface_bsdvar.go	711 B	-rw-r--r--
interface_darwin.go	1.29 KB	-rw-r--r--
interface_freebsd.go	1.42 KB	-rw-r--r--
interface_linux.go	6.9 KB	-rw-r--r--
interface_linux_test.go	3.65 KB	-rw-r--r--
interface_plan9.go	4.59 KB	-rw-r--r--
interface_solaris.go	2.46 KB	-rw-r--r--
interface_stub.go	808 B	-rw-r--r--
interface_test.go	9.67 KB	-rw-r--r--
interface_unix_test.go	4.69 KB	-rw-r--r--
interface_windows.go	5.41 KB	-rw-r--r--
ip.go	16.61 KB	-rw-r--r--
ip_test.go	23.96 KB	-rw-r--r--
iprawsock.go	7.08 KB	-rw-r--r--
iprawsock_plan9.go	874 B	-rw-r--r--
iprawsock_posix.go	3.45 KB	-rw-r--r--
iprawsock_test.go	5.62 KB	-rw-r--r--
ipsock.go	8.77 KB	-rw-r--r--
ipsock_plan9.go	6.25 KB	-rw-r--r--
ipsock_posix.go	6.16 KB	-rw-r--r--
ipsock_test.go	6.81 KB	-rw-r--r--
listen_test.go	21.32 KB	-rw-r--r--
lookup.go	15.45 KB	-rw-r--r--
lookup_fake.go	1.64 KB	-rw-r--r--
lookup_plan9.go	7.68 KB	-rw-r--r--
lookup_test.go	29.14 KB	-rw-r--r--
lookup_unix.go	8.78 KB	-rw-r--r--
lookup_windows.go	11.74 KB	-rw-r--r--
lookup_windows_test.go	8 KB	-rw-r--r--
mac.go	1.88 KB	-rw-r--r--
mac_test.go	3.26 KB	-rw-r--r--
main_cloexec_test.go	669 B	-rw-r--r--
main_conf_test.go	915 B	-rw-r--r--
main_noconf_test.go	493 B	-rw-r--r--
main_plan9_test.go	392 B	-rw-r--r--
main_posix_test.go	1.37 KB	-rw-r--r--
main_test.go	7.11 KB	-rw-r--r--
main_unix_test.go	1.24 KB	-rw-r--r--
main_windows_test.go	1.08 KB	-rw-r--r--
mockserver_test.go	11.23 KB	-rw-r--r--
net.go	20.9 KB	-rw-r--r--
net_fake.go	5.34 KB	-rw-r--r--
net_test.go	12.1 KB	-rw-r--r--
net_windows_test.go	15.94 KB	-rw-r--r--
netgo_unix_test.go	631 B	-rw-r--r--
nss.go	3.71 KB	-rw-r--r--
nss_test.go	3.33 KB	-rw-r--r--
packetconn_test.go	3.56 KB	-rw-r--r--
parse.go	7.82 KB	-rw-r--r--
parse_test.go	2.14 KB	-rw-r--r--
pipe.go	5.59 KB	-rw-r--r--
pipe_test.go	1.2 KB	-rw-r--r--
platform_test.go	4.59 KB	-rw-r--r--
port.go	1.46 KB	-rw-r--r--
port_test.go	1.34 KB	-rw-r--r--
port_unix.go	1.28 KB	-rw-r--r--
protoconn_test.go	7.22 KB	-rw-r--r--
rawconn.go	1.89 KB	-rw-r--r--
rawconn_stub_test.go	622 B	-rw-r--r--
rawconn_test.go	4.52 KB	-rw-r--r--
rawconn_unix_test.go	3.15 KB	-rw-r--r--
rawconn_windows_test.go	3.26 KB	-rw-r--r--
sendfile_linux.go	1.1 KB	-rw-r--r--
sendfile_stub.go	329 B	-rw-r--r--
sendfile_test.go	5.69 KB	-rw-r--r--
sendfile_unix_alt.go	1.98 KB	-rw-r--r--
sendfile_windows.go	1.02 KB	-rw-r--r--
server_test.go	11.55 KB	-rw-r--r--
sock_bsd.go	898 B	-rw-r--r--
sock_cloexec.go	1.46 KB	-rw-r--r--
sock_linux.go	644 B	-rw-r--r--
sock_plan9.go	262 B	-rw-r--r--
sock_posix.go	6.83 KB	-rw-r--r--
sock_stub.go	378 B	-rw-r--r--
sock_windows.go	1.16 KB	-rw-r--r--
sockaddr_posix.go	955 B	-rw-r--r--
sockopt_aix.go	1.32 KB	-rw-r--r--
sockopt_bsd.go	2.09 KB	-rw-r--r--
sockopt_linux.go	1.14 KB	-rw-r--r--
sockopt_plan9.go	406 B	-rw-r--r--
sockopt_posix.go	2.67 KB	-rw-r--r--
sockopt_solaris.go	1.14 KB	-rw-r--r--
sockopt_stub.go	738 B	-rw-r--r--
sockopt_windows.go	1.34 KB	-rw-r--r--
sockoptip_bsdvar.go	848 B	-rw-r--r--
sockoptip_linux.go	735 B	-rw-r--r--
sockoptip_posix.go	1.43 KB	-rw-r--r--
sockoptip_stub.go	949 B	-rw-r--r--
sockoptip_windows.go	819 B	-rw-r--r--
splice_linux.go	1.09 KB	-rw-r--r--
splice_stub.go	286 B	-rw-r--r--
splice_test.go	10.51 KB	-rw-r--r--
sys_cloexec.go	977 B	-rw-r--r--
tcpsock.go	9.85 KB	-rw-r--r--
tcpsock_plan9.go	2.13 KB	-rw-r--r--
tcpsock_posix.go	5.27 KB	-rw-r--r--
tcpsock_test.go	17.51 KB	-rw-r--r--
tcpsock_unix_test.go	2.38 KB	-rw-r--r--
tcpsockopt_darwin.go	770 B	-rw-r--r--
tcpsockopt_dragonfly.go	698 B	-rw-r--r--
tcpsockopt_openbsd.go	365 B	-rw-r--r--
tcpsockopt_plan9.go	503 B	-rw-r--r--
tcpsockopt_posix.go	491 B	-rw-r--r--
tcpsockopt_solaris.go	1.15 KB	-rw-r--r--
tcpsockopt_stub.go	393 B	-rw-r--r--
tcpsockopt_unix.go	712 B	-rw-r--r--
tcpsockopt_windows.go	741 B	-rw-r--r--
timeout_test.go	23.18 KB	-rw-r--r--
udpsock.go	8.7 KB	-rw-r--r--
udpsock_plan9.go	3.77 KB	-rw-r--r--
udpsock_plan9_test.go	1.31 KB	-rw-r--r--
udpsock_posix.go	4.09 KB	-rw-r--r--
udpsock_test.go	11.18 KB	-rw-r--r--
unixsock.go	10.17 KB	-rw-r--r--
unixsock_linux_test.go	2.29 KB	-rw-r--r--
unixsock_plan9.go	1.24 KB	-rw-r--r--
unixsock_posix.go	5.81 KB	-rw-r--r--
unixsock_test.go	10.58 KB	-rw-r--r--
unixsock_windows_test.go	2.07 KB	-rw-r--r--
write_unix_test.go	1.59 KB	-rw-r--r--
writev_test.go	5.01 KB	-rw-r--r--
writev_unix.go	706 B	-rw-r--r--

Code Editor : mockserver_test.go

// Copyright 2013 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 !js

package net

import (
	"errors"
	"fmt"
	"io/ioutil"
	"os"
	"sync"
	"testing"
	"time"
)

// testUnixAddr uses ioutil.TempFile to get a name that is unique.
func testUnixAddr() string {
	f, err := ioutil.TempFile("", "go-nettest")
	if err != nil {
		panic(err)
	}
	addr := f.Name()
	f.Close()
	os.Remove(addr)
	return addr
}

func newLocalListener(network string) (Listener, error) {
	switch network {
	case "tcp":
		if supportsIPv4() {
			if ln, err := Listen("tcp4", "127.0.0.1:0"); err == nil {
				return ln, nil
			}
		}
		if supportsIPv6() {
			return Listen("tcp6", "[::1]:0")
		}
	case "tcp4":
		if supportsIPv4() {
			return Listen("tcp4", "127.0.0.1:0")
		}
	case "tcp6":
		if supportsIPv6() {
			return Listen("tcp6", "[::1]:0")
		}
	case "unix", "unixpacket":
		return Listen(network, testUnixAddr())
	}
	return nil, fmt.Errorf("%s is not supported", network)
}

func newDualStackListener() (lns []*TCPListener, err error) {
	var args = []struct {
		network string
		TCPAddr
	}{
		{"tcp4", TCPAddr{IP: IPv4(127, 0, 0, 1)}},
		{"tcp6", TCPAddr{IP: IPv6loopback}},
	}
	for i := 0; i < 64; i++ {
		var port int
		var lns []*TCPListener
		for _, arg := range args {
			arg.TCPAddr.Port = port
			ln, err := ListenTCP(arg.network, &arg.TCPAddr)
			if err != nil {
				continue
			}
			port = ln.Addr().(*TCPAddr).Port
			lns = append(lns, ln)
		}
		if len(lns) != len(args) {
			for _, ln := range lns {
				ln.Close()
			}
			continue
		}
		return lns, nil
	}
	return nil, errors.New("no dualstack port available")
}

type localServer struct {
	lnmu sync.RWMutex
	Listener
	done chan bool // signal that indicates server stopped
}

func (ls *localServer) buildup(handler func(*localServer, Listener)) error {
	go func() {
		handler(ls, ls.Listener)
		close(ls.done)
	}()
	return nil
}

func (ls *localServer) teardown() error {
	ls.lnmu.Lock()
	if ls.Listener != nil {
		network := ls.Listener.Addr().Network()
		address := ls.Listener.Addr().String()
		ls.Listener.Close()
		<-ls.done
		ls.Listener = nil
		switch network {
		case "unix", "unixpacket":
			os.Remove(address)
		}
	}
	ls.lnmu.Unlock()
	return nil
}

func newLocalServer(network string) (*localServer, error) {
	ln, err := newLocalListener(network)
	if err != nil {
		return nil, err
	}
	return &localServer{Listener: ln, done: make(chan bool)}, nil
}

type streamListener struct {
	network, address string
	Listener
	done chan bool // signal that indicates server stopped
}

func (sl *streamListener) newLocalServer() (*localServer, error) {
	return &localServer{Listener: sl.Listener, done: make(chan bool)}, nil
}

type dualStackServer struct {
	lnmu sync.RWMutex
	lns  []streamListener
	port string

cmu sync.RWMutex
	cs  []Conn // established connections at the passive open side
}

func (dss *dualStackServer) buildup(handler func(*dualStackServer, Listener)) error {
	for i := range dss.lns {
		go func(i int) {
			handler(dss, dss.lns[i].Listener)
			close(dss.lns[i].done)
		}(i)
	}
	return nil
}

func (dss *dualStackServer) teardownNetwork(network string) error {
	dss.lnmu.Lock()
	for i := range dss.lns {
		if network == dss.lns[i].network && dss.lns[i].Listener != nil {
			dss.lns[i].Listener.Close()
			<-dss.lns[i].done
			dss.lns[i].Listener = nil
		}
	}
	dss.lnmu.Unlock()
	return nil
}

func (dss *dualStackServer) teardown() error {
	dss.lnmu.Lock()
	for i := range dss.lns {
		if dss.lns[i].Listener != nil {
			dss.lns[i].Listener.Close()
			<-dss.lns[i].done
		}
	}
	dss.lns = dss.lns[:0]
	dss.lnmu.Unlock()
	dss.cmu.Lock()
	for _, c := range dss.cs {
		c.Close()
	}
	dss.cs = dss.cs[:0]
	dss.cmu.Unlock()
	return nil
}

func newDualStackServer() (*dualStackServer, error) {
	lns, err := newDualStackListener()
	if err != nil {
		return nil, err
	}
	_, port, err := SplitHostPort(lns[0].Addr().String())
	if err != nil {
		lns[0].Close()
		lns[1].Close()
		return nil, err
	}
	return &dualStackServer{
		lns: []streamListener{
			{network: "tcp4", address: lns[0].Addr().String(), Listener: lns[0], done: make(chan bool)},
			{network: "tcp6", address: lns[1].Addr().String(), Listener: lns[1], done: make(chan bool)},
		},
		port: port,
	}, nil
}

func transponder(ln Listener, ch chan<- error) {
	defer close(ch)

switch ln := ln.(type) {
	case *TCPListener:
		ln.SetDeadline(time.Now().Add(someTimeout))
	case *UnixListener:
		ln.SetDeadline(time.Now().Add(someTimeout))
	}
	c, err := ln.Accept()
	if err != nil {
		if perr := parseAcceptError(err); perr != nil {
			ch <- perr
		}
		ch <- err
		return
	}
	defer c.Close()

network := ln.Addr().Network()
	if c.LocalAddr().Network() != network || c.RemoteAddr().Network() != network {
		ch <- fmt.Errorf("got %v->%v; expected %v->%v", c.LocalAddr().Network(), c.RemoteAddr().Network(), network, network)
		return
	}
	c.SetDeadline(time.Now().Add(someTimeout))
	c.SetReadDeadline(time.Now().Add(someTimeout))
	c.SetWriteDeadline(time.Now().Add(someTimeout))

b := make([]byte, 256)
	n, err := c.Read(b)
	if err != nil {
		if perr := parseReadError(err); perr != nil {
			ch <- perr
		}
		ch <- err
		return
	}
	if _, err := c.Write(b[:n]); err != nil {
		if perr := parseWriteError(err); perr != nil {
			ch <- perr
		}
		ch <- err
		return
	}
}

func transceiver(c Conn, wb []byte, ch chan<- error) {
	defer close(ch)

c.SetDeadline(time.Now().Add(someTimeout))
	c.SetReadDeadline(time.Now().Add(someTimeout))
	c.SetWriteDeadline(time.Now().Add(someTimeout))

n, err := c.Write(wb)
	if err != nil {
		if perr := parseWriteError(err); perr != nil {
			ch <- perr
		}
		ch <- err
		return
	}
	if n != len(wb) {
		ch <- fmt.Errorf("wrote %d; want %d", n, len(wb))
	}
	rb := make([]byte, len(wb))
	n, err = c.Read(rb)
	if err != nil {
		if perr := parseReadError(err); perr != nil {
			ch <- perr
		}
		ch <- err
		return
	}
	if n != len(wb) {
		ch <- fmt.Errorf("read %d; want %d", n, len(wb))
	}
}

func timeoutReceiver(c Conn, d, min, max time.Duration, ch chan<- error) {
	var err error
	defer func() { ch <- err }()

t0 := time.Now()
	if err = c.SetReadDeadline(time.Now().Add(d)); err != nil {
		return
	}
	b := make([]byte, 256)
	var n int
	n, err = c.Read(b)
	t1 := time.Now()
	if n != 0 || err == nil || !err.(Error).Timeout() {
		err = fmt.Errorf("Read did not return (0, timeout): (%d, %v)", n, err)
		return
	}
	if dt := t1.Sub(t0); min > dt || dt > max && !testing.Short() {
		err = fmt.Errorf("Read took %s; expected %s", dt, d)
		return
	}
}

func timeoutTransmitter(c Conn, d, min, max time.Duration, ch chan<- error) {
	var err error
	defer func() { ch <- err }()

t0 := time.Now()
	if err = c.SetWriteDeadline(time.Now().Add(d)); err != nil {
		return
	}
	var n int
	for {
		n, err = c.Write([]byte("TIMEOUT TRANSMITTER"))
		if err != nil {
			break
		}
	}
	t1 := time.Now()
	if err == nil || !err.(Error).Timeout() {
		err = fmt.Errorf("Write did not return (any, timeout): (%d, %v)", n, err)
		return
	}
	if dt := t1.Sub(t0); min > dt || dt > max && !testing.Short() {
		err = fmt.Errorf("Write took %s; expected %s", dt, d)
		return
	}
}

func newLocalPacketListener(network string) (PacketConn, error) {
	switch network {
	case "udp":
		if supportsIPv4() {
			return ListenPacket("udp4", "127.0.0.1:0")
		}
		if supportsIPv6() {
			return ListenPacket("udp6", "[::1]:0")
		}
	case "udp4":
		if supportsIPv4() {
			return ListenPacket("udp4", "127.0.0.1:0")
		}
	case "udp6":
		if supportsIPv6() {
			return ListenPacket("udp6", "[::1]:0")
		}
	case "unixgram":
		return ListenPacket(network, testUnixAddr())
	}
	return nil, fmt.Errorf("%s is not supported", network)
}

func newDualStackPacketListener() (cs []*UDPConn, err error) {
	var args = []struct {
		network string
		UDPAddr
	}{
		{"udp4", UDPAddr{IP: IPv4(127, 0, 0, 1)}},
		{"udp6", UDPAddr{IP: IPv6loopback}},
	}
	for i := 0; i < 64; i++ {
		var port int
		var cs []*UDPConn
		for _, arg := range args {
			arg.UDPAddr.Port = port
			c, err := ListenUDP(arg.network, &arg.UDPAddr)
			if err != nil {
				continue
			}
			port = c.LocalAddr().(*UDPAddr).Port
			cs = append(cs, c)
		}
		if len(cs) != len(args) {
			for _, c := range cs {
				c.Close()
			}
			continue
		}
		return cs, nil
	}
	return nil, errors.New("no dualstack port available")
}

type localPacketServer struct {
	pcmu sync.RWMutex
	PacketConn
	done chan bool // signal that indicates server stopped
}

func (ls *localPacketServer) buildup(handler func(*localPacketServer, PacketConn)) error {
	go func() {
		handler(ls, ls.PacketConn)
		close(ls.done)
	}()
	return nil
}

func (ls *localPacketServer) teardown() error {
	ls.pcmu.Lock()
	if ls.PacketConn != nil {
		network := ls.PacketConn.LocalAddr().Network()
		address := ls.PacketConn.LocalAddr().String()
		ls.PacketConn.Close()
		<-ls.done
		ls.PacketConn = nil
		switch network {
		case "unixgram":
			os.Remove(address)
		}
	}
	ls.pcmu.Unlock()
	return nil
}

func newLocalPacketServer(network string) (*localPacketServer, error) {
	c, err := newLocalPacketListener(network)
	if err != nil {
		return nil, err
	}
	return &localPacketServer{PacketConn: c, done: make(chan bool)}, nil
}

type packetListener struct {
	PacketConn
}

func (pl *packetListener) newLocalServer() (*localPacketServer, error) {
	return &localPacketServer{PacketConn: pl.PacketConn, done: make(chan bool)}, nil
}

func packetTransponder(c PacketConn, ch chan<- error) {
	defer close(ch)

c.SetDeadline(time.Now().Add(someTimeout))
	c.SetReadDeadline(time.Now().Add(someTimeout))
	c.SetWriteDeadline(time.Now().Add(someTimeout))

b := make([]byte, 256)
	n, peer, err := c.ReadFrom(b)
	if err != nil {
		if perr := parseReadError(err); perr != nil {
			ch <- perr
		}
		ch <- err
		return
	}
	if peer == nil { // for connected-mode sockets
		switch c.LocalAddr().Network() {
		case "udp":
			peer, err = ResolveUDPAddr("udp", string(b[:n]))
		case "unixgram":
			peer, err = ResolveUnixAddr("unixgram", string(b[:n]))
		}
		if err != nil {
			ch <- err
			return
		}
	}
	if _, err := c.WriteTo(b[:n], peer); err != nil {
		if perr := parseWriteError(err); perr != nil {
			ch <- perr
		}
		ch <- err
		return
	}
}

func packetTransceiver(c PacketConn, wb []byte, dst Addr, ch chan<- error) {
	defer close(ch)

c.SetDeadline(time.Now().Add(someTimeout))
	c.SetReadDeadline(time.Now().Add(someTimeout))
	c.SetWriteDeadline(time.Now().Add(someTimeout))

n, err := c.WriteTo(wb, dst)
	if err != nil {
		if perr := parseWriteError(err); perr != nil {
			ch <- perr
		}
		ch <- err
		return
	}
	if n != len(wb) {
		ch <- fmt.Errorf("wrote %d; want %d", n, len(wb))
	}
	rb := make([]byte, len(wb))
	n, _, err = c.ReadFrom(rb)
	if err != nil {
		if perr := parseReadError(err); perr != nil {
			ch <- perr
		}
		ch <- err
		return
	}
	if n != len(wb) {
		ch <- fmt.Errorf("read %d; want %d", n, len(wb))
	}
}

func timeoutPacketReceiver(c PacketConn, d, min, max time.Duration, ch chan<- error) {
	var err error
	defer func() { ch <- err }()

t0 := time.Now()
	if err = c.SetReadDeadline(time.Now().Add(d)); err != nil {
		return
	}
	b := make([]byte, 256)
	var n int
	n, _, err = c.ReadFrom(b)
	t1 := time.Now()
	if n != 0 || err == nil || !err.(Error).Timeout() {
		err = fmt.Errorf("ReadFrom did not return (0, timeout): (%d, %v)", n, err)
		return
	}
	if dt := t1.Sub(t0); min > dt || dt > max && !testing.Short() {
		err = fmt.Errorf("ReadFrom took %s; expected %s", dt, d)
		return
	}
}

${this.title}

Code Editor : mockserver_test.go