Gecko [ www.smanegeri1koba.sch.id ]

Name	Size	Permission
agent	[ DIR ]	dr-xr-xr-x
internal	[ DIR ]	dr-xr-xr-x
knownhosts	[ DIR ]	dr-xr-xr-x
terminal	[ DIR ]	dr-xr-xr-x
test	[ DIR ]	dr-xr-xr-x
testdata	[ DIR ]	dr-xr-xr-x
benchmark_test.go	2.33 KB	-r--r--r--
buffer.go	2.13 KB	-r--r--r--
buffer_test.go	2.17 KB	-r--r--r--
certs.go	17.5 KB	-r--r--r--
certs_test.go	13.67 KB	-r--r--r--
channel.go	16.12 KB	-r--r--r--
cipher.go	21.25 KB	-r--r--r--
cipher_test.go	6.13 KB	-r--r--r--
client.go	8.58 KB	-r--r--r--
client_auth.go	23.27 KB	-r--r--r--
client_auth_test.go	32.46 KB	-r--r--r--
client_test.go	8.62 KB	-r--r--r--
common.go	13.2 KB	-r--r--r--
common_test.go	3.71 KB	-r--r--r--
connection.go	3.33 KB	-r--r--r--
doc.go	1007 B	-r--r--r--
example_test.go	10.79 KB	-r--r--r--
handshake.go	21.73 KB	-r--r--r--
handshake_test.go	26.84 KB	-r--r--r--
kex.go	22.18 KB	-r--r--r--
kex_test.go	2.45 KB	-r--r--r--
keys.go	44.73 KB	-r--r--r--
keys_test.go	19.62 KB	-r--r--r--
mac.go	1.54 KB	-r--r--r--
mempipe_test.go	2.3 KB	-r--r--r--
messages.go	20.28 KB	-r--r--r--
messages_test.go	6.05 KB	-r--r--r--
mux.go	7.88 KB	-r--r--r--
mux_test.go	18.06 KB	-r--r--r--
server.go	25.93 KB	-r--r--r--
server_test.go	3.33 KB	-r--r--r--
session.go	15.08 KB	-r--r--r--
session_test.go	21.29 KB	-r--r--r--
ssh_gss.go	5.44 KB	-r--r--r--
ssh_gss_test.go	3.23 KB	-r--r--r--
streamlocal.go	2.87 KB	-r--r--r--
tcpip.go	12.84 KB	-r--r--r--
tcpip_test.go	1.45 KB	-r--r--r--
testdata_test.go	2.11 KB	-r--r--r--
transport.go	9.76 KB	-r--r--r--
transport_test.go	2.73 KB	-r--r--r--

Name

Size

Permission

Action

agent

[ DIR ]

dr-xr-xr-x

internal

[ DIR ]

dr-xr-xr-x

knownhosts

[ DIR ]

dr-xr-xr-x

terminal

[ DIR ]

dr-xr-xr-x

test

[ DIR ]

dr-xr-xr-x

testdata

[ DIR ]

dr-xr-xr-x

benchmark_test.go

2.33 KB

-r--r--r--

buffer.go

2.13 KB

-r--r--r--

buffer_test.go

2.17 KB

-r--r--r--

certs.go

17.5 KB

-r--r--r--

certs_test.go

13.67 KB

-r--r--r--

channel.go

16.12 KB

-r--r--r--

cipher.go

21.25 KB

-r--r--r--

cipher_test.go

6.13 KB

-r--r--r--

client.go

8.58 KB

-r--r--r--

client_auth.go

23.27 KB

-r--r--r--

client_auth_test.go

32.46 KB

-r--r--r--

client_test.go

8.62 KB

-r--r--r--

common.go

13.2 KB

-r--r--r--

common_test.go

3.71 KB

-r--r--r--

connection.go

3.33 KB

-r--r--r--

doc.go

1007 B

-r--r--r--

example_test.go

10.79 KB

-r--r--r--

handshake.go

21.73 KB

-r--r--r--

handshake_test.go

26.84 KB

-r--r--r--

kex.go

22.18 KB

-r--r--r--

kex_test.go

2.45 KB

-r--r--r--

keys.go

