sm/smbinterp
1
0
Fork 0
Code Issues Pull Requests Activity

working slave/master setup

Browse Source
This commit is contained in:
Stephen Mardson McQuay 2011-03-03 00:20:03 -07:00
parent eefcc682cc
commit f125a653b1
2 changed files with 5 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
bin/master.py
View File

@ -1,21 +0,0 @@
#!/usr/bin/env python
import interp.bootstrap
from multiprocessing.managers import BaseManager
from interp.grid.gmsh import gmsh_grid3D
class QueueManager(BaseManager): pass
QueueManager.register('get_inqueue' )
QueueManager.register('get_outqueue')
m = QueueManager(address=('install', 50000), authkey='asdf')
m.connect()
inq = m.get_inqueue()
outq = m.get_outqueue()
while True:
for i in xrange(1000):
X = np.random.random((1,3))[0]
utq.get()

5
bin/slave.py
View File

@ -4,6 +4,8 @@ import sys
from multiprocessing.managers import BaseManager
import numpy as np
import interp.bootstrap
from interp.grid.gmsh import gmsh_grid3D
from interp.tools import exact
@ -24,8 +26,11 @@ if __name__ == '__main__':
outq = m.get_outqueue()
g = gmsh_grid3D(sys.argv[1])
g.q = np.array([exact(x) for x in g.verts])
my_name = sys.argv[2]
while True:
i, X = inq.get()
a = g.run_baker(X, order = 3, extra_points = 32)
outq.put((i, my_name, exact(X)))