From cbc2d13e703cada16d3402fe2617ac1620f5264a Mon Sep 17 00:00:00 2001
From: Stephen Mardson McQuay <stephen@mardson.com>
Date: Thu, 3 Mar 2011 00:01:46 -0700
Subject: [PATCH] in progress

---
 bin/master.py |  5 +++++
 bin/slave.py  | 15 +++++++--------
 bin/submit.py | 20 ++++++++++++++++++++
 3 files changed, 32 insertions(+), 8 deletions(-)
 create mode 100644 bin/submit.py

diff --git a/bin/master.py b/bin/master.py
index 2d89fde..a21fcf1 100644
--- a/bin/master.py
+++ b/bin/master.py
@@ -14,3 +14,8 @@ 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()
diff --git a/bin/slave.py b/bin/slave.py
index c178c24..dba1947 100644
--- a/bin/slave.py
+++ b/bin/slave.py
@@ -6,6 +6,7 @@ from   multiprocessing.managers import BaseManager
 
 import interp.bootstrap
 from   interp.grid.gmsh import gmsh_grid3D
+from   interp.tools import exact
 
 class QueueManager(BaseManager): pass
 QueueManager.register('get_inqueue' )
@@ -13,20 +14,18 @@ QueueManager.register('get_outqueue')
 
 
 if __name__ == '__main__':
-  if len(sys.argv) != 2:
-    print >> sys.stderr, "usage: %s <gmsh file>" % sys.argv[0]
+  if len(sys.argv) != 3:
+    print >> sys.stderr, "usage: %s <gmsh file> <id>" % sys.argv[0]
     sys.exit(1)
-  m = QueueManager(address=('install', 50000), authkey='asdf')
+  m = QueueManager(address=('gannon', 50000), authkey='asdf')
   m.connect()
 
   inq  = m.get_inqueue()
   outq = m.get_outqueue()
 
   g = gmsh_grid3D(sys.argv[1])
+  my_name = sys.argv[2]
 
   while True:
-    id, X = inq.get()
-    print id, X
-
-  for i in xrange(10):
-    outq.put("hello from slave %d" % i)
+    i, X = inq.get()
+    outq.put((i, my_name, exact(X)))
diff --git a/bin/submit.py b/bin/submit.py
new file mode 100644
index 0000000..92bdb6f
--- /dev/null
+++ b/bin/submit.py
@@ -0,0 +1,20 @@
+#!/usr/bin/env python
+
+from multiprocessing.managers import BaseManager
+
+import numpy as np
+
+import interp.bootstrap
+
+class QueueManager(BaseManager): pass
+QueueManager.register('get_inqueue' )
+
+m = QueueManager(address=('gannon', 50000), authkey='asdf')
+m.connect()
+
+if __name__ == '__main__':
+  inq = m.get_inqueue()
+
+  for i in xrange(1000):
+    X = np.random.random((1,3))[0]
+    inq.put((i,X))