Skip to content

Commit 789d03a

Browse files
topointon-jumptopointon-jump
committed
flamenco, runtime: remove unuused feature
1 parent a743b28 commit 789d03a

File tree

12 files changed

+47
-313
lines changed

12 files changed

+47
-313
lines changed

‎src/app/firedancer-dev/commands/backtest.c

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -252,25 +252,20 @@ backtest_topo( config_t * config ) {
252252
FD_TEST( fd_pod_insertf_ulong( topo->props, writer_fseq_obj->id, "writer_fseq.%lu", i ) );
253253
}
254254

255-
/* txncache_obj, busy_obj, poh_slot_obj and constipated_obj only by replay tile */
255+
/* txncache_obj, busy_obj and poh_slot_obj only by replay tile */
256256
fd_topob_wksp( topo, "tcache" );
257257
fd_topob_wksp( topo, "bank_busy" );
258-
fd_topob_wksp( topo, "constipate" );
259258
fd_topo_obj_t * txncache_obj = setup_topo_txncache( topo, "tcache",
260259
config->firedancer.runtime.limits.max_rooted_slots,
261260
config->firedancer.runtime.limits.max_live_slots,
262-
config->firedancer.runtime.limits.max_transactions_per_slot,
263-
fd_txncache_max_constipated_slots_est( config->firedancer.runtime.limits.snapshot_grace_period_seconds ) );
261+
config->firedancer.runtime.limits.max_transactions_per_slot );
264262
fd_topob_tile_uses( topo, replay_tile, txncache_obj, FD_SHMEM_JOIN_MODE_READ_WRITE );
265263
FD_TEST( fd_pod_insertf_ulong( topo->props, txncache_obj->id, "txncache" ) );
266264
for( ulong i=0UL; i<bank_tile_cnt; i++ ) {
267265
fd_topo_obj_t * busy_obj = fd_topob_obj( topo, "fseq", "bank_busy" );
268266
fd_topob_tile_uses( topo, replay_tile, busy_obj, FD_SHMEM_JOIN_MODE_READ_WRITE );
269267
FD_TEST( fd_pod_insertf_ulong( topo->props, busy_obj->id, "bank_busy.%lu", i ) );
270268
}
271-
fd_topo_obj_t * constipated_obj = fd_topob_obj( topo, "fseq", "constipate" );
272-
fd_topob_tile_uses( topo, replay_tile, constipated_obj, FD_SHMEM_JOIN_MODE_READ_WRITE );
273-
FD_TEST( fd_pod_insertf_ulong( topo->props, constipated_obj->id, "constipate" ) );
274269

