Method handleSessionChannel

internal/sshserver/serverImpl.go:823–875

(
	channelMetadata metadata.ChannelMetadata,
	newChannel ssh.NewChannel,
	connection SSHConnectionHandler,
	logger log.Logger,
)

}

func (s *serverImpl) handleSessionChannel(
	channelMetadata metadata.ChannelMetadata,
	newChannel ssh.NewChannel,
	connection SSHConnectionHandler,
	logger log.Logger,
) {
	channelCallbacks := &channelWrapper{
		logger: logger,
		lock:   &sync.Mutex{},
	}
	handlerChannel, rejection := connection.OnSessionChannel(channelMetadata, newChannel.ExtraData(), channelCallbacks)
	if rejection != nil {
		logger.Debug(
			messageCodes.Wrap(
				rejection,
				messageCodes.MSSHNewChannelRejected,
				"New SSH channel rejected",
			).Label("type", newChannel.ChannelType()),
		)

		if err := newChannel.Reject(rejection.Reason(), rejection.UserMessage()); err != nil {
			logger.Debug(messageCodes.Wrap(err, messageCodes.ESSHReplyFailed, "Failed to send reply to channel request"))
		}
		return
	}
	shutdownHandlerID := fmt.Sprintf(
		"session-%s-%d",
		channelMetadata.Connection.ConnectionID,
		channelMetadata.ChannelID,
	)
	s.shutdownHandlers.Register(shutdownHandlerID, handlerChannel)
	channel, requests, err := newChannel.Accept()
	if err != nil {
		logger.Debug(messageCodes.Wrap(err, messageCodes.ESSHReplyFailed, "failed to accept session channel"))
		s.shutdownHandlers.Unregister(shutdownHandlerID)
		return
	}
	logger.Debug(messageCodes.NewMessage(messageCodes.MSSHNewChannel, "New SSH channel").Label("type", newChannel.ChannelType()))
	channelCallbacks.channel = channel
	nextRequestID := uint64(0)
	for {
		request, ok := <-requests
		if !ok {
			s.shutdownHandlers.Unregister(shutdownHandlerID)
			channelCallbacks.onClose()
			handlerChannel.OnClose()
			break
		}
		requestID := nextRequestID
		nextRequestID++
		s.handleChannelRequest(channelMetadata, requestID, request, handlerChannel, logger)
	}
}

func serveConnection(log log.Logger, dst io.WriteCloser, src io.ReadCloser) {
	_, err := io.Copy(dst, src)