mats/go-cart-actor
1
0
Fork 0
Code Issues Pull Requests 1 Actions 3 Packages Projects Releases Wiki Activity

log ownership change
All checks were successful
Build and Publish / Metadata (push) Successful in 9s
Details
Build and Publish / BuildAndDeployAmd64 (push) Successful in 1m20s
Details
Build and Publish / BuildAndDeployArm64 (push) Successful in 4m3s
Details

Browse Source
This commit is contained in:
matst80
2025-10-14 13:43:10 +02:00
parent de62b0664d
commit bb9a595d25
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/actor/simple_grain_pool.go
View File

@@ -115,7 +115,7 @@ func (p *SimpleGrainPool[V]) HandleRemoteExpiry(host string, ids []uint64) error
} }
func (p *SimpleGrainPool[V]) HandleOwnershipChange(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() p.remoteMu.RLock()
remoteHost, exists := p.remoteHosts[host] remoteHost, exists := p.remoteHosts[host]
p.remoteMu.RUnlock() p.remoteMu.RUnlock()
@@ -344,7 +344,7 @@ func (p *SimpleGrainPool[V]) broadcastOwnership(ids []uint64) {
p.forAllHosts(func(rh Host) { p.forAllHosts(func(rh Host) {
rh.AnnounceOwnership(p.hostname, ids) 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() // go p.statsUpdate()
} }