octoleo/syncthing
1
0
Fork 0
mirror of https://github.com/octoleo/syncthing.git synced 2025-01-09 09:50:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

debug

Browse Source
This commit is contained in:
Jakob Borg 2021-11-22 08:58:34 +01:00
parent a9c9fb1a2f
commit 842934347d
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/connections/connections_test.go
View File

@ -446,6 +446,7 @@ func withConnectionPair(b interface{ Fatal(...interface{}) }, connUri string, h
}
natSvc := nat.NewService(deviceId, wcfg)
conns := make(chan internalConn, 1)
fmt.Println("listening", uri)
listenSvc := lf.New(uri, wcfg, tlsCfg, conns, natSvc)
supervisor.Add(listenSvc)
@ -468,7 +469,9 @@ func withConnectionPair(b interface{ Fatal(...interface{}) }, connUri string, h
dialer := df.New(cfg.Options, tlsCfg)
// Relays might take some time to register the device, so dial multiple times
fmt.Println("dialing", addr)
clientConn, err := dialer.Dial(ctx, deviceId, addr)
fmt.Println("clientConn", clientConn.LocalAddr(), "->", clientConn.RemoteAddr())
if err != nil {
for i := 0; i < 10 && err != nil; i++ {
clientConn, err = dialer.Dial(ctx, deviceId, addr)
@ -487,6 +490,7 @@ func withConnectionPair(b interface{ Fatal(...interface{}) }, connUri string, h
}
serverConn := <-conns
fmt.Println("serverConn", serverConn.LocalAddr(), "->", serverConn.RemoteAddr())
recv := make([]byte, len(send))
if _, err := io.ReadFull(serverConn, recv); err != nil {
@ -502,7 +506,7 @@ func withConnectionPair(b interface{ Fatal(...interface{}) }, connUri string, h
_ = serverConn.Close()
}
func mustGetCert(b *testing.B) tls.Certificate {
func mustGetCert(b interface{ Fatal(...interface{}) }) tls.Certificate {
cert, err := tlsutil.NewCertificateInMemory("bench", 10)
if err != nil {
b.Fatal(err)