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)