Skip to content

Commit 1a935c2

Browse files
committed
fixes
1 parent a46bd2a commit 1a935c2

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

src/disco/bundle/fd_bundle_client.c

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -229,6 +229,7 @@ fd_bundle_client_subscribe_bundles( fd_bundle_tile_t * ctx ) {
229229

230230
static void
231231
fd_bundle_client_send_ping( fd_bundle_tile_t * ctx ) {
232+
if( FD_UNLIKELY( !ctx->grpc_client ) ) return; /* no client */
232233
fd_h2_conn_t * conn = fd_grpc_client_h2_conn( ctx->grpc_client );
233234
if( FD_UNLIKELY( !conn ) ) return; /* no conn */
234235
if( FD_UNLIKELY( conn->flags ) ) return; /* conn busy */
@@ -659,8 +660,9 @@ fd_bundle_client_handle_builder_fee_info(
659660
return;
660661
}
661662
if( FD_UNLIKELY( res.commission > 100 ) ) {
662-
FD_LOG_WARNING(( "BlockBuilderFeeInfoResponse commission out of range (0-100): %lu, assuming 100%% commission", res.commission ));
663-
res.commission = (uchar)100;
663+
ctx->metrics.decode_fail_cnt++;
664+
FD_LOG_WARNING(( "BlockBuilderFeeInfoResponse commission out of range (0-100): %lu", res.commission ));
665+
return;
664666
}
665667

666668
ctx->builder_commission = (uchar)res.commission;
@@ -820,10 +822,12 @@ fd_bundle_client_grpc_rx_end(
820822
switch( request_ctx ) {
821823
case FD_BUNDLE_CLIENT_REQ_Bundle_SubscribePackets:
822824
ctx->packet_subscription_live = 0;
825+
ctx->packet_subscription_wait = 0;
823826
fd_bundle_tile_backoff( ctx, fd_tickcount() );
824827
break;
825828
case FD_BUNDLE_CLIENT_REQ_Bundle_SubscribeBundles:
826829
ctx->bundle_subscription_live = 0;
830+
ctx->bundle_subscription_wait = 0;
827831
fd_bundle_tile_backoff( ctx, fd_tickcount() );
828832
break;
829833
default:

0 commit comments

Comments
 (0)