Skip to content

Commit 1e65dfa

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 fd06bd5 commit 1e65dfa

Some content is hidden

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

49 files changed

+874
-899
lines changed

‎src/app/ledger/main.c

Lines changed: 7 additions & 7 deletions
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,13 +894,13 @@ 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;
901+
if( FD_UNLIKELY( !funk ) ) FD_LOG_ERR(( "Failed to join funk" ));
902902
args->funk_wksp = fd_funk_wksp( funk );
903-
FD_LOG_NOTICE(( "funky at global address 0x%016lx", fd_wksp_gaddr_fast( args->funk_wksp, funk ) ));
903+
FD_LOG_NOTICE(( "Funk database is at %s:0x%lx", fd_wksp_name( args->wksp ), fd_wksp_gaddr_fast( args->funk_wksp, funk ) ));
904904
}
905905

906906
void
@@ -1171,9 +1171,9 @@ ingest( fd_ledger_args_t * args ) {
11711171

11721172
#ifdef FD_FUNK_HANDHOLDING
11731173
if( args->verify_funk ) {
1174-
FD_LOG_NOTICE(( "verifying funky" ));
1174+
FD_LOG_NOTICE(( "fd_funk_verify() start" ));
11751175
if( fd_funk_verify( funk ) ) {
1176-
FD_LOG_ERR(( "verification failed" ));
1176+
FD_LOG_ERR(( "fd_funk_verify() failed" ));
11771177
}
11781178
}
11791179
#endif

‎src/app/rpcserver/main.c

Lines changed: 10 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -32,9 +32,9 @@ 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 ) {
37-
FD_LOG_ERR(( "failed to join a funky" ));
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 ) {
37+
FD_LOG_ERR(( "failed to join funk" ));
3838
}
3939

4040
char const * blockstore_file = fd_env_strip_cmdline_cstr( argc, argv, "--blockstore-file", NULL, NULL );
@@ -107,10 +107,13 @@ init_args_offline( int * argc, char *** argv, fd_rpcserver_args_t * args ) {
107107
if( FD_UNLIKELY( !funk_file ))
108108
FD_LOG_ERR(( "--funk-file argument is required" ));
109109
char const * restore = fd_env_strip_cmdline_cstr ( argc, argv, "--restore-funk", NULL, NULL );
110-
if( restore != NULL )
111-
args->funk = fd_funk_recover_checkpoint( funk_file, 1, restore, NULL );
112-
else
113-
args->funk = fd_funk_open_file( funk_file, 1, 0, 0, 0, 0, FD_FUNK_READONLY, NULL );
110+
fd_funk_t * funk = NULL;
111+
if( restore != NULL ) {
112+
funk = fd_funk_recover_checkpoint( args->funk, funk_file, 1, restore, NULL );
113+
} else {
114+
funk = fd_funk_open_file( args->funk, funk_file, 1, 0, 0, 0, 0, FD_FUNK_READONLY, NULL );
115+
}
116+
if( FD_UNLIKELY( !funk ) ) FD_LOG_ERR(( "Failed to join funk database" ));
114117

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

‎src/choreo/forks/fd_forks.c

Lines changed: 3 additions & 3 deletions
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

Lines changed: 6 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -442,20 +442,15 @@ 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 ) ) {
454-
FD_LOG_ERR(( "failed to join a funky" ));
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 ) ) {
449+
FD_LOG_ERR(( "Failed to join a funk database" ));
455450
}
456451
ctx->is_funk_active = 1;
457452

458-
FD_LOG_WARNING(( "Just joined funk at file=%s", ctx->funk_file ));
453+
FD_LOG_WARNING(( "Joined funk database at file=%s", ctx->funk_file ));
459454
}
460455

