gh-116738: Keep the macros

Author: yoney

Modules/_bz2module.c

@@ -96,6 +96,9 @@ OutputBuffer_OnError(_BlocksOutputBuffer *buffer)
 #define BZ2_bzDecompressEnd bzDecompressEnd
 #endif  /* ! BZ_CONFIG_ERROR */
 
+#define ACQUIRE_LOCK(obj) PyMutex_Lock(&(obj)->mutex)
+#define RELEASE_LOCK(obj) PyMutex_Unlock(&(obj)->mutex)
+
 
 typedef struct {
     PyObject_HEAD
@@ -262,12 +265,12 @@ _bz2_BZ2Compressor_compress_impl(BZ2Compressor *self, Py_buffer *data)
 {
     PyObject *result = NULL;
 
-    PyMutex_Lock(&self->mutex);
+    ACQUIRE_LOCK(self);
     if (self->flushed)
         PyErr_SetString(PyExc_ValueError, "Compressor has been flushed");
     else
         result = compress(self, data->buf, data->len, BZ_RUN);
-    PyMutex_Unlock(&self->mutex);
+    RELEASE_LOCK(self);
     return result;
 }
 
@@ -287,14 +290,14 @@ _bz2_BZ2Compressor_flush_impl(BZ2Compressor *self)
 {
     PyObject *result = NULL;
 
-    PyMutex_Lock(&self->mutex);
+    ACQUIRE_LOCK(self);
     if (self->flushed)
         PyErr_SetString(PyExc_ValueError, "Repeated call to flush()");
     else {
         self->flushed = 1;
         result = compress(self, NULL, 0, BZ_FINISH);
     }
-    PyMutex_Unlock(&self->mutex);
+    RELEASE_LOCK(self);
     return result;
 }
 
@@ -601,12 +604,12 @@ _bz2_BZ2Decompressor_decompress_impl(BZ2Decompressor *self, Py_buffer *data,
 {
     PyObject *result = NULL;
 
-    PyMutex_Lock(&self->mutex);
+    ACQUIRE_LOCK(self);
     if (self->eof)
         PyErr_SetString(PyExc_EOFError, "End of stream already reached");
     else
         result = decompress(self, data->buf, data->len, max_length);
-    PyMutex_Unlock(&self->mutex);
+    RELEASE_LOCK(self);
     return result;
 }