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 : benchmark_test.go

package ssh

import (
	"errors"
	"fmt"
	"io"
	"net"
	"testing"
)

type server struct {
	*ServerConn
	chans <-chan NewChannel
}

func newServer(c net.Conn, conf *ServerConfig) (*server, error) {
	sconn, chans, reqs, err := NewServerConn(c, conf)
	if err != nil {
		return nil, err
	}
	go DiscardRequests(reqs)
	return &server{sconn, chans}, nil
}

func (s *server) Accept() (NewChannel, error) {
	n, ok := <-s.chans
	if !ok {
		return nil, io.EOF
	}
	return n, nil
}

func sshPipe() (Conn, *server, error) {
	c1, c2, err := netPipe()
	if err != nil {
		return nil, nil, err
	}

clientConf := ClientConfig{
		User:            "user",
		HostKeyCallback: InsecureIgnoreHostKey(),
	}
	serverConf := ServerConfig{
		NoClientAuth: true,
	}
	serverConf.AddHostKey(testSigners["ecdsa"])
	done := make(chan *server, 1)
	go func() {
		server, err := newServer(c2, &serverConf)
		if err != nil {
			done <- nil
		}
		done <- server
	}()

client, _, reqs, err := NewClientConn(c1, "", &clientConf)
	if err != nil {
		return nil, nil, err
	}

server := <-done
	if server == nil {
		return nil, nil, errors.New("server handshake failed.")
	}
	go DiscardRequests(reqs)

return client, server, nil
}

func BenchmarkEndToEnd(b *testing.B) {
	b.StopTimer()

client, server, err := sshPipe()
	if err != nil {
		b.Fatalf("sshPipe: %v", err)
	}

defer client.Close()
	defer server.Close()

size := (1 << 20)
	input := make([]byte, size)
	output := make([]byte, size)
	b.SetBytes(int64(size))
	done := make(chan int, 1)

go func() {
		newCh, err := server.Accept()
		if err != nil {
			panic(fmt.Sprintf("Client: %v", err))
		}
		ch, incoming, err := newCh.Accept()
		if err != nil {
			panic(fmt.Sprintf("Accept: %v", err))
		}
		go DiscardRequests(incoming)
		for i := 0; i < b.N; i++ {
			if _, err := io.ReadFull(ch, output); err != nil {
				panic(fmt.Sprintf("ReadFull: %v", err))
			}
		}
		ch.Close()
		done <- 1
	}()

ch, in, err := client.OpenChannel("speed", nil)
	if err != nil {
		b.Fatalf("OpenChannel: %v", err)
	}
	go DiscardRequests(in)

b.ResetTimer()
	b.StartTimer()
	for i := 0; i < b.N; i++ {
		if _, err := ch.Write(input); err != nil {
			b.Fatalf("WriteFull: %v", err)
		}
	}
	ch.Close()
	b.StopTimer()

<-done
}

${this.title}

Code Editor : benchmark_test.go