diff --git a/socketserver/server/commands.go b/socketserver/server/commands.go index 86b1649a..efef59c2 100644 --- a/socketserver/server/commands.go +++ b/socketserver/server/commands.go @@ -435,7 +435,7 @@ func C2SHandleBunchedCommand(conn *websocket.Conn, client *ClientInfo, msg Clien key := fmt.Sprintf("%s:%s", msg.Command, msg.origArguments) resultCh := bunchGroup.DoChan(key, func() (interface{}, error) { - return Backend.SendRemoteCommandCached(msg.Command, msg.origArguments, AuthInfo{}) + return Backend.SendRemoteCommandCached(string(msg.Command), msg.origArguments, AuthInfo{}) }) client.MsgChannelKeepalive.Add(1) diff --git a/socketserver/server/handlecore.go b/socketserver/server/handlecore.go index f87e61e8..99f26459 100644 --- a/socketserver/server/handlecore.go +++ b/socketserver/server/handlecore.go @@ -133,7 +133,6 @@ func startJanitors() { go authorizationJanitor() go aggregateDataSender() - go bunchCacheJanitor() go cachedMessageJanitor() go commandCounter() go pubsubJanitor()