diff --git a/cmix/message/handler.go b/cmix/message/handler.go index d8cd687f8ccc49941b13bac2fb1aba0810758206..9c6080761c54a9a29fb1cbfd20d5cf7f3d32a436 100644 --- a/cmix/message/handler.go +++ b/cmix/message/handler.go @@ -9,13 +9,14 @@ package message import ( "fmt" - "gitlab.com/elixxir/client/event" - "gitlab.com/elixxir/client/storage/versioned" - "gitlab.com/xx_network/primitives/id" "strconv" "sync" "time" + "gitlab.com/elixxir/client/event" + "gitlab.com/elixxir/client/storage/versioned" + "gitlab.com/xx_network/primitives/id" + jww "github.com/spf13/jwalterweatherman" "gitlab.com/elixxir/client/stoppable" "gitlab.com/elixxir/primitives/format" @@ -191,7 +192,7 @@ func (h *handler) handleMessageHelper(ecrMsg format.Message, bundle Bundle) bool return true } - im := fmt.Sprintf("Message cannot be identify: keyFP: %v, round: %d "+ + im := fmt.Sprintf("Message cannot be identified: keyFP: %v, round: %d "+ "msgDigest: %s, not determined to be for client", ecrMsg.GetKeyFP(), bundle.Round, ecrMsg.Digest()) jww.TRACE.Printf(im) diff --git a/cmix/message/meteredCmixMessageBuffer.go b/cmix/message/meteredCmixMessageBuffer.go index 3b43838105dda925bd135f192eeefc9dc34faff1..0bc82450812e8e993f43e63c61a658df48a27cc4 100644 --- a/cmix/message/meteredCmixMessageBuffer.go +++ b/cmix/message/meteredCmixMessageBuffer.go @@ -9,6 +9,8 @@ package message import ( "encoding/json" + "time" + "github.com/pkg/errors" jww "github.com/spf13/jwalterweatherman" "gitlab.com/elixxir/client/cmix/identity/receptionID" @@ -20,7 +22,6 @@ import ( "gitlab.com/xx_network/primitives/netTime" "golang.org/x/crypto/blake2b" "google.golang.org/protobuf/proto" - "time" ) const currentMeteredCmixMessageVersion = 0 @@ -145,6 +146,8 @@ func (mcmb *MeteredCmixMessageBuffer) Add(m format.Message, ri *pb.RoundInfo, jww.FATAL.Panic( "Cannot handle a metered cMix message with a length of 0.") } + jww.TRACE.Printf("Metered Messages Add(MsgDigest: %s)", + m.Digest()) msg := buildMsg(m, ri, identity) addedMsgFace := mcmb.mb.Add(msg) diff --git a/storage/utility/messageBuffer.go b/storage/utility/messageBuffer.go index f661e73ca3daed2070079501fc1db73567840862..4e5a5d32fb1f6695965cd97d1d28a64512eb0ba0 100644 --- a/storage/utility/messageBuffer.go +++ b/storage/utility/messageBuffer.go @@ -10,11 +10,12 @@ package utility import ( "encoding/base64" "encoding/json" + "sync" + jww "github.com/spf13/jwalterweatherman" "gitlab.com/elixxir/client/storage/versioned" "gitlab.com/elixxir/primitives/format" "gitlab.com/xx_network/primitives/netTime" - "sync" ) // MessageHash stores the hash of a message, which is used as the key for each @@ -198,6 +199,8 @@ func (mb *MessageBuffer) load() error { // Add adds a message to the buffer in "not processing" state. func (mb *MessageBuffer) Add(m interface{}) interface{} { h := mb.handler.HashMessage(m) + jww.TRACE.Printf("Critical Messages Add(%s)", + base64.StdEncoding.EncodeToString(h[:])) mb.mux.Lock() defer mb.mux.Unlock()