275270
for( ulong i=0UL; i<topo->tile_cnt; i++ ) {
276271
fd_topo_tile_t * tile = &topo->tiles[ i ];

‎src/app/firedancer-dev/commands/sim.c

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,6 @@ sim_topo( config_t * config ) {
120120
fd_topob_wksp( topo, "runtime_pub" );
121121
fd_topob_wksp( topo, "tcache" );
122122
fd_topob_wksp( topo, "poh_slot" );
123-
fd_topob_wksp( topo, "constipate" );
124123
fd_topob_wksp( topo, "bank_busy" );
125124
fd_topob_wksp( topo, "exec_spad" );
126125
fd_topob_wksp( topo, "exec_fseq" );
@@ -137,10 +136,8 @@ sim_topo( config_t * config ) {
137136
fd_topo_obj_t * txncache_obj = setup_topo_txncache( topo, "tcache",
138137
config->firedancer.runtime.limits.max_rooted_slots,
139138
config->firedancer.runtime.limits.max_live_slots,
140-
config->firedancer.runtime.limits.max_transactions_per_slot,
141-
fd_txncache_max_constipated_slots_est( config->firedancer.runtime.limits.snapshot_grace_period_seconds ) );
139+
config->firedancer.runtime.limits.max_transactions_per_slot );
142140
fd_topo_obj_t * poh_slot_obj = fd_topob_obj( topo, "fseq", "poh_slot" );
143-
fd_topo_obj_t * constipated_obj = fd_topob_obj( topo, "fseq", "constipate" );
144141
fd_topo_obj_t * banks_obj = setup_topo_banks( topo, "banks", config->firedancer.runtime.limits.max_banks );
145142

146143
FD_TEST( fd_pod_insertf_ulong( topo->props, blockstore_obj->id, "blockstore" ) );
@@ -149,7 +146,6 @@ sim_topo( config_t * config ) {
149146
FD_TEST( fd_pod_insertf_ulong( topo->props, runtime_pub_obj->id, "runtime_pub" ) );
150147
FD_TEST( fd_pod_insertf_ulong( topo->props, txncache_obj->id, "txncache" ) );
151148
FD_TEST( fd_pod_insertf_ulong( topo->props, poh_slot_obj->id, "poh_slot" ) );
152-
FD_TEST( fd_pod_insertf_ulong( topo->props, constipated_obj->id, "constipate" ) );
153149
FD_TEST( fd_pod_insertf_ulong( topo->props, banks_obj->id, "banks" ) );
154150

155151
fd_topob_tile_uses( topo, storei_tile, blockstore_obj, FD_SHMEM_JOIN_MODE_READ_WRITE );
@@ -160,7 +156,6 @@ sim_topo( config_t * config ) {
160156
fd_topob_tile_uses( topo, replay_tile, runtime_pub_obj, FD_SHMEM_JOIN_MODE_READ_WRITE );
161157
fd_topob_tile_uses( topo, replay_tile, root_slot_obj, FD_SHMEM_JOIN_MODE_READ_WRITE );
162158
fd_topob_tile_uses( topo, replay_tile, poh_slot_obj, FD_SHMEM_JOIN_MODE_READ_ONLY );
163-
fd_topob_tile_uses( topo, replay_tile, constipated_obj, FD_SHMEM_JOIN_MODE_READ_WRITE );
164159
fd_topob_tile_uses( topo, replay_tile, banks_obj, FD_SHMEM_JOIN_MODE_READ_WRITE );
165160
for( ulong i=0UL; i<config->layout.bank_tile_count; i++ ) {
166161
fd_topo_obj_t * busy_obj = fd_topob_obj( topo, "fseq", "bank_busy" );

‎src/app/firedancer/callbacks.c

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -181,7 +181,7 @@ fd_topo_obj_callbacks_t fd_obj_cb_fec_sets = {
181181
static ulong
182182
txncache_footprint( fd_topo_t const * topo,
183183
fd_topo_obj_t const * obj ) {
184-
return fd_txncache_footprint( VAL("max_rooted_slots"), VAL("max_live_slots"), VAL("max_txn_per_slot"), VAL("max_constipated_slots") );
184+
return fd_txncache_footprint( VAL("max_rooted_slots"), VAL("max_live_slots"), VAL("max_txn_per_slot") );
185185
}
186186

187187
static ulong
@@ -193,7 +193,7 @@ txncache_align( fd_topo_t const * topo FD_FN_UNUSED,
193193
static void
194194
txncache_new( fd_topo_t const * topo,
195195
fd_topo_obj_t const * obj ) {
196-
FD_TEST( fd_txncache_new( fd_topo_obj_laddr( topo, obj->id ), VAL("max_rooted_slots"), VAL("max_live_slots"), VAL("max_txn_per_slot"), VAL("max_constipated_slots") ) );
196+
FD_TEST( fd_txncache_new( fd_topo_obj_laddr( topo, obj->id ), VAL("max_rooted_slots"), VAL("max_live_slots"), VAL("max_txn_per_slot") ) );
197197
}
198198

199199
fd_topo_obj_callbacks_t fd_obj_cb_txncache = {

‎src/app/firedancer/topology.c

Lines changed: 2 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -85,14 +85,12 @@ setup_topo_txncache( fd_topo_t * topo,
8585
char const * wksp_name,
8686
ulong max_rooted_slots,
8787
ulong max_live_slots,
88-
ulong max_txn_per_slot,
89-
ulong max_constipated_slots ) {
88+
ulong max_txn_per_slot ) {
9089
fd_topo_obj_t * obj = fd_topob_obj( topo, "txncache", wksp_name );
9190

9291
FD_TEST( fd_pod_insertf_ulong( topo->props, max_rooted_slots, "obj.%lu.max_rooted_slots", obj->id ) );
9392
FD_TEST( fd_pod_insertf_ulong( topo->props, max_live_slots, "obj.%lu.max_live_slots", obj->id ) );
9493
FD_TEST( fd_pod_insertf_ulong( topo->props, max_txn_per_slot, "obj.%lu.max_txn_per_slot", obj->id ) );
95-
FD_TEST( fd_pod_insertf_ulong( topo->props, max_constipated_slots, "obj.%lu.max_constipated_slots", obj->id ) );
9694

9795
return obj;
9896
}
@@ -333,7 +331,6 @@ fd_topo_initialize( config_t * config ) {
333331
fd_topob_wksp( topo, "poh" );
334332
fd_topob_wksp( topo, "send" );
335333
fd_topob_wksp( topo, "tower" );
336-
fd_topob_wksp( topo, "constipate" );
337334
fd_topob_wksp( topo, "exec_spad" );
338335
fd_topob_wksp( topo, "exec_fseq" );
339336
fd_topob_wksp( topo, "writer_fseq" );
@@ -535,8 +532,7 @@ fd_topo_initialize( config_t * config ) {
535532
fd_topo_obj_t * txncache_obj = setup_topo_txncache( topo, "tcache",
536533
config->firedancer.runtime.limits.max_rooted_slots,
537534
config->firedancer.runtime.limits.max_live_slots,
538-
config->firedancer.runtime.limits.max_transactions_per_slot,
539-
fd_txncache_max_constipated_slots_est( config->firedancer.runtime.limits.snapshot_grace_period_seconds ) );
535+
config->firedancer.runtime.limits.max_transactions_per_slot );
540536
fd_topob_tile_uses( topo, replay_tile, txncache_obj, FD_SHMEM_JOIN_MODE_READ_WRITE );
541537
FD_TEST( fd_pod_insertf_ulong( topo->props, txncache_obj->id, "txncache" ) );
542538

@@ -614,10 +610,6 @@ fd_topo_initialize( config_t * config ) {
614610
}
615611
FD_TEST( fd_pod_insertf_ulong( topo->props, poh_shred_obj->id, "poh_shred" ) );
616612

617-
fd_topo_obj_t * constipated_obj = fd_topob_obj( topo, "fseq", "constipate" );
618-
fd_topob_tile_uses( topo, replay_tile, constipated_obj, FD_SHMEM_JOIN_MODE_READ_WRITE );
619-
FD_TEST( fd_pod_insertf_ulong( topo->props, constipated_obj->id, "constipate" ) );
620-
621613
if( FD_LIKELY( !is_auto_affinity ) ) {
622614
if( FD_UNLIKELY( affinity_tile_cnt<topo->tile_cnt ) )
623615
FD_LOG_ERR(( "The topology you are using has %lu tiles, but the CPU affinity specified in the config tile as [layout.affinity] only provides for %lu cores. "

‎src/app/firedancer/topology.h

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,7 @@ setup_topo_txncache( fd_topo_t * topo,
3232
char const * wksp_name,
3333
ulong max_rooted_slots,
3434
ulong max_live_slots,
35-
ulong max_txn_per_slot,
36-
ulong max_constipated_slots );
35+
ulong max_txn_per_slot );
3736

3837
fd_topo_obj_t *
3938
setup_topo_funk( fd_topo_t * topo,

‎src/app/ledger/main.c

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -887,14 +887,12 @@ ingest( fd_ledger_args_t * args ) {
887887
// fd_txncache_align(),
888888
// fd_txncache_footprint( FD_TXNCACHE_DEFAULT_MAX_ROOTED_SLOTS,
889889
// FD_TXNCACHE_DEFAULT_MAX_LIVE_SLOTS,
890-
// MAX_CACHE_TXNS_PER_SLOT,
891-
// FD_TXNCACHE_DEFAULT_MAX_CONSTIPATED_SLOTS ) );
890+
// MAX_CACHE_TXNS_PER_SLOT ) );
892891
// FD_TEST( status_cache_mem );
893892
// slot_ctx->status_cache = fd_txncache_join( fd_txncache_new( status_cache_mem,
894893
// FD_TXNCACHE_DEFAULT_MAX_ROOTED_SLOTS,
895894
// FD_TXNCACHE_DEFAULT_MAX_LIVE_SLOTS,
896-
// MAX_CACHE_TXNS_PER_SLOT,
897-
// FD_TXNCACHE_DEFAULT_MAX_CONSTIPATED_SLOTS ) );
895+
// MAX_CACHE_TXNS_PER_SLOT ) );
898896
// FD_TEST( slot_ctx->status_cache );
899897
// }
900898

@@ -1064,8 +1062,7 @@ replay( fd_ledger_args_t * args ) {
10641062
// args->slot_ctx->status_cache = fd_txncache_join( fd_txncache_new( status_cache_mem,
10651063
// FD_TXNCACHE_DEFAULT_MAX_ROOTED_SLOTS,
10661064
// FD_TXNCACHE_DEFAULT_MAX_LIVE_SLOTS,
1067-
// MAX_CACHE_TXNS_PER_SLOT,
1068-
// FD_TXNCACHE_DEFAULT_MAX_CONSTIPATED_SLOTS ) );
1065+
// MAX_CACHE_TXNS_PER_SLOT ) );
10691066
// if( FD_UNLIKELY( !args->slot_ctx->status_cache ) ) {
10701067
// FD_LOG_ERR(( "Status cache was not allocated" ));
10711068
// }

‎src/discof/replay/fd_replay_tile.c

Lines changed: 13 additions & 94 deletions
Original file line numberDiff line numberDiff line change
@@ -228,7 +228,6 @@ struct fd_replay_tile_ctx {
228228
ulong exec_spad_cnt;
229229

230230
fd_spad_t * runtime_spad;
231-
ulong * is_constipated; /* Shared fseq to determine if funk should be constipated */
232231

233232
fd_funk_txn_t * false_root;
234233

@@ -558,13 +557,10 @@ txncache_publish( fd_replay_tile_ctx_t * ctx,
558557
fd_funk_txn_pool_t * txn_pool = fd_funk_txn_pool( ctx->funk );
559558
while( txn!=rooted_txn ) {
560559
ulong slot = txn->xid.ul[0];
561-
if( FD_LIKELY( !fd_txncache_get_is_constipated( ctx->slot_ctx->status_cache ) ) ) {
562-
FD_LOG_INFO(( "Registering slot %lu", slot ));
563-
fd_txncache_register_root_slot( ctx->slot_ctx->status_cache, slot );
564-
} else {
565-
FD_LOG_INFO(( "Registering constipated slot %lu", slot ));
566-
fd_txncache_register_constipated_slot( ctx->slot_ctx->status_cache, slot );
567-
}
560+
561+
FD_LOG_INFO(( "Registering slot %lu", slot ));
562+
fd_txncache_register_root_slot( ctx->slot_ctx->status_cache, slot );
563+
568564
txn = fd_funk_txn_parent( txn, txn_pool );
569565
}
570566

@@ -574,41 +570,16 @@ txncache_publish( fd_replay_tile_ctx_t * ctx,
574570
static void
575571
funk_publish( fd_replay_tile_ctx_t * ctx,
576572
fd_funk_txn_t * to_root_txn,
577-
ulong wmk,
578-
uchar is_constipated ) {
573+
ulong wmk ) {
579574

580575
fd_funk_txn_start_write( ctx->funk );
576+
FD_LOG_DEBUG(( "Publishing slot=%lu xid=%lu", wmk, to_root_txn->xid.ul[0] ));
581577

582-
fd_funk_txn_pool_t * txn_pool = fd_funk_txn_pool( ctx->funk );
583-
584-
/* Try to publish into Funk */
585-
if( is_constipated ) {
586-
FD_LOG_NOTICE(( "Publishing slot=%lu while constipated", wmk ));
587-
588-
/* At this point, first collapse the current transaction that should be
589-
published into the oldest child transaction. */
590-
FD_LOG_NOTICE(( "Publishing into constipated root for wmk=%lu", wmk ));
591-
fd_funk_txn_t * txn = to_root_txn;
592-
593-
while( txn!=ctx->false_root ) {
594-
if( FD_UNLIKELY( fd_funk_txn_publish_into_parent( ctx->funk, txn, 0 ) ) ) {
595-
FD_LOG_ERR(( "Can't publish funk transaction" ));
596-
}
597-
txn = fd_funk_txn_parent( txn, txn_pool );
598-
}
599-
600-
} else {
601-
/* This is the case where we are not in the constipated case. We only need
602-
to do special handling in the case where the epoch account hash is about
603-
to be calculated. */
604-
FD_LOG_DEBUG(( "Publishing slot=%lu xid=%lu", wmk, to_root_txn->xid.ul[0] ));
605-
606-
/* This is the standard case. Publish all transactions up to and
607-
including the watermark. This will publish any in-prep ancestors
608-
of root_txn as well. */
609-
if( FD_UNLIKELY( !fd_funk_txn_publish( ctx->funk, to_root_txn, 1 ) ) ) {
610-
FD_LOG_ERR(( "failed to funk publish slot %lu", wmk ));
611-
}
578+
/* This is the standard case. Publish all transactions up to and
579+
including the watermark. This will publish any in-prep ancestors
580+
of root_txn as well. */
581+
if( FD_UNLIKELY( !fd_funk_txn_publish( ctx->funk, to_root_txn, 1 ) ) ) {
582+
FD_LOG_ERR(( "failed to funk publish slot %lu", wmk ));
612583
}
613584
fd_funk_txn_end_write( ctx->funk );
614585

@@ -640,45 +611,6 @@ funk_publish( fd_replay_tile_ctx_t * ctx,
640611

641612
}
642613

643-
static fd_funk_txn_t*
644-
get_rooted_txn( fd_replay_tile_ctx_t * ctx,
645-
fd_funk_txn_t * to_root_txn,
646-
uchar is_constipated ) {
647-
648-
/* We need to get the rooted transaction that we are publishing into. This
649-
needs to account for the two different cases: no constipation and single
650-
constipation.
651-
652-
Also, if it's the first time that we are setting the false root, then
653-
we must also register it into the status cache because we don't register
654-
the root in txncache_publish to avoid registering the same slot multiple times. */
655-
656-
fd_funk_txn_pool_t * txn_pool = fd_funk_txn_pool( ctx->funk );
657-
658-
if( is_constipated ) {
659-
660-
if( FD_UNLIKELY( !ctx->false_root ) ) {
661-
662-
fd_funk_txn_t * txn = to_root_txn;
663-
fd_funk_txn_t * parent_txn = fd_funk_txn_parent( txn, txn_pool );
664-
while( parent_txn ) {
665-
txn = parent_txn;
666-
parent_txn = fd_funk_txn_parent( txn, txn_pool );
667-
}
668-
669-
ctx->false_root = txn;
670-
if( !fd_txncache_get_is_constipated( ctx->slot_ctx->status_cache ) ) {
671-
fd_txncache_register_root_slot( ctx->slot_ctx->status_cache, txn->xid.ul[0] );
672-
} else {
673-
fd_txncache_register_constipated_slot( ctx->slot_ctx->status_cache, txn->xid.ul[0] );
674-
}
675-
}
676-
return ctx->false_root;
677-
} else {
678-
return NULL;
679-
}
680-
}
681-
682614
static void
683615
funk_and_txncache_publish( fd_replay_tile_ctx_t * ctx, ulong wmk, fd_funk_txn_xid_t const * xid ) {
684616

@@ -696,12 +628,12 @@ funk_and_txncache_publish( fd_replay_tile_ctx_t * ctx, ulong wmk, fd_funk_txn_xi
696628
if( FD_UNLIKELY( !to_root_txn ) ) {
697629
FD_LOG_ERR(( "Unable to find funk transaction for xid %lu", xid->ul[0] ));
698630
}
699-
fd_funk_txn_t * rooted_txn = get_rooted_txn( ctx, to_root_txn, 0 );
631+
fd_funk_txn_t * rooted_txn = NULL;
700632
fd_funk_txn_end_read( ctx->funk );
701633

702634
txncache_publish( ctx, to_root_txn, rooted_txn );
703635

704-
funk_publish( ctx, to_root_txn, wmk, 0 );
636+
funk_publish( ctx, to_root_txn, wmk );
705637

706638
if( FD_UNLIKELY( ctx->capture_ctx ) ) {
707639
fd_runtime_checkpt( ctx->capture_ctx, ctx->slot_ctx, wmk );
@@ -2126,19 +2058,6 @@ unprivileged_init( fd_topo_t * topo,
21262058
if( FD_UNLIKELY( !ctx->published_wmark ) ) FD_LOG_ERR(( "replay tile has no root_slot fseq" ));
21272059
FD_TEST( ULONG_MAX==fd_fseq_query( ctx->published_wmark ) );
21282060

2129-
/**********************************************************************/
2130-
/* constipated fseq */
2131-
/**********************************************************************/
2132-
2133-
/* When the replay tile boots, funk should not be constipated */
2134-
2135-
ulong constipated_obj_id = fd_pod_queryf_ulong( topo->props, ULONG_MAX, "constipate" );
2136-
FD_TEST( constipated_obj_id!=ULONG_MAX );
2137-
ctx->is_constipated = fd_fseq_join( fd_topo_obj_laddr( topo, constipated_obj_id ) );
2138-
if( FD_UNLIKELY( !ctx->is_constipated ) ) FD_LOG_ERR(( "replay tile has no constipated fseq" ));
2139-
fd_fseq_update( ctx->is_constipated, 0UL );
2140-
FD_TEST( 0UL==fd_fseq_query( ctx->is_constipated ) );
2141-
21422061
/**********************************************************************/
21432062
/* turbine_slot fseq */
21442063
/**********************************************************************/

‎src/discof/restart/fd_restart.c

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -220,7 +220,6 @@ fd_restart_find_heaviest_fork_bank_hash( fd_restart_t * restart,
220220

221221
void
222222
fd_restart_verify_heaviest_fork( fd_restart_t * restart,
223-
ulong * is_constipated,
224223
fd_slot_pair_t * hard_forks,
225224
ulong hard_forks_len,
226225
fd_hash_t * genesis_hash,
@@ -262,7 +261,6 @@ fd_restart_verify_heaviest_fork( fd_restart_t * restart,
262261

263262
/* Generate a full snapshot since we started wen-restart with a funk file instead of a snapshot file */
264263
ulong updated_fseq = fd_batch_fseq_pack( 1, 0, restart->heaviest_fork_slot );
265-
fd_fseq_update( is_constipated, updated_fseq );
266264

267265
/* Calculate the new shred version after inserting a hard fork */
268266
fd_sha256_t _sha[ 1 ]; fd_sha256_t * sha = fd_sha256_join( fd_sha256_new( _sha ) );

‎src/discof/restart/fd_restart_tile.c

Lines changed: 1 addition & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ struct fd_restart_tile_ctx {
2121
fd_pubkey_t identity, coordinator, genesis_hash;
2222
fd_slot_pair_t * new_hard_forks;
2323
ulong new_hard_forks_len;
24-
ulong * is_constipated;
2524

2625
// Gossip tile output
2726
fd_frag_meta_t * gossip_out_mcache;
@@ -138,17 +137,6 @@ unprivileged_init( fd_topo_t * topo,
138137
fd_base58_decode_32( tile->restart.genesis_hash, ctx->genesis_hash.key );
139138
ctx->identity = *(fd_pubkey_t const *)fd_type_pun_const( fd_keyload_load( tile->restart.identity_key_path, 1 ) );
140139

141-
/**********************************************************************/
142-
/* constipated fseq */
143-
/**********************************************************************/
144-
145-
ulong constipated_obj_id = fd_pod_queryf_ulong( topo->props, ULONG_MAX, "constipate" );
146-
FD_TEST( constipated_obj_id!=ULONG_MAX );
147-
ctx->is_constipated = fd_fseq_join( fd_topo_obj_laddr( topo, constipated_obj_id ) );
148-
if( FD_UNLIKELY( !ctx->is_constipated ) ) FD_LOG_ERR(( "restart tile has no constipated fseq" ));
149-
//fd_fseq_update( ctx->is_constipated, 0UL );
150-
//FD_TEST( 0UL==fd_fseq_query( ctx->is_constipated ) );
151-
152140
/**********************************************************************/
153141
/* links */
154142
/**********************************************************************/
@@ -455,7 +443,7 @@ after_credit( fd_restart_tile_ctx_t * ctx,
455443
ulong send = 0;
456444
uchar * buf = fd_chunk_to_laddr( ctx->gossip_out_mem, ctx->gossip_out_chunk );
457445
fd_restart_verify_heaviest_fork( ctx->restart,
458-
ctx->is_constipated,
446+
0,
459447
ctx->new_hard_forks,
460448
ctx->new_hard_forks_len,
461449
&ctx->genesis_hash,

0 commit comments

Comments
 (0)