Line data Source code
1 : #include "topology.h"
2 : #include "config.h"
3 : #include "../shared/boot/fd_boot.h"
4 : #include "../shared/commands/configure/configure.h"
5 : #include "../shared/fd_action.h"
6 :
7 : char const * FD_APP_NAME = "Firedancer";
8 : char const * FD_BINARY_NAME = "firedancer";
9 :
10 : extern fd_topo_obj_callbacks_t fd_obj_cb_mcache;
11 : extern fd_topo_obj_callbacks_t fd_obj_cb_dcache;
12 : extern fd_topo_obj_callbacks_t fd_obj_cb_fseq;
13 : extern fd_topo_obj_callbacks_t fd_obj_cb_metrics;
14 : extern fd_topo_obj_callbacks_t fd_obj_cb_netdev_tbl;
15 : extern fd_topo_obj_callbacks_t fd_obj_cb_neigh4_hmap;
16 : extern fd_topo_obj_callbacks_t fd_obj_cb_keyswitch;
17 : extern fd_topo_obj_callbacks_t fd_obj_cb_node_info;
18 : extern fd_topo_obj_callbacks_t fd_obj_cb_leader_txn_timing;
19 : extern fd_topo_obj_callbacks_t fd_obj_cb_tile;
20 : extern fd_topo_obj_callbacks_t fd_obj_cb_store;
21 : extern fd_topo_obj_callbacks_t fd_obj_cb_fec_sets;
22 : extern fd_topo_obj_callbacks_t fd_obj_cb_txncache;
23 : extern fd_topo_obj_callbacks_t fd_obj_cb_accdb;
24 : extern fd_topo_obj_callbacks_t fd_obj_cb_backup;
25 : extern fd_topo_obj_callbacks_t fd_obj_cb_banks;
26 : extern fd_topo_obj_callbacks_t fd_obj_cb_progcache;
27 : extern fd_topo_obj_callbacks_t fd_obj_cb_rnonce_ss;
28 : extern fd_topo_obj_callbacks_t fd_obj_cb_adminctl;
29 : extern fd_topo_obj_callbacks_t fd_obj_cb_sleep;
30 :
31 : fd_topo_obj_callbacks_t * CALLBACKS[] = {
32 : &fd_obj_cb_mcache,
33 : &fd_obj_cb_dcache,
34 : &fd_obj_cb_fseq,
35 : &fd_obj_cb_metrics,
36 : &fd_obj_cb_netdev_tbl,
37 : &fd_obj_cb_neigh4_hmap,
38 : &fd_obj_cb_keyswitch,
39 : &fd_obj_cb_node_info,
40 : &fd_obj_cb_leader_txn_timing,
41 : &fd_obj_cb_tile,
42 : &fd_obj_cb_store,
43 : &fd_obj_cb_fec_sets,
44 : &fd_obj_cb_txncache,
45 : &fd_obj_cb_accdb,
46 : &fd_obj_cb_backup,
47 : &fd_obj_cb_banks,
48 : &fd_obj_cb_progcache,
49 : &fd_obj_cb_rnonce_ss,
50 : &fd_obj_cb_adminctl,
51 : &fd_obj_cb_sleep,
52 : NULL,
53 : };
54 :
55 : configure_stage_t * STAGES[] = {
56 : &fd_cfg_stage_hugetlbfs,
57 : &fd_cfg_stage_sysctl,
58 : &fd_cfg_stage_bonding,
59 : &fd_cfg_stage_ethtool_channels,
60 : &fd_cfg_stage_ethtool_offloads,
61 : &fd_cfg_stage_ethtool_loopback,
62 : &fd_cfg_stage_irq_balance,
63 : &fd_cfg_stage_irq_affinity,
64 : &fd_cfg_stage_sysfs_poll,
65 : &fd_cfg_stage_kworkers,
66 : &fd_cfg_stage_cpuset,
67 : &fd_cfg_stage_nohz_full,
68 : &fd_cfg_stage_rcu_nocbs,
69 : &fd_cfg_stage_console,
70 : &fd_cfg_stage_snapshots,
71 : NULL,
72 : };
73 :
74 : FD_STATIC_ASSERT( sizeof(STAGES)/sizeof(STAGES[0])<=CONFIGURE_STAGE_COUNT, stage_array_larger_than_configure_stage_count );
75 :
76 :
77 : extern fd_topo_run_tile_t fd_tile_net;
78 : extern fd_topo_run_tile_t fd_tile_netlnk;
79 : extern fd_topo_run_tile_t fd_tile_mlx5;
80 : extern fd_topo_run_tile_t fd_tile_sock;
81 : extern fd_topo_run_tile_t fd_tile_quic;
82 : extern fd_topo_run_tile_t fd_tile_verify;
83 : extern fd_topo_run_tile_t fd_tile_dedup;
84 : extern fd_topo_run_tile_t fd_tile_resolv;
85 : extern fd_topo_run_tile_t fd_tile_pack;
86 : extern fd_topo_run_tile_t fd_tile_execle;
87 : extern fd_topo_run_tile_t fd_tile_poh;
88 : extern fd_topo_run_tile_t fd_tile_motor;
89 : extern fd_topo_run_tile_t fd_tile_shred;
90 : extern fd_topo_run_tile_t fd_tile_sign;
91 : extern fd_topo_run_tile_t fd_tile_metric;
92 : extern fd_topo_run_tile_t fd_tile_event;
93 : extern fd_topo_run_tile_t fd_tile_diag;
94 : extern fd_topo_run_tile_t fd_tile_waker;
95 : extern fd_topo_run_tile_t fd_tile_gui;
96 : extern fd_topo_run_tile_t fd_tile_rpc;
97 : extern fd_topo_run_tile_t fd_tile_bundle;
98 : extern fd_topo_run_tile_t fd_tile_genesi;
99 : extern fd_topo_run_tile_t fd_tile_ipecho;
100 : extern fd_topo_run_tile_t fd_tile_admin;
101 :
102 : extern fd_topo_run_tile_t fd_tile_gossvf;
103 : extern fd_topo_run_tile_t fd_tile_gossip;
104 : extern fd_topo_run_tile_t fd_tile_repair;
105 : extern fd_topo_run_tile_t fd_tile_rotor;
106 : extern fd_topo_run_tile_t fd_tile_rserve;
107 : extern fd_topo_run_tile_t fd_tile_replay;
108 : extern fd_topo_run_tile_t fd_tile_execrp;
109 : extern fd_topo_run_tile_t fd_tile_txsend;
110 : extern fd_topo_run_tile_t fd_tile_tower;
111 : extern fd_topo_run_tile_t fd_tile_votor;
112 : extern fd_topo_run_tile_t fd_tile_accdb;
113 : extern fd_topo_run_tile_t fd_tile_solcap;
114 :
115 : extern fd_topo_run_tile_t fd_tile_snapct;
116 : extern fd_topo_run_tile_t fd_tile_snapld;
117 : extern fd_topo_run_tile_t fd_tile_snapdc;
118 : extern fd_topo_run_tile_t fd_tile_snapin;
119 : extern fd_topo_run_tile_t fd_tile_snapwr;
120 : extern fd_topo_run_tile_t fd_tile_snapmk;
121 : extern fd_topo_run_tile_t fd_tile_snapzp;
122 : extern fd_topo_run_tile_t fd_tile_snaprd;
123 : extern fd_topo_run_tile_t fd_tile_snapsv;
124 :
125 : fd_topo_run_tile_t * TILES[] = {
126 : &fd_tile_net,
127 : &fd_tile_netlnk,
128 : &fd_tile_mlx5,
129 : &fd_tile_sock,
130 : &fd_tile_quic,
131 : &fd_tile_verify,
132 : &fd_tile_dedup,
133 : &fd_tile_resolv,
134 : &fd_tile_pack,
135 : &fd_tile_execle,
136 : &fd_tile_shred,
137 : &fd_tile_sign,
138 : &fd_tile_metric,
139 : &fd_tile_event,
140 : &fd_tile_diag,
141 : &fd_tile_waker,
142 : &fd_tile_gui,
143 : &fd_tile_rpc,
144 : &fd_tile_bundle,
145 : &fd_tile_gossvf,
146 : &fd_tile_gossip,
147 : &fd_tile_repair,
148 : &fd_tile_rotor,
149 : &fd_tile_rserve,
150 : &fd_tile_replay,
151 : &fd_tile_execrp,
152 : &fd_tile_poh,
153 : &fd_tile_motor,
154 : &fd_tile_txsend,
155 : &fd_tile_tower,
156 : &fd_tile_votor,
157 : &fd_tile_accdb,
158 : &fd_tile_snapct,
159 : &fd_tile_snapld,
160 : &fd_tile_snapdc,
161 : &fd_tile_snapin,
162 : &fd_tile_snapwr,
163 : &fd_tile_genesi,
164 : &fd_tile_ipecho,
165 : &fd_tile_admin,
166 : &fd_tile_solcap,
167 : &fd_tile_snapmk,
168 : &fd_tile_snapzp,
169 : &fd_tile_snaprd,
170 : &fd_tile_snapsv,
171 : NULL,
172 : };
173 :
174 : extern action_t fd_action_run;
175 : extern action_t fd_action_run1;
176 : extern action_t fd_action_configure;
177 : extern action_t fd_action_monitor;
178 : extern action_t fd_action_keys;
179 : extern action_t fd_action_ready;
180 : extern action_t fd_action_mem;
181 : extern action_t fd_action_netconf;
182 : extern action_t fd_action_help;
183 : extern action_t fd_action_metrics;
184 : extern action_t fd_action_version;
185 : extern action_t fd_action_shred_version;
186 : extern action_t fd_action_watch;
187 : extern action_t fd_action_add_authorized_voter;
188 : extern action_t fd_action_remove_all_authorized_voters;
189 : extern action_t fd_action_set_identity;
190 : extern action_t fd_action_get_identity;
191 : extern action_t fd_action_ps;
192 : extern action_t fd_action_monitor_gossip;
193 : extern action_t fd_action_snapshot_create;
194 :
195 : action_t * ACTIONS[] = {
196 : &fd_action_run,
197 : &fd_action_run1,
198 : &fd_action_configure,
199 : &fd_action_monitor,
200 : &fd_action_keys,
201 : &fd_action_ready,
202 : &fd_action_mem,
203 : &fd_action_netconf,
204 : &fd_action_help,
205 : &fd_action_metrics,
206 : &fd_action_version,
207 : &fd_action_shred_version,
208 : &fd_action_add_authorized_voter,
209 : &fd_action_remove_all_authorized_voters,
210 : &fd_action_watch,
211 : &fd_action_monitor_gossip,
212 : &fd_action_set_identity,
213 : &fd_action_get_identity,
214 : &fd_action_ps,
215 : &fd_action_snapshot_create,
216 : NULL,
217 : };
218 :
219 : int
220 : main( int argc,
221 24 : char ** argv ) {
222 24 : fd_config_file_t _default = fd_config_file_default();
223 24 : fd_config_file_t testnet = fd_config_file_testnet();
224 24 : fd_config_file_t devnet = fd_config_file_devnet();
225 24 : fd_config_file_t mainnet = fd_config_file_mainnet();
226 :
227 24 : fd_config_file_t * configs[] = {
228 24 : &_default,
229 24 : &testnet,
230 24 : &devnet,
231 24 : &mainnet,
232 24 : NULL
233 24 : };
234 :
235 24 : return fd_main( argc, argv, 1, configs, fd_topo_initialize );
236 24 : }
237 :
238 : /* Kind of a hack for now, we sometimes want to view bench generation
239 : in the monitor binary, but it's not part of the production binary. */
240 :
241 : void
242 : add_bench_topo( fd_topo_t * topo,
243 : char const * affinity,
244 : ulong benchg_tile_cnt,
245 : ulong benchs_tile_cnt,
246 : ulong accounts_cnt,
247 : int transaction_mode,
248 : float contending_fraction,
249 : float cu_price_spread,
250 : ulong conn_cnt,
251 : ushort send_to_port,
252 : uint send_to_ip_addr,
253 : ushort rpc_port,
254 : uint rpc_ip_addr,
255 0 : int reserve_agave_cores ) {
256 0 : (void)topo;
257 0 : (void)affinity;
258 0 : (void)benchg_tile_cnt;
259 0 : (void)benchs_tile_cnt;
260 0 : (void)accounts_cnt;
261 0 : (void)transaction_mode;
262 0 : (void)contending_fraction;
263 0 : (void)cu_price_spread;
264 0 : (void)conn_cnt;
265 0 : (void)send_to_port;
266 0 : (void)send_to_ip_addr;
267 0 : (void)rpc_port;
268 0 : (void)rpc_ip_addr;
269 0 : (void)reserve_agave_cores;
270 0 : }
|
