@@ -154,9 +154,14 @@ func (s *Submitter) daSubmissionLoop() {
154154 case <- ticker .C :
155155 // Submit headers
156156 if s .cache .NumPendingHeaders () != 0 {
157+ s .logger .Info ().Time ("t" , time .Now ()).Msg ("Submitting headers" )
157158 if s .headerSubmissionMtx .TryLock () {
159+ s .logger .Warn ().Time ("t" , time .Now ()).Msg ("Header submission in progress" )
158160 go func () {
159- defer s .headerSubmissionMtx .Unlock ()
161+ defer func () {
162+ s .logger .Info ().Time ("t" , time .Now ()).Msg ("Header submission completed" )
163+ s .headerSubmissionMtx .Unlock ()
164+ }()
160165 if err := s .daSubmitter .SubmitHeaders (s .ctx , s .cache ); err != nil {
161166 // Check for unrecoverable errors that indicate a critical issue
162167 if errors .Is (err , common .ErrOversizedItem ) {
@@ -173,9 +178,14 @@ func (s *Submitter) daSubmissionLoop() {
173178
174179 // Submit data
175180 if s .cache .NumPendingData () != 0 {
181+ s .logger .Info ().Time ("t" , time .Now ()).Msg ("Submitting data" )
176182 if s .dataSubmissionMtx .TryLock () {
183+ s .logger .Info ().Time ("t" , time .Now ()).Msg ("Data submission in progress" )
177184 go func () {
178- defer s .dataSubmissionMtx .Unlock ()
185+ defer func () {
186+ s .logger .Info ().Time ("t" , time .Now ()).Msg ("Data submission completed" )
187+ s .dataSubmissionMtx .Unlock ()
188+ }()
179189 if err := s .daSubmitter .SubmitData (s .ctx , s .cache , s .signer , s .genesis ); err != nil {
180190 // Check for unrecoverable errors that indicate a critical issue
181191 if errors .Is (err , common .ErrOversizedItem ) {
0 commit comments