Skip to content

Commit db03718

Browse files
committed
Fix calling deprecated functions
1 parent 14c85bb commit db03718

File tree

3 files changed

+9
-9
lines changed

3 files changed

+9
-9
lines changed

numcodecs/__init__.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@
4949
ncores = multiprocessing.cpu_count()
5050
except OSError: # pragma: no cover
5151
ncores = 1
52-
blosc.init()
52+
blosc._init()
5353
blosc.set_nthreads(min(8, ncores))
5454
atexit.register(blosc.destroy)
5555

numcodecs/blosc.pyx

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -273,7 +273,7 @@ def compress(source, char* cname, int clevel, int shuffle=SHUFFLE,
273273
# check valid cname early
274274
cname_str = cname.decode('ascii')
275275
if cname_str not in list_compressors():
276-
err_bad_cname(cname_str)
276+
_err_bad_cname(cname_str)
277277

278278
# setup source buffer
279279
source_buffer = Buffer(source, PyBUF_ANY_CONTIGUOUS)
@@ -311,7 +311,7 @@ def compress(source, char* cname, int clevel, int shuffle=SHUFFLE,
311311
if compressor_set < 0:
312312
# shouldn't happen if we checked against list of compressors
313313
# already, but just in case
314-
err_bad_cname(cname_str)
314+
_err_bad_cname(cname_str)
315315

316316
# set blocksize
317317
blosc_set_blocksize(blocksize)
@@ -587,7 +587,7 @@ class Blosc(Codec):
587587
def decode_partial(self, buf, int start, int nitems, out=None):
588588
'''**Experimental**'''
589589
buf = ensure_contiguous_ndarray(buf, self.max_buffer_size)
590-
return decompress_partial(buf, start, nitems, dest=out)
590+
return _decompress_partial(buf, start, nitems, dest=out)
591591

592592
def __repr__(self):
593593
r = '%s(cname=%r, clevel=%r, shuffle=%s, blocksize=%s)' % \

numcodecs/tests/test_blosc.py

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -124,12 +124,12 @@ def test_compress_blocksize_default(use_threads):
124124

125125
# default blocksize
126126
enc = blosc.compress(arr, b'lz4', 1, Blosc.NOSHUFFLE)
127-
_, _, blocksize = blosc.cbuffer_sizes(enc)
127+
_, _, blocksize = blosc._cbuffer_sizes(enc)
128128
assert blocksize > 0
129129

130130
# explicit default blocksize
131131
enc = blosc.compress(arr, b'lz4', 1, Blosc.NOSHUFFLE, 0)
132-
_, _, blocksize = blosc.cbuffer_sizes(enc)
132+
_, _, blocksize = blosc._cbuffer_sizes(enc)
133133
assert blocksize > 0
134134

135135

@@ -140,7 +140,7 @@ def test_compress_blocksize(use_threads, bs):
140140
blosc.use_threads = use_threads
141141

142142
enc = blosc.compress(arr, b'lz4', 1, Blosc.NOSHUFFLE, bs)
143-
_, _, blocksize = blosc.cbuffer_sizes(enc)
143+
_, _, blocksize = blosc._cbuffer_sizes(enc)
144144
assert blocksize == bs
145145

146146

@@ -174,7 +174,7 @@ def test_compress_metainfo(dtype, use_threads):
174174
blosc.use_threads = use_threads
175175
for cname in blosc.list_compressors():
176176
enc = blosc.compress(arr, cname.encode(), 1, shuffle)
177-
typesize, did_shuffle, _ = blosc.cbuffer_metainfo(enc)
177+
typesize, did_shuffle, _ = blosc._cbuffer_metainfo(enc)
178178
assert typesize == arr.dtype.itemsize
179179
assert did_shuffle == shuffle
180180

@@ -186,7 +186,7 @@ def test_compress_autoshuffle(use_threads):
186186
blosc.use_threads = use_threads
187187
for cname in blosc.list_compressors():
188188
enc = blosc.compress(varr, cname.encode(), 1, Blosc.AUTOSHUFFLE)
189-
typesize, did_shuffle, _ = blosc.cbuffer_metainfo(enc)
189+
typesize, did_shuffle, _ = blosc._cbuffer_metainfo(enc)
190190
assert typesize == varr.dtype.itemsize
191191
if typesize == 1:
192192
assert did_shuffle == Blosc.BITSHUFFLE

0 commit comments

Comments
 (0)