1 viewer

rust 1,961,941 · typescript 233,850 · javascript 141,145 · python 22,871 · 6,801 files · digest 6d882eacc8db · built in 12.5 s · crystals off

crates/cre8-app-protocol/src/connection/execute.rs

cre8-app-protocol · module connection::execute · src · 2,634 lines (2,365 code, 49 comment) · sha ff49bfe149a6b7ed

Items

const PLANNER_HISTORY_WINDOW struct PlannerHistoricalSignals struct PlannerLatencyHistory struct ExecuteTarget struct ExecutePlanning struct ExecuteRunResult struct ExecutePostExecution enum ProtocolRouteHandler impl ProtocolRouteHandler struct ProtocolRoute const PROTOCOL_ROUTES

Functions

By call-graph weight (PageRank; 1.0 is the average function). 99 functions in all.

function	kind	lines	cyclomatic	callers	callees	weight
with_protocol_storesrc/connection/execute.rs:280	fn	6	1	10	1	3.2
protocol_catalogsrc/connection/execute.rs:49	fn	3	1	6	1	2.5
delegate_or_localsrc/connection/execute.rs:965	fn	3	1	3	0	1.7
short_label_idsrc/connection/execute.rs:444	fn	7	2	2	0	1.5
replan_dispatch_strategysrc/connection/execute.rs:1011	fn	21	4	3	0	1.5
create_conflict_responsesrc/connection/execute.rs:110	fn	55	5	5	0	1.4
legacy_execution_cache_keysrc/connection/execute.rs:1831	fn	6	1	2	1	1.3
descriptor_fixturesrc/connection/execute.rs:2557	fn	17	1	4	0	1.3
read_public_input_limbssrc/connection/execute.rs:2371	fn	15	2	1	0	1.1
protocol_status_responsesrc/connection/execute.rs:80	fn	29	3	1	4	1.1
ProtocolRouteHandler::dispatchsrc/connection/execute.rs:2438	method	13	4	1	1	1.1
parse_distributed_result_valuesrc/connection/execute.rs:1033	fn	9	3	1	0	1
percentile_sortedsrc/connection/execute.rs:435	fn	8	2	1	0	1
node_function_symbolssrc/connection/execute.rs:593	fn	17	5	1	0	1
protocol_get_responsesrc/connection/execute.rs:60	fn	9	1	1	1	0.9
latest_resolvable_ir_hashsrc/connection/execute.rs:287	fn	19	5	1	3	0.8
protocol_id_as_ir_hashsrc/connection/execute.rs:312	fn	4	1	1	1	0.8
dispatch_strategy_labelsrc/connection/execute.rs:990	fn	9	5	2	0	0.8
planner_mode_labelsrc/connection/execute.rs:403	fn	10	6	3	0	0.8
resolve_ir_hash_for_protocolsrc/connection/execute.rs:317	fn	7	2	1	2	0.7
execute_cache_aliasessrc/connection/execute.rs:1882	fn	12	2	1	1	0.7
is_empty_truth_fallbacksrc/connection/execute.rs:307	fn	4	2	1	0	0.7
decode_proof_hexsrc/connection/execute.rs:2362	fn	6	1	1	0	0.7
protocol_verify_public_inputssrc/connection/execute.rs:2389	fn	21	1	1	1	0.7
should_attempt_midflight_replansrc/connection/execute.rs:1000	fn	10	7	1	0	0.7
preferred_dispatch_peersrc/connection/execute.rs:961	fn	3	1	1	0	0.6
plan_shard_chain_strategysrc/connection/execute.rs:969	fn	13	3	1	1	0.6
plan_gpu_strategysrc/connection/execute.rs:983	fn	6	2	1	1	0.6
handle_distributed_successsrc/connection/execute.rs:1630	fn	38	3	1	1	0.6
maybe_replan_distributedsrc/connection/execute.rs:1669	fn	27	3	1	3	0.6
planner_latency_historysrc/connection/execute.rs:695	fn	33	7	1	1	0.6
apply_planner_latency_historysrc/connection/execute.rs:729	fn	19	5	1	1	0.6
apply_planner_replan_historysrc/connection/execute.rs:749	fn	22	5	1	1	0.6
apply_planner_runtime_historysrc/connection/execute.rs:772	fn	25	5	1	1	0.6
ranked_region_contributorssrc/connection/execute.rs:452	fn	37	2	1	1	0.6
ranked_function_contributorssrc/connection/execute.rs:490	fn	37	2	1	0	0.6
measured_region_contributorssrc/connection/execute.rs:528	fn	64	8	1	1	0.6
measured_function_contributorssrc/connection/execute.rs:611	fn	57	6	1	1	0.6
plan_mode_to_dispatch_strategysrc/connection/execute.rs:946	fn	14	4	1	4	0.6
run_distributed_dispatch_loopsrc/connection/execute.rs:1594	fn	35	6	1	4	0.6
seed_execute_memorysrc/connection/execute.rs:1511	fn	9	2	1	3	0.6
try_execute_distributedsrc/connection/execute.rs:1521	fn	72	5	1	5	0.6
run_local_executesrc/connection/execute.rs:1697	fn	44	1	1	2	0.6
open_storesrc/connection/execute.rs:275	fn	4	1	1	2	0.6
planner_historical_signals_for_ir_hashsrc/connection/execute.rs:669	fn	16	1	1	4	0.6
resolve_ir_hash_or_fetchsrc/connection/execute.rs:1285	fn	30	4	1	2	0.6
apply_planning_success_ratesrc/connection/execute.rs:1389	fn	5	3	1	0	0.6
apply_planning_replan_ratesrc/connection/execute.rs:1395	fn	7	2	1	0	0.6
apply_planning_io_waitsrc/connection/execute.rs:1403	fn	8	2	1	0	0.6
apply_planning_hotspot_ratesrc/connection/execute.rs:1412	fn	7	2	1	0	0.6
apply_planning_tail_ratiosrc/connection/execute.rs:1420	fn	9	2	1	0	0.6
apply_planning_error_ratesrc/connection/execute.rs:1430	fn	8	2	1	0	0.6
apply_planning_cache_ratesrc/connection/execute.rs:1439	fn	6	2	1	0	0.6
broadcast_attestationsrc/connection/execute.rs:334	fn	68	7	1	5	0.5
cache_execute_resultsrc/connection/execute.rs:1838	fn	43	4	1	2	0.5
record_execute_observationsrc/connection/execute.rs:1895	fn	35	1	1	2	0.5
execute_local_quorum_statussrc/connection/execute.rs:1931	fn	11	1	1	1	0.5
record_execute_runtime_metricssrc/connection/execute.rs:1943	fn	51	1	1	12	0.5
has_existing_bindingsrc/connection/execute.rs:53	fn	6	1	1	0	0.5
upsert_create_app_manifestsrc/connection/execute.rs:166	fn	24	2	1	2	0.5
existing_protocol_for_createsrc/connection/execute.rs:191	fn	6	1	1	1	0.5
create_catalog_countssrc/connection/execute.rs:198	fn	4	1	1	1	0.5
protocol_create_success_responsesrc/connection/execute.rs:203	fn	20	1	1	0	0.5
load_planner_feedback_for_protocolsrc/connection/execute.rs:414	fn	4	1	1	2	0.5
hypergraph_planning_snapshot_for_executesrc/connection/execute.rs:798	fn	67	11	1	6	0.5
peer_estimates_for_ir_hashsrc/connection/execute.rs:866	fn	79	11	1	2	0.5
execute_min_peers_requiredsrc/connection/execute.rs:1353	fn	11	1	1	0	0.5
apply_execute_planning_snapshotsrc/connection/execute.rs:1365	fn	23	3	1	7	0.5
append_execute_planner_outcomesrc/connection/execute.rs:1995	fn	64	3	1	5	0.5
update_execute_runtime_contributorssrc/connection/execute.rs:2060	fn	49	5	1	4	0.5
execute_runtime_metricssrc/connection/execute.rs:2110	fn	25	3	1	0	0.5
invocation_id_for_tracesrc/connection/execute.rs:1191	fn	3	1	1	0	0.5
prepare_execute_targetsrc/connection/execute.rs:1239	fn	45	4	1	6	0.5
plan_protocol_executionsrc/connection/execute.rs:1316	fn	36	2	1	11	0.5
record_initial_execute_plansrc/connection/execute.rs:1446	fn	28	1	1	5	0.5
execute_protocol_plansrc/connection/execute.rs:1475	fn	35	2	1	5	0.5
register_execute_receipt_aliasessrc/connection/execute.rs:1742	fn	8	5	1	1	0.5
checkpoint_execute_memorysrc/connection/execute.rs:1751	fn	16	2	1	2	0.5
finish_protocol_executionsrc/connection/execute.rs:1768	fn	59	3	1	9	0.5
append_execute_summary_diagnosticssrc/connection/execute.rs:2136	fn	31	4	1	0	0.5
build_protocol_execute_responsesrc/connection/execute.rs:2168	fn	24	1	1	0	0.5
protocol_list_responsesrc/connection/execute.rs:70	fn	9	1	0	1	0.5
protocol_create_responsesrc/connection/execute.rs:224	fn	46	4	0	9	0.5
protocol_detail_responsesrc/connection/execute.rs:1043	fn	64	1	0	4	0.5
protocol_similar_responsesrc/connection/execute.rs:1108	fn	22	1	0	1	0.5
protocol_execute_responsesrc/connection/execute.rs:1131	fn	57	3	0	11	0.5
execute_planner_payloadsrc/connection/execute.rs:2193	fn	31	1	0	0	0.5
execute_planner_hypergraph_payloadsrc/connection/execute.rs:2225	fn	20	1	0	0	0.5
execute_receipt_payloadsrc/connection/execute.rs:2246	fn	19	1	0	0	0.5
execute_consensus_payloadsrc/connection/execute.rs:2266	fn	9	1	0	0	0.5
protocol_symbol_using_responsesrc/connection/execute.rs:2276	fn	15	1	0	1	0.5
protocol_prove_responsesrc/connection/execute.rs:2294	fn	65	3	0	5	0.5
protocol_verify_responsesrc/connection/execute.rs:2413	fn	15	2	0	2	0.5
protocol_get_action_responsesrc/connection/execute.rs:2459	fn	7	1	0	1	0.5
protocol_graph_patch_responsesrc/connection/execute.rs:2545	fn	6	1	0	1	0.5
create_conflict_response_rejects_existing_protocol_without_overwritesrc/connection/execute.rs:2576	fn	11	1	0	2	0.5
create_conflict_response_requires_explicit_version_changesrc/connection/execute.rs:2589	fn	15	1	0	2	0.5
create_conflict_response_requires_owner_revision_for_version_changesrc/connection/execute.rs:2606	fn	15	1	0	2	0.5
create_conflict_response_allows_same_version_or_authorized_version_changesrc/connection/execute.rs:2623	fn	11	1	0	2	0.5

Source not readable from this process.