@@ -572,7 +572,7 @@ namespace glz
572
572
{
573
573
namespace repe
574
574
{
575
- inline void encode_error (const error_code& ec, const std::string_view error_message, message& msg )
575
+ inline void encode_error (const error_code& ec, message& msg, const std::string_view error_message = " " )
576
576
{
577
577
msg.header .ec = ec;
578
578
if (error_message.size () > (std::numeric_limits<uint32_t >::max)()) {
@@ -666,15 +666,15 @@ namespace glz
666
666
header.notify (true );
667
667
repe::request<Opts>(std::move (header), *request, std::forward<Params>(params)...);
668
668
if (bool (request->error ())) {
669
- encode_error (request->error (), " " , response);
669
+ encode_error (request->error (), response);
670
670
return ;
671
671
}
672
672
673
673
unique_socket socket{socket_pool.get ()};
674
674
if (not socket) {
675
675
socket.ptr .reset ();
676
676
(*is_connected) = false ;
677
- encode_error (error_code::send_error, " " , response);
677
+ encode_error (error_code::send_error, response);
678
678
return ;
679
679
}
680
680
@@ -684,7 +684,7 @@ namespace glz
684
684
if (bool (ec)) {
685
685
socket.ptr .reset ();
686
686
(*is_connected) = false ;
687
- encode_error (ec, " " , response);
687
+ encode_error (ec, response);
688
688
return ;
689
689
}
690
690
}
@@ -696,15 +696,15 @@ namespace glz
696
696
header.read (true );
697
697
repe::request<Opts>(std::move (header), *request);
698
698
if (bool (request->error ())) {
699
- encode_error (request->error (), " " , response);
699
+ encode_error (request->error (), response);
700
700
return ;
701
701
}
702
702
703
703
unique_socket socket{socket_pool.get ()};
704
704
if (not socket) {
705
705
socket.ptr .reset ();
706
706
(*is_connected) = false ;
707
- encode_error (error_code::send_error, " " , response);
707
+ encode_error (error_code::send_error, response);
708
708
return ;
709
709
}
710
710
@@ -714,15 +714,15 @@ namespace glz
714
714
if (bool (ec)) {
715
715
socket.ptr .reset ();
716
716
(*is_connected) = false ;
717
- encode_error (ec, " " , response);
717
+ encode_error (ec, response);
718
718
return ;
719
719
}
720
720
721
721
receive_buffer (*socket, response, ec);
722
722
if (bool (ec)) {
723
723
socket.ptr .reset ();
724
724
(*is_connected) = false ;
725
- encode_error (ec, " " , response);
725
+ encode_error (ec, response);
726
726
return ;
727
727
}
728
728
}
@@ -733,15 +733,15 @@ namespace glz
733
733
auto request = message_pool->borrow ();
734
734
repe::request<Opts>(std::move (header), *request, std::forward<Params>(params)...);
735
735
if (bool (request->error ())) {
736
- encode_error (request->error (), " " , response);
736
+ encode_error (request->error (), response);
737
737
return ;
738
738
}
739
739
740
740
unique_socket socket{socket_pool.get ()};
741
741
if (not socket) {
742
742
socket.ptr .reset ();
743
743
(*is_connected) = false ;
744
- encode_error (error_code::send_error, " " , response);
744
+ encode_error (error_code::send_error, response);
745
745
return ;
746
746
}
747
747
@@ -751,15 +751,15 @@ namespace glz
751
751
if (bool (ec)) {
752
752
socket.ptr .reset ();
753
753
(*is_connected) = false ;
754
- encode_error (ec, " " , response);
754
+ encode_error (ec, response);
755
755
return ;
756
756
}
757
757
758
758
receive_buffer (*socket, response, ec);
759
759
if (bool (ec)) {
760
760
socket.ptr .reset ();
761
761
(*is_connected) = false ;
762
- encode_error (ec, " " , response);
762
+ encode_error (ec, response);
763
763
return ;
764
764
}
765
765
}
0 commit comments