LCOV - code coverage report
Current view: top level - disco/events/generated - fd_event_gen.c (source / functions) Hit Total Coverage
Test: cov.lcov Lines: 0 254 0.0 %
Date: 2026-08-13 04:56:22 Functions: 0 7 0.0 %

          Line data    Source code
       1             : /* THIS FILE WAS GENERATED BY gen_events.py. DO NOT EDIT BY HAND! */
       2             : #include "fd_event_gen.h"
       3             : #include "../../../ballet/pb/fd_pb_encode.h"
       4             : 
       5             : void
       6             : fd_event_signed_vote_serialize( fd_circq_t *                   circq,
       7             :                                 fd_event_client_t *            client,
       8             :                                 long                           timestamp_nanos,
       9             :                                 ulong                          link_seq,
      10           0 :                                 fd_event_signed_vote_t const * msg ) {
      11           0 :   uchar * buffer = fd_circq_push_back( circq, 1UL, FD_EVENT_SIGNED_VOTE_BUF_MAX );
      12           0 :   FD_TEST( buffer );
      13             : 
      14           0 :   ulong event_id = fd_event_client_id_reserve( client );
      15             : 
      16           0 :   fd_pb_encoder_t encoder[1];
      17           0 :   fd_pb_encoder_init( encoder, buffer, FD_EVENT_SIGNED_VOTE_BUF_MAX );
      18             : 
      19           0 :   FD_TEST( circq->cursor_push_seq );
      20           0 :   fd_pb_push_uint64( encoder, 1U, circq->cursor_push_seq-1UL );
      21           0 :   fd_pb_push_uint64( encoder, 2U, event_id );
      22           0 :   fd_pb_push_uint64( encoder, 3U, link_seq );
      23           0 :   fd_pb_push_uint64( encoder, 4U, (ulong)timestamp_nanos );
      24             : 
      25           0 :   FD_TEST( msg->signed_txn_len<=1232UL );
      26           0 :   FD_TEST( msg->tower_cnt<=31UL );
      27             : 
      28           0 :   fd_pb_submsg_open( encoder, 5U ); /* Event */
      29           0 :   fd_pb_submsg_open( encoder, 3U ); /* SignedVote */
      30           0 :   if( msg->signed_txn_len ) fd_pb_push_bytes ( encoder, 1U, msg->signed_txn, msg->signed_txn_len );
      31           0 :   fd_pb_push_bytes ( encoder, 2U, msg->vote_account, 32UL );
      32           0 :   fd_pb_push_bytes ( encoder, 3U, msg->vote_authority, 32UL );
      33           0 :   fd_pb_push_bytes ( encoder, 4U, msg->fee_payer, 32UL );
      34           0 :   fd_pb_push_bytes ( encoder, 5U, msg->signature, 64UL );
      35           0 :   if( msg->vote_slot ) fd_pb_push_uint64( encoder, 6U, (ulong)msg->vote_slot );
      36           0 :   fd_pb_push_bytes ( encoder, 7U, msg->vote_bank_hash, 32UL );
      37           0 :   fd_pb_push_bytes ( encoder, 8U, msg->vote_block_id, 32UL );
      38           0 :   fd_pb_push_bytes ( encoder, 9U, msg->txn_blockhash, 32UL );
      39           0 :   for( ulong k=0UL; k<msg->tower_cnt; k++ ) {
      40           0 :     fd_pb_submsg_open( encoder, 10U );
      41           0 :     if( msg->tower[ k ].slot ) fd_pb_push_uint64( encoder, 1U, (ulong)msg->tower[ k ].slot );
      42           0 :     if( msg->tower[ k ].confirmation_count ) fd_pb_push_uint32( encoder, 2U, (uint)msg->tower[ k ].confirmation_count );
      43           0 :     fd_pb_submsg_close( encoder );
      44           0 :   }
      45           0 :   fd_pb_submsg_close( encoder );
      46           0 :   fd_pb_submsg_close( encoder );
      47           0 :   fd_circq_resize_back( circq, fd_pb_encoder_out_sz( encoder ) );
      48           0 : }
      49             : 
      50             : void
      51             : fd_event_slot_confirmed_serialize( fd_circq_t *                      circq,
      52             :                                    fd_event_client_t *               client,
      53             :                                    long                              timestamp_nanos,
      54             :                                    ulong                             link_seq,
      55           0 :                                    fd_event_slot_confirmed_t const * msg ) {
      56           0 :   uchar * buffer = fd_circq_push_back( circq, 1UL, FD_EVENT_SLOT_CONFIRMED_BUF_MAX );
      57           0 :   FD_TEST( buffer );
      58             : 
      59           0 :   ulong event_id = fd_event_client_id_reserve( client );
      60             : 
      61           0 :   fd_pb_encoder_t encoder[1];
      62           0 :   fd_pb_encoder_init( encoder, buffer, FD_EVENT_SLOT_CONFIRMED_BUF_MAX );
      63             : 
      64           0 :   FD_TEST( circq->cursor_push_seq );
      65           0 :   fd_pb_push_uint64( encoder, 1U, circq->cursor_push_seq-1UL );
      66           0 :   fd_pb_push_uint64( encoder, 2U, event_id );
      67           0 :   fd_pb_push_uint64( encoder, 3U, link_seq );
      68           0 :   fd_pb_push_uint64( encoder, 4U, (ulong)timestamp_nanos );
      69             : 
      70           0 :   fd_pb_submsg_open( encoder, 5U ); /* Event */
      71           0 :   fd_pb_submsg_open( encoder, 4U ); /* SlotConfirmed */
      72           0 :   if( msg->bank_seq ) fd_pb_push_uint64( encoder, 1U, (ulong)msg->bank_seq );
      73           0 :   if( msg->slot ) fd_pb_push_uint64( encoder, 2U, (ulong)msg->slot );
      74           0 :   fd_pb_push_bytes ( encoder, 3U, msg->block_id, 32UL );
      75           0 :   if( msg->stake ) fd_pb_push_uint64( encoder, 4U, (ulong)msg->stake );
      76           0 :   if( msg->total_stake ) fd_pb_push_uint64( encoder, 5U, (ulong)msg->total_stake );
      77           0 :   if( msg->valid ) fd_pb_push_bool  ( encoder, 6U, msg->valid );
      78           0 :   if( msg->level ) fd_pb_push_int32 ( encoder, 7U, msg->level );
      79           0 :   if( msg->forward ) fd_pb_push_bool  ( encoder, 8U, msg->forward );
      80           0 :   fd_pb_submsg_close( encoder );
      81           0 :   fd_pb_submsg_close( encoder );
      82           0 :   fd_circq_resize_back( circq, fd_pb_encoder_out_sz( encoder ) );
      83           0 : }
      84             : 
      85             : void
      86             : fd_event_accdb_compaction_completed_serialize( fd_circq_t *                                  circq,
      87             :                                                fd_event_client_t *                           client,
      88             :                                                long                                          timestamp_nanos,
      89             :                                                ulong                                         link_seq,
      90           0 :                                                fd_event_accdb_compaction_completed_t const * msg ) {
      91           0 :   uchar * buffer = fd_circq_push_back( circq, 1UL, FD_EVENT_ACCDB_COMPACTION_COMPLETED_BUF_MAX );
      92           0 :   FD_TEST( buffer );
      93             : 
      94           0 :   ulong event_id = fd_event_client_id_reserve( client );
      95             : 
      96           0 :   fd_pb_encoder_t encoder[1];
      97           0 :   fd_pb_encoder_init( encoder, buffer, FD_EVENT_ACCDB_COMPACTION_COMPLETED_BUF_MAX );
      98             : 
      99           0 :   FD_TEST( circq->cursor_push_seq );
     100           0 :   fd_pb_push_uint64( encoder, 1U, circq->cursor_push_seq-1UL );
     101           0 :   fd_pb_push_uint64( encoder, 2U, event_id );
     102           0 :   fd_pb_push_uint64( encoder, 3U, link_seq );
     103           0 :   fd_pb_push_uint64( encoder, 4U, (ulong)timestamp_nanos );
     104             : 
     105           0 :   fd_pb_submsg_open( encoder, 5U ); /* Event */
     106           0 :   fd_pb_submsg_open( encoder, 5U ); /* AccdbCompactionCompleted */
     107           0 :   if( msg->partition_idx ) fd_pb_push_uint64( encoder, 1U, (ulong)msg->partition_idx );
     108           0 :   if( msg->src_layer ) fd_pb_push_uint32( encoder, 2U, (uint)msg->src_layer );
     109           0 :   if( msg->dest_layer ) fd_pb_push_uint32( encoder, 3U, (uint)msg->dest_layer );
     110           0 :   if( msg->bytes_scanned ) fd_pb_push_uint64( encoder, 4U, (ulong)msg->bytes_scanned );
     111           0 :   if( msg->bytes_freed ) fd_pb_push_uint64( encoder, 5U, (ulong)msg->bytes_freed );
     112           0 :   if( msg->accounts_relocated ) fd_pb_push_uint64( encoder, 6U, (ulong)msg->accounts_relocated );
     113           0 :   if( msg->bytes_relocated ) fd_pb_push_uint64( encoder, 7U, (ulong)msg->bytes_relocated );
     114           0 :   if( msg->dead_records ) fd_pb_push_uint64( encoder, 8U, (ulong)msg->dead_records );
     115           0 :   if( msg->start_time ) fd_pb_push_uint64( encoder, 9U, (ulong)msg->start_time );
     116           0 :   if( msg->end_time ) fd_pb_push_uint64( encoder, 10U, (ulong)msg->end_time );
     117           0 :   fd_pb_submsg_close( encoder );
     118           0 :   fd_pb_submsg_close( encoder );
     119           0 :   fd_circq_resize_back( circq, fd_pb_encoder_out_sz( encoder ) );
     120           0 : }
     121             : 
     122             : void
     123             : fd_event_accdb_partition_added_serialize( fd_circq_t *                             circq,
     124             :                                           fd_event_client_t *                      client,
     125             :                                           long                                     timestamp_nanos,
     126             :                                           ulong                                    link_seq,
     127           0 :                                           fd_event_accdb_partition_added_t const * msg ) {
     128           0 :   uchar * buffer = fd_circq_push_back( circq, 1UL, FD_EVENT_ACCDB_PARTITION_ADDED_BUF_MAX );
     129           0 :   FD_TEST( buffer );
     130             : 
     131           0 :   ulong event_id = fd_event_client_id_reserve( client );
     132             : 
     133           0 :   fd_pb_encoder_t encoder[1];
     134           0 :   fd_pb_encoder_init( encoder, buffer, FD_EVENT_ACCDB_PARTITION_ADDED_BUF_MAX );
     135             : 
     136           0 :   FD_TEST( circq->cursor_push_seq );
     137           0 :   fd_pb_push_uint64( encoder, 1U, circq->cursor_push_seq-1UL );
     138           0 :   fd_pb_push_uint64( encoder, 2U, event_id );
     139           0 :   fd_pb_push_uint64( encoder, 3U, link_seq );
     140           0 :   fd_pb_push_uint64( encoder, 4U, (ulong)timestamp_nanos );
     141             : 
     142           0 :   fd_pb_submsg_open( encoder, 5U ); /* Event */
     143           0 :   fd_pb_submsg_open( encoder, 6U ); /* AccdbPartitionAdded */
     144           0 :   if( msg->partition_idx ) fd_pb_push_uint64( encoder, 1U, (ulong)msg->partition_idx );
     145           0 :   if( msg->prior_partition_idx ) fd_pb_push_uint64( encoder, 2U, (ulong)msg->prior_partition_idx );
     146           0 :   if( msg->layer ) fd_pb_push_uint32( encoder, 3U, (uint)msg->layer );
     147           0 :   if( msg->old_partition_max ) fd_pb_push_uint64( encoder, 4U, (ulong)msg->old_partition_max );
     148           0 :   if( msg->new_partition_max ) fd_pb_push_uint64( encoder, 5U, (ulong)msg->new_partition_max );
     149           0 :   if( msg->partition_sz ) fd_pb_push_uint64( encoder, 6U, (ulong)msg->partition_sz );
     150           0 :   if( msg->disk_allocated_bytes ) fd_pb_push_uint64( encoder, 7U, (ulong)msg->disk_allocated_bytes );
     151           0 :   fd_pb_submsg_close( encoder );
     152           0 :   fd_pb_submsg_close( encoder );
     153           0 :   fd_circq_resize_back( circq, fd_pb_encoder_out_sz( encoder ) );
     154           0 : }
     155             : 
     156             : void
     157             : fd_event_block_equivocated_serialize( fd_circq_t *                         circq,
     158             :                                       fd_event_client_t *                  client,
     159             :                                       long                                 timestamp_nanos,
     160             :                                       ulong                                link_seq,
     161           0 :                                       fd_event_block_equivocated_t const * msg ) {
     162           0 :   uchar * buffer = fd_circq_push_back( circq, 1UL, FD_EVENT_BLOCK_EQUIVOCATED_BUF_MAX );
     163           0 :   FD_TEST( buffer );
     164             : 
     165           0 :   ulong event_id = fd_event_client_id_reserve( client );
     166             : 
     167           0 :   fd_pb_encoder_t encoder[1];
     168           0 :   fd_pb_encoder_init( encoder, buffer, FD_EVENT_BLOCK_EQUIVOCATED_BUF_MAX );
     169             : 
     170           0 :   FD_TEST( circq->cursor_push_seq );
     171           0 :   fd_pb_push_uint64( encoder, 1U, circq->cursor_push_seq-1UL );
     172           0 :   fd_pb_push_uint64( encoder, 2U, event_id );
     173           0 :   fd_pb_push_uint64( encoder, 3U, link_seq );
     174           0 :   fd_pb_push_uint64( encoder, 4U, (ulong)timestamp_nanos );
     175             : 
     176           0 :   fd_pb_submsg_open( encoder, 5U ); /* Event */
     177           0 :   fd_pb_submsg_open( encoder, 7U ); /* BlockEquivocated */
     178           0 :   if( msg->bank_seq ) fd_pb_push_uint64( encoder, 1U, (ulong)msg->bank_seq );
     179           0 :   if( msg->slot ) fd_pb_push_uint64( encoder, 2U, (ulong)msg->slot );
     180           0 :   if( msg->parent_slot ) fd_pb_push_uint64( encoder, 3U, (ulong)msg->parent_slot );
     181           0 :   if( msg->epoch ) fd_pb_push_uint64( encoder, 4U, (ulong)msg->epoch );
     182           0 :   fd_pb_push_bytes ( encoder, 5U, msg->block_id, 32UL );
     183           0 :   fd_pb_push_bytes ( encoder, 6U, msg->sibling_block_id, 32UL );
     184           0 :   fd_pb_push_bytes ( encoder, 7U, msg->bank_hash, 32UL );
     185           0 :   fd_pb_push_bytes ( encoder, 8U, msg->block_hash, 32UL );
     186           0 :   if( msg->is_leader ) fd_pb_push_bool  ( encoder, 9U, msg->is_leader );
     187           0 :   if( msg->our_block_voted ) fd_pb_push_bool  ( encoder, 10U, msg->our_block_voted );
     188           0 :   if( msg->our_block_confirmed ) fd_pb_push_bool  ( encoder, 11U, msg->our_block_confirmed );
     189           0 :   if( msg->block_stake ) fd_pb_push_uint64( encoder, 12U, (ulong)msg->block_stake );
     190           0 :   if( msg->sibling_stake ) fd_pb_push_uint64( encoder, 13U, (ulong)msg->sibling_stake );
     191           0 :   if( msg->total_stake ) fd_pb_push_uint64( encoder, 14U, (ulong)msg->total_stake );
     192           0 :   if( msg->detection ) fd_pb_push_int32 ( encoder, 15U, msg->detection );
     193           0 :   fd_pb_submsg_close( encoder );
     194           0 :   fd_pb_submsg_close( encoder );
     195           0 :   fd_circq_resize_back( circq, fd_pb_encoder_out_sz( encoder ) );
     196           0 : }
     197             : 
     198             : void
     199             : fd_event_runtime_txn_serialize( fd_circq_t *                   circq,
     200             :                                 fd_event_client_t *            client,
     201             :                                 long                           timestamp_nanos,
     202             :                                 ulong                          link_seq,
     203           0 :                                 fd_event_runtime_txn_t const * msg ) {
     204           0 :   uchar * buffer = fd_circq_push_back( circq, 1UL, FD_EVENT_RUNTIME_TXN_BUF_MAX );
     205           0 :   FD_TEST( buffer );
     206             : 
     207           0 :   ulong event_id = fd_event_client_id_reserve( client );
     208             : 
     209           0 :   fd_pb_encoder_t encoder[1];
     210           0 :   fd_pb_encoder_init( encoder, buffer, FD_EVENT_RUNTIME_TXN_BUF_MAX );
     211             : 
     212           0 :   FD_TEST( circq->cursor_push_seq );
     213           0 :   fd_pb_push_uint64( encoder, 1U, circq->cursor_push_seq-1UL );
     214           0 :   fd_pb_push_uint64( encoder, 2U, event_id );
     215           0 :   fd_pb_push_uint64( encoder, 3U, link_seq );
     216           0 :   fd_pb_push_uint64( encoder, 4U, (ulong)timestamp_nanos );
     217             : 
     218           0 :   FD_TEST( msg->account_diffs_cnt<=64UL );
     219           0 :   FD_TEST( msg->writable_accounts_cnt<=64UL );
     220           0 :   FD_TEST( msg->readonly_accounts_cnt<=64UL );
     221           0 :   FD_TEST( msg->program_ids_cnt<=64UL );
     222             : 
     223           0 :   fd_pb_submsg_open( encoder, 5U ); /* Event */
     224           0 :   fd_pb_submsg_open( encoder, 8U ); /* RuntimeTxn */
     225           0 :   if( msg->bank_seq ) fd_pb_push_uint64( encoder, 1U, (ulong)msg->bank_seq );
     226           0 :   if( msg->slot ) fd_pb_push_uint64( encoder, 2U, (ulong)msg->slot );
     227           0 :   if( msg->index_in_slot ) fd_pb_push_uint64( encoder, 3U, (ulong)msg->index_in_slot );
     228           0 :   if( msg->commit_index_in_slot ) fd_pb_push_uint64( encoder, 4U, (ulong)msg->commit_index_in_slot );
     229           0 :   fd_pb_push_bytes ( encoder, 5U, msg->fec_merkle_root, 32UL );
     230           0 :   if( msg->epoch ) fd_pb_push_uint64( encoder, 6U, (ulong)msg->epoch );
     231           0 :   fd_pb_push_bytes ( encoder, 7U, msg->signature, 64UL );
     232           0 :   fd_pb_push_bytes ( encoder, 8U, msg->blockhash, 32UL );
     233           0 :   fd_pb_push_bytes ( encoder, 9U, msg->fee_payer, 32UL );
     234           0 :   if( msg->is_simple_vote ) fd_pb_push_bool  ( encoder, 10U, msg->is_simple_vote );
     235           0 :   if( msg->is_bundle ) fd_pb_push_bool  ( encoder, 11U, msg->is_bundle );
     236           0 :   if( msg->is_committable ) fd_pb_push_bool  ( encoder, 12U, msg->is_committable );
     237           0 :   if( msg->is_fees_only ) fd_pb_push_bool  ( encoder, 13U, msg->is_fees_only );
     238           0 :   if( msg->txn_err ) fd_pb_push_int32 ( encoder, 14U, msg->txn_err );
     239           0 :   if( msg->exec_err ) fd_pb_push_int32 ( encoder, 15U, msg->exec_err );
     240           0 :   if( msg->exec_err_kind ) fd_pb_push_int32 ( encoder, 16U, msg->exec_err_kind );
     241           0 :   if( msg->exec_err_idx ) fd_pb_push_uint32( encoder, 17U, (uint)msg->exec_err_idx );
     242           0 :   if( msg->custom_err ) fd_pb_push_uint32( encoder, 18U, (uint)msg->custom_err );
     243           0 :   if( msg->compute_unit_limit ) fd_pb_push_uint64( encoder, 19U, (ulong)msg->compute_unit_limit );
     244           0 :   if( msg->compute_unit_price ) fd_pb_push_uint64( encoder, 20U, (ulong)msg->compute_unit_price );
     245           0 :   if( msg->compute_units_consumed ) fd_pb_push_uint64( encoder, 21U, (ulong)msg->compute_units_consumed );
     246           0 :   if( msg->heap_size ) fd_pb_push_uint64( encoder, 22U, (ulong)msg->heap_size );
     247           0 :   if( msg->num_builtin_instrs ) fd_pb_push_uint64( encoder, 23U, (ulong)msg->num_builtin_instrs );
     248           0 :   if( msg->num_non_builtin_instrs ) fd_pb_push_uint64( encoder, 24U, (ulong)msg->num_non_builtin_instrs );
     249           0 :   if( msg->loaded_accounts_data_size ) fd_pb_push_uint64( encoder, 25U, (ulong)msg->loaded_accounts_data_size );
     250           0 :   if( msg->loaded_accounts_data_size_limit ) fd_pb_push_uint64( encoder, 26U, (ulong)msg->loaded_accounts_data_size_limit );
     251           0 :   if( msg->accounts_resize_delta ) fd_pb_push_sint64( encoder, 27U, msg->accounts_resize_delta );
     252           0 :   if( msg->execution_fee ) fd_pb_push_uint64( encoder, 28U, (ulong)msg->execution_fee );
     253           0 :   if( msg->priority_fee ) fd_pb_push_uint64( encoder, 29U, (ulong)msg->priority_fee );
     254           0 :   if( msg->tips ) fd_pb_push_uint64( encoder, 30U, (ulong)msg->tips );
     255           0 :   if( msg->signature_count ) fd_pb_push_uint64( encoder, 31U, (ulong)msg->signature_count );
     256           0 :   if( msg->cost_signature ) fd_pb_push_uint32( encoder, 32U, (uint)msg->cost_signature );
     257           0 :   if( msg->cost_write_lock ) fd_pb_push_uint32( encoder, 33U, (uint)msg->cost_write_lock );
     258           0 :   if( msg->cost_data_bytes ) fd_pb_push_uint32( encoder, 34U, (uint)msg->cost_data_bytes );
     259           0 :   if( msg->cost_programs_execution ) fd_pb_push_uint32( encoder, 35U, (uint)msg->cost_programs_execution );
     260           0 :   if( msg->cost_loaded_accounts_data_size ) fd_pb_push_uint32( encoder, 36U, (uint)msg->cost_loaded_accounts_data_size );
     261           0 :   if( msg->cost_allocated_accounts_data_size ) fd_pb_push_uint64( encoder, 37U, (ulong)msg->cost_allocated_accounts_data_size );
     262           0 :   for( ulong k=0UL; k<msg->account_diffs_cnt; k++ ) {
     263           0 :     fd_pb_submsg_open( encoder, 38U );
     264           0 :     fd_pb_push_bytes ( encoder, 1U, msg->account_diffs[ k ].pubkey, 32UL );
     265           0 :     fd_pb_push_bytes ( encoder, 2U, msg->account_diffs[ k ].owner, 32UL );
     266           0 :     fd_pb_push_bytes ( encoder, 3U, msg->account_diffs[ k ].prev_owner, 32UL );
     267           0 :     if( msg->account_diffs[ k ].lamports ) fd_pb_push_uint64( encoder, 4U, (ulong)msg->account_diffs[ k ].lamports );
     268           0 :     if( msg->account_diffs[ k ].prev_lamports ) fd_pb_push_uint64( encoder, 5U, (ulong)msg->account_diffs[ k ].prev_lamports );
     269           0 :     if( msg->account_diffs[ k ].data_sz ) fd_pb_push_uint64( encoder, 6U, (ulong)msg->account_diffs[ k ].data_sz );
     270           0 :     if( msg->account_diffs[ k ].prev_data_sz ) fd_pb_push_uint64( encoder, 7U, (ulong)msg->account_diffs[ k ].prev_data_sz );
     271           0 :     if( msg->account_diffs[ k ].is_executable ) fd_pb_push_bool  ( encoder, 8U, msg->account_diffs[ k ].is_executable );
     272           0 :     if( msg->account_diffs[ k ].is_stake_update ) fd_pb_push_bool  ( encoder, 9U, msg->account_diffs[ k ].is_stake_update );
     273           0 :     if( msg->account_diffs[ k ].is_vote_update ) fd_pb_push_bool  ( encoder, 10U, msg->account_diffs[ k ].is_vote_update );
     274           0 :     if( msg->account_diffs[ k ].is_new_vote ) fd_pb_push_bool  ( encoder, 11U, msg->account_diffs[ k ].is_new_vote );
     275           0 :     if( msg->account_diffs[ k ].is_rm_vote ) fd_pb_push_bool  ( encoder, 12U, msg->account_diffs[ k ].is_rm_vote );
     276           0 :     fd_pb_submsg_close( encoder );
     277           0 :   }
     278           0 :   for( ulong k=0UL; k<msg->writable_accounts_cnt; k++ ) {
     279           0 :     fd_pb_push_bytes ( encoder, 39U, msg->writable_accounts[ k ], 32UL );
     280           0 :   }
     281           0 :   for( ulong k=0UL; k<msg->readonly_accounts_cnt; k++ ) {
     282           0 :     fd_pb_push_bytes ( encoder, 40U, msg->readonly_accounts[ k ], 32UL );
     283           0 :   }
     284           0 :   for( ulong k=0UL; k<msg->program_ids_cnt; k++ ) {
     285           0 :     fd_pb_push_bytes ( encoder, 41U, msg->program_ids[ k ], 32UL );
     286           0 :   }
     287           0 :   fd_pb_submsg_close( encoder );
     288           0 :   fd_pb_submsg_close( encoder );
     289           0 :   fd_circq_resize_back( circq, fd_pb_encoder_out_sz( encoder ) );
     290           0 : }
     291             : 
     292             : void
     293             : fd_event_serialize_by_type( ulong               type,
     294             :                             fd_circq_t *        circq,
     295             :                             fd_event_client_t * client,
     296             :                             long                timestamp_nanos,
     297             :                             ulong               link_seq,
     298             :                             void const *        ev,
     299           0 :                             ulong               ev_sz ) {
     300           0 :   switch( type ) {
     301           0 :   case 3UL:
     302           0 :     FD_TEST( ev_sz==sizeof(fd_event_signed_vote_t) );
     303           0 :     fd_event_signed_vote_serialize( circq, client, timestamp_nanos, link_seq, (fd_event_signed_vote_t const *)ev );
     304           0 :     break;
     305           0 :   case 4UL:
     306           0 :     FD_TEST( ev_sz==sizeof(fd_event_slot_confirmed_t) );
     307           0 :     fd_event_slot_confirmed_serialize( circq, client, timestamp_nanos, link_seq, (fd_event_slot_confirmed_t const *)ev );
     308           0 :     break;
     309           0 :   case 5UL:
     310           0 :     FD_TEST( ev_sz==sizeof(fd_event_accdb_compaction_completed_t) );
     311           0 :     fd_event_accdb_compaction_completed_serialize( circq, client, timestamp_nanos, link_seq, (fd_event_accdb_compaction_completed_t const *)ev );
     312           0 :     break;
     313           0 :   case 6UL:
     314           0 :     FD_TEST( ev_sz==sizeof(fd_event_accdb_partition_added_t) );
     315           0 :     fd_event_accdb_partition_added_serialize( circq, client, timestamp_nanos, link_seq, (fd_event_accdb_partition_added_t const *)ev );
     316           0 :     break;
     317           0 :   case 7UL:
     318           0 :     FD_TEST( ev_sz==sizeof(fd_event_block_equivocated_t) );
     319           0 :     fd_event_block_equivocated_serialize( circq, client, timestamp_nanos, link_seq, (fd_event_block_equivocated_t const *)ev );
     320           0 :     break;
     321           0 :   case 8UL:
     322           0 :     FD_TEST( ev_sz==sizeof(fd_event_runtime_txn_t) );
     323           0 :     fd_event_runtime_txn_serialize( circq, client, timestamp_nanos, link_seq, (fd_event_runtime_txn_t const *)ev );
     324           0 :     break;
     325           0 :   default: FD_LOG_ERR(( "unexpected event type %lu", type ));
     326           0 :   }
     327           0 : }

Generated by: LCOV version 1.14