@@ -386,13 +386,13 @@ pub(crate) fn encode<Cx: ThriftContext>(
386
386
if let Some ( biz_error) = cx. stats ( ) . biz_error ( ) {
387
387
let mut ibuf = itoa:: Buffer :: new ( ) ;
388
388
let status_code = ibuf. format ( biz_error. status_code ) ;
389
- dst. put_u16 ( TT_HEADER_BIZ_STATUS_KEY . as_bytes ( ) . len ( ) as u16 ) ;
389
+ dst. put_u16 ( TT_HEADER_BIZ_STATUS_KEY . len ( ) as u16 ) ;
390
390
dst. put_slice ( TT_HEADER_BIZ_STATUS_KEY . as_bytes ( ) ) ;
391
391
dst. put_u16 ( status_code. len ( ) as u16 ) ;
392
392
dst. put_slice ( status_code. as_bytes ( ) ) ;
393
393
string_kv_len += 1 ;
394
394
395
- dst. put_u16 ( TT_HEADER_BIZ_MESSAGE_KEY . as_bytes ( ) . len ( ) as u16 ) ;
395
+ dst. put_u16 ( TT_HEADER_BIZ_MESSAGE_KEY . len ( ) as u16 ) ;
396
396
dst. put_slice ( TT_HEADER_BIZ_MESSAGE_KEY . as_bytes ( ) ) ;
397
397
dst. put_u16 ( biz_error. status_message . len ( ) as u16 ) ;
398
398
dst. put_slice ( biz_error. status_message . as_bytes ( ) ) ;
@@ -408,9 +408,9 @@ pub(crate) fn encode<Cx: ThriftContext>(
408
408
. expect ( "encode biz error extra" )
409
409
. into ( )
410
410
} ;
411
- dst. put_u16 ( TT_HEADER_BIZ_EXTRA_KEY . as_bytes ( ) . len ( ) as u16 ) ;
411
+ dst. put_u16 ( TT_HEADER_BIZ_EXTRA_KEY . len ( ) as u16 ) ;
412
412
dst. put_slice ( TT_HEADER_BIZ_EXTRA_KEY . as_bytes ( ) ) ;
413
- dst. put_u16 ( extra_str. as_bytes ( ) . len ( ) as u16 ) ;
413
+ dst. put_u16 ( extra_str. len ( ) as u16 ) ;
414
414
dst. put_slice ( extra_str. as_bytes ( ) ) ;
415
415
string_kv_len += 1 ;
416
416
}
@@ -600,7 +600,7 @@ pub(crate) fn encode_size<Cx: ThriftContext>(cx: &mut Cx) -> Result<usize, Thrif
600
600
len += 2 ;
601
601
len += key_len;
602
602
len += 2 ;
603
- len += value. as_bytes ( ) . len ( ) ;
603
+ len += value. len ( ) ;
604
604
}
605
605
}
606
606
if let Some ( at) = metainfo. get_all_transients ( ) {
@@ -609,7 +609,7 @@ pub(crate) fn encode_size<Cx: ThriftContext>(cx: &mut Cx) -> Result<usize, Thrif
609
609
len += 2 ;
610
610
len += key_len;
611
611
len += 2 ;
612
- len += value. as_bytes ( ) . len ( ) ;
612
+ len += value. len ( ) ;
613
613
}
614
614
}
615
615
}
@@ -620,36 +620,33 @@ pub(crate) fn encode_size<Cx: ThriftContext>(cx: &mut Cx) -> Result<usize, Thrif
620
620
len += 2 ;
621
621
len += key_len;
622
622
len += 2 ;
623
- len += value. as_bytes ( ) . len ( ) ;
623
+ len += value. len ( ) ;
624
624
}
625
625
}
626
626
if thrift_cx. encode_conn_reset ( ) {
627
627
len += 2 ;
628
- len += "crrst" . as_bytes ( ) . len ( ) ;
628
+ len += "crrst" . len ( ) ;
629
629
len += 2 ;
630
- len += "1" . as_bytes ( ) . len ( ) ;
630
+ len += "1" . len ( ) ;
631
631
}
632
632
if let Some ( biz_error) = thrift_cx. stats ( ) . biz_error ( ) {
633
633
len += 2 ;
634
- len += TT_HEADER_BIZ_STATUS_KEY . as_bytes ( ) . len ( ) ;
634
+ len += TT_HEADER_BIZ_STATUS_KEY . len ( ) ;
635
635
len += 2 ;
636
- len += itoa:: Buffer :: new ( )
637
- . format ( biz_error. status_code )
638
- . as_bytes ( )
639
- . len ( ) ;
636
+ len += itoa:: Buffer :: new ( ) . format ( biz_error. status_code ) . len ( ) ;
640
637
641
638
len += 2 ;
642
- len += TT_HEADER_BIZ_MESSAGE_KEY . as_bytes ( ) . len ( ) ;
639
+ len += TT_HEADER_BIZ_MESSAGE_KEY . len ( ) ;
643
640
len += 2 ;
644
- len += biz_error. status_message . as_bytes ( ) . len ( ) ;
641
+ len += biz_error. status_message . len ( ) ;
645
642
646
643
if let Some ( extra) = & biz_error. extra {
647
644
len += 2 ;
648
- len += TT_HEADER_BIZ_EXTRA_KEY . as_bytes ( ) . len ( ) ;
645
+ len += TT_HEADER_BIZ_EXTRA_KEY . len ( ) ;
649
646
len += 2 ;
650
647
let extra =
651
648
sonic_rs:: to_string ( & extra) . expect ( "encode biz error extra" ) ;
652
- len += extra. as_bytes ( ) . len ( ) ;
649
+ len += extra. len ( ) ;
653
650
thrift_cx
654
651
. extensions_mut ( )
655
652
. insert ( BizErrorExtra ( extra. into ( ) ) ) ;
@@ -676,48 +673,48 @@ pub(crate) fn encode_size<Cx: ThriftContext>(cx: &mut Cx) -> Result<usize, Thrif
676
673
// WithHeader
677
674
len += 2 ;
678
675
len += 2 ;
679
- len += "3" . as_bytes ( ) . len ( ) ;
676
+ len += "3" . len ( ) ;
680
677
681
678
// Config
682
679
let config = thrift_cx. rpc_info ( ) . config ( ) ;
683
680
if let Some ( timeout) = config. rpc_timeout ( ) {
684
681
let timeout = timeout. as_millis ( ) . to_string ( ) ;
685
682
len += 2 ;
686
683
len += 2 ;
687
- len += timeout. as_bytes ( ) . len ( ) ;
684
+ len += timeout. len ( ) ;
688
685
}
689
686
690
687
if let Some ( timeout) = config. connect_timeout ( ) {
691
688
let timeout = timeout. as_millis ( ) . to_string ( ) ;
692
689
len += 2 ;
693
690
len += 2 ;
694
- len += timeout. as_bytes ( ) . len ( ) ;
691
+ len += timeout. len ( ) ;
695
692
}
696
693
697
694
// Caller
698
695
let caller = thrift_cx. rpc_info ( ) . caller ( ) ;
699
696
let svc = caller. service_name ( ) ;
700
697
len += 2 ;
701
698
len += 2 ;
702
- len += svc. as_bytes ( ) . len ( ) ;
699
+ len += svc. len ( ) ;
703
700
704
701
// Callee
705
702
let callee = thrift_cx. rpc_info ( ) . callee ( ) ;
706
703
let method = thrift_cx. rpc_info ( ) . method ( ) ;
707
704
len += 2 ;
708
705
len += 2 ;
709
- len += method. as_bytes ( ) . len ( ) ;
706
+ len += method. len ( ) ;
710
707
711
708
let svc = callee. service_name ( ) ;
712
709
len += 2 ;
713
710
len += 2 ;
714
- len += svc. as_bytes ( ) . len ( ) ;
711
+ len += svc. len ( ) ;
715
712
716
713
if let Some ( addr) = callee. address ( ) {
717
714
let addr = addr. to_string ( ) ;
718
715
len += 2 ;
719
716
len += 2 ;
720
- len += addr. as_bytes ( ) . len ( ) ;
717
+ len += addr. len ( ) ;
721
718
}
722
719
}
723
720
} ;
0 commit comments