deblan-mirror/nextcloud-spreed-signaling
deblan-mirror/nextcloud-spreed-signaling
1
0
Fork 0
mirror of https://github.com/strukturag/nextcloud-spreed-signaling synced 2024-06-08 17:02:18 +02:00
Code Issues Releases Wiki Activity

Log something if mcu publisher / subscriber was closed.

Browse source
This commit is contained in:
Joachim Bauch 2024-05-16 09:44:47 +02:00
parent 0b259a8171
commit c58564c0e8
No known key found for this signature in database
GPG key ID: 77C1D22D53E15F02
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
mcu_proxy.go
View file

@ -162,6 +162,7 @@ func (p *mcuProxyPublisher) SetMedia(mt MediaType) {
}
func (p *mcuProxyPublisher) NotifyClosed() {
log.Printf("Publisher %s at %s was closed", p.proxyId, p.conn)
p.listener.PublisherClosed(p)
p.conn.removePublisher(p)
}
@ -185,7 +186,7 @@ func (p *mcuProxyPublisher) Close(ctx context.Context) {
return
}
log.Printf("Delete publisher %s at %s", p.proxyId, p.conn)
log.Printf("Deleted publisher %s at %s", p.proxyId, p.conn)
}
func (p *mcuProxyPublisher) SendMessage(ctx context.Context, message *MessageClientMessage, data *MessageClientMessageData, callback func(error, map[string]interface{})) {
@ -243,6 +244,7 @@ func (s *mcuProxySubscriber) Publisher() string {
}
func (s *mcuProxySubscriber) NotifyClosed() {
log.Printf("Subscriber %s at %s was closed", s.proxyId, s.conn)
s.listener.SubscriberClosed(s)
s.conn.removeSubscriber(s)
}
@ -266,7 +268,7 @@ func (s *mcuProxySubscriber) Close(ctx context.Context) {
return
}
log.Printf("Delete subscriber %s at %s", s.proxyId, s.conn)
log.Printf("Deleted subscriber %s at %s", s.proxyId, s.conn)
}
func (s *mcuProxySubscriber) SendMessage(ctx context.Context, message *MessageClientMessage, data *MessageClientMessageData, callback func(error, map[string]interface{})) {