1 viewer

rust 1,859,748 · typescript 235,215 · javascript 132,932 · python 20,426 · 6,405 files · digest 3ddca2872e6e · built in 1.4 s · crystals off

crates/cre8-app-atom/src/sync.rs

cre8-app-atom · module sync · src · 3,748 lines (3,486 code, 109 comment) · sha d60500d3c12901a7

Items

const MAX_FETCH_BYTES const MAX_CORPUS_RESPONSE_BYTES const MAX_FAILURES const CORPUS_FETCH_SCHEMA const CORPUS_FETCH_RESPONSE_SCHEMA const TRANSFER_RECEIPT_SCHEMA const SEMANTIC_DISCOVERY_SCHEMA const SEMANTIC_DISCOVERY_RESPONSE_SCHEMA const SEMANTIC_CLOSURE_DISCOVERY_SCHEMA const SEMANTIC_CLOSURE_DISCOVERY_RESPONSE_SCHEMA const SEMANTIC_CLOSURE_MANIFEST_SCHEMA const SEMANTIC_DEPENDENCY_SCHEMA const SEMANTIC_MANIFEST_SCHEMA const MAX_SEMANTIC_CLOSURE_DEPTH const SEMANTIC_ATOM_KIND_TAG const MAX_AUTH_CLOCK_SKEW_MS const MAX_AVAILABILITY_LEASE_MS static AUTH_REQUEST_NONCE_SEQUENCE static AUTH_REQUEST_NONCE_EPOCH_NANOS trait AtomSource impl AtomSource for F struct PullReport struct SemanticDiscoveryItem struct SemanticDiscoveryResponse struct SemanticDiscoverRequest struct SemanticDiscoveryResponseProof struct SemanticClosureItem struct SemanticClosureEdge struct SemanticClosureDiscoverRequest struct SemanticClosureDiscoveryResponse struct SemanticClosureDiscoveryResponseProof struct PullSemanticClosureRequest struct SemanticClosurePullReport struct PullSemanticsRequest struct SemanticPullReport struct Want struct CorpusFetchRequest struct CorpusFetchResponseProof struct PullTreeRequest struct AuthenticatedCorpusSource impl AuthenticatedCorpusSource impl AtomSource for AuthenticatedCorpusSource struct SemanticDiscoveryClient impl SemanticDiscoveryClient struct SemanticClosureDiscoveryClient impl SemanticClosureDiscoveryClient struct SemanticClosureSelection static NONCES struct MapSource impl AtomSource for MapSource struct PricedSource impl AtomSource for PricedSource struct FsGateGuard impl Drop for FsGateGuard

Functions

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

