mirror of
https://github.com/octoleo/syncthing.git
synced 2024-11-10 15:20:56 +00:00
83 lines
2.1 KiB
Go
83 lines
2.1 KiB
Go
// Copyright (C) 2019 The Syncthing Authors.
|
|
//
|
|
// This Source Code Form is subject to the terms of the Mozilla Public
|
|
// License, v. 2.0. If a copy of the MPL was not distributed with this file,
|
|
// You can obtain one at http://mozilla.org/MPL/2.0/.
|
|
|
|
// +build go1.14,!noquic,!go1.17
|
|
|
|
package connections
|
|
|
|
import (
|
|
"crypto/tls"
|
|
"net"
|
|
"net/url"
|
|
|
|
"github.com/lucas-clemente/quic-go"
|
|
"github.com/syncthing/syncthing/lib/util"
|
|
)
|
|
|
|
var (
|
|
quicConfig = &quic.Config{
|
|
ConnectionIDLength: 4,
|
|
KeepAlive: true,
|
|
}
|
|
)
|
|
|
|
func quicNetwork(uri *url.URL) string {
|
|
switch uri.Scheme {
|
|
case "quic4":
|
|
return "udp4"
|
|
case "quic6":
|
|
return "udp6"
|
|
default:
|
|
return "udp"
|
|
}
|
|
}
|
|
|
|
type quicTlsConn struct {
|
|
quic.Session
|
|
quic.Stream
|
|
// If we created this connection, we should be the ones closing it.
|
|
createdConn net.PacketConn
|
|
}
|
|
|
|
func (q *quicTlsConn) Close() error {
|
|
sterr := q.Stream.Close()
|
|
seerr := q.Session.CloseWithError(0, "closing")
|
|
var pcerr error
|
|
if q.createdConn != nil {
|
|
pcerr = q.createdConn.Close()
|
|
}
|
|
if sterr != nil {
|
|
return sterr
|
|
}
|
|
if seerr != nil {
|
|
return seerr
|
|
}
|
|
return pcerr
|
|
}
|
|
|
|
func (q *quicTlsConn) ConnectionState() tls.ConnectionState {
|
|
qcs := q.Session.ConnectionState()
|
|
return tls.ConnectionState{
|
|
Version: qcs.Version,
|
|
HandshakeComplete: qcs.HandshakeComplete,
|
|
DidResume: qcs.DidResume,
|
|
CipherSuite: qcs.CipherSuite,
|
|
NegotiatedProtocol: qcs.NegotiatedProtocol,
|
|
NegotiatedProtocolIsMutual: qcs.NegotiatedProtocolIsMutual,
|
|
ServerName: qcs.ServerName,
|
|
PeerCertificates: qcs.PeerCertificates,
|
|
VerifiedChains: qcs.VerifiedChains,
|
|
SignedCertificateTimestamps: qcs.SignedCertificateTimestamps,
|
|
OCSPResponse: qcs.OCSPResponse,
|
|
TLSUnique: qcs.TLSUnique,
|
|
}
|
|
}
|
|
|
|
// Sort available packet connections by ip address, preferring unspecified local address.
|
|
func packetConnLess(i interface{}, j interface{}) bool {
|
|
return util.AddressUnspecifiedLess(i.(net.PacketConn).LocalAddr(), j.(net.PacketConn).LocalAddr())
|
|
}
|