chnage disconnect for unusable conn, fix logging level

centrifugal · Jan 18, 2023 · ac44fd4 · ac44fd4
1 parent 5dd8d1b
commit ac44fd4
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/broker_redis.go b/broker_redis.go
@@ -702,7 +702,7 @@ func (b *RedisBroker) runPubSub(s *shardWrapper, eventHandler BrokerEventHandler
 	go func() {
 		wg.Wait()
 		if len(channels) > 0 && b.node.LogEnabled(LogLevelDebug) {
-			b.node.Log(NewLogEntry(LogLevelError, "resubscribed to channels", map[string]interface{}{"elapsed": time.Since(started).String(), "numChannels": len(channels)}))
+			b.node.Log(NewLogEntry(LogLevelDebug, "resubscribed to channels", map[string]interface{}{"elapsed": time.Since(started).String(), "numChannels": len(channels)}))
 		}
 		select {
 		case <-done:

diff --git a/client.go b/client.go
@@ -1085,7 +1085,7 @@ func (c *Client) HandleCommand(cmd *protocol.Command, cmdProtocolSize int) bool
 	c.mu.Unlock()
 
 	if unusable {
-		go func() { _ = c.close(DisconnectInsufficientState) }()
+		go func() { _ = c.close(DisconnectBadRequest) }()
 		return false
 	}