461456
if( fd_batch_fseq_is_snapshot( batch_fseq ) ) {

‎src/discof/consensus/test_consensus.c

Lines changed: 4 additions & 3 deletions
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

Lines changed: 9 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -241,13 +241,13 @@ prepare_new_slot_execution( fd_exec_tile_ctx_t * ctx,
241241
fd_spad_push( ctx->exec_spad );
242242
ctx->pending_slot_pop = 1;
243243

244-
fd_funk_txn_map_t txn_map = fd_funk_txn_map( ctx->funk, ctx->funk_wksp );
245-
if( FD_UNLIKELY( !txn_map.map ) ) {
244+
fd_funk_txn_map_t * txn_map = fd_funk_txn_map( ctx->funk );
245+
if( FD_UNLIKELY( !txn_map->map ) ) {
246246
FD_LOG_ERR(( "Could not find valid funk transaction map" ));
247247
}
248248
fd_funk_txn_xid_t xid = { .ul = { slot_msg->slot, slot_msg->slot } };
249249
fd_funk_txn_start_read( ctx->funk );
250-
fd_funk_txn_t * funk_txn = fd_funk_txn_query( &xid, &txn_map );
250+
fd_funk_txn_t * funk_txn = fd_funk_txn_query( &xid, txn_map );
251251
if( FD_UNLIKELY( !funk_txn ) ) {
252252
FD_LOG_ERR(( "Could not find valid funk transaction" ));
253253
}
@@ -664,19 +664,13 @@ unprivileged_init( fd_topo_t * topo,
664664
the funk that was setup in the replay tile. */
665665
FD_LOG_NOTICE(( "Trying to join funk at file=%s", tile->exec.funk_file ));
666666
fd_funk_txn_start_write( NULL );
667-
ctx->funk = fd_funk_open_file( tile->exec.funk_file,
668-
1UL,
669-
0UL,
670-
0UL,
671-
0UL,
672-
0UL,
673-
FD_FUNK_READONLY,
674-
NULL );
667+
if( FD_UNLIKELY( !fd_funk_open_file(
668+
ctx->funk, tile->exec.funk_file,
669+
1UL, 0UL, 0UL, 0UL, 0UL, FD_FUNK_READONLY, NULL ) ) ) {
670+
FD_LOG_ERR(( "fd_funk_open_file(%s) failed", tile->exec.funk_file ));
671+
}
675672
fd_funk_txn_end_write( NULL );
676673
ctx->funk_wksp = fd_funk_wksp( ctx->funk );
677-
if( FD_UNLIKELY( !ctx->funk ) ) {
678-
FD_LOG_ERR(( "failed to join a funk" ));
679-
}
680674

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

@@ -693,7 +687,7 @@ unprivileged_init( fd_topo_t * topo,
693687
// FIXME account for this in exec spad footprint
694688
uchar * txn_ctx_mem = fd_spad_alloc( ctx->exec_spad, FD_EXEC_TXN_CTX_ALIGN, FD_EXEC_TXN_CTX_FOOTPRINT );
695689
ctx->txn_ctx = fd_exec_txn_ctx_join( fd_exec_txn_ctx_new( txn_ctx_mem ), ctx->exec_spad, ctx->exec_spad_wksp );
696-
ctx->txn_ctx->funk = ctx->funk;
690+
*ctx->txn_ctx->funk = *ctx->funk;
697691

698692
ctx->txn_ctx->runtime_pub_wksp = ctx->runtime_public_wksp;
699693
if( FD_UNLIKELY( !ctx->txn_ctx->runtime_pub_wksp ) ) {

‎src/discof/geyser/fd_geyser.c

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -72,9 +72,9 @@ 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 ) {
77-
FD_LOG_ERR(( "failed to join a funky" ));
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 ) {
77+
FD_LOG_ERR(( "fd_funk_open_file(%s) failed", args->funk_file ));
7878
}
7979

8080
fd_wksp_t * wksp = fd_wksp_attach( args->blockstore_wksp );
@@ -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

Lines changed: 22 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -192,7 +192,7 @@ struct fd_replay_tile_ctx {
192192

193193
fd_alloc_t * alloc;
194194
fd_valloc_t valloc;
195-
fd_funk_t * funk;
195+
fd_funk_t funk[1];
196196
fd_exec_epoch_ctx_t * epoch_ctx;
197197
fd_epoch_t * epoch;
198198
fd_forks_t * forks;
@@ -746,9 +746,9 @@ checkpt( fd_replay_tile_ctx_t * ctx ) {
746746
static void FD_FN_UNUSED
747747
funk_cancel( fd_replay_tile_ctx_t * ctx, ulong mismatch_slot ) {
748748
fd_funk_txn_start_write( ctx->funk );
749-
fd_funk_txn_xid_t xid = { .ul = { mismatch_slot, mismatch_slot } };
750-
fd_funk_txn_map_t txn_map = fd_funk_txn_map( ctx->funk, fd_funk_wksp( ctx->funk ) );
751-
fd_funk_txn_t * mismatch_txn = fd_funk_txn_query( &xid, &txn_map );
749+
fd_funk_txn_xid_t xid = { .ul = { mismatch_slot, mismatch_slot } };
750+
fd_funk_txn_map_t * txn_map = fd_funk_txn_map( ctx->funk );
751+
fd_funk_txn_t * mismatch_txn = fd_funk_txn_query( &xid, txn_map );
752752
FD_TEST( fd_funk_txn_cancel( ctx->funk, mismatch_txn, 1 ) );
753753
fd_funk_txn_end_write( ctx->funk );
754754
}
@@ -773,7 +773,7 @@ txncache_publish( fd_replay_tile_ctx_t * ctx,
773773
fd_funk_txn_start_read( ctx->funk );
774774

775775
fd_funk_txn_t * txn = to_root_txn;
776-
fd_funk_txn_pool_t txn_pool = fd_funk_txn_pool( ctx->funk, fd_funk_wksp( ctx->funk ) );
776+
fd_funk_txn_pool_t * txn_pool = fd_funk_txn_pool( ctx->funk );
777777
while( txn!=rooted_txn ) {
778778
ulong slot = txn->xid.ul[0];
779779
if( FD_LIKELY( !fd_txncache_get_is_constipated( ctx->slot_ctx->status_cache ) ) ) {
@@ -783,7 +783,7 @@ txncache_publish( fd_replay_tile_ctx_t * ctx,
783783
FD_LOG_INFO(( "Registering constipated slot %lu", slot ));
784784
fd_txncache_register_constipated_slot( ctx->slot_ctx->status_cache, slot );
785785
}
786-
txn = fd_funk_txn_parent( txn, &txn_pool );
786+
txn = fd_funk_txn_parent( txn, txn_pool );
787787
}
788788

789789
fd_funk_txn_end_read( ctx->funk );
@@ -875,7 +875,7 @@ funk_publish( fd_replay_tile_ctx_t * ctx,
875875
fd_funk_txn_start_write( ctx->funk );
876876

877877
fd_epoch_bank_t * epoch_bank = fd_exec_epoch_ctx_epoch_bank( ctx->slot_ctx->epoch_ctx );
878-
fd_funk_txn_pool_t txn_pool = fd_funk_txn_pool( ctx->funk, fd_funk_wksp( ctx->funk ) );
878+
fd_funk_txn_pool_t * txn_pool = fd_funk_txn_pool( ctx->funk );
879879

880880
/* Try to publish into Funk */
881881
if( is_constipated ) {
@@ -895,7 +895,7 @@ funk_publish( fd_replay_tile_ctx_t * ctx,
895895
if( FD_UNLIKELY( fd_funk_txn_publish_into_parent( ctx->funk, txn, 0 ) ) ) {
896896
FD_LOG_ERR(( "Can't publish funk transaction" ));
897897
}
898-
txn = fd_funk_txn_parent( txn, &txn_pool );
898+
txn = fd_funk_txn_parent( txn, txn_pool );
899899
}
900900

901901
} else {
@@ -916,7 +916,7 @@ funk_publish( fd_replay_tile_ctx_t * ctx,
916916
we will calculate the epoch account hash for. */
917917

918918
fd_funk_txn_t * txn = to_root_txn;
919-
fd_funk_txn_t * parent_txn = fd_funk_txn_parent( txn, &txn_pool );
919+
fd_funk_txn_t * parent_txn = fd_funk_txn_parent( txn, txn_pool );
920920
while( parent_txn ) {
921921
/* We need to be careful here because the eah start slot may be skipped
922922
so the actual slot that we calculate the eah for may be greater than
@@ -931,7 +931,7 @@ funk_publish( fd_replay_tile_ctx_t * ctx,
931931
break;
932932
}
933933
txn = parent_txn;
934-
parent_txn = fd_funk_txn_parent( txn, &txn_pool );
934+
parent_txn = fd_funk_txn_parent( txn, txn_pool );
935935
}
936936

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

985-
fd_funk_txn_pool_t txn_pool = fd_funk_txn_pool( ctx->funk, fd_funk_wksp( ctx->funk ) );
985+
fd_funk_txn_pool_t * txn_pool = fd_funk_txn_pool( ctx->funk );
986986

987987
if( is_constipated ) {
988988

989989
if( FD_UNLIKELY( !ctx->false_root ) ) {
990990

991991
fd_funk_txn_t * txn = to_root_txn;
992-
fd_funk_txn_t * parent_txn = fd_funk_txn_parent( txn, &txn_pool );
992+
fd_funk_txn_t * parent_txn = fd_funk_txn_parent( txn, txn_pool );
993993
while( parent_txn ) {
994994
txn = parent_txn;
995-
parent_txn = fd_funk_txn_parent( txn, &txn_pool );
995+
parent_txn = fd_funk_txn_parent( txn, txn_pool );
996996
}
997997

998998
ctx->false_root = txn;
@@ -1056,8 +1056,8 @@ funk_and_txncache_publish( fd_replay_tile_ctx_t * ctx, ulong wmk, fd_funk_txn_xi
10561056
/* Handle updates to funk and the status cache. */
10571057

10581058
fd_funk_txn_start_read( ctx->funk );
1059-
fd_funk_txn_map_t txn_map = fd_funk_txn_map( ctx->funk, fd_funk_wksp( ctx->funk ) );
1060-
fd_funk_txn_t * to_root_txn = fd_funk_txn_query( xid, &txn_map );
1059+
fd_funk_txn_map_t * txn_map = fd_funk_txn_map( ctx->funk );
1060+
fd_funk_txn_t * to_root_txn = fd_funk_txn_query( xid, txn_map );
10611061
if( FD_UNLIKELY( !to_root_txn ) ) {
10621062
FD_LOG_ERR(( "Unable to find funk transaction for xid %lu", xid->ul[0] ));
10631063
}
@@ -2763,26 +2763,27 @@ privileged_init( fd_topo_t * topo,
27632763
if( strcmp( snapshot, "funk" ) == 0 ) {
27642764
/* Funk database already exists. The parameters are actually mostly ignored. */
27652765
funk = fd_funk_open_file(
2766-
tile->replay.funk_file, 1, ctx->funk_seed, tile->replay.funk_txn_max,
2766+
ctx->funk,
2767+
tile->replay.funk_file, 1, ctx->funk_seed, tile->replay.funk_txn_max,
27672768
tile->replay.funk_rec_max, tile->replay.funk_sz_gb * (1UL<<30),
27682769
FD_FUNK_READ_WRITE, NULL );
27692770
} else if( strncmp( snapshot, "wksp:", 5 ) == 0) {
27702771
/* Recover funk database from a checkpoint. */
2771-
funk = fd_funk_recover_checkpoint( tile->replay.funk_file, 1, snapshot+5, NULL );
2772+
funk = fd_funk_recover_checkpoint( ctx->funk, tile->replay.funk_file, 1, snapshot+5, NULL );
27722773
} else {
27732774
FD_LOG_NOTICE(( "Trying to create new funk at file=%s", tile->replay.funk_file ));
27742775
/* Create new funk database */
27752776
funk = fd_funk_open_file(
2776-
tile->replay.funk_file, 1, ctx->funk_seed, tile->replay.funk_txn_max,
2777+
ctx->funk,
2778+
tile->replay.funk_file, 1, ctx->funk_seed, tile->replay.funk_txn_max,
27772779
tile->replay.funk_rec_max, tile->replay.funk_sz_gb * (1UL<<30),
27782780
FD_FUNK_OVERWRITE, NULL );
27792781
FD_LOG_NOTICE(( "Opened funk file at %s", tile->replay.funk_file ));
27802782
}
2781-
if( FD_UNLIKELY( funk == NULL ) ) {
2782-
FD_LOG_ERR(( "no funk loaded" ));
2783+
if( FD_UNLIKELY( !funk ) ) {
2784+
FD_LOG_ERR(( "Failed to join funk database" ));
27832785
}
27842786
fd_funk_txn_end_write( NULL );
2785-
ctx->funk = funk;
27862787
ctx->funk_wksp = fd_funk_wksp( funk );
27872788
if( FD_UNLIKELY( ctx->funk_wksp == NULL ) ) {
27882789
FD_LOG_ERR(( "no funk wksp" ));

0 commit comments

Comments
 (0)