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

Add notes

Browse source
This commit is contained in:
Kegan Dougal 2017-04-07 17:08:59 +01:00
parent 465ddc2204
commit ad5328c453
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/github.com/matrix-org/dendrite/clientapi/sync/requestpool.go
View file

@ -74,7 +74,6 @@ func (rp *RequestPool) OnIncomingSyncRequest(req *http.Request) util.JSONRespons
"userID": userID, "userID": userID,
"since": since, "since": since,
"timeout": timeout, "timeout": timeout,
"current": rp.currPos,
}).Info("Incoming /sync request") }).Info("Incoming /sync request")
// Set up a timer based on the provided timeout value. // Set up a timer based on the provided timeout value.
@ -94,6 +93,9 @@ func (rp *RequestPool) OnIncomingSyncRequest(req *http.Request) util.JSONRespons
} }
}() }()
// TODO: Spawn off a 3rd goroutine to do this work so we can simply race
// with the timeout to determine what to return to the client.
res, err := rp.currentSyncForUser(syncReq) res, err := rp.currentSyncForUser(syncReq)
close(done) // signal that the work is complete close(done) // signal that the work is complete
if err != nil { if err != nil {