From bb9a595d25a24a117bc418ba5d71222a03f02714 Mon Sep 17 00:00:00 2001 From: matst80 Date: Tue, 14 Oct 2025 13:43:10 +0200 Subject: [PATCH] log ownership change --- pkg/actor/simple_grain_pool.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/actor/simple_grain_pool.go b/pkg/actor/simple_grain_pool.go index a53fa02..77b53c5 100644 --- a/pkg/actor/simple_grain_pool.go +++ b/pkg/actor/simple_grain_pool.go @@ -115,7 +115,7 @@ func (p *SimpleGrainPool[V]) HandleRemoteExpiry(host string, ids []uint64) error } func (p *SimpleGrainPool[V]) HandleOwnershipChange(host string, ids []uint64) error { - + log.Printf("host %s now owns %d cart ids", host, len(ids)) p.remoteMu.RLock() remoteHost, exists := p.remoteHosts[host] p.remoteMu.RUnlock() @@ -344,7 +344,7 @@ func (p *SimpleGrainPool[V]) broadcastOwnership(ids []uint64) { p.forAllHosts(func(rh Host) { rh.AnnounceOwnership(p.hostname, ids) }) - log.Printf("taking ownership of %d ids", len(ids)) + log.Printf("%s taking ownership of %d ids", p.hostname, len(ids)) // go p.statsUpdate() }