@@ -280,11 +280,14 @@ impl EnvTask {
280280 let mut span = info_span ! (
281281 parent: None ,
282282 "SimEnv" ,
283- confirmed_host. number = "initial" ,
284- confirmed_ru. number = "initial" ,
285- confirmed_ru. hash = "initial" ,
286- sim_host. number = "initial" ,
287- sim_ru. number = "initial" ,
283+ confirmed. host. number = "initial" ,
284+ confirmed. ru. number = "initial" ,
285+ confirmed. ru. hash = "initial" ,
286+ confirmed. timestamp = 0 ,
287+ confirmed. slot = 0 ,
288+ sim. host. number = "initial" ,
289+ sim. ru. number = "initial" ,
290+ sim_slot = 0 ,
288291 trace_id = tracing:: field:: Empty ,
289292 ) ;
290293
@@ -293,17 +296,25 @@ impl EnvTask {
293296 . instrument ( info_span ! ( parent: & span, "waiting_for_notification" ) )
294297 . await
295298 {
296- // Ensure that we record the OpenTelemetry trace ID in the span.
297- span. record ( "trace_id" , span. context ( ) . span ( ) . span_context ( ) . trace_id ( ) . to_string ( ) ) ;
298-
299299 let host_block_number =
300300 self . config . constants . rollup_block_to_host_block_num ( rollup_header. number ) ;
301301 let rollup_block_number = rollup_header. number ;
302+ let confirmed_slot = self
303+ . config
304+ . slot_calculator
305+ . slot_ending_at ( rollup_header. timestamp )
306+ . expect ( "valid timestamp" ) ;
307+ let sim_slot = self . config . slot_calculator . current_slot ( ) . expect ( "chain has started" ) ;
302308
303309 // Populate span fields.
310+ // Ensure that we record the OpenTelemetry trace ID in the span.
311+ span. record ( "trace_id" , span. context ( ) . span ( ) . span_context ( ) . trace_id ( ) . to_string ( ) ) ;
304312 span. record ( "confirmed_host.number" , host_block_number) ;
305313 span. record ( "confirmed_ru.number" , rollup_block_number) ;
306314 span. record ( "confirmed_ru.hash" , rollup_header. hash . to_string ( ) ) ;
315+ span. record ( "confirmed.timestamp" , rollup_header. timestamp ) ;
316+ span. record ( "confirmed.slot" , confirmed_slot) ;
317+ span. record ( "sim.slot" , sim_slot) ;
307318 span. record ( "sim_host.number" , host_block_number + 1 ) ;
308319 span. record ( "sim_ru.number" , rollup_block_number + 1 ) ;
309320
@@ -369,11 +380,14 @@ impl EnvTask {
369380 // Create a new span for the next iteration.
370381 span = info_span ! (
371382 "SimEnv" ,
372- confirmed_host. number = host_block_number + 1 ,
373- confirmed_ru. number = rollup_block_number + 1 ,
374- confirmed_ru. hash = tracing:: field:: Empty ,
375- sim_host. number = host_block_number + 2 ,
376- sim_ru. number = rollup_block_number + 2 ,
383+ confirmed. host. number = host_block_number + 1 ,
384+ confirmed. ru. number = rollup_block_number + 1 ,
385+ confirmed. ru. hash = tracing:: field:: Empty ,
386+ confirmed. timestamp = tracing:: field:: Empty ,
387+ confirmed. slot = tracing:: field:: Empty ,
388+ sim. host. number = host_block_number + 2 ,
389+ sim. ru. number = rollup_block_number + 2 ,
390+ sim. slot = tracing:: field:: Empty ,
377391 trace_id = tracing:: field:: Empty ,
378392 ) ;
379393 }
0 commit comments