mirrors/uquic
1
0
Fork 0
mirror of https://github.com/refraction-networking/uquic.git synced 2025-04-05 21:27:35 +03:00
Code Issues Projects Releases Packages Wiki Activity

Export http3.Server.Port.

Browse source
This commit is contained in:
Aaron Riekenberg 2021-09-18 10:29:37 -05:00
parent 8b56e7d2b5
commit 43ee0c6757
1 changed files with 7 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

10
http3/server.go
View file

@ -92,7 +92,11 @@ type Server struct {
// See https://www.ietf.org/archive/id/draft-schinazi-masque-h3-datagram-02.html. // See https://www.ietf.org/archive/id/draft-schinazi-masque-h3-datagram-02.html.
EnableDatagrams bool EnableDatagrams bool
port uint32 // used atomically // The port to use in Alt-Svc response headers.
// If needed Port can be manually set when the Server is created.
// This is useful when a Layer 4 firewall is redirecting UDP traffic and clients must use
// a port different from the port the Server is listening on.
Port uint32
mutex sync.Mutex mutex sync.Mutex
listeners map[*quic.EarlyListener]struct{} listeners map[*quic.EarlyListener]struct{}
@ -436,7 +440,7 @@ func (s *Server) CloseGracefully(timeout time.Duration) error {
// The values that are set depend on the port information from s.Server.Addr, and currently look like this (if Addr has port 443): // The values that are set depend on the port information from s.Server.Addr, and currently look like this (if Addr has port 443):
// Alt-Svc: quic=":443"; ma=2592000; v="33,32,31,30" // Alt-Svc: quic=":443"; ma=2592000; v="33,32,31,30"
func (s *Server) SetQuicHeaders(hdr http.Header) error { func (s *Server) SetQuicHeaders(hdr http.Header) error {
port := atomic.LoadUint32(&s.port) port := atomic.LoadUint32(&s.Port)
if port == 0 { if port == 0 {
// Extract port from s.Server.Addr // Extract port from s.Server.Addr
@ -449,7 +453,7 @@ func (s *Server) SetQuicHeaders(hdr http.Header) error {
return err return err
} }
port = uint32(portInt) port = uint32(portInt)
atomic.StoreUint32(&s.port, port) atomic.StoreUint32(&s.Port, port)
} }
// This code assumes that we will use protocol.SupportedVersions if no quic.Config is passed. // This code assumes that we will use protocol.SupportedVersions if no quic.Config is passed.