| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828 |
- package quic
- import (
- "context"
- "crypto/rand"
- "crypto/tls"
- "errors"
- "fmt"
- "net"
- "sync"
- "sync/atomic"
- "time"
- "github.com/Psiphon-Labs/quic-go/internal/handshake"
- "github.com/Psiphon-Labs/quic-go/internal/protocol"
- "github.com/Psiphon-Labs/quic-go/internal/qerr"
- "github.com/Psiphon-Labs/quic-go/internal/qtls"
- "github.com/Psiphon-Labs/quic-go/internal/utils"
- "github.com/Psiphon-Labs/quic-go/internal/wire"
- "github.com/Psiphon-Labs/quic-go/logging"
- )
- // ErrServerClosed is returned by the Listener or EarlyListener's Accept method after a call to Close.
- var ErrServerClosed = errors.New("quic: Server closed")
- // packetHandler handles packets
- type packetHandler interface {
- handlePacket(*receivedPacket)
- shutdown()
- destroy(error)
- getPerspective() protocol.Perspective
- }
- type unknownPacketHandler interface {
- handlePacket(*receivedPacket)
- setCloseError(error)
- }
- type packetHandlerManager interface {
- AddWithConnID(protocol.ConnectionID, protocol.ConnectionID, func() packetHandler) bool
- Destroy() error
- connRunner
- SetServer(unknownPacketHandler)
- CloseServer()
- }
- type quicConn interface {
- EarlyConnection
- earlyConnReady() <-chan struct{}
- handlePacket(*receivedPacket)
- GetVersion() protocol.VersionNumber
- getPerspective() protocol.Perspective
- run() error
- destroy(error)
- shutdown()
- }
- // A Listener of QUIC
- type baseServer struct {
- mutex sync.Mutex
- acceptEarlyConns bool
- tlsConf *tls.Config
- config *Config
- conn rawConn
- // If the server is started with ListenAddr, we create a packet conn.
- // If it is started with Listen, we take a packet conn as a parameter.
- createdPacketConn bool
- tokenGenerator *handshake.TokenGenerator
- connHandler packetHandlerManager
- receivedPackets chan *receivedPacket
- // set as a member, so they can be set in the tests
- newConn func(
- sendConn,
- connRunner,
- protocol.ConnectionID, /* original dest connection ID */
- *protocol.ConnectionID, /* retry src connection ID */
- protocol.ConnectionID, /* client dest connection ID */
- protocol.ConnectionID, /* destination connection ID */
- protocol.ConnectionID, /* source connection ID */
- protocol.StatelessResetToken,
- *Config,
- *tls.Config,
- *handshake.TokenGenerator,
- bool, /* client address validated by an address validation token */
- logging.ConnectionTracer,
- uint64,
- utils.Logger,
- protocol.VersionNumber,
- ) quicConn
- serverError error
- errorChan chan struct{}
- closed bool
- running chan struct{} // closed as soon as run() returns
- connQueue chan quicConn
- connQueueLen int32 // to be used as an atomic
- logger utils.Logger
- }
- var (
- _ Listener = &baseServer{}
- _ unknownPacketHandler = &baseServer{}
- )
- type earlyServer struct{ *baseServer }
- var _ EarlyListener = &earlyServer{}
- func (s *earlyServer) Accept(ctx context.Context) (EarlyConnection, error) {
- return s.baseServer.accept(ctx)
- }
- // ListenAddr creates a QUIC server listening on a given address.
- // The tls.Config must not be nil and must contain a certificate configuration.
- // The quic.Config may be nil, in that case the default values will be used.
- func ListenAddr(addr string, tlsConf *tls.Config, config *Config) (Listener, error) {
- return listenAddr(addr, tlsConf, config, false)
- }
- // ListenAddrEarly works like ListenAddr, but it returns connections before the handshake completes.
- func ListenAddrEarly(addr string, tlsConf *tls.Config, config *Config) (EarlyListener, error) {
- s, err := listenAddr(addr, tlsConf, config, true)
- if err != nil {
- return nil, err
- }
- return &earlyServer{s}, nil
- }
- func listenAddr(addr string, tlsConf *tls.Config, config *Config, acceptEarly bool) (*baseServer, error) {
- udpAddr, err := net.ResolveUDPAddr("udp", addr)
- if err != nil {
- return nil, err
- }
- conn, err := net.ListenUDP("udp", udpAddr)
- if err != nil {
- return nil, err
- }
- serv, err := listen(conn, tlsConf, config, acceptEarly)
- if err != nil {
- return nil, err
- }
- serv.createdPacketConn = true
- return serv, nil
- }
- // Listen listens for QUIC connections on a given net.PacketConn. If the
- // PacketConn satisfies the OOBCapablePacketConn interface (as a net.UDPConn
- // does), ECN and packet info support will be enabled. In this case, ReadMsgUDP
- // and WriteMsgUDP will be used instead of ReadFrom and WriteTo to read/write
- // packets. A single net.PacketConn only be used for a single call to Listen.
- // The PacketConn can be used for simultaneous calls to Dial. QUIC connection
- // IDs are used for demultiplexing the different connections. The tls.Config
- // must not be nil and must contain a certificate configuration. The
- // tls.Config.CipherSuites allows setting of TLS 1.3 cipher suites. Furthermore,
- // it must define an application control (using NextProtos). The quic.Config may
- // be nil, in that case the default values will be used.
- func Listen(conn net.PacketConn, tlsConf *tls.Config, config *Config) (Listener, error) {
- return listen(conn, tlsConf, config, false)
- }
- // ListenEarly works like Listen, but it returns connections before the handshake completes.
- func ListenEarly(conn net.PacketConn, tlsConf *tls.Config, config *Config) (EarlyListener, error) {
- s, err := listen(conn, tlsConf, config, true)
- if err != nil {
- return nil, err
- }
- return &earlyServer{s}, nil
- }
- func listen(conn net.PacketConn, tlsConf *tls.Config, config *Config, acceptEarly bool) (*baseServer, error) {
- if tlsConf == nil {
- return nil, errors.New("quic: tls.Config not set")
- }
- if err := validateConfig(config); err != nil {
- return nil, err
- }
- config = populateServerConfig(config)
- for _, v := range config.Versions {
- if !protocol.IsValidVersion(v) {
- return nil, fmt.Errorf("%s is not a valid QUIC version", v)
- }
- }
- connHandler, err := getMultiplexer().AddConn(conn, config.ConnectionIDGenerator.ConnectionIDLen(), config.StatelessResetKey, config.Tracer)
- if err != nil {
- return nil, err
- }
- tokenGenerator, err := handshake.NewTokenGenerator(rand.Reader)
- if err != nil {
- return nil, err
- }
- c, err := wrapConn(conn)
- if err != nil {
- return nil, err
- }
- s := &baseServer{
- conn: c,
- tlsConf: tlsConf,
- config: config,
- tokenGenerator: tokenGenerator,
- connHandler: connHandler,
- connQueue: make(chan quicConn),
- errorChan: make(chan struct{}),
- running: make(chan struct{}),
- receivedPackets: make(chan *receivedPacket, protocol.MaxServerUnprocessedPackets),
- newConn: newConnection,
- logger: utils.DefaultLogger.WithPrefix("server"),
- acceptEarlyConns: acceptEarly,
- }
- go s.run()
- connHandler.SetServer(s)
- s.logger.Debugf("Listening for %s connections on %s", conn.LocalAddr().Network(), conn.LocalAddr().String())
- return s, nil
- }
- func (s *baseServer) run() {
- defer close(s.running)
- for {
- select {
- case <-s.errorChan:
- return
- default:
- }
- select {
- case <-s.errorChan:
- return
- case p := <-s.receivedPackets:
- if bufferStillInUse := s.handlePacketImpl(p); !bufferStillInUse {
- p.buffer.Release()
- }
- }
- }
- }
- // Accept returns connections that already completed the handshake.
- // It is only valid if acceptEarlyConns is false.
- func (s *baseServer) Accept(ctx context.Context) (Connection, error) {
- return s.accept(ctx)
- }
- func (s *baseServer) accept(ctx context.Context) (quicConn, error) {
- select {
- case <-ctx.Done():
- return nil, ctx.Err()
- case conn := <-s.connQueue:
- atomic.AddInt32(&s.connQueueLen, -1)
- return conn, nil
- case <-s.errorChan:
- return nil, s.serverError
- }
- }
- // Close the server
- func (s *baseServer) Close() error {
- s.mutex.Lock()
- if s.closed {
- s.mutex.Unlock()
- return nil
- }
- if s.serverError == nil {
- s.serverError = ErrServerClosed
- }
- // If the server was started with ListenAddr, we created the packet conn.
- // We need to close it in order to make the go routine reading from that conn return.
- createdPacketConn := s.createdPacketConn
- s.closed = true
- close(s.errorChan)
- s.mutex.Unlock()
- <-s.running
- s.connHandler.CloseServer()
- if createdPacketConn {
- return s.connHandler.Destroy()
- }
- return nil
- }
- func (s *baseServer) setCloseError(e error) {
- s.mutex.Lock()
- defer s.mutex.Unlock()
- if s.closed {
- return
- }
- s.closed = true
- s.serverError = e
- close(s.errorChan)
- }
- // Addr returns the server's network address
- func (s *baseServer) Addr() net.Addr {
- return s.conn.LocalAddr()
- }
- func (s *baseServer) handlePacket(p *receivedPacket) {
- select {
- case s.receivedPackets <- p:
- default:
- s.logger.Debugf("Dropping packet from %s (%d bytes). Server receive queue full.", p.remoteAddr, p.Size())
- if s.config.Tracer != nil {
- s.config.Tracer.DroppedPacket(p.remoteAddr, logging.PacketTypeNotDetermined, p.Size(), logging.PacketDropDOSPrevention)
- }
- }
- }
- func (s *baseServer) handlePacketImpl(p *receivedPacket) bool /* is the buffer still in use? */ {
- if wire.IsVersionNegotiationPacket(p.data) {
- s.logger.Debugf("Dropping Version Negotiation packet.")
- if s.config.Tracer != nil {
- s.config.Tracer.DroppedPacket(p.remoteAddr, logging.PacketTypeVersionNegotiation, p.Size(), logging.PacketDropUnexpectedPacket)
- }
- return false
- }
- // Short header packets should never end up here in the first place
- if !wire.IsLongHeaderPacket(p.data[0]) {
- panic(fmt.Sprintf("misrouted packet: %#v", p.data))
- }
- v, err := wire.ParseVersion(p.data)
- // send a Version Negotiation Packet if the client is speaking a different protocol version
- if err != nil || !protocol.IsSupportedVersion(s.config.Versions, v) {
- if err != nil || p.Size() < protocol.MinUnknownVersionPacketSize {
- s.logger.Debugf("Dropping a packet with an unknown version that is too small (%d bytes)", p.Size())
- if s.config.Tracer != nil {
- s.config.Tracer.DroppedPacket(p.remoteAddr, logging.PacketTypeNotDetermined, p.Size(), logging.PacketDropUnexpectedPacket)
- }
- return false
- }
- _, src, dest, err := wire.ParseArbitraryLenConnectionIDs(p.data)
- if err != nil { // should never happen
- s.logger.Debugf("Dropping a packet with an unknown version for which we failed to parse connection IDs")
- if s.config.Tracer != nil {
- s.config.Tracer.DroppedPacket(p.remoteAddr, logging.PacketTypeNotDetermined, p.Size(), logging.PacketDropUnexpectedPacket)
- }
- return false
- }
- if !s.config.DisableVersionNegotiationPackets {
- go s.sendVersionNegotiationPacket(p.remoteAddr, src, dest, p.info.OOB())
- }
- return false
- }
- // If we're creating a new connection, the packet will be passed to the connection.
- // The header will then be parsed again.
- hdr, _, _, err := wire.ParsePacket(p.data)
- if err != nil {
- if s.config.Tracer != nil {
- s.config.Tracer.DroppedPacket(p.remoteAddr, logging.PacketTypeNotDetermined, p.Size(), logging.PacketDropHeaderParseError)
- }
- s.logger.Debugf("Error parsing packet: %s", err)
- return false
- }
- // [Psiphon]
- // To accomodate additional messages, obfuscated QUIC packets may reserve
- // significant space in the Initial packet and send less that 1200 QUIC
- // bytes. In this configuration, the obfuscation layer enforces the
- // anti-amplification 1200 byte rule, but it must be disabled here.
- isObfuscated := s.config.ServerMaxPacketSizeAdjustment != nil && s.config.ServerMaxPacketSizeAdjustment(p.remoteAddr) > 0
- if !isObfuscated &&
- hdr.Type == protocol.PacketTypeInitial && p.Size() < protocol.MinInitialPacketSize {
- s.logger.Debugf("Dropping a packet that is too small to be a valid Initial (%d bytes)", p.Size())
- if s.config.Tracer != nil {
- s.config.Tracer.DroppedPacket(p.remoteAddr, logging.PacketTypeInitial, p.Size(), logging.PacketDropUnexpectedPacket)
- }
- return false
- }
- if hdr.Type != protocol.PacketTypeInitial {
- // Drop long header packets.
- // There's little point in sending a Stateless Reset, since the client
- // might not have received the token yet.
- s.logger.Debugf("Dropping long header packet of type %s (%d bytes)", hdr.Type, len(p.data))
- if s.config.Tracer != nil {
- s.config.Tracer.DroppedPacket(p.remoteAddr, logging.PacketTypeFromHeader(hdr), p.Size(), logging.PacketDropUnexpectedPacket)
- }
- return false
- }
- s.logger.Debugf("<- Received Initial packet.")
- if err := s.handleInitialImpl(p, hdr); err != nil {
- s.logger.Errorf("Error occurred handling initial packet: %s", err)
- }
- // Don't put the packet buffer back.
- // handleInitialImpl deals with the buffer.
- return true
- }
- // [Psiphon]
- type stubCryptoSetup struct {
- initialOpener handshake.LongHeaderOpener
- }
- var notSupported = errors.New("not supported")
- func (s *stubCryptoSetup) RunHandshake() {
- }
- func (s *stubCryptoSetup) Close() error {
- return notSupported
- }
- func (s *stubCryptoSetup) ChangeConnectionID(protocol.ConnectionID) {
- }
- func (s *stubCryptoSetup) GetSessionTicket() ([]byte, error) {
- return nil, notSupported
- }
- func (s *stubCryptoSetup) HandleMessage([]byte, protocol.EncryptionLevel) bool {
- return false
- }
- func (s *stubCryptoSetup) SetLargest1RTTAcked(protocol.PacketNumber) error {
- return notSupported
- }
- func (s *stubCryptoSetup) SetHandshakeConfirmed() {
- }
- func (s *stubCryptoSetup) ConnectionState() handshake.ConnectionState {
- return handshake.ConnectionState{}
- }
- func (s *stubCryptoSetup) GetInitialOpener() (handshake.LongHeaderOpener, error) {
- return s.initialOpener, nil
- }
- func (s *stubCryptoSetup) GetHandshakeOpener() (handshake.LongHeaderOpener, error) {
- return nil, notSupported
- }
- func (s *stubCryptoSetup) Get0RTTOpener() (handshake.LongHeaderOpener, error) {
- return nil, notSupported
- }
- func (s *stubCryptoSetup) Get1RTTOpener() (handshake.ShortHeaderOpener, error) {
- return nil, notSupported
- }
- func (s *stubCryptoSetup) GetInitialSealer() (handshake.LongHeaderSealer, error) {
- return nil, notSupported
- }
- func (s *stubCryptoSetup) GetHandshakeSealer() (handshake.LongHeaderSealer, error) {
- return nil, notSupported
- }
- func (s *stubCryptoSetup) Get0RTTSealer() (handshake.LongHeaderSealer, error) {
- return nil, notSupported
- }
- func (s *stubCryptoSetup) Get1RTTSealer() (handshake.ShortHeaderSealer, error) {
- return nil, notSupported
- }
- // [Psiphon]
- // verifyClientHelloRandom unpacks an Initial packet, extracts the CRYPTO
- // frame, and calls Config.VerifyClientHelloRandom.
- func (s *baseServer) verifyClientHelloRandom(p *receivedPacket, hdr *wire.Header) error {
- // TODO: support QUICv2
- versionNumber := protocol.Version1
- _, initialOpener := handshake.NewInitialAEAD(
- hdr.DestConnectionID, protocol.PerspectiveServer, versionNumber)
- cs := &stubCryptoSetup{
- initialOpener: initialOpener,
- }
- // Make a copy of the packet data since this unpacking modifies it and the
- // original packet data must be retained for subsequent processing.
- data := append([]byte(nil), p.data...)
- unpacker := newPacketUnpacker(cs, 0)
- unpacked, err := unpacker.UnpackLongHeader(hdr, p.rcvTime, data, versionNumber)
- if err != nil {
- return fmt.Errorf("verifyClientHelloRandom: UnpackLongHeader: %w", err)
- }
- parser := wire.NewFrameParser(s.config.EnableDatagrams)
- d := unpacked.data
- for len(d) > 0 {
- l, frame, err := parser.ParseNext(d, protocol.EncryptionInitial, versionNumber)
- if err != nil {
- return fmt.Errorf("verifyClientHelloRandom: ParseNext: %w", err)
- }
- if frame == nil {
- return errors.New("verifyClientHelloRandom: missing CRYPTO frame")
- }
- d = d[l:]
- cryptoFrame, ok := frame.(*wire.CryptoFrame)
- if !ok {
- continue
- }
- if cryptoFrame.Offset != 0 {
- return errors.New("verifyClientHelloRandom: unexpected CRYPTO frame offset")
- }
- random, err := qtls.ReadClientHelloRandom(cryptoFrame.Data)
- if err != nil {
- return fmt.Errorf("verifyClientHelloRandom: ReadClientHelloRandom: %w", err)
- }
- if !s.config.VerifyClientHelloRandom(p.remoteAddr, random) {
- return fmt.Errorf("verifyClientHelloRandom: VerifyClientHelloRandom failed")
- }
- break
- }
- return nil
- }
- // validateToken returns false if:
- // - address is invalid
- // - token is expired
- // - token is null
- func (s *baseServer) validateToken(token *handshake.Token, addr net.Addr) bool {
- if token == nil {
- return false
- }
- if !token.ValidateRemoteAddr(addr) {
- return false
- }
- if !token.IsRetryToken && time.Since(token.SentTime) > s.config.MaxTokenAge {
- return false
- }
- if token.IsRetryToken && time.Since(token.SentTime) > s.config.MaxRetryTokenAge {
- return false
- }
- return true
- }
- func (s *baseServer) handleInitialImpl(p *receivedPacket, hdr *wire.Header) error {
- if len(hdr.Token) == 0 && hdr.DestConnectionID.Len() < protocol.MinConnectionIDLenInitial {
- p.buffer.Release()
- if s.config.Tracer != nil {
- s.config.Tracer.DroppedPacket(p.remoteAddr, logging.PacketTypeInitial, p.Size(), logging.PacketDropUnexpectedPacket)
- }
- return errors.New("too short connection ID")
- }
- // [Psiphon]
- // Drop any Initial packet that fails verifyClientHelloRandom.
- if s.config.VerifyClientHelloRandom != nil {
- err := s.verifyClientHelloRandom(p, hdr)
- if err != nil {
- p.buffer.Release()
- return err
- }
- }
- var (
- token *handshake.Token
- retrySrcConnID *protocol.ConnectionID
- )
- origDestConnID := hdr.DestConnectionID
- if len(hdr.Token) > 0 {
- tok, err := s.tokenGenerator.DecodeToken(hdr.Token)
- if err == nil {
- if tok.IsRetryToken {
- origDestConnID = tok.OriginalDestConnectionID
- retrySrcConnID = &tok.RetrySrcConnectionID
- }
- token = tok
- }
- }
- clientAddrIsValid := s.validateToken(token, p.remoteAddr)
- if token != nil && !clientAddrIsValid {
- // For invalid and expired non-retry tokens, we don't send an INVALID_TOKEN error.
- // We just ignore them, and act as if there was no token on this packet at all.
- // This also means we might send a Retry later.
- if !token.IsRetryToken {
- token = nil
- } else {
- // For Retry tokens, we send an INVALID_ERROR if
- // * the token is too old, or
- // * the token is invalid, in case of a retry token.
- go func() {
- defer p.buffer.Release()
- if err := s.maybeSendInvalidToken(p, hdr); err != nil {
- s.logger.Debugf("Error sending INVALID_TOKEN error: %s", err)
- }
- }()
- return nil
- }
- }
- if token == nil && s.config.RequireAddressValidation(p.remoteAddr) {
- go func() {
- defer p.buffer.Release()
- if err := s.sendRetry(p.remoteAddr, hdr, p.info); err != nil {
- s.logger.Debugf("Error sending Retry: %s", err)
- }
- }()
- return nil
- }
- if queueLen := atomic.LoadInt32(&s.connQueueLen); queueLen >= protocol.MaxAcceptQueueSize {
- s.logger.Debugf("Rejecting new connection. Server currently busy. Accept queue length: %d (max %d)", queueLen, protocol.MaxAcceptQueueSize)
- go func() {
- defer p.buffer.Release()
- if err := s.sendConnectionRefused(p.remoteAddr, hdr, p.info); err != nil {
- s.logger.Debugf("Error rejecting connection: %s", err)
- }
- }()
- return nil
- }
- connID, err := s.config.ConnectionIDGenerator.GenerateConnectionID()
- if err != nil {
- return err
- }
- s.logger.Debugf("Changing connection ID to %s.", connID)
- var conn quicConn
- tracingID := nextConnTracingID()
- if added := s.connHandler.AddWithConnID(hdr.DestConnectionID, connID, func() packetHandler {
- var tracer logging.ConnectionTracer
- if s.config.Tracer != nil {
- // Use the same connection ID that is passed to the client's GetLogWriter callback.
- connID := hdr.DestConnectionID
- if origDestConnID.Len() > 0 {
- connID = origDestConnID
- }
- tracer = s.config.Tracer.TracerForConnection(
- context.WithValue(context.Background(), ConnectionTracingKey, tracingID),
- protocol.PerspectiveServer,
- connID,
- )
- }
- conn = s.newConn(
- newSendConn(s.conn, p.remoteAddr, p.info),
- s.connHandler,
- origDestConnID,
- retrySrcConnID,
- hdr.DestConnectionID,
- hdr.SrcConnectionID,
- connID,
- s.connHandler.GetStatelessResetToken(connID),
- s.config,
- s.tlsConf,
- s.tokenGenerator,
- clientAddrIsValid,
- tracer,
- tracingID,
- s.logger,
- hdr.Version,
- )
- conn.handlePacket(p)
- return conn
- }); !added {
- return nil
- }
- go conn.run()
- go s.handleNewConn(conn)
- if conn == nil {
- p.buffer.Release()
- return nil
- }
- return nil
- }
- func (s *baseServer) handleNewConn(conn quicConn) {
- connCtx := conn.Context()
- if s.acceptEarlyConns {
- // wait until the early connection is ready (or the handshake fails)
- select {
- case <-conn.earlyConnReady():
- case <-connCtx.Done():
- return
- }
- } else {
- // wait until the handshake is complete (or fails)
- select {
- case <-conn.HandshakeComplete().Done():
- case <-connCtx.Done():
- return
- }
- }
- atomic.AddInt32(&s.connQueueLen, 1)
- select {
- case s.connQueue <- conn:
- // blocks until the connection is accepted
- case <-connCtx.Done():
- atomic.AddInt32(&s.connQueueLen, -1)
- // don't pass connections that were already closed to Accept()
- }
- }
- func (s *baseServer) sendRetry(remoteAddr net.Addr, hdr *wire.Header, info *packetInfo) error {
- // Log the Initial packet now.
- // If no Retry is sent, the packet will be logged by the connection.
- (&wire.ExtendedHeader{Header: *hdr}).Log(s.logger)
- srcConnID, err := s.config.ConnectionIDGenerator.GenerateConnectionID()
- if err != nil {
- return err
- }
- token, err := s.tokenGenerator.NewRetryToken(remoteAddr, hdr.DestConnectionID, srcConnID)
- if err != nil {
- return err
- }
- replyHdr := &wire.ExtendedHeader{}
- replyHdr.Type = protocol.PacketTypeRetry
- replyHdr.Version = hdr.Version
- replyHdr.SrcConnectionID = srcConnID
- replyHdr.DestConnectionID = hdr.SrcConnectionID
- replyHdr.Token = token
- if s.logger.Debug() {
- s.logger.Debugf("Changing connection ID to %s.", srcConnID)
- s.logger.Debugf("-> Sending Retry")
- replyHdr.Log(s.logger)
- }
- buf := getPacketBuffer()
- defer buf.Release()
- buf.Data, err = replyHdr.Append(buf.Data, hdr.Version)
- if err != nil {
- return err
- }
- // append the Retry integrity tag
- tag := handshake.GetRetryIntegrityTag(buf.Data, hdr.DestConnectionID, hdr.Version)
- buf.Data = append(buf.Data, tag[:]...)
- if s.config.Tracer != nil {
- s.config.Tracer.SentPacket(remoteAddr, &replyHdr.Header, protocol.ByteCount(len(buf.Data)), nil)
- }
- _, err = s.conn.WritePacket(buf.Data, remoteAddr, info.OOB())
- return err
- }
- func (s *baseServer) maybeSendInvalidToken(p *receivedPacket, hdr *wire.Header) error {
- // Only send INVALID_TOKEN if we can unprotect the packet.
- // This makes sure that we won't send it for packets that were corrupted.
- sealer, opener := handshake.NewInitialAEAD(hdr.DestConnectionID, protocol.PerspectiveServer, hdr.Version)
- data := p.data[:hdr.ParsedLen()+hdr.Length]
- extHdr, err := unpackLongHeader(opener, hdr, data, hdr.Version)
- if err != nil {
- if s.config.Tracer != nil {
- s.config.Tracer.DroppedPacket(p.remoteAddr, logging.PacketTypeInitial, p.Size(), logging.PacketDropHeaderParseError)
- }
- // don't return the error here. Just drop the packet.
- return nil
- }
- hdrLen := extHdr.ParsedLen()
- if _, err := opener.Open(data[hdrLen:hdrLen], data[hdrLen:], extHdr.PacketNumber, data[:hdrLen]); err != nil {
- // don't return the error here. Just drop the packet.
- if s.config.Tracer != nil {
- s.config.Tracer.DroppedPacket(p.remoteAddr, logging.PacketTypeInitial, p.Size(), logging.PacketDropPayloadDecryptError)
- }
- return nil
- }
- if s.logger.Debug() {
- s.logger.Debugf("Client sent an invalid retry token. Sending INVALID_TOKEN to %s.", p.remoteAddr)
- }
- return s.sendError(p.remoteAddr, hdr, sealer, qerr.InvalidToken, p.info)
- }
- func (s *baseServer) sendConnectionRefused(remoteAddr net.Addr, hdr *wire.Header, info *packetInfo) error {
- sealer, _ := handshake.NewInitialAEAD(hdr.DestConnectionID, protocol.PerspectiveServer, hdr.Version)
- return s.sendError(remoteAddr, hdr, sealer, qerr.ConnectionRefused, info)
- }
- // sendError sends the error as a response to the packet received with header hdr
- func (s *baseServer) sendError(remoteAddr net.Addr, hdr *wire.Header, sealer handshake.LongHeaderSealer, errorCode qerr.TransportErrorCode, info *packetInfo) error {
- b := getPacketBuffer()
- defer b.Release()
- ccf := &wire.ConnectionCloseFrame{ErrorCode: uint64(errorCode)}
- replyHdr := &wire.ExtendedHeader{}
- replyHdr.Type = protocol.PacketTypeInitial
- replyHdr.Version = hdr.Version
- replyHdr.SrcConnectionID = hdr.DestConnectionID
- replyHdr.DestConnectionID = hdr.SrcConnectionID
- replyHdr.PacketNumberLen = protocol.PacketNumberLen4
- replyHdr.Length = 4 /* packet number len */ + ccf.Length(hdr.Version) + protocol.ByteCount(sealer.Overhead())
- var err error
- b.Data, err = replyHdr.Append(b.Data, hdr.Version)
- if err != nil {
- return err
- }
- payloadOffset := len(b.Data)
- b.Data, err = ccf.Append(b.Data, hdr.Version)
- if err != nil {
- return err
- }
- _ = sealer.Seal(b.Data[payloadOffset:payloadOffset], b.Data[payloadOffset:], replyHdr.PacketNumber, b.Data[:payloadOffset])
- b.Data = b.Data[0 : len(b.Data)+sealer.Overhead()]
- pnOffset := payloadOffset - int(replyHdr.PacketNumberLen)
- sealer.EncryptHeader(
- b.Data[pnOffset+4:pnOffset+4+16],
- &b.Data[0],
- b.Data[pnOffset:payloadOffset],
- )
- replyHdr.Log(s.logger)
- wire.LogFrame(s.logger, ccf, true)
- if s.config.Tracer != nil {
- s.config.Tracer.SentPacket(remoteAddr, &replyHdr.Header, protocol.ByteCount(len(b.Data)), []logging.Frame{ccf})
- }
- _, err = s.conn.WritePacket(b.Data, remoteAddr, info.OOB())
- return err
- }
- func (s *baseServer) sendVersionNegotiationPacket(remote net.Addr, src, dest protocol.ArbitraryLenConnectionID, oob []byte) {
- s.logger.Debugf("Client offered version %s, sending Version Negotiation")
- data := wire.ComposeVersionNegotiation(dest, src, s.config.Versions)
- if s.config.Tracer != nil {
- s.config.Tracer.SentVersionNegotiationPacket(remote, src, dest, s.config.Versions)
- }
- if _, err := s.conn.WritePacket(data, remote, oob); err != nil {
- s.logger.Debugf("Error sending Version Negotiation: %s", err)
- }
- }
|