Method start

cmd/run/socket/proxy.go:138–177

()

}

func (p *proxy) start() {
	if p.process == nil || p.external == nil {
		slog.Error("TCP proxy missing connection", "proxy", p)
		return
	}

	// TODO: should we match the tracee's TCP options on the external side?

	// There's no need for Nagle's algorithm on the process side since it's a
	// loopback connection.
	if err := p.process.SetNoDelay(true); err != nil {
		slog.Debug("failed to set TCP_NODELAY on process side", "proxy", p, "err", err) // not fatal
	}

	slog.Debug("starting tcp proxy", "proxy", p)
	defer func() {
		if err := p.Close(); err != nil {
			slog.Debug("failed close tcp proxy", "proxy", p, "err", err) // not fatal
		}
	}()

	cli, srv := newBufConn(p.process), newBufConn(p.external)
	if !p.isOutgoing {
		cli, srv = srv, cli
	}

	if err := p.proxyOptimistic(cli, srv); err != nil {
		slog.Error("failed to run tcp proxy", "proxy", p, "err", err)
	}

	if p.skipCloseTCP.CompareAndSwap(false, true) {
		// The target program has still not called the close(2) syscall on its file
		// descriptor. When it does, the (*Socket).Close() handler will close the
		// two underlying TCP connections. See the equivalent CAS in socket.go for
		// the process.Close() and external.Close() calls.
	} else {
		p.process.Close()
		p.external.Close()
	}
}

var isHTTP2Enabled = true
var isWebsocketEnabled = false