function	kind	lines	cyclomatic	callers	callees	weight
AuthenticatedCorpusSource::fetch_partssrc/sync.rs:620	method	92	11	3	11	1.8
fresh_authenticated_request_noncesrc/sync.rs:60	fn	6	1	4	1	1.1
handle_pull_tree_with_contextsrc/sync.rs:2220	fn	201	27	3	13	1.1
handle_pull_semantics_with_contextsrc/sync.rs:2548	fn	209	28	2	12	1
handle_pull_semantic_closure_with_contextsrc/sync.rs:2766	fn	266	35	2	13	1
select_semantic_dependency_closuresrc/sync.rs:1184	fn	73	20	4	1	1
build_transfer_receiptsrc/sync.rs:2183	fn	32	1	2	0	1
pull_tree_withsrc/sync.rs:443	fn	96	13	5	9	1
validate_semantic_discovery_response_valuesrc/sync.rs:1258	fn	51	14	2	1	1
validate_semantic_closure_response_structuresrc/sync.rs:1403	fn	120	38	2	1	1
inflate_partsrc/sync.rs:345	fn	10	3	3	0	0.9
verify_and_store_semantic_partsrc/sync.rs:2422	fn	23	4	2	2	0.9
canonical_fetch_requestsrc/sync.rs:1016	fn	3	1	5	0	0.9
remote_corpussrc/sync.rs:3076	fn	68	1	4	2	0.9
claim_corpus_noncesrc/sync.rs:1715	fn	12	2	5	0	0.9
semantic_manifest_inventorysrc/sync.rs:1046	fn	60	15	2	4	0.8
local_peer_seedsrc/sync.rs:2163	fn	10	1	6	0	0.8
error_jsonsrc/sync.rs:3033	fn	8	1	6	0	0.8
canonical_semantic_discover_requestsrc/sync.rs:1024	fn	3	1	4	0	0.8
canonical_semantic_closure_discover_requestsrc/sync.rs:1032	fn	3	1	4	0	0.8
auth_contextsrc/sync.rs:3241	fn	33	1	4	2	0.7
response_headersrc/sync.rs:1524	fn	3	1	4	0	0.7
AuthenticatedCorpusSource::optionssrc/sync.rs:611	method	8	1	3	0	0.7
resolve_peer_endpointsrc/sync.rs:2135	fn	27	10	3	3	0.7
trusted_peer_public_keysrc/sync.rs:2174	fn	8	1	3	0	0.7
pull_semantic_atomssrc/sync.rs:2450	fn	64	14	3	2	0.7
plan_semantic_missing_atomssrc/sync.rs:2515	fn	23	7	3	3	0.7
normalize_route_endpointsrc/sync.rs:2117	fn	12	5	1	0	0.7
debug_peer_url_enabledsrc/sync.rs:2130	fn	4	2	1	0	0.7
canonical_fetch_responsesrc/sync.rs:1020	fn	3	1	3	0	0.7
semantic_closure_manifest_inventorysrc/sync.rs:1111	fn	62	14	2	2	0.7
manifest_inventorysrc/sync.rs:1728	fn	55	9	2	4	0.7
handle_corpus_fetchsrc/sync.rs:1784	fn	90	20	2	18	0.7
handle_semantic_discoversrc/sync.rs:1879	fn	109	18	1	15	0.6
handle_semantic_closure_discoversrc/sync.rs:1992	fn	124	16	1	17	0.6
verify_and_storesrc/sync.rs:318	fn	26	7	1	2	0.6
verify_corpus_fetch_authsrc/sync.rs:1532	fn	52	15	2	4	0.6
canonical_semantic_closure_discovery_responsesrc/sync.rs:1036	fn	5	1	3	0	0.6
verify_semantic_discover_authsrc/sync.rs:1585	fn	61	19	2	4	0.6
verify_semantic_closure_discover_authsrc/sync.rs:1647	fn	67	23	2	4	0.6
request_headersrc/sync.rs:1528	fn	3	1	3	0	0.6
pull_wavesrc/sync.rs:357	fn	84	17	1	4	0.6
canonical_semantic_discovery_responsesrc/sync.rs:1028	fn	3	1	2	0	0.6
validate_semantic_closure_discovery_response_valuesrc/sync.rs:1310	fn	88	26	1	2	0.5
AtomSource::negotiatesrc/sync.rs:73	trait default	3	1	0	0	0.5
AtomSource::last_fetch_wire_bytessrc/sync.rs:82	trait default	3	1	0	0	0.5
AtomSource::fetch_batchsrc/sync.rs:86	trait default	9	2	0	0	0.5
F::fetch_onesrc/sync.rs:101	trait impl	3	1	0	0	0.5
default_desired_replicassrc/sync.rs:580	fn	3	1	0	0	0.5
default_minimum_replicassrc/sync.rs:584	fn	3	1	0	0	0.5
default_availability_lease_mssrc/sync.rs:588	fn	3	1	0	0	0.5
AuthenticatedCorpusSource::negotiatesrc/sync.rs:715	trait impl	7	3	0	1	0.5
AuthenticatedCorpusSource::fetch_onesrc/sync.rs:723	trait impl	20	7	0	1	0.5
AuthenticatedCorpusSource::fetch_batchsrc/sync.rs:744	trait impl	3	1	0	1	0.5
AuthenticatedCorpusSource::last_fetch_wire_bytessrc/sync.rs:748	trait impl	3	1	0	0	0.5
SemanticDiscoveryClient::discoversrc/sync.rs:770	method	100	11	0	10	0.5
SemanticClosureDiscoveryClient::discoversrc/sync.rs:892	method	122	11	0	10	0.5
handle_pull_treesrc/sync.rs:2216	fn	3	1	0	1	0.5
handle_pull_semanticssrc/sync.rs:2539	fn	3	1	0	1	0.5
handle_pull_semantic_closuresrc/sync.rs:2758	fn	3	1	0	1	0.5
MapSource::fetch_onesrc/sync.rs:3054	trait impl	3	1	0	0	0.5
MapSource::fetch_batchsrc/sync.rs:3057	trait impl	17	3	0	0	0.5
batched_pull_fetches_compressed_then_reuses_everythingsrc/sync.rs:3146	fn	27	2	0	4	0.5
tampered_batch_parts_are_rejected_by_addresssrc/sync.rs:3175	fn	14	1	0	4	0.5
warm_sync_repairs_a_corrupt_local_atom_instead_of_reusing_itsrc/sync.rs:3191	fn	17	1	0	5	0.5
priced_and_deferred_parts_fall_back_to_single_fetchsrc/sync.rs:3210	fn	30	1	0	4	0.5
PricedSource::fetch_onesrc/sync.rs:3220	trait impl	3	1	0	0	0.5
PricedSource::fetch_batchsrc/sync.rs:3223	trait impl	10	3	0	0	0.5
corpus_fetch_auth_accepts_trusted_signature_and_rejects_tamperingsrc/sync.rs:3276	fn	20	1	0	5	0.5
manifest_inventory_rejects_ambiguous_materialization_branchessrc/sync.rs:3298	fn	38	1	0	3	0.5
corpus_fetch_handler_binds_signature_scope_manifest_inventory_and_noncesrc/sync.rs:3338	fn	133	1	0	17	0.5
FsGateGuard::dropsrc/sync.rs:3343	trait impl	3	1	0	0	0.5
transfer_receipt_hash_covers_warm_zero_payload_metricssrc/sync.rs:3473	fn	28	1	0	1	0.5
semantic_discovery_rejects_invalid_signaturesrc/sync.rs:3503	fn	22	1	0	6	0.5
semantic_discovery_nonce_is_single_usesrc/sync.rs:3527	fn	5	1	0	3	0.5
semantic_discovery_response_is_exact_query_and_never_enumeratessrc/sync.rs:3534	fn	32	1	0	1	0.5
semantic_payload_tamper_is_rejected_before_storesrc/sync.rs:3568	fn	12	1	0	4	0.5
semantic_warm_pull_plans_only_local_missing_atomssrc/sync.rs:3582	fn	29	1	0	6	0.5
semantic_closure_bfs_is_deterministic_and_sortedsrc/sync.rs:3613	fn	19	1	0	3	0.5
semantic_closure_fails_closed_at_depth_and_atom_boundssrc/sync.rs:3634	fn	16	1	0	3	0.5
semantic_closure_rejects_malformed_dependency_mapssrc/sync.rs:3652	fn	30	2	0	3	0.5
semantic_closure_response_rejects_paths_and_unsolicited_atomssrc/sync.rs:3684	fn	14	1	0	1	0.5
semantic_closure_auth_rejects_stale_and_wrong_signaturesrc/sync.rs:3700	fn	33	1	0	6	0.5
semantic_closure_nonce_is_single_usesrc/sync.rs:3735	fn	5	1	0	3	0.5
semantic_closure_client_nonces_are_unique_for_identical_rapid_requestssrc/sync.rs:3742	fn	6	1	0	1	0.5

Source not readable from this process.