44.73 KB

-r--r--r--

keys_test.go

19.62 KB

-r--r--r--

mac.go

1.54 KB

-r--r--r--

mempipe_test.go

2.3 KB

-r--r--r--

messages.go

20.28 KB

-r--r--r--

messages_test.go

6.05 KB

-r--r--r--

mux.go

7.88 KB

-r--r--r--

mux_test.go

18.06 KB

-r--r--r--

server.go

25.93 KB

-r--r--r--

server_test.go

3.33 KB

-r--r--r--

session.go

15.08 KB

-r--r--r--

session_test.go

21.29 KB

-r--r--r--

ssh_gss.go

5.44 KB

-r--r--r--

ssh_gss_test.go

3.23 KB

-r--r--r--

streamlocal.go

2.87 KB

-r--r--r--

tcpip.go

12.84 KB

-r--r--r--

tcpip_test.go

1.45 KB

-r--r--r--

testdata_test.go

2.11 KB

-r--r--r--

transport.go

9.76 KB

-r--r--r--

transport_test.go

2.73 KB

-r--r--r--

Code Editor : mempipe_test.go

package ssh

import (
	"io"
	"sync"
	"testing"
)

// An in-memory packetConn. It is safe to call Close and writePacket
// from different goroutines.
type memTransport struct {
	eof        bool
	pending    [][]byte
	write      *memTransport
	writeCount uint64
	sync.Mutex
	*sync.Cond
}

func (t *memTransport) readPacket() ([]byte, error) {
	t.Lock()
	defer t.Unlock()
	for {
		if len(t.pending) > 0 {
			r := t.pending[0]
			t.pending = t.pending[1:]
			return r, nil
		}
		if t.eof {
			return nil, io.EOF
		}
		t.Cond.Wait()
	}
}

func (t *memTransport) closeSelf() error {
	t.Lock()
	defer t.Unlock()
	if t.eof {
		return io.EOF
	}
	t.eof = true
	t.Cond.Broadcast()
	return nil
}

func (t *memTransport) Close() error {
	err := t.write.closeSelf()
	t.closeSelf()
	return err
}

func (t *memTransport) writePacket(p []byte) error {
	t.write.Lock()
	defer t.write.Unlock()
	if t.write.eof {
		return io.EOF
	}
	c := make([]byte, len(p))
	copy(c, p)
	t.write.pending = append(t.write.pending, c)
	t.write.Cond.Signal()
	t.writeCount++
	return nil
}

func (t *memTransport) getWriteCount() uint64 {
	t.write.Lock()
	defer t.write.Unlock()
	return t.writeCount
}

func memPipe() (a, b packetConn) {
	t1 := memTransport{}
	t2 := memTransport{}
	t1.write = &t2
	t2.write = &t1
	t1.Cond = sync.NewCond(&t1.Mutex)
	t2.Cond = sync.NewCond(&t2.Mutex)
	return &t1, &t2
}

func TestMemPipe(t *testing.T) {
	a, b := memPipe()
	if err := a.writePacket([]byte{42}); err != nil {
		t.Fatalf("writePacket: %v", err)
	}
	if wc := a.(*memTransport).getWriteCount(); wc != 1 {
		t.Fatalf("got %v, want 1", wc)
	}
	if err := a.Close(); err != nil {
		t.Fatal("Close: ", err)
	}
	p, err := b.readPacket()
	if err != nil {
		t.Fatal("readPacket: ", err)
	}
	if len(p) != 1 || p[0] != 42 {
		t.Fatalf("got %v, want {42}", p)
	}
	p, err = b.readPacket()
	if err != io.EOF {
		t.Fatalf("got %v, %v, want EOF", p, err)
	}
	if wc := b.(*memTransport).getWriteCount(); wc != 0 {
		t.Fatalf("got %v, want 0", wc)
	}
}

func TestDoubleClose(t *testing.T) {
	a, _ := memPipe()
	err := a.Close()
	if err != nil {
		t.Errorf("Close: %v", err)
	}
	err = a.Close()
	if err != io.EOF {
		t.Errorf("expect EOF on double close.")
	}
}

${this.title}

Code Editor : mempipe_test.go