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-gateway/src/server_ws.rs
Items
const DEFAULT_GATEWAY_MAX_WS_CONNECTIONS const DEFAULT_GATEWAY_MAX_WS_MESSAGE_BYTES const DEFAULT_GATEWAY_WS_OUTBOX_CAP const MAX_GATEWAY_MAX_WS_CONNECTIONS const MAX_GATEWAY_MAX_WS_MESSAGE_BYTES const MAX_GATEWAY_WS_OUTBOX_CAP const GATEWAY_WS_IDLE_POLL_MS const GATEWAY_WS_WRITE_TIMEOUT_SECS struct WsConnectionGuard struct WsHandshakeMetadata impl WsConnectionGuard impl Drop for WsConnectionGuard struct WsSession impl WsSession impl Drop for WsSession struct WsHandlerContext enum WsReadResult enum WsLoopStep impl WsLoopStep type WsJsonHandler const JSON_PAYLOAD_HANDLERS enum UnauthenticatedWsDispatch
Functions
By call-graph weight (PageRank; 1.0 is the average function). 94 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| send_ws_textsrc/server_ws.rs:256 | fn | 5 | 2 | 6 | 0 | 3.7 | |
| parse_positive_usizesrc/server_ws.rs:61 | fn | 3 | 1 | 2 | 0 | 3 | |
| parse_bounded_usize_envsrc/server_ws.rs:69 | fn | 4 | 1 | 3 | 2 | 2.8 | |
| send_ws_jsonsrc/server_ws.rs:262 | fn | 3 | 1 | 7 | 1 | 2.6 | |
| parse_bounded_usizesrc/server_ws.rs:65 | fn | 3 | 1 | 3 | 1 | 2.5 | |
| WsLoopStep::into_textsrc/server_ws.rs:248 | method | 6 | 2 | 4 | 0 | 1.5 | |
| handle_direct_rtc_signalsrc/server_ws.rs:515 | fn | 20 | 3 | 2 | 4 | 1.3 | |
| WsConnectionGuard::newsrc/server_ws.rs:50 | method | 3 | 1 | 2 | 0 | 1.1 | |
| gateway_max_ws_message_bytessrc/server_ws.rs:82 | fn | 7 | 1 | 1 | 1 | 1 | |
| WsSession::registered_peersrc/server_ws.rs:179 | method | 3 | 1 | 4 | 0 | 1 | |
| gateway_ws_outbox_capsrc/server_ws.rs:90 | fn | 3 | 1 | 1 | 1 | 1 | |
| WsSession::register_peersrc/server_ws.rs:183 | method | 10 | 4 | 3 | 3 | 1 | |
| handle_gateway_routesrc/server_ws.rs:671 | fn | 55 | 4 | 2 | 12 | 1 | |
| unauthenticated_ws_dispatchsrc/server_ws.rs:1067 | fn | 14 | 3 | 2 | 1 | 1 | |
| websocket_auth_enforcedsrc/server_ws.rs:307 | fn | 3 | 1 | 4 | 1 | 0.9 | |
| handle_compute_capabilitysrc/server_ws.rs:376 | fn | 31 | 5 | 1 | 7 | 0.9 | |
| handle_world_posesrc/server_ws.rs:416 | fn | 27 | 3 | 1 | 6 | 0.9 | |
| handle_tunnel_envelopesrc/server_ws.rs:484 | fn | 9 | 2 | 1 | 2 | 0.9 | |
| handle_rtc_signalingsrc/server_ws.rs:594 | fn | 29 | 2 | 1 | 7 | 0.9 | |
| handle_compute_proofsrc/server_ws.rs:624 | fn | 12 | 2 | 1 | 2 | 0.9 | |
| handle_continuation_messagesrc/server_ws.rs:637 | fn | 33 | 3 | 1 | 3 | 0.9 | |
| handle_tunnel_forwarded_requestsrc/server_ws.rs:444 | fn | 19 | 1 | 1 | 2 | 0.9 | |
| handle_tunnel_forwarded_responsesrc/server_ws.rs:464 | fn | 19 | 1 | 1 | 2 | 0.9 | |
| direct_rtc_targetsrc/server_ws.rs:494 | fn | 8 | 1 | 2 | 0 | 0.9 | |
| websocket_request_access_tokensrc/server_ws.rs:1049 | fn | 10 | 1 | 2 | 2 | 0.9 | |
| WsSession::register_peer_oncesrc/server_ws.rs:194 | method | 6 | 2 | 2 | 1 | 0.9 | |
| handle_rtc_peer_joinedsrc/server_ws.rs:536 | fn | 11 | 3 | 1 | 2 | 0.8 | |
| websocket_transport_authorizedsrc/server_ws.rs:311 | fn | 24 | 4 | 4 | 4 | 0.8 | |
| ws_message_resultsrc/server_ws.rs:290 | fn | 9 | 3 | 2 | 1 | 0.8 | |
| route_is_room_connectionsrc/server_ws.rs:124 | fn | 3 | 1 | 2 | 0 | 0.8 | |
| rtc_signal_ack_statussrc/server_ws.rs:574 | fn | 15 | 3 | 2 | 2 | 0.8 | |
| WsLoopStep::from_readsrc/server_ws.rs:236 | method | 7 | 3 | 3 | 0 | 0.8 | |
| WsLoopStep::should_closesrc/server_ws.rs:244 | method | 3 | 1 | 3 | 0 | 0.8 | |
| peer_envelope_authenticates_ws_sessionsrc/server_ws.rs:347 | fn | 4 | 2 | 1 | 0 | 0.8 | |
| target_outside_roomsrc/server_ws.rs:503 | fn | 3 | 1 | 1 | 1 | 0.8 | |
| unregister_left_peer_if_neededsrc/server_ws.rs:507 | fn | 7 | 4 | 1 | 1 | 0.8 | |
| ws_read_error_resultsrc/server_ws.rs:281 | fn | 8 | 3 | 1 | 0 | 0.7 | |
| is_rtc_signaling_payloadsrc/server_ws.rs:548 | fn | 3 | 1 | 2 | 0 | 0.7 | |
| rtc_signal_actionsrc/server_ws.rs:552 | fn | 3 | 1 | 2 | 0 | 0.7 | |
| rtc_signal_peer_idsrc/server_ws.rs:556 | fn | 7 | 1 | 2 | 0 | 0.7 | |
| rtc_ack_oksrc/server_ws.rs:590 | fn | 3 | 1 | 1 | 0 | 0.7 | |
| routesrc/server_ws.rs:1384 | nested fn | 13 | 1 | 1 | 0 | 0.7 | |
| register_verified_peer_envelope_sessionsrc/server_ws.rs:352 | fn | 6 | 2 | 2 | 2 | 0.7 | |
| peer_envelope_requestsrc/server_ws.rs:1123 | fn | 9 | 1 | 2 | 0 | 0.7 | |
| gateway_ws_configsrc/server_ws.rs:94 | fn | 8 | 1 | 1 | 1 | 0.7 | |
| gateway_max_ws_connectionssrc/server_ws.rs:74 | fn | 7 | 1 | 1 | 1 | 0.6 | |
| handle_websocket_connectionsrc/server_ws.rs:934 | fn | 61 | 10 | 1 | 8 | 0.6 | |
| handle_app_ws_messagesrc/server_ws.rs:740 | fn | 12 | 2 | 1 | 3 | 0.6 | |
| send_websocket_auth_requiredsrc/server_ws.rs:336 | fn | 10 | 1 | 2 | 1 | 0.6 | |
| WsSession::newsrc/server_ws.rs:174 | method | 4 | 1 | 2 | 1 | 0.6 | |
| route_actionsrc/server_ws.rs:115 | fn | 8 | 1 | 1 | 0 | 0.6 | |
| room_subscription_idssrc/server_ws.rs:128 | fn | 10 | 1 | 1 | 2 | 0.6 | |
| apply_room_subscription_actionsrc/server_ws.rs:139 | fn | 7 | 4 | 1 | 2 | 0.6 | |
| register_rtc_signal_sourcesrc/server_ws.rs:564 | fn | 9 | 3 | 1 | 2 | 0.6 | |
| WsSession::verified_peer_envelopesrc/server_ws.rs:201 | method | 3 | 1 | 2 | 0 | 0.6 | |
| insert_peer_id_if_missingsrc/server_ws.rs:103 | fn | 11 | 3 | 1 | 0 | 0.6 | |
| sync_room_subscriptionsrc/server_ws.rs:147 | fn | 18 | 3 | 1 | 4 | 0.6 | |
| flush_ws_outboxsrc/server_ws.rs:275 | fn | 5 | 2 | 1 | 1 | 0.6 | |
| read_ws_textsrc/server_ws.rs:300 | fn | 6 | 2 | 1 | 2 | 0.6 | |
| dispatch_ws_textsrc/server_ws.rs:1082 | fn | 36 | 9 | 1 | 9 | 0.6 | |
| configure_websocket_timeoutssrc/server_ws.rs:266 | fn | 8 | 3 | 1 | 0 | 0.6 | |
| dispatch_claimed_websocket_pathsrc/server_ws.rs:996 | fn | 6 | 1 | 1 | 1 | 0.6 | |
| run_websocket_dispatch_loopsrc/server_ws.rs:1003 | fn | 24 | 3 | 1 | 7 | 0.6 | |
| accept_websocket_with_metadatasrc/server_ws.rs:1028 | fn | 20 | 2 | 1 | 3 | 0.6 | |
| handle_peer_execution_envelopesrc/server_ws.rs:359 | fn | 16 | 1 | 1 | 3 | 0.5 | |
| handle_json_payloadsrc/server_ws.rs:850 | fn | 13 | 3 | 1 | 1 | 0.5 | |
| handle_gateway_fallbacksrc/server_ws.rs:864 | fn | 25 | 1 | 1 | 4 | 0.5 | |
| signed_local_peer_envelopesrc/server_ws.rs:1133 | fn | 12 | 1 | 1 | 3 | 0.5 | |
| spawn_websocket_accept_loopsrc/server_ws.rs:890 | fn | 35 | 4 | 1 | 3 | 0.5 | |
| WsConnectionGuard::dropsrc/server_ws.rs:56 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| WsSession::dropsrc/server_ws.rs:207 | trait impl | 5 | 2 | 0 | 1 | 0.5 | |
| handle_compute_capability_jsonsrc/server_ws.rs:771 | fn | 8 | 1 | 0 | 1 | 0.5 | |
| handle_world_pose_jsonsrc/server_ws.rs:780 | fn | 8 | 1 | 0 | 1 | 0.5 | |
| handle_tunnel_envelope_jsonsrc/server_ws.rs:789 | fn | 8 | 1 | 0 | 1 | 0.5 | |
| handle_rtc_signaling_jsonsrc/server_ws.rs:798 | fn | 8 | 1 | 0 | 1 | 0.5 | |
| handle_compute_proof_jsonsrc/server_ws.rs:807 | fn | 8 | 1 | 0 | 1 | 0.5 | |
| handle_continuation_message_jsonsrc/server_ws.rs:816 | fn | 8 | 1 | 0 | 1 | 0.5 | |
| handle_app_ws_message_jsonsrc/server_ws.rs:825 | fn | 15 | 3 | 0 | 3 | 0.5 | |
| handle_gateway_route_jsonsrc/server_ws.rs:841 | fn | 8 | 1 | 0 | 1 | 0.5 | |
| positive_usize_parser_rejects_empty_zero_and_invalid_valuessrc/server_ws.rs:1147 | fn | 8 | 1 | 0 | 1 | 0.5 | |
| bounded_usize_parser_clamps_oversized_valuessrc/server_ws.rs:1157 | fn | 6 | 1 | 0 | 1 | 0.5 | |
| websocket_config_uses_bounded_message_and_frame_sizessrc/server_ws.rs:1165 | fn | 12 | 1 | 0 | 1 | 0.5 | |
| peer_envelope_session_identity_requires_signature_verificationsrc/server_ws.rs:1179 | fn | 35 | 1 | 0 | 8 | 0.5 | |
| websocket_connection_guard_releases_one_slot_on_dropsrc/server_ws.rs:1216 | fn | 8 | 1 | 0 | 1 | 0.5 | |
| rtc_signaling_helpers_accept_camel_and_snake_case_fieldssrc/server_ws.rs:1226 | fn | 23 | 1 | 0 | 4 | 0.5 | |
| direct_rtc_signal_reports_missing_offline_and_room_mismatchsrc/server_ws.rs:1251 | fn | 23 | 1 | 0 | 1 | 0.5 | |
| rtc_signal_ack_statuses_mark_only_successful_delivery_as_oksrc/server_ws.rs:1276 | fn | 8 | 1 | 0 | 2 | 0.5 | |
| websocket_dispatch_helpers_keep_ordersrc/server_ws.rs:1286 | fn | 3 | 1 | 0 | 0 | 0.5 | |
| websocket_handshake_uses_bearer_before_session_cookiesrc/server_ws.rs:1291 | fn | 16 | 1 | 0 | 2 | 0.5 | |
| websocket_transport_gate_preserves_local_off_and_denies_enforced_missing_tokensrc/server_ws.rs:1309 | fn | 12 | 1 | 0 | 5 | 0.5 | |
| unauthenticated_root_messages_only_reach_the_normal_gateway_pipelinesrc/server_ws.rs:1323 | fn | 30 | 2 | 0 | 1 | 0.5 | |
| websocket_loop_steps_classify_read_resultssrc/server_ws.rs:1355 | fn | 16 | 1 | 0 | 3 | 0.5 | |
| websocket_close_frame_terminates_the_dispatch_loopsrc/server_ws.rs:1373 | fn | 8 | 1 | 0 | 4 | 0.5 | |
| room_connection_detection_uses_connection_prefixsrc/server_ws.rs:1383 | fn | 18 | 1 | 0 | 2 | 0.5 |
Source not readable from this process.