Uh oh!
There was an error while loading.Please reload this page.
- Notifications
You must be signed in to change notification settings - Fork33.7k
gh-132983: Introduce_zstd bindings module#133027
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to ourterms of service andprivacy statement. We’ll occasionally send you account related emails.
Already on GitHub?Sign in to your account
Merged
Uh oh!
There was an error while loading.Please reload this page.
Merged
Changes from1 commit
Commits
Show all changes
59 commits Select commitHold shift + click to select a range
9814e3b Add _zstd module
emmatypingfda87c8 Add _zstd to modules
emmatyping887e564 Fix path for compression.zstd module
emmatypingcdba656 Ignore _zstd module like _io
emmatyping6b67e9b Expand module state macros to improve code quality
emmatypinga99a5d2 Remove backticks suggested in review
emmatyping02cd17a Use critical sections to lock object state
emmatyping54eca74 Remove compress/decompress and mark module as not reliant on the GIL
emmatypingf605956 Lift critical section to avoid clang warning
emmatyping2eadc65 Respond to comments by picnixz
emmatyping8eac354 Call out pyzstd explicitly in license description
emmatyping26775be Use a much more robust implementation...
emmatypingeae460f Use PyList_GetItemRef for thread safety purposes
emmatyping2ab5e4a Use a macro for the minimum supported version
emmatypingd5bf1c1 remove const from primivite types
emmatyping9e92b9f Use PyMem_New in another spot
emmatyping47f815a Simplify error handling in _get_frame_size
emmatyping6a4f7b8 Another simplification of error handling in get_frame_info
emmatypingd7b3805 Rename _module_state to mod_state
emmatypingc225ea6 Rewrite comment explaining the context of the code
emmatyping6e8c61c Add link to pyzstd
emmatypinge52ad06 Add TODO about refactoring dict training code
emmatyping2a1ad8b Use PyModule_AddObjectRef over PyModule_AddObject
emmatyping94473b9 Check result of OutputBufferGrow
emmatypinge2b2515 Simplify return logic in `add_constant_to_type`
emmatypingcd2f085 Ignore return value of _zstd_clear()
emmatyping79e174f Remove redundant comments
emmatypingce6f79c Remove __reduce__ from ZstdDict
emmatypinge15dd85 Use PyUnicode_FromFormat instead of a buffer
emmatyping685a3d1 Don't use C constants/types in error messages
emmatyping1b9f786 Make error messages easier to understand for Python users
emmatyping40c653c Lower minimum required version 1.4.0
emmatyping428677d Use casts and make slot function signatures correct
emmatyping0962bbb Be consistent with CPython on const usage
emmatyping85efc18 Make else clauses in line with PEP 7
emmatypingcadf6e4 Fix over-indented blocks in argument clinic
emmatypinge45c22a Merge branch 'main' into 3.14-zstd-c-code
emmatypingb9415be Merge branch 'main' into 3.14-zstd-c-code
emmatyping6760545 Add critical section around ZSTD_DCtx_setParameter
emmatypingc082d8a Add a TODO about refactoring critical sections
emmatypinge825285 Use Py_UNREACHABLE
emmatypingf02ff5a Move bytes operations out of Py_BEGIN_ALLOW_THREADS
emmatyping0d69c8c Add TODO about ensuring a lock is held
emmatyping58b0008 Remove asserts that may not be correct
emmatypingc786c3c Add TODO to make ZstdDict and others GC objects
emmatypinga9d57fc Make objects GC tracked
emmatypingcc9ab2a Remove unused include
emmatyping1f65d19 Fix some memory issues
emmatyping552da2d Fix refleaks on module and in ZstdDict
emmatypingc0648d8 Update configure to check for ZDICT_finalizeDictionary
emmatypingd149b2c Merge branch 'main' into 3.14-zstd-c-code
emmatypinga5ea379 Properly check version in configure
emmatyping0d88d6d exit(1) if check fails
emmatyping4a0a33e Use AC_RUN_IFELSE
emmatyping30b3934 Use a define() to re-use version check
emmatyping90b9172 Merge branch 'main' into 3.14-zstd-c-code
emmatyping8fdc7f7 Actually properly set _zstd module status based on version
emmatyping10e2e80 Merge branch 'main' into 3.14-zstd-c-code
emmatypingd90b29d Merge branch 'main' into 3.14-zstd-c-code
emmatypingFile filter
Filter by extension
Conversations
Failed to load comments.
Loading
Uh oh!
There was an error while loading.Please reload this page.
Jump to
Jump to file
Failed to load files.
Loading
Uh oh!
There was an error while loading.Please reload this page.
Diff view
Diff view
Make else clauses in line with PEP 7
- Loading branch information
Uh oh!
There was an error while loading.Please reload this page.
commit85efc182e079c167cf183c71fedea1c210c463c9
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -94,7 +94,8 @@ _PyZstd_set_c_parameters(ZstdCompressor *self, PyObject *level_or_options, | ||
| if (key_v == ZSTD_c_compressionLevel) { | ||
| /* Save for generating ZSTD_CDICT */ | ||
| self->compression_level = value_v; | ||
| } | ||
| else if (key_v == ZSTD_c_nbWorkers) { | ||
| /* From zstd library doc: | ||
| 1. When nbWorkers >= 1, triggers asynchronous mode when | ||
| used with ZSTD_compressStream2(). | ||
| @@ -177,7 +178,8 @@ _get_CDict(ZstdDict *self, int compressionLevel) | ||
| goto error; | ||
| } | ||
| Py_DECREF(capsule); | ||
| } | ||
| else { | ||
| /* ZSTD_CDict instance already exists */ | ||
| cdict = PyCapsule_GetPointer(capsule, NULL); | ||
| } | ||
| @@ -206,7 +208,8 @@ _PyZstd_load_c_dict(ZstdCompressor *self, PyObject *dict) { | ||
| ret = PyObject_IsInstance(dict, (PyObject*)mod_state->ZstdDict_type); | ||
| if (ret < 0) { | ||
| return -1; | ||
| } | ||
| else if (ret > 0) { | ||
| /* When compressing, use undigested dictionary by default. */ | ||
| zd = (ZstdDict*)dict; | ||
| type = DICT_TYPE_UNDIGESTED; | ||
| @@ -220,7 +223,8 @@ _PyZstd_load_c_dict(ZstdCompressor *self, PyObject *dict) { | ||
| (PyObject*)mod_state->ZstdDict_type); | ||
| if (ret < 0) { | ||
| return -1; | ||
| } | ||
| else if (ret > 0) { | ||
| /* type == -1 may indicate an error. */ | ||
| type = PyLong_AsInt(PyTuple_GET_ITEM(dict, 1)); | ||
| if (type == DICT_TYPE_DIGESTED || | ||
| @@ -251,7 +255,8 @@ _PyZstd_load_c_dict(ZstdCompressor *self, PyObject *dict) { | ||
| Py_BEGIN_CRITICAL_SECTION(self); | ||
| zstd_ret = ZSTD_CCtx_refCDict(self->cctx, c_dict); | ||
| Py_END_CRITICAL_SECTION(); | ||
| } | ||
| else if (type == DICT_TYPE_UNDIGESTED) { | ||
| /* Load a dictionary. | ||
| It doesn't override compression context's parameters. */ | ||
| Py_BEGIN_CRITICAL_SECTION2(self, zd); | ||
| @@ -260,15 +265,17 @@ _PyZstd_load_c_dict(ZstdCompressor *self, PyObject *dict) { | ||
| PyBytes_AS_STRING(zd->dict_content), | ||
| Py_SIZE(zd->dict_content)); | ||
emmatyping marked this conversation as resolved. Show resolvedHide resolvedUh oh!There was an error while loading.Please reload this page. | ||
| Py_END_CRITICAL_SECTION2(); | ||
| } | ||
| else if (type == DICT_TYPE_PREFIX) { | ||
| /* Load a prefix */ | ||
| Py_BEGIN_CRITICAL_SECTION2(self, zd); | ||
| zstd_ret = ZSTD_CCtx_refPrefix( | ||
| self->cctx, | ||
| PyBytes_AS_STRING(zd->dict_content), | ||
| Py_SIZE(zd->dict_content)); | ||
| Py_END_CRITICAL_SECTION2(); | ||
| } | ||
| else { | ||
| /* Impossible code path */ | ||
| PyErr_SetString(PyExc_SystemError, | ||
emmatyping marked this conversation as resolved. OutdatedShow resolvedHide resolvedUh oh!There was an error while loading.Please reload this page. | ||
| "load_c_dict() impossible code path"); | ||
| @@ -412,7 +419,8 @@ compress_impl(ZstdCompressor *self, Py_buffer *data, | ||
| in.src = data->buf; | ||
| in.size = data->len; | ||
| in.pos = 0; | ||
| } | ||
| else { | ||
| in.src = ∈ | ||
| in.size = 0; | ||
| in.pos = 0; | ||
| @@ -511,7 +519,8 @@ compress_mt_continue_impl(ZstdCompressor *self, Py_buffer *data) | ||
| if (_OutputBuffer_Grow(&buffer, &out) < 0) { | ||
| goto error; | ||
| } | ||
| } | ||
| else if (in.pos == in.size) { | ||
| /* Finished */ | ||
| assert(mt_continue_should_break(&in, &out)); | ||
| break; | ||
| @@ -569,13 +578,15 @@ _zstd_ZstdCompressor_compress_impl(ZstdCompressor *self, Py_buffer *data, | ||
| /* Compress */ | ||
| if (self->use_multithread && mode == ZSTD_e_continue) { | ||
| ret = compress_mt_continue_impl(self, data); | ||
| } | ||
| else { | ||
| ret = compress_impl(self, data, mode); | ||
| } | ||
| if (ret) { | ||
| self->last_mode = mode; | ||
| } | ||
| else { | ||
| self->last_mode = ZSTD_e_end; | ||
| /* Resetting cctx's session never fail */ | ||
| @@ -621,7 +632,8 @@ _zstd_ZstdCompressor_flush_impl(ZstdCompressor *self, int mode) | ||
| if (ret) { | ||
| self->last_mode = mode; | ||
| } | ||
| else { | ||
| self->last_mode = ZSTD_e_end; | ||
| /* Resetting cctx's session never fail */ | ||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.Learn more about bidirectional Unicode characters
Oops, something went wrong.
Uh oh!
There was an error while loading.Please reload this page.
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.