gh-142585: Add PyMutex_STATIC_INIT macro

Author: vstinner

Include/cpython/pylock.h

@@ -13,7 +13,7 @@ extern "C" {
 // represent the unlocked state.
 //
 // Typical initialization:
-//   PyMutex m = (PyMutex){0};
+//   PyMutex m = PyMutex_STATIC_INIT;
 //
 // Or initialize as global variables:
 //   static PyMutex m;
@@ -34,6 +34,10 @@ typedef struct PyMutex {
     uint8_t _bits;  // (private)
 } PyMutex;
 
+// Static initialization for a PyMutex. Typical usage:
+//   PyMutex mutex = PyMutex_STATIC_INIT;
+#define PyMutex_STATIC_INIT (PyMutex){_Py_UNLOCKED}
+
 // exported function for locking the mutex
 PyAPI_FUNC(void) PyMutex_Lock(PyMutex *m);
 

Modules/_bz2module.c

@@ -348,7 +348,7 @@ _bz2_BZ2Compressor_impl(PyTypeObject *type, int compresslevel)
         return NULL;
     }
 
-    self->mutex = (PyMutex){0};
+    self->mutex = PyMutex_STATIC_INIT;
     self->bzs.opaque = NULL;
     self->bzs.bzalloc = BZ2_Malloc;
     self->bzs.bzfree = BZ2_Free;
@@ -633,7 +633,7 @@ _bz2_BZ2Decompressor_impl(PyTypeObject *type)
         return NULL;
     }
 
-    self->mutex = (PyMutex){0};
+    self->mutex = PyMutex_STATIC_INIT;
     self->needs_input = 1;
     self->bzs_avail_in_real = 0;
     self->input_buffer = NULL;

Modules/_ctypes/stgdict.c

@@ -29,7 +29,7 @@ PyCStgInfo_clone(StgInfo *dst_info, StgInfo *src_info)
 
     memcpy(dst_info, src_info, sizeof(StgInfo));
 #ifdef Py_GIL_DISABLED
-    dst_info->mutex = (PyMutex){0};
+    dst_info->mutex = PyMutex_STATIC_INIT;
 #endif
     dst_info->dict_final = 0;
 

Modules/_lzmamodule.c

@@ -813,7 +813,7 @@ Compressor_new(PyTypeObject *type, PyObject *args, PyObject *kwargs)
     self->alloc.free = PyLzma_Free;
     self->lzs.allocator = &self->alloc;
 
-    self->mutex = (PyMutex){0};
+    self->mutex = PyMutex_STATIC_INIT;
 
     self->flushed = 0;
     switch (format) {
@@ -1230,7 +1230,7 @@ _lzma_LZMADecompressor_impl(PyTypeObject *type, int format,
     self->lzs.allocator = &self->alloc;
     self->lzs.next_in = NULL;
 
-    self->mutex = (PyMutex){0};
+    self->mutex = PyMutex_STATIC_INIT;
 
     self->check = LZMA_CHECK_UNKNOWN;
     self->needs_input = 1;

Modules/_ssl.c

@@ -3503,7 +3503,7 @@ _ssl__SSLContext_impl(PyTypeObject *type, int proto_version)
     self->psk_client_callback = NULL;
     self->psk_server_callback = NULL;
 #endif
-    self->tstate_mutex = (PyMutex){0};
+    self->tstate_mutex = PyMutex_STATIC_INIT;
 
     /* Don't check host name by default */
     if (proto_version == PY_SSL_VERSION_TLS_CLIENT) {

Modules/_testinternalcapi/test_lock.c

@@ -32,7 +32,7 @@ pysleep(int ms)
 static PyObject *
 test_lock_basic(PyObject *self, PyObject *obj)
 {
-    PyMutex m = (PyMutex){0};
+    PyMutex m = PyMutex_STATIC_INIT;
 
     // uncontended lock and unlock
     PyMutex_Lock(&m);

Modules/_threadmodule.c

@@ -231,7 +231,7 @@ ThreadHandle_new(void)
     self->os_handle = 0;
     self->has_os_handle = 0;
     self->thread_is_exiting = (PyEvent){0};
-    self->mutex = (PyMutex){_Py_UNLOCKED};
+    self->mutex = PyMutex_STATIC_INIT;
     self->once = (_PyOnceFlag){0};
     self->state = THREAD_HANDLE_NOT_STARTED;
     self->refcount = 1;
@@ -320,7 +320,7 @@ _PyThread_AfterFork(struct _pythread_runtime_state *state)
         // it's safe to set this non-atomically.
         handle->state = THREAD_HANDLE_DONE;
         handle->once = (_PyOnceFlag){_Py_ONCE_INITIALIZED};
-        handle->mutex = (PyMutex){_Py_UNLOCKED};
+        handle->mutex = PyMutex_STATIC_INIT;
         _PyEvent_Notify(&handle->thread_is_exiting);
         llist_remove(node);
         remove_from_shutdown_handles(handle);
@@ -995,7 +995,7 @@ lock_new_impl(PyTypeObject *type)
     if (self == NULL) {
         return NULL;
     }
-    self->lock = (PyMutex){0};
+    self->lock = PyMutex_STATIC_INIT;
     return (PyObject *)self;
 }
 

Modules/_zstd/compressor.c

@@ -348,7 +348,7 @@ _zstd_ZstdCompressor_new_impl(PyTypeObject *type, PyObject *level,
 
     self->use_multithread = 0;
     self->dict = NULL;
-    self->lock = (PyMutex){0};
+    self->lock = PyMutex_STATIC_INIT;
 
     /* Compression context */
     self->cctx = ZSTD_createCCtx();

Modules/_zstd/decompressor.c

@@ -499,7 +499,7 @@ _zstd_ZstdDecompressor_new_impl(PyTypeObject *type, PyObject *zstd_dict,
     self->unused_data = NULL;
     self->eof = 0;
     self->dict = NULL;
-    self->lock = (PyMutex){0};
+    self->lock = PyMutex_STATIC_INIT;
 
     /* needs_input flag */
     self->needs_input = 1;

Modules/_zstd/zstddict.c

@@ -62,7 +62,7 @@ _zstd_ZstdDict_new_impl(PyTypeObject *type, Py_buffer *dict_content,
     self->d_dict = NULL;
     self->dict_buffer = NULL;
     self->dict_id = 0;
-    self->lock = (PyMutex){0};
+    self->lock = PyMutex_STATIC_INIT;
 
     /* ZSTD_CDict dict */
     self->c_dicts = PyDict_New();