From 5025d4112879dbba1d0e1ee2caa26d55fadef1be Mon Sep 17 00:00:00 2001 From: mountain Date: Mon, 20 Nov 2023 16:09:58 +0900 Subject: [PATCH] =?UTF-8?q?totalCCUWriter=20=EC=A0=9C=EA=B1=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- core/tavern.go | 8 -------- 1 file changed, 8 deletions(-) diff --git a/core/tavern.go b/core/tavern.go index d922ff5..9e92fa6 100644 --- a/core/tavern.go +++ b/core/tavern.go @@ -7,7 +7,6 @@ import ( "net" "net/http" "strings" - "sync/atomic" "time" "github.com/go-redis/redis/v8" @@ -15,7 +14,6 @@ import ( "repositories.action2quare.com/ayo/gocommon" "repositories.action2quare.com/ayo/gocommon/flagx" "repositories.action2quare.com/ayo/gocommon/logger" - "repositories.action2quare.com/ayo/gocommon/metric" "repositories.action2quare.com/ayo/gocommon/session" "repositories.action2quare.com/ayo/gocommon/wshandler" @@ -23,8 +21,6 @@ import ( ) var devflag = flagx.Bool("dev", false, "") -var totalCCUWriter = metric.NewMetric(metric.MetricGuage, "concurrent_user", "current connected user count") -var ccu = int64(0) type TavernConfig struct { session.SessionConfig `json:",inline"` @@ -83,7 +79,6 @@ func New(context context.Context, wsh *wshandler.WebsocketHandler) (*Tavern, err } func (tv *Tavern) Cleanup() { - totalCCUWriter(0) tv.mongoClient.Close() } @@ -141,7 +136,6 @@ func (tv *Tavern) LeaveChannel(ctx wshandler.ApiCallContext) { } func (tv *Tavern) ClientConnected(conn *websocket.Conn, callby *wshandler.Sender) { - totalCCUWriter(float64(atomic.AddInt64(&ccu, 1))) tv.redison.Del(tv.redison.Context(), callby.Accid.Hex()) _, err := tv.redison.JSONSet(callby.Accid.Hex(), "$", bson.M{"_ts": time.Now().UTC().Unix()}) if err != nil { @@ -150,8 +144,6 @@ func (tv *Tavern) ClientConnected(conn *websocket.Conn, callby *wshandler.Sender } func (tv *Tavern) ClientDisconnected(msg string, callby *wshandler.Sender) { - totalCCUWriter(float64(atomic.AddInt64(&ccu, -1))) - tv.redison.Del(tv.redison.Context(), callby.Accid.Hex()).Result() }