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-conduit/src/streaming/audio_stream.rs
Items
struct AudioChunk struct InferredAudioChunkMeta struct Mp3AudioInfo struct Mp3FrameInfo enum AudioRecv const AUDIO_PRODUCER_OWNER_LEGACY const AUDIO_PRODUCER_OWNER_CONDUIT_AUDIO_STATION const AUDIO_PRODUCER_OWNER_AUDIO_BACKGROUND const AUDIO_PRODUCER_OWNER_RADIO struct AudioProducerLease struct AudioProducerClaim struct AudioListenerLimit struct AudioListenerLease impl AudioListenerLease impl Drop for AudioListenerLease static NEXT_AUDIO_PRODUCER_GENERATION const MAX_MP3_PROBE_BYTES struct AudioChannelInner struct AudioChannelFrame struct AudioBacklogFrame struct AudioStreamStats impl AudioStreamStats struct AudioChunkChannel struct AudioChunkReceiver struct AudioProducerTelemetry struct AudioListenerState struct AudioReactiveTelemetry impl Default for AudioListenerState impl Default for AudioReactiveTelemetry impl AudioReactiveTelemetry impl AudioListenerState impl Default for AudioProducerTelemetry impl AudioProducerTelemetry impl AudioChunkChannel impl AudioChunkReceiver const MPEG1_LAYER3_KBPS const MPEG2_LAYER3_KBPS const MPEG1_RATES const MPEG2_RATES const MPEG25_RATES struct Mp3ProbeAccumulator impl Mp3ProbeAccumulator enum Mp3ProbeStep struct PcmS16Analysis
Functions
By call-graph weight (PageRank; 1.0 is the average function). 142 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| normalize_audio_stream_idsrc/streaming/audio_stream.rs:1092 | fn | 3 | 1 | 30 | 1 | 15.6 | |
| statesrc/streaming/audio_stream.rs:934 | fn | 3 | 1 | 25 | 1 | 13.5 | |
| get_audio_channelsrc/streaming/audio_stream.rs:1096 | fn | 4 | 1 | 21 | 2 | 7.6 | |
| AudioChunkChannel::is_closedsrc/streaming/audio_stream.rs:625 | method | 3 | 1 | 22 | 0 | 5.5 | |
| publish_audio_chunk_in_contextsrc/streaming/audio_stream.rs:1586 | fn | 104 | 7 | 4 | 9 | 5.1 | |
| publish_audio_chunksrc/streaming/audio_stream.rs:1734 | fn | 3 | 1 | 21 | 1 | 5.1 | |
| open_audio_channelsrc/streaming/audio_stream.rs:1135 | fn | 11 | 2 | 26 | 3 | 4.1 | |
| AudioChunkChannel::latest_sharedsrc/streaming/audio_stream.rs:645 | method | 3 | 1 | 5 | 0 | 3.7 | |
| audio_endpoint_urlssrc/streaming/audio_stream.rs:178 | fn | 42 | 1 | 8 | 8 | 3.4 | |
| infer_audio_chunk_metasrc/streaming/audio_stream.rs:154 | fn | 19 | 3 | 12 | 4 | 3.3 | |
| update_audio_producer_telemetrysrc/streaming/audio_stream.rs:1509 | fn | 11 | 2 | 10 | 2 | 3 | |
| AudioChunkChannel::latestsrc/streaming/audio_stream.rs:641 | method | 3 | 1 | 4 | 1 | 2.9 | |
| audio_channel_statussrc/streaming/audio_stream.rs:1173 | fn | 76 | 1 | 10 | 5 | 2.6 | |
| latest_audio_chunksrc/streaming/audio_stream.rs:1101 | fn | 3 | 1 | 10 | 2 | 2.5 | |
| close_audio_channelsrc/streaming/audio_stream.rs:1147 | fn | 21 | 2 | 28 | 5 | 2.5 | |
| AudioChunkChannel::subscribesrc/streaming/audio_stream.rs:577 | method | 9 | 2 | 17 | 0 | 2.2 | |
| audio_stream_statssrc/streaming/audio_stream.rs:1127 | fn | 3 | 1 | 3 | 1 | 1.9 | |
| AudioChunkChannel::newsrc/streaming/audio_stream.rs:539 | method | 16 | 1 | 3 | 0 | 1.8 | |
| claim_audio_producersrc/streaming/audio_stream.rs:1385 | fn | 25 | 4 | 9 | 5 | 1.8 | |
| audio_chunk_eventsrc/streaming/audio_stream.rs:1738 | fn | 18 | 1 | 3 | 0 | 1.7 | |
| audio_pcm_url_with_layoutsrc/streaming/audio_stream.rs:137 | fn | 8 | 1 | 2 | 1 | 1.7 | |
| try_claim_audio_listenersrc/streaming/audio_stream.rs:1306 | fn | 19 | 2 | 6 | 2 | 1.5 | |
| list_audio_channelssrc/streaming/audio_stream.rs:1250 | fn | 16 | 2 | 2 | 2 | 1.5 | |
| audio_producer_leasesrc/streaming/audio_stream.rs:1481 | fn | 4 | 1 | 4 | 2 | 1.5 | |
| release_audio_producer_leasesrc/streaming/audio_stream.rs:1444 | fn | 19 | 3 | 8 | 3 | 1.4 | |
| mark_audio_producer_telemetry_stoppedsrc/streaming/audio_stream.rs:1490 | fn | 7 | 1 | 3 | 1 | 1.4 | |
| AudioListenerState::idle_for_mssrc/streaming/audio_stream.rs:474 | method | 3 | 1 | 2 | 1 | 1.3 | |
| clear_audio_backlogsrc/streaming/audio_stream.rs:1169 | fn | 3 | 1 | 8 | 2 | 1.3 | |
| infer_pts_ussrc/streaming/audio_stream.rs:174 | fn | 3 | 1 | 4 | 0 | 1.2 | |
| Mp3ProbeAccumulator::accept_framesrc/streaming/audio_stream.rs:873 | method | 12 | 4 | 1 | 0 | 1.2 | |
| probe_mp3_audio_infosrc/streaming/audio_stream.rs:838 | fn | 14 | 3 | 1 | 3 | 1.2 | |
| pcm_s16le_duration_mssrc/streaming/audio_stream.rs:918 | fn | 11 | 4 | 1 | 0 | 1.2 | |
| unique_audio_stream_idsrc/streaming/audio_stream.rs:1761 | fn | 3 | 1 | 10 | 1 | 1.2 | |
| audio_reactivity_snapshotsrc/streaming/audio_stream.rs:1267 | fn | 13 | 1 | 3 | 3 | 1.1 | |
| mpeg1_layer3_128k_44100_stereo_framesrc/streaming/audio_stream.rs:1778 | fn | 5 | 1 | 3 | 0 | 1.1 | |
| mark_audio_listener_disconnectedsrc/streaming/audio_stream.rs:1326 | fn | 15 | 3 | 4 | 3 | 1.1 | |
| mark_audio_producer_stopped_bysrc/streaming/audio_stream.rs:1423 | fn | 20 | 3 | 2 | 4 | 1.1 | |
| is_audio_producer_runningsrc/streaming/audio_stream.rs:1475 | fn | 5 | 1 | 4 | 2 | 1.1 | |
| AudioListenerLease::active_listenerssrc/streaming/audio_stream.rs:86 | method | 3 | 1 | 6 | 0 | 1.1 | |
| pcm_sample_signsrc/streaming/audio_stream.rs:1030 | fn | 9 | 3 | 1 | 0 | 1.1 | |
| audio_producer_telemetrysrc/streaming/audio_stream.rs:1521 | fn | 6 | 1 | 2 | 2 | 1.1 | |
| AudioChunkChannel::clear_pendingsrc/streaming/audio_stream.rs:607 | method | 10 | 2 | 1 | 0 | 1 | |
| normalize_audio_producer_ownersrc/streaming/audio_stream.rs:940 | fn | 4 | 2 | 2 | 0 | 1 | |
| AudioChunkChannel::latest_matching_sharedsrc/streaming/audio_stream.rs:663 | method | 13 | 1 | 2 | 0 | 1 | |
| AudioListenerState::defaultsrc/streaming/audio_stream.rs:400 | trait impl | 8 | 1 | 2 | 0 | 1 | |
| AudioChunkChannel::published_countsrc/streaming/audio_stream.rs:637 | method | 3 | 1 | 5 | 0 | 1 | |
| should_stop_audio_producer_for_idlesrc/streaming/audio_stream.rs:1378 | fn | 6 | 1 | 5 | 3 | 1 | |
| latest_audio_chunk_matching_sharedsrc/streaming/audio_stream.rs:1112 | fn | 6 | 1 | 1 | 2 | 1 | |
| audio_status_urlsrc/streaming/audio_stream.rs:150 | fn | 3 | 1 | 2 | 1 | 1 | |
| AudioReactiveTelemetry::defaultsrc/streaming/audio_stream.rs:411 | trait impl | 25 | 1 | 2 | 0 | 1 | |
| update_audio_reactivitysrc/streaming/audio_stream.rs:1040 | fn | 51 | 8 | 1 | 5 | 1 | |
| mirror_mp3_chunk_into_atom_storesrc/streaming/audio_stream.rs:1545 | fn | 40 | 3 | 1 | 3 | 1 | |
| mp3_atom_inputsrc/streaming/audio_stream.rs:1691 | fn | 7 | 3 | 1 | 1 | 1 | |
| audio_packet_media_ledgersrc/streaming/audio_stream.rs:1699 | fn | 29 | 4 | 1 | 2 | 1 | |
| audio_publish_media_graphsrc/streaming/audio_stream.rs:1729 | fn | 4 | 1 | 1 | 1 | 1 | |
| AudioChunkChannel::dropped_countsrc/streaming/audio_stream.rs:633 | method | 3 | 1 | 4 | 0 | 0.9 | |
| audio_listener_statussrc/streaming/audio_stream.rs:1352 | fn | 6 | 1 | 1 | 2 | 0.9 | |
| force_audio_producer_stoppedsrc/streaming/audio_stream.rs:1464 | fn | 10 | 2 | 1 | 3 | 0.9 | |
| audio_live_mp3_urlsrc/streaming/audio_stream.rs:100 | fn | 6 | 1 | 1 | 1 | 0.9 | |
| audio_live_opus_urlsrc/streaming/audio_stream.rs:107 | fn | 6 | 1 | 1 | 1 | 0.9 | |
| audio_live_wav_urlsrc/streaming/audio_stream.rs:114 | fn | 6 | 1 | 1 | 1 | 0.9 | |
| audio_live_flac_urlsrc/streaming/audio_stream.rs:121 | fn | 6 | 1 | 1 | 1 | 0.9 | |
| audio_pcm_urlsrc/streaming/audio_stream.rs:128 | fn | 3 | 1 | 1 | 1 | 0.9 | |
| audio_events_urlsrc/streaming/audio_stream.rs:146 | fn | 3 | 1 | 1 | 1 | 0.9 | |
| parse_mp3_frame_headersrc/streaming/audio_stream.rs:765 | fn | 34 | 7 | 1 | 5 | 0.8 | |
| mp3_probe_misssrc/streaming/audio_stream.rs:914 | fn | 3 | 2 | 1 | 0 | 0.8 | |
| id3v2_tag_lensrc/streaming/audio_stream.rs:749 | fn | 15 | 5 | 1 | 0 | 0.8 | |
| Mp3ProbeAccumulator::apply_stepsrc/streaming/audio_stream.rs:862 | method | 10 | 3 | 1 | 1 | 0.8 | |
| probe_next_mp3_framesrc/streaming/audio_stream.rs:904 | fn | 9 | 2 | 1 | 2 | 0.8 | |
| active_audio_listener_countsrc/streaming/audio_stream.rs:1365 | fn | 12 | 1 | 5 | 2 | 0.8 | |
| unit_audio_chunksrc/streaming/audio_stream.rs:1765 | fn | 12 | 1 | 5 | 0 | 0.8 | |
| next_audio_producer_generationsrc/streaming/audio_stream.rs:945 | fn | 3 | 1 | 1 | 0 | 0.8 | |
| AudioChunkChannel::backlog_framessrc/streaming/audio_stream.rs:687 | method | 9 | 1 | 2 | 0 | 0.8 | |
| AudioChunkChannel::latest_matchingsrc/streaming/audio_stream.rs:649 | method | 13 | 1 | 1 | 0 | 0.8 | |
| AudioListenerState::idle_expiredsrc/streaming/audio_stream.rs:478 | method | 5 | 3 | 1 | 1 | 0.8 | |
| mark_audio_listener_connectedsrc/streaming/audio_stream.rs:1294 | fn | 11 | 1 | 4 | 3 | 0.7 | |
| AudioChunkChannel::backlogsrc/streaming/audio_stream.rs:677 | method | 9 | 1 | 1 | 0 | 0.7 | |
| reset_audio_producer_telemetrysrc/streaming/audio_stream.rs:1498 | fn | 10 | 2 | 4 | 3 | 0.7 | |
| AudioProducerTelemetry::defaultsrc/streaming/audio_stream.rs:497 | trait impl | 18 | 1 | 1 | 0 | 0.7 | |
| latest_audio_chunk_matchingsrc/streaming/audio_stream.rs:1105 | fn | 6 | 1 | 3 | 2 | 0.7 | |
| scan_pcm_s16le_samplessrc/streaming/audio_stream.rs:1010 | fn | 19 | 6 | 1 | 1 | 0.7 | |
| analyze_pcm_s16lesrc/streaming/audio_stream.rs:988 | fn | 21 | 7 | 1 | 3 | 0.7 | |
| mp3_header_bytessrc/streaming/audio_stream.rs:800 | fn | 6 | 2 | 1 | 0 | 0.6 | |
| mp3_header_has_syncsrc/streaming/audio_stream.rs:807 | fn | 3 | 2 | 1 | 0 | 0.6 | |
| mp3_header_is_layer3src/streaming/audio_stream.rs:811 | fn | 3 | 2 | 1 | 0 | 0.6 | |
| mp3_bitrate_kbpssrc/streaming/audio_stream.rs:815 | fn | 8 | 3 | 1 | 0 | 0.6 | |
| mp3_sample_ratesrc/streaming/audio_stream.rs:824 | fn | 13 | 4 | 1 | 0 | 0.6 | |
| mark_audio_producer_startedsrc/streaming/audio_stream.rs:1411 | fn | 3 | 1 | 1 | 1 | 0.6 | |
| mark_audio_producer_stoppedsrc/streaming/audio_stream.rs:1419 | fn | 3 | 1 | 1 | 1 | 0.6 | |
| configure_audio_idlesrc/streaming/audio_stream.rs:1281 | fn | 12 | 4 | 2 | 2 | 0.6 | |
| AudioChunkReceiver::skip_to_sequencesrc/streaming/audio_stream.rs:720 | method | 3 | 1 | 2 | 0 | 0.6 | |
| audio_stream_close_responsesrc/streaming/audio_stream.rs:261 | fn | 16 | 1 | 1 | 0 | 0.6 | |
| audio_stream_open_responsesrc/streaming/audio_stream.rs:231 | fn | 20 | 1 | 1 | 0 | 0.6 | |
| audio_backlog_framessrc/streaming/audio_stream.rs:1131 | fn | 3 | 1 | 1 | 2 | 0.5 | |
| audio_idle_for_mssrc/streaming/audio_stream.rs:1359 | fn | 5 | 1 | 1 | 3 | 0.5 | |
| AudioListenerLease::dropsrc/streaming/audio_stream.rs:92 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| audio_stream_status_payloadsrc/streaming/audio_stream.rs:221 | fn | 9 | 2 | 0 | 3 | 0.5 | |
| audio_stream_status_responsesrc/streaming/audio_stream.rs:252 | fn | 8 | 1 | 0 | 0 | 0.5 | |
| AudioStreamStats::to_jsonsrc/streaming/audio_stream.rs:318 | method | 8 | 1 | 0 | 0 | 0.5 | |
| AudioReactiveTelemetry::to_jsonsrc/streaming/audio_stream.rs:439 | method | 32 | 1 | 0 | 0 | 0.5 | |
| AudioListenerState::to_jsonsrc/streaming/audio_stream.rs:484 | method | 10 | 1 | 0 | 0 | 0.5 | |
| AudioProducerTelemetry::to_jsonsrc/streaming/audio_stream.rs:518 | method | 18 | 1 | 0 | 0 | 0.5 | |
| AudioChunkChannel::sendsrc/streaming/audio_stream.rs:556 | method | 20 | 3 | 0 | 0 | 0.5 | |
| AudioChunkChannel::recv_timeoutsrc/streaming/audio_stream.rs:587 | method | 19 | 4 | 0 | 0 | 0.5 | |
| AudioChunkChannel::closesrc/streaming/audio_stream.rs:618 | method | 6 | 1 | 0 | 0 | 0.5 | |
| AudioChunkChannel::lensrc/streaming/audio_stream.rs:629 | method | 3 | 1 | 0 | 0 | 0.5 | |
| AudioChunkChannel::capacitysrc/streaming/audio_stream.rs:697 | method | 3 | 1 | 0 | 0 | 0.5 | |
| AudioChunkChannel::statssrc/streaming/audio_stream.rs:705 | method | 12 | 1 | 0 | 0 | 0.5 | |
| AudioChunkReceiver::recv_timeoutsrc/streaming/audio_stream.rs:724 | method | 19 | 4 | 0 | 0 | 0.5 | |
| queue_fill_ratiosrc/streaming/audio_stream.rs:745 | fn | 3 | 2 | 0 | 0 | 0.5 | |
| Mp3ProbeAccumulator::finishsrc/streaming/audio_stream.rs:886 | method | 10 | 4 | 0 | 0 | 0.5 | |
| queue_remaining_capacitysrc/streaming/audio_stream.rs:930 | fn | 3 | 1 | 0 | 0 | 0.5 | |
| round4src/streaming/audio_stream.rs:949 | fn | 3 | 1 | 0 | 0 | 0.5 | |
| round2src/streaming/audio_stream.rs:953 | fn | 3 | 1 | 0 | 0 | 0.5 | |
| energy_bandsrc/streaming/audio_stream.rs:957 | fn | 11 | 4 | 0 | 0 | 0.5 | |
| spectral_bandsrc/streaming/audio_stream.rs:969 | fn | 11 | 4 | 0 | 0 | 0.5 | |
| audio_backlog_chunkssrc/streaming/audio_stream.rs:1119 | fn | 3 | 1 | 0 | 2 | 0.5 | |
| mark_audio_stream_idlesrc/streaming/audio_stream.rs:1342 | fn | 9 | 2 | 0 | 2 | 0.5 | |
| mark_audio_producer_started_bysrc/streaming/audio_stream.rs:1415 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| audio_producer_ownersrc/streaming/audio_stream.rs:1486 | fn | 3 | 1 | 0 | 1 | 0.5 | |
| audio_chunk_event_exposes_generic_audio_base64_with_legacy_pcm_aliassrc/streaming/audio_stream.rs:1785 | fn | 20 | 1 | 0 | 1 | 0.5 | |
| mp3_metadata_probe_is_bounded_before_falling_backsrc/streaming/audio_stream.rs:1807 | fn | 11 | 1 | 0 | 2 | 0.5 | |
| mp3_metadata_probe_reads_valid_frame_inside_budgetsrc/streaming/audio_stream.rs:1820 | fn | 6 | 1 | 0 | 2 | 0.5 | |
| mp3_metadata_probe_accepts_browser_mime_aliasessrc/streaming/audio_stream.rs:1828 | fn | 8 | 2 | 0 | 2 | 0.5 | |
| pcm_metadata_probe_accepts_s16le_mime_aliasessrc/streaming/audio_stream.rs:1838 | fn | 10 | 2 | 0 | 1 | 0.5 | |
| audio_channel_retains_latest_when_fullsrc/streaming/audio_stream.rs:1850 | fn | 38 | 1 | 0 | 5 | 0.5 | |
| audio_channel_shared_snapshot_reuses_retained_chunk_storagesrc/streaming/audio_stream.rs:1890 | fn | 11 | 1 | 0 | 4 | 0.5 | |
| audio_channel_subscribers_do_not_steal_chunkssrc/streaming/audio_stream.rs:1903 | fn | 29 | 1 | 0 | 3 | 0.5 | |
| subscriber_can_skip_replayed_backlog_by_retained_sequencesrc/streaming/audio_stream.rs:1934 | fn | 20 | 2 | 0 | 7 | 0.5 | |
| audio_channel_clear_pending_counts_as_droppedsrc/streaming/audio_stream.rs:1956 | fn | 26 | 2 | 0 | 5 | 0.5 | |
| audio_stream_stats_counts_capacity_overflow_dropssrc/streaming/audio_stream.rs:1984 | fn | 26 | 2 | 0 | 6 | 0.5 | |
| audio_stream_stats_counts_listener_underruns_on_empty_drainsrc/streaming/audio_stream.rs:2012 | fn | 20 | 1 | 0 | 4 | 0.5 | |
| audio_producer_registry_prevents_duplicate_startssrc/streaming/audio_stream.rs:2034 | fn | 11 | 1 | 0 | 3 | 0.5 | |
| audio_producer_lease_blocks_foreign_owner_and_protects_new_generationsrc/streaming/audio_stream.rs:2047 | fn | 31 | 1 | 0 | 6 | 0.5 | |
| audio_producer_stop_is_idempotent_and_restart_gets_new_leasesrc/streaming/audio_stream.rs:2080 | fn | 16 | 1 | 0 | 6 | 0.5 | |
| close_audio_channel_clears_side_state_and_packet_lanesrc/streaming/audio_stream.rs:2098 | fn | 24 | 1 | 0 | 12 | 0.5 | |
| audio_listener_disconnect_without_connect_does_not_create_stale_statesrc/streaming/audio_stream.rs:2124 | fn | 17 | 1 | 0 | 6 | 0.5 | |
| audio_listener_claim_enforces_limit_atomicallysrc/streaming/audio_stream.rs:2143 | fn | 12 | 1 | 0 | 6 | 0.5 | |
| audio_listener_lease_allows_max_listeners_and_reclaims_on_dropsrc/streaming/audio_stream.rs:2157 | fn | 23 | 1 | 0 | 6 | 0.5 | |
| first_non_replay_listener_clears_backlog_without_touching_active_fanoutsrc/streaming/audio_stream.rs:2182 | fn | 37 | 4 | 0 | 9 | 0.5 | |
| audio_producer_telemetry_is_reported_in_statussrc/streaming/audio_stream.rs:2221 | fn | 21 | 1 | 0 | 5 | 0.5 | |
| audio_listener_idle_timeout_expires_after_last_listener_leavessrc/streaming/audio_stream.rs:2244 | fn | 15 | 1 | 0 | 5 | 0.5 |
Source not readable from this process.