[Bf-extensions-cvs] SVN commit: /data/svn/bf-extensions [2604] trunk/py/scripts/addons/ netrender: NetRender OS X bugfix
Martin Poirier
theeth at yahoo.com
Sat Nov 12 17:57:05 CET 2011
Revision: 2604
http://projects.blender.org/scm/viewvc.php?view=rev&root=bf-extensions&revision=2604
Author: theeth
Date: 2011-11-12 16:57:05 +0000 (Sat, 12 Nov 2011)
Log Message:
-----------
NetRender OS X bugfix
Fix for #26867
Hunted down and debugged with great help from Geoff Murphy
Modified Paths:
--------------
trunk/py/scripts/addons/netrender/client.py
trunk/py/scripts/addons/netrender/operators.py
trunk/py/scripts/addons/netrender/slave.py
trunk/py/scripts/addons/netrender/utils.py
Modified: trunk/py/scripts/addons/netrender/client.py
===================================================================
--- trunk/py/scripts/addons/netrender/client.py 2011-11-12 11:15:44 UTC (rev 2603)
+++ trunk/py/scripts/addons/netrender/client.py 2011-11-12 16:57:05 UTC (rev 2604)
@@ -157,7 +157,8 @@
job.version_info.revision = netsettings.vcs_revision
# try to send path first
- conn.request("POST", "/job", json.dumps(job.serialize()))
+ with ConnectionContext():
+ conn.request("POST", "/job", json.dumps(job.serialize()))
response = conn.getresponse()
response.read()
@@ -240,7 +241,8 @@
fillCommonJobSettings(job, job_name, netsettings)
# try to send path first
- conn.request("POST", "/job", json.dumps(job.serialize()))
+ with ConnectionContext():
+ conn.request("POST", "/job", json.dumps(job.serialize()))
response = conn.getresponse()
response.read()
@@ -250,7 +252,8 @@
if response.status == http.client.ACCEPTED:
for rfile in job.files:
f = open(rfile.filepath, "rb")
- conn.request("PUT", fileURL(job_id, rfile.index), f)
+ with ConnectionContext():
+ conn.request("PUT", fileURL(job_id, rfile.index), f)
f.close()
response = conn.getresponse()
response.read()
@@ -260,7 +263,8 @@
return job_id
def requestResult(conn, job_id, frame):
- conn.request("GET", renderURL(job_id, frame))
+ with ConnectionContext():
+ conn.request("GET", renderURL(job_id, frame))
class NetworkRenderEngine(bpy.types.RenderEngine):
bl_idname = 'NET_RENDER'
@@ -333,7 +337,8 @@
# cancel new jobs (animate on network) on break
if self.test_break() and new_job:
- conn.request("POST", cancelURL(job_id))
+ with ConnectionContext():
+ conn.request("POST", cancelURL(job_id))
response = conn.getresponse()
response.read()
print( response.status, response.reason )
Modified: trunk/py/scripts/addons/netrender/operators.py
===================================================================
--- trunk/py/scripts/addons/netrender/operators.py 2011-11-12 11:15:44 UTC (rev 2603)
+++ trunk/py/scripts/addons/netrender/operators.py 2011-11-12 16:57:05 UTC (rev 2604)
@@ -201,8 +201,8 @@
conn = clientConnection(netsettings.server_address, netsettings.server_port, self.report)
if conn:
- conn.request("GET", "/status")
-
+ with ConnectionContext():
+ conn.request("GET", "/status")
response = conn.getresponse()
content = response.read()
print( response.status, response.reason )
@@ -229,7 +229,7 @@
return self.execute(context)
class RENDER_OT_netclientblacklistslave(bpy.types.Operator):
- '''Exclude from rendering, by adding slave to the blacklist.'''
+ '''Exclude from rendering, by adding slave to the blacklist'''
bl_idname = "render.netclientblacklistslave"
bl_label = "Client Blacklist Slave"
@@ -259,7 +259,7 @@
return self.execute(context)
class RENDER_OT_netclientwhitelistslave(bpy.types.Operator):
- '''Remove slave from the blacklist.'''
+ '''Remove slave from the blacklist'''
bl_idname = "render.netclientwhitelistslave"
bl_label = "Client Whitelist Slave"
@@ -303,8 +303,8 @@
conn = clientConnection(netsettings.server_address, netsettings.server_port, self.report)
if conn:
- conn.request("GET", "/slaves")
-
+ with ConnectionContext():
+ conn.request("GET", "/slaves")
response = conn.getresponse()
content = response.read()
print( response.status, response.reason )
@@ -341,7 +341,7 @@
return self.execute(context)
class RENDER_OT_netclientcancel(bpy.types.Operator):
- '''Cancel the selected network rendering job.'''
+ '''Cancel the selected network rendering job'''
bl_idname = "render.netclientcancel"
bl_label = "Client Cancel"
@@ -357,8 +357,8 @@
if conn:
job = netrender.jobs[netsettings.active_job_index]
- conn.request("POST", cancelURL(job.id), json.dumps({'clear':False}))
-
+ with ConnectionContext():
+ conn.request("POST", cancelURL(job.id), json.dumps({'clear':False}))
response = conn.getresponse()
response.read()
print( response.status, response.reason )
@@ -371,7 +371,7 @@
return self.execute(context)
class RENDER_OT_netclientcancelall(bpy.types.Operator):
- '''Cancel all running network rendering jobs.'''
+ '''Cancel all running network rendering jobs'''
bl_idname = "render.netclientcancelall"
bl_label = "Client Cancel All"
@@ -384,8 +384,8 @@
conn = clientConnection(netsettings.server_address, netsettings.server_port, self.report)
if conn:
- conn.request("POST", "/clear", json.dumps({'clear':False}))
-
+ with ConnectionContext():
+ conn.request("POST", "/clear", json.dumps({'clear':False}))
response = conn.getresponse()
response.read()
print( response.status, response.reason )
@@ -416,10 +416,10 @@
if conn:
job_id = netrender.jobs[netsettings.active_job_index].id
- conn.request("GET", "/status", headers={"job-id":job_id})
-
+ with ConnectionContext():
+ conn.request("GET", "/status", headers={"job-id":job_id})
response = conn.getresponse()
-
+
if response.status != http.client.OK:
self.report({'ERROR'}, "Job ID %i not defined on master" % job_id)
return {'ERROR'}
@@ -486,7 +486,7 @@
return self.execute(context)
class netclientscan(bpy.types.Operator):
- '''Listen on network for master server broadcasting its address and port.'''
+ '''Listen on network for master server broadcasting its address and port'''
bl_idname = "render.netclientscan"
bl_label = "Client Scan"
Modified: trunk/py/scripts/addons/netrender/slave.py
===================================================================
--- trunk/py/scripts/addons/netrender/slave.py 2011-11-12 11:15:44 UTC (rev 2603)
+++ trunk/py/scripts/addons/netrender/slave.py 2011-11-12 16:57:05 UTC (rev 2604)
@@ -67,7 +67,8 @@
return slave
def testCancel(conn, job_id, frame_number):
- conn.request("HEAD", "/status", headers={"job-id":job_id, "job-frame": str(frame_number)})
+ with ConnectionContext():
+ conn.request("HEAD", "/status", headers={"job-id":job_id, "job-frame": str(frame_number)})
# canceled if job isn't found anymore
if responseStatus(conn) == http.client.NO_CONTENT:
@@ -93,7 +94,8 @@
# Force prefix path if not found
job_full_path = prefixPath(JOB_PREFIX, rfile.filepath, main_path, force = True)
temp_path = os.path.join(JOB_PREFIX, "slave.temp")
- conn.request("GET", fileURL(job_id, rfile.index), headers={"slave-id":slave_id})
+ with ConnectionContext():
+ conn.request("GET", fileURL(job_id, rfile.index), headers={"slave-id":slave_id})
response = conn.getresponse()
if response.status != http.client.OK:
@@ -155,7 +157,8 @@
print("Retry %i failed, waiting %is before retrying" % (i + 1, bisleep.current))
if conn:
- conn.request("POST", "/slave", json.dumps(slave_Info().serialize()))
+ with ConnectionContext():
+ conn.request("POST", "/slave", json.dumps(slave_Info().serialize()))
response = conn.getresponse()
response.read()
@@ -168,7 +171,8 @@
engine.update_stats("", "Network render connected to master, waiting for jobs")
while not engine.test_break():
- conn.request("GET", "/job", headers={"slave-id":slave_id})
+ with ConnectionContext():
+ conn.request("GET", "/job", headers={"slave-id":slave_id})
response = conn.getresponse()
if response.status == http.client.OK:
@@ -218,7 +222,8 @@
# announce log to master
logfile = netrender.model.LogFile(job.id, slave_id, [frame.number for frame in job.frames])
- conn.request("POST", "/log", bytes(json.dumps(logfile.serialize()), encoding='utf8'))
+ with ConnectionContext():
+ conn.request("POST", "/log", bytes(json.dumps(logfile.serialize()), encoding='utf8'))
response = conn.getresponse()
response.read()
@@ -258,7 +263,8 @@
# update logs if needed
if stdout:
# (only need to update on one frame, they are linked
- conn.request("PUT", logURL(job.id, first_frame), stdout, headers=headers)
+ with ConnectionContext():
+ conn.request("PUT", logURL(job.id, first_frame), stdout, headers=headers)
responseStatus(conn)
# Also output on console
@@ -293,7 +299,9 @@
print(str(stdout, encoding='utf8'), end="")
# (only need to update on one frame, they are linked
- conn.request("PUT", logURL(job.id, first_frame), stdout, headers=headers)
+ with ConnectionContext():
+ conn.request("PUT", logURL(job.id, first_frame), stdout, headers=headers)
+
if responseStatus(conn) == http.client.NO_CONTENT:
continue
@@ -323,18 +331,21 @@
if thumbname:
f = open(thumbname, 'rb')
- conn.request("PUT", "/thumb", f, headers=headers)
+ with ConnectionContext():
+ conn.request("PUT", "/thumb", f, headers=headers)
f.close()
responseStatus(conn)
@@ Diff output truncated at 10240 characters. @@
More information about the Bf-extensions-cvs
mailing list