streamd: Add callerAddress and callerPort to srtStats

Author: hmelder

streamd/gstreamer_srt_stats.go

@@ -1,10 +1,13 @@
 package main
 
 import (
+	"errors"
 	"fmt"
+	"net"
 	"time"
 	"unsafe"
 
+	"github.com/go-gst/go-glib/glib"
 	"github.com/go-gst/go-gst/gst"
 )
 
@@ -68,7 +71,8 @@ type srtCallerStats struct {
 
 	negotiatedLatencyMS int
 
-	// callerAddress net.IP
+	callerAddress net.IP
+	callerPort    uint16
 }
 
 // Retrieve value from name and convert it to the correct time (known at compile time)
@@ -148,6 +152,19 @@ func (s *srtStats) convertCallerStats(arr []interface{}) error {
 			return fmt.Errorf("struct has wrong mimetype '%s'", name)
 		}
 
+		socketAddress, err := gs.GetValue("caller-address")
+		if err != nil {
+			return err
+		}
+		socketAddressObj, ok := socketAddress.(*glib.Object)
+		if ok != true {
+			return errors.New("caller-address is not a glib object")
+		}
+		sc.callerAddress, sc.callerPort, err = inetSocketAddressIP(socketAddressObj.Unsafe())
+		if err != nil {
+			return err
+		}
+
 		intProps := []struct {
 			dest *int
 			name string