kopia lustrzana https://github.com/OpenDroneMap/ODM
40 wiersze
1.2 KiB
Python
40 wiersze
1.2 KiB
Python
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) |