diff --git a/dependencies.tsv b/dependencies.tsv index ae64cf9..9855e5f 100644 --- a/dependencies.tsv +++ b/dependencies.tsv @@ -6,7 +6,7 @@ github.com/gorilla/websocket git ea4d1f681babbce9545c9c5f3d5194a789c89f5b 2017-0 github.com/mailru/easyjson git 2f5df55504ebc322e4d52d34df6a1f5b503bf26d 2017-06-24T19:09:25Z github.com/nats-io/go-nats git d4ca4c8b588d5da9c2ac82d6e445ce4feaba18ba 2017-06-01T15:47:09Z github.com/nats-io/nuid git 3cf34f9fca4e88afa9da8eabd75e3326c9941b44 2017-03-03T15:02:24Z -github.com/notedit/janus-go git 8e6e2c423c03884d938d84442d37d6f6f5294197 2017-06-11T06:05:37Z +github.com/notedit/janus-go git 10eb8b95d1a0469ac8921c5ce5fb55b4c0d3ad7d 2020-05-17T10:12:15Z github.com/oschwald/maxminddb-golang git 1960b16a5147df3a4c61ac83b2f31cd8f811d609 2019-05-23T23:57:38Z golang.org/x/net git f01ecb60fe3835d80d9a0b7b2bf24b228c89260e 2017-07-11T18:12:19Z golang.org/x/sys git ac767d655b305d4e9612f5f6e33120b9176c4ad4 2018-07-15T08:55:29Z diff --git a/src/signaling/janus_client.go b/src/signaling/janus_client.go index 5a47ff9..f0d258b 100644 --- a/src/signaling/janus_client.go +++ b/src/signaling/janus_client.go @@ -450,7 +450,7 @@ func (gateway *JanusGateway) recv() { } // Pass message on from here - if base.Id == "" { + if base.ID == "" { // Is this a Handle event? if base.Handle == 0 { // Nope. No idea what's going on... @@ -478,9 +478,9 @@ func (gateway *JanusGateway) recv() { go passMsg(handle.Events, msg) } } else { - id, err := strconv.ParseUint(base.Id, 10, 64) + id, err := strconv.ParseUint(base.ID, 10, 64) if err != nil { - log.Printf("Could not decode transaction id %s: %s", base.Id, err) + log.Printf("Could not decode transaction id %s: %s", base.ID, err) continue } @@ -558,7 +558,7 @@ func (gateway *JanusGateway) Create(ctx context.Context) (*JanusSession, error) // Create new session session := new(JanusSession) session.gateway = gateway - session.Id = success.Data.Id + session.Id = success.Data.ID session.Handles = make(map[uint64]*JanusHandle) // Store this session @@ -615,7 +615,7 @@ func (session *JanusSession) Attach(ctx context.Context, plugin string) (*JanusH handle := new(JanusHandle) handle.session = session - handle.Id = success.Data.Id + handle.Id = success.Data.ID handle.Events = make(chan interface{}, 8) session.Lock() diff --git a/src/signaling/mcu_janus.go b/src/signaling/mcu_janus.go index 0acd282..1aa7b9e 100644 --- a/src/signaling/mcu_janus.go +++ b/src/signaling/mcu_janus.go @@ -678,9 +678,9 @@ func (p *mcuJanusPublisher) handleConnected(event *janus.WebRTCUpMsg) { func (p *mcuJanusPublisher) handleSlowLink(event *janus.SlowLinkMsg) { if event.Uplink { - log.Printf("Publisher %s (%d) is reporting %d NACKs on the uplink (Janus -> client)", p.listener.PublicId(), p.handleId, event.Nacks) + log.Printf("Publisher %s (%d) is reporting %d lost packets on the uplink (Janus -> client)", p.listener.PublicId(), p.handleId, event.Lost) } else { - log.Printf("Publisher %s (%d) is reporting %d NACKs on the downlink (client -> Janus)", p.listener.PublicId(), p.handleId, event.Nacks) + log.Printf("Publisher %s (%d) is reporting %d lost packets on the downlink (client -> Janus)", p.listener.PublicId(), p.handleId, event.Lost) } } @@ -966,9 +966,9 @@ func (p *mcuJanusSubscriber) handleConnected(event *janus.WebRTCUpMsg) { func (p *mcuJanusSubscriber) handleSlowLink(event *janus.SlowLinkMsg) { if event.Uplink { - log.Printf("Subscriber %s (%d) is reporting %d NACKs on the uplink (Janus -> client)", p.listener.PublicId(), p.handleId, event.Nacks) + log.Printf("Subscriber %s (%d) is reporting %d lost packets on the uplink (Janus -> client)", p.listener.PublicId(), p.handleId, event.Lost) } else { - log.Printf("Subscriber %s (%d) is reporting %d NACKs on the downlink (client -> Janus)", p.listener.PublicId(), p.handleId, event.Nacks) + log.Printf("Subscriber %s (%d) is reporting %d lost packets on the downlink (client -> Janus)", p.listener.PublicId(), p.handleId, event.Lost) } }