1 viewer
rust 1,860,549 · typescript 235,540 · javascript 132,956 · python 20,426 · 6,408 files · digest f04d4637f52b · built in 1.5 s · crystals off
crates/cre8-app-network/src/relay.rs
Items
struct RelayDispatchResult static SESSIONS static ROOM_SESSIONS const DEFAULT_MAX_CHUNK_SIZE const DEFAULT_CHUNK_COLLECTOR_MAX_PENDING_MESSAGES const DEFAULT_CHUNK_COLLECTOR_MAX_PENDING_BYTES struct ChunkedMessage struct ChunkCollector impl ChunkCollector
Functions
By call-graph weight (PageRank; 1.0 is the average function). 51 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| room_session_mapsrc/relay.rs:26 | fn | 4 | 1 | 6 | 0 | 7.6 | |
| session_mapsrc/relay.rs:21 | fn | 4 | 1 | 6 | 0 | 5.2 | |
| unregister_peer_from_all_roomssrc/relay.rs:94 | fn | 13 | 3 | 6 | 1 | 3.4 | |
| broadcast_to_roomsrc/relay.rs:139 | fn | 37 | 8 | 9 | 4 | 3.2 | |
| ChunkCollector::with_limitssrc/relay.rs:478 | method | 8 | 1 | 7 | 0 | 2.5 | |
| try_send_session_messagesrc/relay.rs:41 | fn | 9 | 2 | 4 | 1 | 2.5 | |
| register_peer_sessionsrc/relay.rs:51 | fn | 5 | 2 | 3 | 1 | 2.3 | |
| split_into_chunkssrc/relay.rs:367 | fn | 28 | 2 | 11 | 1 | 2.2 | |
| reassemble_chunkssrc/relay.rs:400 | fn | 7 | 1 | 6 | 5 | 1.9 | |
| ChunkCollector::entry_accepts_chunksrc/relay.rs:528 | method | 4 | 2 | 2 | 0 | 1.8 | |
| register_room_sessionsrc/relay.rs:64 | fn | 12 | 4 | 10 | 2 | 1.8 | |
| send_to_registered_sessionssrc/relay.rs:177 | fn | 22 | 4 | 2 | 2 | 1.6 | |
| broadcast_to_allsrc/relay.rs:202 | fn | 8 | 2 | 3 | 2 | 1.5 | |
| peer_in_roomsrc/relay.rs:108 | fn | 13 | 3 | 4 | 1 | 1.4 | |
| unregister_room_sessionsrc/relay.rs:77 | fn | 16 | 6 | 2 | 1 | 1.4 | |
| send_endpoint_payloadsrc/relay.rs:296 | fn | 39 | 2 | 1 | 1 | 1.4 | |
| ChunkCollector::receivesrc/relay.rs:491 | method | 22 | 4 | 8 | 3 | 1.4 | |
| dispatch_envelope_to_routesrc/relay.rs:244 | fn | 19 | 3 | 4 | 2 | 1.4 | |
| send_to_peersrc/relay.rs:225 | fn | 18 | 6 | 5 | 3 | 1.3 | |
| ChunkCollector::newsrc/relay.rs:474 | method | 3 | 1 | 4 | 1 | 1.2 | |
| unregister_peer_sessionsrc/relay.rs:57 | fn | 6 | 2 | 2 | 2 | 1.2 | |
| remove_peer_from_session_mapsrc/relay.rs:131 | fn | 5 | 2 | 1 | 1 | 1.2 | |
| ChunkCollector::pending_countsrc/relay.rs:534 | method | 3 | 1 | 6 | 0 | 1.1 | |
| dispatch_to_live_sessionsrc/relay.rs:264 | fn | 21 | 6 | 1 | 3 | 1.1 | |
| dispatch_to_endpointsrc/relay.rs:286 | fn | 9 | 2 | 1 | 1 | 1.1 | |
| ChunkCollector::can_receive_chunksrc/relay.rs:514 | method | 6 | 4 | 2 | 0 | 1 | |
| ChunkCollector::can_append_chunksrc/relay.rs:521 | method | 6 | 3 | 2 | 1 | 1 | |
| broadcast_to_all_exceptsrc/relay.rs:214 | fn | 8 | 2 | 2 | 2 | 1 | |
| chunk_reassembly_headersrc/relay.rs:408 | fn | 14 | 4 | 1 | 0 | 0.8 | |
| validate_chunk_setsrc/relay.rs:423 | fn | 12 | 4 | 1 | 0 | 0.8 | |
| sorted_reassembly_chunkssrc/relay.rs:436 | fn | 5 | 1 | 1 | 0 | 0.8 | |
| validate_chunk_sequencesrc/relay.rs:442 | fn | 8 | 3 | 1 | 0 | 0.8 | |
| join_sorted_chunkssrc/relay.rs:451 | fn | 8 | 2 | 1 | 0 | 0.8 | |
| ChunkCollector::evict_stalesrc/relay.rs:543 | method | 14 | 2 | 1 | 1 | 0.6 | |
| room_session_countsrc/relay.rs:122 | fn | 8 | 2 | 0 | 1 | 0.5 | |
| now_unixsrc/relay.rs:359 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| ChunkCollector::pending_bytessrc/relay.rs:538 | method | 3 | 1 | 0 | 0 | 0.5 | |
| test_split_and_reassemblesrc/relay.rs:566 | fn | 11 | 1 | 0 | 2 | 0.5 | |
| test_single_chunksrc/relay.rs:579 | fn | 10 | 1 | 0 | 2 | 0.5 | |
| test_empty_payloadsrc/relay.rs:591 | fn | 8 | 1 | 0 | 2 | 0.5 | |
| test_reassemble_missing_chunksrc/relay.rs:601 | fn | 8 | 1 | 0 | 2 | 0.5 | |
| test_chunk_collectorsrc/relay.rs:611 | fn | 18 | 1 | 0 | 4 | 0.5 | |
| test_collector_multiple_messagessrc/relay.rs:631 | fn | 16 | 1 | 0 | 4 | 0.5 | |
| test_collector_ignores_duplicate_chunks_without_dropping_messagesrc/relay.rs:649 | fn | 15 | 1 | 0 | 4 | 0.5 | |
| test_collector_rejects_new_messages_past_pending_limitsrc/relay.rs:666 | fn | 10 | 1 | 0 | 4 | 0.5 | |
| test_collector_rejects_chunks_past_pending_byte_limitsrc/relay.rs:678 | fn | 9 | 1 | 0 | 4 | 0.5 | |
| test_collector_releases_pending_bytes_on_complete_and_evictsrc/relay.rs:689 | fn | 24 | 1 | 0 | 5 | 0.5 | |
| test_send_to_peer_removes_dead_session_from_roomssrc/relay.rs:715 | fn | 10 | 1 | 0 | 5 | 0.5 | |
| test_broadcast_to_room_prunes_dead_senderssrc/relay.rs:727 | fn | 15 | 1 | 0 | 5 | 0.5 | |
| test_full_session_outbox_is_prunedsrc/relay.rs:744 | fn | 10 | 1 | 0 | 4 | 0.5 | |
| test_large_payloadsrc/relay.rs:756 | fn | 10 | 1 | 0 | 2 | 0.5 |
Source not readable from this process.