Merge pull request #223 from openvstorage/0.1.x_gevent_threading

ArakoonClientPool does not work well in a threaded context and requires monkeypatching

src/db/arakoon/pyrakoon/client/client_pooled.py

@@ -26,6 +26,13 @@ class PyrakoonClientPooled(PyrakoonBase):
     """
     Pooled arakoon client wrapper
     Exposes the same API as the base PyrakoonClient while using a pool underneath
+
+    NOTE: this client won't work in a thread except the main thread when not monkey patching gevent
+    Monkey patching can be done using
+    from gevent import monkey
+    monkey.patch_all()
+
+    This has to be called at the start of the application.
     """
 
     _logger = Logger('extensions')

src/storage/persistent/pyrakoonstore.py

@@ -22,7 +22,7 @@
 from ConfigParser import RawConfigParser
 from functools import wraps
 from StringIO import StringIO
-from ovs_extensions.db.arakoon.pyrakoon.client import PyrakoonClient, PyrakoonClientPooled
+from ovs_extensions.db.arakoon.pyrakoon.client import PyrakoonClient
 from ovs_extensions.db.arakoon.pyrakoon.pyrakoon.compat import ArakoonAssertionFailed, ArakoonNotFound
 from ovs_extensions.storage.exceptions import AssertException, KeyNotFoundException
 
@@ -66,7 +66,7 @@ def __init__(self, cluster, configuration):
         for node in parser.get('global', 'cluster').split(','):
             node = node.strip()
             nodes[node] = ([parser.get(node, 'ip')], parser.get(node, 'client_port'))
-        self._client = PyrakoonClientPooled(cluster, nodes)
+        self._client = PyrakoonClient(cluster, nodes)
 
     @convert_exception()
     def get(self, key):