Refactoring WIP

.travis.yml

@@ -11,4 +11,4 @@ install:
   - python setup.py build_ext --inplace
 
 script:
-  - nosetests -v
+  - nosetests -v zarr

setup.py

@@ -44,8 +44,8 @@
 
 # define extension module
 ext_modules = cythonize([
-    Extension('zarr.ext',
-              sources=['zarr/ext.pyx'] + blosc_sources,
+    Extension('zarr.blosc',
+              sources=['zarr/blosc.pyx'] + blosc_sources,
               include_dirs=include_dirs,
               define_macros=define_macros,
               extra_compile_args=extra_compile_args,

tox.ini

@@ -11,7 +11,7 @@ setenv =
     PYTHONHASHSEED = 42
 commands =
     python setup.py build_ext --inplace
-    nosetests -v
+    nosetests -v zarr
     py34: python -m doctest -o NORMALIZE_WHITESPACE README.rst PERSISTENCE.rst
 deps =
     nose

zarr/__init__.py

@@ -1,21 +1,20 @@
 # -*- coding: utf-8 -*-
 from __future__ import absolute_import, print_function, division
-
-
-import atexit
 import multiprocessing
+import atexit
 
 
-from zarr.create import empty, zeros, ones, full, array, open, empty_like, \
+from zarr.array import Array, SynchronizedArray, set_blosc_options
+from zarr.store.memory import MemoryStore
+from zarr.store.directory import DirectoryStore
+from zarr.sync import ThreadSynchronizer, ProcessSynchronizer
+from zarr.create import array, empty, zeros, ones, full, open, empty_like, \
     zeros_like, ones_like, full_like, open_like
-from zarr.ext import blosc_version, init as _init, destroy as _destroy, \
-    set_blosc_options
-from zarr import defaults
-from zarr import constants
-from zarr.version import version as __version__
+from zarr import blosc
 
 
 ncores = multiprocessing.cpu_count()
-_init()
-set_blosc_options(use_context=False, nthreads=ncores)
-atexit.register(_destroy)
+blosc.init()
+# diminishing returns beyond 4 threads?
+set_blosc_options(use_context=False, nthreads=min(4, ncores))
+atexit.register(blosc.destroy)