MCPcopy Create free account

hub / github.com/livekit/livekit / functions

Functions7,437 in github.com/livekit/livekit

↓ 2 callersMethodsetState
(state streamAllocatorState)
pkg/sfu/streamallocator/streamallocator.go:899
↓ 2 callersMethodsetSubscribedTrack
(track types.SubscribedTrack)
pkg/rtc/subscriptionmanager.go:1437
↓ 2 callersMethodsetTargetLayer
(targetLayer buffer.VideoLayer, requestLayerSpatial int32)
pkg/sfu/forwarder.go:1684
↓ 2 callersMethodsetupBuffer
(buff buffer.BufferProvider, layer int32, rtt uint32, paused bool)
pkg/sfu/receiver_base.go:761
↓ 2 callersFunctionsetupDataBlobServer
(t *testing.T, name string, enable bool)
test/singlenode_test.go:1599
↓ 2 callersMethodsetupMigrationTimerLocked
()
pkg/rtc/participant.go:1560
↓ 2 callersFunctionsetupMultiNodeTestWithConfig
(name string, configUpdater func(*config.Config))
test/integration_helpers.go:86
↓ 2 callersMethodsetupRTPStats
(clockRate uint32)
pkg/sfu/buffer/buffer_base.go:449
↓ 2 callersMethodsetupRTPStatsLite
(clockRate uint32)
pkg/sfu/buffer/buffer_base.go:463
↓ 2 callersMethodshadowDownTracks
()
pkg/sfu/utils/downtrackspreader.go:116
↓ 2 callersMethodshadowVideoTracksLocked
()
pkg/sfu/streamallocator/streamallocator.go:1436
↓ 2 callersMethodshouldWriteActiveDecodeTargetsBitmask
()
pkg/sfu/rtpextension/dependencydescriptor/dependencydescriptorwriter.go:463
↓ 2 callersMethodstartAtLocked
(packetLossWeight float64, at time.Time)
pkg/sfu/connectionquality/scorer.go:242
↓ 2 callersMethodstartForwarderForBufferLocked
(layer int32, buff buffer.BufferProvider)
pkg/sfu/receiver_base.go:930
↓ 2 callersMethodstartForwardersGeneration
()
pkg/sfu/receiver_base.go:912
↓ 2 callersMethodstopMaxQualityTimer
()
pkg/rtc/dynacast/dynacastqualityvideo.go:241
↓ 2 callersMethodstopRTPStats
(reason string)
pkg/sfu/buffer/buffer_base.go:473
↓ 2 callersMethodstopRTPStatsLite
(reason string)
pkg/sfu/buffer/buffer_base.go:490
↓ 2 callersMethodstoreIngress
(_ context.Context, info *livekit.IngressInfo)
pkg/service/redisstore.go:542
↓ 2 callersMethodstoreIngressState
(_ context.Context, ingressId string, state *livekit.IngressState)
pkg/service/redisstore.go:619
↓ 2 callersMethodsubscriberRTCPWorker
subscriberRTCPWorker sends SenderReports periodically when the participant is subscribed to other publishedTracks in the room.
pkg/rtc/participant.go:2691
↓ 2 callersMethodtakeBlobResponse
()
test/singlenode_test.go:1582
↓ 2 callersMethodtakeStoreResponse
()
test/singlenode_test.go:1571
↓ 2 callersFunctiontestBatchJobRequest
(t require.TestingT, batchSize int, totalJobs int, client rpc.AgentInternalClient, workers []*testutils.AgentW
pkg/agent/agent_test.go:60
↓ 2 callersFunctiontestIter
( t *testing.T, create func(ctx context.Context, id string) error, list func(ctx context.Context, page *liv
pkg/service/redisstore_sip_test.go:316
↓ 2 callersFunctiontestRTCServicePathToTestClientOptions
(testRTCServicePath testRTCServicePath, opts *testclient.Options)
test/integration_helpers.go:256
↓ 2 callersFunctiontoAggregateDeltaInfo
(streams map[uint32]*buffer.StreamStatsWithLayers, useRemoteView bool)
pkg/sfu/connectionquality/connectionstats.go:429
↓ 2 callersMethodtoDD
()
pkg/sfu/buffer/fps_test.go:46
↓ 2 callersMethodtoH26x
()
pkg/sfu/buffer/fps_test.go:61
↓ 2 callersFunctiontoParticipants
(lps []types.LocalParticipant)
pkg/rtc/room.go:2398
↓ 2 callersMethodtoVP8
()
pkg/sfu/buffer/fps_test.go:36
↓ 2 callersMethodtrendCoefficient
()
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:298
↓ 2 callersMethodunmarkSubscribedTo
(publisherID livekit.ParticipantID, trackID livekit.TrackID)
pkg/rtc/subscriptionmanager.go:1202
↓ 2 callersFunctionunmarshalCandidate
(i ice.Candidate)
pkg/rtc/types/ice.go:353
↓ 2 callersFunctionunmarshalICECandidate
(c webrtc.ICECandidateInit)
pkg/rtc/types/ice.go:339
↓ 2 callersMethodunmarshalKeys
(keys string)
pkg/config/config.go:918
↓ 2 callersMethodunsubscribeSynchronous
(trackID livekit.TrackID)
pkg/rtc/subscriptionmanager.go:919
↓ 2 callersMethodupdateAtLocked
(stat *windowStat, at time.Time)
pkg/sfu/connectionquality/scorer.go:388
↓ 2 callersMethodupdateCongestedSignal
()
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:942
↓ 2 callersMethodupdateCongestionSignal
( qdJQRConfig CongestionSignalConfig, qdDQRConfig CongestionSignalConfig, lossJQRConfig CongestionSignalCon
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:881
↓ 2 callersMethodupdateConnectionTypeLocked
()
pkg/rtc/types/ice.go:267
↓ 2 callersMethodupdateEarlyWarningSignal
()
pkg/sfu/bwe/sendsidebwe/congestion_detector.go:933
↓ 2 callersFunctionupdateEnableTranscoding
(info *livekit.IngressInfo)
pkg/service/ingress.go:219
↓ 2 callersMethodupdateEvalInterval
()
pkg/sfu/streamtracker/streamtracker_frame.go:221
↓ 2 callersFunctionupdateInfoUsingRequest
(req *livekit.UpdateIngressRequest, info *livekit.IngressInfo)
pkg/service/ingress.go:237
↓ 2 callersMethodupdateJitter
(ets uint64, packetTime int64)
pkg/sfu/rtpstats/rtpstats_base.go:663
↓ 2 callersMethodupdateLastNegotiateLocked
()
pkg/rtc/transport.go:2015
↓ 2 callersMethodupdateLayerMuteAtLocked
(isMuted bool, at time.Time)
pkg/sfu/connectionquality/scorer.go:312
↓ 2 callersMethodupdateMuteAtLocked
(isMuted bool, at time.Time)
pkg/sfu/connectionquality/scorer.go:268
↓ 2 callersMethodupdatePauseAtLocked
(isPaused bool, at time.Time)
pkg/sfu/connectionquality/scorer.go:341
↓ 2 callersMethodupdateSNOffset
()
pkg/sfu/sequencer.go:431
↓ 2 callersFunctionverifyEncodingEqual
(t *testing.T, p1, p2 *rtp.Packet)
pkg/sfu/redreceiver_test.go:259
↓ 2 callersMethodwithinAcquireGraceLocked
withinAcquireGraceLocked reports whether the initial-acquisition grace window is still open.
pkg/sfu/forwarder.go:317
↓ 2 callersMethodworker
()
pkg/rtc/signalanddatastats.go:166
↓ 2 callersMethodworker
(generation uint32)
pkg/sfu/streamtracker/streamtracker_dd.go:230
↓ 2 callersMethodwrite
()
pkg/routing/signal.go:310
↓ 2 callersMethodwriteBlankFrameRTP
(duration float32, generation uint32)
pkg/sfu/downtrack.go:1796
↓ 2 callersMethodwriteNonSymmetric
(value, numValues uint32)
pkg/sfu/rtpextension/dependencydescriptor/dependencydescriptorwriter.go:366
↓ 2 callersMethodwritePartialByte
(source uint8, sourceBitCount int, target uint8, targetBitOffset int)
pkg/sfu/rtpextension/dependencydescriptor/bitstreamwriter.go:93
↓ 2 callersMethodwriteRTX
(rtxPkt *rtp.Packet, arrivalTime int64)
pkg/sfu/buffer/buffer.go:242
↓ 1 callersMethodAPICall
(ctx context.Context, apiCallInfo *livekit.APICallInfo)
pkg/telemetry/telemetryservice.go:87
↓ 1 callersMethodActiveAt
()
pkg/rtc/participant.go:608
↓ 1 callersMethodActiveAt
()
pkg/rtc/types/interfaces.go:415
↓ 1 callersMethodAddAgentDispatch
(dispatch *livekit.AgentDispatch)
pkg/rtc/room.go:881
↓ 1 callersMethodAddBuffer
(buff buffer.BufferProvider, layer int32)
pkg/sfu/receiver_base.go:816
↓ 1 callersMethodAddCluster
(mode ProbeClusterMode, pcg ProbeClusterGoal)
pkg/sfu/ccutils/prober.go:184
↓ 1 callersMethodAddCodec
(mime mime.MimeType)
pkg/rtc/dynacast/interfaces.go:51
↓ 1 callersMethodAddDataBlob
(dataBlob *livekit.DataBlob)
pkg/rtc/participant_data_blob_handler.go:80
↓ 1 callersMethodAddDataDownTrack
(sender DataTrackSender)
pkg/rtc/types/interfaces.go:846
↓ 1 callersMethodAddDataTrack
(dataTrack types.DataTrack, publisherIdentity livekit.ParticipantIdentity, publisherID livekit.ParticipantID)
pkg/rtc/roomtrackmanager.go:178
↓ 1 callersMethodAddDependencyDescriptorTrackers
()
pkg/sfu/streamtrackermanager.go:215
↓ 1 callersMethodAddEstimate
(estimate int64)
pkg/sfu/bwe/remotebwe/channel_observer.go:146
↓ 1 callersMethodAddLayerTransitionAt
(distance float64, at time.Time)
pkg/sfu/connectionquality/connectionstats.go:184
↓ 1 callersMethodAddNack
(packets uint32, repeatedNacks uint32)
pkg/sfu/bwe/remotebwe/channel_observer.go:150
↓ 1 callersMethodAddOnBindArgsForCall
(i int)
pkg/rtc/types/typesfakes/fake_subscribed_track.go:203
↓ 1 callersMethodAddOnBindCallCount
()
pkg/rtc/types/typesfakes/fake_subscribed_track.go:191
↓ 1 callersFunctionAddPublishedTrack
(kind string)
pkg/telemetry/prometheus/rooms.go:175
↓ 1 callersMethodAddPublisherRTT
(participantIdentity livekit.ParticipantIdentity, rtt float32)
pkg/metric/metrics_collector.go:85
↓ 1 callersMethodAddReceiver
AddReceiver adds a new RTP receiver to the track, returns true when receiver represents a new codec and if a receiver was added successfully
pkg/rtc/mediatrack.go:295
↓ 1 callersMethodAddRemoteCandidate
(c webrtc.ICECandidateInit, filtered, trickle, canUpdate bool)
pkg/rtc/types/ice.go:186
↓ 1 callersMethodAddSubscribedTrack
(subTrack types.SubscribedTrack)
pkg/rtc/transportmanager.go:332
↓ 1 callersMethodAddSubscriber
(sub types.LocalParticipant)
pkg/rtc/datatrack.go:116
↓ 1 callersMethodAddSubscriberCalls
(stub func(types.LocalParticipant) (types.DataDownTrack, error))
pkg/rtc/types/typesfakes/fake_data_track.go:230
↓ 1 callersMethodAddSubscriberCalls
(stub func(types.LocalParticipant) (types.SubscribedTrack, error))
pkg/rtc/types/typesfakes/fake_media_track.go:364
↓ 1 callersMethodAddSubscriberRTT
(rtt float32)
pkg/metric/metrics_collector.go:104
↓ 1 callersMethodAddTrack
AddTrack is called when client intends to publish track. records track details and lets client know it's ok to proceed
pkg/rtc/participant.go:1326
↓ 1 callersMethodAddTrackCalls
(stub func(*livekit.AddTrackRequest))
pkg/rtc/types/typesfakes/fake_local_participant.go:1723
↓ 1 callersMethodAddUpTrack
(track TrackRemote, buff *buffer.Buffer)
pkg/sfu/receiver.go:171
↓ 1 callersFunctionAggregateRTPDeltaInfo
(deltaInfoList []*RTPDeltaInfo)
pkg/sfu/rtpstats/rtpstats_base.go:839
↓ 1 callersMethodAutoCreateEnabled
(ctx context.Context)
pkg/service/interfaces.go:82
↓ 1 callersMethodAutoCreateEnabledReturns
(result1 bool)
pkg/service/servicefakes/fake_room_allocator.go:110
↓ 1 callersMethodBWEType
get the BWE type in use
pkg/sfu/downtrack.go:250
↓ 1 callersMethodBaseSendTimeThreshold
(threshold int64)
pkg/sfu/bwe/sendsidebwe/packet_tracker.go:94
↓ 1 callersMethodBitrate
()
pkg/sfu/ccutils/prober.go:371
↓ 1 callersFunctionBroadcastDataMessageForRoom
(r types.Room, source types.LocalParticipant, data []byte, logger logger.Logger)
pkg/rtc/room.go:2157
↓ 1 callersFunctionBroadcastDataPacketForRoom
------------------------------------------------------------
pkg/rtc/room.go:2094
↓ 1 callersFunctionBroadcastMetricsForRoom
(r types.Room, source types.Participant, dp *livekit.DataPacket, logger logger.Logger)
pkg/rtc/room.go:2167
↓ 1 callersMethodBufferedAmount
()
pkg/sfu/datachannel/datachannel_writer_test.go:131
↓ 1 callersMethodBytesRead
()
pkg/sfu/rtpextension/dependencydescriptor/bitstreamreader.go:124
↓ 1 callersMethodCacheDownTrack
(trackID livekit.TrackID, rtpTransceiver *webrtc.RTPTransceiver, downTrackState sfu.DownTrackState)
pkg/rtc/types/interfaces.go:534
← previousnext →1,601–1,700 of 7,437, ranked by callers