From 13d1549f8470cbefbab6aa029defb52c7ada8096 Mon Sep 17 00:00:00 2001 From: Andrew Gouin Date: Wed, 31 Jan 2024 20:52:06 -0700 Subject: [PATCH] nil safety --- relayer/processor/types_internal.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/relayer/processor/types_internal.go b/relayer/processor/types_internal.go index 9bc972be2..f18cfccfc 100644 --- a/relayer/processor/types_internal.go +++ b/relayer/processor/types_internal.go @@ -381,6 +381,9 @@ func (c *packetMessageSendCache) set(sequence uint64) { func (c packetChannelMessageCache) deleteMessages(toDelete ...map[string][]uint64) { for _, toDeleteMap := range toDelete { for message, toDeleteMessages := range toDeleteMap { + if _, ok := c[message]; !ok { + continue + } c[message].mu.Lock() for _, sequence := range toDeleteMessages { delete(c[message].m, sequence) @@ -417,6 +420,9 @@ func (c *channelKeySendCache) set(key ChannelKey) { func (c channelProcessingCache) deleteMessages(toDelete ...map[string][]ChannelKey) { for _, toDeleteMap := range toDelete { for message, toDeleteMessages := range toDeleteMap { + if _, ok := c[message]; !ok { + continue + } c[message].mu.Lock() for _, channel := range toDeleteMessages { delete(c[message].m, channel) @@ -453,6 +459,9 @@ func (c *connectionKeySendCache) set(key ConnectionKey) { func (c connectionProcessingCache) deleteMessages(toDelete ...map[string][]ConnectionKey) { for _, toDeleteMap := range toDelete { for message, toDeleteMessages := range toDeleteMap { + if _, ok := c[message]; !ok { + continue + } c[message].mu.Lock() for _, connection := range toDeleteMessages { delete(c[message].m, connection)