fix message

Author: e04

srt.go

@@ -297,7 +297,7 @@ func openSrtStream(addr string) (io.ReadCloser, error) {
 }
 
 func openUDPWriter(addr string) (io.WriteCloser, error) {
-    u, err := url.Parse(addr)
+	u, err := url.Parse(addr)
 	if err != nil {
 		return nil, err
 	}

srtla.go

@@ -61,7 +61,7 @@ func randomBytes(n int) []byte {
 	if _, err := io.ReadFull(rand.Reader, b); err != nil {
 		// crypto/rand should never fail on *nix, fall back to math/rand if it
 		// ever does.
-		log.Printf("warning: crypto/rand failed (%v); falling back to pseudo-rand", err)
+		log.Printf("Warning: crypto/rand failed (%v); falling back to pseudo-rand", err)
 		for i := range b {
 			b[i] = byte(mathrand.Intn(256))
 		}
@@ -161,14 +161,14 @@ func sendRegErr(addr *net.UDPAddr) {
 
 func registerGroup(addr *net.UDPAddr, pkt []byte) {
 	if len(groups) >= MaxGroups {
-		log.Printf("[%s] registration failed: max groups reached", addr)
+		log.Printf("[%s] Registration failed: Max groups reached", addr)
 		sendRegErr(addr)
 		return
 	}
 
 	// Prevent duplicate registration from same remote addr
 	if g, _ := findByAddr(addr); g != nil {
-		log.Printf("[%s] registration failed: addr already in group", addr)
+		log.Printf("[%s] Registration failed: Addr already in group", addr)
 		sendRegErr(addr)
 		return
 	}
@@ -186,15 +186,15 @@ func registerGroup(addr *net.UDPAddr, pkt []byte) {
 	copy(out[2:], g.id[:])
 
 	if _, err := srtlaSock.WriteToUDP(out, addr); err != nil {
-		log.Printf("[%s] registration failed: %v", addr, err)
+		log.Printf("[%s] Registration failed: %v", addr, err)
 		return
 	}
 
 	groupsMu.Lock()
 	groups = append(groups, g)
 	groupsMu.Unlock()
 
-	log.Printf("[%s] [group %p] registered", addr, g)
+	log.Printf("[%s] [group %p] Registered", addr, g)
 }
 
 func registerConn(addr *net.UDPAddr, pkt []byte) {
@@ -204,14 +204,14 @@ func registerConn(addr *net.UDPAddr, pkt []byte) {
 		var hdr [2]byte
 		binary.BigEndian.PutUint16(hdr[:], SRTLATypeRegNGP)
 		srtlaSock.WriteToUDP(hdr[:], addr)
-		log.Printf("[%s] conn registration failed: no group", addr)
+		log.Printf("[%s] Conn registration failed: no group", addr)
 		return
 	}
 
 	// Reject if this addr is already tied to another group
 	if tmp, _ := findByAddr(addr); tmp != nil && tmp != g {
 		sendRegErr(addr)
-		log.Printf("[%s] [group %p] conn reg failed: addr in other group", addr, g)
+		log.Printf("[%s] [group %p] Conn registration failed: Addr in other group", addr, g)
 		return
 	}
 
@@ -231,7 +231,7 @@ func registerConn(addr *net.UDPAddr, pkt []byte) {
 		if len(g.conns) >= MaxConnsPerGroup {
 			g.mu.Unlock()
 			sendRegErr(addr)
-			log.Printf("[%s] [group %p] conn reg failed: too many conns", addr, g)
+			log.Printf("[%s] [group %p] Conn registration failed: Too many conns", addr, g)
 			return
 		}
 		g.conns = append(g.conns, &Conn{addr: addr, lastRcvd: time.Now()})
@@ -246,7 +246,7 @@ func registerConn(addr *net.UDPAddr, pkt []byte) {
 	binary.BigEndian.PutUint16(hdr[:], SRTLATypeReg3)
 	_, _ = srtlaSock.WriteToUDP(hdr[:], addr)
 
-	log.Printf("[%s] [group %p] conn registered", addr, g)
+	log.Printf("[%s] [group %p] Conn Registered", addr, g)
 }
 
 func startSRTReader(g *Group) {
@@ -281,7 +281,7 @@ func handleSRTData(g *Group, pkt []byte) {
 		defer g.mu.Unlock()
 		for _, c := range g.conns {
 			if _, err := srtlaSock.WriteToUDP(pkt, c.addr); err != nil {
-				log.Printf("[%s] [group %p] failed to fwd SRT ACK: %v", c.addr, g, err)
+				log.Printf("[%s] [group %p] Failed to fwd SRT ACK: %v", c.addr, g, err)
 			}
 		}
 	} else {
@@ -291,7 +291,7 @@ func handleSRTData(g *Group, pkt []byte) {
 		g.mu.Unlock()
 		if dst != nil {
 			if _, err := srtlaSock.WriteToUDP(pkt, dst); err != nil {
-				log.Printf("[%s] [group %p] failed to fwd SRT pkt: %v", dst, g, err)
+				log.Printf("[%s] [group %p] Failed to fwd SRT pkt: %v", dst, g, err)
 			}
 		}
 	}
@@ -329,7 +329,7 @@ func handleSRTLAIncoming(pkt []byte, addr *net.UDPAddr) {
 		conn, err := net.DialUDP("udp", nil, srtAddr)
 		if err != nil {
 			g.mu.Unlock()
-			log.Printf("[group %p] failed to dial SRT server: %v", g, err)
+			log.Printf("[group %p] Failed to dial SRT server: %v", g, err)
 			removeGroup(g)
 			return
 		}
@@ -339,7 +339,7 @@ func handleSRTLAIncoming(pkt []byte, addr *net.UDPAddr) {
 		g.srtSock = conn
 		g.mu.Unlock()
 		startSRTReader(g)
-		log.Printf("[group %p] created SRT socket (local %s)", g, conn.LocalAddr())
+		log.Printf("[group %p] Created SRT socket (local %s)", g, conn.LocalAddr())
 	} else {
 		g.mu.Unlock()
 	}
@@ -353,7 +353,7 @@ func handleSRTLAIncoming(pkt []byte, addr *net.UDPAddr) {
 
 	_, err := srtConn.Write(pkt)
 	if err != nil {
-		log.Printf("[group %p] failed to fwd SRTLA pkt: %v", g, err)
+		log.Printf("[group %p] Failed to fwd SRTLA pkt: %v", g, err)
 		g.close()
 		removeGroup(g)
 	}
@@ -374,7 +374,7 @@ func cleanup() {
 			if now.Sub(c.lastRcvd) < ConnTimeout {
 				newConns = append(newConns, c)
 			} else {
-				log.Printf("[%s] [group %p] connection timed out", c.addr, g)
+				log.Printf("[%s] [group %p] Connection timed out", c.addr, g)
 			}
 		}
 		if len(newConns) != len(g.conns) {
@@ -391,7 +391,7 @@ func cleanup() {
 		if keep {
 			newGroups = append(newGroups, g)
 		} else {
-			log.Printf("[group %p] removed (no connections)", g)
+			log.Printf("[group %p] Removed (No connections)", g)
 			g.close()
 		}
 	}
@@ -430,7 +430,7 @@ func resolveSRTAddr(host string, port uint16) (*net.UDPAddr, error) {
 	}
 	// Fallback to first IP even if handshake failed
 	if len(addrs) == 0 {
-		return nil, fmt.Errorf("no IPs for host %s", host)
+		return nil, fmt.Errorf("No IPs for host %s", host)
 	}
 	return &net.UDPAddr{IP: addrs[0], Port: int(port)}, nil
 }
@@ -445,20 +445,20 @@ func runSrtla(srtlaPort uint, srtHost string, srtPort uint, verbose bool) {
 	var err error
 	srtAddr, err = resolveSRTAddr(srtHost, uint16(srtPort))
 	if err != nil {
-		log.Fatalf("could not resolve downstream SRT server: %v", err)
+		log.Fatalf("Could not resolve downstream SRT server: %v", err)
 	}
-	log.Printf("downstream SRT server %s", srtAddr)
+	log.Printf("Downstream SRT server %s", srtAddr)
 
 	// Listen UDP (dual-stack) for SRT-LA
 	laddr := &net.UDPAddr{IP: net.IPv6unspecified, Port: int(srtlaPort)}
 	srtlaSock, err = net.ListenUDP("udp", laddr)
 	if err != nil {
-		log.Fatalf("failed to listen on UDP port %d: %v", srtlaPort, err)
+		log.Fatalf("Failed to listen on UDP port %d: %v", srtlaPort, err)
 	}
 	_ = srtlaSock.SetReadBuffer(RecvBufSize)
 	_ = srtlaSock.SetWriteBuffer(SendBufSize)
 
-	log.Printf("listening on %s", srtlaSock.LocalAddr())
+	log.Printf("Listening on %s", srtlaSock.LocalAddr())
 
 	// Reader goroutine for SRT-LA socket
 	go func() {