@@ -593,26 +593,6 @@ static int adapter_responseto(neu_adapter_t * adapter,
593
593
neu_reqresp_head_t * pheader = neu_msg_get_header (msg );
594
594
strcpy (pheader -> sender , adapter -> name );
595
595
596
- neu_otel_trace_ctx trace = NULL ;
597
- neu_otel_scope_ctx scope = NULL ;
598
- if (neu_otel_control_is_started ()) {
599
- trace = neu_otel_find_trace (header -> ctx );
600
- if (trace ) {
601
- scope = neu_otel_add_span (trace );
602
- neu_otel_scope_set_span_name (scope , "adapter write tag response" );
603
- char new_span_id [36 ] = { 0 };
604
- neu_otel_new_span_id (new_span_id );
605
- neu_otel_scope_set_span_id (scope , new_span_id );
606
- uint8_t * p_sp_id = neu_otel_scope_get_pre_span_id (scope );
607
- if (p_sp_id ) {
608
- neu_otel_scope_set_parent_span_id2 (scope , p_sp_id , 8 );
609
- }
610
- neu_otel_scope_add_span_attr_int (scope , "thread id" ,
611
- (int64_t ) pthread_self ());
612
- neu_otel_scope_set_span_start_time (scope , neu_time_ms ());
613
- }
614
- }
615
-
616
596
int ret = neu_send_msg_to (adapter -> control_fd , & dst , msg );
617
597
if (0 != ret ) {
618
598
nlog_error ("adapter: %s send responseto %s failed, ret: %d, errno: %d" ,
@@ -621,10 +601,6 @@ static int adapter_responseto(neu_adapter_t * adapter,
621
601
neu_msg_free (msg );
622
602
}
623
603
624
- if (neu_otel_control_is_started () && trace ) {
625
- neu_otel_scope_set_span_end_time (scope , neu_time_ms ());
626
- }
627
-
628
604
return ret ;
629
605
}
630
606
0 commit comments