diff options
| author | Jakob Borg <jakob@kastelo.net> | 2023-04-28 09:14:50 +0200 |
|---|---|---|
| committer | Jakob Borg <jakob@kastelo.net> | 2023-04-28 09:14:50 +0200 |
| commit | 134df290a33379b3155ffb821fdfa4a1345ca01a (patch) | |
| tree | bba1a84d77c39e9dbc685ee9fe774e364c72201e | |
| parent | 020cfe395a23db0cf0aa51a35d2506b788530daa (diff) | |
wip
| -rw-r--r-- | lib/connections/quic_listen.go | 1 | ||||
| -rw-r--r-- | lib/protocol/protocol.go | 6 |
2 files changed, 4 insertions, 3 deletions
diff --git a/lib/connections/quic_listen.go b/lib/connections/quic_listen.go index 18723fcd4b..4146ebd1c0 100644 --- a/lib/connections/quic_listen.go +++ b/lib/connections/quic_listen.go @@ -97,6 +97,7 @@ func (t *quicListener) serve(ctx context.Context) error { } defer func() { _ = udpConn.Close() }() + // XXX: HAX TO BE REVERTED // svc, conn := stun.New(t.cfg, t, udpConn) // defer conn.Close() diff --git a/lib/protocol/protocol.go b/lib/protocol/protocol.go index 6912d281d5..e865792de7 100644 --- a/lib/protocol/protocol.go +++ b/lib/protocol/protocol.go @@ -272,8 +272,8 @@ func newRawConnection(deviceID DeviceID, stream netutil.Stream, receiver Model, receiver: receiver, stream: cs, awaiting: make(map[int]chan asyncResult), - inbox: make(chan streamMessage, 1), - outbox: make(chan asyncMessage, 1), + inbox: make(chan streamMessage), + outbox: make(chan asyncMessage), closeBox: make(chan asyncMessage), clusterConfigBox: make(chan *ClusterConfig), dispatcherLoopStopped: make(chan struct{}), @@ -436,7 +436,7 @@ func (c *rawConnection) streamForRequest(ctx context.Context) chan asyncMessage } func (c *rawConnection) registerNewSubstream(strm io.ReadWriteCloser) chan asyncMessage { - outbox := make(chan asyncMessage, 1) + outbox := make(chan asyncMessage) c.substreams = append(c.substreams, outbox) go c.substreamReaderLoop(strm, outbox) go c.substreamWriterLoop(strm, outbox) |