From ab7e654f7c23ff36f74cee37740b82e0d0dda1e2 Mon Sep 17 00:00:00 2001 From: Peter Stuifzand Date: Wed, 3 Oct 2018 18:41:46 +0200 Subject: [PATCH] Move refreshChannels to own method --- cmd/eksterd/memory.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/cmd/eksterd/memory.go b/cmd/eksterd/memory.go index 1777087..ebe542a 100644 --- a/cmd/eksterd/memory.go +++ b/cmd/eksterd/memory.go @@ -108,12 +108,15 @@ func (b *memoryBackend) load() error { return err } + return nil +} + +func (b *memoryBackend) refreshChannels() { conn := pool.Get() defer conn.Close() - conn.Do("SETNX", "channel_sortorder_notifications", 1) - conn.Do("DEL", "channels") + conn.Do("SETNX", "channel_sortorder_notifications", 1) b.lock.RLock() defer b.lock.RUnlock() @@ -123,8 +126,6 @@ func (b *memoryBackend) load() error { conn.Do("SADD", "channels", uid) conn.Do("SETNX", "channel_sortorder_"+uid, 99999) } - - return nil } func (b *memoryBackend) save() { @@ -145,6 +146,7 @@ func loadMemoryBackend() microsub.Microsub { log.Printf("Error while loadingbackend: %v\n", err) return nil } + backend.refreshChannels() return backend }