OpenDroneMap-ODM/opendm/progress.py

40 wiersze
1.2 KiB
Python
Czysty Zwykły widok Historia

import socket
import os
from opendm import log
PROGRESS_BROADCAST_PORT = 6367 #ODMR
try:
sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
except:
log.ODM_WARNING("Cannot create UDP socket, progress reporting will be disabled.")
sock = None
class Broadcaster:
def __init__(self, port):
self.port = port
self.project_name = "<unnamed>"
self.pid = os.getpid()
def set_project_name(self, project_name):
self.project_name = project_name
def send_update(self, global_progress):
"""
Update any listener on the pipeline progress (in percentage terms)
"""
if not sock:
return
UDP_IP = "127.0.0.1"
if global_progress > 100:
log.ODM_WARNING("Global progress is > 100 (%s), please contact the developers." % global_progress)
global_progress = 100
try:
sock.sendto("PGUP/{}/{}/{}".format(self.pid, self.project_name, float(global_progress)).encode('utf8'),
(UDP_IP, self.port))
except Exception as e:
log.ODM_WARNING("Failed to broadcast progress update on UDP port %s (%s)" % (str(self.port), str(e)))
progressbc = Broadcaster(PROGRESS_BROADCAST_PORT)