Function broadcastProgressUpdate

src/webserver.go:144–194

Broadcast progress update to all connected WebSocket clients

(progress ProcessingProgress)

// Broadcast progress update to all connected WebSocket clients
func broadcastProgressUpdate(progress ProcessingProgress) {
	broadcastMutex.Lock()
	defer broadcastMutex.Unlock()

	connections := make([]*websocket.Conn, 0, len(wsConnections))
	wsMutex.RLock()
	for conn := range wsConnections {
		connections = append(connections, conn)
	}
	wsMutex.RUnlock()

	var deadConnections []*websocket.Conn

	for _, conn := range connections {
		progressMessage := map[string]interface{}{
			"cmd":      "progress",
			"progress": progress,
		}

		wsWriteMutex.Lock()
		if conn == nil {
			deadConnections = append(deadConnections, conn)
		} else {
			wsMutex.RLock()
			_, exists := wsConnections[conn]
			connMutex, mutexExists := connWriteMutexes[conn]
			wsMutex.RUnlock()

			if !exists || !mutexExists {
				continue
			}

			connMutex.Lock()
			conn.SetWriteDeadline(time.Now().Add(5 * time.Second))

			if err := conn.WriteJSON(progressMessage); err != nil {
				deadConnections = append(deadConnections, conn)
			}

			conn.SetWriteDeadline(time.Time{})
			connMutex.Unlock()
		}
		wsWriteMutex.Unlock()
	}

	for _, deadConn := range deadConnections {
		if deadConn != nil {
			removeWSConnection(deadConn)
		}
	}
}

// StartWebserver : Startet den Webserver
func StartWebserver() (err error) {