more verbose

Author: julienrbrt

block/internal/submitting/da_submitter.go

@@ -400,7 +400,9 @@ func submitToDA[T any](
 		submitCtx, cancel := context.WithTimeout(ctx, submissionTimeout)
 		defer cancel()
 		// Perform submission
+		start := time.Now()
 		res := types.SubmitWithHelpers(submitCtx, s.da, s.logger, marshaled, rs.GasPrice, namespace, options)
+		s.logger.Info().Int("attempts", rs.Attempt).Dur("elapsed", time.Since(start)).Msg("got SubmitWithHelpers response from celestia")
 
 		// Record submission result for observability
 		if daVisualizationServer := server.GetDAVisualizationServer(); daVisualizationServer != nil {

block/internal/submitting/submitter.go

@@ -153,13 +153,13 @@ func (s *Submitter) daSubmissionLoop() {
 			return
 		case <-ticker.C:
 			// Submit headers
-			if s.cache.NumPendingHeaders() != 0 {
-				s.logger.Info().Time("t", time.Now()).Msg("Submitting headers")
+			if headersNb := s.cache.NumPendingHeaders(); headersNb != 0 {
+				s.logger.Info().Time("t", time.Now()).Uint64("headers", headersNb).Msg("Submitting headers")
 				if s.headerSubmissionMtx.TryLock() {
-					s.logger.Warn().Time("t", time.Now()).Msg("Header submission in progress")
+					s.logger.Warn().Time("t", time.Now()).Uint64("headers", headersNb).Msg("Header submission in progress")
 					go func() {
 						defer func() {
-							s.logger.Info().Time("t", time.Now()).Msg("Header submission completed")
+							s.logger.Info().Time("t", time.Now()).Uint64("headers", headersNb).Msg("Header submission completed")
 							s.headerSubmissionMtx.Unlock()
 						}()
 						if err := s.daSubmitter.SubmitHeaders(s.ctx, s.cache); err != nil {
@@ -177,13 +177,13 @@ func (s *Submitter) daSubmissionLoop() {
 			}
 
 			// Submit data
-			if s.cache.NumPendingData() != 0 {
-				s.logger.Info().Time("t", time.Now()).Msg("Submitting data")
+			if dataNb := s.cache.NumPendingData(); dataNb != 0 {
+				s.logger.Info().Time("t", time.Now()).Uint64("data", dataNb).Msg("Submitting data")
 				if s.dataSubmissionMtx.TryLock() {
-					s.logger.Info().Time("t", time.Now()).Msg("Data submission in progress")
+					s.logger.Info().Time("t", time.Now()).Uint64("data", dataNb).Msg("Data submission in progress")
 					go func() {
 						defer func() {
-							s.logger.Info().Time("t", time.Now()).Msg("Data submission completed")
+							s.logger.Info().Time("t", time.Now()).Uint64("data", dataNb).Msg("Data submission completed")
 							s.dataSubmissionMtx.Unlock()
 						}()
 						if err := s.daSubmitter.SubmitData(s.ctx, s.cache, s.signer, s.genesis); err != nil {