diff --git a/network/message/handler.go b/network/message/handler.go index a72dece83b97ddaf4c63acd561fdefc9b06477af..bc47864d7232f5528d520e2633e63d500645a397 100644 --- a/network/message/handler.go +++ b/network/message/handler.go @@ -72,9 +72,9 @@ func (m *Manager) handleMessage(ecrMsg format.Message, bundle Bundle, edge *edge identity.Source, expectedFP, ecrMsg.GetIdentityFP()) } im := fmt.Sprintf("Garbled/RAW Message: keyFP: %v, round: %d"+ - "msgDigest: %s, not determined to be for client", msg.GetKeyFP(), bundle.Round, msg.Digest()) + "msgDigest: %s, not determined to be for client", ecrMsg.GetKeyFP(), bundle.Round, ecrMsg.Digest()) m.Internal.Events.Report(1, "MessageReception", "Garbled", im) - m.Session.GetGarbledMessages().Add(msg) + m.Session.GetGarbledMessages().Add(ecrMsg) return } diff --git a/storage/utility/meteredCmixMessageBuffer.go b/storage/utility/meteredCmixMessageBuffer.go index ed1920ff42f2cf0f122549584ef11d480d43ebbb..9060dbb7ea2424f87879032371ee25944ff64851 100644 --- a/storage/utility/meteredCmixMessageBuffer.go +++ b/storage/utility/meteredCmixMessageBuffer.go @@ -114,6 +114,10 @@ func LoadMeteredCmixMessageBuffer(kv *versioned.KV, key string) (*MeteredCmixMes } func (mcmb *MeteredCmixMessageBuffer) Add(m format.Message) { + if m.GetPrimeByteLen()==0{ + jww.FATAL.Panicf("Cannot handle a metered " + + "cmix message with a length of 0") + } msg := meteredCmixMessage{ M: m.Marshal(), Count: 0,