Skip to content

Commit 3c16970

Browse files
riptlriptl
committed
funk: clean up join API
Adds a 'join' struct containing local address space pointers to sub objects. Improves insert performance by about 20ns per record. Reverts 'ele_max' to ulong to avoid integer truncation issues.
1 parent b7ef4be commit 3c16970

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

41 files changed

+772
-812
lines changed

‎src/app/ledger/main.c

+3-4
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ struct fd_ledger_args {
2222
fd_wksp_t * status_cache_wksp; /* wksp for status cache. */
2323
fd_blockstore_t blockstore_ljoin;
2424
fd_blockstore_t * blockstore; /* blockstore for replay */
25-
fd_funk_t * funk; /* handle to funk */
25+
fd_funk_t funk[1]; /* handle to funk */
2626
fd_alloc_t * alloc; /* handle to alloc */
2727
char const * cmd; /* user passed command to fd_ledger */
2828
ulong start_slot; /* start slot for offline replay */
@@ -894,11 +894,10 @@ void
894894
init_funk( fd_ledger_args_t * args ) {
895895
fd_funk_t * funk;
896896
if( args->restore_funk ) {
897-
funk = fd_funk_recover_checkpoint( args->funk_file, 1, args->restore_funk, &args->funk_close_args );
897+
funk = fd_funk_recover_checkpoint( args->funk, args->funk_file, 1, args->restore_funk, &args->funk_close_args );
898898
} else {
899-
funk = fd_funk_open_file( args->funk_file, 1, args->hashseed, args->txns_max, args->index_max, args->funk_page_cnt*(1UL<<30), FD_FUNK_OVERWRITE, &args->funk_close_args );
899+
funk = fd_funk_open_file( args->funk, args->funk_file, 1, args->hashseed, args->txns_max, args->index_max, args->funk_page_cnt*(1UL<<30), FD_FUNK_OVERWRITE, &args->funk_close_args );
900900
}
901-
args->funk = funk;
902901
args->funk_wksp = fd_funk_wksp( funk );
903902
FD_LOG_NOTICE(( "funky at global address 0x%016lx", fd_wksp_gaddr_fast( args->funk_wksp, funk ) ));
904903
}

‎src/app/rpcserver/main.c

+4-4
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,8 @@ init_args( int * argc, char *** argv, fd_rpcserver_args_t * args ) {
3232
char const * funk_file = fd_env_strip_cmdline_cstr( argc, argv, "--funk-file", NULL, NULL );
3333
if( FD_UNLIKELY( !funk_file ))
3434
FD_LOG_ERR(( "--funk-file argument is required" ));
35-
args->funk = fd_funk_open_file( funk_file, 1, 0, 0, 0, 0, FD_FUNK_READONLY, NULL );
36-
if( args->funk == NULL ) {
35+
fd_funk_t * funk = fd_funk_open_file( args->funk, funk_file, 1, 0, 0, 0, 0, FD_FUNK_READONLY, NULL );
36+
if( !funk ) {
3737
FD_LOG_ERR(( "failed to join a funky" ));
3838
}
3939

@@ -108,9 +108,9 @@ init_args_offline( int * argc, char *** argv, fd_rpcserver_args_t * args ) {
108108
FD_LOG_ERR(( "--funk-file argument is required" ));
109109
char const * restore = fd_env_strip_cmdline_cstr ( argc, argv, "--restore-funk", NULL, NULL );
110110
if( restore != NULL )
111-
args->funk = fd_funk_recover_checkpoint( funk_file, 1, restore, NULL );
111+
fd_funk_recover_checkpoint( args->funk, funk_file, 1, restore, NULL );
112112
else
113-
args->funk = fd_funk_open_file( funk_file, 1, 0, 0, 0, 0, FD_FUNK_READONLY, NULL );
113+
fd_funk_open_file( args->funk, funk_file, 1, 0, 0, 0, 0, FD_FUNK_READONLY, NULL );
114114

115115
fd_wksp_t * wksp;
116116
const char * wksp_name = fd_env_strip_cmdline_cstr ( argc, argv, "--wksp-name-blockstore", NULL, NULL );

‎src/choreo/forks/fd_forks.c

+3-3
Original file line numberDiff line numberDiff line change
@@ -193,7 +193,7 @@ slot_ctx_restore( ulong slot,
193193
fd_exec_epoch_ctx_t * epoch_ctx,
194194
fd_spad_t * runtime_spad,
195195
fd_exec_slot_ctx_t * slot_ctx_out ) {
196-
fd_funk_txn_map_t txn_map = fd_funk_txn_map( funk, fd_funk_wksp( funk ) );
196+
fd_funk_txn_map_t * txn_map = fd_funk_txn_map( funk );
197197
bool block_exists = fd_blockstore_shreds_complete( blockstore, slot );
198198

199199
FD_LOG_DEBUG( ( "Current slot %lu", slot ) );
@@ -204,11 +204,11 @@ slot_ctx_restore( ulong slot,
204204
fd_funk_rec_key_t id = fd_runtime_slot_bank_key();
205205
for( ; ; ) {
206206
fd_funk_txn_start_read( funk );
207-
fd_funk_txn_t * txn = fd_funk_txn_query( &xid, &txn_map );
207+
fd_funk_txn_t * txn = fd_funk_txn_query( &xid, txn_map );
208208
if( !txn ) {
209209
memset( xid.uc, 0, sizeof( fd_funk_txn_xid_t ) );
210210
xid.ul[0] = slot;
211-
txn = fd_funk_txn_query( &xid, &txn_map );
211+
txn = fd_funk_txn_query( &xid, txn_map );
212212
if( !txn ) {
213213
FD_LOG_ERR( ( "missing txn, parent slot %lu", slot ) );
214214
}

‎src/discof/batch/fd_batch_tile.c

+4-9
Original file line numberDiff line numberDiff line change
@@ -442,15 +442,10 @@ after_credit( fd_snapshot_tile_ctx_t * ctx,
442442
if( FD_UNLIKELY( !ctx->is_funk_active ) ) {
443443
/* Setting these parameters are not required because we are joining the
444444
funk that was setup in the replay tile. */
445-
ctx->funk = fd_funk_open_file( ctx->funk_file,
446-
1UL,
447-
0UL,
448-
0UL,
449-
0UL,
450-
0UL,
451-
FD_FUNK_READ_WRITE,
452-
NULL );
453-
if( FD_UNLIKELY( !ctx->funk ) ) {
445+
fd_funk_t * funk = fd_funk_open_file(
446+
ctx->funk, ctx->funk_file,
447+
1UL, 0UL, 0UL, 0UL, 0UL, FD_FUNK_READ_WRITE, NULL );
448+
if( FD_UNLIKELY( !funk ) ) {
454449
FD_LOG_ERR(( "failed to join a funky" ));
455450
}
456451
ctx->is_funk_active = 1;

‎src/discof/consensus/test_consensus.c

+4-3
Original file line numberDiff line numberDiff line change
@@ -444,13 +444,14 @@ main( void ) {
444444
// /**********************************************************************/
445445

446446
// fd_wksp_tag_query_info_t funk_info;
447-
// fd_funk_t * funk = NULL;
447+
// fd_funk_t funk_[1];
448+
// fd_funk_t * funk = NULL;
448449
// ulong funk_tag = FD_FUNK_MAGIC;
449450
// if( fd_wksp_tag_query( wksp, &funk_tag, 1, &funk_info, 1 ) > 0 ) {
450451
// void * shmem = fd_wksp_laddr_fast( wksp, funk_info.gaddr_lo );
451-
// funk = fd_funk_join( shmem );
452+
// funk = fd_funk_join( funk_, shmem );
452453
// }
453-
// if( funk == NULL ) FD_LOG_ERR( ( "failed to join a funky" ) );
454+
// if( !funk ) FD_LOG_ERR( ( "failed to join a funky" ) );
454455

455456
// /**********************************************************************/
456457
// /* blockstore */

‎src/discof/exec/fd_exec_tile.c

+8-13
Original file line numberDiff line numberDiff line change
@@ -228,13 +228,13 @@ prepare_new_slot_execution( fd_exec_tile_ctx_t * ctx,
228228
fd_spad_push( ctx->exec_spad );
229229
ctx->pending_slot_pop = 1;
230230

231-
fd_funk_txn_map_t txn_map = fd_funk_txn_map( ctx->funk, ctx->funk_wksp );
232-
if( FD_UNLIKELY( !txn_map.map ) ) {
231+
fd_funk_txn_map_t * txn_map = fd_funk_txn_map( ctx->funk );
232+
if( FD_UNLIKELY( !txn_map->map ) ) {
233233
FD_LOG_ERR(( "Could not find valid funk transaction map" ));
234234
}
235235
fd_funk_txn_xid_t xid = { .ul = { slot_msg->slot, slot_msg->slot } };
236236
fd_funk_txn_start_read( ctx->funk );
237-
fd_funk_txn_t * funk_txn = fd_funk_txn_query( &xid, &txn_map );
237+
fd_funk_txn_t * funk_txn = fd_funk_txn_query( &xid, txn_map );
238238
if( FD_UNLIKELY( !funk_txn ) ) {
239239
FD_LOG_ERR(( "Could not find valid funk transaction" ));
240240
}
@@ -616,19 +616,14 @@ unprivileged_init( fd_topo_t * topo,
616616
the funk that was setup in the replay tile. */
617617
FD_LOG_NOTICE(( "Trying to join funk at file=%s", tile->exec.funk_file ));
618618
fd_funk_txn_start_write( NULL );
619-
ctx->funk = fd_funk_open_file( tile->exec.funk_file,
620-
1UL,
621-
0UL,
622-
0UL,
623-
0UL,
624-
0UL,
625-
FD_FUNK_READONLY,
626-
NULL );
619+
fd_funk_open_file(
620+
ctx->funk, tile->exec.funk_file,
621+
1UL, 0UL, 0UL, 0UL, 0UL, FD_FUNK_READONLY, NULL );
627622
fd_funk_txn_end_write( NULL );
628-
ctx->funk_wksp = fd_funk_wksp( ctx->funk );
629-
if( FD_UNLIKELY( !ctx->funk ) ) {
623+
if( FD_UNLIKELY( !ctx->funk->shmem ) ) {
630624
FD_LOG_ERR(( "failed to join a funk" ));
631625
}
626+
ctx->funk_wksp = fd_funk_wksp( ctx->funk );
632627

633628
FD_LOG_NOTICE(( "Just joined funk at file=%s", tile->exec.funk_file ));
634629

‎src/discof/geyser/fd_geyser.c

+4-4
Original file line numberDiff line numberDiff line change
@@ -72,8 +72,8 @@ fd_geyser_new( void * mem, fd_geyser_args_t * args ) {
7272
ulong scratch_top = FD_SCRATCH_ALLOC_FINI( l, 1UL );
7373
FD_TEST( scratch_top <= (ulong)mem + fd_geyser_footprint() );
7474

75-
self->funk = fd_funk_open_file( args->funk_file, 1, 0, 0, 0, 0, FD_FUNK_READONLY, NULL );
76-
if( self->funk == NULL ) {
75+
fd_funk_t * funk = fd_funk_open_file( self->funk, args->funk_file, 1, 0, 0, 0, 0, FD_FUNK_READONLY, NULL );
76+
if( !funk ) {
7777
FD_LOG_ERR(( "failed to join a funky" ));
7878
}
7979

@@ -216,8 +216,8 @@ replay_sham_link_during_frag( fd_geyser_t * ctx, fd_replay_notif_msg_t * state,
216216

217217
static const void *
218218
read_account_with_xid( fd_geyser_t * ctx, fd_funk_rec_key_t * recid, fd_funk_txn_xid_t * xid, ulong * result_len ) {
219-
fd_funk_txn_map_t txn_map = fd_funk_txn_map( ctx->funk, fd_funk_wksp( ctx->funk ) );
220-
fd_funk_txn_t * txn = fd_funk_txn_query( xid, &txn_map );
219+
fd_funk_txn_map_t * txn_map = fd_funk_txn_map( ctx->funk );
220+
fd_funk_txn_t * txn = fd_funk_txn_query( xid, txn_map );
221221
return fd_funk_rec_query_copy( ctx->funk, txn, recid, fd_scratch_virtual(), result_len );
222222
}
223223

‎src/discof/replay/fd_replay_tile.c

+21-20
Original file line numberDiff line numberDiff line change
@@ -199,7 +199,7 @@ struct fd_replay_tile_ctx {
199199

200200
fd_alloc_t * alloc;
201201
fd_valloc_t valloc;
202-
fd_funk_t * funk;
202+
fd_funk_t funk[1];
203203
fd_exec_epoch_ctx_t * epoch_ctx;
204204
fd_epoch_t * epoch;
205205
fd_forks_t * forks;
@@ -826,9 +826,9 @@ checkpt( fd_replay_tile_ctx_t * ctx ) {
826826
static void FD_FN_UNUSED
827827
funk_cancel( fd_replay_tile_ctx_t * ctx, ulong mismatch_slot ) {
828828
fd_funk_txn_start_write( ctx->funk );
829-
fd_funk_txn_xid_t xid = { .ul = { mismatch_slot, mismatch_slot } };
830-
fd_funk_txn_map_t txn_map = fd_funk_txn_map( ctx->funk, fd_funk_wksp( ctx->funk ) );
831-
fd_funk_txn_t * mismatch_txn = fd_funk_txn_query( &xid, &txn_map );
829+
fd_funk_txn_xid_t xid = { .ul = { mismatch_slot, mismatch_slot } };
830+
fd_funk_txn_map_t * txn_map = fd_funk_txn_map( ctx->funk );
831+
fd_funk_txn_t * mismatch_txn = fd_funk_txn_query( &xid, txn_map );
832832
FD_TEST( fd_funk_txn_cancel( ctx->funk, mismatch_txn, 1 ) );
833833
fd_funk_txn_end_write( ctx->funk );
834834
}
@@ -860,7 +860,7 @@ txncache_publish( fd_replay_tile_ctx_t * ctx,
860860
fd_funk_txn_start_read( ctx->funk );
861861

862862
fd_funk_txn_t * txn = to_root_txn;
863-
fd_funk_txn_pool_t txn_pool = fd_funk_txn_pool( ctx->funk, fd_funk_wksp( ctx->funk ) );
863+
fd_funk_txn_pool_t * txn_pool = fd_funk_txn_pool( ctx->funk );
864864
while( txn!=rooted_txn ) {
865865
ulong slot = txn->xid.ul[0];
866866
if( FD_LIKELY( !fd_txncache_get_is_constipated( ctx->slot_ctx->status_cache ) ) ) {
@@ -870,7 +870,7 @@ txncache_publish( fd_replay_tile_ctx_t * ctx,
870870
FD_LOG_INFO(( "Registering constipated slot %lu", slot ));
871871
fd_txncache_register_constipated_slot( ctx->slot_ctx->status_cache, slot );
872872
}
873-
txn = fd_funk_txn_parent( txn, &txn_pool );
873+
txn = fd_funk_txn_parent( txn, txn_pool );
874874
}
875875

876876
fd_funk_txn_end_read( ctx->funk );
@@ -962,7 +962,7 @@ funk_publish( fd_replay_tile_ctx_t * ctx,
962962
fd_funk_txn_start_write( ctx->funk );
963963

964964
fd_epoch_bank_t * epoch_bank = fd_exec_epoch_ctx_epoch_bank( ctx->slot_ctx->epoch_ctx );
965-
fd_funk_txn_pool_t txn_pool = fd_funk_txn_pool( ctx->funk, fd_funk_wksp( ctx->funk ) );
965+
fd_funk_txn_pool_t * txn_pool = fd_funk_txn_pool( ctx->funk );
966966

967967
/* Try to publish into Funk */
968968
if( is_constipated ) {
@@ -982,7 +982,7 @@ funk_publish( fd_replay_tile_ctx_t * ctx,
982982
if( FD_UNLIKELY( fd_funk_txn_publish_into_parent( ctx->funk, txn, 0 ) ) ) {
983983
FD_LOG_ERR(( "Can't publish funk transaction" ));
984984
}
985-
txn = fd_funk_txn_parent( txn, &txn_pool );
985+
txn = fd_funk_txn_parent( txn, txn_pool );
986986
}
987987

988988
} else {
@@ -1003,7 +1003,7 @@ funk_publish( fd_replay_tile_ctx_t * ctx,
10031003
we will calculate the epoch account hash for. */
10041004

10051005
fd_funk_txn_t * txn = to_root_txn;
1006-
fd_funk_txn_t * parent_txn = fd_funk_txn_parent( txn, &txn_pool );
1006+
fd_funk_txn_t * parent_txn = fd_funk_txn_parent( txn, txn_pool );
10071007
while( parent_txn ) {
10081008
/* We need to be careful here because the eah start slot may be skipped
10091009
so the actual slot that we calculate the eah for may be greater than
@@ -1018,7 +1018,7 @@ funk_publish( fd_replay_tile_ctx_t * ctx,
10181018
break;
10191019
}
10201020
txn = parent_txn;
1021-
parent_txn = fd_funk_txn_parent( txn, &txn_pool );
1021+
parent_txn = fd_funk_txn_parent( txn, txn_pool );
10221022
}
10231023

10241024
/* At this point, we know txn is the funk txn that we will want to
@@ -1069,17 +1069,17 @@ get_rooted_txn( fd_replay_tile_ctx_t * ctx,
10691069
we must also register it into the status cache because we don't register
10701070
the root in txncache_publish to avoid registering the same slot multiple times. */
10711071

1072-
fd_funk_txn_pool_t txn_pool = fd_funk_txn_pool( ctx->funk, fd_funk_wksp( ctx->funk ) );
1072+
fd_funk_txn_pool_t * txn_pool = fd_funk_txn_pool( ctx->funk );
10731073

10741074
if( is_constipated ) {
10751075

10761076
if( FD_UNLIKELY( !ctx->false_root ) ) {
10771077

10781078
fd_funk_txn_t * txn = to_root_txn;
1079-
fd_funk_txn_t * parent_txn = fd_funk_txn_parent( txn, &txn_pool );
1079+
fd_funk_txn_t * parent_txn = fd_funk_txn_parent( txn, txn_pool );
10801080
while( parent_txn ) {
10811081
txn = parent_txn;
1082-
parent_txn = fd_funk_txn_parent( txn, &txn_pool );
1082+
parent_txn = fd_funk_txn_parent( txn, txn_pool );
10831083
}
10841084

10851085
ctx->false_root = txn;
@@ -1143,8 +1143,8 @@ funk_and_txncache_publish( fd_replay_tile_ctx_t * ctx, ulong wmk, fd_funk_txn_xi
11431143
/* Handle updates to funk and the status cache. */
11441144

11451145
fd_funk_txn_start_read( ctx->funk );
1146-
fd_funk_txn_map_t txn_map = fd_funk_txn_map( ctx->funk, fd_funk_wksp( ctx->funk ) );
1147-
fd_funk_txn_t * to_root_txn = fd_funk_txn_query( xid, &txn_map );
1146+
fd_funk_txn_map_t * txn_map = fd_funk_txn_map( ctx->funk );
1147+
fd_funk_txn_t * to_root_txn = fd_funk_txn_query( xid, txn_map );
11481148
if( FD_UNLIKELY( !to_root_txn ) ) {
11491149
FD_LOG_ERR(( "Unable to find funk transaction for xid %lu", xid->ul[0] ));
11501150
}
@@ -2918,26 +2918,27 @@ privileged_init( fd_topo_t * topo,
29182918
if( strcmp( snapshot, "funk" ) == 0 ) {
29192919
/* Funk database already exists. The parameters are actually mostly ignored. */
29202920
funk = fd_funk_open_file(
2921-
tile->replay.funk_file, 1, ctx->funk_seed, tile->replay.funk_txn_max,
2921+
ctx->funk,
2922+
tile->replay.funk_file, 1, ctx->funk_seed, tile->replay.funk_txn_max,
29222923
tile->replay.funk_rec_max, tile->replay.funk_sz_gb * (1UL<<30),
29232924
FD_FUNK_READ_WRITE, NULL );
29242925
} else if( strncmp( snapshot, "wksp:", 5 ) == 0) {
29252926
/* Recover funk database from a checkpoint. */
2926-
funk = fd_funk_recover_checkpoint( tile->replay.funk_file, 1, snapshot+5, NULL );
2927+
funk = fd_funk_recover_checkpoint( ctx->funk, tile->replay.funk_file, 1, snapshot+5, NULL );
29272928
} else {
29282929
FD_LOG_NOTICE(( "Trying to create new funk at file=%s", tile->replay.funk_file ));
29292930
/* Create new funk database */
29302931
funk = fd_funk_open_file(
2931-
tile->replay.funk_file, 1, ctx->funk_seed, tile->replay.funk_txn_max,
2932+
ctx->funk,
2933+
tile->replay.funk_file, 1, ctx->funk_seed, tile->replay.funk_txn_max,
29322934
tile->replay.funk_rec_max, tile->replay.funk_sz_gb * (1UL<<30),
29332935
FD_FUNK_OVERWRITE, NULL );
29342936
FD_LOG_NOTICE(( "Opened funk file at %s", tile->replay.funk_file ));
29352937
}
2936-
if( FD_UNLIKELY( funk == NULL ) ) {
2938+
if( FD_UNLIKELY( funk->shmem == NULL ) ) {
29372939
FD_LOG_ERR(( "no funk loaded" ));
29382940
}
29392941
fd_funk_txn_end_write( NULL );
2940-
ctx->funk = funk;
29412942
ctx->funk_wksp = fd_funk_wksp( funk );
29422943
if( FD_UNLIKELY( ctx->funk_wksp == NULL ) ) {
29432944
FD_LOG_ERR(( "no funk wksp" ));

‎src/discof/restart/fd_restart_tile.c

+11-16
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ struct fd_restart_tile_ctx {
1616
int in_wen_restart;
1717

1818
fd_restart_t * restart;
19-
fd_funk_t * funk;
19+
fd_funk_t funk[1];
2020
fd_epoch_bank_t epoch_bank;
2121
int is_funk_active;
2222
char funk_file[ PATH_MAX ];
@@ -275,14 +275,14 @@ after_frag( fd_restart_tile_ctx_t * ctx,
275275
if( FD_UNLIKELY( in_idx==STORE_IN_IDX ) ) {
276276
/* Decode the slot bank for HeaviestForkSlot from funk, referencing fd_runtime_recover_banks() in fd_runtime_init.c */
277277
fd_slot_bank_t slot_bank;
278-
fd_funk_rec_key_t id = fd_runtime_slot_bank_key();
279-
fd_funk_txn_map_t txn_map = fd_funk_txn_map( ctx->funk, fd_funk_wksp( ctx->funk ) );
278+
fd_funk_rec_key_t id = fd_runtime_slot_bank_key();
279+
fd_funk_txn_map_t * txn_map = fd_funk_txn_map( ctx->funk );
280280
fd_funk_txn_start_read( ctx->funk );
281-
fd_funk_txn_t * funk_txn = fd_funk_txn_query( &ctx->store_xid_msg, &txn_map );
281+
fd_funk_txn_t * funk_txn = fd_funk_txn_query( &ctx->store_xid_msg, txn_map );
282282
if( FD_UNLIKELY( !funk_txn ) ) {
283283
/* Try again with xid.ul[1] being the slot number instead of the block hash */
284284
ctx->store_xid_msg.ul[1] = ctx->restart->heaviest_fork_slot;
285-
funk_txn = fd_funk_txn_query( &ctx->store_xid_msg, &txn_map );
285+
funk_txn = fd_funk_txn_query( &ctx->store_xid_msg, txn_map );
286286
if( FD_UNLIKELY( !funk_txn ) ) {
287287
FD_LOG_ERR(( "Wen-restart fails due to NULL funk_txn" ));
288288
}
@@ -348,7 +348,7 @@ after_frag( fd_restart_tile_ctx_t * ctx,
348348
}
349349

350350
ulong sz = sizeof(uint) + fd_slot_bank_size( &slot_bank );
351-
uchar * buf = fd_funk_val_truncate( new_rec, sz, fd_funk_alloc( ctx->funk, fd_funk_wksp( ctx->funk ) ), fd_funk_wksp( ctx->funk ), &opt_err );
351+
uchar * buf = fd_funk_val_truncate( new_rec, sz, fd_funk_alloc( ctx->funk ), fd_funk_wksp( ctx->funk ), &opt_err );
352352
*(uint*)buf = FD_RUNTIME_ENC_BINCODE;
353353
fd_bincode_encode_ctx_t slot_bank_encode_ctx = {
354354
.data = buf + sizeof(uint),
@@ -359,7 +359,7 @@ after_frag( fd_restart_tile_ctx_t * ctx,
359359
FD_LOG_ERR(( "Wen-restart fails at inserting a hard fork in slot bank and save it in funk" ));
360360
}
361361

362-
fd_funk_rec_publish( prepare );
362+
fd_funk_rec_publish( ctx->funk, prepare );
363363

364364
/* Publish the txn in funk */
365365
fd_funk_txn_start_write( ctx->funk );
@@ -385,15 +385,10 @@ after_credit( fd_restart_tile_ctx_t * ctx,
385385
if( FD_UNLIKELY( !ctx->is_funk_active ) ) {
386386
/* Setting these parameters are not required because we are joining the
387387
funk that was setup in the replay tile. */
388-
ctx->funk = fd_funk_open_file( ctx->funk_file,
389-
1UL,
390-
0UL,
391-
0UL,
392-
0UL,
393-
0UL,
394-
FD_FUNK_READ_WRITE,
395-
NULL );
396-
if( FD_UNLIKELY( !ctx->funk ) ) {
388+
fd_funk_t * funk = fd_funk_open_file(
389+
ctx->funk, ctx->funk_file,
390+
1UL, 0UL, 0UL, 0UL, 0UL, FD_FUNK_READ_WRITE, NULL );
391+
if( FD_UNLIKELY( !funk ) ) {
397392
FD_LOG_ERR(( "failed to join a funky" ));
398393
} else {
399394
FD_LOG_NOTICE(("Restart tile joins funk successfully"));

‎src/discof/rpc/fd_rpcserv_tile.c

+3-3
Original file line numberDiff line numberDiff line change
@@ -140,9 +140,9 @@ after_frag( fd_rpcserv_tile_ctx_t * ctx,
140140
if( FD_LIKELY( in_idx==REPLAY_NOTIF_IDX ) ) {
141141
if( FD_UNLIKELY( !ctx->activated ) ) {
142142
fd_rpcserver_args_t * args = &ctx->args;
143-
args->funk = fd_funk_open_file(
144-
ctx->funk_file, 1, 0, 0, 0, 0, FD_FUNK_READ_WRITE, NULL );
145-
if( FD_UNLIKELY( args->funk == NULL ) ) {
143+
fd_funk_t * funk = fd_funk_open_file(
144+
args->funk, ctx->funk_file, 1, 0, 0, 0, 0, FD_FUNK_READ_WRITE, NULL );
145+
if( FD_UNLIKELY( !funk ) ) {
146146
FD_LOG_ERR(( "failed to join a funky" ));
147147
}
148148

0 commit comments

Comments
 (0)