1 viewer
rust 1,854,395 · typescript 233,161 · javascript 131,995 · python 19,227 · 6,379 files · digest 17dcda71e44b · built in 1.5 s · crystals off
crates/cre8-app-conduit/src/transcode_worker.rs
Items
const LOCAL_PACKAGING_WORKER_ID const AUDIO_RENDITION_ID const VIDEO_RENDITION_ID const WORKER_STALE_AFTER_MS const WORKER_LEASE_TTL_MS const WORKER_CANDIDATE_LIMIT struct WorkerRuntimeState struct WorkerCandidate struct AacSequenceConfig struct AudioWorkerState struct H264SequenceConfig struct VideoWorkerState const WORKER_ROLE_NAMES const WORKER_ROLE_ALIASES const ACCELERATION_API_NAMES const ACCELERATION_API_ALIASES const PACKAGING_TARGET_ALIASES const AAC_SAMPLE_RATES struct BitReader impl BitReader struct SpsDimensionFields
Functions
By call-graph weight (PageRank; 1.0 is the average function). 159 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| BitReader::read_bitsrc/transcode_worker.rs:1599 | method | 12 | 3 | 9 | 0 | 5.7 | |
| BitReader::read_uesrc/transcode_worker.rs:1621 | method | 17 | 4 | 9 | 2 | 3.6 | |
| statesrc/transcode_worker.rs:71 | fn | 3 | 1 | 13 | 1 | 2.8 | |
| BitReader::read_bitssrc/transcode_worker.rs:1612 | method | 7 | 2 | 2 | 1 | 2.3 | |
| worker_is_alivesrc/transcode_worker.rs:386 | fn | 3 | 2 | 3 | 0 | 2.3 | |
| lookup_tokensrc/transcode_worker.rs:184 | fn | 3 | 1 | 4 | 0 | 2.2 | |
| lookup_namesrc/transcode_worker.rs:180 | fn | 3 | 1 | 2 | 0 | 2 | |
| strings_from_valuesrc/transcode_worker.rs:200 | fn | 17 | 4 | 6 | 0 | 1.8 | |
| worker_request_checkssrc/transcode_worker.rs:483 | fn | 11 | 1 | 1 | 7 | 1.8 | |
| worker_limit_oksrc/transcode_worker.rs:541 | fn | 3 | 1 | 2 | 0 | 1.7 | |
| normalized_worker_tokensrc/transcode_worker.rs:176 | fn | 3 | 1 | 3 | 0 | 1.7 | |
| worker_alive_by_idsrc/transcode_worker.rs:390 | fn | 3 | 1 | 1 | 1 | 1.5 | |
| local_worker_capabilitysrc/transcode_worker.rs:319 | fn | 18 | 1 | 7 | 0 | 1.5 | |
| worker_supports_requestsrc/transcode_worker.rs:479 | fn | 3 | 1 | 6 | 1 | 1.5 | |
| aac_sample_ratesrc/transcode_worker.rs:1510 | fn | 5 | 1 | 1 | 0 | 1.4 | |
| BitReader::read_sesrc/transcode_worker.rs:1640 | method | 5 | 2 | 2 | 1 | 1.4 | |
| normalize_worker_idsrc/transcode_worker.rs:77 | fn | 3 | 1 | 7 | 1 | 1.3 | |
| worker_snapshotssrc/transcode_worker.rs:375 | fn | 5 | 1 | 7 | 3 | 1.3 | |
| worker_candidate_bonusessrc/transcode_worker.rs:567 | fn | 15 | 1 | 1 | 7 | 1.2 | |
| packaging_target_from_strsrc/transcode_worker.rs:196 | fn | 3 | 1 | 3 | 2 | 1.2 | |
| video_packaging_requestsrc/transcode_worker.rs:726 | fn | 11 | 1 | 6 | 1 | 1.2 | |
| lease_is_activesrc/transcode_worker.rs:413 | fn | 4 | 2 | 1 | 1 | 1.2 | |
| ensure_local_worker_registeredsrc/transcode_worker.rs:357 | fn | 17 | 1 | 4 | 5 | 1.2 | |
| packet_sourcesrc/transcode_worker.rs:1494 | fn | 3 | 1 | 2 | 0 | 1.1 | |
| worker_name_apisrc/transcode_worker.rs:144 | fn | 3 | 1 | 2 | 1 | 1.1 | |
| avc_payload_to_annex_bsrc/transcode_worker.rs:1855 | fn | 35 | 8 | 3 | 0 | 1.1 | |
| publish_h264_annex_b_packetsrc/transcode_worker.rs:2003 | fn | 38 | 2 | 3 | 2 | 1.1 | |
| string_from_valuesrc/transcode_worker.rs:247 | fn | 12 | 1 | 5 | 0 | 1.1 | |
| remove_emulation_preventionsrc/transcode_worker.rs:1649 | fn | 15 | 6 | 1 | 0 | 1.1 | |
| parse_audio_specific_configsrc/transcode_worker.rs:1498 | fn | 11 | 2 | 1 | 1 | 1.1 | |
| register_worker_from_valuesrc/transcode_worker.rs:913 | fn | 51 | 2 | 5 | 8 | 1 | |
| platform_gpu_hintssrc/transcode_worker.rs:260 | fn | 3 | 1 | 1 | 0 | 0.9 | |
| request_forsrc/transcode_worker.rs:2369 | fn | 3 | 1 | 3 | 0 | 0.9 | |
| worker_candidate_scoresrc/transcode_worker.rs:545 | fn | 9 | 1 | 3 | 2 | 0.9 | |
| packet_notesrc/transcode_worker.rs:1490 | fn | 3 | 1 | 5 | 0 | 0.9 | |
| worker_candidate_eligiblesrc/transcode_worker.rs:555 | fn | 3 | 2 | 1 | 2 | 0.9 | |
| worker_candidate_score_valuesrc/transcode_worker.rs:559 | fn | 7 | 1 | 1 | 1 | 0.9 | |
| codec_from_strsrc/transcode_worker.rs:188 | fn | 7 | 3 | 3 | 0 | 0.9 | |
| remove_workersrc/transcode_worker.rs:1019 | fn | 35 | 3 | 5 | 3 | 0.9 | |
| acceleration_from_strsrc/transcode_worker.rs:167 | fn | 3 | 1 | 2 | 2 | 0.8 | |
| u64_from_valuesrc/transcode_worker.rs:1068 | fn | 9 | 1 | 2 | 1 | 0.8 | |
| read_avcc_nalssrc/transcode_worker.rs:1555 | fn | 21 | 4 | 1 | 0 | 0.8 | |
| parse_sps_dimensionssrc/transcode_worker.rs:1775 | fn | 14 | 1 | 1 | 4 | 0.8 | |
| lease_snapshotssrc/transcode_worker.rs:381 | fn | 4 | 1 | 3 | 2 | 0.8 | |
| active_lease_countssrc/transcode_worker.rs:418 | fn | 13 | 3 | 3 | 1 | 0.8 | |
| audio_packaging_requestsrc/transcode_worker.rs:713 | fn | 12 | 1 | 3 | 1 | 0.8 | |
| heartbeat_workersrc/transcode_worker.rs:965 | fn | 41 | 2 | 3 | 6 | 0.8 | |
| parse_avccsrc/transcode_worker.rs:1531 | fn | 23 | 6 | 2 | 2 | 0.8 | |
| worker_payloadsrc/transcode_worker.rs:450 | fn | 13 | 1 | 2 | 0 | 0.8 | |
| skip_sps_pic_order_cycle_fieldssrc/transcode_worker.rs:1732 | fn | 10 | 2 | 1 | 3 | 0.8 | |
| ranked_candidates_for_requestsrc/transcode_worker.rs:624 | fn | 22 | 1 | 2 | 5 | 0.8 | |
| skip_sps_scaling_listsrc/transcode_worker.rs:1708 | fn | 12 | 4 | 1 | 1 | 0.8 | |
| session_worker_manifestsrc/transcode_worker.rs:1423 | fn | 37 | 1 | 2 | 5 | 0.8 | |
| role_from_strsrc/transcode_worker.rs:163 | fn | 3 | 1 | 2 | 2 | 0.8 | |
| assign_worker_leasesrc/transcode_worker.rs:672 | fn | 40 | 2 | 3 | 7 | 0.8 | |
| publish_packet_from_valuesrc/transcode_worker.rs:1233 | fn | 116 | 6 | 3 | 11 | 0.7 | |
| publish_packaging_ready_packetssrc/transcode_worker.rs:2299 | fn | 33 | 3 | 3 | 8 | 0.7 | |
| unique_test_noncesrc/transcode_worker.rs:2365 | fn | 3 | 1 | 3 | 0 | 0.7 | |
| worker_role_supports_requestsrc/transcode_worker.rs:495 | fn | 6 | 2 | 1 | 3 | 0.7 | |
| worker_codec_supports_requestsrc/transcode_worker.rs:506 | fn | 3 | 2 | 1 | 0 | 0.7 | |
| worker_packaging_supports_requestsrc/transcode_worker.rs:510 | fn | 3 | 1 | 1 | 0 | 0.7 | |
| worker_rendition_supports_requestsrc/transcode_worker.rs:514 | fn | 3 | 2 | 1 | 0 | 0.7 | |
| worker_gpu_supports_requestsrc/transcode_worker.rs:518 | fn | 3 | 2 | 1 | 0 | 0.7 | |
| worker_dimension_constraints_oksrc/transcode_worker.rs:532 | fn | 4 | 2 | 1 | 1 | 0.7 | |
| worker_fps_constraint_oksrc/transcode_worker.rs:537 | fn | 3 | 1 | 1 | 1 | 0.7 | |
| worker_name_rolesrc/transcode_worker.rs:140 | fn | 3 | 1 | 1 | 1 | 0.7 | |
| request_requires_reconstructionsrc/transcode_worker.rs:502 | fn | 3 | 1 | 1 | 0 | 0.7 | |
| worker_has_reconstruct_rolesrc/transcode_worker.rs:522 | fn | 3 | 1 | 1 | 0 | 0.7 | |
| worker_has_transcode_rolesrc/transcode_worker.rs:526 | fn | 5 | 1 | 1 | 0 | 0.7 | |
| local_worker_metadatasrc/transcode_worker.rs:338 | fn | 18 | 1 | 1 | 0 | 0.7 | |
| sps_crop_offsetssrc/transcode_worker.rs:1743 | fn | 3 | 2 | 1 | 2 | 0.7 | |
| ack_replica_from_valuesrc/transcode_worker.rs:1364 | fn | 58 | 4 | 2 | 4 | 0.7 | |
| bool_from_valuesrc/transcode_worker.rs:218 | fn | 15 | 1 | 3 | 0 | 0.7 | |
| u32_from_valuesrc/transcode_worker.rs:234 | fn | 12 | 1 | 3 | 1 | 0.7 | |
| read_sps_profile_headersrc/transcode_worker.rs:1808 | fn | 7 | 1 | 1 | 2 | 0.7 | |
| skip_sps_before_dimensionssrc/transcode_worker.rs:1816 | fn | 8 | 1 | 1 | 4 | 0.7 | |
| read_sps_picture_fieldssrc/transcode_worker.rs:1825 | fn | 21 | 2 | 1 | 3 | 0.7 | |
| lease_keysrc/transcode_worker.rs:394 | fn | 3 | 1 | 2 | 0 | 0.7 | |
| lease_prioritysrc/transcode_worker.rs:398 | fn | 14 | 4 | 2 | 0 | 0.7 | |
| build_adts_headersrc/transcode_worker.rs:1516 | fn | 14 | 1 | 1 | 0 | 0.7 | |
| worker_registry_statussrc/transcode_worker.rs:738 | fn | 44 | 1 | 2 | 6 | 0.7 | |
| signed_i24src/transcode_worker.rs:2166 | fn | 4 | 2 | 1 | 0 | 0.7 | |
| BitReader::newsrc/transcode_worker.rs:1595 | method | 3 | 1 | 1 | 0 | 0.7 | |
| sps_dimensions_from_fieldssrc/transcode_worker.rs:1747 | fn | 14 | 2 | 1 | 0 | 0.7 | |
| clean_sps_payloadsrc/transcode_worker.rs:1790 | fn | 11 | 3 | 1 | 1 | 0.7 | |
| read_sps_dimension_fieldssrc/transcode_worker.rs:1802 | fn | 5 | 1 | 1 | 3 | 0.7 | |
| update_aac_sequence_configsrc/transcode_worker.rs:1948 | fn | 6 | 2 | 1 | 1 | 0.7 | |
| publish_raw_aac_packetsrc/transcode_worker.rs:1955 | fn | 47 | 2 | 1 | 3 | 0.7 | |
| handle_enhanced_h264_nalu_packetsrc/transcode_worker.rs:2083 | fn | 37 | 2 | 1 | 2 | 0.7 | |
| handle_enhanced_h264_coded_frames_xsrc/transcode_worker.rs:2122 | fn | 43 | 3 | 1 | 3 | 0.7 | |
| local_worker_score_bonussrc/transcode_worker.rs:583 | fn | 3 | 2 | 1 | 0 | 0.6 | |
| low_latency_score_bonussrc/transcode_worker.rs:587 | fn | 3 | 3 | 1 | 0 | 0.6 | |
| rendition_score_bonussrc/transcode_worker.rs:591 | fn | 3 | 2 | 1 | 0 | 0.6 | |
| local_region_score_bonussrc/transcode_worker.rs:595 | fn | 3 | 2 | 1 | 0 | 0.6 | |
| active_lease_score_penaltysrc/transcode_worker.rs:599 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| gpu_request_score_bonussrc/transcode_worker.rs:603 | fn | 9 | 4 | 1 | 0 | 0.6 | |
| h264_width_score_bonussrc/transcode_worker.rs:613 | fn | 10 | 4 | 1 | 0 | 0.6 | |
| replica_ack_from_valuesrc/transcode_worker.rs:1117 | fn | 11 | 1 | 1 | 2 | 0.6 | |
| skip_sps_chroma_and_scaling_fieldssrc/transcode_worker.rs:1669 | fn | 12 | 3 | 1 | 4 | 0.6 | |
| skip_sps_pic_order_count_fieldssrc/transcode_worker.rs:1721 | fn | 10 | 3 | 1 | 2 | 0.6 | |
| candidate_payloadssrc/transcode_worker.rs:647 | fn | 24 | 2 | 1 | 3 | 0.6 | |
| sps_has_chroma_and_scaling_fieldssrc/transcode_worker.rs:1665 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| skip_sps_chroma_header_fieldssrc/transcode_worker.rs:1682 | fn | 7 | 2 | 1 | 2 | 0.6 | |
| skip_sps_bit_depth_and_transform_fieldssrc/transcode_worker.rs:1690 | fn | 6 | 1 | 1 | 2 | 0.6 | |
| skip_sps_scaling_matricessrc/transcode_worker.rs:1697 | fn | 10 | 5 | 1 | 2 | 0.6 | |
| parse_flv_composition_timesrc/transcode_worker.rs:1847 | fn | 7 | 3 | 1 | 0 | 0.6 | |
| reset_worker_pipeline_statesrc/transcode_worker.rs:1013 | fn | 5 | 1 | 2 | 2 | 0.6 | |
| capability_from_valuesrc/transcode_worker.rs:818 | fn | 21 | 2 | 1 | 10 | 0.6 | |
| worker_name_api_tailsrc/transcode_worker.rs:149 | fn | 3 | 1 | 1 | 1 | 0.6 | |
| acceleration_tail_from_strsrc/transcode_worker.rs:172 | fn | 3 | 1 | 1 | 1 | 0.6 | |
| record_replica_test_segmentsrc/transcode_worker.rs:2490 | fn | 54 | 1 | 1 | 7 | 0.6 | |
| publish_aac_packetsrc/transcode_worker.rs:1915 | fn | 32 | 8 | 1 | 3 | 0.6 | |
| lease_payloadsrc/transcode_worker.rs:464 | fn | 14 | 1 | 1 | 0 | 0.6 | |
| worker_statussrc/transcode_worker.rs:783 | fn | 34 | 1 | 1 | 5 | 0.6 | |
| claim_worker_leasesrc/transcode_worker.rs:1157 | fn | 63 | 3 | 1 | 6 | 0.6 | |
| claim_request_from_valuesrc/transcode_worker.rs:1078 | fn | 38 | 3 | 1 | 6 | 0.6 | |
| upsert_claimed_leasesrc/transcode_worker.rs:1129 | fn | 27 | 1 | 1 | 5 | 0.6 | |
| publish_aac_packetssrc/transcode_worker.rs:1891 | fn | 23 | 3 | 1 | 5 | 0.6 | |
| publish_h264_packetssrc/transcode_worker.rs:2230 | fn | 57 | 8 | 1 | 7 | 0.6 | |
| delegated_publish_payloadsrc/transcode_worker.rs:2288 | fn | 10 | 1 | 1 | 0 | 0.6 | |
| sample_adts_framesrc/transcode_worker.rs:2351 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| sample_h264_annex_bsrc/transcode_worker.rs:2355 | fn | 9 | 1 | 1 | 0 | 0.6 | |
| handle_enhanced_h264_packetsrc/transcode_worker.rs:2042 | fn | 39 | 7 | 1 | 3 | 0.6 | |
| handle_legacy_h264_packetsrc/transcode_worker.rs:2171 | fn | 58 | 6 | 1 | 4 | 0.6 | |
| publish_rtmp_audiosrc/transcode_worker.rs:2545 | fn | 59 | 1 | 1 | 3 | 0.6 | |
| kind_from_codecsrc/transcode_worker.rs:1055 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| kind_from_strsrc/transcode_worker.rs:1059 | fn | 8 | 4 | 1 | 0 | 0.6 | |
| lease_heartbeat_for_streamsrc/transcode_worker.rs:1221 | fn | 11 | 4 | 1 | 3 | 0.6 | |
| publish_rtmp_videosrc/transcode_worker.rs:2605 | fn | 66 | 1 | 1 | 3 | 0.5 | |
| find_reconstruct_worker_candidatesrc/transcode_worker.rs:2333 | fn | 12 | 5 | 1 | 3 | 0.5 | |
| apply_worker_accelerationsrc/transcode_worker.rs:840 | fn | 17 | 4 | 1 | 2 | 0.5 | |
| apply_worker_codecssrc/transcode_worker.rs:858 | fn | 16 | 3 | 1 | 2 | 0.5 | |
| apply_worker_packaging_targetssrc/transcode_worker.rs:875 | fn | 13 | 2 | 1 | 2 | 0.5 | |
| apply_worker_renditionssrc/transcode_worker.rs:889 | fn | 7 | 2 | 1 | 1 | 0.5 | |
| apply_worker_role_defaultssrc/transcode_worker.rs:897 | fn | 15 | 6 | 1 | 0 | 0.5 | |
| worker_name_targetsrc/transcode_worker.rs:153 | fn | 9 | 5 | 0 | 0 | 0.5 | |
| hintssrc/transcode_worker.rs:268 | fn | 8 | 1 | 0 | 0 | 0.5 | |
| hintssrc/transcode_worker.rs:282 | fn | 3 | 1 | 0 | 0 | 0.5 | |
| hintssrc/transcode_worker.rs:291 | fn | 3 | 1 | 0 | 0 | 0.5 | |
| hintssrc/transcode_worker.rs:300 | fn | 3 | 1 | 0 | 0 | 0.5 | |
| platform_gpu_blueprintssrc/transcode_worker.rs:305 | fn | 13 | 1 | 0 | 1 | 0.5 | |
| capability_payloadsrc/transcode_worker.rs:432 | fn | 17 | 1 | 0 | 0 | 0.5 | |
| replica_receipt_payloadsrc/transcode_worker.rs:1350 | fn | 13 | 1 | 0 | 0 | 0.5 | |
| packaging_worker_statussrc/transcode_worker.rs:1461 | fn | 28 | 1 | 0 | 3 | 0.5 | |
| worker_role_names_and_aliases_are_stablesrc/transcode_worker.rs:2374 | fn | 10 | 1 | 0 | 2 | 0.5 | |
| acceleration_names_and_aliases_are_stablesrc/transcode_worker.rs:2386 | fn | 10 | 1 | 0 | 4 | 0.5 | |
| packaging_target_aliases_are_stablesrc/transcode_worker.rs:2398 | fn | 6 | 1 | 0 | 1 | 0.5 | |
| worker_supports_local_audio_and_video_packaging_requestssrc/transcode_worker.rs:2406 | fn | 6 | 1 | 0 | 4 | 0.5 | |
| worker_supports_request_rejects_missing_packaging_and_renditionsrc/transcode_worker.rs:2414 | fn | 9 | 1 | 0 | 3 | 0.5 | |
| worker_supports_request_uses_reconstruct_role_for_reconstruction_codecssrc/transcode_worker.rs:2425 | fn | 9 | 1 | 0 | 3 | 0.5 | |
| worker_supports_request_rejects_dimension_fps_and_gpu_overflowsrc/transcode_worker.rs:2436 | fn | 21 | 1 | 0 | 3 | 0.5 | |
| worker_candidate_score_applies_bonuses_and_lease_penaltysrc/transcode_worker.rs:2459 | fn | 12 | 1 | 0 | 3 | 0.5 | |
| worker_candidate_score_skips_stale_or_unsupported_workerssrc/transcode_worker.rs:2473 | fn | 16 | 1 | 0 | 3 | 0.5 | |
| worker_publishes_adts_aac_from_rtmp_packetssrc/transcode_worker.rs:2673 | fn | 18 | 1 | 0 | 7 | 0.5 | |
| worker_publishes_annexb_h264_from_rtmp_packetssrc/transcode_worker.rs:2693 | fn | 31 | 1 | 0 | 8 | 0.5 | |
| publish_packet_from_value_rejects_invalid_or_incomplete_requestssrc/transcode_worker.rs:2726 | fn | 49 | 1 | 0 | 4 | 0.5 | |
| publish_packet_from_value_publishes_packet_with_metadatasrc/transcode_worker.rs:2777 | fn | 50 | 1 | 0 | 7 | 0.5 | |
| gpu_worker_wins_when_request_requires_gpusrc/transcode_worker.rs:2829 | fn | 20 | 1 | 0 | 3 | 0.5 | |
| worker_can_acknowledge_segment_replicasrc/transcode_worker.rs:2851 | fn | 29 | 1 | 0 | 4 | 0.5 |
Source not readable from this process.