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 : }
|