From 8811127eae98209dca4006660338a29372242b48 Mon Sep 17 00:00:00 2001 From: Henry Date: Thu, 22 Apr 2021 19:58:35 +0200 Subject: [PATCH] disable debugging logger --- roomstate/roomstate.go | 35 +---------------------------------- 1 file changed, 1 insertion(+), 34 deletions(-) diff --git a/roomstate/roomstate.go b/roomstate/roomstate.go index 8388632..cb4bb9f 100644 --- a/roomstate/roomstate.go +++ b/roomstate/roomstate.go @@ -4,14 +4,12 @@ import ( "context" "sort" "sync" - "time" kitlog "github.com/go-kit/kit/log" - "github.com/go-kit/kit/log/level" "go.cryptoscope.co/muxrpc/v2" - refs "go.mindeco.de/ssb-refs" "github.com/ssb-ngi-pointer/go-ssb-room/internal/broadcasts" + refs "go.mindeco.de/ssb-refs" ) type Manager struct { @@ -31,40 +29,9 @@ func NewManager(ctx context.Context, log kitlog.Logger) *Manager { m.roomMu = new(sync.Mutex) m.room = make(roomStateMap) - go m.stateTicker(ctx) - return &m } -func (m *Manager) stateTicker(ctx context.Context) { - tick := time.NewTicker(10 * time.Second) - last := 0 - for { - select { - case <-ctx.Done(): - tick.Stop() - return - - case <-tick.C: - } - m.roomMu.Lock() - - cnt := len(m.room) - if cnt == last { - m.roomMu.Unlock() - continue - } - last = cnt - - level.Info(m.logger).Log("room-cnt", cnt) - for who := range m.room { - level.Info(m.logger).Log("feed", who[1:5]) - } - - m.roomMu.Unlock() - } -} - // roomStateMap is a single room type roomStateMap map[string]muxrpc.Endpoint