@@ -12,6 +12,8 @@ import (
1212 "google.golang.org/protobuf/types/known/anypb"
1313
1414 "github.com/obolnetwork/charon/app/errors"
15+ "github.com/obolnetwork/charon/app/log"
16+ "github.com/obolnetwork/charon/app/z"
1517 "github.com/obolnetwork/charon/core"
1618 pbv1 "github.com/obolnetwork/charon/core/corepb/v1"
1719 "github.com/obolnetwork/charon/core/qbft"
@@ -141,6 +143,12 @@ func (t *transport) Broadcast(ctx context.Context, typ qbft.MsgType, duty core.D
141143 }
142144 }()
143145
146+ log .Debug (ctx , "QBFT broadcasting msg" ,
147+ z .Str ("duty" , duty .String ()),
148+ z .I64 ("round" , round ),
149+ z .Str ("type" , typ .String ()),
150+ z .I64 ("peer_idx" , peerIdx ))
151+
144152 return t .broadcaster .Broadcast (ctx , msg .ToConsensusMsg ())
145153}
146154
@@ -157,6 +165,12 @@ func (t *transport) ProcessReceives(ctx context.Context, outerBuffer chan Msg) {
157165 case <- ctx .Done ():
158166 return
159167 case t .recvBuffer <- msg :
168+ log .Debug (ctx , "QBFT received msg" ,
169+ z .Str ("duty" , msg .msg .GetDuty ().String ()),
170+ z .I64 ("round" , msg .msg .GetRound ()),
171+ z .Str ("type" , qbft .MsgType (msg .msg .GetType ()).String ()),
172+ z .I64 ("peer_idx" , msg .msg .GetPeerIdx ()))
173+
160174 t .sniffer .Add (msg .ToConsensusMsg ())
161175 }
162176 }
0 commit comments