Method handleChannels

internal/sshserver/serverImpl.go:784–821

(
	authenticatedMetadata metadata.ConnectionAuthenticatedMetadata,
	channels <-chan ssh.NewChannel,
	connection SSHConnectionHandler,
	logger log.Logger,
)

}

func (s *serverImpl) handleChannels(
	authenticatedMetadata metadata.ConnectionAuthenticatedMetadata,
	channels <-chan ssh.NewChannel,
	connection SSHConnectionHandler,
	logger log.Logger,
) {
	for {
		newChannel, ok := <-channels
		if !ok {
			break
		}
		s.lock.Lock()
		channelID := s.nextChannelID
		s.nextChannelID++
		s.lock.Unlock()
		logger = logger.WithLabel("channelId", channelID)
		switch newChannel.ChannelType() {
		case ChannelTypeSession:
			go s.handleSessionChannel(authenticatedMetadata.Channel(channelID), newChannel, connection, logger)
		case ChannelTypeDirectTCPIP:
			go s.handleDirectForwardingChannel(authenticatedMetadata.Channel(channelID), newChannel, connection, logger)
		case ChannelTypeDirectStreamLocal:
			go s.handleDirectStreamLocalChannel(authenticatedMetadata.Channel(channelID), newChannel, connection, logger)
		default:
			logger.Debug(
				messageCodes.NewMessage(
					messageCodes.ESSHUnsupportedChannelType,
					"Unsupported channel type requested",
				).Label("type", newChannel.ChannelType()),
			)
			connection.OnUnsupportedChannel(channelID, newChannel.ChannelType(), newChannel.ExtraData())
			if err := newChannel.Reject(ssh.UnknownChannelType, "unsupported channel type"); err != nil {
				logger.Debug("failed to send channel rejection for channel type %s", newChannel.ChannelType())
			}
			continue
		}
	}
}

func (s *serverImpl) handleSessionChannel(
	channelMetadata metadata.ChannelMetadata,