mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-26 08:13:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Setup tweaks

Browse source
This commit is contained in:
Neil Alexander 2021-02-01 13:59:33 +00:00
parent d64d859c96
commit 3f750a4fc2
No known key found for this signature in database
GPG key ID: A02A2019A2BB0944
1 changed files with 12 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
build/gobind-pinecone/monolith.go
View file

@ -8,6 +8,7 @@ import (
"encoding/hex"
"encoding/json"
"fmt"
"io"
"io/ioutil"
"log"
"net"
@ -100,14 +101,23 @@ func (m *DendriteMonolith) DisconnectMulticastPeers() {
func (m *DendriteMonolith) Conduit(zone string) (*Conduit, error) {
l, r := net.Pipe()
go func() {
loop:
for i := 1; i <= 10; i++ {
logrus.Errorf("Attempting authenticated connect (attempt %d)", i)
p, err := m.PineconeRouter.AuthenticatedConnect(l, zone)
if err == nil {
switch err {
case io.ErrClosedPipe:
logrus.Errorf("Authenticated connect failed due to closed pipe (attempt %d)", i)
return
case io.EOF:
logrus.Errorf("Authenticated connect failed due to EOF (attempt %d)", i)
break loop
case nil:
logrus.Errorf("Authenticated connect succeeded, connected to port %d (attempt %d)", p, i)
return
default:
logrus.WithError(err).Errorf("Authenticated connect failed (attempt %d)", i)
}
logrus.WithError(err).Errorf("Authenticated connect failed (attempt %d)", i)
}
_ = l.Close()
_ = r.Close()