Minor fix.

xwinwin · Apr 3, 2021 · 0c983c1 · 0c983c1
1 parent ffca46a
commit 0c983c1
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/pkg/node/islb/server.go b/pkg/node/islb/server.go
@@ -60,6 +60,10 @@ func (s *islbServer) FindNode(ctx context.Context, req *proto.FindNodeRequest) (
 
 	nodes := []*ion.Node{}
 
+	if nid == "" {
+		nid = "*"
+	}
+
 	// find node by sid from reids
 	mkey := s.conf.Global.Dc + "/" + nid + "/" + sid
 	log.Infof("islb.FindNode: mkey => %v", mkey)

diff --git a/pkg/util/sdp.go b/pkg/util/sdp.go
@@ -25,6 +25,10 @@ func ParseSDP(sdpstr string) ([]*ion.Stream, error) {
 			msid := m.Attributes.Get("msid")
 			//fmt.Printf("msid id = %v\n", msid)
 
+			if msid == "" {
+				continue
+			}
+
 			strs := strings.Split(msid, " ")
 			streamID := strs[0]
 			trackID := msid