Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/atomirex/umbrella
/ functions
Functions
147 in github.com/atomirex/umbrella
⨍
Functions
147
◇
Types & classes
47
↓ 44 callers
Method
Error
(component string, msg string)
razor/logger.go:77
↓ 41 callers
Method
Info
(component string, msg string)
razor/logger.go:85
↓ 28 callers
Method
Send
(what MessageQueueWhat, payload *PayloadType)
razor/messagehandler.go:42
↓ 28 callers
Method
log
(level LoggingLevel, component string, msg string)
razor/logger.go:49
↓ 23 callers
Method
String
()
sfu/tracks.go:16
↓ 13 callers
Method
NilErrCheck
(component string, msg string, err error)
razor/logger.go:55
↓ 13 callers
Method
Timeout
(what MessageQueueWhat, payload *PayloadType, delay time.Duration)
razor/messagehandler.go:64
↓ 12 callers
Method
Cancel
(what MessageQueueWhat)
razor/messagehandler.go:84
↓ 11 callers
Method
Leave
()
razor/lockandnotify.go:47
↓ 9 callers
Function
log
(msg: string)
frontend/src/umbrella/SfuApp.tsx:162
↓ 8 callers
Method
Trace
(component string, msg string)
razor/logger.go:97
↓ 8 callers
Method
UmbrellaID
This points to the definition of descriptor being wrong i.e. the descriptor needs to include separate fields for the mid, the id, the src mid etc. the
sfu/tracks.go:53
↓ 7 callers
Method
Enter
()
razor/lockandnotify.go:43
↓ 6 callers
Method
writeProto
(m *RemoteNodeMessage)
sfu/client_webrtc.go:702
↓ 5 callers
Method
Notify
This is really dangerous if we've aborted!
razor/lockandnotify.go:52
↓ 5 callers
Method
Verbose
(component string, msg string)
razor/logger.go:89
↓ 4 callers
Function
NilOptional
()
razor/common.go:21
↓ 4 callers
Function
mkdir
(dir)
frontend/build.js:11
↓ 3 callers
Method
Close
()
sfu/peerconnection.go:103
↓ 3 callers
Method
GetStatus
()
sfu/sfu.go:73
↓ 3 callers
Method
Label
()
sfu/clients.go:12
↓ 3 callers
Method
Loop
(oncleanup func())
razor/messagehandler.go:166
↓ 3 callers
Function
NewMessageHandler
(logger *Logger, label string, queueLength uint16, callback MessageHandlerCallback[MessageQueueWhat, PayloadTy
razor/messagehandler.go:23
↓ 3 callers
Function
NewOptional
(value T)
razor/common.go:17
↓ 3 callers
Method
NewPeerConnection
(label string)
sfu/peerconnection.go:23
↓ 3 callers
Method
Wait
(delay time.Duration)
razor/lockandnotify.go:56
↓ 3 callers
Method
WriteHeader
(code int)
main.go:43
↓ 3 callers
Method
heapifyDown
(index uint16)
razor/messagequeue.go:138
↓ 3 callers
Method
removeOutgoingTracksForIncomingTrack
(t *incomingTrack)
sfu/sfu.go:315
↓ 3 callers
Method
run
(ws *websocket.Conn, s *Sfu)
sfu/client_webrtc.go:89
↓ 3 callers
Method
stop
()
sfu/client_webrtc.go:353
↓ 2 callers
Method
Abort
Clears all work and stops any loops Does not block waiting though
razor/messagehandler.go:203
↓ 2 callers
Method
AddTransceiverFromKind
(kind webrtc.RTPCodecType, params webrtc.RTPTransceiverInit)
sfu/peerconnection.go:133
↓ 2 callers
Method
Assert
(component string, msg string, condition bool)
razor/logger.go:67
↓ 2 callers
Method
CancelAll
()
razor/messagehandler.go:99
↓ 2 callers
Method
CreateDataChannel
(name string, params *webrtc.DataChannelInit)
sfu/peerconnection.go:113
↓ 2 callers
Method
Debug
(component string, msg string)
razor/logger.go:93
↓ 2 callers
Method
GetReceivers
()
sfu/peerconnection.go:117
↓ 2 callers
Method
GetTransceivers
()
sfu/peerconnection.go:125
↓ 2 callers
Method
IsTerminated
()
sfu/peerconnection.go:137
↓ 2 callers
Method
NewClient
(params *RemoteClientParameters)
sfu/clients.go:37
↓ 2 callers
Method
SetLocalDescription
(description webrtc.SessionDescription)
sfu/peerconnection.go:164
↓ 2 callers
Method
SetRemoteDescription
(description webrtc.SessionDescription)
sfu/peerconnection.go:160
↓ 2 callers
Function
Swap
(a, b *T)
razor/common.go:25
↓ 2 callers
Method
TryPush
(at time.Time, what MessageQueueWhat, payload *PayloadType)
razor/messagequeue.go:37
↓ 2 callers
Method
continueWebsocket
(s *Sfu)
sfu/client_webrtc.go:706
↓ 2 callers
Method
evalIncomingState
(s *Sfu)
sfu/client_webrtc.go:499
↓ 2 callers
Function
evaluateIncomingTracks
()
frontend/src/umbrella/SfuApp.tsx:201
↓ 2 callers
Function
offerNeeded
()
frontend/src/umbrella/SfuApp.tsx:334
↓ 2 callers
Function
runCommand
(cmd)
frontend/build.js:30
↓ 2 callers
Function
trackKindFromString
(k: string)
frontend/src/umbrella/SfuApp.tsx:6
↓ 2 callers
Function
updateHtml
(input, output)
frontend/build.js:54
↓ 1 callers
Method
AddICECandidate
(candidate webrtc.ICECandidateInit)
sfu/peerconnection.go:148
↓ 1 callers
Method
AddOutgoingTracksForIncomingTrack
(*incomingTrack)
sfu/clients.go:15
↓ 1 callers
Method
AddTrack
(track webrtc.TrackLocal)
sfu/peerconnection.go:168
↓ 1 callers
Function
Assert
(cond bool)
razor/common.go:29
↓ 1 callers
Method
Clear
()
razor/messagequeue.go:90
↓ 1 callers
Method
CreateAnswer
(options *webrtc.AnswerOptions)
sfu/peerconnection.go:152
↓ 1 callers
Method
CreateOffer
(options *webrtc.OfferOptions)
sfu/peerconnection.go:156
↓ 1 callers
Method
CurrentSize
()
razor/messagequeue.go:29
↓ 1 callers
Method
DoWork
(now time.Time)
razor/messagehandler.go:114
↓ 1 callers
Method
GetCurrentServers
()
sfu/sfu.go:83
↓ 1 callers
Method
GetSenders
()
sfu/peerconnection.go:121
↓ 1 callers
Function
NewLockAndNotify
()
razor/lockandnotify.go:16
↓ 1 callers
Function
NewLogger
(level LoggingLevel, panicOnAssertFailure bool)
razor/logger.go:45
↓ 1 callers
Function
NewSfu
(logger *razor.Logger, minPort uint16, maxPort uint16, ip *string)
sfu/sfu.go:106
↓ 1 callers
Method
NextWorkAt
()
razor/messagehandler.go:153
↓ 1 callers
Method
RemoveMessagesOfWhat
(what WHAT)
razor/messagequeue.go:103
↓ 1 callers
Method
RemoveOutgoingTracksForIncomingTrack
(*incomingTrack)
sfu/clients.go:16
↓ 1 callers
Method
RemoveTrack
(sender *webrtc.RTPSender)
sfu/peerconnection.go:172
↓ 1 callers
Method
RequestEvalState
()
sfu/clients.go:17
↓ 1 callers
Method
SetCurrentServers
(update *CurrentServers)
sfu/sfu.go:93
↓ 1 callers
Method
SetMdnsConn
(mdnsConn *mdns.Conn)
sfu/sfu.go:329
↓ 1 callers
Method
TryPeek
()
razor/messagequeue.go:81
↓ 1 callers
Method
TryPopAtTime
(at time.Time)
razor/messagequeue.go:64
↓ 1 callers
Method
UmbrellaID
()
sfu/tracks.go:61
↓ 1 callers
Function
WaitForOsInterruptSignal
()
razor/common.go:35
↓ 1 callers
Method
WebsocketHandler
(w http.ResponseWriter, r *http.Request)
sfu/sfu.go:319
↓ 1 callers
Method
WriteRTCP
(pkts []rtcp.Packet)
sfu/peerconnection.go:129
↓ 1 callers
Method
addTrack
(intrack *incomingTrack)
sfu/sfu.go:311
↓ 1 callers
Method
evalState
(s *Sfu)
sfu/client_webrtc.go:580
↓ 1 callers
Method
evaluateServers
()
sfu/sfu.go:285
↓ 1 callers
Method
fanoutIncoming
(intrack *incomingTrack, s *Sfu)
sfu/client_webrtc.go:547
↓ 1 callers
Method
getStatus
()
sfu/clients.go:13
↓ 1 callers
Method
handleWsMessage
(message *RemoteNodeMessage, s *Sfu)
sfu/client_webrtc.go:362
↓ 1 callers
Method
heapifyUp
(index uint16)
razor/messagequeue.go:125
↓ 1 callers
Method
mdnsLookup
Use our own mdns for resolving .local addresses to work around compatibility problems If we are in cloud mode this will return an error If the host is
sfu/sfu.go:337
↓ 1 callers
Method
pcTerminated
()
sfu/client_webrtc.go:358
↓ 1 callers
Function
removePrefix
(path: string)
frontend/src/index.tsx:20
↓ 1 callers
Function
removeServerClick
(server: string)
frontend/src/umbrella/SfuApp.tsx:549
↓ 1 callers
Function
runApp
()
frontend/src/index.tsx:28
↓ 1 callers
Method
stop
()
sfu/clients.go:14
↓ 1 callers
Function
trackKindToString
(k: TrackKind)
frontend/src/umbrella/SfuApp.tsx:17
↓ 1 callers
Function
trackKindToWebrtcKind
(kind TrackKind)
sfu/descriptors.go:5
Method
AddOutgoingTracksForIncomingTrack
(intrack *incomingTrack)
sfu/client_rtsp.go:194
Method
AddOutgoingTracksForIncomingTrack
(intrack *incomingTrack)
sfu/client_webrtc.go:827
Method
Capacity
()
razor/messagequeue.go:33
Method
Capacity
()
razor/messagehandler.go:38
Function
ClientStatusListElement
({client})
frontend/src/umbrella/SfuApp.tsx:599
Function
EmptyApp
()
frontend/src/index.tsx:7
next →
1–100 of 147, ranked by callers