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--

Code Editor : connection.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.

package ssh

import (
	"fmt"
	"net"
)

// OpenChannelError is returned if the other side rejects an
// OpenChannel request.
type OpenChannelError struct {
	Reason  RejectionReason
	Message string
}

func (e *OpenChannelError) Error() string {
	return fmt.Sprintf("ssh: rejected: %s (%s)", e.Reason, e.Message)
}

// ConnMetadata holds metadata for the connection.
type ConnMetadata interface {
	// User returns the user ID for this connection.
	User() string

// SessionID returns the session hash, also denoted by H.
	SessionID() []byte

// ClientVersion returns the client's version string as hashed
	// into the session ID.
	ClientVersion() []byte

// ServerVersion returns the server's version string as hashed
	// into the session ID.
	ServerVersion() []byte

// RemoteAddr returns the remote address for this connection.
	RemoteAddr() net.Addr

// LocalAddr returns the local address for this connection.
	LocalAddr() net.Addr
}

// Conn represents an SSH connection for both server and client roles.
// Conn is the basis for implementing an application layer, such
// as ClientConn, which implements the traditional shell access for
// clients.
type Conn interface {
	ConnMetadata

// SendRequest sends a global request, and returns the
	// reply. If wantReply is true, it returns the response status
	// and payload. See also RFC 4254, section 4.
	SendRequest(name string, wantReply bool, payload []byte) (bool, []byte, error)

// OpenChannel tries to open an channel. If the request is
	// rejected, it returns *OpenChannelError. On success it returns
	// the SSH Channel and a Go channel for incoming, out-of-band
	// requests. The Go channel must be serviced, or the
	// connection will hang.
	OpenChannel(name string, data []byte) (Channel, <-chan *Request, error)

// Close closes the underlying network connection
	Close() error

// Wait blocks until the connection has shut down, and returns the
	// error causing the shutdown.
	Wait() error

// TODO(hanwen): consider exposing:
	//   RequestKeyChange
	//   Disconnect
}

// DiscardRequests consumes and rejects all requests from the
// passed-in channel.
func DiscardRequests(in <-chan *Request) {
	for req := range in {
		if req.WantReply {
			req.Reply(false, nil)
		}
	}
}

// A connection represents an incoming connection.
type connection struct {
	transport *handshakeTransport
	sshConn

// The connection protocol.
	*mux
}

func (c *connection) Close() error {
	return c.sshConn.conn.Close()
}

// sshConn provides net.Conn metadata, but disallows direct reads and
// writes.
type sshConn struct {
	conn net.Conn

user          string
	sessionID     []byte
	clientVersion []byte
	serverVersion []byte
}

func dup(src []byte) []byte {
	dst := make([]byte, len(src))
	copy(dst, src)
	return dst
}

func (c *sshConn) User() string {
	return c.user
}

func (c *sshConn) RemoteAddr() net.Addr {
	return c.conn.RemoteAddr()
}

func (c *sshConn) Close() error {
	return c.conn.Close()
}

func (c *sshConn) LocalAddr() net.Addr {
	return c.conn.LocalAddr()
}

func (c *sshConn) SessionID() []byte {
	return dup(c.sessionID)
}

func (c *sshConn) ClientVersion() []byte {
	return dup(c.clientVersion)
}

func (c *sshConn) ServerVersion() []byte {
	return dup(c.serverVersion)
}

${this.title}

Code Editor : connection.go