From 4bd75311fb421df1fa727c88cae9bd5ac724bb0f Mon Sep 17 00:00:00 2001 From: David Robertson Date: Tue, 25 Jul 2023 18:50:09 +0100 Subject: [PATCH] todo marker --- sync3/handler/handler.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/sync3/handler/handler.go b/sync3/handler/handler.go index c02c5a29..c0cb8d2f 100644 --- a/sync3/handler/handler.go +++ b/sync3/handler/handler.go @@ -622,7 +622,13 @@ func (h *SyncLiveHandler) Accumulate(p *pubsub.V2Accumulate) { func (h *SyncLiveHandler) OnTransactionID(p *pubsub.V2TransactionID) { _, task := internal.StartTask(context.Background(), "TransactionID") defer task.End() - // TODO implement me + + // There is some event E for which we now have a transaction ID, or else now know + // that we will never get a transaction ID. In either case, tell the sender's + // connections to unblock that event in the transaction ID waiter. + + // TODO implement me. Something like + // h.ConnMap.ClearUpdateQueues(p.UserID, p.RoomID, p.NID) } // Called from the v2 poller, implements V2DataReceiver