MCPcopy Create free account

hub / github.com/peer-calls/peer-calls / functions

Functions1,240 in github.com/peer-calls/peer-calls

↓ 1 callersMethodstart
(pingTicker clock.Ticker)
server/udptransport2/factory.go:218
↓ 1 callersMethodstart
()
server/udptransport2/manager.go:68
↓ 1 callersMethodstart
(in <-chan PubTrackEvent)
server/pubsub/events.go:46
↓ 1 callersMethodstartLoop
()
server/udpmux/udpmux.go:104
↓ 1 callersMethodstartRTCPLoop
(ctx context.Context, stream *playStream)
server/cli/play.go:211
↓ 1 callersMethodstartRTPLoop
(ctx context.Context, stream *playStream)
server/cli/play.go:185
↓ 1 callersMethodstartReadLoop
()
server/servertransport/metadata_transport.go:127
↓ 1 callersMethodstartReadLoop
()
server/udptransport2/control_transport.go:46
↓ 1 callersMethodstartReadLoop
()
server/pubsub/track_reader.go:52
↓ 1 callersMethodstartReading
(ctx context.Context)
server/udpmux/udpmux.go:252
↓ 1 callersMethodstartReading
(ctx context.Context)
server/stringmux/stringmux.go:207
↓ 1 callersMethodstartRoomEventLoop
()
server/nodemanager.go:213
↓ 1 callersFunctionstartSignalling
( t *testing.T, wsClient *server.Client, wsRecvCh <-chan message.Message, clientID identifiers.ClientID,
server/sfu_test.go:83
↓ 1 callersMethodstartTransportEventLoop
()
server/nodemanager.go:101
↓ 1 callersMethodstartWriteLoop
()
server/servertransport/metadata_transport.go:91
↓ 1 callersMethodstartWriteLoop
()
server/udptransport2/control_transport.go:78
↓ 1 callersFunctionstopTrack
(track: MediaStreamTrack)
src/client/reducers/streams.ts:298
↓ 1 callersMethodsub
(pub publisher, tr Transport)
server/pubsub/pubsub.go:161
↓ 1 callersMethodsubscribe
Reads from subscribed keys and dispatches relevant messages to client websockets. This method blocks until the context is closed.
server/redisadapter.go:329
↓ 1 callersMethodsubscribe
()
server/servertransport/track_local.go:138
↓ 1 callersMethodsubscribeUntilReady
(timeout time.Duration)
server/redisadapter.go:368
↓ 1 callersFunctiontoggle
(state: SidebarState)
src/client/reducers/sidebar.ts:14
↓ 1 callersFunctionunminimize
(state: WindowStates, key: string)
src/client/reducers/windowStates.ts:17
↓ 1 callersMethodunsafeAddTrack
(streamId: string, track: MediaStreamTrack)
src/client/audio/AudioProcessor.ts:53
↓ 1 callersMethodupdateJitter
Report is implemented according to the RFC 3550 Appendix A.8.
server/sfu/stats/source.go:120
↓ 1 callersMethodupdateSeq
updateSeq is implemented according to the RFC 3550 Appendix A.1.
server/sfu/stats/source.go:63
↓ 1 callersFunctionwaitForUsersEvent
(t *testing.T, ctx context.Context, ch <-chan message.Message)
server/sfu_test.go:63
↓ 1 callersFunctionwithDefault
( state: Partial<SettingsState> | null, init: SettingsState, )
src/client/reducers/settings.ts:21
↓ 1 callersFunctionworkerFunc
( encodeHeader: EncodeHeader, headerSizeBytes: number, )
src/client/codec/index.ts:62
MethodAdd
(room identifiers.RoomID, transport transport.Transport)
server/mux_test.go:46
MethodAdd
(client server.ClientWriter)
server/mesh_test.go:69
MethodAdd
(client ClientWriter)
server/wsadapter.go:17
MethodAdd
Add wraps MultiErr.Add with a mutex lock.
server/multierr/sync.go:12
MethodAdd
(fn func())
server/test/testcloser.go:25
MethodAdd
Add adds a transport with ClientID. If there was already an existing Transport with the same ClientID, it will be closed and removed before a new one
server/sfu/peer_manager.go:80
MethodAdd
Add adds a transport to the existing PeerManager. If the manager does not exist, it is created. NOTE: rooms are created when the peer joins the room
server/sfu/tracks_manager.go:40
MethodAddTrack
(t transport.Track)
server/webrtctransport.go:392
MethodAddTrack
(Track)
server/transport/transport.go:30
MethodAddTrack
(track transport.Track)
server/servertransport/metadata_transport.go:315
MethodAddTrack
(track transport.Track)
server/pubsub/pubsub_test.go:475
FunctionBenchmarkDefer
(b *testing.B)
server/juju_test.go:57
FunctionBenchmarkJuju
(b *testing.B)
server/juju_test.go:38
FunctionBenchmarkLogger_Disabled
(b *testing.B)
server/logger/logger_test.go:307
FunctionBenchmarkLogger_Enabled
(b *testing.B)
server/logger/logger_test.go:324
FunctionBenchmarkLogger_EnabledWithoutSorting
(b *testing.B)
server/logger/logger_test.go:341
FunctionBenchmarkNewUUID_base62
(b *testing.B)
server/uuid/uuid_test.go:20
FunctionBenchmarkNewUUID_normal
(b *testing.B)
server/uuid/uuid_test.go:14
FunctionBenchmarkNoDefer
(b *testing.B)
server/juju_test.go:63
FunctionBenchmarkNoJuju
(b *testing.B)
server/juju_test.go:33
MethodBroadcast
(message message.Message)
server/mesh_test.go:77
MethodC
C implements the Ticker and Timer interfaces.
server/clock/mock.go:129
MethodC
C implements the Ticker interface.
server/clock/clock.go:83
MethodC
C implements the timer interface.
server/clock/clock.go:158
MethodClientID
()
server/webrtctransport.go:338
MethodClientID
()
server/transport/transport.go:19
MethodClientID
()
server/servertransport/transport.go:130
MethodClientID
()
server/pubsub/pubsub_test.go:466
MethodClients
()
server/mesh_test.go:86
MethodClose
Close closes the subscription, but not the redis clients
server/redisadapter.go:412
MethodClose
()
server/nodemanager.go:268
MethodClose
()
server/mesh_test.go:90
MethodClose
(statusCode websocket.StatusCode, reason string)
server/test_test.go:55
MethodClose
()
server/wsadapter.go:25
MethodClose
()
server/memoryadapter.go:54
MethodClose
()
server/datatransceiver.go:142
MethodClose
()
server/servertransport/media_stream.go:287
MethodClose
()
server/servertransport/rtcp_reader.go:53
MethodClose
()
server/servertransport/track_remote.go:127
MethodClose
()
server/servertransport/track_local.go:146
MethodClose
()
server/servertransport/metadata_transport.go:408
MethodClose
()
server/servertransport/data_transport.go:108
MethodClose
()
server/cli/play/rtcp_reader.go:56
MethodClose
()
server/cli/play/rtp_reader.go:80
MethodClose
()
server/cli/play/rtcp_writer.go:49
MethodClose
()
server/test/testcloser.go:10
MethodClose
()
server/udpmux/udpmux.go:286
MethodClose
()
server/udpmux/conn.go:32
MethodClose
()
server/stringmux/conn.go:42
MethodClose
()
server/stringmux/stringmux.go:285
MethodClose
()
server/sfu/peer_manager.go:460
MethodClose
()
server/udptransport2/factory.go:562
MethodClose
()
server/udptransport2/control_transport.go:126
MethodClose
Close closes the subscription channel. The caller must ensure that no other methods are called after close has been called.
server/pubsub/pubsub.go:343
MethodCloseWrite
()
server/stringmux/conn.go:38
MethodCloseWrite
()
server/udptransport2/transport.go:51
MethodConns
Conns is the channel with incoming connections. Users should use either AcceptConn or Conns, but never both.
server/stringmux/stringmux.go:246
MethodCtx
Ctx implements Logger.
server/logger/logger.go:94
MethodDebug
Debug implements Logger.
server/logger/logger.go:189
MethodDeserialize
(data []byte)
server/wsmessage.go:25
MethodDone
()
server/wrtcnegotiator.go:73
MethodDone
()
server/webrtctransport.go:356
MethodDone
()
server/servertransport/transport.go:134
MethodDone
()
server/udpmux/udpmux.go:282
MethodDone
()
server/udpmux/conn.go:15
MethodDone
()
server/udpmux/conn.go:54
MethodDone
()
server/stringmux/conn.go:64
MethodDone
()
server/stringmux/stringmux.go:308
MethodDone
()
server/udptransport2/factory.go:536
MethodDone
()
server/pubsub/events.go:126
MethodEmit
(clientID identifiers.ClientID, msg message.Message)
server/redisadapter.go:487
← previousnext →701–800 of 1,240, ranked by callers