From f68abcdb541f214843006fa175bd2e5d35707d39 Mon Sep 17 00:00:00 2001 From: Neil Alexander Date: Fri, 29 Jan 2021 12:55:12 +0000 Subject: [PATCH] Fixes --- syncapi/streams/stream_pdu.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/syncapi/streams/stream_pdu.go b/syncapi/streams/stream_pdu.go index 7f6b8c409..4bc9d1b14 100644 --- a/syncapi/streams/stream_pdu.go +++ b/syncapi/streams/stream_pdu.go @@ -2,6 +2,7 @@ package streams import ( "context" + "sync" "github.com/matrix-org/dendrite/syncapi/types" userapi "github.com/matrix-org/dendrite/userapi/api" @@ -54,7 +55,7 @@ func (p *PDUStreamProvider) CompleteSync( // Build up a /sync response. Add joined rooms. var reqMutex sync.Mutex var reqWaitGroup sync.WaitGroup - reqWaitGroup.add(len(joinedRooms)) + reqWaitGroup.Add(len(joinedRooms)) for _, roomID := range joinedRoomIDs { go func() { defer reqWaitGroup.Done() @@ -64,7 +65,7 @@ func (p *PDUStreamProvider) CompleteSync( ) if err != nil { req.Log.WithError(err).Error("p.getJoinResponseForCompleteSync failed") - return from + return //from } reqMutex.Lock() defer reqMutex.Unlock()