From acf5b95646df8b51775a17672a23107860fd7d93 Mon Sep 17 00:00:00 2001 From: mcrakhman Date: Mon, 5 Dec 2022 17:21:14 +0100 Subject: [PATCH] Fix notifiable when creating sync tree --- common/commonspace/space.go | 2 +- common/commonspace/synctree/synctree.go | 6 ++++++ 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/common/commonspace/space.go b/common/commonspace/space.go index a1ce64b0..4c654e17 100644 --- a/common/commonspace/space.go +++ b/common/commonspace/space.go @@ -108,7 +108,7 @@ func (s *space) LastUsage() time.Time { } func (s *space) Locked() bool { - log.With(zap.Bool("locked", s.treesUsed.Load() > 1)).Debug("space lock status check") + log.With(zap.Int32("trees used", s.treesUsed.Load())).Debug("space lock status check") return s.treesUsed.Load() > 1 } diff --git a/common/commonspace/synctree/synctree.go b/common/commonspace/synctree/synctree.go index 69fe04a4..c6461c8a 100644 --- a/common/commonspace/synctree/synctree.go +++ b/common/commonspace/synctree/synctree.go @@ -100,6 +100,9 @@ func DeriveSyncTree(ctx context.Context, deps CreateDeps) (t SyncTree, err error syncTree.listener.Rebuild(syncTree) } syncTree.treeUsage.Add(1) + if syncTree.notifiable != nil { + syncTree.notifiable.UpdateHeads(objTree.ID(), objTree.Heads()) + } headUpdate := syncClient.CreateHeadUpdate(t, nil) err = syncClient.BroadcastAsync(headUpdate) @@ -133,6 +136,9 @@ func CreateSyncTree(ctx context.Context, deps CreateDeps) (t SyncTree, err error syncTree.listener.Rebuild(syncTree) } syncTree.treeUsage.Add(1) + if syncTree.notifiable != nil { + syncTree.notifiable.UpdateHeads(objTree.ID(), objTree.Heads()) + } headUpdate := syncClient.CreateHeadUpdate(t, nil) err = syncClient.BroadcastAsync(headUpdate)