[Bf-extensions-cvs] SVN commit: /data/svn/bf-extensions [2167] trunk/py/scripts/addons/ netrender/master.py: [#27796] Netrendering "path:" failing
Martin Poirier
theeth at yahoo.com
Sun Jul 24 23:25:05 CEST 2011
Revision: 2167
http://projects.blender.org/scm/viewvc.php?view=rev&root=bf-extensions&revision=2167
Author: theeth
Date: 2011-07-24 21:25:05 +0000 (Sun, 24 Jul 2011)
Log Message:
-----------
[#27796] Netrendering "path:" failing
by Wintch Analyzer
moving master working path initialization before connection creation
also added error checks and prints to debug an invalid internal state (related to another tracker entry)
Modified Paths:
--------------
trunk/py/scripts/addons/netrender/master.py
Modified: trunk/py/scripts/addons/netrender/master.py
===================================================================
--- trunk/py/scripts/addons/netrender/master.py 2011-07-24 21:15:27 UTC (rev 2166)
+++ trunk/py/scripts/addons/netrender/master.py 2011-07-24 21:25:05 UTC (rev 2167)
@@ -61,7 +61,11 @@
self.last_seen = time.time()
def finishedFrame(self, frame_number):
- self.job_frames.remove(frame_number)
+ try:
+ self.job_frames.remove(frame_number)
+ except ValueError as e:
+ print("Internal error: Frame %i not in job frames list" % frame_number)
+ print(self.job_frames)
if not self.job_frames:
self.job = None
@@ -849,7 +853,6 @@
class RenderMasterServer(socketserver.ThreadingMixIn, http.server.HTTPServer):
def __init__(self, address, handler_class, path, subdir=True):
- super().__init__(address, handler_class)
self.jobs = []
self.jobs_map = {}
self.slaves = []
@@ -861,6 +864,9 @@
else:
self.path = path
+ if not os.path.exists(self.path):
+ os.mkdir(self.path)
+
self.slave_timeout = 5 # 5 mins: need a parameter for that
self.balancer = netrender.balancing.Balancer()
@@ -871,8 +877,7 @@
self.balancer.addPriority(netrender.balancing.NewJobPriority())
self.balancer.addPriority(netrender.balancing.MinimumTimeBetweenDispatchPriority(limit = 2))
- if not os.path.exists(self.path):
- os.mkdir(self.path)
+ super().__init__(address, handler_class)
def restore(self, jobs, slaves, balancer = None):
self.jobs = jobs
More information about the Bf-extensions-cvs
mailing list