mirrors
/
blocky
mirror of https://github.com/0xERR0R/blocky.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

new pointers

This commit is contained in:
Kwitsch 2024-04-22 19:57:57 +00:00
parent f8093f30d8
commit 61c83af493
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
redis/redis.go
View File

@ -244,15 +244,15 @@ func (c *Client) processReceivedMessage(ctx context.Context, msg *redis.Message)
util.CtxSend(ctx, c.CacheChannel, &cm)
case messageTypeEnable:
var msg EnabledMessage
msg := new(EnabledMessage)
if err := json.Unmarshal(rm.Message, &msg); err != nil {
if err := json.Unmarshal(rm.Message, msg); err != nil {
c.l.Error("Processing EnabledMessage error: ", err)
return
}
util.CtxSend(ctx, c.EnabledChannel, &msg)
util.CtxSend(ctx, c.EnabledChannel, msg)
default:
c.l.Warn("Unknown message type: ", rm.Type)
}
@ -292,7 +292,7 @@ func convertMessage[T util.TTLInput](ttl T, key string, message []byte) (CacheEn
return res, packErr
}
var msg *dns.Msg
msg := new(dns.Msg)
if err := msg.Unpack(message); err != nil {
return res, packErr
}