func()

in src/sessionmanagerplugin/session/portsession/basicportforwarding.go [144:164]

• 19 lines of code
• 4 McCabe index (conditional complexity)

func (p *BasicPortForwarding) startLocalListener(log log.T, portNumber string) (listener net.Listener, err error) {
	var displayMessage string
	switch p.portParameters.LocalConnectionType {
	case "unix":
		if listener, err = getNewListener(p.portParameters.LocalConnectionType, p.portParameters.LocalUnixSocket); err != nil {
			return
		}
		displayMessage = fmt.Sprintf("Unix socket %s opened for sessionId %s.", p.portParameters.LocalUnixSocket, p.sessionId)
	default:
		if listener, err = getNewListener("tcp", "localhost:"+portNumber); err != nil {
			return
		}
		// get port number the TCP listener opened
		p.portParameters.LocalPortNumber = strconv.Itoa(listener.Addr().(*net.TCPAddr).Port)
		displayMessage = fmt.Sprintf("Port %s opened for sessionId %s.", p.portParameters.LocalPortNumber, p.sessionId)
	}

	log.Info(displayMessage)
	fmt.Println(displayMessage)
	return
}