transport

package
v0.0.0-...-b4b96de Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 24, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const SO_ORIGINAL_DST = 80

Variables

This section is empty.

Functions

func HandleConnection

func HandleConnection(
	logger *log.Logger,
	conn *net.TCPConn,
	ec *estabcache.EstablishedCache,
	tracingContextMapping *cache.Cache,
	routingInfoContextMapping *cache.Cache,
	statsdMetrics *statsd.Client,
)

func TcpCopyRequest

func TcpCopyRequest(
	logger *log.Logger,
	r *net.TCPConn,
	w *net.TCPConn,
	connCh chan *net.TCPConn,
	netRequest protocol.NetRequest,
	netHandler protocol.NetHandler,
	isInBoundConn bool,
	f *os.File,
	addrCh chan string,
	originalDst string,
)

func TcpCopyResponse

func TcpCopyResponse(
	logger *log.Logger,
	r *net.TCPConn,
	w *net.TCPConn,
	netRequest protocol.NetRequest,
	netHandler protocol.NetHandler,
	isInBoundConn bool,
	f *os.File,
)

Types

type MutexQueue

type MutexQueue struct {
	// contains filtered or unexported fields
}

func NewMutexQueue

func NewMutexQueue() *MutexQueue

MutexQueue implements mutex queue with FIFO support

func (*MutexQueue) Lock

func (mq *MutexQueue) Lock()

func (*MutexQueue) Unlock

func (mq *MutexQueue) Unlock()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL